From b59448dbcd2837a9531dcbfbb5090db8dbbe50fa Mon Sep 17 00:00:00 2001 From: automerge Date: Wed, 20 Jun 2007 15:18:19 +0000 Subject: automerge commit git-svn-id: http://svn.digium.com/svn/asterisk/branches/1.2-netsec@70340 f38db490-d61c-443f-a65b-d21fe96a405b --- channels/misdn/isdn_lib.c | 70 ++++++++++++++++++++++++++++++++--------------- channels/misdn/isdn_lib.h | 2 ++ 2 files changed, 50 insertions(+), 22 deletions(-) (limited to 'channels/misdn') diff --git a/channels/misdn/isdn_lib.c b/channels/misdn/isdn_lib.c index 38a1f4ad4..86643d1e5 100644 --- a/channels/misdn/isdn_lib.c +++ b/channels/misdn/isdn_lib.c @@ -536,9 +536,7 @@ void bc_next_state_change(struct misdn_bchannel *bc, enum bchannel_state state) void empty_bc(struct misdn_bchannel *bc) { bc->bframe_len=0; - - bc->in_use= 0; bc->cw= 0; bc->dec=0; @@ -660,6 +658,7 @@ int clean_up_bc(struct misdn_bchannel *bc) mISDN_write_frame(stack->midev, buff, bc->layer_id|FLG_MSG_TARGET|FLG_MSG_DOWN, MGR_DELLAYER | REQUEST, 0, 0, NULL, TIMEOUT_1SEC); bc->b_stid = 0; + bc->in_use = 0; bc_state_change(bc, BCHAN_CLEANED); return ret; @@ -1105,6 +1104,7 @@ int init_bc(struct misdn_stack *stack, struct misdn_bchannel *bc, int midev, in bc->port=stack->port; bc->nt=stack->nt?1:0; + bc->pri=stack->pri; { ibuffer_t* ibuf= init_ibuffer(MISDN_IBUF_SIZE); @@ -1478,14 +1478,6 @@ int handle_event ( struct misdn_bchannel *bc, enum event_e event, iframe_t *frm) switch (event) { case EVENT_CONNECT_ACKNOWLEDGE: -#if 0 - if ( !misdn_cap_is_speech(bc->capability)) { - int ret=setup_bc(bc); - if (ret == -EINVAL){ - cb_log(0,bc->port,"send_event: setup_bc failed\n"); - } - } -#endif break; case EVENT_CONNECT: @@ -1579,10 +1571,9 @@ int handle_cr ( struct misdn_stack *stack, iframe_t *frm) } if (bc) { + int channel = bc->channel; cb_log(4, stack->port, " --> lib: CLEANING UP l3id: %x\n",frm->dinfo); - if (bc->channel>0) - empty_chan_in_stack(stack,bc->channel); - + /*bc->pid = 0;*/ bc->need_disconnect=0; bc->need_release=0; @@ -1592,6 +1583,10 @@ int handle_cr ( struct misdn_stack *stack, iframe_t *frm) empty_bc(bc); clean_up_bc(bc); + + if (channel>0) + empty_chan_in_stack(stack,bc->channel); + dump_chan_list(stack); if (bc->stack_holder) { @@ -2067,12 +2062,16 @@ handle_event_nt(void *dat, void *arg) break; case EVENT_RELEASE: case EVENT_RELEASE_COMPLETE: - if (bc->channel>0) - empty_chan_in_stack(stack, bc->channel); + { + int channel=bc->channel; int tmpcause=bc->cause; empty_bc(bc); bc->cause=tmpcause; clean_up_bc(bc); + + if (channel>0) + empty_chan_in_stack(stack, bc->channel); + } break; default: @@ -2637,6 +2636,7 @@ int handle_frm(msg_t *msg) empty_chan_in_stack(stack, bc->channel); empty_bc(bc); bc_state_change(bc,BCHAN_CLEANED); + bc->in_use=0; cb_log(0, stack->port, "GOT IGNORE SETUP\n"); @@ -2654,14 +2654,22 @@ int handle_frm(msg_t *msg) if (event == EVENT_RELEASE_COMPLETE) { /* release bchannel only after we've anounced the RELEASE_COMPLETE */ - if (bc->channel>0) - empty_chan_in_stack(stack,bc->channel); + int channel=bc->channel; int tmpcause=bc->cause; int tmp_out_cause=bc->out_cause; empty_bc(bc); bc->cause=tmpcause; bc->out_cause=tmp_out_cause; clean_up_bc(bc); + + if (tmpcause == 44) { + cb_log(0,stack->port,"**** Received CAUSE:44, so not cleaning up channel %d\n", channel); + cb_log(0,stack->port,"**** This channel is now no longer available,\nplease try to restart it with 'misdn send restart '\n"); + set_chan_in_stack(stack,bc->channel); + } else { + if (channel>0) + empty_chan_in_stack(stack,bc->channel); + } } cb_log(5, stack->port, "Freeing Msg on prim:%x \n",frm->prim); @@ -3324,11 +3332,14 @@ int misdn_lib_send_event(struct misdn_bchannel *bc, enum event_e event ) misdn_split_conf(bc2,bc->conf_id); } } + + int channel=bc->channel; - if (bc->channel>0) - empty_chan_in_stack(stack,bc->channel); empty_bc(bc); clean_up_bc(bc); + + if (channel>0) + empty_chan_in_stack(stack,bc->channel); } } @@ -3362,14 +3373,17 @@ int misdn_lib_send_event(struct misdn_bchannel *bc, enum event_e event ) if (!stack->nt) { /*create clenaup in TE*/ - if (bc->channel>0) - empty_chan_in_stack(stack,bc->channel); + int channel=bc->channel; + int tmpcause=bc->cause; int tmp_out_cause=bc->out_cause; empty_bc(bc); bc->cause=tmpcause; bc->out_cause=tmp_out_cause; clean_up_bc(bc); + + if (channel>0) + empty_chan_in_stack(stack,bc->channel); } break; @@ -3656,9 +3670,21 @@ int misdn_lib_send_restart(int port, int channel) for (;i<=max;i++) { dummybc.channel=i; - cb_log(0, port, "Restarting channel %d\n",i); + cb_log(0, port, "Restarting and cleaning channel %d\n",i); misdn_lib_send_event(&dummybc, EVENT_RESTART); /*do we need to wait before we get an EVENT_RESTART_ACK ?*/ + + /* clean up chan in stack, to be sure we don't think it's + * in use anymore */ + int cnt; + for (cnt=0; cnt<=stack->b_num; cnt++) { + if (stack->bc[cnt].channel == i) { + empty_bc(&stack->bc[cnt]); + clean_up_bc(&stack->bc[cnt]); + } + } + empty_chan_in_stack(stack, i); + } return 0; diff --git a/channels/misdn/isdn_lib.h b/channels/misdn/isdn_lib.h index 776ad142e..aa6aba88d 100644 --- a/channels/misdn/isdn_lib.h +++ b/channels/misdn/isdn_lib.h @@ -216,6 +216,8 @@ struct misdn_bchannel { struct send_lock *send_lock; int nt; + int pri; + int port; /** init stuff **/ int b_stid; -- cgit v1.2.3