X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Fconsumer.c;fp=src%2Fcommon%2Fconsumer.c;h=c741a1b8ec438925bf9da59edeef65b47652b444;hp=0035aae82d51e1afaa538fddfeb6e7463bfa53db;hb=7fa2082ed250230b7823e01b144aa6b580d4b2f5;hpb=25b397f9ccee70eb6f2968837702c50f22ad7bbf diff --git a/src/common/consumer.c b/src/common/consumer.c index 0035aae82..c741a1b8e 100644 --- a/src/common/consumer.c +++ b/src/common/consumer.c @@ -2190,9 +2190,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) { @@ -2765,9 +2768,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) {