X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Fstream.h;fp=src%2Fbin%2Flttng-relayd%2Fstream.h;h=5e23e7339cf4fcf7495f2ae4825fcdfdd57641d1;hp=dcdacfbb6d3fcbf6c3b88a32a1cf8d2e0fec0d2a;hb=c6db3843828a8fbf08444a2bc4191291a4807936;hpb=b00e554eef4eec08eea1f245b82cf737db9547e6 diff --git a/src/bin/lttng-relayd/stream.h b/src/bin/lttng-relayd/stream.h index dcdacfbb6..5e23e7339 100644 --- a/src/bin/lttng-relayd/stream.h +++ b/src/bin/lttng-relayd/stream.h @@ -166,6 +166,14 @@ struct relay_stream { * Always access with stream lock held. */ uint64_t rotate_at_seq_num; + /* + * When rotate_at_seq_num != -1ULL, meaning that a rotation is ongoing, + * data_rotated and index_rotated respectively indicate if the stream's + * data and index have been rotated. A rotation is considered completed + * when both rotations have occurred. + */ + bool data_rotated; + bool index_rotated; /* * This is the id of the chunk where we are writing to if no rotation is * pending (rotate_at_seq_num == -1ULL). If a rotation is pending, this