X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fcommon%2Fconsumer%2Fconsumer-stream.c;h=cdda9412ee8df2d97395a12abc3f2cdc52dd379d;hb=a40a503f4218296700d791f1b79671bf3d0f1e22;hp=32441ea2cd313327cfacf22ab47772f6fea1d39f;hpb=d295668767ac8234e83984e1812d342d03293d88;p=lttng-tools.git diff --git a/src/common/consumer/consumer-stream.c b/src/common/consumer/consumer-stream.c index 32441ea2c..cdda9412e 100644 --- a/src/common/consumer/consumer-stream.c +++ b/src/common/consumer/consumer-stream.c @@ -576,7 +576,7 @@ int consumer_stream_create_output_files(struct lttng_consumer_stream *stream, ret = utils_stream_file_path(stream->chan->pathname, stream->name, stream->chan->tracefile_size, - stream->chan->tracefile_count, NULL, + stream->tracefile_count_current, NULL, stream_path, sizeof(stream_path)); if (ret < 0) { goto end; @@ -645,3 +645,13 @@ int consumer_stream_rotate_output_files(struct lttng_consumer_stream *stream) end: return ret; } + +bool consumer_stream_is_deleted(struct lttng_consumer_stream *stream) +{ + /* + * This function does not take a const stream since + * cds_lfht_is_node_deleted was not const before liburcu 0.12. + */ + assert(stream); + return cds_lfht_is_node_deleted(&stream->node.node); +}