diff options
author | Alec L Davis <sivad.a@paradise.net.nz> | 2012-02-18 08:02:08 +0000 |
---|---|---|
committer | Alec L Davis <sivad.a@paradise.net.nz> | 2012-02-18 08:02:08 +0000 |
commit | a4f6d96b2e7774521076e6b8648af14f49e7a5bd (patch) | |
tree | 4bf8aa8f0ef379f64b08dfc576d9621b811d1f6d | |
parent | 3816fdde94216189e9bbe956a2ec520d8f2c62fa (diff) |
push 'outgoing' flag from sig_XXX up to chan_dahdi
'p->outgoing' in chan_dahdi and sig_analog wern't kept in sync, particulary FXS ast_hangup didn't clear the 'outgoing' flag.
sig_pri and sig_ss7 were keeping 'outgoing' flag insync.
Now provides a callback for all the low level sig_XXX modules.
(issue ASTERISK-19316)
alecdavis (license 585)
Reported by: Jeremy Pepper
Tested by: alecdavis
Review: https://reviewboard.asterisk.org/r/1747/
........
Merged revisions 355850 from http://svn.asterisk.org/svn/asterisk/branches/1.8
........
Merged revisions 355851 from http://svn.asterisk.org/svn/asterisk/branches/10
git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@355852 65c4cc65-6c06-0410-ace0-fbb531ad65f3
-rw-r--r-- | channels/chan_dahdi.c | 10 | ||||
-rw-r--r-- | channels/sig_analog.c | 16 | ||||
-rw-r--r-- | channels/sig_analog.h | 1 | ||||
-rw-r--r-- | channels/sig_pri.c | 16 | ||||
-rw-r--r-- | channels/sig_pri.h | 1 | ||||
-rw-r--r-- | channels/sig_ss7.c | 14 | ||||
-rw-r--r-- | channels/sig_ss7.h | 1 |
7 files changed, 48 insertions, 11 deletions
diff --git a/channels/chan_dahdi.c b/channels/chan_dahdi.c index 560fb02d4..73bfcfe8c 100644 --- a/channels/chan_dahdi.c +++ b/channels/chan_dahdi.c @@ -2277,6 +2277,13 @@ static void my_set_dialing(void *pvt, int is_dialing) p->dialing = is_dialing; } +static void my_set_outgoing(void *pvt, int is_outgoing) +{ + struct dahdi_pvt *p = pvt; + + p->outgoing = is_outgoing; +} + #if defined(HAVE_PRI) || defined(HAVE_SS7) static void my_set_digital(void *pvt, int is_digital) { @@ -3400,6 +3407,7 @@ static struct sig_pri_callback dahdi_pri_callbacks = .fixup_chans = my_pri_fixup_chans, .set_alarm = my_set_alarm, .set_dialing = my_set_dialing, + .set_outgoing = my_set_outgoing, .set_digital = my_set_digital, .set_callerid = my_set_callerid, .set_dnid = my_set_dnid, @@ -3571,6 +3579,7 @@ static struct sig_ss7_callback dahdi_ss7_callbacks = .handle_link_exception = my_handle_link_exception, .set_alarm = my_set_alarm, .set_dialing = my_set_dialing, + .set_outgoing = my_set_outgoing, .set_digital = my_set_digital, .set_inservice = my_set_inservice, .set_locallyblocked = my_set_locallyblocked, @@ -3712,6 +3721,7 @@ static struct analog_callback dahdi_analog_callbacks = .set_cadence = my_set_cadence, .set_alarm = my_set_alarm, .set_dialing = my_set_dialing, + .set_outgoing = my_set_outgoing, .set_ringtimeout = my_set_ringtimeout, .set_waitingfordt = my_set_waitingfordt, .check_waitingfordt = my_check_waitingfordt, diff --git a/channels/sig_analog.c b/channels/sig_analog.c index ecb62b938..21a96317a 100644 --- a/channels/sig_analog.c +++ b/channels/sig_analog.c @@ -512,6 +512,14 @@ static int analog_on_hook(struct analog_pvt *p) return -1; } +static void analog_set_outgoing(struct analog_pvt *p, int is_outgoing) +{ + p->outgoing = is_outgoing; + if (p->calls->set_outgoing) { + p->calls->set_outgoing(p->chan_pvt, is_outgoing); + } +} + static int analog_check_for_conference(struct analog_pvt *p) { if (p->calls->check_for_conference) { @@ -796,11 +804,11 @@ struct ast_channel * analog_request(struct analog_pvt *p, int *callwait, const s } } - p->outgoing = 1; + analog_set_outgoing(p, 1); ast = analog_new_ast_channel(p, AST_STATE_RESERVED, 0, p->owner ? ANALOG_SUB_CALLWAIT : ANALOG_SUB_REAL, requestor); if (!ast) { - p->outgoing = 0; + analog_set_outgoing(p, 0); } return ast; } @@ -1026,7 +1034,7 @@ int analog_call(struct analog_pvt *p, struct ast_channel *ast, const char *rdest } p->dialednone = 0; - p->outgoing = 1; + analog_set_outgoing(p, 1); mysig = p->sig; if (p->outsigmod > -1) { @@ -1429,7 +1437,7 @@ int analog_hangup(struct analog_pvt *p, struct ast_channel *ast) analog_set_ringtimeout(p, 0); analog_set_confirmanswer(p, 0); analog_set_pulsedial(p, 0); - p->outgoing = 0; + analog_set_outgoing(p, 0); p->onhooktime = time(NULL); p->cidrings = 1; diff --git a/channels/sig_analog.h b/channels/sig_analog.h index 9412f8ad3..46453ed15 100644 --- a/channels/sig_analog.h +++ b/channels/sig_analog.h @@ -223,6 +223,7 @@ struct analog_callback { void (* const set_cadence)(void *pvt, int *cidrings, struct ast_channel *chan); void (* const set_alarm)(void *pvt, int in_alarm); void (* const set_dialing)(void *pvt, int is_dialing); + void (* const set_outgoing)(void *pvt, int is_outgoing); void (* const set_ringtimeout)(void *pvt, int ringt); void (* const set_waitingfordt)(void *pvt, struct ast_channel *ast); int (* const check_waitingfordt)(void *pvt); diff --git a/channels/sig_pri.c b/channels/sig_pri.c index 28a640639..5c70179ef 100644 --- a/channels/sig_pri.c +++ b/channels/sig_pri.c @@ -180,6 +180,14 @@ static void sig_pri_set_digital(struct sig_pri_chan *p, int is_digital) } } +static void sig_pri_set_outgoing(struct sig_pri_chan *p, int is_outgoing) +{ + p->outgoing = is_outgoing; + if (p->calls->set_outgoing) { + p->calls->set_outgoing(p->chan_pvt, is_outgoing); + } +} + void sig_pri_set_alarm(struct sig_pri_chan *p, int in_alarm) { /* @@ -1003,10 +1011,10 @@ struct ast_channel *sig_pri_request(struct sig_pri_chan *p, enum sig_pri_law law ast_debug(1, "%s %d\n", __FUNCTION__, p->channel); - p->outgoing = 1; + sig_pri_set_outgoing(p, 1); ast = sig_pri_new_ast_channel(p, AST_STATE_RESERVED, law, transfercapability, p->exten, requestor); if (!ast) { - p->outgoing = 0; + sig_pri_set_outgoing(p, 0); } return ast; } @@ -7228,7 +7236,7 @@ int sig_pri_hangup(struct sig_pri_chan *p, struct ast_channel *ast) return 0; } - p->outgoing = 0; + sig_pri_set_outgoing(p, 0); sig_pri_set_digital(p, 0); /* push up to parent for EC*/ #if defined(HAVE_PRI_CALL_WAITING) if (p->is_call_waiting) { @@ -7440,7 +7448,7 @@ int sig_pri_call(struct sig_pri_chan *p, struct ast_channel *ast, const char *rd } p->dialdest[0] = '\0'; - p->outgoing = 1; + sig_pri_set_outgoing(p, 1); ast_copy_string(dest, rdest, sizeof(dest)); AST_NONSTANDARD_APP_ARGS(args, dest, '/'); diff --git a/channels/sig_pri.h b/channels/sig_pri.h index dbef00042..8123f6bf8 100644 --- a/channels/sig_pri.h +++ b/channels/sig_pri.h @@ -180,6 +180,7 @@ struct sig_pri_callback { void (* const set_alarm)(void *pvt, int in_alarm); void (* const set_dialing)(void *pvt, int is_dialing); void (* const set_digital)(void *pvt, int is_digital); + void (* const set_outgoing)(void *pvt, int is_outgoing); void (* const set_callerid)(void *pvt, const struct ast_party_caller *caller); void (* const set_dnid)(void *pvt, const char *dnid); void (* const set_rdnis)(void *pvt, const char *rdnis); diff --git a/channels/sig_ss7.c b/channels/sig_ss7.c index 12cc2806c..9edb04bbb 100644 --- a/channels/sig_ss7.c +++ b/channels/sig_ss7.c @@ -120,6 +120,14 @@ static void sig_ss7_set_digital(struct sig_ss7_chan *p, int is_digital) } } +static void sig_ss7_set_outgoing(struct sig_ss7_chan *p, int is_outgoing) +{ + p->outgoing = is_outgoing; + if (p->calls->set_outgoing) { + p->calls->set_outgoing(p->chan_pvt, is_outgoing); + } +} + static void sig_ss7_set_inservice(struct sig_ss7_chan *p, int is_inservice) { if (p->calls->set_inservice) { @@ -1570,7 +1578,7 @@ int sig_ss7_hangup(struct sig_ss7_chan *p, struct ast_channel *ast) p->owner = NULL; sig_ss7_set_dialing(p, 0); - p->outgoing = 0; + sig_ss7_set_outgoing(p, 0); p->progress = 0; p->rlt = 0; p->exten[0] = '\0'; @@ -1755,10 +1763,10 @@ struct ast_channel *sig_ss7_request(struct sig_ss7_chan *p, enum sig_ss7_law law { struct ast_channel *ast; - p->outgoing = 1; + sig_ss7_set_outgoing(p, 1); ast = sig_ss7_new_ast_channel(p, AST_STATE_RESERVED, law, transfercapability, p->exten, requestor); if (!ast) { - p->outgoing = 0; + sig_ss7_set_outgoing(p, 0); /* Release the allocated channel. Only have to deal with the linkset lock. */ ast_mutex_lock(&p->ss7->lock); diff --git a/channels/sig_ss7.h b/channels/sig_ss7.h index 63ee5dee8..a69671c8d 100644 --- a/channels/sig_ss7.h +++ b/channels/sig_ss7.h @@ -142,6 +142,7 @@ struct sig_ss7_callback { void (* const set_alarm)(void *pvt, int in_alarm); void (* const set_dialing)(void *pvt, int is_dialing); void (* const set_digital)(void *pvt, int is_digital); + void (* const set_outgoing)(void *pvt, int is_outgoing); void (* const set_inservice)(void *pvt, int is_inservice); void (* const set_locallyblocked)(void *pvt, int is_blocked); void (* const set_remotelyblocked)(void *pvt, int is_blocked); |