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

Change Thread Create location. 

Move Thread Create after all direct esl_send_recv.  avoid deadlocks.
This commit is contained in:
gilles0606 2022-09-24 17:25:15 +02:00
parent 98d2e6212c
commit 90304ba081
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
libs/esl/fs_cli.c
View File

@ -1732,12 +1732,6 @@ int main(int argc, char *argv[])
global_handle = &handle; global_handle = &handle;
global_profile = profile; global_profile = profile;
if (esl_thread_create_detached(msg_thread_run, &handle) != ESL_SUCCESS) {
printf("Error starting thread!\n");
esl_disconnect(&handle);
return 0;
}
snprintf(cmd_str, sizeof(cmd_str), "api switchname\n\n"); snprintf(cmd_str, sizeof(cmd_str), "api switchname\n\n");
esl_send_recv(global_handle, cmd_str); esl_send_recv(global_handle, cmd_str);
if (global_handle->last_sr_event && global_handle->last_sr_event->body) { if (global_handle->last_sr_event && global_handle->last_sr_event->body) {
@ -1852,6 +1846,13 @@ int main(int argc, char *argv[])
snprintf(cmd_str, sizeof(cmd_str), "log %s\n\n", profile->loglevel); snprintf(cmd_str, sizeof(cmd_str), "log %s\n\n", profile->loglevel);
esl_send_recv(&handle, cmd_str); esl_send_recv(&handle, cmd_str);
} }
if (esl_thread_create_detached(msg_thread_run, &handle) != ESL_SUCCESS) {
printf("Error starting thread!\n");
esl_disconnect(&handle);
return 0;
}
if (global_profile->batch_mode) { if (global_profile->batch_mode) {
setvbuf(stdout, (char*)NULL, _IONBF, 0); setvbuf(stdout, (char*)NULL, _IONBF, 0);
} }