X-Git-Url: http://git.liburcu.org/?a=blobdiff_plain;f=src%2Fcommon%2Fconsumer%2Fconsumer-stream.h;h=5f3a34e3ee26063b4305c41a7f1086c033ecaf05;hb=cdb72e4e9298c5a5852c6995de7a58fe7fdeaaac;hp=c5fb09732d7a94f065480b01bedd4f683e0daf39;hpb=c8fea79c745d42ea8143b7020ae11b4fc2da0d8a;p=lttng-tools.git diff --git a/src/common/consumer/consumer-stream.h b/src/common/consumer/consumer-stream.h index c5fb09732..5f3a34e3e 100644 --- a/src/common/consumer/consumer-stream.h +++ b/src/common/consumer/consumer-stream.h @@ -77,4 +77,30 @@ int consumer_stream_write_index(struct lttng_consumer_stream *stream, int consumer_stream_sync_metadata(struct lttng_consumer_local_data *ctx, uint64_t session_id); +/* + * Create the output files of a local stream. + * + * This must be called with the channel's and the stream's lock held. + */ +int consumer_stream_create_output_files(struct lttng_consumer_stream *stream, + bool create_index); + +/* + * Rotate the output files of a local stream. This will change the + * active output files of both the binary and index in accordance + * with the stream's configuration (stream file count). + * + * This must be called with the channel's and the stream's lock held. + */ +int consumer_stream_rotate_output_files(struct lttng_consumer_stream *stream); + +/* + * Indicates whether or not a stream is logically deleted. A deleted stream + * should no longer be used; its existence is only garanteed by the RCU lock + * held by the caller. + * + * This function must be called with the RCU read side lock held. + */ +bool consumer_stream_is_deleted(struct lttng_consumer_stream *stream); + #endif /* LTTNG_CONSUMER_STREAM_H */