X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Flttng-relayd.h;h=c60280e0fd9c717dc0bd0d1e975236ca0e73bed5;hb=1c20f0e29cbf8627bfb1ff444572d52d6655c4e2;hp=f231f0f6c0b85b172a56ba0c9d2d0cde15481fa7;hpb=173af62f4804133d4a7f45e34b6f72126f3eca5f;p=lttng-tools.git diff --git a/src/bin/lttng-relayd/lttng-relayd.h b/src/bin/lttng-relayd/lttng-relayd.h index f231f0f6c..c60280e0f 100644 --- a/src/bin/lttng-relayd/lttng-relayd.h +++ b/src/bin/lttng-relayd/lttng-relayd.h @@ -22,6 +22,8 @@ #define _LGPL_SOURCE #include #include +#include +#include /* * Queue used to enqueue relay requests @@ -40,9 +42,13 @@ enum connection_type { * Represents a session for the relay point of view */ struct relay_session { + /* + * This session id is used to identify a set of stream to a tracing session + * but also make sure we have a unique session id associated with a session + * daemon which can provide multiple data source. + */ uint64_t id; struct lttcomm_sock *sock; - unsigned int version_check_done:1; }; /* @@ -55,10 +61,22 @@ struct relay_stream { struct relay_session *session; struct rcu_head rcu_node; int fd; + /* FD on which to write the index data. */ + int index_fd; + + char *path_name; + char *channel_name; + /* on-disk circular buffer of tracefiles */ + uint64_t tracefile_size; + uint64_t tracefile_size_current; + uint64_t tracefile_count; + uint64_t tracefile_count_current; /* Information telling us when to close the stream */ unsigned int close_flag:1; uint64_t last_net_seq_num; + /* Indicate if the stream was initialized for a data pending command. */ + unsigned int data_pending_check_done:1; }; /* @@ -72,6 +90,12 @@ struct relay_command { struct lttng_ht_node_ulong sock_n; struct rcu_head rcu_node; enum connection_type type; + unsigned int version_check_done:1; + /* protocol version to use for this session */ + uint32_t major; + uint32_t minor; }; +extern char *opt_output_path; + #endif /* LTTNG_RELAYD_H */