X-Git-Url: http://git.liburcu.org/?a=blobdiff_plain;f=src%2Fcommon%2Fconsumer.c;h=129203fa5a9bb8ca655ae22c428d9531a1368adb;hb=3628d5bd420ccb6e7937506a2dbadb95bd3d2d0b;hp=72c5f3426f0cc4cbfce38d951eff38b0ee188418;hpb=6550503d44c075f45b5c15e42d5770a0a5a7d82c;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) {