X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fbin%2Flttng-relayd%2Fmain.c;h=0eb8e28251f2451ab229dc41cf0e62726fddc7c5;hb=0ed3b1a8426260c2b8a9cb7987b6b242568a2d02;hp=2fcc60af00d9d3b29b9809865ed7747ab4dbde45;hpb=8ada111f6d3ab40d1c33cf1a7b2546de9a47d1d5;p=lttng-tools.git diff --git a/src/bin/lttng-relayd/main.c b/src/bin/lttng-relayd/main.c index 2fcc60af0..0eb8e2825 100644 --- a/src/bin/lttng-relayd/main.c +++ b/src/bin/lttng-relayd/main.c @@ -977,12 +977,16 @@ static void *relay_thread_dispatcher(void *data) health_code_update(); - while (!CMM_LOAD_SHARED(dispatch_thread_exit)) { + for (;;) { health_code_update(); /* Atomically prepare the queue futex */ futex_nto1_prepare(&relay_conn_queue.futex); + if (CMM_LOAD_SHARED(dispatch_thread_exit)) { + break; + } + do { health_code_update();