X-Git-Url: https://git.liburcu.org/?a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Fmanage-kernel.cpp;h=0920852501d486e2d1a6bbdf7ba07189a54a6423;hb=8a00688e1d58cc5a2e77eba206ff23bd6105130c;hp=a6393b6c0832bce45c903446c8de28df4cb4f1b9;hpb=64803277bbdbe0a943360d918298a48157d9da55;p=lttng-tools.git

diff --git a/src/bin/lttng-sessiond/manage-kernel.cpp b/src/bin/lttng-sessiond/manage-kernel.cpp
index a6393b6c0..092085250 100644
--- a/src/bin/lttng-sessiond/manage-kernel.cpp
+++ b/src/bin/lttng-sessiond/manage-kernel.cpp
@@ -18,10 +18,12 @@
 #include "kernel.hpp"
 #include "kernel-consumer.hpp"
 
+namespace {
 struct thread_notifiers {
 	struct lttng_pipe *quit_pipe;
 	int kernel_poll_pipe_read_fd;
 };
+} /* namespace */
 
 /*
  * Update the kernel poll set of all channel fd available over all tracing
@@ -163,12 +165,12 @@ error:
  */
 static void *thread_kernel_management(void *data)
 {
-	int ret, i, pollfd, update_poll_flag = 1, err = -1;
-	uint32_t revents, nb_fd;
+	int ret, i, update_poll_flag = 1, err = -1;
+	uint32_t nb_fd;
 	char tmp;
 	struct lttng_poll_event events;
 	struct thread_notifiers *notifiers = (thread_notifiers *) data;
-	const int quit_pipe_read_fd = lttng_pipe_get_readfd(notifiers->quit_pipe);
+	const auto thread_quit_pipe_fd = lttng_pipe_get_readfd(notifiers->quit_pipe);
 
 	DBG("[thread] Thread manage kernel started");
 
@@ -210,7 +212,7 @@ static void *thread_kernel_management(void *data)
 			}
 
 			ret = lttng_poll_add(&events,
-					quit_pipe_read_fd,
+					thread_quit_pipe_fd,
 					LPOLLIN);
 			if (ret < 0) {
 				goto error;
@@ -252,12 +254,14 @@ static void *thread_kernel_management(void *data)
 
 		for (i = 0; i < nb_fd; i++) {
 			/* Fetch once the poll data */
-			revents = LTTNG_POLL_GETEV(&events, i);
-			pollfd = LTTNG_POLL_GETFD(&events, i);
+			const auto revents = LTTNG_POLL_GETEV(&events, i);
+			const auto pollfd = LTTNG_POLL_GETFD(&events, i);
 
 			health_code_update();
 
-			if (pollfd == quit_pipe_read_fd) {
+			/* Activity on thread quit pipe, exiting. */
+			if (pollfd == thread_quit_pipe_fd) {
+				DBG("Activity on thread quit pipe");
 				err = 0;
 				goto exit;
 			}