X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Findex.hpp;fp=src%2Fbin%2Flttng-relayd%2Findex.hpp;h=8ba88c99220642da66e74d03372591bb45f9a649;hp=cb29485eb72559b8d049cc03af4c477634a3580b;hb=28f23191dcbf047429d51950a337a57d7a3f866a;hpb=f250b40e2179eccdb83766bf4abef5a35036c47b diff --git a/src/bin/lttng-relayd/index.hpp b/src/bin/lttng-relayd/index.hpp index cb29485eb..8ba88c992 100644 --- a/src/bin/lttng-relayd/index.hpp +++ b/src/bin/lttng-relayd/index.hpp @@ -10,12 +10,12 @@ * */ -#include -#include - #include #include +#include +#include + struct relay_stream; struct relay_connection; struct lttcomm_relayd_index; @@ -24,8 +24,8 @@ struct relay_index { /* * index lock nests inside stream lock. */ - struct urcu_ref ref; /* Reference from getters. */ - struct relay_stream *stream; /* Back ref to stream */ + struct urcu_ref ref; /* Reference from getters. */ + struct relay_stream *stream; /* Back ref to stream */ pthread_mutex_t lock; /* @@ -49,17 +49,16 @@ struct relay_index { * index across the stream. */ struct lttng_ht_node_u64 index_n; - struct rcu_head rcu_node; /* For call_rcu teardown. */ + struct rcu_head rcu_node; /* For call_rcu teardown. */ }; struct relay_index *relay_index_get_by_id_or_create(struct relay_stream *stream, - uint64_t net_seq_num); + uint64_t net_seq_num); void relay_index_put(struct relay_index *index); int relay_index_set_file(struct relay_index *index, - struct lttng_index_file *index_file, - uint64_t data_offset); -int relay_index_set_data(struct relay_index *index, - const struct ctf_packet_index *data); + struct lttng_index_file *index_file, + uint64_t data_offset); +int relay_index_set_data(struct relay_index *index, const struct ctf_packet_index *data); int relay_index_try_flush(struct relay_index *index); void relay_index_close_all(struct relay_stream *stream); @@ -67,7 +66,7 @@ void relay_index_close_partial_fd(struct relay_stream *stream); uint64_t relay_index_find_last(struct relay_stream *stream); int relay_index_switch_all_files(struct relay_stream *stream); int relay_index_set_control_data(struct relay_index *index, - const struct lttcomm_relayd_index *data, - unsigned int minor_version); + const struct lttcomm_relayd_index *data, + unsigned int minor_version); #endif /* _RELAY_INDEX_H */