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;
"metadata",
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,
pathname,
session->id);
- health_code_update(&health_thread_kernel);
+ health_code_update();
/* Send stream and file descriptor */
ret = consumer_send_stream(sock, consumer, &lkm,
goto error;
}
- health_code_update(&health_thread_kernel);
+ health_code_update();
error:
return ret;
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);
goto error;
}
- health_code_update(&health_thread_kernel);
+ health_code_update();
error:
return ret;