uchan->name,
uchan->streams.count);
+ health_code_update(&health_thread_cmd);
+
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;
}
+ health_code_update(&health_thread_cmd);
+
error:
return ret;
}
*/
static int send_channel_stream(struct consumer_socket *sock,
struct ust_app_channel *uchan, struct ust_app_session *usess,
- struct ltt_ust_stream *stream, struct consumer_output *consumer,
+ struct ust_app_stream *stream, struct consumer_output *consumer,
const char *pathname)
{
int ret, fds[2];
pathname,
usess->id);
+ health_code_update(&health_thread_cmd);
+
/* Send stream and file descriptor */
fds[0] = stream->obj->shm_fd;
fds[1] = stream->obj->wait_fd;
goto error;
}
+ health_code_update(&health_thread_cmd);
+
error:
return ret;
}
int ret;
char tmp_path[PATH_MAX];
const char *pathname;
- struct ltt_ust_stream *stream, *tmp;
+ struct ust_app_stream *stream, *tmp;
assert(sock);
usess->metadata->obj->shm_fd,
usess->metadata->attr.subbuf_size,
usess->metadata->obj->memory_map_size,
- "metadata",
+ DEFAULT_METADATA_NAME,
1);
+ health_code_update(&health_thread_cmd);
+
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);
goto error;
}
+ health_code_update(&health_thread_cmd);
+
/* Get correct path name destination */
if (consumer->type == CONSUMER_DST_LOCAL) {
/* Set application path to the destination path */
usess->gid,
consumer->net_seq_index,
1, /* Flag metadata set */
- "metadata",
+ DEFAULT_METADATA_NAME,
pathname,
usess->id);
+ 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;
goto error;
}
+ health_code_update(&health_thread_cmd);
+
error:
return ret;
}