start to handle async rotation on the relay + basics for remote rotate_pending

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

diff --git a/src/common/consumer/consumer.h b/src/common/consumer/consumer.h
index 92552504eb796ebc03190a9d8b7d8ae6db7d1da0..63254007af65bf912e38418848275f2c727ab7a3 100644 (file)
--- a/src/common/consumer/consumer.h
+++ b/src/common/consumer/consumer.h
@@ -236,6 +236,13 @@ struct lttng_consumer_channel {
         * daemon that this channel has finished its rotation.
         */
        uint64_t nr_stream_rotate_pending;
+
+       /*
+        * The chunk id where we currently write the data. This value is sent
+        * to the relay when we add a stream and when a stream rotates. This
+        * allows to keep track of where each stream on the relay is writing.
+        */
+       uint64_t current_chunk_id;
 };
 
 /*
@@ -818,7 +825,7 @@ void consumer_del_stream_for_metadata(struct lttng_consumer_stream *stream);
 int consumer_create_index_file(struct lttng_consumer_stream *stream);
 int lttng_consumer_rotate_channel(uint64_t key, char *path,
                uint64_t relayd_id, uint32_t metadata,
-               struct lttng_consumer_local_data *ctx);
+               uint64_t new_chunk_id, struct lttng_consumer_local_data *ctx);
 int lttng_consumer_stream_is_rotate_ready(struct lttng_consumer_stream *stream,
                unsigned long len);
 int lttng_consumer_rotate_stream(struct lttng_consumer_local_data *ctx,