kenmirrors
/
freeswitch
mirror of https://github.com/signalwire/freeswitch.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Don't exit the entire listener for a single session failure (reported by Timur Irmatov) 

git-svn-id: http://svn.freeswitch.org/svn/freeswitch/trunk@16516 d0543943-73ff-0310-b7d9-9358b9ac24b2
This commit is contained in:
Andrew Thompson 2010-01-26 15:44:46 +00:00
parent 034489d182
commit 77ac925dc5
1 changed files with 13 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/mod/event_handlers/mod_erlang_event/mod_erlang_event.c
View File

@ -532,14 +532,20 @@ static switch_status_t check_attached_sessions(listener_t *listener)
while(sp) { while(sp) {
removed = NULL; removed = NULL;
if (switch_test_flag(sp, LFLAG_WAITING_FOR_PID)) { if (switch_test_flag(sp, LFLAG_WAITING_FOR_PID)) {
break; sp = sp->next;
continue;
} }
if (!switch_test_flag(sp, LFLAG_OUTBOUND_INIT)) { if (!switch_test_flag(sp, LFLAG_OUTBOUND_INIT)) {
status = notify_new_session(listener, sp); status = notify_new_session(listener, sp);
if (status != SWITCH_STATUS_SUCCESS) { if (status != SWITCH_STATUS_SUCCESS) {
switch_log_printf(SWITCH_CHANNEL_UUID_LOG(sp->uuid_str), SWITCH_LOG_DEBUG, "Notifying new session failed\n"); switch_log_printf(SWITCH_CHANNEL_UUID_LOG(sp->uuid_str), SWITCH_LOG_DEBUG, "Notifying new session failed\n");
break; removed = sp;
sp = removed->next;
remove_session_elem_from_listener(listener, removed);
destroy_session_elem(removed);
continue;
} }
switch_set_flag(sp, LFLAG_OUTBOUND_INIT); switch_set_flag(sp, LFLAG_OUTBOUND_INIT);
} }
@ -610,7 +616,11 @@ static switch_status_t check_attached_sessions(listener_t *listener)
sp = sp->next; sp = sp->next;
} }
switch_mutex_unlock(listener->session_mutex); switch_mutex_unlock(listener->session_mutex);
return status; if (prefs.done) {
return SWITCH_STATUS_FALSE; /* we're shutting down */
} else {
return SWITCH_STATUS_SUCCESS;
}
} }
static void check_log_queue(listener_t *listener) static void check_log_queue(listener_t *listener)