<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.1//EN"
"http://www.w3.org/TR/xhtml11/DTD/xhtml11.dtd">
<html xmlns="http://www.w3.org/1999/xhtml">
<head><meta http-equiv="content-type" content="text/html; charset=utf-8" />
<title>[Freeswitch-trunk][17309] </title>
</head>
<body>
<style type="text/css"><!--
#msg dl.meta { border: 1px #006 solid; background: #369; padding: 6px; color: #fff; }
#msg dl.meta dt { float: left; width: 6em; font-weight: bold; }
#msg dt:after { content:':';}
#msg dl, #msg dt, #msg ul, #msg li, #header, #footer, #logmsg { font-family: verdana,arial,helvetica,sans-serif; font-size: 10pt; }
#msg dl a { font-weight: bold}
#msg dl a:link { color:#fc3; }
#msg dl a:active { color:#ff0; }
#msg dl a:visited { color:#cc6; }
h3 { font-family: verdana,arial,helvetica,sans-serif; font-size: 10pt; font-weight: bold; }
#msg pre { overflow: auto; background: #ffc; border: 1px #fa0 solid; padding: 6px; }
#logmsg { background: #ffc; border: 1px #fa0 solid; padding: 1em 1em 0 1em; }
#logmsg p, #logmsg pre, #logmsg blockquote { margin: 0 0 1em 0; }
#logmsg p, #logmsg li, #logmsg dt, #logmsg dd { line-height: 14pt; }
#logmsg h1, #logmsg h2, #logmsg h3, #logmsg h4, #logmsg h5, #logmsg h6 { margin: .5em 0; }
#logmsg h1:first-child, #logmsg h2:first-child, #logmsg h3:first-child, #logmsg h4:first-child, #logmsg h5:first-child, #logmsg h6:first-child { margin-top: 0; }
#logmsg ul, #logmsg ol { padding: 0; list-style-position: inside; margin: 0 0 0 1em; }
#logmsg ul { text-indent: -1em; padding-left: 1em; }#logmsg ol { text-indent: -1.5em; padding-left: 1.5em; }
#logmsg > ul, #logmsg > ol { margin: 0 0 1em 0; }
#logmsg pre { background: #eee; padding: 1em; }
#logmsg blockquote { border: 1px solid #fa0; border-left-width: 10px; padding: 1em 1em 0 1em; background: white;}
#logmsg dl { margin: 0; }
#logmsg dt { font-weight: bold; }
#logmsg dd { margin: 0; padding: 0 0 0.5em 0; }
#logmsg dd:before { content:'\00bb';}
#logmsg table { border-spacing: 0px; border-collapse: collapse; border-top: 4px solid #fa0; border-bottom: 1px solid #fa0; background: #fff; }
#logmsg table th { text-align: left; font-weight: normal; padding: 0.2em 0.5em; border-top: 1px dotted #fa0; }
#logmsg table td { text-align: right; border-top: 1px dotted #fa0; padding: 0.2em 0.5em; }
#logmsg table thead th { text-align: center; border-bottom: 1px solid #fa0; }
#logmsg table th.Corner { text-align: left; }
#logmsg hr { border: none 0; border-top: 2px dashed #fa0; height: 1px; }
#header, #footer { color: #fff; background: #636; border: 1px #300 solid; padding: 6px; }
#patch { width: 100%; }
#patch h4 {font-family: verdana,arial,helvetica,sans-serif;font-size:10pt;padding:8px;background:#369;color:#fff;margin:0;}
#patch .propset h4, #patch .binary h4 {margin:0;}
#patch pre {padding:0;line-height:1.2em;margin:0;}
#patch .diff {width:100%;background:#eee;padding: 0 0 10px 0;overflow:auto;}
#patch .propset .diff, #patch .binary .diff {padding:10px 0;}
#patch span {display:block;padding:0 10px;}
#patch .modfile, #patch .addfile, #patch .delfile, #patch .propset, #patch .binary, #patch .copfile {border:1px solid #ccc;margin:10px 0;}
#patch ins {background:#dfd;text-decoration:none;display:block;padding:0 10px;}
#patch del {background:#fdd;text-decoration:none;display:block;padding:0 10px;}
#patch .lines, .info {color:#888;background:#fff;}
--></style>
<div id="msg">
<div id="header">FreeSWITCH Subversion</div>
<dl class="meta">
<dt>Revision</dt> <dd><a href="http://fisheye.freeswitch.org/changelog/FreeSWITCH?cs=17309">17309</a></dd>
<dt>Author</dt> <dd>dyatsin</dd>
<dt>Date</dt> <dd>2010-04-15 10:54:32 -0500 (Thu, 15 Apr 2010)</dd>
</dl>
<h3>Log Message</h3>
<pre>Merge root@192.168.1.163:/freeswitch
Conflicts:
libs/freetdm/src/ftmod/ftmod_sangoma_boost/ftmod_sangoma_boost.c</pre>
<h3>Modified Paths</h3>
<ul>
<li><a href="#freeswitchtrunkfscommcallcpp">freeswitch/trunk/fscomm/call.cpp</a></li>
<li><a href="#freeswitchtrunkfscommcallh">freeswitch/trunk/fscomm/call.h</a></li>
<li><a href="#freeswitchtrunkfscommdebugtoolsconsolewindowcpp">freeswitch/trunk/fscomm/debugtools/consolewindow.cpp</a></li>
<li><a href="#freeswitchtrunkfscommmainwindowcpp">freeswitch/trunk/fscomm/mainwindow.cpp</a></li>
<li><a href="#freeswitchtrunkfscommmainwindowh">freeswitch/trunk/fscomm/mainwindow.h</a></li>
<li><a href="#freeswitchtrunklibsfreetdmmod_freetdmmod_freetdmc">freeswitch/trunk/libs/freetdm/mod_freetdm/mod_freetdm.c</a></li>
<li><a href="#freeswitchtrunklibsfreetdmsrcftdm_configc">freeswitch/trunk/libs/freetdm/src/ftdm_config.c</a></li>
<li><a href="#freeswitchtrunklibsfreetdmsrcftdm_ioc">freeswitch/trunk/libs/freetdm/src/ftdm_io.c</a></li>
<li><a href="#freeswitchtrunklibsfreetdmsrcftdm_threadmutexc">freeswitch/trunk/libs/freetdm/src/ftdm_threadmutex.c</a></li>
<li><a href="#freeswitchtrunklibsfreetdmsrcftmodftmod_sangoma_boostftmod_sangoma_boostc">freeswitch/trunk/libs/freetdm/src/ftmod/ftmod_sangoma_boost/ftmod_sangoma_boost.c</a></li>
<li><a href="#freeswitchtrunklibsfreetdmsrcftmodftmod_sangoma_boostsangoma_boost_clientc">freeswitch/trunk/libs/freetdm/src/ftmod/ftmod_sangoma_boost/sangoma_boost_client.c</a></li>
<li><a href="#freeswitchtrunklibsfreetdmsrcftmodftmod_sangoma_boostsigboosth">freeswitch/trunk/libs/freetdm/src/ftmod/ftmod_sangoma_boost/sigboost.h</a></li>
<li><a href="#freeswitchtrunklibsfreetdmsrcincludefreetdmh">freeswitch/trunk/libs/freetdm/src/include/freetdm.h</a></li>
<li><a href="#freeswitchtrunklibsfreetdmsrcincludeftdm_typesh">freeswitch/trunk/libs/freetdm/src/include/ftdm_types.h</a></li>
<li><a href="#freeswitchtrunklibsopenzapsrcozmodozmod_sangoma_boostozmod_sangoma_boostc">freeswitch/trunk/libs/openzap/src/ozmod/ozmod_sangoma_boost/ozmod_sangoma_boost.c</a></li>
<li><a href="#freeswitchtrunklibsopenzapsrcozmodozmod_sangoma_boostsigboosth">freeswitch/trunk/libs/openzap/src/ozmod/ozmod_sangoma_boost/sigboost.h</a></li>
<li><a href="#freeswitchtrunksrcmodapplicationsmod_commandsmod_commandsc">freeswitch/trunk/src/mod/applications/mod_commands/mod_commands.c</a></li>
<li><a href="#freeswitchtrunksrcmodapplicationsmod_valet_parkingmod_valet_parkingc">freeswitch/trunk/src/mod/applications/mod_valet_parking/mod_valet_parking.c</a></li>
<li><a href="#freeswitchtrunksrcmodapplicationsmod_voicemailmod_voicemailc">freeswitch/trunk/src/mod/applications/mod_voicemail/mod_voicemail.c</a></li>
<li><a href="#freeswitchtrunksrcmodcodecsmod_sangoma_codecmod_sangoma_codecc">freeswitch/trunk/src/mod/codecs/mod_sangoma_codec/mod_sangoma_codec.c</a></li>
<li><a href="#freeswitchtrunksrcmodendpointsmod_skinnymod_skinnyc">freeswitch/trunk/src/mod/endpoints/mod_skinny/mod_skinny.c</a></li>
<li><a href="#freeswitchtrunksrcmodendpointsmod_skinnyskinny_protocolc">freeswitch/trunk/src/mod/endpoints/mod_skinny/skinny_protocol.c</a></li>
<li><a href="#freeswitchtrunksrcmodendpointsmod_skinnyskinny_protocolh">freeswitch/trunk/src/mod/endpoints/mod_skinny/skinny_protocol.h</a></li>
<li><a href="#freeswitchtrunksrcmodendpointsmod_skinnyskinny_tablesc">freeswitch/trunk/src/mod/endpoints/mod_skinny/skinny_tables.c</a></li>
<li><a href="#freeswitchtrunksrcmodendpointsmod_skinnyskinny_tablesh">freeswitch/trunk/src/mod/endpoints/mod_skinny/skinny_tables.h</a></li>
<li><a href="#freeswitchtrunksrcmodendpointsmod_sofiasofia_presencec">freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_presence.c</a></li>
</ul>
</div>
<div id="patch">
<h3>Diff</h3>
<a id="freeswitchtrunkfscommcallcpp"></a>
<div class="modfile"><h4>Modified: freeswitch/trunk/fscomm/call.cpp ( => )</h4>
<pre class="diff"><span>
<span class="info">
Modified: freeswitch/trunk/fscomm/call.h
</span><span class="cx">===================================================================
</span></span></pre></div>
<a id="freeswitchtrunkfscommdebugtoolsconsolewindowcpp"></a>
<div class="modfile"><h4>Modified: freeswitch/trunk/fscomm/debugtools/consolewindow.cpp ( => )</h4>
<pre class="diff"><span>
<span class="info">
Modified: freeswitch/trunk/fscomm/mainwindow.cpp
</span><span class="cx">===================================================================
</span></span></pre></div>
<a id="freeswitchtrunkfscommmainwindowh"></a>
<div class="modfile"><h4>Modified: freeswitch/trunk/fscomm/mainwindow.h ( => )</h4>
<pre class="diff"><span>
<span class="info">
Modified: freeswitch/trunk/libs/freetdm/mod_freetdm/mod_freetdm.c
</span><span class="cx">===================================================================
</span></span></pre></div>
<a id="freeswitchtrunklibsfreetdmsrcftdm_configc"></a>
<div class="modfile"><h4>Modified: freeswitch/trunk/libs/freetdm/src/ftdm_config.c ( => )</h4>
<pre class="diff"><span>
<span class="info">
Modified: freeswitch/trunk/libs/freetdm/src/ftdm_io.c
</span><span class="cx">===================================================================
</span></span></pre></div>
<a id="freeswitchtrunklibsfreetdmsrcftdm_threadmutexc"></a>
<div class="modfile"><h4>Modified: freeswitch/trunk/libs/freetdm/src/ftdm_threadmutex.c ( => )</h4>
<pre class="diff"><span>
<span class="info">
Modified: freeswitch/trunk/libs/freetdm/src/ftmod/ftmod_sangoma_boost/ftmod_sangoma_boost.c
</span><span class="cx">===================================================================
</span><del>--- freeswitch/trunk/libs/freetdm/src/ftmod/ftmod_sangoma_boost/ftmod_sangoma_boost.c 2010-04-15 15:48:09 UTC (rev 17308)
</del><ins>+++ freeswitch/trunk/libs/freetdm/src/ftmod/ftmod_sangoma_boost/ftmod_sangoma_boost.c 2010-04-15 15:54:32 UTC (rev 17309)
</ins><span class="lines">@@ -92,7 +92,6 @@
</span><span class="cx"> typedef enum {
</span><span class="cx"> BST_FREE,
</span><span class="cx"> BST_WAITING,
</span><del>- BST_ACK,
</del><span class="cx"> BST_READY,
</span><span class="cx"> BST_FAIL
</span><span class="cx"> } sangoma_boost_request_status_t;
</span><span class="lines">@@ -109,6 +108,13 @@
</span><span class="cx"> int flags;
</span><span class="cx"> } sangoma_boost_request_t;
</span><span class="cx">
</span><ins>+typedef struct {
+ int call_setup_id;
+ int last_event_id;
+} sangoma_boost_call_t;
+
+#define CALL_DATA(ftdmchan) ((sangoma_boost_call_t*)((ftdmchan)->call_data))
+
</ins><span class="cx"> //#define MAX_REQ_ID FTDM_MAX_PHYSICAL_SPANS_PER_LOGICAL_SPAN * FTDM_MAX_CHANNELS_PHYSICAL_SPAN
</span><span class="cx"> #define MAX_REQ_ID 6000
</span><span class="cx">
</span><span class="lines">@@ -179,7 +185,7 @@
</span><span class="cx"> r = ++last_req;
</span><span class="cx">
</span><span class="cx"> if (r >= MAX_REQ_ID) {
</span><del>- r = i = last_req = 1;
</del><ins>+ r = last_req = 1;
</ins><span class="cx"> }
</span><span class="cx">
</span><span class="cx"> if (req_map[r]) {
</span><span class="lines">@@ -204,6 +210,25 @@
</span><span class="cx"> }
</span><span class="cx"> #define next_request_id() __next_request_id(__FUNCTION__, __LINE__)
</span><span class="cx">
</span><ins>+
+static void print_request_ids(void)
+{
+ sangoma_boost_request_id_t i = 0;
+
+ ftdm_mutex_lock(request_mutex);
+
+ for (i=1; i<= MAX_REQ_ID; i++){
+ if (req_map[i]) {
+ ftdm_log(FTDM_LOG_CRIT, "Used Request ID=%i\n",i);
+ }
+ }
+
+ ftdm_mutex_unlock(request_mutex);
+
+ return;
+}
+
+
</ins><span class="cx"> /**
</span><span class="cx"> * \brief Finds the channel that triggered an event
</span><span class="cx"> * \param span Span where to search the channel
</span><span class="lines">@@ -215,10 +240,26 @@
</span><span class="cx"> {
</span><span class="cx"> uint32_t i;
</span><span class="cx"> ftdm_channel_t *ftdmchan = NULL;
</span><ins>+
</ins><span class="cx"> ftdm_sangoma_boost_data_t *sangoma_boost_data = span->signal_data;
</span><span class="cx"> uint32_t targetspan = BOOST_EVENT_SPAN(sangoma_boost_data->sigmod, event);
</span><span class="cx"> uint32_t targetchan = BOOST_EVENT_CHAN(sangoma_boost_data->sigmod, event);
</span><span class="cx">
</span><ins>+ /* NC: Sanity check in case the call setup id does not relate
+ to span. This can happen if RESTART is received on a
+ full load. Where stray ACK messages can arrive after
+ a RESTART has taken place.
+ */
+ if (!span) {
+ ftdm_log(FTDM_LOG_CRIT, "No Span for Event=%s s%dc%d cid=%d\n",
+ BOOST_DECODE_EVENT_ID(event->event_id),
+ event->span,
+ event->chan,
+ event->call_setup_id);
+ return NULL;
+ }
+
+
</ins><span class="cx"> for(i = 1; i <= span->chan_count; i++) {
</span><span class="cx"> if (span->channels[i]->physical_span_id == targetspan && span->channels[i]->physical_chan_id == targetchan) {
</span><span class="cx"> ftdmchan = span->channels[i];
</span><span class="lines">@@ -276,12 +317,20 @@
</span><span class="cx"> * and PRI stack will retransmit a second SETUP after the first timeout, so
</span><span class="cx"> * we should allow for at least 8 seconds.
</span><span class="cx"> */
</span><ins>+
</ins><span class="cx"> int boost_request_timeout = 10000;
</span><span class="cx"> sangoma_boost_request_status_t st;
</span><span class="cx"> char dnis[128] = "";
</span><span class="cx"> char *gr = NULL;
</span><span class="cx"> uint32_t count = 0;
</span><span class="cx"> int tg=0;
</span><ins>+
+ /* NC: On large number of calls 10 seconds is not enough.
+ Resetting to 30 seconds. Especially on ss7 when
+ links are reset during large call volume */
+ if (!sangoma_boost_data->sigmod) {
+ boost_request_timeout = 30000;
+ }
</ins><span class="cx">
</span><span class="cx"> if (sangoma_boost_data->sigmod) {
</span><span class="cx"> ftdm_log(FTDM_LOG_CRIT, "This function should not be called when sigmod was configured in boost\n");
</span><span class="lines">@@ -290,21 +339,35 @@
</span><span class="cx"> }
</span><span class="cx">
</span><span class="cx"> if (ftdm_test_flag(span, FTDM_SPAN_SUSPENDED)) {
</span><del>- ftdm_log(FTDM_LOG_CRIT, "SPAN is not online.\n");
</del><ins>+ ftdm_log(FTDM_LOG_CRIT, "SPAN is Suspended.\n");
</ins><span class="cx"> *ftdmchan = NULL;
</span><span class="cx"> return FTDM_FAIL;
</span><span class="cx"> }
</span><del>-
- ftdm_set_string(dnis, caller_data->dnis.digits);
</del><span class="cx">
</span><ins>+ if (check_congestion(tg)) {
+ ftdm_log(FTDM_LOG_CRIT, "All circuits are busy. Trunk Group=%i (CONGESTION)\n",tg+1);
+ *ftdmchan = NULL;
+ return FTDM_FAIL;
+ }
+
+ if (count >= span->chan_count) {
+ ftdm_log(FTDM_LOG_CRIT, "All circuits are busy.\n");
+ *ftdmchan = NULL;
+ return FTDM_FAIL;
+ }
+
</ins><span class="cx"> r = next_request_id();
</span><span class="cx"> if (r == 0) {
</span><span class="cx"> ftdm_log(FTDM_LOG_CRIT, "All tanks ids are busy.\n");
</span><span class="cx"> *ftdmchan = NULL;
</span><span class="cx"> return FTDM_FAIL;
</span><span class="cx"> }
</span><del>- sangomabc_call_init(&event, caller_data->cid_num.digits, dnis, r);
</del><span class="cx">
</span><ins>+ /* After this point we must release request id before we leave the function
+ in case of an error. */
+
+ ftdm_set_string(dnis, caller_data->dnis.digits);
+
</ins><span class="cx"> if ((gr = strchr(dnis, '@'))) {
</span><span class="cx"> *gr++ = '\0';
</span><span class="cx"> }
</span><span class="lines">@@ -315,22 +378,14 @@
</span><span class="cx"> tg--;
</span><span class="cx"> }
</span><span class="cx"> }
</span><ins>+
+ sangomabc_call_init(&event, caller_data->cid_num.digits, dnis, r);
+
</ins><span class="cx"> event.trunk_group = tg;
</span><span class="cx">
</span><del>- if (check_congestion(tg)) {
- ftdm_log(FTDM_LOG_CRIT, "All circuits are busy. Trunk Group=%i (BOOST REQUESTED BACK OFF)\n",tg+1);
- *ftdmchan = NULL;
- return FTDM_FAIL;
- }
</del><span class="cx">
</span><span class="cx"> ftdm_span_channel_use_count(span, &count);
</span><span class="cx">
</span><del>- if (count >= span->chan_count) {
- ftdm_log(FTDM_LOG_CRIT, "All circuits are busy.\n");
- *ftdmchan = NULL;
- return FTDM_FAIL;
- }
-
</del><span class="cx"> if (gr && *(gr+1)) {
</span><span class="cx"> switch(*gr) {
</span><span class="cx"> case 'g':
</span><span class="lines">@@ -373,7 +428,7 @@
</span><span class="cx">
</span><span class="cx"> if (sangomabc_connection_write(&sangoma_boost_data->mcon, &event) <= 0) {
</span><span class="cx"> ftdm_log(FTDM_LOG_CRIT, "Failed to tx boost event [%s]\n", strerror(errno));
</span><del>- status = FTDM_FAIL;
</del><ins>+ status = OUTBOUND_REQUESTS[r].status = FTDM_FAIL;
</ins><span class="cx"> if (!sangoma_boost_data->sigmod) {
</span><span class="cx"> *ftdmchan = NULL;
</span><span class="cx"> }
</span><span class="lines">@@ -387,7 +442,7 @@
</span><span class="cx"> if (!sangoma_boost_data->sigmod) {
</span><span class="cx"> *ftdmchan = NULL;
</span><span class="cx"> }
</span><del>- ftdm_log(FTDM_LOG_CRIT, "s%dc%d: Csid:%d Timed out waiting for boost channel request response, current status: BST_WAITING\n", (*ftdmchan)->physical_span_id, (*ftdmchan)->physical_chan_id, r);
</del><ins>+ ftdm_log(FTDM_LOG_CRIT, "Csid:%d Timed out waiting for boost channel request response, current status: BST_WAITING\n", r);
</ins><span class="cx"> goto done;
</span><span class="cx"> }
</span><span class="cx"> }
</span><span class="lines">@@ -494,6 +549,7 @@
</span><span class="cx">
</span><span class="cx"> ftdm_log(FTDM_LOG_DEBUG, "Dialing number %s over boost channel with request id %d\n", event.called_number_digits, r);
</span><span class="cx"> if (sangomabc_connection_write(&sangoma_boost_data->mcon, &event) <= 0) {
</span><ins>+ release_request_id(r);
</ins><span class="cx"> ftdm_log(FTDM_LOG_CRIT, "Failed to tx boost event [%s]\n", strerror(errno));
</span><span class="cx"> return FTDM_FAIL;
</span><span class="cx"> }
</span><span class="lines">@@ -550,7 +606,12 @@
</span><span class="cx"> uint32_t event_span = BOOST_EVENT_SPAN(mcon->sigmod, event);
</span><span class="cx"> uint32_t event_chan = BOOST_EVENT_CHAN(mcon->sigmod, event);
</span><span class="cx">
</span><ins>+
</ins><span class="cx"> if (nack_map[event->call_setup_id]) {
</span><ins>+ /* In this scenario outgoing call was alrady stopped
+ via NACK and now we are expecting an NACK_ACK.
+ If we receive an ACK its a race condition thus
+ ignor it */
</ins><span class="cx"> return;
</span><span class="cx"> }
</span><span class="cx">
</span><span class="lines">@@ -607,15 +668,43 @@
</span><span class="cx"> OUTBOUND_REQUESTS[event->call_setup_id].status = BST_READY;
</span><span class="cx"> return;
</span><span class="cx"> }
</span><del>- }
</del><ins>+ } else {
</ins><span class="cx">
</span><ins>+ ftdm_assert(!mcon->sigmod, "CALL STOP ACK: Invalid Sigmod Path");
+
+ if ((ftdmchan = find_ftdmchan(OUTBOUND_REQUESTS[event->call_setup_id].span, (sangomabc_short_event_t*)event, 1))) {
+ int r;
+ /* NC: If we get CALL START ACK and channel is in active state
+ then we are completely out of sync with the other end.
+ Treat CALL START ACK as CALL STOP and hangup the current call.
+ */
+
+ if (ftdmchan->state == FTDM_CHANNEL_STATE_UP ||
+ ftdmchan->state == FTDM_CHANNEL_STATE_PROGRESS_MEDIA ||
+ ftdmchan->state == FTDM_CHANNEL_STATE_PROGRESS) {
+ ftdm_log(FTDM_LOG_CRIT, "FTDM_CHAN STATE UP/PROG/PROG_MEDIA -> Changed to HANGUP %d:%d\n", event->span+1,event->chan+1);
+ ftdm_set_state_r(ftdmchan, FTDM_CHANNEL_STATE_HANGUP, 0, r);
+
+ } else if (ftdm_test_sflag(ftdmchan, SFLAG_HANGUP)) {
+ /* Do nothing because outgoing STOP will generaate a stop ack */
+
+ } else {
+ ftdm_log(FTDM_LOG_CRIT, "FTDM_CHAN STATE INVALID %s on IN CALL ACK %d:%d\n", ftdm_channel_state2str(ftdmchan->state),event->span+1,event->chan+1);
+
+ }
+ ftdmchan=NULL;
+ }
+ }
+
+
</ins><span class="cx"> if (!ftdmchan) {
</span><span class="cx"> ftdm_log(FTDM_LOG_CRIT, "START ACK CANT FIND A CHAN %d:%d\n", BOOST_EVENT_SPAN(mcon->sigmod, event), BOOST_EVENT_CHAN(mcon->sigmod, event));
</span><span class="cx"> } else {
</span><span class="cx"> /* only reason to be here is failed to open channel when we we're in sigmod */
</span><span class="cx"> ftdm_set_state_locked(ftdmchan, FTDM_CHANNEL_STATE_TERMINATING);
</span><ins>+ ftdm_set_sflag(ftdmchan, SFLAG_SENT_FINAL_MSG);
</ins><span class="cx"> }
</span><del>- ftdm_set_sflag(ftdmchan, SFLAG_SENT_FINAL_MSG);
</del><ins>+
</ins><span class="cx"> sangomabc_exec_command(mcon,
</span><span class="cx"> event->span,
</span><span class="cx"> event->chan,
</span><span class="lines">@@ -636,7 +725,7 @@
</span><span class="cx"> {
</span><span class="cx"> ftdm_channel_t *ftdmchan;
</span><span class="cx"> int r = 0;
</span><del>-
</del><ins>+
</ins><span class="cx"> if ((ftdmchan = find_ftdmchan(span, event, 1))) {
</span><span class="cx"> ftdm_sangoma_boost_data_t *sangoma_boost_data = ftdmchan->span->signal_data;
</span><span class="cx"> ftdm_mutex_lock(ftdmchan->mutex);
</span><span class="lines">@@ -677,6 +766,7 @@
</span><span class="cx"> }
</span><span class="cx"> }
</span><span class="cx">
</span><ins>+
</ins><span class="cx"> /**
</span><span class="cx"> * \brief Handler for call start nack event
</span><span class="cx"> * \param span Span where event was fired
</span><span class="lines">@@ -718,7 +808,7 @@
</span><span class="cx"> if (event->call_setup_id) {
</span><span class="cx"> if (sangoma_boost_data->sigmod) {
</span><span class="cx"> ftdmchan = OUTBOUND_REQUESTS[event->call_setup_id].ftdmchan;
</span><del>- ftdmchan->call_data = (void*)(intptr_t)event->event_id;
</del><ins>+ CALL_DATA(ftdmchan)->last_event_id = event->event_id;
</ins><span class="cx"> ftdm_set_state_locked(ftdmchan, FTDM_CHANNEL_STATE_TERMINATING);
</span><span class="cx"> } else {
</span><span class="cx"> sangomabc_exec_command(mcon,
</span><span class="lines">@@ -740,7 +830,7 @@
</span><span class="cx"> /* if there is no call setup id this should not be an outbound channel for sure */
</span><span class="cx"> ftdm_assert(!ftdm_test_flag(ftdmchan, FTDM_CHANNEL_OUTBOUND), "Yay, outbound flag should not be set here!\n");
</span><span class="cx">
</span><del>- ftdmchan->call_data = (void*)(intptr_t)event->event_id;
</del><ins>+ CALL_DATA(ftdmchan)->last_event_id = event->event_id;
</ins><span class="cx"> ftdm_mutex_lock(ftdmchan->mutex);
</span><span class="cx"> ftdm_set_state_r(ftdmchan, FTDM_CHANNEL_STATE_TERMINATING, 0, r);
</span><span class="cx"> if (r == FTDM_STATE_CHANGE_SUCCESS) {
</span><span class="lines">@@ -793,7 +883,16 @@
</span><span class="cx">
</span><span class="cx"> ftdm_mutex_lock(ftdmchan->mutex);
</span><span class="cx">
</span><del>- if (ftdm_test_sflag(ftdmchan, SFLAG_HANGUP)) {
</del><ins>+ if (ftdm_test_sflag(ftdmchan, SFLAG_HANGUP) ||
+ ftdmchan->state == FTDM_CHANNEL_STATE_DOWN ||
+ ftdmchan->state == FTDM_CHANNEL_STATE_TERMINATING) {
+
+ /* NC: Checking for state DOWN because ss7box can
+ send CALL_STOP twice in a row. If we do not check for
+ STATE_DOWN we will set the state back to termnating
+ and block the channel forever
+ */
+
</ins><span class="cx"> /* racing condition where both sides initiated a hangup
</span><span class="cx"> * Do not change current state as channel is already clearing
</span><span class="cx"> * itself through local initiated hangup */
</span><span class="lines">@@ -848,8 +947,18 @@
</span><span class="cx">
</span><span class="cx"> if ((ftdmchan = find_ftdmchan(span, event, 1))) {
</span><span class="cx"> ftdm_mutex_lock(ftdmchan->mutex);
</span><del>- if (ftdmchan->state == FTDM_CHANNEL_STATE_HOLD) {
</del><ins>+
+ if (ftdm_test_sflag(ftdmchan, SFLAG_HANGUP) ||
+ ftdmchan->state == FTDM_CHANNEL_STATE_DOWN ||
+ ftdmchan->state == FTDM_CHANNEL_STATE_TERMINATING) {
+
+ /* NC: Do nothing here because we are in process
+ of stopping the call. So ignore the ANSWER. */
+ ftdm_log(FTDM_LOG_CRIT, "ANSWER BUT CALL IS HANGUP %d:%d\n", event->span+1,event->chan+1);
+
+ } else if (ftdmchan->state == FTDM_CHANNEL_STATE_HOLD) {
</ins><span class="cx"> ftdmchan->init_state = FTDM_CHANNEL_STATE_UP;
</span><ins>+
</ins><span class="cx"> } else {
</span><span class="cx"> int r = 0;
</span><span class="cx"> ftdm_set_state_r(ftdmchan, FTDM_CHANNEL_STATE_UP, 0, r);
</span><span class="lines">@@ -881,6 +990,12 @@
</span><span class="cx"> if (!(ftdmchan = find_ftdmchan(span, (sangomabc_short_event_t*)event, 0))) {
</span><span class="cx"> if ((ftdmchan = find_ftdmchan(span, (sangomabc_short_event_t*)event, 1))) {
</span><span class="cx"> int r;
</span><ins>+
+ /* NC: If we get CALL START and channel is in active state
+ then we are completely out of sync with the other end.
+ Treat CALL START as CALL STOP and hangup the current call.
+ */
+
</ins><span class="cx"> if (ftdmchan->state == FTDM_CHANNEL_STATE_UP) {
</span><span class="cx"> ftdm_log(FTDM_LOG_CRIT, "ZCHAN STATE UP -> Changed to TERMINATING %d:%d\n", BOOST_EVENT_SPAN(mcon->sigmod, event), BOOST_EVENT_CHAN(mcon->sigmod, event));
</span><span class="cx"> ftdm_set_state_r(ftdmchan, FTDM_CHANNEL_STATE_TERMINATING, 0, r);
</span><span class="lines">@@ -1179,8 +1294,12 @@
</span><span class="cx"> handle_call_done(span, mcon, event);
</span><span class="cx"> break;
</span><span class="cx"> case SIGBOOST_EVENT_CALL_START_NACK_ACK:
</span><del>- handle_call_done(span, mcon, event);
- nack_map[event->call_setup_id] = 0;
</del><ins>+ /* On NACK ack span chan are always invalid
+ All there is to do is to clear the id */
+ if (event->call_setup_id) {
+ nack_map[event->call_setup_id] = 0;
+ release_request_id(event->call_setup_id);
+ }
</ins><span class="cx"> break;
</span><span class="cx"> case SIGBOOST_EVENT_INSERT_CHECK_LOOP:
</span><span class="cx"> handle_call_loop_start(span, mcon, event);
</span><span class="lines">@@ -1246,7 +1365,7 @@
</span><span class="cx"> if (!ftdm_test_sflag(ftdmchan, SFLAG_SENT_FINAL_MSG)) {
</span><span class="cx"> ftdm_set_sflag_locked(ftdmchan, SFLAG_SENT_FINAL_MSG);
</span><span class="cx">
</span><del>- if (ftdmchan->call_data && ((uint32_t)(intptr_t)ftdmchan->call_data == SIGBOOST_EVENT_CALL_START_NACK)) {
</del><ins>+ if (ftdmchan->call_data && CALL_DATA(ftdmchan)->last_event_id == SIGBOOST_EVENT_CALL_START_NACK) {
</ins><span class="cx"> sangomabc_exec_command(mcon,
</span><span class="cx"> BOOST_SPAN(ftdmchan),
</span><span class="cx"> BOOST_CHAN(ftdmchan),
</span><span class="lines">@@ -1266,7 +1385,8 @@
</span><span class="cx"> }
</span><span class="cx"> }
</span><span class="cx"> ftdmchan->sflags = 0;
</span><del>- ftdmchan->call_data = NULL;
</del><ins>+ memset(ftdmchan->call_data,0,sizeof(sangoma_boost_call_t));
+
</ins><span class="cx"> if (sangoma_boost_data->sigmod && call_stopped_ack_sent) {
</span><span class="cx"> /* we dont want to call ftdm_channel_done just yet until call released is received */
</span><span class="cx"> ftdm_log(FTDM_LOG_DEBUG, "Waiting for call release confirmation before declaring chan %d:%d as available \n",
</span><span class="lines">@@ -1457,13 +1577,17 @@
</span><span class="cx"> uint32_t j;
</span><span class="cx"> ftdm_clear_flag_locked(span, FTDM_SPAN_STATE_CHANGE);
</span><span class="cx"> if (susp) {
</span><del>- for (j = 0; j <= span->chan_count; j++) {
- ftdm_mutex_lock(span->channels[j]->mutex);
- ftdm_clear_flag((span->channels[j]), FTDM_CHANNEL_STATE_CHANGE);
- ftdm_channel_set_state(span->channels[j], FTDM_CHANNEL_STATE_RESTART, 0);
- state_advance(span->channels[j]);
- ftdm_channel_complete_state(span->channels[j]);
- ftdm_mutex_unlock(span->channels[j]->mutex);
</del><ins>+ for(j = 1; j <= span->chan_count; j++) {
+ if (ftdm_test_flag((span->channels[j]), FTDM_CHANNEL_STATE_CHANGE) || susp) {
+ ftdm_mutex_lock(span->channels[j]->mutex);
+ ftdm_clear_flag((span->channels[j]), FTDM_CHANNEL_STATE_CHANGE);
+ if (susp && span->channels[j]->state != FTDM_CHANNEL_STATE_DOWN) {
+ ftdm_channel_set_state(span->channels[j], FTDM_CHANNEL_STATE_RESTART, 0);
+ }
+ state_advance(span->channels[j]);
+ ftdm_channel_complete_state(span->channels[j]);
+ ftdm_mutex_unlock(span->channels[j]->mutex);
+ }
</ins><span class="cx"> }
</span><span class="cx"> } else {
</span><span class="cx"> while ((ftdmchan = ftdm_queue_dequeue(span->pendingchans))) {
</span><span class="lines">@@ -1642,8 +1766,8 @@
</span><span class="cx"> sangoma_boost_data->iteration = 0;
</span><span class="cx"> }
</span><span class="cx"> #endif
</span><del>- res = ftdm_interrupt_multiple_wait(ints, numints, -1);
- if (FTDM_SUCCESS != res) {
</del><ins>+ res = ftdm_interrupt_multiple_wait(ints, numints, 100);
+ if (FTDM_SUCCESS != res && FTDM_TIMEOUT != res) {
</ins><span class="cx"> ftdm_log(FTDM_LOG_CRIT, "Unexpected return value from interrupt waiting: %d\n", res);
</span><span class="cx"> return -1;
</span><span class="cx"> }
</span><span class="lines">@@ -1730,7 +1854,6 @@
</span><span class="cx">
</span><span class="cx"> if (ftdm_boost_wait_event(span) < 0) {
</span><span class="cx"> ftdm_log(FTDM_LOG_ERROR, "ftdm_boost_wait_event failed\n");
</span><del>- goto error;
</del><span class="cx"> }
</span><span class="cx">
</span><span class="cx"> while ((event = ftdm_boost_read_event(span))) {
</span><span class="lines">@@ -1743,7 +1866,6 @@
</span><span class="cx">
</span><span class="cx"> goto end;
</span><span class="cx">
</span><del>-error:
</del><span class="cx"> ftdm_log(FTDM_LOG_CRIT, "Boost event processing Error!\n");
</span><span class="cx">
</span><span class="cx"> end:
</span><span class="lines">@@ -1758,7 +1880,38 @@
</span><span class="cx"> return NULL;
</span><span class="cx"> }
</span><span class="cx">
</span><ins>+#if 0
+static int sigmod_ss7box_isup_exec_cmd(ftdm_stream_handle_t *stream, char *cmd)
+{
+ FILE *fp;
+ int status=0;
+ char path[1024];
+
+ fp = popen(cmd, "r");
+ if (fp == NULL) {
+ stream->write_function(stream, "%s: -ERR failed to execute cmd: %s\n",
+ __FILE__,cmd);
+ return -1;
+ }
+
+ while (fgets(path, sizeof(path)-1, fp) != NULL) {
+ path[sizeof(path)-1]='\0';
+ stream->write_function(stream,"%s", path);
+ }
+
+
+ status = pclose(fp);
+ if (status == -1) {
+ /* Error reported by pclose() */
+ } else {
+ /* Use macros described under wait() to inspect `status' in order
+ to determine success/failure of command executed by popen() */
+ }
</ins><span class="cx">
</span><ins>+ return status;
+}
+#endif
+
</ins><span class="cx"> #define FTDM_BOOST_SYNTAX "list sigmods | <sigmod_name> <command>"
</span><span class="cx"> /**
</span><span class="cx"> * \brief API function to kill or debug a sangoma_boost span
</span><span class="lines">@@ -1780,11 +1933,63 @@
</span><span class="cx"> if (!strcasecmp(argv[0], "list")) {
</span><span class="cx"> if (!strcasecmp(argv[1], "sigmods")) {
</span><span class="cx"> if (ftdm_sangoma_boost_list_sigmods(stream) != FTDM_SUCCESS) {
</span><del>- stream->write_function(stream, "%s: -ERR failed to execute cmd\n", __FILE__);
</del><ins>+ stream->write_function(stream, "-ERR failed to list sigmods\n");
</ins><span class="cx"> goto done;
</span><span class="cx"> }
</span><span class="cx"> goto done;
</span><span class="cx"> }
</span><ins>+
+ if (!strcasecmp(argv[1], "ids")) {
+ print_request_ids();
+ goto done;
+ }
+
+#ifndef __WINDOWS__
+#if 0
+/* NC: This code crashes the kernel due to fork on heavy fs load */
+ } else if (!strcasecmp(argv[0], "ss7box_isupd_ckt")) {
+
+ if (!strcasecmp(argv[1], "used")) {
+ stream->write_function(stream, "ss7box_isupd: in use\n", FTDM_BOOST_SYNTAX);
+ sigmod_ss7box_isup_exec_cmd(stream, (char*) "ckt_report.sh inuse");
+ } else if (!strcasecmp(argv[1], "reset")) {
+ stream->write_function(stream, "ss7box_isupd: in reset\n", FTDM_BOOST_SYNTAX);
+ sigmod_ss7box_isup_exec_cmd(stream, (char*) "ckt_report.sh reset");
+ } else if (!strcasecmp(argv[1], "ready")) {
+ stream->write_function(stream, "ss7box_isupd: ready \n", FTDM_BOOST_SYNTAX);
+ sigmod_ss7box_isup_exec_cmd(stream, (char*) "ckt_report.sh free");
+ } else {
+ stream->write_function(stream, "ss7box_isupd: list\n", FTDM_BOOST_SYNTAX);
+ sigmod_ss7box_isup_exec_cmd(stream, (char*) "ckt_report.sh");
+ }
+
+ goto done;
+#endif
+#endif
+ } else if (!strcasecmp(argv[0], "restart")) {
+ sangomabc_connection_t *pcon;
+ ftdm_sangoma_boost_data_t *sangoma_boost_data;
+ ftdm_span_t *span;
+ int err = ftdm_span_find_by_name(argv[1], &span);
+ if (FTDM_SUCCESS != err) {
+ stream->write_function(stream, "-ERR failed to find span by name %s\n",argv[1]);
+ goto done;
+ }
+
+ sangoma_boost_data = span->signal_data;
+ pcon = &sangoma_boost_data->pcon;
+
+ /* No need to set any span flags because
+ our RESTART will generate a RESTART from the sig daemon */
+ sangomabc_exec_commandp(pcon,
+ 0,
+ 0,
+ -1,
+ SIGBOOST_EVENT_SYSTEM_RESTART,
+ 0);
+
+ goto done;
+
</ins><span class="cx"> } else {
</span><span class="cx"> boost_sigmod_interface_t *sigmod_iface = NULL;
</span><span class="cx"> sigmod_iface = hashtable_search(g_boost_modules_hash, argv[0]);
</span><span class="lines">@@ -1822,7 +2027,7 @@
</span><span class="cx"> */
</span><span class="cx"> static FIO_IO_LOAD_FUNCTION(ftdm_sangoma_boost_io_init)
</span><span class="cx"> {
</span><del>- assert(fio != NULL);
</del><ins>+ ftdm_assert(fio != NULL, "fio is NULL");
</ins><span class="cx"> memset(&ftdm_sangoma_boost_interface, 0, sizeof(ftdm_sangoma_boost_interface));
</span><span class="cx">
</span><span class="cx"> ftdm_sangoma_boost_interface.name = "boost";
</span><span class="lines">@@ -2205,6 +2410,7 @@
</span><span class="cx"> ftdm_dso_lib_t lib = NULL;
</span><span class="cx"> char path[255] = "";
</span><span class="cx"> char *err = NULL;
</span><ins>+ int j = 0;
</ins><span class="cx"> unsigned paramindex = 0;
</span><span class="cx"> ftdm_status_t rc = FTDM_SUCCESS;
</span><span class="cx">
</span><span class="lines">@@ -2299,6 +2505,14 @@
</span><span class="cx"> ftdm_set_string(sangoma_boost_data->mcon.cfg.remote_ip, remote_ip);
</span><span class="cx"> sangoma_boost_data->mcon.cfg.remote_port = remote_port;
</span><span class="cx"> }
</span><ins>+
+ for (j = 1; j <= span->chan_count; j++) {
+ span->channels[j]->call_data = ftdm_calloc(1,sizeof(sangoma_boost_call_t));
+ if (!span->channels[j]->call_data) {
+ FAIL_CONFIG_RETURN(FTDM_FAIL);
+ }
+ }
+
</ins><span class="cx"> span->signal_cb = sig_cb;
</span><span class="cx"> span->start = ftdm_sangoma_boost_start;
</span><span class="cx"> span->stop = ftdm_sangoma_boost_stop;
</span></span></pre></div>
<a id="freeswitchtrunklibsfreetdmsrcftmodftmod_sangoma_boostsangoma_boost_clientc"></a>
<div class="modfile"><h4>Modified: freeswitch/trunk/libs/freetdm/src/ftmod/ftmod_sangoma_boost/sangoma_boost_client.c ( => )</h4>
<pre class="diff"><span>
<span class="info">
Modified: freeswitch/trunk/libs/freetdm/src/ftmod/ftmod_sangoma_boost/sigboost.h
</span><span class="cx">===================================================================
</span></span></pre></div>
<a id="freeswitchtrunklibsfreetdmsrcincludefreetdmh"></a>
<div class="modfile"><h4>Modified: freeswitch/trunk/libs/freetdm/src/include/freetdm.h ( => )</h4>
<pre class="diff"><span>
<span class="info">
Modified: freeswitch/trunk/libs/freetdm/src/include/ftdm_types.h
</span><span class="cx">===================================================================
</span></span></pre></div>
<a id="freeswitchtrunklibsopenzapsrcozmodozmod_sangoma_boostozmod_sangoma_boostc"></a>
<div class="modfile"><h4>Modified: freeswitch/trunk/libs/openzap/src/ozmod/ozmod_sangoma_boost/ozmod_sangoma_boost.c (17308 => 17309)</h4>
<pre class="diff"><span>
<span class="info">--- freeswitch/trunk/libs/openzap/src/ozmod/ozmod_sangoma_boost/ozmod_sangoma_boost.c 2010-04-15 15:48:09 UTC (rev 17308)
+++ freeswitch/trunk/libs/openzap/src/ozmod/ozmod_sangoma_boost/ozmod_sangoma_boost.c 2010-04-15 15:54:32 UTC (rev 17309)
</span><span class="lines">@@ -344,7 +344,6 @@
</span><span class="cx"> if (sangomabc_connection_write(&sangoma_boost_data->mcon, &event) <= 0) {
</span><span class="cx"> zap_log(ZAP_LOG_CRIT, "Failed to tx on ISUP socket [%s]\n", strerror(errno));
</span><span class="cx"> status = ZAP_FAIL;
</span><del>- OUTBOUND_REQUESTS[r].status = ZAP_FAIL;
</del><span class="cx"> *zchan = NULL;
</span><span class="cx"> goto done;
</span><span class="cx"> }
</span><span class="lines">@@ -352,7 +351,7 @@
</span><span class="cx"> while(zap_running() && OUTBOUND_REQUESTS[r].status == BST_WAITING) {
</span><span class="cx"> zap_sleep(1);
</span><span class="cx"> if (--sanity <= 0) {
</span><del>- status = ZAP_FAIL;
</del><ins>+ status = ZAP_FAIL;
</ins><span class="cx"> *zchan = NULL;
</span><span class="cx"> goto done;
</span><span class="cx"> }
</span><span class="lines">@@ -457,18 +456,13 @@
</span><span class="cx"> return;
</span><span class="cx"> }
</span><span class="cx">
</span><ins>+ OUTBOUND_REQUESTS[event->call_setup_id].event = *event;
+ SETUP_GRID[event->span][event->chan] = event->call_setup_id;
</ins><span class="cx">
</span><del>-
</del><span class="cx"> if ((zchan = find_zchan(OUTBOUND_REQUESTS[event->call_setup_id].span, event, 0))) {
</span><span class="cx"> if (zap_channel_open_chan(zchan) != ZAP_SUCCESS) {
</span><span class="cx"> zap_log(ZAP_LOG_ERROR, "OPEN ERROR [%s]\n", zchan->last_error);
</span><span class="cx"> } else {
</span><del>-
- /* Only bind the setup id to GRID when we are sure that channel is ready
- otherwise we could overwite the original call */
- OUTBOUND_REQUESTS[event->call_setup_id].event = *event;
- SETUP_GRID[event->span][event->chan] = event->call_setup_id;
-
</del><span class="cx"> zap_set_flag(zchan, ZAP_CHANNEL_OUTBOUND);
</span><span class="cx"> zap_set_flag_locked(zchan, ZAP_CHANNEL_INUSE);
</span><span class="cx"> zchan->extra_id = event->call_setup_id;
</span><span class="lines">@@ -505,20 +499,16 @@
</span><span class="cx"> if (zchan->state == ZAP_CHANNEL_STATE_UP ||
</span><span class="cx"> zchan->state == ZAP_CHANNEL_STATE_PROGRESS_MEDIA ||
</span><span class="cx"> zchan->state == ZAP_CHANNEL_STATE_PROGRESS) {
</span><del>- zap_log(ZAP_LOG_CRIT, "ZCHAN CALL ACK STATE %s -> Changed to HANGUP %d:%d\n",
- zap_channel_state2str(zchan->state),event->span+1,event->chan+1);
- zap_set_state_r(zchan, ZAP_CHANNEL_STATE_TERMINATING, 0, r);
</del><ins>+ zap_log(ZAP_LOG_CRIT, "ZCHAN STATE UP/PROG/PROG_MEDIA -> Changed to HANGUP %d:%d\n", event->span+1,event->chan+1);
+ zap_set_state_r(zchan, ZAP_CHANNEL_STATE_HANGUP, 0, r);
</ins><span class="cx">
</span><del>- } else if (zchan->state == ZAP_CHANNEL_STATE_HANGUP || zap_test_sflag(zchan, SFLAG_HANGUP)) {
- zap_log(ZAP_LOG_CRIT, "ZCHAN CALL ACK STATE HANGUP -> Changed to HANGUP %d:%d\n", event->span+1,event->chan+1);
- zap_set_state_r(zchan, ZAP_CHANNEL_STATE_HANGUP_COMPLETE, 0, r);
</del><ins>+ } else if (zap_test_sflag(zchan, SFLAG_HANGUP)) {
</ins><span class="cx"> /* Do nothing because outgoing STOP will generaate a stop ack */
</span><span class="cx">
</span><span class="cx"> } else {
</span><del>- zap_log(ZAP_LOG_CRIT, "ZCHAN CALL ACK STATE INVALID %s s%dc%d\n",
- zap_channel_state2str(zchan->state),event->span+1,event->chan+1);
</del><ins>+ zap_log(ZAP_LOG_CRIT, "ZCHAN STATE INVALID %s on IN CALL ACK %d:%d\n", zap_channel_state2str(zchan->state),event->span+1,event->chan+1);
+
</ins><span class="cx"> }
</span><del>- zap_set_sflag(zchan, SFLAG_SENT_FINAL_MSG);
</del><span class="cx"> zchan=NULL;
</span><span class="cx"> }
</span><span class="cx"> }
</span><span class="lines">@@ -528,10 +518,7 @@
</span><span class="cx"> //printf("WTF BAD ACK2 %d:%d (%d:%d) CSid=%d xtra_id=%d out=%d state=%s\n", zchan->span_id, zchan->chan_id, event->span+1,event->chan+1, event->call_setup_id, zchan->extra_id, zap_test_flag(zchan, ZAP_CHANNEL_OUTBOUND), zap_channel_state2str(zchan->state));
</span><span class="cx"> }
</span><span class="cx">
</span><del>- if (zchan) {
- zap_set_sflag(zchan, SFLAG_SENT_FINAL_MSG);
- }
-
</del><ins>+ zap_set_sflag(zchan, SFLAG_SENT_FINAL_MSG);
</ins><span class="cx"> zap_log(ZAP_LOG_CRIT, "START ACK CANT FIND A CHAN %d:%d\n", event->span+1,event->chan+1);
</span><span class="cx"> sangomabc_exec_command(mcon,
</span><span class="cx"> event->span,
</span><span class="lines">@@ -790,24 +777,17 @@
</span><span class="cx"> then we are completely out of sync with the other end.
</span><span class="cx"> Treat CALL START as CALL STOP and hangup the current call.
</span><span class="cx"> */
</span><del>-
- if (zchan->state == ZAP_CHANNEL_STATE_UP ||
- zchan->state == ZAP_CHANNEL_STATE_PROGRESS_MEDIA ||
- zchan->state == ZAP_CHANNEL_STATE_PROGRESS) {
- zap_log(ZAP_LOG_CRIT, "ZCHAN CALL STATE %s -> Changed to TERMINATING %d:%d\n",
- zap_channel_state2str(zchan->state),event->span+1,event->chan+1);
</del><ins>+
+ if (zchan->state == ZAP_CHANNEL_STATE_UP) {
+ zap_log(ZAP_LOG_CRIT, "ZCHAN STATE UP -> Changed to TERMINATING %d:%d\n", event->span+1,event->chan+1);
</ins><span class="cx"> zap_set_state_r(zchan, ZAP_CHANNEL_STATE_TERMINATING, 0, r);
</span><del>-
- } else if (zchan->state == ZAP_CHANNEL_STATE_HANGUP || zap_test_sflag(zchan, SFLAG_HANGUP)) {
- zap_log(ZAP_LOG_CRIT, "ZCHAN CALL STATE HANGUP -> Changed to HANGUP %d:%d\n", event->span+1,event->chan+1);
</del><ins>+ } else if (zap_test_sflag(zchan, SFLAG_HANGUP)) {
+ zap_log(ZAP_LOG_CRIT, "ZCHAN STATE HANGUP -> Changed to HANGUP COMPLETE %d:%d\n", event->span+1,event->chan+1);
</ins><span class="cx"> zap_set_state_r(zchan, ZAP_CHANNEL_STATE_HANGUP_COMPLETE, 0, r);
</span><del>- /* Do nothing because outgoing STOP will generaate a stop ack */
-
</del><span class="cx"> } else {
</span><del>- zap_log(ZAP_LOG_CRIT, "ZCHAN CALL ACK STATE INVALID %s s%dc%d\n",
- zap_channel_state2str(zchan->state),event->span+1,event->chan+1);
- }
</del><ins>+ zap_log(ZAP_LOG_CRIT, "ZCHAN STATE INVALID %s on IN CALL %d:%d\n", zap_channel_state2str(zchan->state),event->span+1,event->chan+1);
</ins><span class="cx">
</span><ins>+ }
</ins><span class="cx"> zap_set_sflag(zchan, SFLAG_SENT_FINAL_MSG);
</span><span class="cx"> zchan=NULL;
</span><span class="cx"> }
</span></span></pre></div>
<a id="freeswitchtrunklibsopenzapsrcozmodozmod_sangoma_boostsigboosth"></a>
<div class="modfile"><h4>Modified: freeswitch/trunk/libs/openzap/src/ozmod/ozmod_sangoma_boost/sigboost.h ( => )</h4>
<pre class="diff"><span>
<span class="info">
Modified: freeswitch/trunk/src/mod/applications/mod_commands/mod_commands.c
</span><span class="cx">===================================================================
</span></span></pre></div>
<a id="freeswitchtrunksrcmodapplicationsmod_valet_parkingmod_valet_parkingc"></a>
<div class="modfile"><h4>Modified: freeswitch/trunk/src/mod/applications/mod_valet_parking/mod_valet_parking.c ( => )</h4>
<pre class="diff"><span>
<span class="info">
Modified: freeswitch/trunk/src/mod/applications/mod_voicemail/mod_voicemail.c
</span><span class="cx">===================================================================
</span></span></pre></div>
<a id="freeswitchtrunksrcmodcodecsmod_sangoma_codecmod_sangoma_codecc"></a>
<div class="modfile"><h4>Modified: freeswitch/trunk/src/mod/codecs/mod_sangoma_codec/mod_sangoma_codec.c ( => )</h4>
<pre class="diff"><span>
<span class="info">
Modified: freeswitch/trunk/src/mod/endpoints/mod_skinny/mod_skinny.c
</span><span class="cx">===================================================================
</span></span></pre></div>
<a id="freeswitchtrunksrcmodendpointsmod_skinnyskinny_protocolc"></a>
<div class="modfile"><h4>Modified: freeswitch/trunk/src/mod/endpoints/mod_skinny/skinny_protocol.c ( => )</h4>
<pre class="diff"><span>
<span class="info">
Modified: freeswitch/trunk/src/mod/endpoints/mod_skinny/skinny_protocol.h
</span><span class="cx">===================================================================
</span></span></pre></div>
<a id="freeswitchtrunksrcmodendpointsmod_skinnyskinny_tablesc"></a>
<div class="modfile"><h4>Modified: freeswitch/trunk/src/mod/endpoints/mod_skinny/skinny_tables.c ( => )</h4>
<pre class="diff"><span>
<span class="info">
Modified: freeswitch/trunk/src/mod/endpoints/mod_skinny/skinny_tables.h
</span><span class="cx">===================================================================
</span></span></pre></div>
<a id="freeswitchtrunksrcmodendpointsmod_sofiasofia_presencec"></a>
<div class="modfile"><h4>Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_presence.c ( => )</h4>
<pre class="diff"><span>
<span class="info">
</span></span></pre>
</div>
</div>
<div id="footer">See you at ClueCon</div>
</body>
</html>