Move UST registry into sessiond and implement notifiers
[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);
149/*
150 * Send a NULL stream to finish iteration over all streams of a given
151 * channel.
152 */
153int ustctl_send_stream_to_sessiond(int sock,
154 struct ustctl_consumer_stream *stream);
155int ustctl_stream_close_wait_fd(struct ustctl_consumer_stream *stream);
156int ustctl_stream_close_wakeup_fd(struct ustctl_consumer_stream *stream);
f3105c67 157
74d81a6c
MD
158/* Create/destroy stream buffers for read */
159struct ustctl_consumer_stream *
160 ustctl_create_stream(struct ustctl_consumer_channel *channel,
161 int cpu);
162void ustctl_destroy_stream(struct ustctl_consumer_stream *stream);
f3105c67 163
74d81a6c
MD
164int ustctl_get_wait_fd(struct ustctl_consumer_stream *stream);
165int ustctl_get_wakeup_fd(struct ustctl_consumer_stream *stream);
6e922b24 166
f3105c67 167/* For mmap mode, readable without "get" operation */
74d81a6c 168int ustctl_get_mmap_len(struct ustctl_consumer_stream *stream,
f3105c67 169 unsigned long *len);
74d81a6c 170int ustctl_get_max_subbuf_size(struct ustctl_consumer_stream *stream,
f3105c67
MD
171 unsigned long *len);
172
173/*
174 * For mmap mode, operate on the current packet (between get/put or
175 * get_next/put_next).
176 */
74d81a6c
MD
177void *ustctl_get_mmap_base(struct ustctl_consumer_stream *stream);
178int ustctl_get_mmap_read_offset(struct ustctl_consumer_stream *stream,
179 unsigned long *off);
180int ustctl_get_subbuf_size(struct ustctl_consumer_stream *stream,
181 unsigned long *len);
182int ustctl_get_padded_subbuf_size(struct ustctl_consumer_stream *stream,
183 unsigned long *len);
184int ustctl_get_next_subbuf(struct ustctl_consumer_stream *stream);
185int ustctl_put_next_subbuf(struct ustctl_consumer_stream *stream);
f3105c67
MD
186
187/* snapshot */
188
74d81a6c
MD
189int ustctl_snapshot(struct ustctl_consumer_stream *stream);
190int ustctl_snapshot_get_consumed(struct ustctl_consumer_stream *stream,
191 unsigned long *pos);
192int ustctl_snapshot_get_produced(struct ustctl_consumer_stream *stream,
193 unsigned long *pos);
194int ustctl_get_subbuf(struct ustctl_consumer_stream *stream,
195 unsigned long *pos);
196int ustctl_put_subbuf(struct ustctl_consumer_stream *stream);
5f9d3dbc 197
74d81a6c
MD
198void ustctl_flush_buffer(struct ustctl_consumer_stream *stream,
199 int producer_active);
f3105c67 200
32ce8569
MD
201/* event registry management */
202
203enum ustctl_socket_type {
204 USTCTL_SOCKET_CMD = 0,
205 USTCTL_SOCKET_NOTIFY = 1,
206};
207
208enum ustctl_notify_cmd {
209 USTCTL_NOTIFY_CMD_EVENT = 0,
210 USTCTL_NOTIFY_CMD_CHANNEL = 1,
211};
212
213enum ustctl_channel_header {
214 USTCTL_CHANNEL_HEADER_UNKNOWN = 0,
215 USTCTL_CHANNEL_HEADER_COMPACT = 1,
216 USTCTL_CHANNEL_HEADER_LARGE = 2,
217};
218
219/* event type structures */
220
221enum ustctl_abstract_types {
222 ustctl_atype_integer,
223 ustctl_atype_enum,
224 ustctl_atype_array,
225 ustctl_atype_sequence,
226 ustctl_atype_string,
227 ustctl_atype_float,
228 NR_USTCTL_ABSTRACT_TYPES,
229};
230
231enum ustctl_string_encodings {
232 ustctl_encode_none = 0,
233 ustctl_encode_UTF8 = 1,
234 ustctl_encode_ASCII = 2,
235 NR_USTCTL_STRING_ENCODINGS,
236};
237
238#define USTCTL_UST_INTEGER_TYPE_PADDING 24
239struct ustctl_integer_type {
240 uint32_t size; /* in bits */
241 uint32_t signedness;
242 uint32_t reverse_byte_order;
243 uint32_t base; /* 2, 8, 10, 16, for pretty print */
244 enum ustctl_string_encodings encoding;
245 uint16_t alignment; /* in bits */
246 char padding[USTCTL_UST_INTEGER_TYPE_PADDING];
247} LTTNG_PACKED;
248
249#define USTCTL_UST_FLOAT_TYPE_PADDING 24
250struct ustctl_float_type {
251 uint32_t exp_dig; /* exponent digits, in bits */
252 uint32_t mant_dig; /* mantissa digits, in bits */
253 uint32_t reverse_byte_order;
254 uint16_t alignment; /* in bits */
255 char padding[USTCTL_UST_FLOAT_TYPE_PADDING];
256} LTTNG_PACKED;
257
258#define USTCTL_UST_BASIC_TYPE_PADDING 296
259union _ustctl_basic_type {
260 struct ustctl_integer_type integer;
261 struct {
262 enum ustctl_string_encodings encoding;
263 } string;
264 struct ustctl_float_type _float;
265 char padding[USTCTL_UST_BASIC_TYPE_PADDING];
266} LTTNG_PACKED;
267
268struct ustctl_basic_type {
269 enum ustctl_abstract_types atype;
270 union {
271 union _ustctl_basic_type basic;
272 } u;
273} LTTNG_PACKED;
274
275#define USTCTL_UST_TYPE_PADDING 128
276struct ustctl_type {
277 enum ustctl_abstract_types atype;
278 union {
279 union _ustctl_basic_type basic;
280 struct {
281 struct ustctl_basic_type elem_type;
282 uint32_t length; /* num. elems. */
283 } array;
284 struct {
285 struct ustctl_basic_type length_type;
286 struct ustctl_basic_type elem_type;
287 } sequence;
288 char padding[USTCTL_UST_TYPE_PADDING];
289 } u;
290} LTTNG_PACKED;
291
292#define USTCTL_UST_FIELD_PADDING 28
293struct ustctl_field {
294 char name[LTTNG_UST_SYM_NAME_LEN];
295 struct ustctl_type type;
296 char padding[USTCTL_UST_FIELD_PADDING];
297} LTTNG_PACKED;
298
299/*
300 * Returns 0 on success, negative error value on error.
301 * If an error other than -LTTNG_UST_ERR_UNSUP_MAJOR is returned,
302 * the output fields are not populated.
303 */
304int ustctl_recv_reg_msg(int sock,
305 enum ustctl_socket_type *type,
306 uint32_t *major,
307 uint32_t *minor,
308 uint32_t *pid,
309 uint32_t *ppid,
310 uint32_t *uid,
311 uint32_t *gid,
312 uint32_t *bits_per_long,
313 uint32_t *uint8_t_alignment,
314 uint32_t *uint16_t_alignment,
315 uint32_t *uint32_t_alignment,
316 uint32_t *uint64_t_alignment,
317 uint32_t *long_alignment,
318 int *byte_order,
319 char *name); /* size LTTNG_UST_ABI_PROCNAME_LEN */
320
321/*
322 * Returns 0 on success, negative UST or system error value on error.
323 * Receive the notification command. The "notify_cmd" can then be used
324 * by the caller to find out which ustctl_recv_* function should be
325 * called to receive the notification, and which ustctl_reply_* is
326 * appropriate.
327 */
328int ustctl_recv_notify(int sock, enum ustctl_notify_cmd *notify_cmd);
329
330/*
331 * Returns 0 on success, negative UST or system error value on error.
332 */
333int ustctl_recv_register_event(int sock,
334 int *session_objd, /* session descriptor (output) */
335 int *channel_objd, /* channel descriptor (output) */
336 char *event_name, /*
337 * event name (output,
338 * size LTTNG_UST_SYM_NAME_LEN)
339 */
340 int *loglevel,
341 char **signature, /*
342 * event signature
343 * (output, dynamically
344 * allocated, must be free(3)'d
345 * by the caller if function
346 * returns success.)
347 */
348 size_t *nr_fields,
349 struct ustctl_field **fields,
350 char **model_emf_uri);
351
352/*
353 * Returns 0 on success, negative error value on error.
354 */
355int ustctl_reply_register_event(int sock,
356 uint32_t id, /* event id (input) */
357 int ret_code); /* return code. 0 ok, negative error */
358
359/*
360 * Returns 0 on success, negative UST or system error value on error.
361 */
362int ustctl_recv_register_channel(int sock,
363 int *session_objd, /* session descriptor (output) */
364 int *channel_objd, /* channel descriptor (output) */
365 size_t *nr_fields, /* context fields */
366 struct ustctl_field **fields);
367
368/*
369 * Returns 0 on success, negative error value on error.
370 */
371int ustctl_reply_register_channel(int sock,
372 uint32_t chan_id,
373 enum ustctl_channel_header header_type,
374 int ret_code); /* return code. 0 ok, negative error */
375
f3105c67 376#endif /* _LTTNG_UST_CTL_H */
This page took 0.049792 seconds and 4 git commands to generate.