kenmirrors/freeswitch
1
0
Fork 0
mirror of https://github.com/signalwire/freeswitch.git synced 2025-06-04 12:21:54 +00:00
Code Issues Projects Releases Wiki Activity

Bump the 'spawn process' timeout, fix some logging

Browse Source
This commit is contained in:
Andrew Thompson 2010-08-05 13:38:07 -04:00
parent 7266527a7f
commit f281ac390a
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1311,7 +1311,7 @@ session_elem_t *attach_call_to_spawned_process(listener_t *listener, char *modul
ei_x_free(&rbuf); ei_x_free(&rbuf);
} else { } else {
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "rpc call: %s:%s(Ref)\n", module, function); switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(session), SWITCH_LOG_DEBUG, "rpc call: %s:%s(Ref)\n", module, function);
/* should lock with mutex? */ /* should lock with mutex? */
ei_pid_from_rpc(listener->ec, listener->sockfd, &ref, module, function); ei_pid_from_rpc(listener->ec, listener->sockfd, &ref, module, function);
/* /*
@ -1322,8 +1322,8 @@ session_elem_t *attach_call_to_spawned_process(listener_t *listener, char *modul
/* loop until either we timeout or we get a value that's not the waiting marker */ /* loop until either we timeout or we get a value that's not the waiting marker */
while (!(p = switch_core_hash_find(listener->spawn_pid_hash, hash)) || p == &globals.WAITING) { while (!(p = switch_core_hash_find(listener->spawn_pid_hash, hash)) || p == &globals.WAITING) {
if (i > 50) { /* half a second timeout */ if (i > 500) { /* 5 second timeout */
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_WARNING, "Timed out when waiting for outbound pid\n"); switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(session), SWITCH_LOG_WARNING, "Timed out when waiting for outbound pid\n");
remove_session_elem_from_listener_locked(listener, session_element); remove_session_elem_from_listener_locked(listener, session_element);
switch_core_hash_insert(listener->spawn_pid_hash, hash, &globals.TIMEOUT); /* TODO lock this? */ switch_core_hash_insert(listener->spawn_pid_hash, hash, &globals.TIMEOUT); /* TODO lock this? */
destroy_session_elem(session_element); destroy_session_elem(session_element);
@ -1336,7 +1336,7 @@ session_elem_t *attach_call_to_spawned_process(listener_t *listener, char *modul
switch_core_hash_delete(listener->spawn_pid_hash, hash); switch_core_hash_delete(listener->spawn_pid_hash, hash);
pid = (erlang_pid *) p; pid = (erlang_pid *) p;
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "got pid!\n"); switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(session), SWITCH_LOG_DEBUG, "got pid!\n");
session_element->process.type = ERLANG_PID; session_element->process.type = ERLANG_PID;
memcpy(&session_element->process.pid, pid, sizeof(erlang_pid)); memcpy(&session_element->process.pid, pid, sizeof(erlang_pid));