X-Git-Url: http://git.liburcu.org/?a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Fmanage-consumer.c;h=6980dfa33f5931af96b1e145e3e11613a4d3f9a8;hb=da151cc5d0a127c08de59d6861c20a617c192682;hp=72e9a8600e93e01f1eab74942d14bd3ddf12f0b3;hpb=2e435abd2c3e09706fab156e1f965deccbbc68d5;p=lttng-tools.git

diff --git a/src/bin/lttng-sessiond/manage-consumer.c b/src/bin/lttng-sessiond/manage-consumer.c
index 72e9a8600..6980dfa33 100644
--- a/src/bin/lttng-sessiond/manage-consumer.c
+++ b/src/bin/lttng-sessiond/manage-consumer.c
@@ -161,9 +161,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 */
+	{
+		int32_t comm_code = 0;
+
+		ret = lttcomm_recv_unix_sock(sock, &comm_code, sizeof(comm_code));
+		code = (typeof(code)) comm_code;
+	}
 	if (ret <= 0) {
 		mark_thread_intialization_as_failed(notifiers);
 		goto error;
@@ -308,9 +312,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 */
+				{
+					int32_t comm_code = 0;
+
+					ret = lttcomm_recv_unix_sock(
+						sock, &comm_code, sizeof(comm_code));
+					code = (typeof(code)) comm_code;
+				}
 				if (ret <= 0) {
 					ERR("consumer closed the command socket");
 					goto error;