X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fcommon%2Fconsumer%2Fconsumer-stream.h;h=c9af63cd83841c10a542e015aba3d6c3eb5fd69d;hb=HEAD;hp=0e1827c4a55382a4eabffdb78c832249317461de;hpb=ab5be9fa2eb5ba9600a82cd18fd3cfcbac69169a;p=lttng-tools.git diff --git a/src/common/consumer/consumer-stream.h b/src/common/consumer/consumer-stream.h deleted file mode 100644 index 0e1827c4a..000000000 --- a/src/common/consumer/consumer-stream.h +++ /dev/null @@ -1,96 +0,0 @@ -/* - * Copyright (C) 2013 David Goulet - * - * SPDX-License-Identifier: GPL-2.0-only - * - */ - -#ifndef LTTNG_CONSUMER_STREAM_H -#define LTTNG_CONSUMER_STREAM_H - -#include "consumer.h" - -/* - * Close stream's file descriptors and, if needed, close stream also on the - * relayd side. - * - * The stream lock MUST be acquired. - * The consumer data lock MUST be acquired. - */ -void consumer_stream_close(struct lttng_consumer_stream *stream); - -/* - * Close stream on the relayd side. This call can destroy a relayd if the - * conditions are met. - * - * A RCU read side lock MUST be acquired if the relayd object was looked up in - * a hash table before calling this. - */ -void consumer_stream_relayd_close(struct lttng_consumer_stream *stream, - struct consumer_relayd_sock_pair *relayd); - -/* - * Delete the stream from all possible hash tables. - * - * The consumer data lock MUST be acquired. - */ -void consumer_stream_delete(struct lttng_consumer_stream *stream, - struct lttng_ht *ht); - -/* - * Free the given stream within a RCU call. - */ -void consumer_stream_free(struct lttng_consumer_stream *stream); - -/* - * Destroy a stream completely. This will delete, close and free the stream. - * Once return, the stream is NO longer usable. Its channel may get destroyed - * if conditions are met. - * - * This MUST be called WITHOUT the consumer data and stream lock acquired. - */ -void consumer_stream_destroy(struct lttng_consumer_stream *stream, - struct lttng_ht *ht); - -/* - * Destroy the stream's buffers on the tracer side. This is also called in a - * stream destroy. - */ -void consumer_stream_destroy_buffers(struct lttng_consumer_stream *stream); - -/* - * Write index of a specific stream either on the relayd or local disk. - */ -int consumer_stream_write_index(struct lttng_consumer_stream *stream, - struct ctf_packet_index *index); - -int consumer_stream_sync_metadata(struct lttng_consumer_local_data *ctx, - uint64_t session_id); - -/* - * Create the output files of a local stream. - * - * This must be called with the channel's and the stream's lock held. - */ -int consumer_stream_create_output_files(struct lttng_consumer_stream *stream, - bool create_index); - -/* - * Rotate the output files of a local stream. This will change the - * active output files of both the binary and index in accordance - * with the stream's configuration (stream file count). - * - * This must be called with the channel's and the stream's lock held. - */ -int consumer_stream_rotate_output_files(struct lttng_consumer_stream *stream); - -/* - * Indicates whether or not a stream is logically deleted. A deleted stream - * should no longer be used; its existence is only garanteed by the RCU lock - * held by the caller. - * - * This function must be called with the RCU read side lock held. - */ -bool consumer_stream_is_deleted(struct lttng_consumer_stream *stream); - -#endif /* LTTNG_CONSUMER_STREAM_H */