wip rotate consumer pipe

[deliverable/lttng-tools.git] / src / common / consumer / consumer.h

diff --git a/src/common/consumer/consumer.h b/src/common/consumer/consumer.h
index 0ee937c7a488053e3df5e2b06571c6538857392e..8b87838e65bf0f4f88ff714185072bfdae2c1df0 100644 (file)
--- a/src/common/consumer/consumer.h
+++ b/src/common/consumer/consumer.h
@@ -606,6 +606,16 @@ struct lttng_consumer_local_data {
         * its rotation (write-only).
         */
        int channel_rotate_pipe;
+       /*
+        * Pipe to wakeup the data thread if a stream needs to rotated
+        * immediately (vs waiting for more data).
+        */
+       struct lttng_pipe *consumer_data_rotate_pipe;
+       /*
+        * Pipe to wakeup the metadata thread if a stream needs to rotated
+        * immediately (vs waiting for more data).
+        */
+       struct lttng_pipe *consumer_metadata_rotate_pipe;
 };
 
 /*