]> git.ipfire.org Git - thirdparty/freeswitch.git/commitdiff
Freetdm: ISDN fix for link not always recovering after T1/E1 alarm
authorDavid Yat Sin <dyatsin@sangoma.com>
Tue, 11 Sep 2012 05:22:31 +0000 (01:22 -0400)
committerDavid Yat Sin <dyatsin@sangoma.com>
Tue, 11 Sep 2012 05:22:31 +0000 (01:22 -0400)
libs/freetdm/src/ftmod/ftmod_sangoma_isdn/ftmod_sangoma_isdn.c
libs/freetdm/src/ftmod/ftmod_sangoma_isdn/ftmod_sangoma_isdn.h
libs/freetdm/src/ftmod/ftmod_sangoma_isdn/ftmod_sangoma_isdn_stack_cfg.c
libs/freetdm/src/ftmod/ftmod_sangoma_isdn/ftmod_sangoma_isdn_stack_cntrl.c
libs/freetdm/src/ftmod/ftmod_sangoma_isdn/ftmod_sangoma_isdn_stack_out.c
libs/freetdm/src/ftmod/ftmod_sangoma_isdn/ftmod_sangoma_isdn_stack_rcv.c
libs/freetdm/src/ftmod/ftmod_sangoma_isdn/ftmod_sangoma_isdn_support.c

index 65f17fa47b1e15459759a2339fe690c2e7230d20..2483c0109481a399ef6a86ee695b4cc84b3d6ee9 100644 (file)
@@ -1376,8 +1376,11 @@ static FIO_SIG_LOAD_FUNCTION(ftdm_sangoma_isdn_init)
        }
        
        /* initalize sng_isdn library */
-
        ftdm_assert_return(!sng_isdn_init(&g_sngisdn_event_interface), FTDM_FAIL, "Failed to initialize stack\n");
+
+       /* Load Stack General Configuration */
+       sngisdn_start_gen_cfg();
+
        return FTDM_SUCCESS;
 }
 
index fc93155ffadec825428086c75f62ac5efbcabaa4..40a89a80c805d3001fd01c14e846fd28345a43cf 100644 (file)
@@ -583,6 +583,7 @@ void sngisdn_t3_timeout(void* p_sngisdn_info);
 void sngisdn_restart_timeout(void* p_signal_data);
 
 /* Stack management functions */
+ftdm_status_t sngisdn_start_gen_cfg(void);
 ftdm_status_t sngisdn_stack_cfg(ftdm_span_t *span);
 ftdm_status_t sngisdn_stack_start(ftdm_span_t *span);
 ftdm_status_t sngisdn_stack_stop(ftdm_span_t *span);
index 52daf3ad7bcd19c47583a76630940d82d86f305a..946b9769b001aa0280cfeb5794d6d1fb595ecb93 100644 (file)
@@ -58,12 +58,8 @@ ftdm_status_t sngisdn_stack_cfg_q931_lce(ftdm_span_t *span);
 
 ftdm_status_t sngisdn_stack_cfg_cc_sap(ftdm_span_t *span);
 
-ftdm_status_t sngisdn_stack_cfg(ftdm_span_t *span)
+ftdm_status_t sngisdn_start_gen_cfg(void)
 {
-       sngisdn_span_data_t *signal_data = (sngisdn_span_data_t*)span->signal_data;
-
-       ftdm_log(FTDM_LOG_DEBUG, "Starting stack configuration for span:%s\n", span->name);
-       
        if (!g_sngisdn_data.gen_config_done) {
                g_sngisdn_data.gen_config_done = 1;
                ftdm_log(FTDM_LOG_DEBUG, "Starting general stack configuration\n");
@@ -92,6 +88,15 @@ ftdm_status_t sngisdn_stack_cfg(ftdm_span_t *span)
                ftdm_log(FTDM_LOG_DEBUG, "General stack CC done\n");
                ftdm_log(FTDM_LOG_INFO, "General stack configuration done\n");
        }
+       return FTDM_SUCCESS;
+}
+
+
+ftdm_status_t sngisdn_stack_cfg(ftdm_span_t *span)
+{
+       sngisdn_span_data_t *signal_data = (sngisdn_span_data_t*)span->signal_data;
+
+       ftdm_log(FTDM_LOG_DEBUG, "Starting stack configuration for span:%s\n", span->name);
 
        if (signal_data->dchan) {
                if (sngisdn_stack_cfg_phy_psap(span) != FTDM_SUCCESS) {
index 1cc23ddb8d52aa40ca4c0188f8e62b6e803ce61e..d745efed0b9c34be197defbf2e2cf3b18708a46b 100644 (file)
@@ -232,6 +232,11 @@ ftdm_status_t sngisdn_activate_trace(ftdm_span_t *span, sngisdn_tracetype_t trac
 {
        sngisdn_span_data_t *signal_data = sngisdn_dchan((sngisdn_span_data_t*)span->signal_data);
 
+       if (!signal_data) {
+               ftdm_log(FTDM_LOG_ERROR, "%s:Span is not used by signalling module\n", span->name);
+               return FTDM_FAIL;
+       }
+
        switch (trace_opt) {
                case SNGISDN_TRACE_DISABLE:
                        if (sngisdn_test_trace_flag(signal_data, SNGISDN_TRACE_Q921)) {
index b05ee41356a0181c9a91042d2ca599ac9ef3025a..9055f7006bf32cbd768f5f65814fefa23316decf 100644 (file)
@@ -314,19 +314,12 @@ void sngisdn_snd_info_req(ftdm_channel_t *ftdmchan)
        sngisdn_chan_data_t *sngisdn_info = (sngisdn_chan_data_t*) ftdmchan->call_data;
        sngisdn_span_data_t *signal_data = (sngisdn_span_data_t*) ftdmchan->span->signal_data;
 
-       if (ftdmchan->span->trunk_type != FTDM_TRUNK_BRI &&
-               ftdmchan->span->trunk_type != FTDM_TRUNK_BRI_PTMP) {
-
-               ftdm_log_chan_msg(ftdmchan, FTDM_LOG_DEBUG, "Ignoring INFO REQ on non-BRI channel\n");
-               return;
-       }
-
        memset(&cnStEvnt, 0, sizeof(cnStEvnt));
 
-       ftdm_log_chan(ftdmchan, FTDM_LOG_INFO, "Sending INFO REQ (suId:%d dchan:%d ces:%d)\n", signal_data->cc_id, sngisdn_dchan(signal_data)->link_id, sngisdn_info->ces);
+       ftdm_log_chan(ftdmchan, FTDM_LOG_INFO, "Requesting Link establishment (suId:%d dchan:%d ces:%d)\n", signal_data->cc_id, sngisdn_dchan(signal_data)->link_id, sngisdn_info->ces);
 
        if (sng_isdn_con_status(signal_data->cc_id, 0, 0, &cnStEvnt, MI_INFO, sngisdn_dchan(signal_data)->link_id, sngisdn_info->ces)) {
-               ftdm_log_chan_msg(ftdmchan, FTDM_LOG_CRIT,      "stack refused INFO request\n");
+               ftdm_log_chan_msg(ftdmchan, FTDM_LOG_CRIT,      "stack refused Link establishment\n");
        }
        return;
 }
@@ -552,6 +545,8 @@ void sngisdn_snd_event(sngisdn_span_data_t *signal_data, ftdm_oob_event_t event)
                case FTDM_OOB_ALARM_CLEAR:
                        l1_event.type = SNG_L1EVENT_ALARM_OFF;
                        sng_isdn_event_ind(signal_data->link_id, &l1_event);
+
+                       sngisdn_snd_info_req(signal_data->ftdm_span->channels[1]);
                        break;
                case FTDM_OOB_ALARM_TRAP:
                        l1_event.type = SNG_L1EVENT_ALARM_ON;
index a5ba7c54b9351bb72ced12c834e48c3976d9f182..34b4150ac0774c2ef7f8749524e174f289dd8198 100644 (file)
@@ -525,10 +525,17 @@ void sngisdn_rcv_sta_cfm (int16_t suId, uint32_t suInstId, uint32_t spInstId, St
 
        ISDN_FUNC_TRACE_ENTER(__FUNCTION__);
 
+       if (!suInstId && !spInstId) {
+               /* This is a response to a sngisdn_snd_info_req
+                * that was sent to attempt to re-establish DL link */
+               ISDN_FUNC_TRACE_EXIT(__FUNCTION__);
+               return;
+       }
+
        /* We sometimes receive a STA CFM after receiving a RELEASE/RELEASE COMPLETE, so we need to lock
                here in case we are calling clear_call_data at the same time this function is called */
 
-       ftdm_mutex_lock(g_sngisdn_data.ccs[suId].mutex);        
+       ftdm_mutex_lock(g_sngisdn_data.ccs[suId].mutex);
        if (!(spInstId && get_ftdmchan_by_spInstId(suId, spInstId, &sngisdn_info) == FTDM_SUCCESS) &&
                !(suInstId && get_ftdmchan_by_suInstId(suId, suInstId, &sngisdn_info) == FTDM_SUCCESS)) {
 
@@ -838,7 +845,7 @@ void sngisdn_rcv_q931_ind(InMngmt *status)
 
                        if (nfas_data && status->t.usta.alarm.event == LCM_EVENT_DOWN) {
                                if (nfas_data->dchan->sigstatus == FTDM_SIG_STATE_DOWN &&
-                                  (nfas_data->backup && nfas_data->backup->sigstatus == FTDM_SIG_STATE_DOWN)) {
+                                  ((nfas_data->backup && nfas_data->backup->sigstatus == FTDM_SIG_STATE_DOWN) || !nfas_data->backup)) {
 
                                        for (i = 0; i < ftdm_array_len(nfas_data->spans); i++) {
                                                if (nfas_data->spans[i] && nfas_data->spans[i]->nfas.sigchan == SNGISDN_NFAS_DCHAN_NONE) {
index 5f63f384d76e84c9be3272b5a5f9f2e88ca7b261..8232d1969f0091fece1eceac37bf03cc588952db 100644 (file)
@@ -1595,6 +1595,10 @@ void sngisdn_send_signal(sngisdn_chan_data_t *sngisdn_info, ftdm_signal_event_t
 
 sngisdn_span_data_t *sngisdn_dchan(sngisdn_span_data_t *signal_data)
 {
+       if (!signal_data) {
+               return NULL;
+       }
+
        if (!signal_data->nfas.trunk) {
                return signal_data;
        }