X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Fstream.h;h=fb3e1ed68b936e1fd7411273c4b7a9b338f76e0b;hp=47ae2e8f9927fdcd672a595bf3c20902fd375846;hb=81164b6b222b4bafe1e3cec57c50429ab6dab30f;hpb=0b50e4b3fb9859af7072adcca784684834e5f8d1 diff --git a/src/bin/lttng-relayd/stream.h b/src/bin/lttng-relayd/stream.h index 47ae2e8f9..fb3e1ed68 100644 --- a/src/bin/lttng-relayd/stream.h +++ b/src/bin/lttng-relayd/stream.h @@ -31,6 +31,11 @@ #include "stream-fd.h" #include "tracefile-array.h" +struct relay_stream_chunk_id { + bool is_set; + uint64_t value; +}; + /* * Represents a stream in the relay */ @@ -150,14 +155,17 @@ struct relay_stream { * atomically with rotate_at_seq_num. * * Always access with stream lock held. + * + * This attribute is not set if the stream is created by a pre-2.11 + * consumer. */ - uint64_t chunk_id; + struct relay_stream_chunk_id current_chunk_id; }; struct relay_stream *stream_create(struct ctf_trace *trace, uint64_t stream_handle, char *path_name, char *channel_name, uint64_t tracefile_size, - uint64_t tracefile_count); + uint64_t tracefile_count, const struct relay_stream_chunk_id *chunk_id); struct relay_stream *stream_get_by_id(uint64_t stream_id); bool stream_get(struct relay_stream *stream);