X-Git-Url: http://git.efficios.com/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Findex.h;h=dda5b910b5b8c8df0b88dcd1bda2fd50f9be8c66;hp=e882ed97d2552b71225fee0517698fcdf0143475;hb=ce4d40839ac3beef1a58730d3636a522497bc60f;hpb=7591bab11eceedc6a0d1e02fd6f85592267a63b5 diff --git a/src/bin/lttng-relayd/index.h b/src/bin/lttng-relayd/index.h index e882ed97d..dda5b910b 100644 --- a/src/bin/lttng-relayd/index.h +++ b/src/bin/lttng-relayd/index.h @@ -34,16 +34,15 @@ struct relay_index { /* * index lock nests inside stream lock. */ - pthread_mutex_t reflock; /* Protects refcounting. */ struct urcu_ref ref; /* Reference from getters. */ struct relay_stream *stream; /* Back ref to stream */ pthread_mutex_t lock; /* - * FD on which to write the index data. May differ from - * stream->index_fd due to tracefile rotation. + * index file on which to write the index data. May differ from + * stream->index_file due to tracefile rotation. */ - struct stream_fd *index_fd; + struct lttng_index_file *index_file; /* Index packet data. This is the data that is written on disk. */ struct ctf_packet_index index_data; @@ -64,12 +63,15 @@ struct relay_index { struct relay_index *relay_index_get_by_id_or_create(struct relay_stream *stream, uint64_t net_seq_num); void relay_index_put(struct relay_index *index); -int relay_index_set_fd(struct relay_index *index, struct stream_fd *index_fd, - uint64_t data_offset); +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); int relay_index_try_flush(struct relay_index *index); void relay_index_close_all(struct relay_stream *stream); +void relay_index_close_partial_fd(struct relay_stream *stream); +uint64_t relay_index_find_last(struct relay_stream *stream); #endif /* _RELAY_INDEX_H */