From df52cc09524e6a24e7fe72c2bac784e2b9f534c7 Mon Sep 17 00:00:00 2001 From: Anthony Minessale Date: Tue, 2 Nov 2010 17:58:24 -0500 Subject: [PATCH] fix registration overlap timeout snafu --- libs/sofia-sip/.update | 2 +- libs/sofia-sip/libsofia-sip-ua/nta/nta.c | 4 ++++ src/mod/endpoints/mod_sofia/mod_sofia.h | 1 + src/mod/endpoints/mod_sofia/sofia_reg.c | 21 +++++++++++++++++---- 4 files changed, 23 insertions(+), 5 deletions(-) diff --git a/libs/sofia-sip/.update b/libs/sofia-sip/.update index ec0a895cdb..8a93851773 100644 --- a/libs/sofia-sip/.update +++ b/libs/sofia-sip/.update @@ -1 +1 @@ -Mon May 31 09:47:08 EDT 2010 +Tue Nov 2 17:57:25 CDT 2010 diff --git a/libs/sofia-sip/libsofia-sip-ua/nta/nta.c b/libs/sofia-sip/libsofia-sip-ua/nta/nta.c index 40ee1f8f85..abe7e68c44 100644 --- a/libs/sofia-sip/libsofia-sip-ua/nta/nta.c +++ b/libs/sofia-sip/libsofia-sip-ua/nta/nta.c @@ -8660,6 +8660,10 @@ void outgoing_destroy(nta_outgoing_t *orq) orq->orq_destroyed = 1; orq->orq_callback = outgoing_default_cb; orq->orq_magic = NULL; + + if (orq->orq_method != sip_method_invite && + orq->orq_method != sip_method_ack) + outgoing_terminate(orq); } /** @internal Outgoing transaction timer routine. diff --git a/src/mod/endpoints/mod_sofia/mod_sofia.h b/src/mod/endpoints/mod_sofia/mod_sofia.h index 0cd3b38871..6a9e4ce620 100644 --- a/src/mod/endpoints/mod_sofia/mod_sofia.h +++ b/src/mod/endpoints/mod_sofia/mod_sofia.h @@ -343,6 +343,7 @@ typedef enum { REG_STATE_FAIL_WAIT, REG_STATE_EXPIRED, REG_STATE_NOREG, + REG_STATE_TIMEOUT, REG_STATE_LAST } reg_state_t; diff --git a/src/mod/endpoints/mod_sofia/sofia_reg.c b/src/mod/endpoints/mod_sofia/sofia_reg.c index 2f5fb5a35a..2614bd6e15 100644 --- a/src/mod/endpoints/mod_sofia/sofia_reg.c +++ b/src/mod/endpoints/mod_sofia/sofia_reg.c @@ -369,11 +369,24 @@ void sofia_reg_check_gateway(sofia_profile_t *profile, time_t now) user_via = NULL; break; + case REG_STATE_TIMEOUT: + { + nua_handle_t *nh = gateway_ptr->nh; + + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_WARNING, "Timeout Registering %s\n", gateway_ptr->name); + + gateway_ptr->nh = NULL; + nua_handle_destroy(nh); + gateway_ptr->state = REG_STATE_FAILED; + gateway_ptr->failures++; + gateway_ptr->failure_status = 908; + } + break; case REG_STATE_FAILED: { int sec; - if (gateway_ptr->failure_status == 503) { + if (gateway_ptr->failure_status == 503 || gateway_ptr->failure_status == 908) { sec = gateway_ptr->retry_seconds; } else { sec = gateway_ptr->retry_seconds * (gateway_ptr->failures + 1); @@ -384,8 +397,8 @@ void sofia_reg_check_gateway(sofia_profile_t *profile, time_t now) gateway_ptr->state = REG_STATE_FAIL_WAIT; gateway_ptr->failure_status = 0; - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_WARNING, "%s Failed Registration, setting retry to %d seconds.\n", - gateway_ptr->name, sec); + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_WARNING, "%s Failed Registration [%d], setting retry to %d seconds.\n", + gateway_ptr->name, gateway_ptr->failure_status, sec); } break; @@ -396,7 +409,7 @@ void sofia_reg_check_gateway(sofia_profile_t *profile, time_t now) break; case REG_STATE_TRYING: if (!gateway_ptr->retry || now >= gateway_ptr->retry) { - gateway_ptr->state = REG_STATE_FAILED; + gateway_ptr->state = REG_STATE_TIMEOUT; } break; default: