Signed-off-by: David Goulet <dgoulet@efficios.com>
channel->channel->name,
channel->stream_count);
channel->channel->name,
channel->stream_count);
+ health_code_update(&health_thread_kernel);
+
ret = consumer_send_channel(sock, &lkm);
if (ret < 0) {
goto error;
}
ret = consumer_send_channel(sock, &lkm);
if (ret < 0) {
goto error;
}
+ health_code_update(&health_thread_kernel);
+
+ health_code_update(&health_thread_kernel);
+
ret = consumer_send_channel(sock, &lkm);
if (ret < 0) {
goto error;
}
ret = consumer_send_channel(sock, &lkm);
if (ret < 0) {
goto error;
}
+ health_code_update(&health_thread_kernel);
+
/* Prep stream message structure */
consumer_init_stream_comm_msg(&lkm,
LTTNG_CONSUMER_ADD_STREAM,
/* Prep stream message structure */
consumer_init_stream_comm_msg(&lkm,
LTTNG_CONSUMER_ADD_STREAM,
+ health_code_update(&health_thread_kernel);
+
/* Send stream and file descriptor */
ret = consumer_send_stream(sock, consumer, &lkm,
&session->metadata_stream_fd, 1);
/* Send stream and file descriptor */
ret = consumer_send_stream(sock, consumer, &lkm,
&session->metadata_stream_fd, 1);
+ health_code_update(&health_thread_kernel);
+
+ health_code_update(&health_thread_kernel);
+
/* Send stream and file descriptor */
ret = consumer_send_stream(sock, consumer, &lkm, &stream->fd, 1);
if (ret < 0) {
goto error;
}
/* Send stream and file descriptor */
ret = consumer_send_stream(sock, consumer, &lkm, &stream->fd, 1);
if (ret < 0) {
goto error;
}
+ health_code_update(&health_thread_kernel);
+
uchan->name,
uchan->streams.count);
uchan->name,
uchan->streams.count);
+ health_code_update(&health_thread_cmd);
+
ret = consumer_send_channel(sock, &msg);
if (ret < 0) {
goto error;
}
ret = consumer_send_channel(sock, &msg);
if (ret < 0) {
goto error;
}
+ health_code_update(&health_thread_cmd);
+
fd = uchan->obj->shm_fd;
ret = consumer_send_fds(sock, &fd, 1);
if (ret < 0) {
goto error;
}
fd = uchan->obj->shm_fd;
ret = consumer_send_fds(sock, &fd, 1);
if (ret < 0) {
goto error;
}
+ health_code_update(&health_thread_cmd);
+
+ health_code_update(&health_thread_cmd);
+
/* Send stream and file descriptor */
fds[0] = stream->obj->shm_fd;
fds[1] = stream->obj->wait_fd;
/* Send stream and file descriptor */
fds[0] = stream->obj->shm_fd;
fds[1] = stream->obj->wait_fd;
+ health_code_update(&health_thread_cmd);
+
+ health_code_update(&health_thread_cmd);
+
ret = consumer_send_channel(sock, &msg);
if (ret < 0) {
goto error;
}
ret = consumer_send_channel(sock, &msg);
if (ret < 0) {
goto error;
}
+ health_code_update(&health_thread_cmd);
+
/* Sending metadata shared memory fd */
fd = usess->metadata->obj->shm_fd;
ret = consumer_send_fds(sock, &fd, 1);
/* Sending metadata shared memory fd */
fd = usess->metadata->obj->shm_fd;
ret = consumer_send_fds(sock, &fd, 1);
+ health_code_update(&health_thread_cmd);
+
/* Get correct path name destination */
if (consumer->type == CONSUMER_DST_LOCAL) {
/* Set application path to the destination path */
/* Get correct path name destination */
if (consumer->type == CONSUMER_DST_LOCAL) {
/* Set application path to the destination path */
+ health_code_update(&health_thread_cmd);
+
/* Send stream and file descriptor */
fds[0] = usess->metadata->stream_obj->shm_fd;
fds[1] = usess->metadata->stream_obj->wait_fd;
/* Send stream and file descriptor */
fds[0] = usess->metadata->stream_obj->shm_fd;
fds[1] = usess->metadata->stream_obj->wait_fd;
+ health_code_update(&health_thread_cmd);
+