[svn-commits] crichter: branch 1.2 r70311 - in /branches/1.2/channels: ./ misdn/
SVN commits to the Digium repositories
svn-commits at lists.digium.com
Wed Jun 20 09:47:59 CDT 2007
Author: crichter
Date: Wed Jun 20 09:47:59 2007
New Revision: 70311
URL: http://svn.digium.com/view/asterisk?view=rev&rev=70311
Log:
on receiption of cause:44 we mark the channel as in use and inform the user about the situation, we need to test the RESTART stuff then. Also shuffled the empty_chan_in_stack function after the bchannel cleaning functions, to avoid race conditions.
Modified:
branches/1.2/channels/chan_misdn.c
branches/1.2/channels/misdn/isdn_lib.c
branches/1.2/channels/misdn/isdn_lib.h
Modified: branches/1.2/channels/chan_misdn.c
URL: http://svn.digium.com/view/asterisk/branches/1.2/channels/chan_misdn.c?view=diff&rev=70311&r1=70310&r2=70311
==============================================================================
--- branches/1.2/channels/chan_misdn.c (original)
+++ branches/1.2/channels/chan_misdn.c Wed Jun 20 09:47:59 2007
@@ -3149,6 +3149,8 @@
static struct chan_list *find_holded(struct chan_list *list, struct misdn_bchannel *bc)
{
struct chan_list *help=list;
+
+ if (bc->pri) return NULL;
chan_misdn_log(6, bc->port, "$$$ find_holded: channel:%d oad:%s dad:%s\n",bc->channel, bc->oad,bc->dad);
for (;help; help=help->next) {
Modified: branches/1.2/channels/misdn/isdn_lib.c
URL: http://svn.digium.com/view/asterisk/branches/1.2/channels/misdn/isdn_lib.c?view=diff&rev=70311&r1=70310&r2=70311
==============================================================================
--- branches/1.2/channels/misdn/isdn_lib.c (original)
+++ branches/1.2/channels/misdn/isdn_lib.c Wed Jun 20 09:47:59 2007
@@ -536,9 +536,7 @@
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 @@
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 @@
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 @@
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 @@
}
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 @@
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 @@
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 @@
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 @@
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 <port> <channel>'\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 @@
misdn_split_conf(bc2,bc->conf_id);
}
}
-
- if (bc->channel>0)
- empty_chan_in_stack(stack,bc->channel);
+
+ int channel=bc->channel;
+
empty_bc(bc);
clean_up_bc(bc);
+
+ if (channel>0)
+ empty_chan_in_stack(stack,bc->channel);
}
}
@@ -3362,14 +3373,17 @@
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 @@
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;
Modified: branches/1.2/channels/misdn/isdn_lib.h
URL: http://svn.digium.com/view/asterisk/branches/1.2/channels/misdn/isdn_lib.h?view=diff&rev=70311&r1=70310&r2=70311
==============================================================================
--- branches/1.2/channels/misdn/isdn_lib.h (original)
+++ branches/1.2/channels/misdn/isdn_lib.h Wed Jun 20 09:47:59 2007
@@ -216,6 +216,8 @@
struct send_lock *send_lock;
int nt;
+ int pri;
+
int port;
/** init stuff **/
int b_stid;
More information about the svn-commits
mailing list