X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Findex.h;h=4364f12ffdb096179e6e736dd821388c4c4bb028;hp=e882ed97d2552b71225fee0517698fcdf0143475;hb=HEAD;hpb=7591bab11eceedc6a0d1e02fd6f85592267a63b5 diff --git a/src/bin/lttng-relayd/index.h b/src/bin/lttng-relayd/index.h deleted file mode 100644 index e882ed97d..000000000 --- a/src/bin/lttng-relayd/index.h +++ /dev/null @@ -1,75 +0,0 @@ -#ifndef _RELAY_INDEX_H -#define _RELAY_INDEX_H - -/* - * Copyright (C) 2013 - Julien Desfossez - * David Goulet - * 2015 - Mathieu Desnoyers - * - * This program is free software; you can redistribute it and/or modify it - * under the terms of the GNU General Public License, version 2 only, as - * published by the Free Software Foundation. - * - * This program is distributed in the hope that it will be useful, but WITHOUT - * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or - * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for - * more details. - * - * You should have received a copy of the GNU General Public License along with - * this program; if not, write to the Free Software Foundation, Inc., 51 - * Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. - */ - -#include -#include - -#include -#include - -#include "stream-fd.h" - -struct relay_stream; - -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. - */ - struct stream_fd *index_fd; - - /* Index packet data. This is the data that is written on disk. */ - struct ctf_packet_index index_data; - - bool has_index_data; - bool flushed; - bool in_hash_table; - - /* - * Node within indexes_ht that corresponds to this struct - * relay_index. Indexed by net_seq_num, which is unique for this - * index across the stream. - */ - struct lttng_ht_node_u64 index_n; - struct rcu_head rcu_node; /* For call_rcu teardown. */ -}; - -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_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); - -#endif /* _RELAY_INDEX_H */