[lttng-tools.git] / src / common / relayd / relayd.hpp

/*
 * Copyright (C) 2012 David Goulet <dgoulet@efficios.com>
 *
 * SPDX-License-Identifier: GPL-2.0-only
 *
 */

#ifndef _RELAYD_H
#define _RELAYD_H

#include <common/dynamic-array.hpp>
#include <common/sessiond-comm/relayd.hpp>
#include <common/sessiond-comm/sessiond-comm.hpp>
#include <common/trace-chunk.hpp>

#include <stdbool.h>
#include <unistd.h>

struct relayd_stream_rotation_position {
	uint64_t stream_id;
	/*
	 * Packet sequence number of the first packet belonging to the new
	 * "destination" trace chunk to which the stream is rotating.
	 *
	 * Ignored for metadata streams.
	 */
	uint64_t rotate_at_seq_num;
};

int relayd_connect(struct lttcomm_relayd_sock *sock);
int relayd_close(struct lttcomm_relayd_sock *sock);
int relayd_create_session(struct lttcomm_relayd_sock *rsock,
			  uint64_t *relayd_session_id,
			  const char *session_name,
			  const char *hostname,
			  const char *base_path,
			  int session_live_timer,
			  unsigned int snapshot,
			  uint64_t sessiond_session_id,
			  const lttng_uuid& sessiond_uuid,
			  const uint64_t *current_chunk_id,
			  time_t creation_time,
			  bool session_name_contains_creation_time,
			  char *output_path);
int relayd_add_stream(struct lttcomm_relayd_sock *sock,
		      const char *channel_name,
		      const char *domain_name,
		      const char *pathname,
		      uint64_t *stream_id,
		      uint64_t tracefile_size,
		      uint64_t tracefile_count,
		      struct lttng_trace_chunk *trace_chunk);
int relayd_streams_sent(struct lttcomm_relayd_sock *rsock);
int relayd_send_close_stream(struct lttcomm_relayd_sock *sock,
			     uint64_t stream_id,
			     uint64_t last_net_seq_num);
int relayd_version_check(struct lttcomm_relayd_sock *sock);
int relayd_start_data(struct lttcomm_relayd_sock *sock);
int relayd_send_metadata(struct lttcomm_relayd_sock *sock, size_t len);
int relayd_send_data_hdr(struct lttcomm_relayd_sock *sock,
			 struct lttcomm_relayd_data_hdr *hdr,
			 size_t size);
int relayd_data_pending(struct lttcomm_relayd_sock *sock,
			uint64_t stream_id,
			uint64_t last_net_seq_num);
int relayd_quiescent_control(struct lttcomm_relayd_sock *sock, uint64_t metadata_stream_id);
int relayd_begin_data_pending(struct lttcomm_relayd_sock *sock, uint64_t id);
int relayd_end_data_pending(struct lttcomm_relayd_sock *sock,
			    uint64_t id,
			    unsigned int *is_data_inflight);
int relayd_send_index(struct lttcomm_relayd_sock *rsock,
		      struct ctf_packet_index *index,
		      uint64_t relay_stream_id,
		      uint64_t net_seq_num);
int relayd_reset_metadata(struct lttcomm_relayd_sock *rsock, uint64_t stream_id, uint64_t version);
/* `positions` is an array of `stream_count` relayd_stream_rotation_position. */
int relayd_rotate_streams(struct lttcomm_relayd_sock *sock,
			  unsigned int stream_count,
			  const uint64_t *new_chunk_id,
			  const struct relayd_stream_rotation_position *positions);
int relayd_create_trace_chunk(struct lttcomm_relayd_sock *sock, struct lttng_trace_chunk *chunk);
int relayd_close_trace_chunk(struct lttcomm_relayd_sock *sock,
			     struct lttng_trace_chunk *chunk,
			     char *path);
int relayd_trace_chunk_exists(struct lttcomm_relayd_sock *sock,
			      uint64_t chunk_id,
			      bool *chunk_exists);
int relayd_get_configuration(struct lttcomm_relayd_sock *sock,
			     uint64_t query_flags,
			     uint64_t *result_flags);

#endif /* _RELAYD_H */
Commit	Line	Data
00e2e675	1	/*
ab5be9fa	2	* Copyright (C) 2012 David Goulet <dgoulet@efficios.com>
00e2e675	3	*
ab5be9fa	4	* SPDX-License-Identifier: GPL-2.0-only
00e2e675	5	*
00e2e675 DG	6	*/
	7
	8	#ifndef _RELAYD_H
	9	#define _RELAYD_H
	10
28f23191	11	#include <common/dynamic-array.hpp>
c9e313bc SM	12	#include <common/sessiond-comm/relayd.hpp>
	13	#include <common/sessiond-comm/sessiond-comm.hpp>
	14	#include <common/trace-chunk.hpp>
28f23191 JG	15
	16	#include <stdbool.h>
	17	#include <unistd.h>
c35f9726 JG	18
	19	struct relayd_stream_rotation_position {
	20	uint64_t stream_id;
	21	/*
0f83d1cc	22	* Packet sequence number of the first packet belonging to the new
c35f9726 JG	23	* "destination" trace chunk to which the stream is rotating.
	24	*
	25	* Ignored for metadata streams.
	26	*/
	27	uint64_t rotate_at_seq_num;
	28	};
00e2e675	29
6151a90f JD	30	int relayd_connect(struct lttcomm_relayd_sock *sock);
6151a90f JD	31	int relayd_close(struct lttcomm_relayd_sock *sock);
1e791a74	32	int relayd_create_session(struct lttcomm_relayd_sock *rsock,
28f23191 JG	33	uint64_t *relayd_session_id,
	34	const char *session_name,
	35	const char *hostname,
	36	const char *base_path,
	37	int session_live_timer,
	38	unsigned int snapshot,
	39	uint64_t sessiond_session_id,
	40	const lttng_uuid& sessiond_uuid,
	41	const uint64_t *current_chunk_id,
	42	time_t creation_time,
	43	bool session_name_contains_creation_time,
	44	char *output_path);
	45	int relayd_add_stream(struct lttcomm_relayd_sock *sock,
	46	const char *channel_name,
	47	const char *domain_name,
	48	const char *pathname,
	49	uint64_t *stream_id,
	50	uint64_t tracefile_size,
	51	uint64_t tracefile_count,
	52	struct lttng_trace_chunk *trace_chunk);
a4baae1b	53	int relayd_streams_sent(struct lttcomm_relayd_sock *rsock);
28f23191 JG	54	int relayd_send_close_stream(struct lttcomm_relayd_sock *sock,
	55	uint64_t stream_id,
	56	uint64_t last_net_seq_num);
6151a90f JD	57	int relayd_version_check(struct lttcomm_relayd_sock *sock);
	58	int relayd_start_data(struct lttcomm_relayd_sock *sock);
	59	int relayd_send_metadata(struct lttcomm_relayd_sock *sock, size_t len);
	60	int relayd_send_data_hdr(struct lttcomm_relayd_sock *sock,
28f23191 JG	61	struct lttcomm_relayd_data_hdr *hdr,
	62	size_t size);
	63	int relayd_data_pending(struct lttcomm_relayd_sock *sock,
	64	uint64_t stream_id,
	65	uint64_t last_net_seq_num);
	66	int relayd_quiescent_control(struct lttcomm_relayd_sock *sock, uint64_t metadata_stream_id);
6151a90f	67	int relayd_begin_data_pending(struct lttcomm_relayd_sock *sock, uint64_t id);
28f23191 JG	68	int relayd_end_data_pending(struct lttcomm_relayd_sock *sock,
	69	uint64_t id,
	70	unsigned int *is_data_inflight);
1c20f0e2	71	int relayd_send_index(struct lttcomm_relayd_sock *rsock,
28f23191 JG	72	struct ctf_packet_index *index,
	73	uint64_t relay_stream_id,
	74	uint64_t net_seq_num);
	75	int relayd_reset_metadata(struct lttcomm_relayd_sock *rsock, uint64_t stream_id, uint64_t version);
c35f9726 JG	76	/* `positions` is an array of `stream_count` relayd_stream_rotation_position. */
c35f9726 JG	77	int relayd_rotate_streams(struct lttcomm_relayd_sock *sock,
28f23191 JG	78	unsigned int stream_count,
	79	const uint64_t *new_chunk_id,
	80	const struct relayd_stream_rotation_position *positions);
	81	int relayd_create_trace_chunk(struct lttcomm_relayd_sock sock, struct lttng_trace_chunk chunk);
bbc4768c	82	int relayd_close_trace_chunk(struct lttcomm_relayd_sock *sock,
28f23191 JG	83	struct lttng_trace_chunk *chunk,
28f23191 JG	84	char *path);
c35f9726	85	int relayd_trace_chunk_exists(struct lttcomm_relayd_sock *sock,
28f23191 JG	86	uint64_t chunk_id,
28f23191 JG	87	bool *chunk_exists);
8614e600	88	int relayd_get_configuration(struct lttcomm_relayd_sock *sock,
28f23191 JG	89	uint64_t query_flags,
28f23191 JG	90	uint64_t *result_flags);
00e2e675 DG	91
00e2e675 DG	92	#endif /* _RELAYD_H */