X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Fstream.h;h=5e23e7339cf4fcf7495f2ae4825fcdfdd57641d1;hp=ae75dacc3a061e1d77e16445f1f3d0371baf0db9;hb=c6db3843828a8fbf08444a2bc4191291a4807936;hpb=a8f9f353edcfac878ed6977381e3030608bf4e92 diff --git a/src/bin/lttng-relayd/stream.h b/src/bin/lttng-relayd/stream.h index ae75dacc3..5e23e7339 100644 --- a/src/bin/lttng-relayd/stream.h +++ b/src/bin/lttng-relayd/stream.h @@ -65,6 +65,20 @@ struct relay_stream { struct lttng_index_file *index_file; char *path_name; + /* + * prev_path_name is only used for session rotation support. + * It is essentially used to work around the fact that index + * files are always created from the 'data' connection. + * + * Hence, it is possible to receive a ROTATE_STREAM command + * which affects the stream's path_name before the creation of + * an index file. In this situation, the index file of the + * 'previous' chunk would be created in the new destination folder. + * + * It would then be unlinked when the actual index of the new chunk + * is created. + */ + char *prev_path_name; char *channel_name; /* On-disk circular buffer of tracefiles. */ @@ -152,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