liblttng-ust/lttng-filter.c

   1 /*
   2  * lttng-filter.c
   3  *
   4  * LTTng UST filter code.
   5  *
   6  * Copyright (C) 2010-2016 Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
   7  *
   8  * Permission is hereby granted, free of charge, to any person obtaining a copy
   9  * of this software and associated documentation files (the "Software"), to deal
  10  * in the Software without restriction, including without limitation the rights
  11  * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
  12  * copies of the Software, and to permit persons to whom the Software is
  13  * furnished to do so, subject to the following conditions:
  14  *
  15  * The above copyright notice and this permission notice shall be included in
  16  * all copies or substantial portions of the Software.
  17  *
  18  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  19  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  20  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
  21  * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  22  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
  23  * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
  24  * SOFTWARE.
  25  */
  26
  27 #define _LGPL_SOURCE
  28 #include <stddef.h>
  29 #include <stdint.h>
  30
  31 #include <urcu/rculist.h>
  32
  33 #include "lttng-filter.h"
  34
  35 static const char *opnames[] = {
  36         [ FILTER_OP_UNKNOWN ] = "UNKNOWN",
  37
  38         [ FILTER_OP_RETURN ] = "RETURN",
  39
  40         /* binary */
  41         [ FILTER_OP_MUL ] = "MUL",
  42         [ FILTER_OP_DIV ] = "DIV",
  43         [ FILTER_OP_MOD ] = "MOD",
  44         [ FILTER_OP_PLUS ] = "PLUS",
  45         [ FILTER_OP_MINUS ] = "MINUS",
  46         [ FILTER_OP_BIT_RSHIFT ] = "BIT_RSHIFT",
  47         [ FILTER_OP_BIT_LSHIFT ] = "BIT_LSHIFT",
  48         [ FILTER_OP_BIT_AND ] = "BIT_AND",
  49         [ FILTER_OP_BIT_OR ] = "BIT_OR",
  50         [ FILTER_OP_BIT_XOR ] = "BIT_XOR",
  51
  52         /* binary comparators */
  53         [ FILTER_OP_EQ ] = "EQ",
  54         [ FILTER_OP_NE ] = "NE",
  55         [ FILTER_OP_GT ] = "GT",
  56         [ FILTER_OP_LT ] = "LT",
  57         [ FILTER_OP_GE ] = "GE",
  58         [ FILTER_OP_LE ] = "LE",
  59
  60         /* string binary comparators */
  61         [ FILTER_OP_EQ_STRING ] = "EQ_STRING",
  62         [ FILTER_OP_NE_STRING ] = "NE_STRING",
  63         [ FILTER_OP_GT_STRING ] = "GT_STRING",
  64         [ FILTER_OP_LT_STRING ] = "LT_STRING",
  65         [ FILTER_OP_GE_STRING ] = "GE_STRING",
  66         [ FILTER_OP_LE_STRING ] = "LE_STRING",
  67
  68         /* s64 binary comparators */
  69         [ FILTER_OP_EQ_S64 ] = "EQ_S64",
  70         [ FILTER_OP_NE_S64 ] = "NE_S64",
  71         [ FILTER_OP_GT_S64 ] = "GT_S64",
  72         [ FILTER_OP_LT_S64 ] = "LT_S64",
  73         [ FILTER_OP_GE_S64 ] = "GE_S64",
  74         [ FILTER_OP_LE_S64 ] = "LE_S64",
  75
  76         /* double binary comparators */
  77         [ FILTER_OP_EQ_DOUBLE ] = "EQ_DOUBLE",
  78         [ FILTER_OP_NE_DOUBLE ] = "NE_DOUBLE",
  79         [ FILTER_OP_GT_DOUBLE ] = "GT_DOUBLE",
  80         [ FILTER_OP_LT_DOUBLE ] = "LT_DOUBLE",
  81         [ FILTER_OP_GE_DOUBLE ] = "GE_DOUBLE",
  82         [ FILTER_OP_LE_DOUBLE ] = "LE_DOUBLE",
  83
  84         /* Mixed S64-double binary comparators */
  85         [ FILTER_OP_EQ_DOUBLE_S64 ] = "EQ_DOUBLE_S64",
  86         [ FILTER_OP_NE_DOUBLE_S64 ] = "NE_DOUBLE_S64",
  87         [ FILTER_OP_GT_DOUBLE_S64 ] = "GT_DOUBLE_S64",
  88         [ FILTER_OP_LT_DOUBLE_S64 ] = "LT_DOUBLE_S64",
  89         [ FILTER_OP_GE_DOUBLE_S64 ] = "GE_DOUBLE_S64",
  90         [ FILTER_OP_LE_DOUBLE_S64 ] = "LE_DOUBLE_S64",
  91
  92         [ FILTER_OP_EQ_S64_DOUBLE ] = "EQ_S64_DOUBLE",
  93         [ FILTER_OP_NE_S64_DOUBLE ] = "NE_S64_DOUBLE",
  94         [ FILTER_OP_GT_S64_DOUBLE ] = "GT_S64_DOUBLE",
  95         [ FILTER_OP_LT_S64_DOUBLE ] = "LT_S64_DOUBLE",
  96         [ FILTER_OP_GE_S64_DOUBLE ] = "GE_S64_DOUBLE",
  97         [ FILTER_OP_LE_S64_DOUBLE ] = "LE_S64_DOUBLE",
  98
  99         /* unary */
 100         [ FILTER_OP_UNARY_PLUS ] = "UNARY_PLUS",
 101         [ FILTER_OP_UNARY_MINUS ] = "UNARY_MINUS",
 102         [ FILTER_OP_UNARY_NOT ] = "UNARY_NOT",
 103         [ FILTER_OP_UNARY_PLUS_S64 ] = "UNARY_PLUS_S64",
 104         [ FILTER_OP_UNARY_MINUS_S64 ] = "UNARY_MINUS_S64",
 105         [ FILTER_OP_UNARY_NOT_S64 ] = "UNARY_NOT_S64",
 106         [ FILTER_OP_UNARY_PLUS_DOUBLE ] = "UNARY_PLUS_DOUBLE",
 107         [ FILTER_OP_UNARY_MINUS_DOUBLE ] = "UNARY_MINUS_DOUBLE",
 108         [ FILTER_OP_UNARY_NOT_DOUBLE ] = "UNARY_NOT_DOUBLE",
 109
 110         /* logical */
 111         [ FILTER_OP_AND ] = "AND",
 112         [ FILTER_OP_OR ] = "OR",
 113
 114         /* load field ref */
 115         [ FILTER_OP_LOAD_FIELD_REF ] = "LOAD_FIELD_REF",
 116         [ FILTER_OP_LOAD_FIELD_REF_STRING ] = "LOAD_FIELD_REF_STRING",
 117         [ FILTER_OP_LOAD_FIELD_REF_SEQUENCE ] = "LOAD_FIELD_REF_SEQUENCE",
 118         [ FILTER_OP_LOAD_FIELD_REF_S64 ] = "LOAD_FIELD_REF_S64",
 119         [ FILTER_OP_LOAD_FIELD_REF_DOUBLE ] = "LOAD_FIELD_REF_DOUBLE",
 120
 121         /* load from immediate operand */
 122         [ FILTER_OP_LOAD_STRING ] = "LOAD_STRING",
 123         [ FILTER_OP_LOAD_S64 ] = "LOAD_S64",
 124         [ FILTER_OP_LOAD_DOUBLE ] = "LOAD_DOUBLE",
 125
 126         /* cast */
 127         [ FILTER_OP_CAST_TO_S64 ] = "CAST_TO_S64",
 128         [ FILTER_OP_CAST_DOUBLE_TO_S64 ] = "CAST_DOUBLE_TO_S64",
 129         [ FILTER_OP_CAST_NOP ] = "CAST_NOP",
 130
 131         /* get context ref */
 132         [ FILTER_OP_GET_CONTEXT_REF ] = "GET_CONTEXT_REF",
 133         [ FILTER_OP_GET_CONTEXT_REF_STRING ] = "GET_CONTEXT_REF_STRING",
 134         [ FILTER_OP_GET_CONTEXT_REF_S64 ] = "GET_CONTEXT_REF_S64",
 135         [ FILTER_OP_GET_CONTEXT_REF_DOUBLE ] = "GET_CONTEXT_REF_DOUBLE",
 136
 137         /* load userspace field ref */
 138         [ FILTER_OP_LOAD_FIELD_REF_USER_STRING ] = "LOAD_FIELD_REF_USER_STRING",
 139         [ FILTER_OP_LOAD_FIELD_REF_USER_SEQUENCE ] = "LOAD_FIELD_REF_USER_SEQUENCE",
 140
 141         /*
 142          * load immediate star globbing pattern (literal string)
 143          * from immediate.
 144          */
 145         [ FILTER_OP_LOAD_STAR_GLOB_STRING ] = "LOAD_STAR_GLOB_STRING",
 146
 147         /* globbing pattern binary operator: apply to */
 148         [ FILTER_OP_EQ_STAR_GLOB_STRING ] = "EQ_STAR_GLOB_STRING",
 149         [ FILTER_OP_NE_STAR_GLOB_STRING ] = "NE_STAR_GLOB_STRING",
 150
 151         /*
 152          * Instructions for recursive traversal through composed types.
 153          */
 154         [ FILTER_OP_GET_CONTEXT_ROOT ] = "GET_CONTEXT_ROOT",
 155         [ FILTER_OP_GET_APP_CONTEXT_ROOT ] = "GET_APP_CONTEXT_ROOT",
 156         [ FILTER_OP_GET_PAYLOAD_ROOT ] = "GET_PAYLOAD_ROOT",
 157
 158         [ FILTER_OP_GET_SYMBOL ] = "GET_SYMBOL",
 159         [ FILTER_OP_GET_SYMBOL_FIELD ] = "GET_SYMBOL_FIELD",
 160         [ FILTER_OP_GET_INDEX_U16 ] = "GET_INDEX_U16",
 161         [ FILTER_OP_GET_INDEX_U64 ] = "GET_INDEX_U64",
 162
 163         [ FILTER_OP_LOAD_FIELD ] = "LOAD_FIELD",
 164         [ FILTER_OP_LOAD_FIELD_S8 ] = "LOAD_FIELD_S8",
 165         [ FILTER_OP_LOAD_FIELD_S16 ] = "LOAD_FIELD_S16",
 166         [ FILTER_OP_LOAD_FIELD_S32 ] = "LOAD_FIELD_S32",
 167         [ FILTER_OP_LOAD_FIELD_S64 ] = "LOAD_FIELD_S64",
 168         [ FILTER_OP_LOAD_FIELD_U8 ] = "LOAD_FIELD_U8",
 169         [ FILTER_OP_LOAD_FIELD_U16 ] = "LOAD_FIELD_U16",
 170         [ FILTER_OP_LOAD_FIELD_U32 ] = "LOAD_FIELD_U32",
 171         [ FILTER_OP_LOAD_FIELD_U64 ] = "LOAD_FIELD_U64",
 172         [ FILTER_OP_LOAD_FIELD_STRING ] = "LOAD_FIELD_STRING",
 173         [ FILTER_OP_LOAD_FIELD_SEQUENCE ] = "LOAD_FIELD_SEQUENCE",
 174         [ FILTER_OP_LOAD_FIELD_DOUBLE ] = "LOAD_FIELD_DOUBLE",
 175
 176         [ FILTER_OP_UNARY_BIT_NOT ] = "UNARY_BIT_NOT",
 177
 178         [ FILTER_OP_RETURN_S64 ] = "RETURN_S64",
 179 };
 180
 181 const char *print_op(enum filter_op op)
 182 {
 183         if (op >= NR_FILTER_OPS)
 184                 return "UNKNOWN";
 185         else
 186                 return opnames[op];
 187 }
 188
 189 static
 190 int apply_field_reloc(struct lttng_event *event,
 191                 struct bytecode_runtime *runtime,
 192                 uint32_t runtime_len,
 193                 uint32_t reloc_offset,
 194                 const char *field_name,
 195                 enum filter_op filter_op)
 196 {
 197         const struct lttng_event_desc *desc;
 198         const struct lttng_event_field *fields, *field = NULL;
 199         unsigned int nr_fields, i;
 200         struct load_op *op;
 201         uint32_t field_offset = 0;
 202
 203         dbg_printf("Apply field reloc: %u %s\n", reloc_offset, field_name);
 204
 205         /* Lookup event by name */
 206         desc = event->desc;
 207         if (!desc)
 208                 return -EINVAL;
 209         fields = desc->fields;
 210         if (!fields)
 211                 return -EINVAL;
 212         nr_fields = desc->nr_fields;
 213         for (i = 0; i < nr_fields; i++) {
 214                 if (fields[i].u.ext.nofilter) {
 215                         continue;
 216                 }
 217                 if (!strcmp(fields[i].name, field_name)) {
 218                         field = &fields[i];
 219                         break;
 220                 }
 221                 /* compute field offset */
 222                 switch (fields[i].type.atype) {
 223                 case atype_integer:
 224                 case atype_enum:
 225                 case atype_enum_nestable:
 226                         field_offset += sizeof(int64_t);
 227                         break;
 228                 case atype_array:
 229                 case atype_array_nestable:
 230                 case atype_sequence:
 231                 case atype_sequence_nestable:
 232                         field_offset += sizeof(unsigned long);
 233                         field_offset += sizeof(void *);
 234                         break;
 235                 case atype_string:
 236                         field_offset += sizeof(void *);
 237                         break;
 238                 case atype_float:
 239                         field_offset += sizeof(double);
 240                         break;
 241                 default:
 242                         return -EINVAL;
 243                 }
 244         }
 245         if (!field)
 246                 return -EINVAL;
 247
 248         /* Check if field offset is too large for 16-bit offset */
 249         if (field_offset > FILTER_BYTECODE_MAX_LEN - 1)
 250                 return -EINVAL;
 251
 252         /* set type */
 253         op = (struct load_op *) &runtime->code[reloc_offset];
 254
 255         switch (filter_op) {
 256         case FILTER_OP_LOAD_FIELD_REF:
 257         {
 258                 struct field_ref *field_ref;
 259
 260                 field_ref = (struct field_ref *) op->data;
 261                 switch (field->type.atype) {
 262                 case atype_integer:
 263                 case atype_enum:
 264                 case atype_enum_nestable:
 265                         op->op = FILTER_OP_LOAD_FIELD_REF_S64;
 266                         break;
 267                 case atype_array:
 268                 case atype_array_nestable:
 269                 case atype_sequence:
 270                 case atype_sequence_nestable:
 271                         op->op = FILTER_OP_LOAD_FIELD_REF_SEQUENCE;
 272                         break;
 273                 case atype_string:
 274                         op->op = FILTER_OP_LOAD_FIELD_REF_STRING;
 275                         break;
 276                 case atype_float:
 277                         op->op = FILTER_OP_LOAD_FIELD_REF_DOUBLE;
 278                         break;
 279                 default:
 280                         return -EINVAL;
 281                 }
 282                 /* set offset */
 283                 field_ref->offset = (uint16_t) field_offset;
 284                 break;
 285         }
 286         default:
 287                 return -EINVAL;
 288         }
 289         return 0;
 290 }
 291
 292 static
 293 int apply_context_reloc(struct lttng_event *event,
 294                 struct bytecode_runtime *runtime,
 295                 uint32_t runtime_len,
 296                 uint32_t reloc_offset,
 297                 const char *context_name,
 298                 enum filter_op filter_op)
 299 {
 300         struct load_op *op;
 301         struct lttng_ctx_field *ctx_field;
 302         int idx;
 303         struct lttng_ctx *ctx = *runtime->p.pctx;
 304
 305         dbg_printf("Apply context reloc: %u %s\n", reloc_offset, context_name);
 306
 307         /* Get context index */
 308         idx = lttng_get_context_index(ctx, context_name);
 309         if (idx < 0) {
 310                 if (lttng_context_is_app(context_name)) {
 311                         int ret;
 312
 313                         ret = lttng_ust_add_app_context_to_ctx_rcu(context_name,
 314                                         &ctx);
 315                         if (ret)
 316                                 return ret;
 317                         idx = lttng_get_context_index(ctx, context_name);
 318                         if (idx < 0)
 319                                 return -ENOENT;
 320                 } else {
 321                         return -ENOENT;
 322                 }
 323         }
 324         /* Check if idx is too large for 16-bit offset */
 325         if (idx > FILTER_BYTECODE_MAX_LEN - 1)
 326                 return -EINVAL;
 327
 328         /* Get context return type */
 329         ctx_field = &ctx->fields[idx];
 330         op = (struct load_op *) &runtime->code[reloc_offset];
 331
 332         switch (filter_op) {
 333         case FILTER_OP_GET_CONTEXT_REF:
 334         {
 335                 struct field_ref *field_ref;
 336
 337                 field_ref = (struct field_ref *) op->data;
 338                 switch (ctx_field->event_field.type.atype) {
 339                 case atype_integer:
 340                 case atype_enum:
 341                 case atype_enum_nestable:
 342                         op->op = FILTER_OP_GET_CONTEXT_REF_S64;
 343                         break;
 344                         /* Sequence and array supported as string */
 345                 case atype_string:
 346                 case atype_array:
 347                 case atype_array_nestable:
 348                 case atype_sequence:
 349                 case atype_sequence_nestable:
 350                         op->op = FILTER_OP_GET_CONTEXT_REF_STRING;
 351                         break;
 352                 case atype_float:
 353                         op->op = FILTER_OP_GET_CONTEXT_REF_DOUBLE;
 354                         break;
 355                 case atype_dynamic:
 356                         op->op = FILTER_OP_GET_CONTEXT_REF;
 357                         break;
 358                 default:
 359                         return -EINVAL;
 360                 }
 361                 /* set offset to context index within channel contexts */
 362                 field_ref->offset = (uint16_t) idx;
 363                 break;
 364         }
 365         default:
 366                 return -EINVAL;
 367         }
 368         return 0;
 369 }
 370
 371 static
 372 int apply_reloc(struct lttng_event *event,
 373                 struct bytecode_runtime *runtime,
 374                 uint32_t runtime_len,
 375                 uint32_t reloc_offset,
 376                 const char *name)
 377 {
 378         struct load_op *op;
 379
 380         dbg_printf("Apply reloc: %u %s\n", reloc_offset, name);
 381
 382         /* Ensure that the reloc is within the code */
 383         if (runtime_len - reloc_offset < sizeof(uint16_t))
 384                 return -EINVAL;
 385
 386         op = (struct load_op *) &runtime->code[reloc_offset];
 387         switch (op->op) {
 388         case FILTER_OP_LOAD_FIELD_REF:
 389                 return apply_field_reloc(event, runtime, runtime_len,
 390                         reloc_offset, name, op->op);
 391         case FILTER_OP_GET_CONTEXT_REF:
 392                 return apply_context_reloc(event, runtime, runtime_len,
 393                         reloc_offset, name, op->op);
 394         case FILTER_OP_GET_SYMBOL:
 395         case FILTER_OP_GET_SYMBOL_FIELD:
 396                 /*
 397                  * Will be handled by load specialize phase or
 398                  * dynamically by interpreter.
 399                  */
 400                 return 0;
 401         default:
 402                 ERR("Unknown reloc op type %u\n", op->op);
 403                 return -EINVAL;
 404         }
 405         return 0;
 406 }
 407
 408 static
 409 int bytecode_is_linked(struct lttng_ust_filter_bytecode_node *filter_bytecode,
 410                 struct lttng_event *event)
 411 {
 412         struct lttng_bytecode_runtime *bc_runtime;
 413
 414         cds_list_for_each_entry(bc_runtime,
 415                         &event->bytecode_runtime_head, node) {
 416                 if (bc_runtime->bc == filter_bytecode)
 417                         return 1;
 418         }
 419         return 0;
 420 }
 421
 422 /*
 423  * Take a bytecode with reloc table and link it to an event to create a
 424  * bytecode runtime.
 425  */
 426 static
 427 int _lttng_filter_event_link_bytecode(struct lttng_event *event,
 428                 struct lttng_ust_filter_bytecode_node *filter_bytecode,
 429                 struct cds_list_head *insert_loc)
 430 {
 431         int ret, offset, next_offset;
 432         struct bytecode_runtime *runtime = NULL;
 433         size_t runtime_alloc_len;
 434
 435         if (!filter_bytecode)
 436                 return 0;
 437         /* Bytecode already linked */
 438         if (bytecode_is_linked(filter_bytecode, event))
 439                 return 0;
 440
 441         dbg_printf("Linking...\n");
 442
 443         /* We don't need the reloc table in the runtime */
 444         runtime_alloc_len = sizeof(*runtime) + filter_bytecode->bc.reloc_offset;
 445         runtime = zmalloc(runtime_alloc_len);
 446         if (!runtime) {
 447                 ret = -ENOMEM;
 448                 goto alloc_error;
 449         }
 450         runtime->p.bc = filter_bytecode;
 451         runtime->p.pctx = &event->chan->session->ctx;
 452         runtime->len = filter_bytecode->bc.reloc_offset;
 453         /* copy original bytecode */
 454         memcpy(runtime->code, filter_bytecode->bc.data, runtime->len);
 455         /*
 456          * apply relocs. Those are a uint16_t (offset in bytecode)
 457          * followed by a string (field name).
 458          */
 459         for (offset = filter_bytecode->bc.reloc_offset;
 460                         offset < filter_bytecode->bc.len;
 461                         offset = next_offset) {
 462                 uint16_t reloc_offset =
 463                         *(uint16_t *) &filter_bytecode->bc.data[offset];
 464                 const char *name =
 465                         (const char *) &filter_bytecode->bc.data[offset + sizeof(uint16_t)];
 466
 467                 ret = apply_reloc(event, runtime, runtime->len, reloc_offset, name);
 468                 if (ret) {
 469                         goto link_error;
 470                 }
 471                 next_offset = offset + sizeof(uint16_t) + strlen(name) + 1;
 472         }
 473         /* Validate bytecode */
 474         ret = lttng_filter_validate_bytecode(runtime);
 475         if (ret) {
 476                 goto link_error;
 477         }
 478         /* Specialize bytecode */
 479         ret = lttng_filter_specialize_bytecode(event, runtime);
 480         if (ret) {
 481                 goto link_error;
 482         }
 483         runtime->p.filter = lttng_filter_interpret_bytecode;
 484         runtime->p.link_failed = 0;
 485         cds_list_add_rcu(&runtime->p.node, insert_loc);
 486         dbg_printf("Linking successful.\n");
 487         return 0;
 488
 489 link_error:
 490         runtime->p.filter = lttng_filter_false;
 491         runtime->p.link_failed = 1;
 492         cds_list_add_rcu(&runtime->p.node, insert_loc);
 493 alloc_error:
 494         dbg_printf("Linking failed.\n");
 495         return ret;
 496 }
 497
 498 void lttng_filter_sync_state(struct lttng_bytecode_runtime *runtime)
 499 {
 500         struct lttng_ust_filter_bytecode_node *bc = runtime->bc;
 501
 502         if (!bc->enabler->enabled || runtime->link_failed)
 503                 runtime->filter = lttng_filter_false;
 504         else
 505                 runtime->filter = lttng_filter_interpret_bytecode;
 506 }
 507
 508 /*
 509  * Link bytecode for all enablers referenced by an event.
 510  */
 511 void lttng_enabler_event_link_bytecode(struct lttng_event *event,
 512                 struct lttng_enabler *enabler)
 513 {
 514         struct lttng_ust_filter_bytecode_node *bc;
 515         struct lttng_bytecode_runtime *runtime;
 516
 517         /* Can only be called for events with desc attached */
 518         assert(event->desc);
 519
 520         /* Link each bytecode. */
 521         cds_list_for_each_entry(bc, &enabler->filter_bytecode_head, node) {
 522                 int found = 0, ret;
 523                 struct cds_list_head *insert_loc;
 524
 525                 cds_list_for_each_entry(runtime,
 526                                 &event->bytecode_runtime_head, node) {
 527                         if (runtime->bc == bc) {
 528                                 found = 1;
 529                                 break;
 530                         }
 531                 }
 532                 /* Skip bytecode already linked */
 533                 if (found)
 534                         continue;
 535
 536                 /*
 537                  * Insert at specified priority (seqnum) in increasing
 538                  * order. If there already is a bytecode of the same priority,
 539                  * insert the new bytecode right after it.
 540                  */
 541                 cds_list_for_each_entry_reverse(runtime,
 542                                 &event->bytecode_runtime_head, node) {
 543                         if (runtime->bc->bc.seqnum <= bc->bc.seqnum) {
 544                                 /* insert here */
 545                                 insert_loc = &runtime->node;
 546                                 goto add_within;
 547                         }
 548                 }
 549                 /* Add to head to list */
 550                 insert_loc = &event->bytecode_runtime_head;
 551         add_within:
 552                 dbg_printf("linking bytecode\n");
 553                 ret = _lttng_filter_event_link_bytecode(event, bc,
 554                                 insert_loc);
 555                 if (ret) {
 556                         dbg_printf("[lttng filter] warning: cannot link event bytecode\n");
 557                 }
 558         }
 559 }
 560
 561 /*
 562  * We own the filter_bytecode if we return success.
 563  */
 564 int lttng_filter_enabler_attach_bytecode(struct lttng_enabler *enabler,
 565                 struct lttng_ust_filter_bytecode_node *filter_bytecode)
 566 {
 567         cds_list_add(&filter_bytecode->node, &enabler->filter_bytecode_head);
 568         return 0;
 569 }
 570
 571 static
 572 void free_filter_runtime(struct cds_list_head *bytecode_runtime_head)
 573 {
 574         struct bytecode_runtime *runtime, *tmp;
 575
 576         cds_list_for_each_entry_safe(runtime, tmp, bytecode_runtime_head,
 577                         p.node) {
 578                 free(runtime->data);
 579                 free(runtime);
 580         }
 581 }
 582
 583 void lttng_free_event_filter_runtime(struct lttng_event *event)
 584 {
 585         free_filter_runtime(&event->bytecode_runtime_head);
 586 }