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

avoid little race 

git-svn-id: http://svn.freeswitch.org/svn/freeswitch/trunk@8105 d0543943-73ff-0310-b7d9-9358b9ac24b2
This commit is contained in:
Anthony Minessale 2008-04-14 16:18:49 +00:00
parent 9c9fd03300
commit be85fcd204
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/mod/event_handlers/mod_event_socket/mod_event_socket.c
View File

@ -852,10 +852,11 @@ static switch_status_t parse_command(listener_t * listener, switch_event_t *even
acs->arg = switch_core_strdup(acs->pool, arg); acs->arg = switch_core_strdup(acs->pool, arg);
} }
acs->bg = 1; acs->bg = 1;
switch_threadattr_create(&thd_attr, acs->pool); switch_threadattr_create(&thd_attr, acs->pool);
switch_threadattr_detach_set(thd_attr, 1); switch_threadattr_detach_set(thd_attr, 1);
switch_threadattr_stacksize_set(thd_attr, SWITCH_THREAD_STACKSIZE); switch_threadattr_stacksize_set(thd_attr, SWITCH_THREAD_STACKSIZE);
switch_thread_create(&thread, thd_attr, api_exec, acs, acs->pool);
if ((uuid_str = switch_event_get_header(event, "job-uuid"))) { if ((uuid_str = switch_event_get_header(event, "job-uuid"))) {
switch_copy_string(acs->uuid_str, uuid_str, sizeof(acs->uuid_str)); switch_copy_string(acs->uuid_str, uuid_str, sizeof(acs->uuid_str));
} else { } else {
@ -864,6 +865,8 @@ static switch_status_t parse_command(listener_t * listener, switch_event_t *even
} }
switch_snprintf(reply, reply_len, "+OK Job-UUID: %s", acs->uuid_str); switch_snprintf(reply, reply_len, "+OK Job-UUID: %s", acs->uuid_str);
switch_thread_create(&thread, thd_attr, api_exec, acs, acs->pool);
return SWITCH_STATUS_SUCCESS; return SWITCH_STATUS_SUCCESS;
} else if (!strncasecmp(cmd, "log", 3)) { } else if (!strncasecmp(cmd, "log", 3)) {