/*****************************************************************************\ ** ** ** Linux Call Router ** ** ** **---------------------------------------------------------------------------** ** Copyright: Andreas Eversberg ** ** ** ** mISDN channel handlin for remote application ** ** ** \*****************************************************************************/ #include #include #include #include #include #include #include #include #include #include #ifdef SOCKET_MISDN #include #include #include #include #else #include #include #endif #include "extension.h" #include "message.h" #include "lcrsocket.h" #include "cause.h" #include "bchannel.h" #include "chan_lcr.h" #include "callerid.h" #ifndef ISDN_PID_L4_B_USER #define ISDN_PID_L4_B_USER 0x440000ff #endif pid_t bchannel_pid; enum { BSTATE_IDLE, BSTATE_ACTIVATING, BSTATE_ACTIVE, }; #ifdef SOCKET_MISDN int bchannel_initialize(void) { return(0); } void bchannel_deinitialize(void) { } #else int bchannel_entity = 0; /* used for udevice */ int bchannel_device = -1; /* the device handler and port list */ int bchannel_initialize(void) { unsigned char buff[1025]; iframe_t *frm = (iframe_t *)buff; int ret; /* open mISDNdevice if not already open */ if (bchannel_device < 0) { ret = mISDN_open(); if (ret < 0) { CERROR("cannot open mISDN device ret=%d errno=%d (%s) Check for mISDN modules!\nAlso did you create \"/dev/mISDN\"? Do: \"mknod /dev/mISDN c 46 0\"\n", ret, errno, strerror(errno)); return(-1); } bchannel_device = ret; CDEBUG("mISDN device opened.\n"); /* create entity for layer 3 TE-mode */ mISDN_write_frame(bchannel_device, buff, 0, MGR_NEWENTITY | REQUEST, 0, 0, NULL, TIMEOUT_1SEC); ret = mISDN_read_frame(bchannel_device, frm, sizeof(iframe_t), 0, MGR_NEWENTITY | CONFIRM, TIMEOUT_1SEC); if (ret < (int)mISDN_HEADER_LEN) { noentity: CERROR("Cannot request MGR_NEWENTITY from mISDN. Exitting due to software bug."); return(-1); } bchannel_entity = frm->dinfo & 0xffff; if (!bchannel_entity) goto noentity; } return(0); } void bchannel_deinitialize(void) { unsigned char buff[1025]; if (bchannel_device >= 0) { /* free entity */ mISDN_write_frame(bchannel_device, buff, 0, MGR_DELENTITY | REQUEST, bchannel_entity, 0, NULL, TIMEOUT_1SEC); /* close device */ mISDN_close(bchannel_device); bchannel_device = -1; } } #endif /* * send control information to the channel (dsp-module) */ static void ph_control(unsigned long handle, unsigned long c1, unsigned long c2, char *trace_name, int trace_value) { #ifdef SOCKET_MISDN unsigned char buffer[MISDN_HEADER_LEN+sizeof(int)+sizeof(int)]; struct mISDNhead *ctrl = (struct mISDNhead *)buffer; unsigned long *d = buffer+MISDN_HEADER_LEN; int ret; ctrl->prim = PH_CONTROL_REQ; ctrl->id = 0; *d++ = c1; *d++ = c2; ret = sendto(handle, buffer, MISDN_HEADER_LEN+sizeof(int)*2, 0, NULL, 0); if (!ret) CERROR("Failed to send to socket %d\n", handle); #else unsigned char buffer[mISDN_HEADER_LEN+sizeof(int)+sizeof(int)]; iframe_t *ctrl = (iframe_t *)buffer; unsigned long *d = (unsigned long *)&ctrl->data.p; ctrl->prim = PH_CONTROL | REQUEST; ctrl->addr = handle | FLG_MSG_DOWN; ctrl->dinfo = 0; ctrl->len = sizeof(int)*2; *d++ = c1; *d++ = c2; mISDN_write(bchannel_device, ctrl, mISDN_HEADER_LEN+ctrl->len, TIMEOUT_1SEC); #endif #if 0 chan_trace_header(mISDNport, isdnport, "BCHANNEL control", DIRECTION_OUT); if (c1 == CMX_CONF_JOIN) add_trace(trace_name, NULL, "0x%08x", trace_value); else add_trace(trace_name, NULL, "%d", trace_value); end_trace(); #endif } static void ph_control_block(unsigned long handle, unsigned long c1, void *c2, int c2_len, char *trace_name, int trace_value) { #ifdef SOCKET_MISDN unsigned char buffer[MISDN_HEADER_LEN+sizeof(int)+c2_len]; struct mISDNhead *ctrl = (struct mISDNhead *)buffer; unsigned long *d = buffer+MISDN_HEADER_LEN; int ret; ctrl->prim = PH_CONTROL_REQ; ctrl->id = 0; *d++ = c1; memcpy(d, c2, c2_len); ret = sendto(handle, buffer, MISDN_HEADER_LEN+sizeof(int)+c2_len, 0, NULL, 0); if (!ret) CERROR("Failed to send to socket %d\n", handle); #else unsigned char buffer[mISDN_HEADER_LEN+sizeof(int)+c2_len]; iframe_t *ctrl = (iframe_t *)buffer; unsigned long *d = (unsigned long *)&ctrl->data.p; ctrl->prim = PH_CONTROL | REQUEST; ctrl->addr = handle | FLG_MSG_DOWN; ctrl->dinfo = 0; ctrl->len = sizeof(int)+c2_len; *d++ = c1; memcpy(d, c2, c2_len); mISDN_write(bchannel_device, ctrl, mISDN_HEADER_LEN+ctrl->len, TIMEOUT_1SEC); #endif #if 0 chan_trace_header(mISDNport, isdnport, "BCHANNEL control", DIRECTION_OUT); add_trace(trace_name, NULL, "%d", trace_value); end_trace(); #endif } /* * create stack */ int bchannel_create(struct bchannel *bchannel) { unsigned char buff[1024]; int ret; #ifdef SOCKET_MISDN unsigned long on = 1; struct sockadd_mISDN addr; if (bchannel->b_sock) { CERROR("Error: Socket already created for handle 0x%x\n", bchannel->handle); return(0); } /* default tx_dejitter */ bchannel->b_tx_dejitter = 1; /* open socket */ channel->b_sock = socket(PF_ISDN, SOCK_DGRAM, ISDN_P_B_L2DSP); if (bchannel->b_sock < 0) { CERROR("Error: Failed to open bchannel-socket for handle 0x%x with mISDN-DSP layer. Did you load mISDNdsp.ko?\n", bchannel->handle); return(0); } /* set nonblocking io */ ret = ioctl(bchannel->b_sock, FIONBIO, &on); if (ret < 0) { CERROR("Error: Failed to set bchannel-socket handle 0x%x into nonblocking IO\n", bchannel->handle); close(bchannel->b_sock); channel->b_sock = -1; return(0); } /* bind socket to bchannel */ addr.family = AF_ISDN; addr.dev = (bchannel->handle>>8)-1; addr.channel = bchannel->handle && 0xff; ret = bind(bchannel->b_sock, (struct sockaddr *)&addr, sizeof(addr)); if (ret < 0) { CERROR("Error: Failed to bind bchannel-socket for handle 0x%x with mISDN-DSP layer. Did you load mISDNdsp.ko?\n", bchannel->handle); close(bchannel->b_sock); channel->b_sock = -1; return(0); } #if 0 chan_trace_header(mISDNport, mISDNport->b_port[i], "BCHANNEL create socket", DIRECTION_OUT); add_trace("channel", NULL, "%d", i+1+(i>=15)); add_trace("socket", NULL, "%d", mISDNport->b_socket[i]); end_trace(); #endif #else layer_info_t li; mISDN_pid_t pid; if (bchannel->b_stid) { CERROR("Error: stack already created for address 0x%lx\n", bchannel->b_stid); return(0); } if (bchannel->b_addr) { CERROR("Error: stack already created for address 0x%lx\n", bchannel->b_addr); return(0); } /* create new layer */ CDEBUG("creating new layer for stid 0x%lx.\n" , bchannel->handle); memset(&li, 0, sizeof(li)); memset(&pid, 0, sizeof(pid)); li.object_id = -1; li.extentions = 0; li.st = bchannel->handle; strcpy(li.name, "B L4"); li.pid.layermask = ISDN_LAYER((4)); li.pid.protocol[4] = ISDN_PID_L4_B_USER; ret = mISDN_new_layer(bchannel_device, &li); if (ret) { failed_new_layer: CERROR("mISDN_new_layer() failed to add bchannel for stid 0x%lx.\n", bchannel->handle); goto failed; } if (!li.id) { goto failed_new_layer; } bchannel->b_stid = bchannel->handle; bchannel->b_addr = li.id; CDEBUG("new layer (b_addr=0x%x)\n", bchannel->b_addr); /* create new stack */ pid.protocol[1] = ISDN_PID_L1_B_64TRANS; pid.protocol[2] = ISDN_PID_L2_B_TRANS; pid.protocol[3] = ISDN_PID_L3_B_DSP; pid.protocol[4] = ISDN_PID_L4_B_USER; pid.layermask = ISDN_LAYER((1)) | ISDN_LAYER((2)) | ISDN_LAYER((3)) | ISDN_LAYER((4)); ret = mISDN_set_stack(bchannel_device, bchannel->b_stid, &pid); if (ret) { stack_error: CERROR("mISDN_set_stack() failed (ret=%d) to add bchannel stid=0x%lx\n", ret, bchannel->b_stid); mISDN_write_frame(bchannel_device, buff, bchannel->b_addr, MGR_DELLAYER | REQUEST, 0, 0, NULL, TIMEOUT_1SEC); goto failed; } ret = mISDN_get_setstack_ind(bchannel_device, bchannel->b_addr); if (ret) goto stack_error; /* get layer id */ bchannel->b_addr = mISDN_get_layerid(bchannel_device, bchannel->b_stid, 4); if (!bchannel->b_addr) goto stack_error; #if 0 chan_trace_header(mISDNport, mISDNport->b_port[i], "BCHANNEL create stack", DIRECTION_OUT); add_trace("channel", NULL, "%d", i+1+(i>=15)); add_trace("stack", "id", "0x%08x", mISDNport->b_stid[i]); add_trace("stack", "address", "0x%08x", mISDNport->b_addr[i]); end_trace(); #endif #endif return(1); failed: bchannel->b_stid = 0; bchannel->b_addr = 0; return(0); } /* * activate / deactivate request */ void bchannel_activate(struct bchannel *bchannel, int activate) { #ifdef SOCKET_MISDN struct mISDNhead act; int ret; act.prim = (activate)?DL_ESTABLISH_REQ:DL_RELEASE_REQ; act.id = 0; ret = sendto(bchannel->b_sock, &act, MISDN_HEADER_LEN, 0, NULL, 0); if (!ret) CERROR("Failed to send to socket %d\n", bchannel->b_sock); #else iframe_t act; /* activate bchannel */ act.prim = (activate?DL_ESTABLISH:DL_RELEASE) | REQUEST; act.addr = bchannel->b_addr | FLG_MSG_DOWN; act.dinfo = 0; act.len = 0; mISDN_write(bchannel_device, &act, mISDN_HEADER_LEN+act.len, TIMEOUT_1SEC); #endif bchannel->b_state = BSTATE_ACTIVATING; #if 0 /* trace */ chan_trace_header(mISDNport, mISDNport->b_port[i], activate?(char*)"BCHANNEL activate":(char*)"BCHANNEL deactivate", DIRECTION_OUT); add_trace("channel", NULL, "%d", i+1+(i>=15)); end_trace(); #endif } /* * set features */ static void bchannel_activated(struct bchannel *bchannel) { #ifdef SOCKET_MISDN int handle; handle = bchannel->b_sock; #else unsigned long handle; handle = bchannel->b_addr; #endif /* set dsp features */ if (bchannel->b_txdata) ph_control(handle, (bchannel->b_txdata)?DSP_TXDATA_ON:DSP_TXDATA_OFF, 0, "DSP-TXDATA", bchannel->b_txdata); if (bchannel->b_delay) ph_control(handle, DSP_DELAY, bchannel->b_delay, "DSP-DELAY", bchannel->b_delay); if (bchannel->b_tx_dejitter) ph_control(handle, (bchannel->b_tx_dejitter)?DSP_TX_DEJITTER:DSP_TX_DEJ_OFF, 0, "DSP-TX_DEJITTER", bchannel->b_tx_dejitter); if (bchannel->b_tx_gain) ph_control(handle, DSP_VOL_CHANGE_TX, bchannel->b_tx_gain, "DSP-TX_GAIN", bchannel->b_tx_gain); if (bchannel->b_rx_gain) ph_control(handle, DSP_VOL_CHANGE_RX, bchannel->b_rx_gain, "DSP-RX_GAIN", bchannel->b_rx_gain); if (bchannel->b_pipeline[0]) ph_control_block(handle, PIPELINE_CFG, bchannel->b_pipeline, strlen(bchannel->b_pipeline)+1, "DSP-PIPELINE", 0); if (bchannel->b_conf) ph_control(handle, DSP_CONF_JOIN, bchannel->b_conf, "DSP-CONF", bchannel->b_conf); if (bchannel->b_echo) ph_control(handle, DSP_ECHO_ON, 0, "DSP-ECHO", 1); if (bchannel->b_tone) ph_control(handle, DSP_TONE_PATT_ON, bchannel->b_tone, "DSP-TONE", bchannel->b_tone); if (bchannel->b_rxoff) ph_control(handle, DSP_RECEIVE_OFF, 0, "DSP-RXOFF", 1); // if (bchannel->b_txmix) // ph_control(handle, DSP_MIX_ON, 0, "DSP-MIX", 1); if (bchannel->b_dtmf) ph_control(handle, DTMF_TONE_START, 0, "DSP-DTMF", 1); if (bchannel->b_crypt_len) ph_control_block(handle, DSP_BF_ENABLE_KEY, bchannel->b_crypt_key, bchannel->b_crypt_len, "DSP-CRYPT", bchannel->b_crypt_len); if (bchannel->b_conf) ph_control(handle, DSP_CONF_JOIN, bchannel->b_conf, "DSP-CONF", bchannel->b_conf); bchannel->b_state = BSTATE_ACTIVE; } /* * destroy stack */ static void bchannel_destroy(struct bchannel *bchannel) { #ifdef SOCKET_MISDN #if 0 chan_trace_header(mISDNport, mISDNport->b_port[i], "BCHANNEL remove socket", DIRECTION_OUT); add_trace("channel", NULL, "%d", i+1+(i>=15)); add_trace("socket", NULL, "%d", mISDNport->b_socket[i]); end_trace(); #endif if (bchannel->b_sock > -1) { close(bchannel->b_sock); bchannel->b_sock = -1; } #else unsigned char buff[1024]; #if 0 chan_trace_header(mISDNport, mISDNport->b_port[i], "BCHANNEL remove stack", DIRECTION_OUT); add_trace("channel", NULL, "%d", i+1+(i>=15)); add_trace("stack", "id", "0x%08x", mISDNport->b_stid[i]); add_trace("stack", "address", "0x%08x", mISDNport->b_addr[i]); end_trace(); #endif /* remove our stack only if set */ if (bchannel->b_addr) { CDEBUG("free stack (b_addr=0x%x)\n", bchannel->b_addr); mISDN_clear_stack(bchannel_device, bchannel->b_stid); mISDN_write_frame(bchannel_device, buff, bchannel->b_addr | FLG_MSG_DOWN, MGR_DELLAYER | REQUEST, 0, 0, NULL, TIMEOUT_1SEC); bchannel->b_stid = 0; bchannel->b_addr = 0; } #endif bchannel->b_state = BSTATE_IDLE; } /* * whenever we get audio data from bchannel, we process it here */ static void bchannel_receive(struct bchannel *bchannel, unsigned long prim, unsigned long dinfo, unsigned char *data, int len) { unsigned long cont = *((unsigned long *)data); // unsigned char *data_temp; // unsigned long length_temp; // unsigned char *p; // int l; if (prim == (PH_CONTROL | INDICATION)) { if (len < 4) { CERROR("SHORT READ OF PH_CONTROL INDICATION\n"); return; } if ((cont&(~DTMF_TONE_MASK)) == DTMF_TONE_VAL) { #if 0 chan_trace_header(p_m_mISDNport, this, "BCHANNEL control", DIRECTION_IN); add_trace("DTMF", NULL, "%c", cont & DTMF_TONE_MASK); end_trace(); #endif if (bchannel->rx_dtmf) bchannel->rx_dtmf(bchannel, cont & DTMF_TONE_MASK); return; } switch(cont) { case BF_REJECT: #if 0 chan_trace_header(p_m_mISDNport, this, "BCHANNEL control", DIRECTION_IN); add_trace("DSP-CRYPT", NULL, "error"); end_trace(); #endif break; case BF_ACCEPT: #if 0 chan_trace_header(p_m_mISDNport, this, "BCHANNEL control", DIRECTION_IN); add_trace("DSP-CRYPT", NULL, "ok"); end_trace(); #endif break; default: #if 0 chan_trace_header(p_m_mISDNport, this, "BCHANNEL control", DIRECTION_IN); add_trace("unknown", NULL, "0x%x", cont); end_trace(); #else ; #endif } return; } if (prim == (PH_SIGNAL | INDICATION)) { switch(dinfo) { case CMX_TX_DATA: if (!bchannel->b_txdata) { /* if tx is off, it may happen that fifos send us pending informations, we just ignore them */ CDEBUG("PmISDN(%s) ignoring tx data, because 'txdata' is turned off\n", p_name); return; } break; default: #if 0 chan_trace_header(p_m_mISDNport, this, "BCHANNEL signal", DIRECTION_IN); add_trace("unknown", NULL, "0x%x", frm->dinfo); end_trace(); #else ; #endif } return; } if (prim != PH_DATA_IND && prim != DL_DATA_IND) { CERROR("Bchannel received unknown primitve: 0x%lx\n", prim); return; } /* calls will not process any audio data unless * the call is connected OR interface features audio during call setup. */ /* if rx is off, it may happen that fifos send us pending informations, we just ignore them */ if (bchannel->b_rxoff) { CDEBUG("PmISDN(%s) ignoring data, because rx is turned off\n", p_name); return; } if (!bchannel->call) { CDEBUG("PmISDN(%s) ignoring data, because no call associated with bchannel\n", p_name); return; } len = write(bchannel->call->pipe[1], data, len); if (len < 0) { CDEBUG("PmISDN(%s) broken pipe on bchannel pipe\n", p_name); return; } } /* * transmit data to bchannel */ void bchannel_transmit(struct bchannel *bchannel, unsigned char *data, int len) { unsigned char buff[1025]; iframe_t *frm = (iframe_t *)buff; if (bchannel->b_state != BSTATE_ACTIVE) return; #ifdef SOCKET_MISDN frm->prim = DL_DATA_REQ; frm->id = 0; ret = sendto(bchannel->b_sock, data, len, 0, NULL, 0); if (!ret) CERROR("Failed to send to socket %d\n", bchannel->b_sock); #else frm->prim = DL_DATA | REQUEST; frm->addr = bchannel->b_addr | FLG_MSG_DOWN; frm->dinfo = 0; frm->len = len; if (frm->len) mISDN_write(bchannel_device, frm, mISDN_HEADER_LEN+frm->len, TIMEOUT_1SEC); #endif } /* * join bchannel */ void bchannel_join(struct bchannel *bchannel, unsigned short id) { #ifdef SOCKET_MISDN int handle; handle = bchannel->b_sock; #else unsigned long handle; handle = bchannel->b_addr; #endif if (id) { bchannel->b_conf = (id<<16) + bchannel_pid; bchannel->b_rxoff = 1; } else { bchannel->b_conf = 0; bchannel->b_rxoff = 0; } if (bchannel->b_state == BSTATE_ACTIVE) { ph_control(handle, DSP_RX_OFF, bchannel->b_rxoff, "DSP-RX_OFF", bchannel->b_conf); ph_control(handle, DSP_CONF_JOIN, bchannel->b_conf, "DSP-CONF", bchannel->b_conf); } } /* * main loop for processing messages from mISDN */ #ifdef SOCKET_MISDN int bchannel_handle(void) { int ret, work = 0; struct bchannel *bchannel; int i; char buffer[2048+MISDN_HEADER_LEN]; struct mISDNhead *hh = (struct mISDNhead *)buffer; /* process all bchannels */ bchannel = bchannel_first; while(bchannel) { /* handle message from bchannel */ if (bchannel->b_sock > -1) { ret = recv(bchannel->b_sock, buffer, sizeof(buffer), 0); if (ret >= MISDN_HEADER_LEN) { work = 1; switch(hh->prim) { /* we don't care about confirms, we use rx data to sync tx */ case PH_DATA_CONF: case DL_DATA_CONF: break; /* we receive audio data, we respond to it AND we send tones */ case PH_DATA_IND: case DL_DATA_IND: case PH_SIGNAL_IND: case PH_CONTROL | INDICATION: bchannel_receive(bchannel, hh->prim, hh->dinfo, buffer+MISDN_HEADER_LEN, ret-MISDN_HEADER_LEN); break; case PH_ACTIVATE_IND: case DL_ESTABLISH_IND: case PH_ACTIVATE_CONF: case DL_ESTABLISH_CONF: CDEBUG("DL_ESTABLISH confirm: bchannel is now activated (socket %d).\n", bchannel->b_sock); bchannel_activated(bchannel); break; case PH_DEACTIVATE_IND: case DL_RELEASE_IND: case PH_DEACTIVATE_CONF: case DL_RELEASE_CONF: CDEBUG("DL_RELEASE confirm: bchannel is now de-activated (socket %d).\n", bchannel->b_sock); // bchannel_deactivated(bchannel); break; default: CERROR("child message not handled: prim(0x%x) socket(%d) msg->len(%d)\n", hh->prim, bchannel->b_sock, msg->len); } } else { if (ret < 0 && errno != EWOULDBLOCK) CERROR("Read from socket %d failed with return code %d\n", bchannel->b_sock, ret); } } bchannel = bchannel->next; } /* if we received at least one b-frame, we will return 1 */ return(work); } #else int bchannel_handle(void) { struct bchannel *bchannel; iframe_t *frm; unsigned char buffer[2048]; int len; /* no device, no read */ if (bchannel_device < 0) return(0); /* get message from kernel */ len = mISDN_read(bchannel_device, buffer, sizeof(buffer), 0); if (len < 0) { if (errno == EAGAIN) return(0); CERROR("Failed to do mISDN_read()\n"); return(0); } if (!len) { // printf("%s: ERROR: mISDN_read() returns nothing\n"); return(0); } frm = (iframe_t *)buffer; /* global prim */ switch(frm->prim) { case MGR_DELLAYER | CONFIRM: case MGR_INITTIMER | CONFIRM: case MGR_ADDTIMER | CONFIRM: case MGR_DELTIMER | CONFIRM: case MGR_REMOVETIMER | CONFIRM: return(1); } /* find the mISDNport that belongs to the stack */ bchannel = bchannel_first; while(bchannel) { if (frm->addr == bchannel->b_addr) break; bchannel = bchannel->next; } if (!bchannel) { CERROR("message belongs to no bchannel: prim(0x%x) addr(0x%x) msg->len(%d)\n", frm->prim, frm->addr, len); goto out; } /* b-message */ switch(frm->prim) { /* we don't care about confirms, we use rx data to sync tx */ case PH_DATA | CONFIRM: case DL_DATA | CONFIRM: break; /* we receive audio data, we respond to it AND we send tones */ case PH_DATA | INDICATION: case DL_DATA | INDICATION: case PH_CONTROL | INDICATION: case PH_SIGNAL | INDICATION: bchannel_receive(bchannel, frm->prim, frm->dinfo, (unsigned char *)frm->data.p, frm->len); break; case PH_ACTIVATE | INDICATION: case DL_ESTABLISH | INDICATION: case PH_ACTIVATE | CONFIRM: case DL_ESTABLISH | CONFIRM: CDEBUG( "DL_ESTABLISH confirm: bchannel is now activated (address 0x%x).\n", frm->addr); bchannel_activated(bchannel); break; case PH_DEACTIVATE | INDICATION: case DL_RELEASE | INDICATION: case PH_DEACTIVATE | CONFIRM: case DL_RELEASE | CONFIRM: CDEBUG("DL_RELEASE confirm: bchannel is now de-activated (address 0x%x).\n", frm->addr); // bchannel_deactivated(bchannel); break; default: CERROR("message not handled: prim(0x%x) addr(0x%x) msg->len(%d)\n", frm->prim, frm->addr, len); } out: return(1); } #endif /* * bchannel channel handling */ struct bchannel *bchannel_first = NULL; struct bchannel *find_bchannel_handle(unsigned long handle) { struct bchannel *bchannel = bchannel_first; while(bchannel) { if (bchannel->handle == handle) break; bchannel = bchannel->next; } return(bchannel); } #if 0 struct bchannel *find_bchannel_ref(unsigned long ref) { struct bchannel *bchannel = bchannel_first; while(bchannel) { if (bchannel->ref == ref) break; bchannel = bchannel->next; } return(bchannel); } #endif struct bchannel *alloc_bchannel(unsigned long handle) { struct bchannel **bchannelp = &bchannel_first; while(*bchannelp) bchannelp = &((*bchannelp)->next); *bchannelp = (struct bchannel *)malloc(sizeof(struct bchannel)); if (!*bchannelp) return(NULL); (*bchannelp)->handle = handle; (*bchannelp)->b_state = BSTATE_IDLE; return(*bchannelp); } void free_bchannel(struct bchannel *bchannel) { struct bchannel **temp = &bchannel_first; while(*temp) { if (*temp == bchannel) { *temp = (*temp)->next; #ifdef SOCKET_MISDN if (bchannel->b_sock > -1) #else if (bchannel->b_stid) #endif bchannel_destroy(bchannel); if (bchannel->call) { if (bchannel->call->bchannel) bchannel->call->bchannel = NULL; } free(bchannel); return; } temp = &((*temp)->next); } }