From eaf6ee25c980abc30e3f0b1da404c8a3b3ae9c6d Mon Sep 17 00:00:00 2001 From: Andrew Thompson Date: Sat, 24 Jan 2009 02:08:06 +0000 Subject: [PATCH] Fix some issues with standing up a new outbound listener and cleaning up after a failed session (more issues remain) git-svn-id: http://svn.freeswitch.org/svn/freeswitch/trunk@11479 d0543943-73ff-0310-b7d9-9358b9ac24b2 --- src/mod/event_handlers/mod_erlang_event/mod_erlang_event.c | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/src/mod/event_handlers/mod_erlang_event/mod_erlang_event.c b/src/mod/event_handlers/mod_erlang_event/mod_erlang_event.c index 000f59966d..684143b66d 100644 --- a/src/mod/event_handlers/mod_erlang_event/mod_erlang_event.c +++ b/src/mod/event_handlers/mod_erlang_event/mod_erlang_event.c @@ -864,10 +864,11 @@ static listener_t* new_listener(struct ei_cnode_s *ec, int clientfd) switch_queue_create(&listener->event_queue, SWITCH_CORE_QUEUE_LEN, listener_pool); switch_queue_create(&listener->log_queue, SWITCH_CORE_QUEUE_LEN, listener_pool); - listener->ec = ec; listener->sockfd = clientfd; listener->pool = listener_pool; listener_pool = NULL; + listener->ec = switch_core_alloc(listener->pool, sizeof(ei_cnode)); + memcpy(listener->ec, ec, sizeof(ei_cnode)); listener->level = SWITCH_LOG_DEBUG; switch_mutex_init(&listener->flag_mutex, SWITCH_MUTEX_NESTED, listener->pool); switch_mutex_init(&listener->sock_mutex, SWITCH_MUTEX_NESTED, listener->pool); @@ -945,6 +946,7 @@ session_elem_t* attach_call_to_spawned_process(listener_t* listener, char *modul while (!(pid = (erlang_pid *) switch_core_hash_find(listener->spawn_pid_hash, hash))) { if (i > 50) { /* half a second timeout */ switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "timed out!\n"); + switch_core_session_rwunlock(session); return NULL; } i++; @@ -1013,7 +1015,7 @@ SWITCH_STANDARD_APP(erlang_outbound_function) return; } - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "enter erlang_outbound_function %s %s\n",reg_name, node); + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "enter erlang_outbound_function %s %s\n",argv[0], node); /* first work out if there is a listener already talking to the node we want to talk to */ listener = find_listener(node); @@ -1022,6 +1024,7 @@ SWITCH_STANDARD_APP(erlang_outbound_function) switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Creating new listener for session\n"); new_session = SWITCH_TRUE; listener = new_outbound_listener(node); + add_listener(listener); } else { switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Using existing listener for session\n");