[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>

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

/*
 * 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 char *opt_output_path;
extern const char *tracing_group_name;
extern const char * const config_section_name;

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	/*
	30	* Queue used to enqueue relay requests
	31	*/
	32	struct relay_conn_queue {
	33	struct cds_wfcq_head head;
	34	struct cds_wfcq_tail tail;
	35	int32_t futex;
	36	};
	37
	38	/*
	39	* Contains stream indexed by ID. This is important since many commands lookup
	40	* streams only by ID thus also keeping them in this hash table makes the
	41	* search O(1).
	42	*/
	43	extern struct lttng_ht *sessions_ht;
	44	extern struct lttng_ht *relay_streams_ht;
	45	extern struct lttng_ht *viewer_streams_ht;
	46
	47	extern char *opt_output_path;
	48	extern const char *tracing_group_name;
	49	extern const char * const config_section_name;
	50
	51	extern int thread_quit_pipe[2];
	52
	53	void lttng_relay_notify_ready(void);
	54	int lttng_relay_stop_threads(void);
	55
	56	#endif /* LTTNG_RELAYD_H */