2 * Copyright (C) 2019 Jonathan Rajotte
3 * <jonathan.rajotte-julien@efficios.com>
5 * SPDX-License-Identifier: LGPL-2.1-only
9 #include <common/error.hpp>
10 #include <common/hashtable/hashtable.hpp>
11 #include <common/hashtable/utils.hpp>
12 #include <common/macros.hpp>
13 #include <common/mi-lttng.hpp>
14 #include <common/payload-view.hpp>
15 #include <common/payload.hpp>
17 #include <lttng/event-rule/event-rule-internal.hpp>
18 #include <lttng/event-rule/jul-logging-internal.hpp>
19 #include <lttng/event-rule/kernel-kprobe-internal.hpp>
20 #include <lttng/event-rule/kernel-syscall-internal.hpp>
21 #include <lttng/event-rule/kernel-tracepoint-internal.hpp>
22 #include <lttng/event-rule/kernel-uprobe-internal.hpp>
23 #include <lttng/event-rule/log4j-logging-internal.hpp>
24 #include <lttng/event-rule/log4j2-logging-internal.hpp>
25 #include <lttng/event-rule/python-logging-internal.hpp>
26 #include <lttng/event-rule/user-tracepoint-internal.hpp>
30 enum lttng_event_rule_type
lttng_event_rule_get_type(const struct lttng_event_rule
*event_rule
)
32 return event_rule
? event_rule
->type
: LTTNG_EVENT_RULE_TYPE_UNKNOWN
;
35 enum lttng_domain_type
lttng_event_rule_get_domain_type(const struct lttng_event_rule
*event_rule
)
37 enum lttng_domain_type domain_type
= LTTNG_DOMAIN_NONE
;
39 switch (lttng_event_rule_get_type(event_rule
)) {
40 case LTTNG_EVENT_RULE_TYPE_USER_TRACEPOINT
:
41 domain_type
= LTTNG_DOMAIN_UST
;
43 case LTTNG_EVENT_RULE_TYPE_JUL_LOGGING
:
44 domain_type
= LTTNG_DOMAIN_JUL
;
46 case LTTNG_EVENT_RULE_TYPE_LOG4J_LOGGING
:
47 domain_type
= LTTNG_DOMAIN_LOG4J
;
49 case LTTNG_EVENT_RULE_TYPE_LOG4J2_LOGGING
:
50 domain_type
= LTTNG_DOMAIN_LOG4J2
;
52 case LTTNG_EVENT_RULE_TYPE_PYTHON_LOGGING
:
53 domain_type
= LTTNG_DOMAIN_PYTHON
;
55 case LTTNG_EVENT_RULE_TYPE_KERNEL_SYSCALL
:
56 case LTTNG_EVENT_RULE_TYPE_KERNEL_KPROBE
:
57 case LTTNG_EVENT_RULE_TYPE_KERNEL_UPROBE
:
58 case LTTNG_EVENT_RULE_TYPE_KERNEL_TRACEPOINT
:
59 domain_type
= LTTNG_DOMAIN_KERNEL
;
61 case LTTNG_EVENT_RULE_TYPE_UNKNOWN
:
62 domain_type
= LTTNG_DOMAIN_NONE
;
69 static void lttng_event_rule_release(struct urcu_ref
*ref
)
71 struct lttng_event_rule
*event_rule
=
72 lttng::utils::container_of(ref
, <tng_event_rule::ref
);
74 LTTNG_ASSERT(event_rule
->destroy
);
75 event_rule
->destroy(event_rule
);
78 void lttng_event_rule_destroy(struct lttng_event_rule
*event_rule
)
80 lttng_event_rule_put(event_rule
);
83 bool lttng_event_rule_validate(const struct lttng_event_rule
*event_rule
)
92 if (!event_rule
->validate
) {
93 /* Sub-class guarantees that it can never be invalid. */
98 valid
= event_rule
->validate(event_rule
);
103 int lttng_event_rule_serialize(const struct lttng_event_rule
*event_rule
,
104 struct lttng_payload
*payload
)
107 struct lttng_event_rule_comm event_rule_comm
= {};
114 event_rule_comm
.event_rule_type
= (int8_t) event_rule
->type
;
116 ret
= lttng_dynamic_buffer_append(
117 &payload
->buffer
, &event_rule_comm
, sizeof(event_rule_comm
));
122 ret
= event_rule
->serialize(event_rule
, payload
);
130 bool lttng_event_rule_is_equal(const struct lttng_event_rule
*a
, const struct lttng_event_rule
*b
)
132 bool is_equal
= false;
138 if (a
->type
!= b
->type
) {
147 is_equal
= a
->equal
? a
->equal(a
, b
) : true;
152 ssize_t
lttng_event_rule_create_from_payload(struct lttng_payload_view
*view
,
153 struct lttng_event_rule
**event_rule
)
155 ssize_t ret
, consumed
= 0;
156 event_rule_create_from_payload_cb create_from_payload
= nullptr;
157 const struct lttng_event_rule_comm
*event_rule_comm
;
158 const struct lttng_payload_view event_rule_comm_view
=
159 lttng_payload_view_from_view(view
, 0, sizeof(*event_rule_comm
));
161 if (!view
|| !event_rule
) {
166 if (!lttng_payload_view_is_valid(&event_rule_comm_view
)) {
171 DBG("Deserializing event_rule from payload");
172 event_rule_comm
= (const struct lttng_event_rule_comm
*) event_rule_comm_view
.buffer
.data
;
173 consumed
+= sizeof(*event_rule_comm
);
175 switch ((enum lttng_event_rule_type
) event_rule_comm
->event_rule_type
) {
176 case LTTNG_EVENT_RULE_TYPE_KERNEL_KPROBE
:
177 create_from_payload
= lttng_event_rule_kernel_kprobe_create_from_payload
;
179 case LTTNG_EVENT_RULE_TYPE_KERNEL_UPROBE
:
180 create_from_payload
= lttng_event_rule_kernel_uprobe_create_from_payload
;
182 case LTTNG_EVENT_RULE_TYPE_KERNEL_SYSCALL
:
183 create_from_payload
= lttng_event_rule_kernel_syscall_create_from_payload
;
185 case LTTNG_EVENT_RULE_TYPE_KERNEL_TRACEPOINT
:
186 create_from_payload
= lttng_event_rule_kernel_tracepoint_create_from_payload
;
188 case LTTNG_EVENT_RULE_TYPE_USER_TRACEPOINT
:
189 create_from_payload
= lttng_event_rule_user_tracepoint_create_from_payload
;
191 case LTTNG_EVENT_RULE_TYPE_JUL_LOGGING
:
192 create_from_payload
= lttng_event_rule_jul_logging_create_from_payload
;
194 case LTTNG_EVENT_RULE_TYPE_LOG4J_LOGGING
:
195 create_from_payload
= lttng_event_rule_log4j_logging_create_from_payload
;
197 case LTTNG_EVENT_RULE_TYPE_LOG4J2_LOGGING
:
198 create_from_payload
= lttng_event_rule_log4j2_logging_create_from_payload
;
200 case LTTNG_EVENT_RULE_TYPE_PYTHON_LOGGING
:
201 create_from_payload
= lttng_event_rule_python_logging_create_from_payload
;
204 ERR("Attempted to create event rule of unknown type (%i)",
205 (int) event_rule_comm
->event_rule_type
);
210 LTTNG_ASSERT(create_from_payload
);
213 struct lttng_payload_view child_view
=
214 lttng_payload_view_from_view(view
, consumed
, -1);
216 ret
= create_from_payload(&child_view
, event_rule
);
224 if (!lttng_event_rule_validate(*event_rule
)) {
234 void lttng_event_rule_init(struct lttng_event_rule
*event_rule
, enum lttng_event_rule_type type
)
236 urcu_ref_init(&event_rule
->ref
);
237 event_rule
->type
= type
;
240 bool lttng_event_rule_get(struct lttng_event_rule
*event_rule
)
242 return urcu_ref_get_unless_zero(&event_rule
->ref
);
245 void lttng_event_rule_put(struct lttng_event_rule
*event_rule
)
251 LTTNG_ASSERT(event_rule
->ref
.refcount
);
252 urcu_ref_put(&event_rule
->ref
, lttng_event_rule_release
);
255 enum lttng_error_code
256 lttng_event_rule_generate_filter_bytecode(struct lttng_event_rule
*rule
,
257 const struct lttng_credentials
*creds
)
259 LTTNG_ASSERT(rule
->generate_filter_bytecode
);
260 return rule
->generate_filter_bytecode(rule
, creds
);
263 const char *lttng_event_rule_get_filter(const struct lttng_event_rule
*rule
)
265 LTTNG_ASSERT(rule
->get_filter
);
266 return rule
->get_filter(rule
);
269 const struct lttng_bytecode
*
270 lttng_event_rule_get_filter_bytecode(const struct lttng_event_rule
*rule
)
272 LTTNG_ASSERT(rule
->get_filter_bytecode
);
273 return rule
->get_filter_bytecode(rule
);
276 enum lttng_event_rule_generate_exclusions_status
277 lttng_event_rule_generate_exclusions(const struct lttng_event_rule
*rule
,
278 struct lttng_event_exclusion
**exclusions
)
280 LTTNG_ASSERT(rule
->generate_exclusions
);
281 return rule
->generate_exclusions(rule
, exclusions
);
284 struct lttng_event
*lttng_event_rule_generate_lttng_event(const struct lttng_event_rule
*rule
)
286 LTTNG_ASSERT(rule
->generate_lttng_event
);
287 return rule
->generate_lttng_event(rule
);
290 bool lttng_event_rule_targets_agent_domain(const struct lttng_event_rule
*rule
)
292 bool targets_agent_domain
= false;
293 const lttng_domain_type type
= lttng_event_rule_get_domain_type(rule
);
296 case LTTNG_DOMAIN_JUL
:
297 case LTTNG_DOMAIN_LOG4J
:
298 case LTTNG_DOMAIN_LOG4J2
:
299 case LTTNG_DOMAIN_PYTHON
:
300 targets_agent_domain
= true;
302 case LTTNG_DOMAIN_UST
:
303 case LTTNG_DOMAIN_KERNEL
:
304 targets_agent_domain
= false;
310 return targets_agent_domain
;
313 const char *lttng_event_rule_type_str(enum lttng_event_rule_type type
)
316 case LTTNG_EVENT_RULE_TYPE_UNKNOWN
:
318 case LTTNG_EVENT_RULE_TYPE_KERNEL_SYSCALL
:
319 return "kernel syscall";
320 case LTTNG_EVENT_RULE_TYPE_KERNEL_KPROBE
:
321 return "kernel kprobe";
322 case LTTNG_EVENT_RULE_TYPE_KERNEL_UPROBE
:
323 return "kernel uprobe";
324 case LTTNG_EVENT_RULE_TYPE_KERNEL_TRACEPOINT
:
325 return "kernel tracepoint";
326 case LTTNG_EVENT_RULE_TYPE_USER_TRACEPOINT
:
327 return "user tracepoint";
328 case LTTNG_EVENT_RULE_TYPE_JUL_LOGGING
:
329 return "jul logging";
330 case LTTNG_EVENT_RULE_TYPE_LOG4J_LOGGING
:
331 return "log4j logging";
332 case LTTNG_EVENT_RULE_TYPE_LOG4J2_LOGGING
:
333 return "log4j2 logging";
334 case LTTNG_EVENT_RULE_TYPE_PYTHON_LOGGING
:
335 return "python logging";
342 unsigned long lttng_event_rule_hash(const struct lttng_event_rule
*rule
)
344 LTTNG_ASSERT(rule
->hash
);
345 return rule
->hash(rule
);
348 enum lttng_error_code
lttng_event_rule_mi_serialize(const struct lttng_event_rule
*rule
,
349 struct mi_writer
*writer
)
352 enum lttng_error_code ret_code
;
355 LTTNG_ASSERT(writer
);
356 LTTNG_ASSERT(rule
->mi_serialize
);
358 /* Open event rule element. */
359 ret
= mi_lttng_writer_open_element(writer
, mi_lttng_element_event_rule
);
364 /* Serialize underlying event rule. */
365 ret_code
= rule
->mi_serialize(rule
, writer
);
366 if (ret_code
!= LTTNG_OK
) {
370 /* Close event rule element. */
371 ret
= mi_lttng_writer_close_element(writer
);
380 ret_code
= LTTNG_ERR_MI_IO_FAIL
;