struct urcu_ref ref; /* Reference from getters. */
struct relay_stream *stream; /* Back ref to stream */
pthread_mutex_t lock;
/*
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.
/* Index packet data. This is the data that is written on disk. */
struct ctf_packet_index index_data;
/* Index packet data. This is the data that is written on disk. */
struct ctf_packet_index index_data;
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);
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);
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);
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);