X-Git-Url: http://git.lttng.org/?a=blobdiff_plain;f=src%2Fcommon%2Fconsumer.c;h=129203fa5a9bb8ca655ae22c428d9531a1368adb;hb=65da3cc731c72486d53d58c9b080f235121177d9;hp=72c5f3426f0cc4cbfce38d951eff38b0ee188418;hpb=e0077699b76df46411a6ec0426a31005b2407497;p=lttng-tools.git diff --git a/src/common/consumer.c b/src/common/consumer.c index 72c5f3426..129203fa5 100644 --- a/src/common/consumer.c +++ b/src/common/consumer.c @@ -2189,9 +2189,12 @@ void *consumer_thread_metadata_poll(void *data) } restart: - DBG("Metadata poll wait with %d fd(s)", LTTNG_POLL_GETNB(&events)); + health_code_update(); health_poll_entry(); + DBG("Metadata poll wait"); ret = lttng_poll_wait(&events, -1); + DBG("Metadata poll return from wait with %d fd(s)", + LTTNG_POLL_GETNB(&events)); health_poll_exit(); DBG("Metadata event catched in thread"); if (ret < 0) { @@ -2764,9 +2767,12 @@ void *consumer_thread_channel_poll(void *data) } restart: - DBG("Channel poll wait with %d fd(s)", LTTNG_POLL_GETNB(&events)); + health_code_update(); + DBG("Channel poll wait"); health_poll_entry(); ret = lttng_poll_wait(&events, -1); + DBG("Channel poll return from wait with %d fd(s)", + LTTNG_POLL_GETNB(&events)); health_poll_exit(); DBG("Channel event catched in thread"); if (ret < 0) {