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