[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>
#include <common/fd-tracker/fd-tracker.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];

extern struct fd_tracker *the_fd_tracker;

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	#include <common/fd-tracker/fd-tracker.h>
	29
	30	struct sessiond_trace_chunk_registry;
	31
	32	/*
	33	* Queue used to enqueue relay requests
	34	*/
	35	struct relay_conn_queue {
	36	struct cds_wfcq_head head;
	37	struct cds_wfcq_tail tail;
	38	int32_t futex;
	39	};
	40
	41	enum relay_group_output_by {
	42	RELAYD_GROUP_OUTPUT_BY_UNKNOWN,
	43	RELAYD_GROUP_OUTPUT_BY_HOST,
	44	RELAYD_GROUP_OUTPUT_BY_SESSION,
	45	};
	46
	47	/*
	48	* Contains stream indexed by ID. This is important since many commands lookup
	49	* streams only by ID thus also keeping them in this hash table makes the
	50	* search O(1).
	51	*/
	52	extern struct lttng_ht *sessions_ht;
	53	extern struct lttng_ht *relay_streams_ht;
	54	extern struct lttng_ht *viewer_streams_ht;
	55	extern struct sessiond_trace_chunk_registry *sessiond_trace_chunk_registry;
	56
	57	extern char *opt_output_path;
	58	extern const char *tracing_group_name;
	59	extern const char * const config_section_name;
	60	extern enum relay_group_output_by opt_group_output_by;
	61
	62	extern int thread_quit_pipe[2];
	63
	64	extern struct fd_tracker *the_fd_tracker;
	65
	66	void lttng_relay_notify_ready(void);
	67	int lttng_relay_stop_threads(void);
	68
	69	#endif /* LTTNG_RELAYD_H */