Combine common recorder/notifier functions to lttng_free_event_filter_runtime
[lttng-ust.git] / liblttng-ust / ust-events-internal.h
CommitLineData
d871c65b 1/*
c0c0989a 2 * SPDX-License-Identifier: MIT
d871c65b 3 *
c0c0989a 4 * Copyright 2019 (c) Francis Deslauriers <francis.deslauriers@efficios.com>
d871c65b
FD
5 */
6
c0c0989a
MJ
7#ifndef _LTTNG_UST_EVENTS_INTERNAL_H
8#define _LTTNG_UST_EVENTS_INTERNAL_H
9
d871c65b
FD
10#include <stdint.h>
11
12#include <urcu/list.h>
13#include <urcu/hlist.h>
14
864a1eda 15#include <ust-helper.h>
d871c65b
FD
16#include <lttng/ust-events.h>
17
fd17d7ce
MD
18
19struct lttng_ust_abi_obj;
20
21union lttng_ust_abi_args {
22 struct {
23 void *chan_data;
24 int wakeup_fd;
25 } channel;
26 struct {
27 int shm_fd;
28 int wakeup_fd;
29 } stream;
30 struct {
31 struct lttng_ust_abi_field_iter entry;
32 } field_list;
33 struct {
34 char *ctxname;
35 } app_context;
36 struct {
37 int event_notifier_notif_fd;
38 } event_notifier_handle;
39 struct {
40 void *counter_data;
41 } counter;
42 struct {
43 int shm_fd;
44 } counter_shm;
45};
46
47struct lttng_ust_abi_objd_ops {
48 long (*cmd)(int objd, unsigned int cmd, unsigned long arg,
49 union lttng_ust_abi_args *args, void *owner);
50 int (*release)(int objd);
51};
52
8665f6a4
MJ
53enum lttng_enabler_format_type {
54 LTTNG_ENABLER_FORMAT_STAR_GLOB,
55 LTTNG_ENABLER_FORMAT_EVENT,
56};
57
58/*
59 * Enabler field, within whatever object is enabling an event. Target of
60 * backward reference.
61 */
62struct lttng_enabler {
63 enum lttng_enabler_format_type format_type;
64
65 /* head list of struct lttng_ust_filter_bytecode_node */
66 struct cds_list_head filter_bytecode_head;
67 /* head list of struct lttng_ust_excluder_node */
68 struct cds_list_head excluder_head;
69
fd17d7ce 70 struct lttng_ust_abi_event event_param;
8665f6a4
MJ
71 unsigned int enabled:1;
72};
73
d871c65b
FD
74struct lttng_event_enabler {
75 struct lttng_enabler base;
76 struct cds_list_head node; /* per-session list of enablers */
77 struct lttng_channel *chan;
78 /*
79 * Unused, but kept around to make it explicit that the tracer can do
80 * it.
81 */
82 struct lttng_ctx *ctx;
83};
84
d8d2416d
FD
85struct lttng_event_notifier_enabler {
86 struct lttng_enabler base;
6566528b 87 uint64_t error_counter_index;
d37ecb3f
FD
88 struct cds_list_head node; /* per-app list of event_notifier enablers */
89 struct cds_list_head capture_bytecode_head;
d8d2416d
FD
90 struct lttng_event_notifier_group *group; /* weak ref */
91 uint64_t user_token; /* User-provided token */
d37ecb3f 92 uint64_t num_captures;
d8d2416d
FD
93};
94
ab249ecf
FD
95enum lttng_ust_bytecode_node_type {
96 LTTNG_UST_BYTECODE_NODE_TYPE_FILTER,
d37ecb3f 97 LTTNG_UST_BYTECODE_NODE_TYPE_CAPTURE,
ab249ecf
FD
98};
99
100struct lttng_ust_bytecode_node {
101 enum lttng_ust_bytecode_node_type type;
92495593
FD
102 struct cds_list_head node;
103 struct lttng_enabler *enabler;
ab249ecf
FD
104 struct {
105 uint32_t len;
106 uint32_t reloc_offset;
107 uint64_t seqnum;
108 char data[];
109 } bc;
92495593
FD
110};
111
112struct lttng_ust_excluder_node {
113 struct cds_list_head node;
114 struct lttng_enabler *enabler;
115 /*
116 * struct lttng_ust_event_exclusion had variable sized array,
117 * must be last field.
118 */
fd17d7ce 119 struct lttng_ust_abi_event_exclusion excluder;
92495593
FD
120};
121
bb7ad29d
MJ
122/* Data structures used by the tracer. */
123
124struct tp_list_entry {
fd17d7ce 125 struct lttng_ust_abi_tracepoint_iter tp;
bb7ad29d
MJ
126 struct cds_list_head head;
127};
128
129struct lttng_ust_tracepoint_list {
130 struct tp_list_entry *iter;
131 struct cds_list_head head;
132};
133
134struct tp_field_list_entry {
fd17d7ce 135 struct lttng_ust_abi_field_iter field;
bb7ad29d
MJ
136 struct cds_list_head head;
137};
138
139struct lttng_ust_field_list {
140 struct tp_field_list_entry *iter;
141 struct cds_list_head head;
142};
143
144/*
145 * Objects in a linked-list of enablers, owned by an event or event_notifier.
146 * This is used because an event (or a event_notifier) can be enabled by more
147 * than one enabler and we want a quick way to iterate over all enablers of an
148 * object.
149 *
150 * For example, event rules "my_app:a*" and "my_app:ab*" will both match the
151 * event with the name "my_app:abc".
152 */
153struct lttng_enabler_ref {
154 struct cds_list_head node; /* enabler ref list */
155 struct lttng_enabler *ref; /* backward ref */
156};
157
158#define LTTNG_COUNTER_DIMENSION_MAX 8
159struct lttng_counter_dimension {
160 uint64_t size;
161 uint64_t underflow_index;
162 uint64_t overflow_index;
163 uint8_t has_underflow;
164 uint8_t has_overflow;
165};
166
167struct lttng_counter {
168 int objd;
169 struct lttng_event_notifier_group *event_notifier_group; /* owner */
170 struct lttng_counter_transport *transport;
171 struct lib_counter *counter;
172 struct lttng_counter_ops *ops;
173};
174
175struct lttng_event_notifier_group {
176 int objd;
177 void *owner;
178 int notification_fd;
179 struct cds_list_head node; /* Event notifier group handle list */
180 struct cds_list_head enablers_head;
181 struct cds_list_head event_notifiers_head; /* list of event_notifiers */
182 struct lttng_ust_event_notifier_ht event_notifiers_ht; /* hashtable of event_notifiers */
183 struct lttng_ctx *ctx; /* contexts for filters. */
184
185 struct lttng_counter *error_counter;
186 size_t error_counter_len;
187};
188
189struct lttng_transport {
190 char *name;
191 struct cds_list_head node;
192 struct lttng_channel_ops ops;
193 const struct lttng_ust_lib_ring_buffer_config *client_config;
194};
195
196struct lttng_counter_transport {
197 char *name;
198 struct cds_list_head node;
199 struct lttng_counter_ops ops;
200 const struct lib_counter_config *client_config;
201};
202
80333dfa 203struct lttng_ust_event_common_private {
7ee76145 204 struct lttng_ust_event_common *pub; /* Public event interface */
68bb7559
MD
205
206 const struct lttng_event_desc *desc;
68bb7559
MD
207 /* Backward references: list of lttng_enabler_ref (ref to enablers) */
208 struct cds_list_head enablers_ref_head;
68bb7559 209 int registered; /* has reg'd tracepoint probe */
115db533 210 uint64_t user_token;
68bb7559
MD
211};
212
2e70391c 213struct lttng_ust_event_recorder_private {
80333dfa
MD
214 struct lttng_ust_event_common_private parent;
215
2e70391c
MD
216 struct lttng_ust_event_recorder *pub; /* Public event interface */
217 struct cds_list_head node; /* Event list in session */
218 struct cds_hlist_node hlist; /* session ht of events */
80333dfa
MD
219};
220
115db533
MD
221struct lttng_ust_event_notifier_private {
222 struct lttng_ust_event_common_private parent;
223
d7d45c0d 224 struct lttng_ust_event_notifier *pub; /* Public event notifier interface */
115db533
MD
225 struct cds_hlist_node hlist; /* hashtable of event_notifiers */
226 struct cds_list_head node; /* event_notifier list in session */
227 struct lttng_event_notifier_group *group; /* weak ref */
228 size_t num_captures; /* Needed to allocate the msgpack array. */
229 uint64_t error_counter_index;
230};
231
362a65de
MD
232struct lttng_ust_bytecode_runtime_private {
233 struct bytecode_runtime *pub; /* Public bytecode runtime interface */
234
235 struct lttng_ust_bytecode_node *bc;
236 int link_failed;
237 /*
238 * Pointer to a URCU-protected pointer owned by an `struct
239 * lttng_session`or `struct lttng_event_notifier_group`.
240 */
241 struct lttng_ctx **pctx;
242};
243
bdb12629
MD
244struct lttng_ust_session_private {
245 struct lttng_session *pub; /* Public session interface */
246
247 int been_active; /* Been active ? */
248 int objd; /* Object associated */
249 struct cds_list_head chan_head; /* Channel list head */
250 struct cds_list_head events_head; /* list of events */
251 struct cds_list_head node; /* Session list */
252
253 /* New UST 2.1 */
254 /* List of enablers */
255 struct cds_list_head enablers_head;
256 struct lttng_ust_event_ht events_ht; /* ht of events */
257 void *owner; /* object owner */
258 int tstate:1; /* Transient enable state */
259
260 /* New UST 2.4 */
261 int statedump_pending:1;
262
263 /* New UST 2.8 */
264 struct lttng_ust_enum_ht enums_ht; /* ht of enumerations */
265 struct cds_list_head enums_head;
266 struct lttng_ctx *ctx; /* contexts for filters. */
267};
268
d871c65b
FD
269static inline
270struct lttng_enabler *lttng_event_enabler_as_enabler(
271 struct lttng_event_enabler *event_enabler)
272{
273 return &event_enabler->base;
274}
275
d8d2416d
FD
276static inline
277struct lttng_enabler *lttng_event_notifier_enabler_as_enabler(
278 struct lttng_event_notifier_enabler *event_notifier_enabler)
279{
280 return &event_notifier_enabler->base;
281}
d871c65b
FD
282
283/*
284 * Allocate and initialize a `struct lttng_event_enabler` object.
285 *
286 * On success, returns a `struct lttng_event_enabler`,
287 * On memory error, returns NULL.
288 */
289LTTNG_HIDDEN
290struct lttng_event_enabler *lttng_event_enabler_create(
291 enum lttng_enabler_format_type format_type,
fd17d7ce 292 struct lttng_ust_abi_event *event_param,
d871c65b
FD
293 struct lttng_channel *chan);
294
295/*
296 * Destroy a `struct lttng_event_enabler` object.
297 */
298LTTNG_HIDDEN
299void lttng_event_enabler_destroy(struct lttng_event_enabler *enabler);
300
301/*
302 * Enable a `struct lttng_event_enabler` object and all events related to this
303 * enabler.
304 */
305LTTNG_HIDDEN
306int lttng_event_enabler_enable(struct lttng_event_enabler *enabler);
307
308/*
309 * Disable a `struct lttng_event_enabler` object and all events related to this
310 * enabler.
311 */
312LTTNG_HIDDEN
313int lttng_event_enabler_disable(struct lttng_event_enabler *enabler);
314
315/*
316 * Attach filter bytecode program to `struct lttng_event_enabler` and all
317 * events related to this enabler.
318 */
319LTTNG_HIDDEN
a56fd376
FD
320int lttng_event_enabler_attach_filter_bytecode(
321 struct lttng_event_enabler *enabler,
ab89263e 322 struct lttng_ust_bytecode_node **bytecode);
d871c65b
FD
323
324/*
325 * Attach an application context to an event enabler.
326 *
327 * Not implemented.
328 */
329LTTNG_HIDDEN
330int lttng_event_enabler_attach_context(struct lttng_event_enabler *enabler,
fd17d7ce 331 struct lttng_ust_abi_context *ctx);
d871c65b
FD
332
333/*
334 * Attach exclusion list to `struct lttng_event_enabler` and all
335 * events related to this enabler.
336 */
337LTTNG_HIDDEN
338int lttng_event_enabler_attach_exclusion(struct lttng_event_enabler *enabler,
e9fe6aad 339 struct lttng_ust_excluder_node **excluder);
d871c65b
FD
340
341/*
d37ecb3f
FD
342 * Synchronize bytecodes for the enabler and the instance (event or
343 * event_notifier).
d871c65b 344 *
621c07fc 345 * This function goes over all bytecode programs of the enabler (event or
d37ecb3f 346 * event_notifier enabler) to ensure each is linked to the provided instance.
d871c65b
FD
347 */
348LTTNG_HIDDEN
53b9d7db
FD
349void lttng_enabler_link_bytecode(const struct lttng_event_desc *event_desc,
350 struct lttng_ctx **ctx,
621c07fc
FD
351 struct cds_list_head *instance_bytecode_runtime_head,
352 struct cds_list_head *enabler_bytecode_runtime_head);
d871c65b 353
d8d2416d
FD
354/*
355 * Allocate and initialize a `struct lttng_event_notifier_group` object.
356 *
357 * On success, returns a `struct lttng_triggre_group`,
358 * on memory error, returns NULL.
359 */
360LTTNG_HIDDEN
361struct lttng_event_notifier_group *lttng_event_notifier_group_create(void);
362
363/*
364 * Destroy a `struct lttng_event_notifier_group` object.
365 */
366LTTNG_HIDDEN
367void lttng_event_notifier_group_destroy(
368 struct lttng_event_notifier_group *event_notifier_group);
369
370/*
371 * Allocate and initialize a `struct lttng_event_notifier_enabler` object.
372 *
373 * On success, returns a `struct lttng_event_notifier_enabler`,
374 * On memory error, returns NULL.
375 */
376LTTNG_HIDDEN
377struct lttng_event_notifier_enabler *lttng_event_notifier_enabler_create(
378 struct lttng_event_notifier_group *event_notifier_group,
379 enum lttng_enabler_format_type format_type,
fd17d7ce 380 struct lttng_ust_abi_event_notifier *event_notifier_param);
d8d2416d
FD
381
382/*
383 * Destroy a `struct lttng_event_notifier_enabler` object.
384 */
385LTTNG_HIDDEN
386void lttng_event_notifier_enabler_destroy(
387 struct lttng_event_notifier_enabler *event_notifier_enabler);
388
389/*
390 * Enable a `struct lttng_event_notifier_enabler` object and all event
391 * notifiers related to this enabler.
392 */
393LTTNG_HIDDEN
394int lttng_event_notifier_enabler_enable(
395 struct lttng_event_notifier_enabler *event_notifier_enabler);
396
397/*
398 * Disable a `struct lttng_event_notifier_enabler` object and all event
399 * notifiers related to this enabler.
400 */
401LTTNG_HIDDEN
402int lttng_event_notifier_enabler_disable(
403 struct lttng_event_notifier_enabler *event_notifier_enabler);
404
405/*
406 * Attach filter bytecode program to `struct lttng_event_notifier_enabler` and
407 * all event notifiers related to this enabler.
408 */
409LTTNG_HIDDEN
a56fd376 410int lttng_event_notifier_enabler_attach_filter_bytecode(
d8d2416d 411 struct lttng_event_notifier_enabler *event_notifier_enabler,
ab89263e 412 struct lttng_ust_bytecode_node **bytecode);
d8d2416d 413
d37ecb3f
FD
414/*
415 * Attach capture bytecode program to `struct lttng_event_notifier_enabler` and
416 * all event_notifiers related to this enabler.
417 */
418LTTNG_HIDDEN
419int lttng_event_notifier_enabler_attach_capture_bytecode(
420 struct lttng_event_notifier_enabler *event_notifier_enabler,
49cde654 421 struct lttng_ust_bytecode_node **bytecode);
d37ecb3f 422
d8d2416d
FD
423/*
424 * Attach exclusion list to `struct lttng_event_notifier_enabler` and all
425 * event notifiers related to this enabler.
426 */
427LTTNG_HIDDEN
428int lttng_event_notifier_enabler_attach_exclusion(
429 struct lttng_event_notifier_enabler *event_notifier_enabler,
e9fe6aad 430 struct lttng_ust_excluder_node **excluder);
d8d2416d 431
7753d283 432LTTNG_HIDDEN
b1f720f0 433void lttng_free_event_filter_runtime(struct lttng_ust_event_common *event);
d8d2416d
FD
434
435/*
436 * Connect the probe on all enablers matching this event description.
437 * Called on library load.
438 */
439LTTNG_HIDDEN
440int lttng_fix_pending_event_notifiers(void);
441
67d4e8f5
MJ
442LTTNG_HIDDEN
443struct lttng_counter *lttng_ust_counter_create(
444 const char *counter_transport_name,
445 size_t number_dimensions, const struct lttng_counter_dimension *dimensions);
446
bd8c1787
MJ
447#ifdef HAVE_PERF_EVENT
448
449LTTNG_HIDDEN
450int lttng_add_perf_counter_to_ctx(uint32_t type,
451 uint64_t config,
452 const char *name,
453 struct lttng_ctx **ctx);
454LTTNG_HIDDEN
455int lttng_perf_counter_init(void);
456LTTNG_HIDDEN
457void lttng_perf_counter_exit(void);
458
459#else /* #ifdef HAVE_PERF_EVENT */
460
461static inline
462int lttng_add_perf_counter_to_ctx(uint32_t type,
463 uint64_t config,
464 const char *name,
465 struct lttng_ctx **ctx)
466{
467 return -ENOSYS;
468}
469static inline
470int lttng_perf_counter_init(void)
471{
472 return 0;
473}
474static inline
475void lttng_perf_counter_exit(void)
476{
477}
478#endif /* #else #ifdef HAVE_PERF_EVENT */
479
7753d283
MJ
480LTTNG_HIDDEN
481int lttng_probes_get_event_list(struct lttng_ust_tracepoint_list *list);
482LTTNG_HIDDEN
483void lttng_probes_prune_event_list(struct lttng_ust_tracepoint_list *list);
484
485LTTNG_HIDDEN
486int lttng_probes_get_field_list(struct lttng_ust_field_list *list);
487LTTNG_HIDDEN
488void lttng_probes_prune_field_list(struct lttng_ust_field_list *list);
489
490LTTNG_HIDDEN
fd17d7ce 491struct lttng_ust_abi_tracepoint_iter *
7753d283
MJ
492 lttng_ust_tracepoint_list_get_iter_next(struct lttng_ust_tracepoint_list *list);
493LTTNG_HIDDEN
fd17d7ce 494struct lttng_ust_abi_field_iter *
7753d283
MJ
495 lttng_ust_field_list_get_iter_next(struct lttng_ust_field_list *list);
496
497LTTNG_HIDDEN
498struct lttng_session *lttng_session_create(void);
499LTTNG_HIDDEN
500int lttng_session_enable(struct lttng_session *session);
501LTTNG_HIDDEN
502int lttng_session_disable(struct lttng_session *session);
503LTTNG_HIDDEN
504int lttng_session_statedump(struct lttng_session *session);
505LTTNG_HIDDEN
506void lttng_session_destroy(struct lttng_session *session);
507
508LTTNG_HIDDEN
509struct cds_list_head *lttng_get_sessions(void);
510
511LTTNG_HIDDEN
512void lttng_handle_pending_statedump(void *owner);
513
514LTTNG_HIDDEN
515struct lttng_channel *lttng_channel_create(struct lttng_session *session,
516 const char *transport_name,
517 void *buf_addr,
518 size_t subbuf_size, size_t num_subbuf,
519 unsigned int switch_timer_interval,
520 unsigned int read_timer_interval,
521 int **shm_fd, int **wait_fd,
522 uint64_t **memory_map_size,
523 struct lttng_channel *chan_priv_init);
524
525LTTNG_HIDDEN
526int lttng_channel_enable(struct lttng_channel *channel);
527LTTNG_HIDDEN
528int lttng_channel_disable(struct lttng_channel *channel);
529
530LTTNG_HIDDEN
531void lttng_transport_register(struct lttng_transport *transport);
532LTTNG_HIDDEN
533void lttng_transport_unregister(struct lttng_transport *transport);
534
535LTTNG_HIDDEN
536void lttng_probe_provider_unregister_events(struct lttng_probe_desc *desc);
537
538LTTNG_HIDDEN
539int lttng_fix_pending_events(void);
540
541LTTNG_HIDDEN
542struct cds_list_head *lttng_get_probe_list_head(void);
543
544LTTNG_HIDDEN
545struct lttng_enum *lttng_ust_enum_get_from_desc(struct lttng_session *session,
546 const struct lttng_enum_desc *enum_desc);
547
fd17d7ce
MD
548LTTNG_HIDDEN
549int lttng_abi_create_root_handle(void);
550
551LTTNG_HIDDEN
552const struct lttng_ust_abi_objd_ops *lttng_ust_abi_objd_ops(int id);
553LTTNG_HIDDEN
554int lttng_ust_abi_objd_unref(int id, int is_owner);
555LTTNG_HIDDEN
556void lttng_ust_abi_exit(void);
557LTTNG_HIDDEN
558void lttng_ust_abi_events_exit(void);
559LTTNG_HIDDEN
560void lttng_ust_abi_objd_table_owner_cleanup(void *owner);
561
d871c65b 562#endif /* _LTTNG_UST_EVENTS_INTERNAL_H */
This page took 0.046115 seconds and 4 git commands to generate.