TT#14008 convert threads_join_all arg to bool

Change-Id: Ie1ef9bbfe6faaf9fa7ed163d51475f6f353309df
pull/1388/head
Richard Fuchs 4 years ago
parent 24f607752c
commit d3a3382ac9

@ -133,7 +133,7 @@ static gint thread_equal(gconstpointer a, gconstpointer b) {
return !pthread_equal(*x, *y); return !pthread_equal(*x, *y);
} }
void threads_join_all(int wait) { void threads_join_all(bool wait) {
pthread_t *t; pthread_t *t;
GList *l; GList *l;

@ -1254,7 +1254,7 @@ int main(int argc, char **argv) {
while (!rtpe_shutdown) { while (!rtpe_shutdown) {
usleep(100000); usleep(100000);
threads_join_all(0); threads_join_all(false);
} }
// free libevent // free libevent
@ -1270,7 +1270,7 @@ int main(int argc, char **argv) {
if (!is_addr_unspecified(&rtpe_config.redis_ep.address) && rtpe_redis_notify) if (!is_addr_unspecified(&rtpe_config.redis_ep.address) && rtpe_redis_notify)
redis_async_event_base_action(rtpe_redis_notify, EVENT_BASE_LOOPBREAK); redis_async_event_base_action(rtpe_redis_notify, EVENT_BASE_LOOPBREAK);
threads_join_all(1); threads_join_all(true);
if (!is_addr_unspecified(&rtpe_config.redis_ep.address) && initial_rtpe_config.redis_delete_async) if (!is_addr_unspecified(&rtpe_config.redis_ep.address) && initial_rtpe_config.redis_delete_async)
redis_async_event_base_action(rtpe_redis_write, EVENT_BASE_FREE); redis_async_event_base_action(rtpe_redis_write, EVENT_BASE_FREE);

@ -343,7 +343,7 @@ struct thread_waker {
void thread_waker_add(struct thread_waker *); void thread_waker_add(struct thread_waker *);
void thread_waker_del(struct thread_waker *); void thread_waker_del(struct thread_waker *);
void threads_join_all(int); void threads_join_all(bool);
void thread_create_detach_prio(void (*)(void *), void *, const char *, int, const char *); void thread_create_detach_prio(void (*)(void *), void *, const char *, int, const char *);
INLINE void thread_create_detach(void (*f)(void *), void *a, const char *name) { INLINE void thread_create_detach(void (*f)(void *), void *a, const char *name) {
thread_create_detach_prio(f, a, NULL, 0, name); thread_create_detach_prio(f, a, NULL, 0, name);

Loading…
Cancel
Save