X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=src%2Fcommon%2Fconsumer%2Fconsumer-stream.h;h=5f3a34e3ee26063b4305c41a7f1086c033ecaf05;hb=74e89a8c6a6824c4ca8179a3ae7b9cc4c99bddc5;hp=8bda682bd9bdd4620e4af359b5365c919f61d636;hpb=d295668767ac8234e83984e1812d342d03293d88;p=lttng-tools.git diff --git a/src/common/consumer/consumer-stream.h b/src/common/consumer/consumer-stream.h index 8bda682bd..5f3a34e3e 100644 --- a/src/common/consumer/consumer-stream.h +++ b/src/common/consumer/consumer-stream.h @@ -78,7 +78,7 @@ int consumer_stream_sync_metadata(struct lttng_consumer_local_data *ctx, uint64_t session_id); /* - * Create the output files of a local stream. + * Create the output files of a local stream. * * This must be called with the channel's and the stream's lock held. */ @@ -94,4 +94,13 @@ int consumer_stream_create_output_files(struct lttng_consumer_stream *stream, */ 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 */