[lttng-tools.git] / src / bin / lttng-sessiond / lttng-ust-ctl.h

/*
 * Copyright (C) 2011 - Julien Desfossez <julien.desfossez@polymtl.ca>
 * Copyright (C) 2011-2013 - 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 as published by
 * the Free Software Foundation; version 2 of the License only.
 *
 * 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_UST_CTL_H
#define _LTTNG_UST_CTL_H

#include <lttng/ust-abi.h>

#ifndef LTTNG_PACKED
#define LTTNG_PACKED __attribute__((packed))
#endif

#ifndef LTTNG_UST_UUID_LEN
#define LTTNG_UST_UUID_LEN	16
#endif

struct lttng_ust_shm_handle;
struct lttng_ust_lib_ring_buffer;

struct ustctl_consumer_channel_attr {
	enum lttng_ust_chan_type type;
	uint64_t subbuf_size;			/* bytes */
	uint64_t num_subbuf;			/* power of 2 */
	int overwrite;				/* 1: overwrite, 0: discard */
	unsigned int switch_timer_interval;	/* usec */
	unsigned int read_timer_interval;	/* usec */
	enum lttng_ust_output output;		/* splice, mmap */
	unsigned char uuid[LTTNG_UST_UUID_LEN]; /* Trace session unique ID */
} LTTNG_PACKED;

/*
 * API used by sessiond.
 */

/*
 * Error values: all the following functions return:
 * >= 0: Success (LTTNG_UST_OK)
 * < 0: error code.
 */
int ustctl_register_done(int sock);
int ustctl_create_session(int sock);
int ustctl_create_event(int sock, struct lttng_ust_event *ev,
		struct lttng_ust_object_data *channel_data,
		struct lttng_ust_object_data **event_data);
int ustctl_add_context(int sock, struct lttng_ust_context *ctx,
		struct lttng_ust_object_data *obj_data,
		struct lttng_ust_object_data **context_data);
int ustctl_set_filter(int sock, struct lttng_ust_filter_bytecode *bytecode,
		struct lttng_ust_object_data *obj_data);

int ustctl_enable(int sock, struct lttng_ust_object_data *object);
int ustctl_disable(int sock, struct lttng_ust_object_data *object);
int ustctl_start_session(int sock, int handle);
int ustctl_stop_session(int sock, int handle);

/*
 * ustctl_tracepoint_list returns a tracepoint list handle, or negative
 * error value.
 */
int ustctl_tracepoint_list(int sock);

/*
 * ustctl_tracepoint_list_get is used to iterate on the tp list
 * handle. End is iteration is reached when -LTTNG_UST_ERR_NOENT is
 * returned.
 */
int ustctl_tracepoint_list_get(int sock, int tp_list_handle,
		struct lttng_ust_tracepoint_iter *iter);

/*
 * ustctl_tracepoint_field_list returns a tracepoint field list handle,
 * or negative error value.
 */
int ustctl_tracepoint_field_list(int sock);

/*
 * ustctl_tracepoint_field_list_get is used to iterate on the tp field
 * list handle. End is iteration is reached when -LTTNG_UST_ERR_NOENT is
 * returned.
 */
int ustctl_tracepoint_field_list_get(int sock, int tp_field_list_handle,
		struct lttng_ust_field_iter *iter);

int ustctl_tracer_version(int sock, struct lttng_ust_tracer_version *v);
int ustctl_wait_quiescent(int sock);

int ustctl_sock_flush_buffer(int sock, struct lttng_ust_object_data *object);

int ustctl_calibrate(int sock, struct lttng_ust_calibrate *calibrate);

/* Release object created by members of this API. */
int ustctl_release_object(int sock, struct lttng_ust_object_data *data);
/* Release handle returned by create session. */
int ustctl_release_handle(int sock, int handle);

int ustctl_recv_channel_from_consumer(int sock,
		struct lttng_ust_object_data **channel_data);
int ustctl_recv_stream_from_consumer(int sock,
		struct lttng_ust_object_data **stream_data);
int ustctl_send_channel_to_ust(int sock, int session_handle,
		struct lttng_ust_object_data *channel_data);
int ustctl_send_stream_to_ust(int sock,
		struct lttng_ust_object_data *channel_data,
		struct lttng_ust_object_data *stream_data);

/*
 * API used by consumer.
 */

struct ustctl_consumer_channel;
struct ustctl_consumer_stream;
struct ustctl_consumer_channel_attr;

struct ustctl_consumer_channel *
	ustctl_create_channel(struct ustctl_consumer_channel_attr *attr);
/*
 * Each stream created needs to be destroyed before calling
 * ustctl_destroy_channel().
 */
void ustctl_destroy_channel(struct ustctl_consumer_channel *chan);

int ustctl_send_channel_to_sessiond(int sock,
		struct ustctl_consumer_channel *channel);
/*
 * Send a NULL stream to finish iteration over all streams of a given
 * channel.
 */
int ustctl_send_stream_to_sessiond(int sock,
		struct ustctl_consumer_stream *stream);
int ustctl_stream_close_wakeup_fd(struct ustctl_consumer_stream *stream);

/* Create/destroy stream buffers for read */
struct ustctl_consumer_stream *
	ustctl_create_stream(struct ustctl_consumer_channel *channel,
			int cpu);
void ustctl_destroy_stream(struct ustctl_consumer_stream *stream);

int ustctl_get_wait_fd(struct ustctl_consumer_stream *stream);
int ustctl_get_wakeup_fd(struct ustctl_consumer_stream *stream);

/* For mmap mode, readable without "get" operation */
int ustctl_get_mmap_len(struct ustctl_consumer_stream *stream,
		unsigned long *len);
int ustctl_get_max_subbuf_size(struct ustctl_consumer_stream *stream,
		unsigned long *len);

/*
 * For mmap mode, operate on the current packet (between get/put or
 * get_next/put_next).
 */
void *ustctl_get_mmap_base(struct ustctl_consumer_stream *stream);
int ustctl_get_mmap_read_offset(struct ustctl_consumer_stream *stream,
		unsigned long *off);
int ustctl_get_subbuf_size(struct ustctl_consumer_stream *stream,
		unsigned long *len);
int ustctl_get_padded_subbuf_size(struct ustctl_consumer_stream *stream,
		unsigned long *len);
int ustctl_get_next_subbuf(struct ustctl_consumer_stream *stream);
int ustctl_put_next_subbuf(struct ustctl_consumer_stream *stream);

/* snapshot */

int ustctl_snapshot(struct ustctl_consumer_stream *stream);
int ustctl_snapshot_get_consumed(struct ustctl_consumer_stream *stream,
		unsigned long *pos);
int ustctl_snapshot_get_produced(struct ustctl_consumer_stream *stream,
		unsigned long *pos);
int ustctl_get_subbuf(struct ustctl_consumer_stream *stream,
		unsigned long *pos);
int ustctl_put_subbuf(struct ustctl_consumer_stream *stream);

void ustctl_flush_buffer(struct ustctl_consumer_stream *stream,
		int producer_active);

#endif /* _LTTNG_UST_CTL_H */
Commit	Line	Data
2bdd86d4 MD	1	/*
2bdd86d4 MD	2	* Copyright (C) 2011 - Julien Desfossez <julien.desfossez@polymtl.ca>
ffe60014	3	* Copyright (C) 2011-2013 - Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
2bdd86d4	4	*
d14d33bf	5	* This program is free software; you can redistribute it and/or modify
ffe60014 DG	6	* it under the terms of the GNU General Public License as published by
ffe60014 DG	7	* the Free Software Foundation; version 2 of the License only.
2bdd86d4 MD	8	*
	9	* This program is distributed in the hope that it will be useful,
	10	* but WITHOUT ANY WARRANTY; without even the implied warranty of
	11	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
	12	* GNU General Public License for more details.
	13	*
d14d33bf AM	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.
2bdd86d4 MD	17	*/
	18
	19	#ifndef _LTTNG_UST_CTL_H
	20	#define _LTTNG_UST_CTL_H
	21
ffe60014	22	#include <lttng/ust-abi.h>
2bdd86d4	23
ffe60014 DG	24	#ifndef LTTNG_PACKED
	25	#define LTTNG_PACKED __attribute__((packed))
	26	#endif
	27
	28	#ifndef LTTNG_UST_UUID_LEN
	29	#define LTTNG_UST_UUID_LEN 16
	30	#endif
	31
	32	struct lttng_ust_shm_handle;
	33	struct lttng_ust_lib_ring_buffer;
	34
	35	struct ustctl_consumer_channel_attr {
	36	enum lttng_ust_chan_type type;
	37	uint64_t subbuf_size; /* bytes */
	38	uint64_t num_subbuf; /* power of 2 */
	39	int overwrite; /* 1: overwrite, 0: discard */
	40	unsigned int switch_timer_interval; /* usec */
	41	unsigned int read_timer_interval; /* usec */
	42	enum lttng_ust_output output; /* splice, mmap */
	43	unsigned char uuid[LTTNG_UST_UUID_LEN]; /* Trace session unique ID */
	44	} LTTNG_PACKED;
	45
	46	/*
	47	* API used by sessiond.
	48	*/
	49
	50	/*
	51	* Error values: all the following functions return:
	52	* >= 0: Success (LTTNG_UST_OK)
	53	* < 0: error code.
	54	*/
13161846 DG	55	int ustctl_register_done(int sock);
13161846 DG	56	int ustctl_create_session(int sock);
2bdd86d4	57	int ustctl_create_event(int sock, struct lttng_ust_event *ev,
13161846 DG	58	struct lttng_ust_object_data *channel_data,
13161846 DG	59	struct lttng_ust_object_data **event_data);
2bdd86d4	60	int ustctl_add_context(int sock, struct lttng_ust_context *ctx,
13161846 DG	61	struct lttng_ust_object_data *obj_data,
13161846 DG	62	struct lttng_ust_object_data **context_data);
53a80697 MD	63	int ustctl_set_filter(int sock, struct lttng_ust_filter_bytecode *bytecode,
53a80697 MD	64	struct lttng_ust_object_data *obj_data);
2bdd86d4	65
13161846 DG	66	int ustctl_enable(int sock, struct lttng_ust_object_data *object);
	67	int ustctl_disable(int sock, struct lttng_ust_object_data *object);
	68	int ustctl_start_session(int sock, int handle);
	69	int ustctl_stop_session(int sock, int handle);
2bdd86d4	70
8ec2d32a MD	71	/*
	72	* ustctl_tracepoint_list returns a tracepoint list handle, or negative
	73	* error value.
	74	*/
	75	int ustctl_tracepoint_list(int sock);
ffe60014	76
8ec2d32a MD	77	/*
8ec2d32a MD	78	* ustctl_tracepoint_list_get is used to iterate on the tp list
ffe60014 DG	79	* handle. End is iteration is reached when -LTTNG_UST_ERR_NOENT is
ffe60014 DG	80	* returned.
8ec2d32a MD	81	*/
8ec2d32a MD	82	int ustctl_tracepoint_list_get(int sock, int tp_list_handle,
177f8533	83	struct lttng_ust_tracepoint_iter *iter);
8ec2d32a	84
f37d259d MD	85	/*
	86	* ustctl_tracepoint_field_list returns a tracepoint field list handle,
	87	* or negative error value.
	88	*/
	89	int ustctl_tracepoint_field_list(int sock);
	90
	91	/*
	92	* ustctl_tracepoint_field_list_get is used to iterate on the tp field
ffe60014 DG	93	* list handle. End is iteration is reached when -LTTNG_UST_ERR_NOENT is
ffe60014 DG	94	* returned.
f37d259d MD	95	*/
	96	int ustctl_tracepoint_field_list_get(int sock, int tp_field_list_handle,
	97	struct lttng_ust_field_iter *iter);
	98
13161846 DG	99	int ustctl_tracer_version(int sock, struct lttng_ust_tracer_version *v);
13161846 DG	100	int ustctl_wait_quiescent(int sock);
2bdd86d4	101
6d3686da DG	102	int ustctl_sock_flush_buffer(int sock, struct lttng_ust_object_data *object);
6d3686da DG	103
13161846	104	int ustctl_calibrate(int sock, struct lttng_ust_calibrate *calibrate);
2bdd86d4	105
ffe60014 DG	106	/* Release object created by members of this API. */
	107	int ustctl_release_object(int sock, struct lttng_ust_object_data *data);
	108	/* Release handle returned by create session. */
	109	int ustctl_release_handle(int sock, int handle);
	110
	111	int ustctl_recv_channel_from_consumer(int sock,
	112	struct lttng_ust_object_data **channel_data);
	113	int ustctl_recv_stream_from_consumer(int sock,
	114	struct lttng_ust_object_data **stream_data);
	115	int ustctl_send_channel_to_ust(int sock, int session_handle,
	116	struct lttng_ust_object_data *channel_data);
	117	int ustctl_send_stream_to_ust(int sock,
	118	struct lttng_ust_object_data *channel_data,
	119	struct lttng_ust_object_data *stream_data);
	120
2bdd86d4	121	/*
ffe60014	122	* API used by consumer.
2bdd86d4	123	*/
ffe60014 DG	124
	125	struct ustctl_consumer_channel;
	126	struct ustctl_consumer_stream;
	127	struct ustctl_consumer_channel_attr;
	128
	129	struct ustctl_consumer_channel *
	130	ustctl_create_channel(struct ustctl_consumer_channel_attr *attr);
2bdd86d4	131	/*
ffe60014 DG	132	* Each stream created needs to be destroyed before calling
ffe60014 DG	133	* ustctl_destroy_channel().
2bdd86d4	134	*/
ffe60014	135	void ustctl_destroy_channel(struct ustctl_consumer_channel *chan);
2bdd86d4	136
ffe60014 DG	137	int ustctl_send_channel_to_sessiond(int sock,
	138	struct ustctl_consumer_channel *channel);
	139	/*
	140	* Send a NULL stream to finish iteration over all streams of a given
	141	* channel.
	142	*/
	143	int ustctl_send_stream_to_sessiond(int sock,
	144	struct ustctl_consumer_stream *stream);
	145	int ustctl_stream_close_wakeup_fd(struct ustctl_consumer_stream *stream);
2bdd86d4	146
ffe60014 DG	147	/* Create/destroy stream buffers for read */
	148	struct ustctl_consumer_stream *
	149	ustctl_create_stream(struct ustctl_consumer_channel *channel,
	150	int cpu);
	151	void ustctl_destroy_stream(struct ustctl_consumer_stream *stream);
2bdd86d4	152
ffe60014 DG	153	int ustctl_get_wait_fd(struct ustctl_consumer_stream *stream);
ffe60014 DG	154	int ustctl_get_wakeup_fd(struct ustctl_consumer_stream *stream);
2bdd86d4 MD	155
2bdd86d4 MD	156	/* For mmap mode, readable without "get" operation */
ffe60014	157	int ustctl_get_mmap_len(struct ustctl_consumer_stream *stream,
13161846	158	unsigned long *len);
ffe60014	159	int ustctl_get_max_subbuf_size(struct ustctl_consumer_stream *stream,
13161846	160	unsigned long *len);
2bdd86d4 MD	161
	162	/*
	163	* For mmap mode, operate on the current packet (between get/put or
	164	* get_next/put_next).
	165	*/
ffe60014 DG	166	void ustctl_get_mmap_base(struct ustctl_consumer_stream stream);
	167	int ustctl_get_mmap_read_offset(struct ustctl_consumer_stream *stream,
	168	unsigned long *off);
	169	int ustctl_get_subbuf_size(struct ustctl_consumer_stream *stream,
	170	unsigned long *len);
	171	int ustctl_get_padded_subbuf_size(struct ustctl_consumer_stream *stream,
	172	unsigned long *len);
	173	int ustctl_get_next_subbuf(struct ustctl_consumer_stream *stream);
	174	int ustctl_put_next_subbuf(struct ustctl_consumer_stream *stream);
2bdd86d4 MD	175
	176	/* snapshot */
	177
ffe60014 DG	178	int ustctl_snapshot(struct ustctl_consumer_stream *stream);
	179	int ustctl_snapshot_get_consumed(struct ustctl_consumer_stream *stream,
	180	unsigned long *pos);
	181	int ustctl_snapshot_get_produced(struct ustctl_consumer_stream *stream,
	182	unsigned long *pos);
	183	int ustctl_get_subbuf(struct ustctl_consumer_stream *stream,
	184	unsigned long *pos);
	185	int ustctl_put_subbuf(struct ustctl_consumer_stream *stream);
8ec2d32a	186
ffe60014 DG	187	void ustctl_flush_buffer(struct ustctl_consumer_stream *stream,
ffe60014 DG	188	int producer_active);
2bdd86d4 MD	189
2bdd86d4 MD	190	#endif /* _LTTNG_UST_CTL_H */