X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Findex.c;h=b7507a022076e0e6be789523111c08f4fcad2d66;hp=a3190b71475745d4ee30f444094ee8841776065c;hb=5c32d0aeb3f1e338ff61f9b5c865a01763a3ec4b;hpb=971da06a61170301dc28c2203ef0679c3024e21d diff --git a/src/bin/lttng-relayd/index.c b/src/bin/lttng-relayd/index.c index a3190b714..b7507a022 100644 --- a/src/bin/lttng-relayd/index.c +++ b/src/bin/lttng-relayd/index.c @@ -117,7 +117,7 @@ void relay_index_add(struct relay_index *index, struct relay_index **_index) assert(index); DBG2("Adding relay index with stream id %" PRIu64 " and seqnum %" PRIu64, - index->key.key1, index->key.key2); + index->index_n.key.key1, index->index_n.key.key2); node_ptr = cds_lfht_add_unique(indexes_ht->ht, indexes_ht->hash_fct((void *) &index->index_n.key, lttng_ht_seed), @@ -142,7 +142,8 @@ int relay_index_write(int fd, struct relay_index *index) struct lttng_ht_iter iter; DBG2("Writing index for stream ID %" PRIu64 " and seq num %" PRIu64 - " on fd %d", index->key.key1, index->key.key2, fd); + " on fd %d", index->index_n.key.key1, + index->index_n.key.key2, fd); /* Delete index from hash table. */ iter.iter.node = &index->index_n.node; @@ -184,7 +185,8 @@ void relay_index_delete(struct relay_index *index) struct lttng_ht_iter iter; DBG3("Relay index with stream ID %" PRIu64 " and seq num %" PRIu64 - "deleted.", index->key.key1, index->key.key2); + " deleted.", index->index_n.key.key1, + index->index_n.key.key2); /* Delete index from hash table. */ iter.iter.node = &index->index_n.node; @@ -202,7 +204,7 @@ void relay_index_destroy_by_stream_id(uint64_t stream_id) rcu_read_lock(); cds_lfht_for_each_entry(indexes_ht->ht, &iter.iter, index, index_n.node) { - if (index->key.key1 == stream_id) { + if (index->index_n.key.key1 == stream_id) { relay_index_delete(index); relay_index_free_safe(index); }