X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Fmanage-consumer.cpp;fp=src%2Fbin%2Flttng-sessiond%2Fmanage-consumer.cpp;h=27a368e7f19d80d7dbaed75ee6c64f3eb61b28ca;hp=b7eb10800fcaf2e21dd42e7de661a7568dc5597e;hb=fbd566c25787aa7134e84efcfb7d3569f27d3350;hpb=c91ccadee5bfbc94a95540e17c879ce976caf6a2

diff --git a/src/bin/lttng-sessiond/manage-consumer.cpp b/src/bin/lttng-sessiond/manage-consumer.cpp
index b7eb10800..27a368e7f 100644
--- a/src/bin/lttng-sessiond/manage-consumer.cpp
+++ b/src/bin/lttng-sessiond/manage-consumer.cpp
@@ -164,8 +164,13 @@ static void *thread_consumer_management(void *data)
 
 	DBG2("Receiving code from consumer err_sock");
 
-	/* Getting status code from kconsumerd */
-	ret = lttcomm_recv_unix_sock(sock, &code, sizeof(enum lttcomm_return_code));
+	/* Getting status code from consumerd */
+	{
+		std::int32_t comm_code = 0;
+
+		ret = lttcomm_recv_unix_sock(sock, &comm_code, sizeof(comm_code));
+		code = static_cast<decltype(code)>(comm_code);
+	}
 	if (ret <= 0) {
 		mark_thread_intialization_as_failed(notifiers);
 		goto error;
@@ -304,9 +309,14 @@ static void *thread_consumer_management(void *data)
 					goto error;
 				}
 				health_code_update();
-				/* Wait for any kconsumerd error */
-				ret = lttcomm_recv_unix_sock(
-					sock, &code, sizeof(enum lttcomm_return_code));
+				/* Wait for any consumerd error */
+				{
+					std::int32_t comm_code = 0;
+
+					ret = lttcomm_recv_unix_sock(
+						sock, &comm_code, sizeof(comm_code));
+					code = static_cast<decltype(code)>(comm_code);
+				}
 				if (ret <= 0) {
 					ERR("consumer closed the command socket");
 					goto error;