X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Fkernel-consumer.c;h=bdf9b4098be5edef16f3f1d9ad076637079304ec;hp=7fae5b0e96f08c2c1c1deb8197e4e9ec4f73c2e8;hb=840cb59cfc335e2ca44841f6fd57972ac3a623be;hpb=927ca06aed61ff6dd3f64ae71854f2d7f9acebe5 diff --git a/src/bin/lttng-sessiond/kernel-consumer.c b/src/bin/lttng-sessiond/kernel-consumer.c index 7fae5b0e9..bdf9b4098 100644 --- a/src/bin/lttng-sessiond/kernel-consumer.c +++ b/src/bin/lttng-sessiond/kernel-consumer.c @@ -52,14 +52,14 @@ int kernel_consumer_add_channel(struct consumer_socket *sock, channel->channel->name, channel->stream_count); - health_code_update(&health_thread_kernel); + health_code_update(); ret = consumer_send_channel(sock, &lkm); if (ret < 0) { goto error; } - health_code_update(&health_thread_kernel); + health_code_update(); error: return ret; @@ -127,14 +127,14 @@ int kernel_consumer_add_metadata(struct consumer_socket *sock, DEFAULT_METADATA_NAME, 1); - health_code_update(&health_thread_kernel); + health_code_update(); ret = consumer_send_channel(sock, &lkm); if (ret < 0) { goto error; } - health_code_update(&health_thread_kernel); + health_code_update(); /* Prep stream message structure */ consumer_init_stream_comm_msg(&lkm, @@ -152,7 +152,7 @@ int kernel_consumer_add_metadata(struct consumer_socket *sock, pathname, session->id); - health_code_update(&health_thread_kernel); + health_code_update(); /* Send stream and file descriptor */ ret = consumer_send_stream(sock, consumer, &lkm, @@ -161,7 +161,7 @@ int kernel_consumer_add_metadata(struct consumer_socket *sock, goto error; } - health_code_update(&health_thread_kernel); + health_code_update(); error: return ret; @@ -228,7 +228,7 @@ int kernel_consumer_add_stream(struct consumer_socket *sock, pathname, session->id); - health_code_update(&health_thread_kernel); + health_code_update(); /* Send stream and file descriptor */ ret = consumer_send_stream(sock, consumer, &lkm, &stream->fd, 1); @@ -236,7 +236,7 @@ int kernel_consumer_add_stream(struct consumer_socket *sock, goto error; } - health_code_update(&health_thread_kernel); + health_code_update(); error: return ret;