#include <lttng/lttng.h>
#include <common/defaults.h>
+#include <common/index/ctf-index.h>
+#include <config.h>
-#define RELAYD_VERSION_COMM_MAJOR 2
-#define RELAYD_VERSION_COMM_MINOR 1
+#define RELAYD_VERSION_COMM_MAJOR VERSION_MAJOR
+#define RELAYD_VERSION_COMM_MINOR VERSION_MINOR
/*
* lttng-relayd communication header.
/* Circuit ID not used for now so always ignored */
uint64_t circuit_id;
uint64_t data_size; /* data size following this header */
- uint32_t cmd; /* enum lttcomm_sessiond_command */
+ uint32_t cmd; /* enum lttcomm_relayd_command */
uint32_t cmd_version; /* command version */
} LTTNG_PACKED;
char pathname[PATH_MAX];
} LTTNG_PACKED;
+/*
+ * Used to add a stream on the relay daemon.
+ * Protocol version 2.2
+ */
+struct lttcomm_relayd_add_stream_2_2 {
+ char channel_name[DEFAULT_STREAM_NAME_LEN];
+ char pathname[PATH_MAX];
+ uint64_t tracefile_size;
+ uint64_t tracefile_count;
+} LTTNG_PACKED;
+
/*
* Answer from an add stream command.
*/
uint64_t session_id;
} LTTNG_PACKED;
+struct lttcomm_relayd_quiescent_control {
+ uint64_t stream_id;
+} LTTNG_PACKED;
+
+/*
+ * Index data.
+ */
+struct lttcomm_relayd_index {
+ uint64_t relay_stream_id;
+ uint64_t net_seq_num;
+ uint64_t packet_size;
+ uint64_t content_size;
+ uint64_t timestamp_begin;
+ uint64_t timestamp_end;
+ uint64_t events_discarded;
+ uint64_t stream_id;
+} LTTNG_PACKED;
+
+/*
+ * Create session in 2.4 adds additionnal parameters for live reading.
+ */
+struct lttcomm_relayd_create_session_2_4 {
+ char session_name[LTTNG_NAME_MAX];
+ char hostname[LTTNG_HOST_NAME_MAX];
+ uint32_t live_timer;
+ uint32_t snapshot;
+} LTTNG_PACKED;
+
#endif /* _RELAYD_COMM */