X-Git-Url: http://git.liburcu.org/?a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Flttng-relayd.h;h=bb5b7a365aaae214a10bd3757e34f1074ce4e81f;hb=8966b2b03f62a03e132f504853e9699152e9399b;hp=8039a7ec703d01f4672d32abcc9448ed49fb017a;hpb=6b6b9a5a667d6713eb7bcf22daf4f9bbeef00fb1;p=lttng-tools.git diff --git a/src/bin/lttng-relayd/lttng-relayd.h b/src/bin/lttng-relayd/lttng-relayd.h index 8039a7ec7..bb5b7a365 100644 --- a/src/bin/lttng-relayd/lttng-relayd.h +++ b/src/bin/lttng-relayd/lttng-relayd.h @@ -25,7 +25,7 @@ #include #include -#include +#include #include "ctf-trace.h" @@ -163,9 +163,18 @@ struct relay_viewer_stream { uint64_t total_index_received; uint64_t tracefile_count; uint64_t tracefile_count_current; + /* Stop after reading this tracefile. */ + uint64_t tracefile_count_last; struct lttng_ht_node_u64 stream_n; struct rcu_head rcu_node; struct ctf_trace *ctf_trace; + /* + * This lock blocks only when the writer is about to start overwriting + * a file currently read by the reader. + * + * This is nested INSIDE the viewer_stream_rotation_lock. + */ + pthread_mutex_t overwrite_lock; /* Information telling us if the stream is a metadata stream. */ unsigned int metadata_flag:1; /* @@ -211,6 +220,8 @@ extern struct lttng_ht *indexes_ht; extern const char *tracing_group_name; +extern const char * const config_section_name; + struct relay_stream *relay_stream_find_by_id(uint64_t stream_id); #endif /* LTTNG_RELAYD_H */