Fix: refcount issue in lttng-ust-abi.c
[lttng-ust.git] / include / lttng / ust-ctl.h
CommitLineData
f3105c67
MD
1/*
2 * Copyright (C) 2011 - Julien Desfossez <julien.desfossez@polymtl.ca>
74d81a6c 3 * Copyright (C) 2011-2013 - Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
f3105c67 4 *
e92f3e28
MD
5 * This program is free software; you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License as published by
7 * the Free Software Foundation; version 2 of the License only.
f3105c67
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 *
e92f3e28
MD
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.
f3105c67
MD
17 */
18
19#ifndef _LTTNG_UST_CTL_H
20#define _LTTNG_UST_CTL_H
21
4318ae1b 22#include <lttng/ust-abi.h>
32ce8569 23#include <sys/types.h>
74d81a6c
MD
24
25#ifndef LTTNG_UST_UUID_LEN
26#define LTTNG_UST_UUID_LEN 16
27#endif
28
32ce8569
MD
29/* Default unix socket path */
30#define LTTNG_UST_SOCK_FILENAME \
31 "lttng-ust-sock-" \
32 __ust_stringify(LTTNG_UST_ABI_MAJOR_VERSION)
33
34/*
35 * Shared memory files path are automatically related to shm root, e.g.
36 * /dev/shm under linux.
37 */
38#define LTTNG_UST_WAIT_FILENAME \
39 "lttng-ust-wait-" \
40 __ust_stringify(LTTNG_UST_ABI_MAJOR_VERSION)
41
74d81a6c
MD
42struct lttng_ust_shm_handle;
43struct lttng_ust_lib_ring_buffer;
44
45struct ustctl_consumer_channel_attr {
46 enum lttng_ust_chan_type type;
47 uint64_t subbuf_size; /* bytes */
48 uint64_t num_subbuf; /* power of 2 */
49 int overwrite; /* 1: overwrite, 0: discard */
50 unsigned int switch_timer_interval; /* usec */
51 unsigned int read_timer_interval; /* usec */
52 enum lttng_ust_output output; /* splice, mmap */
53 unsigned char uuid[LTTNG_UST_UUID_LEN]; /* Trace session unique ID */
54} LTTNG_PACKED;
55
56/*
57 * API used by sessiond.
58 */
59
7bc53e94
MD
60/*
61 * Error values: all the following functions return:
c354a72c 62 * >= 0: Success (LTTNG_UST_OK)
7bc53e94
MD
63 * < 0: error code.
64 */
1c5e467e 65int ustctl_register_done(int sock);
f3105c67 66int ustctl_create_session(int sock);
f3105c67 67int ustctl_create_event(int sock, struct lttng_ust_event *ev,
61f02aea
MD
68 struct lttng_ust_object_data *channel_data,
69 struct lttng_ust_object_data **event_data);
f3105c67 70int ustctl_add_context(int sock, struct lttng_ust_context *ctx,
61f02aea
MD
71 struct lttng_ust_object_data *obj_data,
72 struct lttng_ust_object_data **context_data);
cd54f6d9
MD
73int ustctl_set_filter(int sock, struct lttng_ust_filter_bytecode *bytecode,
74 struct lttng_ust_object_data *obj_data);
f3105c67 75
61f02aea
MD
76int ustctl_enable(int sock, struct lttng_ust_object_data *object);
77int ustctl_disable(int sock, struct lttng_ust_object_data *object);
4a6ca058
MD
78int ustctl_start_session(int sock, int handle);
79int ustctl_stop_session(int sock, int handle);
f3105c67 80
b115631f
MD
81/*
82 * ustctl_tracepoint_list returns a tracepoint list handle, or negative
83 * error value.
84 */
85int ustctl_tracepoint_list(int sock);
74d81a6c 86
b115631f
MD
87/*
88 * ustctl_tracepoint_list_get is used to iterate on the tp list
7bc53e94
MD
89 * handle. End is iteration is reached when -LTTNG_UST_ERR_NOENT is
90 * returned.
b115631f
MD
91 */
92int ustctl_tracepoint_list_get(int sock, int tp_list_handle,
cbef6901 93 struct lttng_ust_tracepoint_iter *iter);
b115631f 94
40003310
MD
95/*
96 * ustctl_tracepoint_field_list returns a tracepoint field list handle,
97 * or negative error value.
98 */
99int ustctl_tracepoint_field_list(int sock);
100
101/*
102 * ustctl_tracepoint_field_list_get is used to iterate on the tp field
7bc53e94
MD
103 * list handle. End is iteration is reached when -LTTNG_UST_ERR_NOENT is
104 * returned.
40003310
MD
105 */
106int ustctl_tracepoint_field_list_get(int sock, int tp_field_list_handle,
107 struct lttng_ust_field_iter *iter);
108
f3105c67
MD
109int ustctl_tracer_version(int sock, struct lttng_ust_tracer_version *v);
110int ustctl_wait_quiescent(int sock);
111
f1fffc57
MD
112int ustctl_sock_flush_buffer(int sock, struct lttng_ust_object_data *object);
113
f3105c67
MD
114int ustctl_calibrate(int sock, struct lttng_ust_calibrate *calibrate);
115
74d81a6c
MD
116/* Release object created by members of this API. */
117int ustctl_release_object(int sock, struct lttng_ust_object_data *data);
118/* Release handle returned by create session. */
119int ustctl_release_handle(int sock, int handle);
120
121int ustctl_recv_channel_from_consumer(int sock,
122 struct lttng_ust_object_data **channel_data);
123int ustctl_recv_stream_from_consumer(int sock,
124 struct lttng_ust_object_data **stream_data);
125int ustctl_send_channel_to_ust(int sock, int session_handle,
126 struct lttng_ust_object_data *channel_data);
127int ustctl_send_stream_to_ust(int sock,
128 struct lttng_ust_object_data *channel_data,
129 struct lttng_ust_object_data *stream_data);
130
f3105c67 131/*
74d81a6c 132 * API used by consumer.
f3105c67 133 */
74d81a6c
MD
134
135struct ustctl_consumer_channel;
136struct ustctl_consumer_stream;
137struct ustctl_consumer_channel_attr;
138
139struct ustctl_consumer_channel *
140 ustctl_create_channel(struct ustctl_consumer_channel_attr *attr);
5224b5c8 141/*
74d81a6c
MD
142 * Each stream created needs to be destroyed before calling
143 * ustctl_destroy_channel().
5224b5c8 144 */
74d81a6c 145void ustctl_destroy_channel(struct ustctl_consumer_channel *chan);
f3105c67 146
74d81a6c
MD
147int ustctl_send_channel_to_sessiond(int sock,
148 struct ustctl_consumer_channel *channel);
c9023c93
MD
149
150int ustctl_write_metadata_to_channel(
151 struct ustctl_consumer_channel *channel,
152 const char *metadata_str, /* NOT null-terminated */
153 size_t len); /* metadata length */
154
74d81a6c
MD
155/*
156 * Send a NULL stream to finish iteration over all streams of a given
157 * channel.
158 */
159int ustctl_send_stream_to_sessiond(int sock,
160 struct ustctl_consumer_stream *stream);
161int ustctl_stream_close_wait_fd(struct ustctl_consumer_stream *stream);
162int ustctl_stream_close_wakeup_fd(struct ustctl_consumer_stream *stream);
f3105c67 163
74d81a6c
MD
164/* Create/destroy stream buffers for read */
165struct ustctl_consumer_stream *
166 ustctl_create_stream(struct ustctl_consumer_channel *channel,
167 int cpu);
168void ustctl_destroy_stream(struct ustctl_consumer_stream *stream);
f3105c67 169
74d81a6c
MD
170int ustctl_get_wait_fd(struct ustctl_consumer_stream *stream);
171int ustctl_get_wakeup_fd(struct ustctl_consumer_stream *stream);
6e922b24 172
f3105c67 173/* For mmap mode, readable without "get" operation */
74d81a6c 174int ustctl_get_mmap_len(struct ustctl_consumer_stream *stream,
f3105c67 175 unsigned long *len);
74d81a6c 176int ustctl_get_max_subbuf_size(struct ustctl_consumer_stream *stream,
f3105c67
MD
177 unsigned long *len);
178
179/*
180 * For mmap mode, operate on the current packet (between get/put or
181 * get_next/put_next).
182 */
74d81a6c
MD
183void *ustctl_get_mmap_base(struct ustctl_consumer_stream *stream);
184int ustctl_get_mmap_read_offset(struct ustctl_consumer_stream *stream,
185 unsigned long *off);
186int ustctl_get_subbuf_size(struct ustctl_consumer_stream *stream,
187 unsigned long *len);
188int ustctl_get_padded_subbuf_size(struct ustctl_consumer_stream *stream,
189 unsigned long *len);
190int ustctl_get_next_subbuf(struct ustctl_consumer_stream *stream);
191int ustctl_put_next_subbuf(struct ustctl_consumer_stream *stream);
f3105c67
MD
192
193/* snapshot */
194
74d81a6c
MD
195int ustctl_snapshot(struct ustctl_consumer_stream *stream);
196int ustctl_snapshot_get_consumed(struct ustctl_consumer_stream *stream,
197 unsigned long *pos);
198int ustctl_snapshot_get_produced(struct ustctl_consumer_stream *stream,
199 unsigned long *pos);
200int ustctl_get_subbuf(struct ustctl_consumer_stream *stream,
201 unsigned long *pos);
202int ustctl_put_subbuf(struct ustctl_consumer_stream *stream);
5f9d3dbc 203
74d81a6c
MD
204void ustctl_flush_buffer(struct ustctl_consumer_stream *stream,
205 int producer_active);
f3105c67 206
32ce8569
MD
207/* event registry management */
208
209enum ustctl_socket_type {
210 USTCTL_SOCKET_CMD = 0,
211 USTCTL_SOCKET_NOTIFY = 1,
212};
213
214enum ustctl_notify_cmd {
215 USTCTL_NOTIFY_CMD_EVENT = 0,
216 USTCTL_NOTIFY_CMD_CHANNEL = 1,
217};
218
219enum ustctl_channel_header {
220 USTCTL_CHANNEL_HEADER_UNKNOWN = 0,
221 USTCTL_CHANNEL_HEADER_COMPACT = 1,
222 USTCTL_CHANNEL_HEADER_LARGE = 2,
223};
224
225/* event type structures */
226
227enum ustctl_abstract_types {
228 ustctl_atype_integer,
229 ustctl_atype_enum,
230 ustctl_atype_array,
231 ustctl_atype_sequence,
232 ustctl_atype_string,
233 ustctl_atype_float,
234 NR_USTCTL_ABSTRACT_TYPES,
235};
236
237enum ustctl_string_encodings {
238 ustctl_encode_none = 0,
239 ustctl_encode_UTF8 = 1,
240 ustctl_encode_ASCII = 2,
241 NR_USTCTL_STRING_ENCODINGS,
242};
243
244#define USTCTL_UST_INTEGER_TYPE_PADDING 24
245struct ustctl_integer_type {
246 uint32_t size; /* in bits */
247 uint32_t signedness;
248 uint32_t reverse_byte_order;
249 uint32_t base; /* 2, 8, 10, 16, for pretty print */
250 enum ustctl_string_encodings encoding;
251 uint16_t alignment; /* in bits */
252 char padding[USTCTL_UST_INTEGER_TYPE_PADDING];
253} LTTNG_PACKED;
254
255#define USTCTL_UST_FLOAT_TYPE_PADDING 24
256struct ustctl_float_type {
257 uint32_t exp_dig; /* exponent digits, in bits */
258 uint32_t mant_dig; /* mantissa digits, in bits */
259 uint32_t reverse_byte_order;
260 uint16_t alignment; /* in bits */
261 char padding[USTCTL_UST_FLOAT_TYPE_PADDING];
262} LTTNG_PACKED;
263
264#define USTCTL_UST_BASIC_TYPE_PADDING 296
265union _ustctl_basic_type {
266 struct ustctl_integer_type integer;
267 struct {
268 enum ustctl_string_encodings encoding;
269 } string;
270 struct ustctl_float_type _float;
271 char padding[USTCTL_UST_BASIC_TYPE_PADDING];
272} LTTNG_PACKED;
273
274struct ustctl_basic_type {
275 enum ustctl_abstract_types atype;
276 union {
277 union _ustctl_basic_type basic;
278 } u;
279} LTTNG_PACKED;
280
281#define USTCTL_UST_TYPE_PADDING 128
282struct ustctl_type {
283 enum ustctl_abstract_types atype;
284 union {
285 union _ustctl_basic_type basic;
286 struct {
287 struct ustctl_basic_type elem_type;
288 uint32_t length; /* num. elems. */
289 } array;
290 struct {
291 struct ustctl_basic_type length_type;
292 struct ustctl_basic_type elem_type;
293 } sequence;
294 char padding[USTCTL_UST_TYPE_PADDING];
295 } u;
296} LTTNG_PACKED;
297
298#define USTCTL_UST_FIELD_PADDING 28
299struct ustctl_field {
300 char name[LTTNG_UST_SYM_NAME_LEN];
301 struct ustctl_type type;
302 char padding[USTCTL_UST_FIELD_PADDING];
303} LTTNG_PACKED;
304
305/*
306 * Returns 0 on success, negative error value on error.
307 * If an error other than -LTTNG_UST_ERR_UNSUP_MAJOR is returned,
308 * the output fields are not populated.
309 */
310int ustctl_recv_reg_msg(int sock,
311 enum ustctl_socket_type *type,
312 uint32_t *major,
313 uint32_t *minor,
314 uint32_t *pid,
315 uint32_t *ppid,
316 uint32_t *uid,
317 uint32_t *gid,
318 uint32_t *bits_per_long,
319 uint32_t *uint8_t_alignment,
320 uint32_t *uint16_t_alignment,
321 uint32_t *uint32_t_alignment,
322 uint32_t *uint64_t_alignment,
323 uint32_t *long_alignment,
324 int *byte_order,
325 char *name); /* size LTTNG_UST_ABI_PROCNAME_LEN */
326
327/*
328 * Returns 0 on success, negative UST or system error value on error.
329 * Receive the notification command. The "notify_cmd" can then be used
330 * by the caller to find out which ustctl_recv_* function should be
331 * called to receive the notification, and which ustctl_reply_* is
332 * appropriate.
333 */
334int ustctl_recv_notify(int sock, enum ustctl_notify_cmd *notify_cmd);
335
336/*
337 * Returns 0 on success, negative UST or system error value on error.
338 */
339int ustctl_recv_register_event(int sock,
340 int *session_objd, /* session descriptor (output) */
341 int *channel_objd, /* channel descriptor (output) */
342 char *event_name, /*
343 * event name (output,
344 * size LTTNG_UST_SYM_NAME_LEN)
345 */
346 int *loglevel,
347 char **signature, /*
348 * event signature
349 * (output, dynamically
350 * allocated, must be free(3)'d
351 * by the caller if function
352 * returns success.)
353 */
354 size_t *nr_fields,
355 struct ustctl_field **fields,
356 char **model_emf_uri);
357
358/*
359 * Returns 0 on success, negative error value on error.
360 */
361int ustctl_reply_register_event(int sock,
362 uint32_t id, /* event id (input) */
363 int ret_code); /* return code. 0 ok, negative error */
364
365/*
366 * Returns 0 on success, negative UST or system error value on error.
367 */
368int ustctl_recv_register_channel(int sock,
369 int *session_objd, /* session descriptor (output) */
370 int *channel_objd, /* channel descriptor (output) */
371 size_t *nr_fields, /* context fields */
372 struct ustctl_field **fields);
373
374/*
375 * Returns 0 on success, negative error value on error.
376 */
377int ustctl_reply_register_channel(int sock,
378 uint32_t chan_id,
379 enum ustctl_channel_header header_type,
380 int ret_code); /* return code. 0 ok, negative error */
381
f3105c67 382#endif /* _LTTNG_UST_CTL_H */
This page took 0.042516 seconds and 4 git commands to generate.