X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Fmain.c;h=bb038a670b0a763afd41b1343cbbb1e919fbe1f7;hp=3bef52b43068e8f8b2ac5ce4a5fbe9289b7fb9ca;hb=309167d2a6f59d0c8cbf64eb23ba912cdea76a34;hpb=d83a952ce0d3a03bd3d36505d665db99b2c65fa2 diff --git a/src/bin/lttng-relayd/main.c b/src/bin/lttng-relayd/main.c index 3bef52b43..bb038a670 100644 --- a/src/bin/lttng-relayd/main.c +++ b/src/bin/lttng-relayd/main.c @@ -868,7 +868,7 @@ int relay_add_stream(struct lttcomm_relayd_hdr *recv_hdr, * uses its own credentials for the stream files. */ ret = utils_create_stream_file(stream->path_name, stream->channel_name, - stream->tracefile_size, 0, -1, -1); + stream->tracefile_size, 0, -1, -1, NULL); if (ret < 0) { ERR("Create output file"); goto end; @@ -1626,7 +1626,8 @@ int relay_process_data(struct relay_command *cmd, struct lttng_ht *streams_ht) ret = utils_rotate_stream_file(stream->path_name, stream->channel_name, stream->tracefile_size, stream->tracefile_count, -1, -1, - stream->fd, &(stream->tracefile_count_current)); + stream->fd, &(stream->tracefile_count_current), + &stream->fd); if (ret < 0) { ERR("Rotating output file"); goto end; @@ -2110,6 +2111,9 @@ int main(int argc, char **argv) /* Set up max poll set size */ lttng_poll_set_max_size(); + /* Initialize communication library */ + lttcomm_init(); + /* Setup the dispatcher thread */ ret = pthread_create(&dispatcher_thread, NULL, relay_thread_dispatcher, (void *) NULL);