X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Fmain.c;h=6234e3e170d92515d1255a15087906531369083a;hp=ed424d9dd0c9036768aeff6d29e4d2a146210308;hb=6760999493e83d75539018eb9eed8f00f116ac12;hpb=d43da0fe92772f5733e856d8c101fe689ae26698 diff --git a/src/bin/lttng-relayd/main.c b/src/bin/lttng-relayd/main.c index ed424d9dd..6234e3e17 100644 --- a/src/bin/lttng-relayd/main.c +++ b/src/bin/lttng-relayd/main.c @@ -64,6 +64,7 @@ #include #include #include +#include #include "backward-compatibility-group-by.h" #include "cmd.h" @@ -664,8 +665,10 @@ static void relayd_cleanup(void) } /* Close thread quit pipes */ utils_close_pipe(health_quit_pipe); - utils_close_pipe(thread_quit_pipe); - + if (thread_quit_pipe[0] != -1) { + (void) fd_tracker_util_pipe_close( + the_fd_tracker, thread_quit_pipe); + } if (sessiond_trace_chunk_registry) { sessiond_trace_chunk_registry_destroy( sessiond_trace_chunk_registry); @@ -835,11 +838,8 @@ void lttng_relay_notify_ready(void) */ static int init_thread_quit_pipe(void) { - int ret; - - ret = utils_create_pipe_cloexec(thread_quit_pipe); - - return ret; + return fd_tracker_util_pipe_open_cloexec( + the_fd_tracker, "Quit pipe", thread_quit_pipe); } /*