X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Fsession.hpp;fp=src%2Fbin%2Flttng-relayd%2Fsession.hpp;h=9c61b942bed04f251fd57538c2973fe2db61fc63;hp=0000000000000000000000000000000000000000;hb=c9e313bc594f40a86eed237dce222c0fc99c957f;hpb=4878de5c7deb512bbdac4fdfc498907efa06fb7c

diff --git a/src/bin/lttng-relayd/session.hpp b/src/bin/lttng-relayd/session.hpp
new file mode 100644
index 000000000..9c61b942b
--- /dev/null
+++ b/src/bin/lttng-relayd/session.hpp
@@ -0,0 +1,163 @@
+#ifndef _SESSION_H
+#define _SESSION_H
+
+/*
+ * Copyright (C) 2013 Julien Desfossez <jdesfossez@efficios.com>
+ * Copyright (C) 2013 David Goulet <dgoulet@efficios.com>
+ * Copyright (C) 2015 Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
+ *
+ * SPDX-License-Identifier: GPL-2.0-only
+ *
+ */
+
+#include <limits.h>
+#include <inttypes.h>
+#include <pthread.h>
+#include <urcu/list.h>
+#include <urcu/ref.h>
+
+#include <lttng/constant.h>
+#include <common/hashtable/hashtable.hpp>
+#include <common/uuid.hpp>
+#include <common/trace-chunk.hpp>
+#include <common/optional.hpp>
+
+/*
+ * Represents a session for the relay point of view
+ */
+struct relay_session {
+	/*
+	 * This session id is generated by the relay daemon to guarantee
+	 * its uniqueness even when serving multiple session daemons.
+	 * It is used to match a set of streams to their session.
+	 */
+	uint64_t id;
+	/*
+	 * ID of the session in the session daemon's domain.
+	 * This information is only provided by 2.11+ peers.
+	 */
+	LTTNG_OPTIONAL(uint64_t) id_sessiond;
+	/*
+	 * Only provided by 2.11+ peers. However, the UUID is set to 'nil' in
+	 * the other cases.
+	 */
+	lttng_uuid sessiond_uuid;
+	/*
+	 * Contains the creation time on the session daemon's end for 2.11+
+	 * peers. Otherwise, this contains the session creation time on the
+	 * relay daemon's end.
+	 */
+	LTTNG_OPTIONAL(time_t) creation_time;
+	/* Must _not_ be empty for 2.4+ peers. */
+	char session_name[LTTNG_NAME_MAX];
+	char hostname[LTTNG_HOST_NAME_MAX];
+	char base_path[LTTNG_PATH_MAX];
+	/*
+	 * Session output path relative to relayd's output path.
+	 * Will be empty when interacting with peers < 2.11 since their
+	 * streams' path are expressed relative to the relay daemon's
+	 * output path.
+	 */
+	char output_path[LTTNG_PATH_MAX];
+	uint32_t live_timer;
+
+	/* Session in snapshot mode. */
+	bool snapshot;
+
+	/*
+	 * Session has no back reference to its connection because it
+	 * has a life-time that can be longer than the consumer connection's
+	 * life-time; a reference can still be held by the viewer
+	 * connection through the viewer streams.
+	 */
+
+	struct urcu_ref ref;
+
+	mutable pthread_mutex_t lock;
+
+	/* major/minor version used for this session. */
+	uint32_t major;
+	uint32_t minor;
+
+	bool viewer_attached;
+	/* Tell if the session connection has been closed on the streaming side. */
+	bool connection_closed;
+
+	/*
+	 * Tell if the session is currently living in a exiting relayd and
+	 * should be cleaned forcefully without waiting for pending data or
+	 * pending ctrl data.
+	 */
+	bool aborted;
+
+	bool session_name_contains_creation_time;
+	/* Whether session has performed an explicit rotation. */
+	bool has_rotated;
+
+	/* Contains ctf_trace object of that session indexed by path name. */
+	struct lttng_ht *ctf_traces_ht;
+
+	/*
+	 * This contains streams that are received on that connection.
+	 * It's used to store them until we get the streams sent
+	 * command. When this is received, we remove those streams from
+	 * the list and publish them.
+	 *
+	 * Updates are protected by the recv_list_lock.
+	 * Traversals are protected by RCU.
+	 * recv_list_lock also protects stream_count.
+	 */
+	struct cds_list_head recv_list;	/* RCU list. */
+	uint32_t stream_count;
+	pthread_mutex_t recv_list_lock;
+
+	/*
+	 * Flag checked and exchanged with uatomic_cmpxchg to tell the
+	 * viewer-side if new streams got added since the last check.
+	 */
+	unsigned long new_streams;
+
+	/*
+	 * Node in the global session hash table.
+	 */
+	struct lttng_ht_node_u64 session_n;
+	/*
+	 * Member of the session list in struct relay_viewer_session.
+	 * Updates are protected by the relay_viewer_session
+	 * session_list_lock. Traversals are protected by RCU.
+	 */
+	struct cds_list_head viewer_session_node;
+	struct lttng_trace_chunk *current_trace_chunk;
+	struct lttng_trace_chunk *pending_closure_trace_chunk;
+	/*
+	 * Prevent live viewers from taking of copy of the chunk
+	 * while new chunk has a temporary directory name.
+	 */
+	bool ongoing_rotation;
+	struct lttng_directory_handle *output_directory;
+	struct rcu_head rcu_node;	/* For call_rcu teardown. */
+};
+
+struct relay_session *session_create(const char *session_name,
+		const char *hostname, const char *base_path,
+		uint32_t live_timer,
+		bool snapshot,
+		const lttng_uuid sessiond_uuid,
+		const uint64_t *id_sessiond,
+		const uint64_t *current_chunk_id,
+		const time_t *creation_time,
+		uint32_t major,
+		uint32_t minor,
+		bool session_name_contains_creation_timestamp);
+struct relay_session *session_get_by_id(uint64_t id);
+bool session_get(struct relay_session *session);
+void session_put(struct relay_session *session);
+
+int session_close(struct relay_session *session);
+int session_abort(struct relay_session *session);
+
+bool session_has_ongoing_rotation(const struct relay_session *session);
+
+void print_sessions(void);
+
+#endif /* _SESSION_H */