You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
 
 
 

469 lines
12 KiB

#include "isdnlogin.h"
extern cfg_t cfg;
extern global_t global;
int get_capi_info (void)
{
int i;
int max_controller;
unsigned long controller_mask = 0;
capi_getprofile_t profile;
memset( &profile, 0, sizeof(profile));
#if WITH_RCAPI_LAYER
rcapi_get_profile( 0, &profile, &(cfg.capi_host));
#else
capi2_get_profile( 0, &profile );
#endif
max_controller = profile.ncontrl;
printf("Available CAPI controllers: %d\n", max_controller);
if (max_controller) {
for( i=1; i<33; i++) {
memset( &profile, 0, sizeof(profile));
#if WITH_RCAPI_LAYER
if (!rcapi_get_profile( i, &profile, &(cfg.capi_host))) {
#else
if (!capi2_get_profile( i, &profile)) {
#endif
controller_mask |= (1 << (i-1));
if (!--max_controller) break;
}
}
}
// XXX: doesnt seem to work!
if (!(((1 << cfg.controller)-1) & controller_mask)) {
fprintf( stderr, "No such Controller %d!\n", cfg.controller);
return 1;
}
memset( &profile, 0, sizeof(profile));
#if WITH_RACPI_LAYER
capi2_get_profile( cfg.controller, &profile, &(cfg.capi_host) );
#else
capi2_get_profile( cfg.controller, &profile );
#endif
#if DEBUG /* debug printf */
fprintf( stderr, "ncontrl = 0x%x\n", profile.ncontrl);
fprintf( stderr, "nchannel = 0x%x\n", profile.nchannel);
fprintf( stderr, "options = 0x%x\n", profile.options);
fprintf( stderr, "b1protocol = 0x%x\n", profile.b1protocol);
fprintf( stderr, "b2protocol = 0x%x\n", profile.b2protocol);
fprintf( stderr, "b3protocol = 0x%x\n", profile.b3protocol);
fprintf( stderr, "\n");
#endif
if ( !(profile.b1protocol & (SI_PHONE)) ||
!(profile.b2protocol & (SI_PHONE)) ||
!(profile.b3protocol & (SI_PHONE))) {
fprintf( stderr, "Controller %d: does not support telephony service\n",
cfg.controller);
return 1;
}
return 0;
}
/*******************************************************************
*
*******************************************************************/
int init_capi()
{
int fd;
for(;;) {
if(cfg.verbose > 2){
putchar('R');
}
#if WITH_RCAPI_LAYER
fd = capi2_register( REG_CAPI_MSG_SIZE,
REG_CAPI_LEVEL3CNT,
cfg.usWindowSize,
REG_CAPI_DATA_BLK_SIZE,
NULL,
&(cfg.capi_host),
&(cfg.capi_auth));
#else
fd = capi2_register( REG_CAPI_MSG_SIZE,
REG_CAPI_LEVEL3CNT,
cfg.usWindowSize,
REG_CAPI_DATA_BLK_SIZE,
NULL);
#endif
if(fd >0 ) break;
fprintf( stderr, "capi2_register failed! retry in %d seconds\n",
REGISTER_FAIL_TIMER );
sleep(REGISTER_FAIL_TIMER);
}
return fd;
}
int setListen( call_t *ptrCall, int mask )
{
int ret;
ret = capi2_listen_req( ptrCall->capi_fd,
ptrCall->ident, /* Controller */
0x000001ff, /* Info Mask */
mask, /* CIP Mask */
0, /* CIP Mask2 */
NULL, /* Calling party number */
NULL); /* Calling party subaddress */
return ret;
}
void check_capi (void)
{
if (global.alive_pending > MAX_KEEPALIVE_PENDING) {
global.endloop = E_KeepAliveFailed; /* indicate keepalive overflow */
return;
}
capi_control_req( global.calls->capi_fd, global.calls->ident,
CTRL_CAPISTATE , NULL);
global.alive_pending++;
}
/*******************************************************************
*
*******************************************************************/
int getCapiInfo( union CAPI_primitives *capi )
{
int info;
switch (GET_PRIMTYPE(capi)) {
case CAPI2_LISTEN_CONF:
info = GET_WORD(capi->c2listen_conf.info);
break;
case CAPI2_ALERT_CONF:
info = GET_WORD(capi->c2alert_conf.info);
break;
case CAPI2_CONNECT_CONF:
info = GET_WORD(capi->c2connect_conf.info);
break;
case CAPI2_INFO_CONF:
info = GET_WORD(capi->c2info_conf.info);
break;
case CAPI2_CONNECTB3_CONF:
info = GET_WORD(capi->c2connectb3_conf.info);
break;
case CAPI2_DATAB3_CONF:
info = GET_WORD(capi->c2datab3_conf.info);
break;
case CAPI2_RESETB3_CONF:
info = GET_WORD(capi->c2resetb3_conf.info);
break;
case CAPI2_DISCONNECTB3_CONF:
info = GET_WORD(capi->c2disconnectb3_conf.info);
break;
case CAPI2_DISCONNECT_CONF:
info = GET_WORD(capi->c2disconnect_conf.info);
break;
case CAPI2_FACILITY_CONF:
info = GET_WORD(capi->c2facility_conf.info);
break;
case CAPI2_SELECTB_CONF:
info = GET_WORD(capi->c2selectb_conf.info);
break;
case CAPI2_DISCONNECT_IND:
info = GET_WORD(capi->c2disconnect_ind.reason);
break;
case CAPI2_DISCONNECTB3_IND:
info = GET_WORD(capi->c2disconnectb3_ind.reason_b3);
break;
default:
info = 0;
break;
}
return (info);
}
void doConnect( call_t *ptrCall )
{
ptrCall->messid = capi2_connect_req( ptrCall->capi_fd,
ptrCall->ident & 0x7f,
ptrCall->service->cip,
&ptrCall->CalledPartyNumber,
&ptrCall->CallingPartyNumber,
&ptrCall->CalledPartySubaddress,
&ptrCall->CallingPartySubaddress,
&ptrCall->Bprotocol,
NULL, &ptrCall->llc, NULL,
&ptrCall->AdditionalInfo);
if(cfg.verbose>8) {
printf("messid from capi2_connect_req() == 0x%x\n", ptrCall->messid);
}
NEWSTATE( ptrCall, D_ConnectPending);
}
/*******************************************************************
*
*******************************************************************/
void doDisconnect( call_t *ptrCall )
{
unsigned long plci, ncci;
ncci = ptrCall->ident;
plci = ptrCall->ident & 0xffff;
switch (ptrCall->state) {
case B_ConnectPending:
case Connected:
if(cfg.wait4dataconf && ptrCall->NotAcknowledged) {
if(cfg.verbose>1) {
printf("doDisconnect() wait for %d CAPI2_DATAB3_CONF\n",
ptrCall->NotAcknowledged);
}
/* don't send a capi2_disconnectb3_req() we have to wait */
break;
}
if(ptrCall->NotAcknowledged && cfg.verbose>0) {
printf("doDisconnect() missing %d CAPI2_DATAB3_CONF\n",
ptrCall->NotAcknowledged);
}
capi2_disconnectb3_req( ptrCall->capi_fd,
ncci,
NULL);
break;
case D_ConnectPending:
case B_DisconnectPending:
NEWSTATE( ptrCall, D_DisconnectPending);
capi2_disconnect_req( ptrCall->capi_fd,
plci,
NULL);
break;
case D_DisconnectPending:
case Disconnected:
default:
break;
}
}
#if WITH_UNFINISHED_XMODEM
int SendXmodemData( call_t *ptrCall )
{
char buffer[1024];
size_t len;
xmodem_t *xm = ptrCall->xmodem;
len = fread( buffer, 1, sizeof(buffer), xm->sendfp);
if (len <= 0) {
/* XXX: check for errors */
fclose(xm->sendfp);
}
printf("\nSend XMODEM sector: %d errors: %d ", xm->sentsectcnt, xm->errors);
if (!xmodem_putpkt(xm, buffer, len, ptrCall->error_msg)) {
xmodem_close(xm);
return 0;
}
return 1;
}
#endif
/*******************************************************************
*
*******************************************************************/
void SendData( call_t *ptrCall )
{
static unsigned short usDataHandle;
char buffer[REG_CAPI_DATA_BLK_SIZE];
int len;
if (0== ptrCall->doSend) { return; }
/*
* Read next blk from file into buffer
*/
#if LOGIN_SCRIPT_LINE_BY_LINE
{
char *dataptr;
dataptr = fgets( buffer, sizeof(buffer), ptrCall->txfp);
if (dataptr == NULL) {
/* fgets returned noting, we are out */
ptrCall->doSend = 0;
return;
}
len = strlen(dataptr); /* get line length */
}
#else
/*
* NOTE: Don't know why but if we send data with a length
* equal to REG_CAPI_DATA_BLK_SIZE, the brick gona
* complain about to long packet, so we just send
* half of the max buffer size.
*/
len = fread( buffer, 1, (sizeof(buffer) / 2), ptrCall->txfp);
if (len <= 0) {
if (len < 0) {
perror("\nERR:SendData\n");
}
ptrCall->doSend = 0;
return;
}
#endif
ptrCall->NotAcknowledged++; /* count pending confirms */
usDataHandle++;
capi2_datab3_req( ptrCall->capi_fd,
ptrCall->ident,
buffer,
len,
0,
usDataHandle);
}
/*******************************************************************
*
*******************************************************************/
void handleConnectB3ActiveInd( call_t *ptrCall )
{
if(cfg.verbose > 0) {
printf("Terminate sequence is '%c%c'\n", ESCAPE_CHAR, TERMINATE_CHAR);
}
/* put terminal into raw mode after connect was okay */
set_raw_terminal();
cfg.starttime = time(0);
ptrCall->wasConnected = 1;
ptrCall->doSend = 1;
if (ptrCall->txfp) {
SendData( ptrCall );
}
}
/*******************************************************************
*
*******************************************************************/
int handleDataB3Ind( call_t *ptrCall,
unsigned short messid,
unsigned char *dataptr,
int datalen,
unsigned short handle,
unsigned short flags )
{
#if 0
printf("komisch hab ne data indicationb\n");
capi_hexdump( dataptr, datalen, 16, 2);
#endif
printf("%*.*s", datalen, datalen, dataptr);
return 1; /* response */
}
/*******************************************************************
*
*******************************************************************/
void handleDataB3Conf( call_t *ptrCall,
unsigned short messid,
unsigned short handle )
{
ptrCall->NotAcknowledged--; /* We got a acknowledge */
#ifdef FAX
if(cfg.verbose > 2) {
putchar('c');
}
#endif
if (ptrCall->txfp) {
SendData( ptrCall ); /* Send the next one */
}
}
/*******************************************************************
*
*******************************************************************/
void handleInfoInd( call_t *ptrCall,
unsigned short infonumber,
struct userdata *data )
{
unsigned long mask;
unsigned char *datap = data->data;
switch(infonumber){
default:
if(cfg.verbose>5){
printf("\tINFOIND: 0x%04x\n", infonumber);
capi_hexdump( data->data, data->length, 16, 2);
}
break;
case 0x18: /* IBCHI */
if (*datap & (1<<5)) {
/* primary rate interface */
if (*datap++ & (1<<6)) {
/* interface identifier present */
while((*datap++ & 0x80) == 0);
}
if (*datap++ & (1<<4)) {
cfg.b_channel = 1;
mask = 1;
while(!(mask & *datap)){
mask<<=1;
cfg.b_channel++;
}
}
else {
cfg.b_channel = *datap & 0x7f;
}
}
else {
/* basic rate interface */
cfg.b_channel = *datap & 0x03;
}
if(cfg.verbose>2){
printf("\tINFOIND: ISDN-BCHANNEL %d\n", cfg.b_channel);
}
break;
}
}
/*******************************************************************
*
*******************************************************************/
void handleDisconnectB3Ind( call_t *ptrCall,
unsigned short nReason,
struct userdata *ncpi )
{
int delta_time;
cfg.endtime = time(0);
delta_time = cfg.endtime - cfg.starttime;
reset_terminal();
/* No need for this here
* if (nReason) printf("\tDISCONNECT B3_Reason (0x%04x)\n", nReason);
*/
if(ptrCall->NotAcknowledged && cfg.verbose>0) {
printf("handleDisconnectB3Ind() missing %d CAPI2_DATAB3_CONF\n",
ptrCall->NotAcknowledged);
}
}
/*******************************************************************
*
*******************************************************************/
void handleDisconnectInd( call_t *ptrCall,
unsigned short nReason)
{
printf("ISDN D-channel disconnect, Reason (%04x)\n", nReason);
}