Add structure size field to struct lttng_session
[lttng-ust.git] / liblttng-ust / lttng-bytecode.c
CommitLineData
2d78951a 1/*
c0c0989a 2 * SPDX-License-Identifier: MIT
2d78951a 3 *
7e50015d 4 * Copyright (C) 2010-2016 Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
2d78951a 5 *
c0c0989a 6 * LTTng UST bytecode code.
2d78951a
MD
7 */
8
3fbec7dc 9#define _LGPL_SOURCE
b4051ad8 10#include <stddef.h>
fb31eb73
FD
11#include <stdint.h>
12
f488575f 13#include <urcu/rculist.h>
fb31eb73 14
fc80554e 15#include "context-internal.h"
04aa13f8 16#include "lttng-bytecode.h"
d871c65b 17#include "ust-events-internal.h"
cd54f6d9
MD
18
19static const char *opnames[] = {
04aa13f8 20 [ BYTECODE_OP_UNKNOWN ] = "UNKNOWN",
cd54f6d9 21
04aa13f8 22 [ BYTECODE_OP_RETURN ] = "RETURN",
cd54f6d9
MD
23
24 /* binary */
04aa13f8
FD
25 [ BYTECODE_OP_MUL ] = "MUL",
26 [ BYTECODE_OP_DIV ] = "DIV",
27 [ BYTECODE_OP_MOD ] = "MOD",
28 [ BYTECODE_OP_PLUS ] = "PLUS",
29 [ BYTECODE_OP_MINUS ] = "MINUS",
30 [ BYTECODE_OP_BIT_RSHIFT ] = "BIT_RSHIFT",
31 [ BYTECODE_OP_BIT_LSHIFT ] = "BIT_LSHIFT",
32 [ BYTECODE_OP_BIT_AND ] = "BIT_AND",
33 [ BYTECODE_OP_BIT_OR ] = "BIT_OR",
34 [ BYTECODE_OP_BIT_XOR ] = "BIT_XOR",
226106c0
MD
35
36 /* binary comparators */
04aa13f8
FD
37 [ BYTECODE_OP_EQ ] = "EQ",
38 [ BYTECODE_OP_NE ] = "NE",
39 [ BYTECODE_OP_GT ] = "GT",
40 [ BYTECODE_OP_LT ] = "LT",
41 [ BYTECODE_OP_GE ] = "GE",
42 [ BYTECODE_OP_LE ] = "LE",
cd54f6d9 43
226106c0 44 /* string binary comparators */
04aa13f8
FD
45 [ BYTECODE_OP_EQ_STRING ] = "EQ_STRING",
46 [ BYTECODE_OP_NE_STRING ] = "NE_STRING",
47 [ BYTECODE_OP_GT_STRING ] = "GT_STRING",
48 [ BYTECODE_OP_LT_STRING ] = "LT_STRING",
49 [ BYTECODE_OP_GE_STRING ] = "GE_STRING",
50 [ BYTECODE_OP_LE_STRING ] = "LE_STRING",
226106c0
MD
51
52 /* s64 binary comparators */
04aa13f8
FD
53 [ BYTECODE_OP_EQ_S64 ] = "EQ_S64",
54 [ BYTECODE_OP_NE_S64 ] = "NE_S64",
55 [ BYTECODE_OP_GT_S64 ] = "GT_S64",
56 [ BYTECODE_OP_LT_S64 ] = "LT_S64",
57 [ BYTECODE_OP_GE_S64 ] = "GE_S64",
58 [ BYTECODE_OP_LE_S64 ] = "LE_S64",
226106c0
MD
59
60 /* double binary comparators */
04aa13f8
FD
61 [ BYTECODE_OP_EQ_DOUBLE ] = "EQ_DOUBLE",
62 [ BYTECODE_OP_NE_DOUBLE ] = "NE_DOUBLE",
63 [ BYTECODE_OP_GT_DOUBLE ] = "GT_DOUBLE",
64 [ BYTECODE_OP_LT_DOUBLE ] = "LT_DOUBLE",
65 [ BYTECODE_OP_GE_DOUBLE ] = "GE_DOUBLE",
66 [ BYTECODE_OP_LE_DOUBLE ] = "LE_DOUBLE",
226106c0 67
1e5f62b4 68 /* Mixed S64-double binary comparators */
04aa13f8
FD
69 [ BYTECODE_OP_EQ_DOUBLE_S64 ] = "EQ_DOUBLE_S64",
70 [ BYTECODE_OP_NE_DOUBLE_S64 ] = "NE_DOUBLE_S64",
71 [ BYTECODE_OP_GT_DOUBLE_S64 ] = "GT_DOUBLE_S64",
72 [ BYTECODE_OP_LT_DOUBLE_S64 ] = "LT_DOUBLE_S64",
73 [ BYTECODE_OP_GE_DOUBLE_S64 ] = "GE_DOUBLE_S64",
74 [ BYTECODE_OP_LE_DOUBLE_S64 ] = "LE_DOUBLE_S64",
75
76 [ BYTECODE_OP_EQ_S64_DOUBLE ] = "EQ_S64_DOUBLE",
77 [ BYTECODE_OP_NE_S64_DOUBLE ] = "NE_S64_DOUBLE",
78 [ BYTECODE_OP_GT_S64_DOUBLE ] = "GT_S64_DOUBLE",
79 [ BYTECODE_OP_LT_S64_DOUBLE ] = "LT_S64_DOUBLE",
80 [ BYTECODE_OP_GE_S64_DOUBLE ] = "GE_S64_DOUBLE",
81 [ BYTECODE_OP_LE_S64_DOUBLE ] = "LE_S64_DOUBLE",
226106c0 82
cd54f6d9 83 /* unary */
04aa13f8
FD
84 [ BYTECODE_OP_UNARY_PLUS ] = "UNARY_PLUS",
85 [ BYTECODE_OP_UNARY_MINUS ] = "UNARY_MINUS",
86 [ BYTECODE_OP_UNARY_NOT ] = "UNARY_NOT",
87 [ BYTECODE_OP_UNARY_PLUS_S64 ] = "UNARY_PLUS_S64",
88 [ BYTECODE_OP_UNARY_MINUS_S64 ] = "UNARY_MINUS_S64",
89 [ BYTECODE_OP_UNARY_NOT_S64 ] = "UNARY_NOT_S64",
90 [ BYTECODE_OP_UNARY_PLUS_DOUBLE ] = "UNARY_PLUS_DOUBLE",
91 [ BYTECODE_OP_UNARY_MINUS_DOUBLE ] = "UNARY_MINUS_DOUBLE",
92 [ BYTECODE_OP_UNARY_NOT_DOUBLE ] = "UNARY_NOT_DOUBLE",
cd54f6d9
MD
93
94 /* logical */
04aa13f8
FD
95 [ BYTECODE_OP_AND ] = "AND",
96 [ BYTECODE_OP_OR ] = "OR",
cd54f6d9 97
77aa5901 98 /* load field ref */
04aa13f8
FD
99 [ BYTECODE_OP_LOAD_FIELD_REF ] = "LOAD_FIELD_REF",
100 [ BYTECODE_OP_LOAD_FIELD_REF_STRING ] = "LOAD_FIELD_REF_STRING",
101 [ BYTECODE_OP_LOAD_FIELD_REF_SEQUENCE ] = "LOAD_FIELD_REF_SEQUENCE",
102 [ BYTECODE_OP_LOAD_FIELD_REF_S64 ] = "LOAD_FIELD_REF_S64",
103 [ BYTECODE_OP_LOAD_FIELD_REF_DOUBLE ] = "LOAD_FIELD_REF_DOUBLE",
2f0145d1 104
77aa5901 105 /* load from immediate operand */
04aa13f8
FD
106 [ BYTECODE_OP_LOAD_STRING ] = "LOAD_STRING",
107 [ BYTECODE_OP_LOAD_S64 ] = "LOAD_S64",
108 [ BYTECODE_OP_LOAD_DOUBLE ] = "LOAD_DOUBLE",
49905038
MD
109
110 /* cast */
04aa13f8
FD
111 [ BYTECODE_OP_CAST_TO_S64 ] = "CAST_TO_S64",
112 [ BYTECODE_OP_CAST_DOUBLE_TO_S64 ] = "CAST_DOUBLE_TO_S64",
113 [ BYTECODE_OP_CAST_NOP ] = "CAST_NOP",
77aa5901
MD
114
115 /* get context ref */
04aa13f8
FD
116 [ BYTECODE_OP_GET_CONTEXT_REF ] = "GET_CONTEXT_REF",
117 [ BYTECODE_OP_GET_CONTEXT_REF_STRING ] = "GET_CONTEXT_REF_STRING",
118 [ BYTECODE_OP_GET_CONTEXT_REF_S64 ] = "GET_CONTEXT_REF_S64",
119 [ BYTECODE_OP_GET_CONTEXT_REF_DOUBLE ] = "GET_CONTEXT_REF_DOUBLE",
f6753f2d
MD
120
121 /* load userspace field ref */
04aa13f8
FD
122 [ BYTECODE_OP_LOAD_FIELD_REF_USER_STRING ] = "LOAD_FIELD_REF_USER_STRING",
123 [ BYTECODE_OP_LOAD_FIELD_REF_USER_SEQUENCE ] = "LOAD_FIELD_REF_USER_SEQUENCE",
f6753f2d
MD
124
125 /*
126 * load immediate star globbing pattern (literal string)
127 * from immediate.
128 */
04aa13f8 129 [ BYTECODE_OP_LOAD_STAR_GLOB_STRING ] = "LOAD_STAR_GLOB_STRING",
f6753f2d
MD
130
131 /* globbing pattern binary operator: apply to */
04aa13f8
FD
132 [ BYTECODE_OP_EQ_STAR_GLOB_STRING ] = "EQ_STAR_GLOB_STRING",
133 [ BYTECODE_OP_NE_STAR_GLOB_STRING ] = "NE_STAR_GLOB_STRING",
47e5f13e
MD
134
135 /*
136 * Instructions for recursive traversal through composed types.
137 */
04aa13f8
FD
138 [ BYTECODE_OP_GET_CONTEXT_ROOT ] = "GET_CONTEXT_ROOT",
139 [ BYTECODE_OP_GET_APP_CONTEXT_ROOT ] = "GET_APP_CONTEXT_ROOT",
140 [ BYTECODE_OP_GET_PAYLOAD_ROOT ] = "GET_PAYLOAD_ROOT",
141
142 [ BYTECODE_OP_GET_SYMBOL ] = "GET_SYMBOL",
143 [ BYTECODE_OP_GET_SYMBOL_FIELD ] = "GET_SYMBOL_FIELD",
144 [ BYTECODE_OP_GET_INDEX_U16 ] = "GET_INDEX_U16",
145 [ BYTECODE_OP_GET_INDEX_U64 ] = "GET_INDEX_U64",
146
147 [ BYTECODE_OP_LOAD_FIELD ] = "LOAD_FIELD",
148 [ BYTECODE_OP_LOAD_FIELD_S8 ] = "LOAD_FIELD_S8",
149 [ BYTECODE_OP_LOAD_FIELD_S16 ] = "LOAD_FIELD_S16",
150 [ BYTECODE_OP_LOAD_FIELD_S32 ] = "LOAD_FIELD_S32",
151 [ BYTECODE_OP_LOAD_FIELD_S64 ] = "LOAD_FIELD_S64",
152 [ BYTECODE_OP_LOAD_FIELD_U8 ] = "LOAD_FIELD_U8",
153 [ BYTECODE_OP_LOAD_FIELD_U16 ] = "LOAD_FIELD_U16",
154 [ BYTECODE_OP_LOAD_FIELD_U32 ] = "LOAD_FIELD_U32",
155 [ BYTECODE_OP_LOAD_FIELD_U64 ] = "LOAD_FIELD_U64",
156 [ BYTECODE_OP_LOAD_FIELD_STRING ] = "LOAD_FIELD_STRING",
157 [ BYTECODE_OP_LOAD_FIELD_SEQUENCE ] = "LOAD_FIELD_SEQUENCE",
158 [ BYTECODE_OP_LOAD_FIELD_DOUBLE ] = "LOAD_FIELD_DOUBLE",
159
160 [ BYTECODE_OP_UNARY_BIT_NOT ] = "UNARY_BIT_NOT",
161
162 [ BYTECODE_OP_RETURN_S64 ] = "RETURN_S64",
cd54f6d9
MD
163};
164
bf617e20 165const char *lttng_bytecode_print_op(enum bytecode_op op)
cd54f6d9 166{
04aa13f8 167 if (op >= NR_BYTECODE_OPS)
cd54f6d9
MD
168 return "UNKNOWN";
169 else
170 return opnames[op];
171}
172
cd54f6d9 173static
53b9d7db 174int apply_field_reloc(const struct lttng_event_desc *event_desc,
cd54f6d9
MD
175 struct bytecode_runtime *runtime,
176 uint32_t runtime_len,
177 uint32_t reloc_offset,
47e5f13e 178 const char *field_name,
04aa13f8 179 enum bytecode_op bytecode_op)
cd54f6d9 180{
cd54f6d9
MD
181 const struct lttng_event_field *fields, *field = NULL;
182 unsigned int nr_fields, i;
2f0145d1 183 struct load_op *op;
cd54f6d9
MD
184 uint32_t field_offset = 0;
185
77aa5901 186 dbg_printf("Apply field reloc: %u %s\n", reloc_offset, field_name);
cd54f6d9
MD
187
188 /* Lookup event by name */
53b9d7db 189 if (!event_desc)
cd54f6d9 190 return -EINVAL;
53b9d7db 191 fields = event_desc->fields;
cd54f6d9
MD
192 if (!fields)
193 return -EINVAL;
53b9d7db 194 nr_fields = event_desc->nr_fields;
cd54f6d9 195 for (i = 0; i < nr_fields; i++) {
218deb69
MD
196 if (fields[i].u.ext.nofilter) {
197 continue;
198 }
cd54f6d9
MD
199 if (!strcmp(fields[i].name, field_name)) {
200 field = &fields[i];
201 break;
202 }
203 /* compute field offset */
204 switch (fields[i].type.atype) {
205 case atype_integer:
206 case atype_enum:
218deb69 207 case atype_enum_nestable:
cd54f6d9
MD
208 field_offset += sizeof(int64_t);
209 break;
210 case atype_array:
218deb69 211 case atype_array_nestable:
cd54f6d9 212 case atype_sequence:
218deb69 213 case atype_sequence_nestable:
cd54f6d9
MD
214 field_offset += sizeof(unsigned long);
215 field_offset += sizeof(void *);
216 break;
217 case atype_string:
218 field_offset += sizeof(void *);
219 break;
220 case atype_float:
221 field_offset += sizeof(double);
da6eed25 222 break;
cd54f6d9
MD
223 default:
224 return -EINVAL;
225 }
226 }
227 if (!field)
228 return -EINVAL;
229
230 /* Check if field offset is too large for 16-bit offset */
5b4839a8 231 if (field_offset > FILTER_BYTECODE_MAX_LEN - 1)
cd54f6d9
MD
232 return -EINVAL;
233
234 /* set type */
47e5f13e
MD
235 op = (struct load_op *) &runtime->code[reloc_offset];
236
04aa13f8
FD
237 switch (bytecode_op) {
238 case BYTECODE_OP_LOAD_FIELD_REF:
47e5f13e
MD
239 {
240 struct field_ref *field_ref;
241
242 field_ref = (struct field_ref *) op->data;
243 switch (field->type.atype) {
244 case atype_integer:
245 case atype_enum:
218deb69 246 case atype_enum_nestable:
04aa13f8 247 op->op = BYTECODE_OP_LOAD_FIELD_REF_S64;
47e5f13e
MD
248 break;
249 case atype_array:
218deb69 250 case atype_array_nestable:
47e5f13e 251 case atype_sequence:
218deb69 252 case atype_sequence_nestable:
04aa13f8 253 op->op = BYTECODE_OP_LOAD_FIELD_REF_SEQUENCE;
47e5f13e
MD
254 break;
255 case atype_string:
04aa13f8 256 op->op = BYTECODE_OP_LOAD_FIELD_REF_STRING;
47e5f13e
MD
257 break;
258 case atype_float:
04aa13f8 259 op->op = BYTECODE_OP_LOAD_FIELD_REF_DOUBLE;
47e5f13e
MD
260 break;
261 default:
262 return -EINVAL;
263 }
264 /* set offset */
265 field_ref->offset = (uint16_t) field_offset;
da6eed25 266 break;
47e5f13e 267 }
cd54f6d9
MD
268 default:
269 return -EINVAL;
270 }
2d78951a
MD
271 return 0;
272}
273
77aa5901 274static
53b9d7db 275int apply_context_reloc(struct bytecode_runtime *runtime,
77aa5901
MD
276 uint32_t runtime_len,
277 uint32_t reloc_offset,
47e5f13e 278 const char *context_name,
04aa13f8 279 enum bytecode_op bytecode_op)
77aa5901 280{
77aa5901
MD
281 struct load_op *op;
282 struct lttng_ctx_field *ctx_field;
283 int idx;
362a65de 284 struct lttng_ctx **pctx = runtime->p.priv->pctx;
77aa5901
MD
285
286 dbg_printf("Apply context reloc: %u %s\n", reloc_offset, context_name);
287
288 /* Get context index */
185c7828 289 idx = lttng_get_context_index(*pctx, context_name);
53569322
MD
290 if (idx < 0) {
291 if (lttng_context_is_app(context_name)) {
292 int ret;
293
294 ret = lttng_ust_add_app_context_to_ctx_rcu(context_name,
185c7828 295 pctx);
53569322
MD
296 if (ret)
297 return ret;
185c7828 298 idx = lttng_get_context_index(*pctx, context_name);
53569322
MD
299 if (idx < 0)
300 return -ENOENT;
301 } else {
302 return -ENOENT;
303 }
304 }
77aa5901
MD
305 /* Check if idx is too large for 16-bit offset */
306 if (idx > FILTER_BYTECODE_MAX_LEN - 1)
307 return -EINVAL;
308
309 /* Get context return type */
185c7828 310 ctx_field = &(*pctx)->fields[idx];
47e5f13e
MD
311 op = (struct load_op *) &runtime->code[reloc_offset];
312
04aa13f8
FD
313 switch (bytecode_op) {
314 case BYTECODE_OP_GET_CONTEXT_REF:
47e5f13e
MD
315 {
316 struct field_ref *field_ref;
317
318 field_ref = (struct field_ref *) op->data;
319 switch (ctx_field->event_field.type.atype) {
320 case atype_integer:
321 case atype_enum:
218deb69 322 case atype_enum_nestable:
04aa13f8 323 op->op = BYTECODE_OP_GET_CONTEXT_REF_S64;
47e5f13e
MD
324 break;
325 /* Sequence and array supported as string */
326 case atype_string:
327 case atype_array:
218deb69 328 case atype_array_nestable:
47e5f13e 329 case atype_sequence:
218deb69 330 case atype_sequence_nestable:
04aa13f8 331 op->op = BYTECODE_OP_GET_CONTEXT_REF_STRING;
47e5f13e
MD
332 break;
333 case atype_float:
04aa13f8 334 op->op = BYTECODE_OP_GET_CONTEXT_REF_DOUBLE;
47e5f13e
MD
335 break;
336 case atype_dynamic:
04aa13f8 337 op->op = BYTECODE_OP_GET_CONTEXT_REF;
47e5f13e
MD
338 break;
339 default:
340 return -EINVAL;
341 }
342 /* set offset to context index within channel contexts */
343 field_ref->offset = (uint16_t) idx;
53569322 344 break;
47e5f13e 345 }
77aa5901
MD
346 default:
347 return -EINVAL;
348 }
77aa5901
MD
349 return 0;
350}
351
352static
53b9d7db 353int apply_reloc(const struct lttng_event_desc *event_desc,
77aa5901
MD
354 struct bytecode_runtime *runtime,
355 uint32_t runtime_len,
356 uint32_t reloc_offset,
357 const char *name)
358{
359 struct load_op *op;
360
361 dbg_printf("Apply reloc: %u %s\n", reloc_offset, name);
362
363 /* Ensure that the reloc is within the code */
364 if (runtime_len - reloc_offset < sizeof(uint16_t))
365 return -EINVAL;
366
47e5f13e 367 op = (struct load_op *) &runtime->code[reloc_offset];
77aa5901 368 switch (op->op) {
04aa13f8 369 case BYTECODE_OP_LOAD_FIELD_REF:
53b9d7db 370 return apply_field_reloc(event_desc, runtime, runtime_len,
47e5f13e 371 reloc_offset, name, op->op);
04aa13f8 372 case BYTECODE_OP_GET_CONTEXT_REF:
53b9d7db 373 return apply_context_reloc(runtime, runtime_len,
47e5f13e 374 reloc_offset, name, op->op);
04aa13f8
FD
375 case BYTECODE_OP_GET_SYMBOL:
376 case BYTECODE_OP_GET_SYMBOL_FIELD:
47e5f13e
MD
377 /*
378 * Will be handled by load specialize phase or
379 * dynamically by interpreter.
380 */
381 return 0;
77aa5901
MD
382 default:
383 ERR("Unknown reloc op type %u\n", op->op);
384 return -EINVAL;
385 }
386 return 0;
387}
388
f488575f 389static
ab249ecf 390int bytecode_is_linked(struct lttng_ust_bytecode_node *bytecode,
53b9d7db 391 struct cds_list_head *bytecode_runtime_head)
f488575f
MD
392{
393 struct lttng_bytecode_runtime *bc_runtime;
394
53b9d7db 395 cds_list_for_each_entry(bc_runtime, bytecode_runtime_head, node) {
362a65de 396 if (bc_runtime->priv->bc == bytecode)
f488575f
MD
397 return 1;
398 }
399 return 0;
400}
401
cd54f6d9
MD
402/*
403 * Take a bytecode with reloc table and link it to an event to create a
404 * bytecode runtime.
405 */
2d78951a 406static
83a109e6 407int link_bytecode(const struct lttng_event_desc *event_desc,
53b9d7db 408 struct lttng_ctx **ctx,
ab249ecf 409 struct lttng_ust_bytecode_node *bytecode,
e58095ef 410 struct cds_list_head *insert_loc)
2d78951a 411{
cd54f6d9
MD
412 int ret, offset, next_offset;
413 struct bytecode_runtime *runtime = NULL;
362a65de 414 struct lttng_ust_bytecode_runtime_private *runtime_priv = NULL;
cd54f6d9
MD
415 size_t runtime_alloc_len;
416
ab249ecf 417 if (!bytecode)
2d78951a 418 return 0;
cd54f6d9 419 /* Bytecode already linked */
ab249ecf 420 if (bytecode_is_linked(bytecode, insert_loc))
cd54f6d9 421 return 0;
2d78951a 422
f488575f 423 dbg_printf("Linking...\n");
cd54f6d9
MD
424
425 /* We don't need the reloc table in the runtime */
ab249ecf 426 runtime_alloc_len = sizeof(*runtime) + bytecode->bc.reloc_offset;
cd54f6d9
MD
427 runtime = zmalloc(runtime_alloc_len);
428 if (!runtime) {
429 ret = -ENOMEM;
e0a7d7ab 430 goto alloc_error;
cd54f6d9 431 }
362a65de
MD
432 runtime_priv = zmalloc(sizeof(struct lttng_ust_bytecode_runtime_private));
433 if (!runtime_priv) {
434 free(runtime);
435 runtime = NULL;
436 ret = -ENOMEM;
437 goto alloc_error;
438 }
439 runtime->p.priv = runtime_priv;
440 runtime_priv->pub = runtime;
441 runtime_priv->bc = bytecode;
442 runtime_priv->pctx = ctx;
ab249ecf 443 runtime->len = bytecode->bc.reloc_offset;
cd54f6d9 444 /* copy original bytecode */
ab249ecf 445 memcpy(runtime->code, bytecode->bc.data, runtime->len);
cd54f6d9
MD
446 /*
447 * apply relocs. Those are a uint16_t (offset in bytecode)
448 * followed by a string (field name).
449 */
ab249ecf
FD
450 for (offset = bytecode->bc.reloc_offset;
451 offset < bytecode->bc.len;
cd54f6d9
MD
452 offset = next_offset) {
453 uint16_t reloc_offset =
ab249ecf 454 *(uint16_t *) &bytecode->bc.data[offset];
77aa5901 455 const char *name =
ab249ecf 456 (const char *) &bytecode->bc.data[offset + sizeof(uint16_t)];
cd54f6d9 457
53b9d7db 458 ret = apply_reloc(event_desc, runtime, runtime->len, reloc_offset, name);
cd54f6d9
MD
459 if (ret) {
460 goto link_error;
461 }
77aa5901 462 next_offset = offset + sizeof(uint16_t) + strlen(name) + 1;
cd54f6d9 463 }
9522a886 464 /* Validate bytecode */
04aa13f8 465 ret = lttng_bytecode_validate(runtime);
9522a886
MD
466 if (ret) {
467 goto link_error;
468 }
08c84b15 469 /* Specialize bytecode */
04aa13f8 470 ret = lttng_bytecode_specialize(event_desc, runtime);
08c84b15
MD
471 if (ret) {
472 goto link_error;
473 }
c42416df
FD
474
475 switch (bytecode->type) {
476 case LTTNG_UST_BYTECODE_NODE_TYPE_FILTER:
477 runtime->p.interpreter_funcs.filter = lttng_bytecode_filter_interpret;
478 break;
d37ecb3f
FD
479 case LTTNG_UST_BYTECODE_NODE_TYPE_CAPTURE:
480 runtime->p.interpreter_funcs.capture = lttng_bytecode_capture_interpret;
481 break;
c42416df
FD
482 default:
483 abort();
484 }
485
362a65de 486 runtime->p.priv->link_failed = 0;
e58095ef 487 cds_list_add_rcu(&runtime->p.node, insert_loc);
f488575f 488 dbg_printf("Linking successful.\n");
2d78951a 489 return 0;
cd54f6d9
MD
490
491link_error:
c42416df
FD
492 switch (bytecode->type) {
493 case LTTNG_UST_BYTECODE_NODE_TYPE_FILTER:
494 runtime->p.interpreter_funcs.filter = lttng_bytecode_filter_interpret_false;
495 break;
d37ecb3f
FD
496 case LTTNG_UST_BYTECODE_NODE_TYPE_CAPTURE:
497 runtime->p.interpreter_funcs.capture = lttng_bytecode_capture_interpret_false;
498 break;
c42416df
FD
499 default:
500 abort();
501 }
502
362a65de 503 runtime_priv->link_failed = 1;
e58095ef 504 cds_list_add_rcu(&runtime->p.node, insert_loc);
e0a7d7ab 505alloc_error:
f488575f 506 dbg_printf("Linking failed.\n");
cd54f6d9 507 return ret;
2d78951a
MD
508}
509
4d451c15 510void lttng_bytecode_filter_sync_state(struct lttng_bytecode_runtime *runtime)
2d78951a 511{
362a65de 512 struct lttng_ust_bytecode_node *bc = runtime->priv->bc;
f488575f 513
362a65de 514 if (!bc->enabler->enabled || runtime->priv->link_failed)
c42416df 515 runtime->interpreter_funcs.filter = lttng_bytecode_filter_interpret_false;
21af05a9 516 else
c42416df 517 runtime->interpreter_funcs.filter = lttng_bytecode_filter_interpret;
2d78951a
MD
518}
519
d37ecb3f
FD
520void lttng_bytecode_capture_sync_state(struct lttng_bytecode_runtime *runtime)
521{
362a65de 522 struct lttng_ust_bytecode_node *bc = runtime->priv->bc;
d37ecb3f 523
362a65de 524 if (!bc->enabler->enabled || runtime->priv->link_failed)
d37ecb3f
FD
525 runtime->interpreter_funcs.capture = lttng_bytecode_capture_interpret_false;
526 else
527 runtime->interpreter_funcs.capture = lttng_bytecode_capture_interpret;
528}
529
2d78951a 530/*
621c07fc
FD
531 * Given the lists of bytecode programs of an instance (trigger or event) and
532 * of a matching enabler, try to link all the enabler's bytecode programs with
533 * the instance.
534 *
535 * This function is called after we confirmed that name enabler and the
536 * instance are name matching (or glob pattern matching).
2d78951a 537 */
53b9d7db
FD
538void lttng_enabler_link_bytecode(const struct lttng_event_desc *event_desc,
539 struct lttng_ctx **ctx,
621c07fc
FD
540 struct cds_list_head *instance_bytecode_head,
541 struct cds_list_head *enabler_bytecode_head)
2d78951a 542{
621c07fc 543 struct lttng_ust_bytecode_node *enabler_bc;
e58095ef
MD
544 struct lttng_bytecode_runtime *runtime;
545
53b9d7db 546 assert(event_desc);
e58095ef 547
621c07fc
FD
548 /* Go over all the bytecode programs of the enabler. */
549 cds_list_for_each_entry(enabler_bc, enabler_bytecode_head, node) {
e58095ef
MD
550 int found = 0, ret;
551 struct cds_list_head *insert_loc;
552
621c07fc
FD
553 /*
554 * Check if the current enabler bytecode program is already
555 * linked with the instance.
556 */
557 cds_list_for_each_entry(runtime, instance_bytecode_head, node) {
362a65de 558 if (runtime->priv->bc == enabler_bc) {
e58095ef
MD
559 found = 1;
560 break;
561 }
562 }
621c07fc
FD
563
564 /*
565 * Skip bytecode already linked, go to the next enabler
566 * bytecode program.
567 */
e58095ef
MD
568 if (found)
569 continue;
570
571 /*
572 * Insert at specified priority (seqnum) in increasing
09434f96
FD
573 * order. If there already is a bytecode of the same priority,
574 * insert the new bytecode right after it.
e58095ef
MD
575 */
576 cds_list_for_each_entry_reverse(runtime,
621c07fc 577 instance_bytecode_head, node) {
362a65de 578 if (runtime->priv->bc->bc.seqnum <= enabler_bc->bc.seqnum) {
e58095ef
MD
579 /* insert here */
580 insert_loc = &runtime->node;
581 goto add_within;
582 }
583 }
53b9d7db 584
e58095ef 585 /* Add to head to list */
621c07fc 586 insert_loc = instance_bytecode_head;
e58095ef 587 add_within:
f488575f 588 dbg_printf("linking bytecode\n");
621c07fc 589 ret = link_bytecode(event_desc, ctx, enabler_bc, insert_loc);
e58095ef
MD
590 if (ret) {
591 dbg_printf("[lttng filter] warning: cannot link event bytecode\n");
592 }
2d78951a 593 }
2d78951a
MD
594}
595
596/*
ab249ecf 597 * We own the bytecode if we return success.
2d78951a 598 */
e58095ef 599int lttng_filter_enabler_attach_bytecode(struct lttng_enabler *enabler,
ab249ecf 600 struct lttng_ust_bytecode_node *bytecode)
2d78951a 601{
ab249ecf 602 cds_list_add(&bytecode->node, &enabler->filter_bytecode_head);
2d78951a
MD
603 return 0;
604}
f488575f 605
b77aaa1b
FD
606static
607void free_filter_runtime(struct cds_list_head *bytecode_runtime_head)
f488575f
MD
608{
609 struct bytecode_runtime *runtime, *tmp;
610
b77aaa1b
FD
611 cds_list_for_each_entry_safe(runtime, tmp, bytecode_runtime_head,
612 p.node) {
47e5f13e 613 free(runtime->data);
362a65de 614 free(runtime->p.priv);
f488575f
MD
615 free(runtime);
616 }
617}
b77aaa1b
FD
618
619void lttng_free_event_filter_runtime(struct lttng_event *event)
620{
a56fd376 621 free_filter_runtime(&event->filter_bytecode_runtime_head);
b77aaa1b 622}
d8d2416d
FD
623
624void lttng_free_event_notifier_filter_runtime(
625 struct lttng_event_notifier *event_notifier)
626{
627 free_filter_runtime(&event_notifier->filter_bytecode_runtime_head);
628}
This page took 0.067303 seconds and 4 git commands to generate.