X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Fstream.c;h=b033dda94d1f39baf70d52ff50a43a7dc6ed797c;hb=f465e9787f5b70d4a8f3761c60b8d6e4161e9628;hp=da0b3fd2680bd689846f6c049491bfabf5ddcbae;hpb=44a2fbf116008c62184cc12f144fc69d29d7f606;p=lttng-tools.git diff --git a/src/bin/lttng-relayd/stream.c b/src/bin/lttng-relayd/stream.c index da0b3fd26..b033dda94 100644 --- a/src/bin/lttng-relayd/stream.c +++ b/src/bin/lttng-relayd/stream.c @@ -123,13 +123,8 @@ struct relay_stream *stream_create(struct ctf_trace *trace, * No need to use run_as API here because whatever we receive, * the relayd 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, NULL); - if (ret < 0) { - ERR("Create output file"); - goto end; - } - stream->stream_fd = stream_fd_create(ret); + stream->stream_fd = stream_fd_create(stream->path_name, + stream->channel_name, stream->tracefile_size, 0, NULL); if (!stream->stream_fd) { if (close(ret)) { PERROR("Error closing file %d", ret); @@ -307,7 +302,7 @@ static void stream_release(struct urcu_ref *ref) stream->stream_fd = NULL; } if (stream->index_file) { - lttng_index_file_put(stream->index_file); + relay_index_file_put(stream->index_file); stream->index_file = NULL; } if (stream->trace) {