kenmirrors/freeswitch
1
0
Fork 0
mirror of https://github.com/signalwire/freeswitch.git synced 2025-02-09 09:17:34 +00:00
Code Issues Projects Releases Wiki Activity

don't create the remote thread detached so we can join it

Browse Source
This commit is contained in:
Mathieu Rene 2010-07-19 10:22:40 -04:00
parent f66ac8906b
commit 90f33b83dc
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/mod/applications/mod_hash/mod_hash.c
View File

@ -684,7 +684,7 @@ static void *SWITCH_THREAD_FUNC limit_remote_thread(switch_thread_t *thread, voi
switch_time_t now = switch_epoch_time_now(NULL); switch_time_t now = switch_epoch_time_now(NULL);
while (p && *p) { while (p && *p) {
/* We are getting the limit data as: /* We are getting the limit data as:
L/a_c/1/0/0/0 L/key/usage/rate/interval/last_checked
*/ */
if ((p2 = strchr(p, '\n'))) { if ((p2 = strchr(p, '\n'))) {
*p2++ = '\0'; *p2++ = '\0';
@ -711,8 +711,9 @@ static void *SWITCH_THREAD_FUNC limit_remote_thread(switch_thread_t *thread, voi
item->last_check = atoi(argv[4]); item->last_check = atoi(argv[4]);
item->last_update = now; item->last_update = now;
switch_thread_rwlock_unlock(remote->rwlock); switch_thread_rwlock_unlock(remote->rwlock);
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Imported key %s %d %d/%d (%d - %d)\n",
argv[0], item->total_usage, item->rate_usage, item->interval, (int)item->last_check, (int)item->last_update); /*switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Imported key %s %d %d/%d (%d - %d)\n",
argv[0], item->total_usage, item->rate_usage, item->interval, (int)item->last_check, (int)item->last_update);*/
} }
} }
@ -765,7 +766,7 @@ static void do_config()
remote->state = REMOTE_DOWN; remote->state = REMOTE_DOWN;
switch_threadattr_create(&thd_attr, remote->pool); switch_threadattr_create(&thd_attr, remote->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(&remote->thread, thd_attr, limit_remote_thread, remote, remote->pool); switch_thread_create(&remote->thread, thd_attr, limit_remote_thread, remote, remote->pool);
} }