}
int relay_index_set_file(struct relay_index *index,
- struct lttng_index_file *index_file,
+ struct relay_index_file *index_file,
uint64_t data_offset)
{
int ret = 0;
ret = -1;
goto end;
}
- lttng_index_file_get(index_file);
+ relay_index_file_get(index_file);
index->index_file = index_file;
index->index_data.offset = data_offset;
end:
struct lttng_ht_iter iter;
if (index->index_file) {
- lttng_index_file_put(index->index_file);
+ relay_index_file_put(index->index_file);
index->index_file = NULL;
}
if (index->in_hash_table) {
{
int ret = 1;
bool flushed = false;
- int fd;
pthread_mutex_lock(&index->lock);
if (index->flushed) {
if (!index->has_index_data || !index->index_file) {
goto skip;
}
- fd = index->index_file->fd;
- DBG2("Writing index for stream ID %" PRIu64 " and seq num %" PRIu64
- " on fd %d", index->stream->stream_handle,
- index->index_n.key, fd);
+ DBG2("Writing index for stream ID %" PRIu64 " and seq num %" PRIu64,
+ index->stream->stream_handle,
+ index->index_n.key);
flushed = true;
index->flushed = true;
- ret = lttng_index_file_write(index->index_file, &index->index_data);
+ ret = relay_index_file_write(index->index_file, &index->index_data);
skip:
pthread_mutex_unlock(&index->lock);