[lttng-tools.git] / src / bin / lttng-relayd / lttng-relayd.h

#ifndef LTTNG_RELAYD_H
#define LTTNG_RELAYD_H

/*
 * Copyright (C) 2012 - Julien Desfossez <jdesfossez@efficios.com>
 *                      David Goulet <dgoulet@efficios.com>
 *               2015 - Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
 *
 * 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 <limits.h>
#include <urcu.h>
#include <urcu/wfcqueue.h>

#include <common/hashtable/hashtable.h>

struct sessiond_trace_chunk_registry;

/*
 * Queue used to enqueue relay requests
 */
struct relay_conn_queue {
	struct cds_wfcq_head head;
	struct cds_wfcq_tail tail;
	int32_t futex;
};

enum relay_group_output_by {
	RELAYD_GROUP_OUTPUT_BY_UNKNOWN,
	RELAYD_GROUP_OUTPUT_BY_HOST,
	RELAYD_GROUP_OUTPUT_BY_SESSION,
};

/*
 * Contains stream indexed by ID. This is important since many commands lookup
 * streams only by ID thus also keeping them in this hash table makes the
 * search O(1).
 */
extern struct lttng_ht *sessions_ht;
extern struct lttng_ht *relay_streams_ht;
extern struct lttng_ht *viewer_streams_ht;
extern struct sessiond_trace_chunk_registry *sessiond_trace_chunk_registry;

extern char *opt_output_path;
extern const char *tracing_group_name;
extern const char * const config_section_name;
extern enum relay_group_output_by opt_group_output_by;

extern int thread_quit_pipe[2];

void lttng_relay_notify_ready(void);
int lttng_relay_stop_threads(void);

#endif /* LTTNG_RELAYD_H */
Commit	Line	Data
	1	#ifndef LTTNG_RELAYD_H
	2	#define LTTNG_RELAYD_H
	3
	4	/*
	5	* Copyright (C) 2012 - Julien Desfossez <jdesfossez@efficios.com>
	6	* David Goulet <dgoulet@efficios.com>
	7	* 2015 - Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
	8	*
	9	* This program is free software; you can redistribute it and/or modify
	10	* it under the terms of the GNU General Public License, version 2 only,
	11	* as published by the Free Software Foundation.
	12	*
	13	* This program is distributed in the hope that it will be useful, but WITHOUT
	14	* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
	15	* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
	16	* more details.
	17	*
	18	* You should have received a copy of the GNU General Public License along
	19	* with this program; if not, write to the Free Software Foundation, Inc.,
	20	* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
	21	*/
	22
	23	#include <limits.h>
	24	#include <urcu.h>
	25	#include <urcu/wfcqueue.h>
	26
	27	#include <common/hashtable/hashtable.h>
	28
	29	struct sessiond_trace_chunk_registry;
	30
	31	/*
	32	* Queue used to enqueue relay requests
	33	*/
	34	struct relay_conn_queue {
	35	struct cds_wfcq_head head;
	36	struct cds_wfcq_tail tail;
	37	int32_t futex;
	38	};
	39
	40	enum relay_group_output_by {
	41	RELAYD_GROUP_OUTPUT_BY_UNKNOWN,
	42	RELAYD_GROUP_OUTPUT_BY_HOST,
	43	RELAYD_GROUP_OUTPUT_BY_SESSION,
	44	};
	45
	46	/*
	47	* Contains stream indexed by ID. This is important since many commands lookup
	48	* streams only by ID thus also keeping them in this hash table makes the
	49	* search O(1).
	50	*/
	51	extern struct lttng_ht *sessions_ht;
	52	extern struct lttng_ht *relay_streams_ht;
	53	extern struct lttng_ht *viewer_streams_ht;
	54	extern struct sessiond_trace_chunk_registry *sessiond_trace_chunk_registry;
	55
	56	extern char *opt_output_path;
	57	extern const char *tracing_group_name;
	58	extern const char * const config_section_name;
	59	extern enum relay_group_output_by opt_group_output_by;
	60
	61	extern int thread_quit_pipe[2];
	62
	63	void lttng_relay_notify_ready(void);
	64	int lttng_relay_stop_threads(void);
	65
	66	#endif /* LTTNG_RELAYD_H */