uchan->name,
uchan->streams.count);
- health_code_update(&health_thread_cmd);
+ health_code_update();
ret = consumer_send_channel(sock, &msg);
if (ret < 0) {
goto error;
}
- health_code_update(&health_thread_cmd);
+ health_code_update();
fd = uchan->obj->shm_fd;
ret = consumer_send_fds(sock, &fd, 1);
goto error;
}
- health_code_update(&health_thread_cmd);
+ health_code_update();
error:
return ret;
pathname,
usess->id);
- health_code_update(&health_thread_cmd);
+ health_code_update();
/* Send stream and file descriptor */
fds[0] = stream->obj->shm_fd;
goto error;
}
- health_code_update(&health_thread_cmd);
+ health_code_update();
error:
return ret;
"metadata",
1);
- health_code_update(&health_thread_cmd);
+ health_code_update();
ret = consumer_send_channel(sock, &msg);
if (ret < 0) {
goto error;
}
- health_code_update(&health_thread_cmd);
+ health_code_update();
/* Sending metadata shared memory fd */
fd = usess->metadata->obj->shm_fd;
goto error;
}
- health_code_update(&health_thread_cmd);
+ health_code_update();
/* Get correct path name destination */
if (consumer->type == CONSUMER_DST_LOCAL) {
pathname,
usess->id);
- health_code_update(&health_thread_cmd);
+ health_code_update();
/* Send stream and file descriptor */
fds[0] = usess->metadata->stream_obj->shm_fd;
goto error;
}
- health_code_update(&health_thread_cmd);
+ health_code_update();
error:
return ret;