X-Git-Url: https://git.liburcu.org/?a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Fmanage-consumer.c;fp=src%2Fbin%2Flttng-sessiond%2Fmanage-consumer.c;h=8f0dde185bd9d7bf58c07f88bfe8392c9a8fc5b7;hb=a73d94960e33d71f20cb99ea648cd24d064aabee;hp=093944c8e397198025b2be515e1aaabbabd036ce;hpb=c0e55b9aa6c04ffffa8ca9a164b09e07df7f7a5d;p=lttng-tools.git diff --git a/src/bin/lttng-sessiond/manage-consumer.c b/src/bin/lttng-sessiond/manage-consumer.c index 093944c8e..8f0dde185 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;