kenmirrors/asterisk
1
0
Fork 0
mirror of https://github.com/asterisk/asterisk.git synced 2025-09-06 12:36:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add "Who Hung Up?" implementation for DAHDI SS7 subtechnology

Browse Source 
Testing was done on a local machine to verify that protocol and
cause information was being sent properly.

Review: https://reviewboard.asterisk.org/r/1955/
(issue SWP-4222)


git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@369184 65c4cc65-6c06-0410-ace0-fbb531ad65f3
This commit is contained in:
Kinsey Moore
2012-06-22 14:57:07 +00:00
parent a4b545222f
commit dee5d6b9e5
1 changed files with 56 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

57
channels/sig_ss7.c
View File

@@ -370,6 +370,32 @@ static void sig_ss7_queue_control(struct sig_ss7_linkset *ss7, int chanpos, int
sig_ss7_queue_frame(ss7, chanpos, &f); sig_ss7_queue_frame(ss7, chanpos, &f);
} }
/*!
* \internal
* \brief Queue a PVT_CAUSE_CODE frame onto the owner channel.
* \since 11
*
* \param owner Owner channel of the pvt.
* \param cause String describing the cause to be placed into the frame.
*
* \note Assumes the linkset->lock is already obtained.
* \note Assumes the sig_ss7_lock_private(linkset->pvts[chanpos]) is already obtained.
* \note Assumes linkset->pvts[chanpos]->owner is non-NULL and its lock is already obtained.
*
* \return Nothing
*/
static void ss7_queue_pvt_cause_data(struct ast_channel *owner, const char *cause)
{
struct ast_control_pvt_cause_code *cause_code;
int datalen = sizeof(*cause_code) + strlen(cause);
cause_code = alloca(datalen);
ast_copy_string(cause_code->chan_name, ast_channel_name(owner), AST_CHANNEL_NAME);
ast_copy_string(cause_code->code, cause, datalen + 1 - sizeof(*cause_code));
ast_queue_control_data(owner, AST_CONTROL_PVT_CAUSE_CODE, cause_code, datalen);
}
/*! /*!
* \internal * \internal
* \brief Find the channel position by CIC/DPC. * \brief Find the channel position by CIC/DPC.
@@ -702,7 +728,6 @@ void *ss7_linkset(void *data)
struct ss7 *ss7 = linkset->ss7; struct ss7 *ss7 = linkset->ss7;
ss7_event *e = NULL; ss7_event *e = NULL;
struct sig_ss7_chan *p; struct sig_ss7_chan *p;
int chanpos;
struct pollfd pollers[SIG_SS7_NUM_DCHANS]; struct pollfd pollers[SIG_SS7_NUM_DCHANS];
int nextms = 0; int nextms = 0;
@@ -770,6 +795,9 @@ void *ss7_linkset(void *data)
} }
while ((e = ss7_check_event(ss7))) { while ((e = ss7_check_event(ss7))) {
int chanpos = -1;
char cause_str[30];
if (linkset->debug) { if (linkset->debug) {
ast_verbose("Linkset %d: Processing event: %s\n", ast_verbose("Linkset %d: Processing event: %s\n",
linkset->span, ss7_event2str(e->e)); linkset->span, ss7_event2str(e->e));
@@ -849,6 +877,7 @@ void *ss7_linkset(void *data)
sig_ss7_lock_owner(linkset, chanpos); sig_ss7_lock_owner(linkset, chanpos);
p->ss7call = NULL; p->ss7call = NULL;
if (p->owner) { if (p->owner) {
ss7_queue_pvt_cause_data(p->owner, "SS7 ISUP_EVENT_RSC");
ast_softhangup_nolock(p->owner, AST_SOFTHANGUP_DEV); ast_softhangup_nolock(p->owner, AST_SOFTHANGUP_DEV);
ast_channel_unlock(p->owner); ast_channel_unlock(p->owner);
} }
@@ -906,6 +935,7 @@ void *ss7_linkset(void *data)
} }
p->call_level = SIG_SS7_CALL_LEVEL_GLARE; p->call_level = SIG_SS7_CALL_LEVEL_GLARE;
if (p->owner) { if (p->owner) {
ss7_queue_pvt_cause_data(p->owner, "SS7 ISUP_EVENT_IAM (glare)");
ast_channel_hangupcause_set(p->owner, AST_CAUSE_NORMAL_CLEARING); ast_channel_hangupcause_set(p->owner, AST_CAUSE_NORMAL_CLEARING);
ast_softhangup_nolock(p->owner, AST_SOFTHANGUP_DEV); ast_softhangup_nolock(p->owner, AST_SOFTHANGUP_DEV);
ast_channel_unlock(p->owner); ast_channel_unlock(p->owner);
@@ -1049,6 +1079,9 @@ void *ss7_linkset(void *data)
sig_ss7_lock_private(p); sig_ss7_lock_private(p);
sig_ss7_lock_owner(linkset, chanpos); sig_ss7_lock_owner(linkset, chanpos);
if (p->owner) { if (p->owner) {
snprintf(cause_str, sizeof(cause_str), "SS7 ISUP_EVENT_REL (%d)", e->rel.cause);
ss7_queue_pvt_cause_data(p->owner, cause_str);
ast_channel_hangupcause_set(p->owner, e->rel.cause); ast_channel_hangupcause_set(p->owner, e->rel.cause);
ast_softhangup_nolock(p->owner, AST_SOFTHANGUP_DEV); ast_softhangup_nolock(p->owner, AST_SOFTHANGUP_DEV);
ast_channel_unlock(p->owner); ast_channel_unlock(p->owner);
@@ -1251,6 +1284,28 @@ void *ss7_linkset(void *data)
ast_debug(1, "Unknown event %s\n", ss7_event2str(e->e)); ast_debug(1, "Unknown event %s\n", ss7_event2str(e->e));
break; break;
} }
if (chanpos > -1) {
switch (e->e) {
/* handled above */
case ISUP_EVENT_IAM:
case ISUP_EVENT_REL:
case ISUP_EVENT_RSC:
break;
default:
p = linkset->pvts[chanpos];
sig_ss7_lock_private(p);
sig_ss7_lock_owner(linkset, chanpos);
if (p->owner) {
char *event_str = ss7_event2str(e->e);
snprintf(cause_str, sizeof(cause_str), "SS7 %s", event_str);
ss7_queue_pvt_cause_data(p->owner, cause_str);
ast_channel_unlock(p->owner);
}
sig_ss7_unlock_private(p);
}
}
} }
ast_mutex_unlock(&linkset->lock); ast_mutex_unlock(&linkset->lock);
} }