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

Fix race in erlang process spawning 

We received the reply and signaled the condition
earlier then started to wait for it
This commit is contained in:
Tamas Cseke 2014-05-19 14:47:39 +02:00
parent 34807208c6
commit ea78f4d0e8
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1466,6 +1466,8 @@ session_elem_t *attach_call_to_spawned_process(listener_t *listener, char *modul
add_session_elem_to_listener(listener, session_element); add_session_elem_to_listener(listener, session_element);
switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(session), SWITCH_LOG_DEBUG, "Added session to listener\n"); switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(session), SWITCH_LOG_DEBUG, "Added session to listener\n");
switch_mutex_lock(p->mutex);
if (!strcmp(function, "!")) { if (!strcmp(function, "!")) {
/* send a message to request a pid */ /* send a message to request a pid */
@ -1499,7 +1501,6 @@ session_elem_t *attach_call_to_spawned_process(listener_t *listener, char *modul
switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(session), SWITCH_LOG_DEBUG, "Waiting for reply %s %s\n", hash, session_element->uuid_str); switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(session), SWITCH_LOG_DEBUG, "Waiting for reply %s %s\n", hash, session_element->uuid_str);
switch_mutex_lock(p->mutex);
switch_thread_cond_timedwait(p->ready_or_found, p->mutex, 5000000); switch_thread_cond_timedwait(p->ready_or_found, p->mutex, 5000000);
switch_mutex_unlock(p->mutex); switch_mutex_unlock(p->mutex);
if (!p->pid) { if (!p->pid) {