X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fcommon%2Fsessiond-comm%2Frelayd.h;h=9a733df1e7aaa68c5c6e252988012fca0eda6eda;hb=e2acc8d25bc0073554a2f3e742e070b7034ec1d0;hp=1fc48c442b4e52b68391683fd3a3f392ce3eb038;hpb=93ec662e687dc15a3601704a1e0c96c51ad228c9;p=lttng-tools.git diff --git a/src/common/sessiond-comm/relayd.h b/src/common/sessiond-comm/relayd.h index 1fc48c442..9a733df1e 100644 --- a/src/common/sessiond-comm/relayd.h +++ b/src/common/sessiond-comm/relayd.h @@ -94,13 +94,6 @@ struct lttcomm_relayd_generic_reply { uint32_t ret_code; } LTTNG_PACKED; -/* - * Used to update synchronization information. - */ -struct lttcomm_relayd_update_sync_info { - /* TODO: fill the structure. Feature not implemented yet */ -} LTTNG_PACKED; - /* * Version command. */ @@ -159,10 +152,30 @@ struct lttcomm_relayd_index { uint64_t timestamp_end; uint64_t events_discarded; uint64_t stream_id; + /* 2.8+ */ uint64_t stream_instance_id; uint64_t packet_seq_num; } LTTNG_PACKED; +static inline size_t lttcomm_relayd_index_len(uint32_t major, uint32_t minor) +{ + if (major == 1) { + switch (minor) { + case 0: + return offsetof(struct lttcomm_relayd_index, stream_id) + + member_sizeof(struct lttcomm_relayd_index, + stream_id); + case 1: + return offsetof(struct lttcomm_relayd_index, packet_seq_num) + + member_sizeof(struct lttcomm_relayd_index, + packet_seq_num); + default: + abort(); + } + } + abort(); +} + /* * Create session in 2.4 adds additionnal parameters for live reading. */ @@ -182,4 +195,31 @@ struct lttcomm_relayd_reset_metadata { uint64_t version; } LTTNG_PACKED; +struct lttcomm_relayd_rotate_stream { + uint64_t stream_id; + uint64_t rotate_at_seq_num; + uint64_t new_chunk_id; + /* Includes trailing NULL. */ + uint32_t pathname_length; + /* Must be the last member of this structure. */ + char new_pathname[]; +} LTTNG_PACKED; + +struct lttcomm_relayd_rotate_rename { + uint32_t old_path_length; + uint32_t new_path_length; + /* Concatenation of the old and new paths, separated by \0. */ + char paths[]; +} LTTNG_PACKED; + +struct lttcomm_relayd_rotate_pending { + uint64_t chunk_id; +} LTTNG_PACKED; + +struct lttcomm_relayd_mkdir { + /* Includes trailing NULL */ + uint32_t length; + char path[]; +} LTTNG_PACKED; + #endif /* _RELAYD_COMM */