Relayd data available command support

[lttng-tools.git] / src / common / sessiond-comm / relayd.h

diff --git a/src/common/sessiond-comm/relayd.h b/src/common/sessiond-comm/relayd.h
index c025fcdd926a21eef1032a72c4f5cd9a8461e99a..5be2328b9794676462f1c0cd96a588a0e97fc406 100644 (file)
--- a/src/common/sessiond-comm/relayd.h
+++ b/src/common/sessiond-comm/relayd.h
@@ -26,6 +26,9 @@
 
 #include <lttng/lttng.h>
 
+#define RELAYD_VERSION_COMM_MAJOR             2
+#define RELAYD_VERSION_COMM_MINOR             1
+
 /*
  * lttng-relayd communication header.
  */
@@ -46,6 +49,7 @@ struct lttcomm_relayd_data_hdr {
        uint64_t stream_id;     /* Stream ID known by the relayd */
        uint64_t net_seq_num;   /* Network sequence number, per stream. */
        uint32_t data_size;     /* data size following this header */
+       uint32_t padding_size;  /* Size of 0 padding the data */
 } __attribute__ ((__packed__));
 
 /*
@@ -91,6 +95,7 @@ struct lttcomm_relayd_version {
  */
 struct lttcomm_relayd_metadata_payload {
        uint64_t stream_id;
+       uint32_t padding_size;
        char payload[];
 } __attribute__ ((__packed__));
 
@@ -102,4 +107,13 @@ struct lttcomm_relayd_close_stream {
        uint64_t last_net_seq_num;      /* sequence number of last packet */
 } __attribute__ ((__packed__));
 
+/*
+ * Used to test if for a given stream id the data is available on the relayd
+ * side for reading.
+ */
+struct lttcomm_relayd_data_available {
+       uint64_t stream_id;
+       uint64_t last_net_seq_num; /* Sequence number of the last packet */
+} __attribute__ ((__packed__));
+
 #endif /* _RELAYD_COMM */