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

/*
 * Copyright (C) 2012 - Julien Desfossez <jdesfossez@efficios.com>
 *                      David Goulet <dgoulet@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.
 */

#ifndef LTTNG_RELAYD_H
#define LTTNG_RELAYD_H

#define _LGPL_SOURCE
#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;
};

struct relay_local_data {
	struct lttng_ht *sessions_ht;
};

extern char *opt_output_path;

/*
 * 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) instead of iterating over the ctf_traces_ht of the session.
 */
extern struct lttng_ht *relay_streams_ht;

extern struct lttng_ht *viewer_streams_ht;
extern struct lttng_ht *indexes_ht;

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);

#endif /* LTTNG_RELAYD_H */
Commit	Line	Data
	1	/*
	2	* Copyright (C) 2012 - Julien Desfossez <jdesfossez@efficios.com>
	3	* David Goulet <dgoulet@efficios.com>
	4	*
	5	* This program is free software; you can redistribute it and/or modify
	6	* it under the terms of the GNU General Public License, version 2 only,
	7	* as published by the Free Software Foundation.
	8	*
	9	* This program is distributed in the hope that it will be useful, but WITHOUT
	10	* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
	11	* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
	12	* more details.
	13	*
	14	* You should have received a copy of the GNU General Public License along
	15	* with this program; if not, write to the Free Software Foundation, Inc.,
	16	* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
	17	*/
	18
	19	#ifndef LTTNG_RELAYD_H
	20	#define LTTNG_RELAYD_H
	21
	22	#define _LGPL_SOURCE
	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	struct relay_local_data {
	39	struct lttng_ht *sessions_ht;
	40	};
	41
	42	extern char *opt_output_path;
	43
	44	/*
	45	* Contains stream indexed by ID. This is important since many commands lookup
	46	* streams only by ID thus also keeping them in this hash table makes the
	47	* search O(1) instead of iterating over the ctf_traces_ht of the session.
	48	*/
	49	extern struct lttng_ht *relay_streams_ht;
	50
	51	extern struct lttng_ht *viewer_streams_ht;
	52	extern struct lttng_ht *indexes_ht;
	53
	54	extern const char *tracing_group_name;
	55
	56	extern const char * const config_section_name;
	57
	58	extern int thread_quit_pipe[2];
	59
	60	void lttng_relay_notify_ready(void);
	61
	62	#endif /* LTTNG_RELAYD_H */