Loading...
1/*
2 * Copyright (C) 2010 Red Hat Inc, Steven Rostedt <srostedt@redhat.com>
3 *
4 * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
5 * This program is free software; you can redistribute it and/or
6 * modify it under the terms of the GNU Lesser General Public
7 * License as published by the Free Software Foundation;
8 * version 2.1 of the License (not later!)
9 *
10 * This program is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 * GNU Lesser General Public License for more details.
14 *
15 * You should have received a copy of the GNU Lesser General Public
16 * License along with this program; if not, see <http://www.gnu.org/licenses>
17 *
18 * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
19 */
20#include <stdio.h>
21#include <stdlib.h>
22#include <string.h>
23#include <stdarg.h>
24#include <errno.h>
25#include <sys/types.h>
26
27#include "event-parse.h"
28#include "event-utils.h"
29
30#define COMM "COMM"
31
32static struct format_field comm = {
33 .name = "COMM",
34};
35
36struct event_list {
37 struct event_list *next;
38 struct event_format *event;
39};
40
41static void show_error(char *error_buf, const char *fmt, ...)
42{
43 unsigned long long index;
44 const char *input;
45 va_list ap;
46 int len;
47 int i;
48
49 input = pevent_get_input_buf();
50 index = pevent_get_input_buf_ptr();
51 len = input ? strlen(input) : 0;
52
53 if (len) {
54 strcpy(error_buf, input);
55 error_buf[len] = '\n';
56 for (i = 1; i < len && i < index; i++)
57 error_buf[len+i] = ' ';
58 error_buf[len + i] = '^';
59 error_buf[len + i + 1] = '\n';
60 len += i+2;
61 }
62
63 va_start(ap, fmt);
64 vsnprintf(error_buf + len, PEVENT_FILTER_ERROR_BUFSZ - len, fmt, ap);
65 va_end(ap);
66}
67
68static void free_token(char *token)
69{
70 pevent_free_token(token);
71}
72
73static enum event_type read_token(char **tok)
74{
75 enum event_type type;
76 char *token = NULL;
77
78 do {
79 free_token(token);
80 type = pevent_read_token(&token);
81 } while (type == EVENT_NEWLINE || type == EVENT_SPACE);
82
83 /* If token is = or ! check to see if the next char is ~ */
84 if (token &&
85 (strcmp(token, "=") == 0 || strcmp(token, "!") == 0) &&
86 pevent_peek_char() == '~') {
87 /* append it */
88 *tok = malloc(3);
89 if (*tok == NULL) {
90 free_token(token);
91 return EVENT_ERROR;
92 }
93 sprintf(*tok, "%c%c", *token, '~');
94 free_token(token);
95 /* Now remove the '~' from the buffer */
96 pevent_read_token(&token);
97 free_token(token);
98 } else
99 *tok = token;
100
101 return type;
102}
103
104static int filter_cmp(const void *a, const void *b)
105{
106 const struct filter_type *ea = a;
107 const struct filter_type *eb = b;
108
109 if (ea->event_id < eb->event_id)
110 return -1;
111
112 if (ea->event_id > eb->event_id)
113 return 1;
114
115 return 0;
116}
117
118static struct filter_type *
119find_filter_type(struct event_filter *filter, int id)
120{
121 struct filter_type *filter_type;
122 struct filter_type key;
123
124 key.event_id = id;
125
126 filter_type = bsearch(&key, filter->event_filters,
127 filter->filters,
128 sizeof(*filter->event_filters),
129 filter_cmp);
130
131 return filter_type;
132}
133
134static struct filter_type *
135add_filter_type(struct event_filter *filter, int id)
136{
137 struct filter_type *filter_type;
138 int i;
139
140 filter_type = find_filter_type(filter, id);
141 if (filter_type)
142 return filter_type;
143
144 filter_type = realloc(filter->event_filters,
145 sizeof(*filter->event_filters) *
146 (filter->filters + 1));
147 if (!filter_type)
148 return NULL;
149
150 filter->event_filters = filter_type;
151
152 for (i = 0; i < filter->filters; i++) {
153 if (filter->event_filters[i].event_id > id)
154 break;
155 }
156
157 if (i < filter->filters)
158 memmove(&filter->event_filters[i+1],
159 &filter->event_filters[i],
160 sizeof(*filter->event_filters) *
161 (filter->filters - i));
162
163 filter_type = &filter->event_filters[i];
164 filter_type->event_id = id;
165 filter_type->event = pevent_find_event(filter->pevent, id);
166 filter_type->filter = NULL;
167
168 filter->filters++;
169
170 return filter_type;
171}
172
173/**
174 * pevent_filter_alloc - create a new event filter
175 * @pevent: The pevent that this filter is associated with
176 */
177struct event_filter *pevent_filter_alloc(struct pevent *pevent)
178{
179 struct event_filter *filter;
180
181 filter = malloc(sizeof(*filter));
182 if (filter == NULL)
183 return NULL;
184
185 memset(filter, 0, sizeof(*filter));
186 filter->pevent = pevent;
187 pevent_ref(pevent);
188
189 return filter;
190}
191
192static struct filter_arg *allocate_arg(void)
193{
194 return calloc(1, sizeof(struct filter_arg));
195}
196
197static void free_arg(struct filter_arg *arg)
198{
199 if (!arg)
200 return;
201
202 switch (arg->type) {
203 case FILTER_ARG_NONE:
204 case FILTER_ARG_BOOLEAN:
205 break;
206
207 case FILTER_ARG_NUM:
208 free_arg(arg->num.left);
209 free_arg(arg->num.right);
210 break;
211
212 case FILTER_ARG_EXP:
213 free_arg(arg->exp.left);
214 free_arg(arg->exp.right);
215 break;
216
217 case FILTER_ARG_STR:
218 free(arg->str.val);
219 regfree(&arg->str.reg);
220 free(arg->str.buffer);
221 break;
222
223 case FILTER_ARG_VALUE:
224 if (arg->value.type == FILTER_STRING ||
225 arg->value.type == FILTER_CHAR)
226 free(arg->value.str);
227 break;
228
229 case FILTER_ARG_OP:
230 free_arg(arg->op.left);
231 free_arg(arg->op.right);
232 default:
233 break;
234 }
235
236 free(arg);
237}
238
239static int add_event(struct event_list **events,
240 struct event_format *event)
241{
242 struct event_list *list;
243
244 list = malloc(sizeof(*list));
245 if (list == NULL)
246 return -1;
247
248 list->next = *events;
249 *events = list;
250 list->event = event;
251 return 0;
252}
253
254static int event_match(struct event_format *event,
255 regex_t *sreg, regex_t *ereg)
256{
257 if (sreg) {
258 return !regexec(sreg, event->system, 0, NULL, 0) &&
259 !regexec(ereg, event->name, 0, NULL, 0);
260 }
261
262 return !regexec(ereg, event->system, 0, NULL, 0) ||
263 !regexec(ereg, event->name, 0, NULL, 0);
264}
265
266static enum pevent_errno
267find_event(struct pevent *pevent, struct event_list **events,
268 char *sys_name, char *event_name)
269{
270 struct event_format *event;
271 regex_t ereg;
272 regex_t sreg;
273 int match = 0;
274 int fail = 0;
275 char *reg;
276 int ret;
277 int i;
278
279 if (!event_name) {
280 /* if no name is given, then swap sys and name */
281 event_name = sys_name;
282 sys_name = NULL;
283 }
284
285 reg = malloc(strlen(event_name) + 3);
286 if (reg == NULL)
287 return PEVENT_ERRNO__MEM_ALLOC_FAILED;
288
289 sprintf(reg, "^%s$", event_name);
290
291 ret = regcomp(&ereg, reg, REG_ICASE|REG_NOSUB);
292 free(reg);
293
294 if (ret)
295 return PEVENT_ERRNO__INVALID_EVENT_NAME;
296
297 if (sys_name) {
298 reg = malloc(strlen(sys_name) + 3);
299 if (reg == NULL) {
300 regfree(&ereg);
301 return PEVENT_ERRNO__MEM_ALLOC_FAILED;
302 }
303
304 sprintf(reg, "^%s$", sys_name);
305 ret = regcomp(&sreg, reg, REG_ICASE|REG_NOSUB);
306 free(reg);
307 if (ret) {
308 regfree(&ereg);
309 return PEVENT_ERRNO__INVALID_EVENT_NAME;
310 }
311 }
312
313 for (i = 0; i < pevent->nr_events; i++) {
314 event = pevent->events[i];
315 if (event_match(event, sys_name ? &sreg : NULL, &ereg)) {
316 match = 1;
317 if (add_event(events, event) < 0) {
318 fail = 1;
319 break;
320 }
321 }
322 }
323
324 regfree(&ereg);
325 if (sys_name)
326 regfree(&sreg);
327
328 if (!match)
329 return PEVENT_ERRNO__EVENT_NOT_FOUND;
330 if (fail)
331 return PEVENT_ERRNO__MEM_ALLOC_FAILED;
332
333 return 0;
334}
335
336static void free_events(struct event_list *events)
337{
338 struct event_list *event;
339
340 while (events) {
341 event = events;
342 events = events->next;
343 free(event);
344 }
345}
346
347static enum pevent_errno
348create_arg_item(struct event_format *event, const char *token,
349 enum event_type type, struct filter_arg **parg, char *error_str)
350{
351 struct format_field *field;
352 struct filter_arg *arg;
353
354 arg = allocate_arg();
355 if (arg == NULL) {
356 show_error(error_str, "failed to allocate filter arg");
357 return PEVENT_ERRNO__MEM_ALLOC_FAILED;
358 }
359
360 switch (type) {
361
362 case EVENT_SQUOTE:
363 case EVENT_DQUOTE:
364 arg->type = FILTER_ARG_VALUE;
365 arg->value.type =
366 type == EVENT_DQUOTE ? FILTER_STRING : FILTER_CHAR;
367 arg->value.str = strdup(token);
368 if (!arg->value.str) {
369 free_arg(arg);
370 show_error(error_str, "failed to allocate string filter arg");
371 return PEVENT_ERRNO__MEM_ALLOC_FAILED;
372 }
373 break;
374 case EVENT_ITEM:
375 /* if it is a number, then convert it */
376 if (isdigit(token[0])) {
377 arg->type = FILTER_ARG_VALUE;
378 arg->value.type = FILTER_NUMBER;
379 arg->value.val = strtoull(token, NULL, 0);
380 break;
381 }
382 /* Consider this a field */
383 field = pevent_find_any_field(event, token);
384 if (!field) {
385 if (strcmp(token, COMM) != 0) {
386 /* not a field, Make it false */
387 arg->type = FILTER_ARG_BOOLEAN;
388 arg->boolean.value = FILTER_FALSE;
389 break;
390 }
391 /* If token is 'COMM' then it is special */
392 field = &comm;
393 }
394 arg->type = FILTER_ARG_FIELD;
395 arg->field.field = field;
396 break;
397 default:
398 free_arg(arg);
399 show_error(error_str, "expected a value but found %s", token);
400 return PEVENT_ERRNO__UNEXPECTED_TYPE;
401 }
402 *parg = arg;
403 return 0;
404}
405
406static struct filter_arg *
407create_arg_op(enum filter_op_type btype)
408{
409 struct filter_arg *arg;
410
411 arg = allocate_arg();
412 if (!arg)
413 return NULL;
414
415 arg->type = FILTER_ARG_OP;
416 arg->op.type = btype;
417
418 return arg;
419}
420
421static struct filter_arg *
422create_arg_exp(enum filter_exp_type etype)
423{
424 struct filter_arg *arg;
425
426 arg = allocate_arg();
427 if (!arg)
428 return NULL;
429
430 arg->type = FILTER_ARG_EXP;
431 arg->op.type = etype;
432
433 return arg;
434}
435
436static struct filter_arg *
437create_arg_cmp(enum filter_exp_type etype)
438{
439 struct filter_arg *arg;
440
441 arg = allocate_arg();
442 if (!arg)
443 return NULL;
444
445 /* Use NUM and change if necessary */
446 arg->type = FILTER_ARG_NUM;
447 arg->op.type = etype;
448
449 return arg;
450}
451
452static enum pevent_errno
453add_right(struct filter_arg *op, struct filter_arg *arg, char *error_str)
454{
455 struct filter_arg *left;
456 char *str;
457 int op_type;
458 int ret;
459
460 switch (op->type) {
461 case FILTER_ARG_EXP:
462 if (op->exp.right)
463 goto out_fail;
464 op->exp.right = arg;
465 break;
466
467 case FILTER_ARG_OP:
468 if (op->op.right)
469 goto out_fail;
470 op->op.right = arg;
471 break;
472
473 case FILTER_ARG_NUM:
474 if (op->op.right)
475 goto out_fail;
476 /*
477 * The arg must be num, str, or field
478 */
479 switch (arg->type) {
480 case FILTER_ARG_VALUE:
481 case FILTER_ARG_FIELD:
482 break;
483 default:
484 show_error(error_str, "Illegal rvalue");
485 return PEVENT_ERRNO__ILLEGAL_RVALUE;
486 }
487
488 /*
489 * Depending on the type, we may need to
490 * convert this to a string or regex.
491 */
492 switch (arg->value.type) {
493 case FILTER_CHAR:
494 /*
495 * A char should be converted to number if
496 * the string is 1 byte, and the compare
497 * is not a REGEX.
498 */
499 if (strlen(arg->value.str) == 1 &&
500 op->num.type != FILTER_CMP_REGEX &&
501 op->num.type != FILTER_CMP_NOT_REGEX) {
502 arg->value.type = FILTER_NUMBER;
503 goto do_int;
504 }
505 /* fall through */
506 case FILTER_STRING:
507
508 /* convert op to a string arg */
509 op_type = op->num.type;
510 left = op->num.left;
511 str = arg->value.str;
512
513 /* reset the op for the new field */
514 memset(op, 0, sizeof(*op));
515
516 /*
517 * If left arg was a field not found then
518 * NULL the entire op.
519 */
520 if (left->type == FILTER_ARG_BOOLEAN) {
521 free_arg(left);
522 free_arg(arg);
523 op->type = FILTER_ARG_BOOLEAN;
524 op->boolean.value = FILTER_FALSE;
525 break;
526 }
527
528 /* Left arg must be a field */
529 if (left->type != FILTER_ARG_FIELD) {
530 show_error(error_str,
531 "Illegal lvalue for string comparison");
532 return PEVENT_ERRNO__ILLEGAL_LVALUE;
533 }
534
535 /* Make sure this is a valid string compare */
536 switch (op_type) {
537 case FILTER_CMP_EQ:
538 op_type = FILTER_CMP_MATCH;
539 break;
540 case FILTER_CMP_NE:
541 op_type = FILTER_CMP_NOT_MATCH;
542 break;
543
544 case FILTER_CMP_REGEX:
545 case FILTER_CMP_NOT_REGEX:
546 ret = regcomp(&op->str.reg, str, REG_ICASE|REG_NOSUB);
547 if (ret) {
548 show_error(error_str,
549 "RegEx '%s' did not compute",
550 str);
551 return PEVENT_ERRNO__INVALID_REGEX;
552 }
553 break;
554 default:
555 show_error(error_str,
556 "Illegal comparison for string");
557 return PEVENT_ERRNO__ILLEGAL_STRING_CMP;
558 }
559
560 op->type = FILTER_ARG_STR;
561 op->str.type = op_type;
562 op->str.field = left->field.field;
563 op->str.val = strdup(str);
564 if (!op->str.val) {
565 show_error(error_str, "Failed to allocate string filter");
566 return PEVENT_ERRNO__MEM_ALLOC_FAILED;
567 }
568 /*
569 * Need a buffer to copy data for tests
570 */
571 op->str.buffer = malloc(op->str.field->size + 1);
572 if (!op->str.buffer) {
573 show_error(error_str, "Failed to allocate string filter");
574 return PEVENT_ERRNO__MEM_ALLOC_FAILED;
575 }
576 /* Null terminate this buffer */
577 op->str.buffer[op->str.field->size] = 0;
578
579 /* We no longer have left or right args */
580 free_arg(arg);
581 free_arg(left);
582
583 break;
584
585 case FILTER_NUMBER:
586
587 do_int:
588 switch (op->num.type) {
589 case FILTER_CMP_REGEX:
590 case FILTER_CMP_NOT_REGEX:
591 show_error(error_str,
592 "Op not allowed with integers");
593 return PEVENT_ERRNO__ILLEGAL_INTEGER_CMP;
594
595 default:
596 break;
597 }
598
599 /* numeric compare */
600 op->num.right = arg;
601 break;
602 default:
603 goto out_fail;
604 }
605 break;
606 default:
607 goto out_fail;
608 }
609
610 return 0;
611
612 out_fail:
613 show_error(error_str, "Syntax error");
614 return PEVENT_ERRNO__SYNTAX_ERROR;
615}
616
617static struct filter_arg *
618rotate_op_right(struct filter_arg *a, struct filter_arg *b)
619{
620 struct filter_arg *arg;
621
622 arg = a->op.right;
623 a->op.right = b;
624 return arg;
625}
626
627static enum pevent_errno add_left(struct filter_arg *op, struct filter_arg *arg)
628{
629 switch (op->type) {
630 case FILTER_ARG_EXP:
631 if (arg->type == FILTER_ARG_OP)
632 arg = rotate_op_right(arg, op);
633 op->exp.left = arg;
634 break;
635
636 case FILTER_ARG_OP:
637 op->op.left = arg;
638 break;
639 case FILTER_ARG_NUM:
640 if (arg->type == FILTER_ARG_OP)
641 arg = rotate_op_right(arg, op);
642
643 /* left arg of compares must be a field */
644 if (arg->type != FILTER_ARG_FIELD &&
645 arg->type != FILTER_ARG_BOOLEAN)
646 return PEVENT_ERRNO__INVALID_ARG_TYPE;
647 op->num.left = arg;
648 break;
649 default:
650 return PEVENT_ERRNO__INVALID_ARG_TYPE;
651 }
652 return 0;
653}
654
655enum op_type {
656 OP_NONE,
657 OP_BOOL,
658 OP_NOT,
659 OP_EXP,
660 OP_CMP,
661};
662
663static enum op_type process_op(const char *token,
664 enum filter_op_type *btype,
665 enum filter_cmp_type *ctype,
666 enum filter_exp_type *etype)
667{
668 *btype = FILTER_OP_NOT;
669 *etype = FILTER_EXP_NONE;
670 *ctype = FILTER_CMP_NONE;
671
672 if (strcmp(token, "&&") == 0)
673 *btype = FILTER_OP_AND;
674 else if (strcmp(token, "||") == 0)
675 *btype = FILTER_OP_OR;
676 else if (strcmp(token, "!") == 0)
677 return OP_NOT;
678
679 if (*btype != FILTER_OP_NOT)
680 return OP_BOOL;
681
682 /* Check for value expressions */
683 if (strcmp(token, "+") == 0) {
684 *etype = FILTER_EXP_ADD;
685 } else if (strcmp(token, "-") == 0) {
686 *etype = FILTER_EXP_SUB;
687 } else if (strcmp(token, "*") == 0) {
688 *etype = FILTER_EXP_MUL;
689 } else if (strcmp(token, "/") == 0) {
690 *etype = FILTER_EXP_DIV;
691 } else if (strcmp(token, "%") == 0) {
692 *etype = FILTER_EXP_MOD;
693 } else if (strcmp(token, ">>") == 0) {
694 *etype = FILTER_EXP_RSHIFT;
695 } else if (strcmp(token, "<<") == 0) {
696 *etype = FILTER_EXP_LSHIFT;
697 } else if (strcmp(token, "&") == 0) {
698 *etype = FILTER_EXP_AND;
699 } else if (strcmp(token, "|") == 0) {
700 *etype = FILTER_EXP_OR;
701 } else if (strcmp(token, "^") == 0) {
702 *etype = FILTER_EXP_XOR;
703 } else if (strcmp(token, "~") == 0)
704 *etype = FILTER_EXP_NOT;
705
706 if (*etype != FILTER_EXP_NONE)
707 return OP_EXP;
708
709 /* Check for compares */
710 if (strcmp(token, "==") == 0)
711 *ctype = FILTER_CMP_EQ;
712 else if (strcmp(token, "!=") == 0)
713 *ctype = FILTER_CMP_NE;
714 else if (strcmp(token, "<") == 0)
715 *ctype = FILTER_CMP_LT;
716 else if (strcmp(token, ">") == 0)
717 *ctype = FILTER_CMP_GT;
718 else if (strcmp(token, "<=") == 0)
719 *ctype = FILTER_CMP_LE;
720 else if (strcmp(token, ">=") == 0)
721 *ctype = FILTER_CMP_GE;
722 else if (strcmp(token, "=~") == 0)
723 *ctype = FILTER_CMP_REGEX;
724 else if (strcmp(token, "!~") == 0)
725 *ctype = FILTER_CMP_NOT_REGEX;
726 else
727 return OP_NONE;
728
729 return OP_CMP;
730}
731
732static int check_op_done(struct filter_arg *arg)
733{
734 switch (arg->type) {
735 case FILTER_ARG_EXP:
736 return arg->exp.right != NULL;
737
738 case FILTER_ARG_OP:
739 return arg->op.right != NULL;
740
741 case FILTER_ARG_NUM:
742 return arg->num.right != NULL;
743
744 case FILTER_ARG_STR:
745 /* A string conversion is always done */
746 return 1;
747
748 case FILTER_ARG_BOOLEAN:
749 /* field not found, is ok */
750 return 1;
751
752 default:
753 return 0;
754 }
755}
756
757enum filter_vals {
758 FILTER_VAL_NORM,
759 FILTER_VAL_FALSE,
760 FILTER_VAL_TRUE,
761};
762
763static enum pevent_errno
764reparent_op_arg(struct filter_arg *parent, struct filter_arg *old_child,
765 struct filter_arg *arg, char *error_str)
766{
767 struct filter_arg *other_child;
768 struct filter_arg **ptr;
769
770 if (parent->type != FILTER_ARG_OP &&
771 arg->type != FILTER_ARG_OP) {
772 show_error(error_str, "can not reparent other than OP");
773 return PEVENT_ERRNO__REPARENT_NOT_OP;
774 }
775
776 /* Get the sibling */
777 if (old_child->op.right == arg) {
778 ptr = &old_child->op.right;
779 other_child = old_child->op.left;
780 } else if (old_child->op.left == arg) {
781 ptr = &old_child->op.left;
782 other_child = old_child->op.right;
783 } else {
784 show_error(error_str, "Error in reparent op, find other child");
785 return PEVENT_ERRNO__REPARENT_FAILED;
786 }
787
788 /* Detach arg from old_child */
789 *ptr = NULL;
790
791 /* Check for root */
792 if (parent == old_child) {
793 free_arg(other_child);
794 *parent = *arg;
795 /* Free arg without recussion */
796 free(arg);
797 return 0;
798 }
799
800 if (parent->op.right == old_child)
801 ptr = &parent->op.right;
802 else if (parent->op.left == old_child)
803 ptr = &parent->op.left;
804 else {
805 show_error(error_str, "Error in reparent op");
806 return PEVENT_ERRNO__REPARENT_FAILED;
807 }
808
809 *ptr = arg;
810
811 free_arg(old_child);
812 return 0;
813}
814
815/* Returns either filter_vals (success) or pevent_errno (failfure) */
816static int test_arg(struct filter_arg *parent, struct filter_arg *arg,
817 char *error_str)
818{
819 int lval, rval;
820
821 switch (arg->type) {
822
823 /* bad case */
824 case FILTER_ARG_BOOLEAN:
825 return FILTER_VAL_FALSE + arg->boolean.value;
826
827 /* good cases: */
828 case FILTER_ARG_STR:
829 case FILTER_ARG_VALUE:
830 case FILTER_ARG_FIELD:
831 return FILTER_VAL_NORM;
832
833 case FILTER_ARG_EXP:
834 lval = test_arg(arg, arg->exp.left, error_str);
835 if (lval != FILTER_VAL_NORM)
836 return lval;
837 rval = test_arg(arg, arg->exp.right, error_str);
838 if (rval != FILTER_VAL_NORM)
839 return rval;
840 return FILTER_VAL_NORM;
841
842 case FILTER_ARG_NUM:
843 lval = test_arg(arg, arg->num.left, error_str);
844 if (lval != FILTER_VAL_NORM)
845 return lval;
846 rval = test_arg(arg, arg->num.right, error_str);
847 if (rval != FILTER_VAL_NORM)
848 return rval;
849 return FILTER_VAL_NORM;
850
851 case FILTER_ARG_OP:
852 if (arg->op.type != FILTER_OP_NOT) {
853 lval = test_arg(arg, arg->op.left, error_str);
854 switch (lval) {
855 case FILTER_VAL_NORM:
856 break;
857 case FILTER_VAL_TRUE:
858 if (arg->op.type == FILTER_OP_OR)
859 return FILTER_VAL_TRUE;
860 rval = test_arg(arg, arg->op.right, error_str);
861 if (rval != FILTER_VAL_NORM)
862 return rval;
863
864 return reparent_op_arg(parent, arg, arg->op.right,
865 error_str);
866
867 case FILTER_VAL_FALSE:
868 if (arg->op.type == FILTER_OP_AND)
869 return FILTER_VAL_FALSE;
870 rval = test_arg(arg, arg->op.right, error_str);
871 if (rval != FILTER_VAL_NORM)
872 return rval;
873
874 return reparent_op_arg(parent, arg, arg->op.right,
875 error_str);
876
877 default:
878 return lval;
879 }
880 }
881
882 rval = test_arg(arg, arg->op.right, error_str);
883 switch (rval) {
884 case FILTER_VAL_NORM:
885 default:
886 break;
887
888 case FILTER_VAL_TRUE:
889 if (arg->op.type == FILTER_OP_OR)
890 return FILTER_VAL_TRUE;
891 if (arg->op.type == FILTER_OP_NOT)
892 return FILTER_VAL_FALSE;
893
894 return reparent_op_arg(parent, arg, arg->op.left,
895 error_str);
896
897 case FILTER_VAL_FALSE:
898 if (arg->op.type == FILTER_OP_AND)
899 return FILTER_VAL_FALSE;
900 if (arg->op.type == FILTER_OP_NOT)
901 return FILTER_VAL_TRUE;
902
903 return reparent_op_arg(parent, arg, arg->op.left,
904 error_str);
905 }
906
907 return rval;
908 default:
909 show_error(error_str, "bad arg in filter tree");
910 return PEVENT_ERRNO__BAD_FILTER_ARG;
911 }
912 return FILTER_VAL_NORM;
913}
914
915/* Remove any unknown event fields */
916static int collapse_tree(struct filter_arg *arg,
917 struct filter_arg **arg_collapsed, char *error_str)
918{
919 int ret;
920
921 ret = test_arg(arg, arg, error_str);
922 switch (ret) {
923 case FILTER_VAL_NORM:
924 break;
925
926 case FILTER_VAL_TRUE:
927 case FILTER_VAL_FALSE:
928 free_arg(arg);
929 arg = allocate_arg();
930 if (arg) {
931 arg->type = FILTER_ARG_BOOLEAN;
932 arg->boolean.value = ret == FILTER_VAL_TRUE;
933 } else {
934 show_error(error_str, "Failed to allocate filter arg");
935 ret = PEVENT_ERRNO__MEM_ALLOC_FAILED;
936 }
937 break;
938
939 default:
940 /* test_arg() already set the error_str */
941 free_arg(arg);
942 arg = NULL;
943 break;
944 }
945
946 *arg_collapsed = arg;
947 return ret;
948}
949
950static enum pevent_errno
951process_filter(struct event_format *event, struct filter_arg **parg,
952 char *error_str, int not)
953{
954 enum event_type type;
955 char *token = NULL;
956 struct filter_arg *current_op = NULL;
957 struct filter_arg *current_exp = NULL;
958 struct filter_arg *left_item = NULL;
959 struct filter_arg *arg = NULL;
960 enum op_type op_type;
961 enum filter_op_type btype;
962 enum filter_exp_type etype;
963 enum filter_cmp_type ctype;
964 enum pevent_errno ret;
965
966 *parg = NULL;
967
968 do {
969 free(token);
970 type = read_token(&token);
971 switch (type) {
972 case EVENT_SQUOTE:
973 case EVENT_DQUOTE:
974 case EVENT_ITEM:
975 ret = create_arg_item(event, token, type, &arg, error_str);
976 if (ret < 0)
977 goto fail;
978 if (!left_item)
979 left_item = arg;
980 else if (current_exp) {
981 ret = add_right(current_exp, arg, error_str);
982 if (ret < 0)
983 goto fail;
984 left_item = NULL;
985 /* Not's only one one expression */
986 if (not) {
987 arg = NULL;
988 if (current_op)
989 goto fail_syntax;
990 free(token);
991 *parg = current_exp;
992 return 0;
993 }
994 } else
995 goto fail_syntax;
996 arg = NULL;
997 break;
998
999 case EVENT_DELIM:
1000 if (*token == ',') {
1001 show_error(error_str, "Illegal token ','");
1002 ret = PEVENT_ERRNO__ILLEGAL_TOKEN;
1003 goto fail;
1004 }
1005
1006 if (*token == '(') {
1007 if (left_item) {
1008 show_error(error_str,
1009 "Open paren can not come after item");
1010 ret = PEVENT_ERRNO__INVALID_PAREN;
1011 goto fail;
1012 }
1013 if (current_exp) {
1014 show_error(error_str,
1015 "Open paren can not come after expression");
1016 ret = PEVENT_ERRNO__INVALID_PAREN;
1017 goto fail;
1018 }
1019
1020 ret = process_filter(event, &arg, error_str, 0);
1021 if (ret != PEVENT_ERRNO__UNBALANCED_PAREN) {
1022 if (ret == 0) {
1023 show_error(error_str,
1024 "Unbalanced number of '('");
1025 ret = PEVENT_ERRNO__UNBALANCED_PAREN;
1026 }
1027 goto fail;
1028 }
1029 ret = 0;
1030
1031 /* A not wants just one expression */
1032 if (not) {
1033 if (current_op)
1034 goto fail_syntax;
1035 *parg = arg;
1036 return 0;
1037 }
1038
1039 if (current_op)
1040 ret = add_right(current_op, arg, error_str);
1041 else
1042 current_exp = arg;
1043
1044 if (ret < 0)
1045 goto fail;
1046
1047 } else { /* ')' */
1048 if (!current_op && !current_exp)
1049 goto fail_syntax;
1050
1051 /* Make sure everything is finished at this level */
1052 if (current_exp && !check_op_done(current_exp))
1053 goto fail_syntax;
1054 if (current_op && !check_op_done(current_op))
1055 goto fail_syntax;
1056
1057 if (current_op)
1058 *parg = current_op;
1059 else
1060 *parg = current_exp;
1061 return PEVENT_ERRNO__UNBALANCED_PAREN;
1062 }
1063 break;
1064
1065 case EVENT_OP:
1066 op_type = process_op(token, &btype, &ctype, &etype);
1067
1068 /* All expect a left arg except for NOT */
1069 switch (op_type) {
1070 case OP_BOOL:
1071 /* Logic ops need a left expression */
1072 if (!current_exp && !current_op)
1073 goto fail_syntax;
1074 /* fall through */
1075 case OP_NOT:
1076 /* logic only processes ops and exp */
1077 if (left_item)
1078 goto fail_syntax;
1079 break;
1080 case OP_EXP:
1081 case OP_CMP:
1082 if (!left_item)
1083 goto fail_syntax;
1084 break;
1085 case OP_NONE:
1086 show_error(error_str,
1087 "Unknown op token %s", token);
1088 ret = PEVENT_ERRNO__UNKNOWN_TOKEN;
1089 goto fail;
1090 }
1091
1092 ret = 0;
1093 switch (op_type) {
1094 case OP_BOOL:
1095 arg = create_arg_op(btype);
1096 if (arg == NULL)
1097 goto fail_alloc;
1098 if (current_op)
1099 ret = add_left(arg, current_op);
1100 else
1101 ret = add_left(arg, current_exp);
1102 current_op = arg;
1103 current_exp = NULL;
1104 break;
1105
1106 case OP_NOT:
1107 arg = create_arg_op(btype);
1108 if (arg == NULL)
1109 goto fail_alloc;
1110 if (current_op)
1111 ret = add_right(current_op, arg, error_str);
1112 if (ret < 0)
1113 goto fail;
1114 current_exp = arg;
1115 ret = process_filter(event, &arg, error_str, 1);
1116 if (ret < 0)
1117 goto fail;
1118 ret = add_right(current_exp, arg, error_str);
1119 if (ret < 0)
1120 goto fail;
1121 break;
1122
1123 case OP_EXP:
1124 case OP_CMP:
1125 if (op_type == OP_EXP)
1126 arg = create_arg_exp(etype);
1127 else
1128 arg = create_arg_cmp(ctype);
1129 if (arg == NULL)
1130 goto fail_alloc;
1131
1132 if (current_op)
1133 ret = add_right(current_op, arg, error_str);
1134 if (ret < 0)
1135 goto fail;
1136 ret = add_left(arg, left_item);
1137 if (ret < 0) {
1138 arg = NULL;
1139 goto fail_syntax;
1140 }
1141 current_exp = arg;
1142 break;
1143 default:
1144 break;
1145 }
1146 arg = NULL;
1147 if (ret < 0)
1148 goto fail_syntax;
1149 break;
1150 case EVENT_NONE:
1151 break;
1152 case EVENT_ERROR:
1153 goto fail_alloc;
1154 default:
1155 goto fail_syntax;
1156 }
1157 } while (type != EVENT_NONE);
1158
1159 if (!current_op && !current_exp)
1160 goto fail_syntax;
1161
1162 if (!current_op)
1163 current_op = current_exp;
1164
1165 ret = collapse_tree(current_op, parg, error_str);
1166 if (ret < 0)
1167 goto fail;
1168
1169 *parg = current_op;
1170
1171 return 0;
1172
1173 fail_alloc:
1174 show_error(error_str, "failed to allocate filter arg");
1175 ret = PEVENT_ERRNO__MEM_ALLOC_FAILED;
1176 goto fail;
1177 fail_syntax:
1178 show_error(error_str, "Syntax error");
1179 ret = PEVENT_ERRNO__SYNTAX_ERROR;
1180 fail:
1181 free_arg(current_op);
1182 free_arg(current_exp);
1183 free_arg(arg);
1184 free(token);
1185 return ret;
1186}
1187
1188static enum pevent_errno
1189process_event(struct event_format *event, const char *filter_str,
1190 struct filter_arg **parg, char *error_str)
1191{
1192 int ret;
1193
1194 pevent_buffer_init(filter_str, strlen(filter_str));
1195
1196 ret = process_filter(event, parg, error_str, 0);
1197 if (ret < 0)
1198 return ret;
1199
1200 /* If parg is NULL, then make it into FALSE */
1201 if (!*parg) {
1202 *parg = allocate_arg();
1203 if (*parg == NULL)
1204 return PEVENT_ERRNO__MEM_ALLOC_FAILED;
1205
1206 (*parg)->type = FILTER_ARG_BOOLEAN;
1207 (*parg)->boolean.value = FILTER_FALSE;
1208 }
1209
1210 return 0;
1211}
1212
1213static enum pevent_errno
1214filter_event(struct event_filter *filter, struct event_format *event,
1215 const char *filter_str, char *error_str)
1216{
1217 struct filter_type *filter_type;
1218 struct filter_arg *arg;
1219 enum pevent_errno ret;
1220
1221 if (filter_str) {
1222 ret = process_event(event, filter_str, &arg, error_str);
1223 if (ret < 0)
1224 return ret;
1225
1226 } else {
1227 /* just add a TRUE arg */
1228 arg = allocate_arg();
1229 if (arg == NULL)
1230 return PEVENT_ERRNO__MEM_ALLOC_FAILED;
1231
1232 arg->type = FILTER_ARG_BOOLEAN;
1233 arg->boolean.value = FILTER_TRUE;
1234 }
1235
1236 filter_type = add_filter_type(filter, event->id);
1237 if (filter_type == NULL)
1238 return PEVENT_ERRNO__MEM_ALLOC_FAILED;
1239
1240 if (filter_type->filter)
1241 free_arg(filter_type->filter);
1242 filter_type->filter = arg;
1243
1244 return 0;
1245}
1246
1247static void filter_init_error_buf(struct event_filter *filter)
1248{
1249 /* clear buffer to reset show error */
1250 pevent_buffer_init("", 0);
1251 filter->error_buffer[0] = '\0';
1252}
1253
1254/**
1255 * pevent_filter_add_filter_str - add a new filter
1256 * @filter: the event filter to add to
1257 * @filter_str: the filter string that contains the filter
1258 *
1259 * Returns 0 if the filter was successfully added or a
1260 * negative error code. Use pevent_filter_strerror() to see
1261 * actual error message in case of error.
1262 */
1263enum pevent_errno pevent_filter_add_filter_str(struct event_filter *filter,
1264 const char *filter_str)
1265{
1266 struct pevent *pevent = filter->pevent;
1267 struct event_list *event;
1268 struct event_list *events = NULL;
1269 const char *filter_start;
1270 const char *next_event;
1271 char *this_event;
1272 char *event_name = NULL;
1273 char *sys_name = NULL;
1274 char *sp;
1275 enum pevent_errno rtn = 0; /* PEVENT_ERRNO__SUCCESS */
1276 int len;
1277 int ret;
1278
1279 filter_init_error_buf(filter);
1280
1281 filter_start = strchr(filter_str, ':');
1282 if (filter_start)
1283 len = filter_start - filter_str;
1284 else
1285 len = strlen(filter_str);
1286
1287 do {
1288 next_event = strchr(filter_str, ',');
1289 if (next_event &&
1290 (!filter_start || next_event < filter_start))
1291 len = next_event - filter_str;
1292 else if (filter_start)
1293 len = filter_start - filter_str;
1294 else
1295 len = strlen(filter_str);
1296
1297 this_event = malloc(len + 1);
1298 if (this_event == NULL) {
1299 /* This can only happen when events is NULL, but still */
1300 free_events(events);
1301 return PEVENT_ERRNO__MEM_ALLOC_FAILED;
1302 }
1303 memcpy(this_event, filter_str, len);
1304 this_event[len] = 0;
1305
1306 if (next_event)
1307 next_event++;
1308
1309 filter_str = next_event;
1310
1311 sys_name = strtok_r(this_event, "/", &sp);
1312 event_name = strtok_r(NULL, "/", &sp);
1313
1314 if (!sys_name) {
1315 /* This can only happen when events is NULL, but still */
1316 free_events(events);
1317 free(this_event);
1318 return PEVENT_ERRNO__FILTER_NOT_FOUND;
1319 }
1320
1321 /* Find this event */
1322 ret = find_event(pevent, &events, strim(sys_name), strim(event_name));
1323 if (ret < 0) {
1324 free_events(events);
1325 free(this_event);
1326 return ret;
1327 }
1328 free(this_event);
1329 } while (filter_str);
1330
1331 /* Skip the ':' */
1332 if (filter_start)
1333 filter_start++;
1334
1335 /* filter starts here */
1336 for (event = events; event; event = event->next) {
1337 ret = filter_event(filter, event->event, filter_start,
1338 filter->error_buffer);
1339 /* Failures are returned if a parse error happened */
1340 if (ret < 0)
1341 rtn = ret;
1342
1343 if (ret >= 0 && pevent->test_filters) {
1344 char *test;
1345 test = pevent_filter_make_string(filter, event->event->id);
1346 if (test) {
1347 printf(" '%s: %s'\n", event->event->name, test);
1348 free(test);
1349 }
1350 }
1351 }
1352
1353 free_events(events);
1354
1355 if (rtn >= 0 && pevent->test_filters)
1356 exit(0);
1357
1358 return rtn;
1359}
1360
1361static void free_filter_type(struct filter_type *filter_type)
1362{
1363 free_arg(filter_type->filter);
1364}
1365
1366/**
1367 * pevent_filter_strerror - fill error message in a buffer
1368 * @filter: the event filter contains error
1369 * @err: the error code
1370 * @buf: the buffer to be filled in
1371 * @buflen: the size of the buffer
1372 *
1373 * Returns 0 if message was filled successfully, -1 if error
1374 */
1375int pevent_filter_strerror(struct event_filter *filter, enum pevent_errno err,
1376 char *buf, size_t buflen)
1377{
1378 if (err <= __PEVENT_ERRNO__START || err >= __PEVENT_ERRNO__END)
1379 return -1;
1380
1381 if (strlen(filter->error_buffer) > 0) {
1382 size_t len = snprintf(buf, buflen, "%s", filter->error_buffer);
1383
1384 if (len > buflen)
1385 return -1;
1386 return 0;
1387 }
1388
1389 return pevent_strerror(filter->pevent, err, buf, buflen);
1390}
1391
1392/**
1393 * pevent_filter_remove_event - remove a filter for an event
1394 * @filter: the event filter to remove from
1395 * @event_id: the event to remove a filter for
1396 *
1397 * Removes the filter saved for an event defined by @event_id
1398 * from the @filter.
1399 *
1400 * Returns 1: if an event was removed
1401 * 0: if the event was not found
1402 */
1403int pevent_filter_remove_event(struct event_filter *filter,
1404 int event_id)
1405{
1406 struct filter_type *filter_type;
1407 unsigned long len;
1408
1409 if (!filter->filters)
1410 return 0;
1411
1412 filter_type = find_filter_type(filter, event_id);
1413
1414 if (!filter_type)
1415 return 0;
1416
1417 free_filter_type(filter_type);
1418
1419 /* The filter_type points into the event_filters array */
1420 len = (unsigned long)(filter->event_filters + filter->filters) -
1421 (unsigned long)(filter_type + 1);
1422
1423 memmove(filter_type, filter_type + 1, len);
1424 filter->filters--;
1425
1426 memset(&filter->event_filters[filter->filters], 0,
1427 sizeof(*filter_type));
1428
1429 return 1;
1430}
1431
1432/**
1433 * pevent_filter_reset - clear all filters in a filter
1434 * @filter: the event filter to reset
1435 *
1436 * Removes all filters from a filter and resets it.
1437 */
1438void pevent_filter_reset(struct event_filter *filter)
1439{
1440 int i;
1441
1442 for (i = 0; i < filter->filters; i++)
1443 free_filter_type(&filter->event_filters[i]);
1444
1445 free(filter->event_filters);
1446 filter->filters = 0;
1447 filter->event_filters = NULL;
1448}
1449
1450void pevent_filter_free(struct event_filter *filter)
1451{
1452 pevent_unref(filter->pevent);
1453
1454 pevent_filter_reset(filter);
1455
1456 free(filter);
1457}
1458
1459static char *arg_to_str(struct event_filter *filter, struct filter_arg *arg);
1460
1461static int copy_filter_type(struct event_filter *filter,
1462 struct event_filter *source,
1463 struct filter_type *filter_type)
1464{
1465 struct filter_arg *arg;
1466 struct event_format *event;
1467 const char *sys;
1468 const char *name;
1469 char *str;
1470
1471 /* Can't assume that the pevent's are the same */
1472 sys = filter_type->event->system;
1473 name = filter_type->event->name;
1474 event = pevent_find_event_by_name(filter->pevent, sys, name);
1475 if (!event)
1476 return -1;
1477
1478 str = arg_to_str(source, filter_type->filter);
1479 if (!str)
1480 return -1;
1481
1482 if (strcmp(str, "TRUE") == 0 || strcmp(str, "FALSE") == 0) {
1483 /* Add trivial event */
1484 arg = allocate_arg();
1485 if (arg == NULL)
1486 return -1;
1487
1488 arg->type = FILTER_ARG_BOOLEAN;
1489 if (strcmp(str, "TRUE") == 0)
1490 arg->boolean.value = 1;
1491 else
1492 arg->boolean.value = 0;
1493
1494 filter_type = add_filter_type(filter, event->id);
1495 if (filter_type == NULL)
1496 return -1;
1497
1498 filter_type->filter = arg;
1499
1500 free(str);
1501 return 0;
1502 }
1503
1504 filter_event(filter, event, str, NULL);
1505 free(str);
1506
1507 return 0;
1508}
1509
1510/**
1511 * pevent_filter_copy - copy a filter using another filter
1512 * @dest - the filter to copy to
1513 * @source - the filter to copy from
1514 *
1515 * Returns 0 on success and -1 if not all filters were copied
1516 */
1517int pevent_filter_copy(struct event_filter *dest, struct event_filter *source)
1518{
1519 int ret = 0;
1520 int i;
1521
1522 pevent_filter_reset(dest);
1523
1524 for (i = 0; i < source->filters; i++) {
1525 if (copy_filter_type(dest, source, &source->event_filters[i]))
1526 ret = -1;
1527 }
1528 return ret;
1529}
1530
1531
1532/**
1533 * pevent_update_trivial - update the trivial filters with the given filter
1534 * @dest - the filter to update
1535 * @source - the filter as the source of the update
1536 * @type - the type of trivial filter to update.
1537 *
1538 * Scan dest for trivial events matching @type to replace with the source.
1539 *
1540 * Returns 0 on success and -1 if there was a problem updating, but
1541 * events may have still been updated on error.
1542 */
1543int pevent_update_trivial(struct event_filter *dest, struct event_filter *source,
1544 enum filter_trivial_type type)
1545{
1546 struct pevent *src_pevent;
1547 struct pevent *dest_pevent;
1548 struct event_format *event;
1549 struct filter_type *filter_type;
1550 struct filter_arg *arg;
1551 char *str;
1552 int i;
1553
1554 src_pevent = source->pevent;
1555 dest_pevent = dest->pevent;
1556
1557 /* Do nothing if either of the filters has nothing to filter */
1558 if (!dest->filters || !source->filters)
1559 return 0;
1560
1561 for (i = 0; i < dest->filters; i++) {
1562 filter_type = &dest->event_filters[i];
1563 arg = filter_type->filter;
1564 if (arg->type != FILTER_ARG_BOOLEAN)
1565 continue;
1566 if ((arg->boolean.value && type == FILTER_TRIVIAL_FALSE) ||
1567 (!arg->boolean.value && type == FILTER_TRIVIAL_TRUE))
1568 continue;
1569
1570 event = filter_type->event;
1571
1572 if (src_pevent != dest_pevent) {
1573 /* do a look up */
1574 event = pevent_find_event_by_name(src_pevent,
1575 event->system,
1576 event->name);
1577 if (!event)
1578 return -1;
1579 }
1580
1581 str = pevent_filter_make_string(source, event->id);
1582 if (!str)
1583 continue;
1584
1585 /* Don't bother if the filter is trivial too */
1586 if (strcmp(str, "TRUE") != 0 && strcmp(str, "FALSE") != 0)
1587 filter_event(dest, event, str, NULL);
1588 free(str);
1589 }
1590 return 0;
1591}
1592
1593/**
1594 * pevent_filter_clear_trivial - clear TRUE and FALSE filters
1595 * @filter: the filter to remove trivial filters from
1596 * @type: remove only true, false, or both
1597 *
1598 * Removes filters that only contain a TRUE or FALES boolean arg.
1599 *
1600 * Returns 0 on success and -1 if there was a problem.
1601 */
1602int pevent_filter_clear_trivial(struct event_filter *filter,
1603 enum filter_trivial_type type)
1604{
1605 struct filter_type *filter_type;
1606 int count = 0;
1607 int *ids = NULL;
1608 int i;
1609
1610 if (!filter->filters)
1611 return 0;
1612
1613 /*
1614 * Two steps, first get all ids with trivial filters.
1615 * then remove those ids.
1616 */
1617 for (i = 0; i < filter->filters; i++) {
1618 int *new_ids;
1619
1620 filter_type = &filter->event_filters[i];
1621 if (filter_type->filter->type != FILTER_ARG_BOOLEAN)
1622 continue;
1623 switch (type) {
1624 case FILTER_TRIVIAL_FALSE:
1625 if (filter_type->filter->boolean.value)
1626 continue;
1627 case FILTER_TRIVIAL_TRUE:
1628 if (!filter_type->filter->boolean.value)
1629 continue;
1630 default:
1631 break;
1632 }
1633
1634 new_ids = realloc(ids, sizeof(*ids) * (count + 1));
1635 if (!new_ids) {
1636 free(ids);
1637 return -1;
1638 }
1639
1640 ids = new_ids;
1641 ids[count++] = filter_type->event_id;
1642 }
1643
1644 if (!count)
1645 return 0;
1646
1647 for (i = 0; i < count; i++)
1648 pevent_filter_remove_event(filter, ids[i]);
1649
1650 free(ids);
1651 return 0;
1652}
1653
1654/**
1655 * pevent_filter_event_has_trivial - return true event contains trivial filter
1656 * @filter: the filter with the information
1657 * @event_id: the id of the event to test
1658 * @type: trivial type to test for (TRUE, FALSE, EITHER)
1659 *
1660 * Returns 1 if the event contains a matching trivial type
1661 * otherwise 0.
1662 */
1663int pevent_filter_event_has_trivial(struct event_filter *filter,
1664 int event_id,
1665 enum filter_trivial_type type)
1666{
1667 struct filter_type *filter_type;
1668
1669 if (!filter->filters)
1670 return 0;
1671
1672 filter_type = find_filter_type(filter, event_id);
1673
1674 if (!filter_type)
1675 return 0;
1676
1677 if (filter_type->filter->type != FILTER_ARG_BOOLEAN)
1678 return 0;
1679
1680 switch (type) {
1681 case FILTER_TRIVIAL_FALSE:
1682 return !filter_type->filter->boolean.value;
1683
1684 case FILTER_TRIVIAL_TRUE:
1685 return filter_type->filter->boolean.value;
1686 default:
1687 return 1;
1688 }
1689}
1690
1691static int test_filter(struct event_format *event, struct filter_arg *arg,
1692 struct pevent_record *record, enum pevent_errno *err);
1693
1694static const char *
1695get_comm(struct event_format *event, struct pevent_record *record)
1696{
1697 const char *comm;
1698 int pid;
1699
1700 pid = pevent_data_pid(event->pevent, record);
1701 comm = pevent_data_comm_from_pid(event->pevent, pid);
1702 return comm;
1703}
1704
1705static unsigned long long
1706get_value(struct event_format *event,
1707 struct format_field *field, struct pevent_record *record)
1708{
1709 unsigned long long val;
1710
1711 /* Handle our dummy "comm" field */
1712 if (field == &comm) {
1713 const char *name;
1714
1715 name = get_comm(event, record);
1716 return (unsigned long)name;
1717 }
1718
1719 pevent_read_number_field(field, record->data, &val);
1720
1721 if (!(field->flags & FIELD_IS_SIGNED))
1722 return val;
1723
1724 switch (field->size) {
1725 case 1:
1726 return (char)val;
1727 case 2:
1728 return (short)val;
1729 case 4:
1730 return (int)val;
1731 case 8:
1732 return (long long)val;
1733 }
1734 return val;
1735}
1736
1737static unsigned long long
1738get_arg_value(struct event_format *event, struct filter_arg *arg,
1739 struct pevent_record *record, enum pevent_errno *err);
1740
1741static unsigned long long
1742get_exp_value(struct event_format *event, struct filter_arg *arg,
1743 struct pevent_record *record, enum pevent_errno *err)
1744{
1745 unsigned long long lval, rval;
1746
1747 lval = get_arg_value(event, arg->exp.left, record, err);
1748 rval = get_arg_value(event, arg->exp.right, record, err);
1749
1750 if (*err) {
1751 /*
1752 * There was an error, no need to process anymore.
1753 */
1754 return 0;
1755 }
1756
1757 switch (arg->exp.type) {
1758 case FILTER_EXP_ADD:
1759 return lval + rval;
1760
1761 case FILTER_EXP_SUB:
1762 return lval - rval;
1763
1764 case FILTER_EXP_MUL:
1765 return lval * rval;
1766
1767 case FILTER_EXP_DIV:
1768 return lval / rval;
1769
1770 case FILTER_EXP_MOD:
1771 return lval % rval;
1772
1773 case FILTER_EXP_RSHIFT:
1774 return lval >> rval;
1775
1776 case FILTER_EXP_LSHIFT:
1777 return lval << rval;
1778
1779 case FILTER_EXP_AND:
1780 return lval & rval;
1781
1782 case FILTER_EXP_OR:
1783 return lval | rval;
1784
1785 case FILTER_EXP_XOR:
1786 return lval ^ rval;
1787
1788 case FILTER_EXP_NOT:
1789 default:
1790 if (!*err)
1791 *err = PEVENT_ERRNO__INVALID_EXP_TYPE;
1792 }
1793 return 0;
1794}
1795
1796static unsigned long long
1797get_arg_value(struct event_format *event, struct filter_arg *arg,
1798 struct pevent_record *record, enum pevent_errno *err)
1799{
1800 switch (arg->type) {
1801 case FILTER_ARG_FIELD:
1802 return get_value(event, arg->field.field, record);
1803
1804 case FILTER_ARG_VALUE:
1805 if (arg->value.type != FILTER_NUMBER) {
1806 if (!*err)
1807 *err = PEVENT_ERRNO__NOT_A_NUMBER;
1808 }
1809 return arg->value.val;
1810
1811 case FILTER_ARG_EXP:
1812 return get_exp_value(event, arg, record, err);
1813
1814 default:
1815 if (!*err)
1816 *err = PEVENT_ERRNO__INVALID_ARG_TYPE;
1817 }
1818 return 0;
1819}
1820
1821static int test_num(struct event_format *event, struct filter_arg *arg,
1822 struct pevent_record *record, enum pevent_errno *err)
1823{
1824 unsigned long long lval, rval;
1825
1826 lval = get_arg_value(event, arg->num.left, record, err);
1827 rval = get_arg_value(event, arg->num.right, record, err);
1828
1829 if (*err) {
1830 /*
1831 * There was an error, no need to process anymore.
1832 */
1833 return 0;
1834 }
1835
1836 switch (arg->num.type) {
1837 case FILTER_CMP_EQ:
1838 return lval == rval;
1839
1840 case FILTER_CMP_NE:
1841 return lval != rval;
1842
1843 case FILTER_CMP_GT:
1844 return lval > rval;
1845
1846 case FILTER_CMP_LT:
1847 return lval < rval;
1848
1849 case FILTER_CMP_GE:
1850 return lval >= rval;
1851
1852 case FILTER_CMP_LE:
1853 return lval <= rval;
1854
1855 default:
1856 if (!*err)
1857 *err = PEVENT_ERRNO__ILLEGAL_INTEGER_CMP;
1858 return 0;
1859 }
1860}
1861
1862static const char *get_field_str(struct filter_arg *arg, struct pevent_record *record)
1863{
1864 struct event_format *event;
1865 struct pevent *pevent;
1866 unsigned long long addr;
1867 const char *val = NULL;
1868 char hex[64];
1869
1870 /* If the field is not a string convert it */
1871 if (arg->str.field->flags & FIELD_IS_STRING) {
1872 val = record->data + arg->str.field->offset;
1873
1874 /*
1875 * We need to copy the data since we can't be sure the field
1876 * is null terminated.
1877 */
1878 if (*(val + arg->str.field->size - 1)) {
1879 /* copy it */
1880 memcpy(arg->str.buffer, val, arg->str.field->size);
1881 /* the buffer is already NULL terminated */
1882 val = arg->str.buffer;
1883 }
1884
1885 } else {
1886 event = arg->str.field->event;
1887 pevent = event->pevent;
1888 addr = get_value(event, arg->str.field, record);
1889
1890 if (arg->str.field->flags & (FIELD_IS_POINTER | FIELD_IS_LONG))
1891 /* convert to a kernel symbol */
1892 val = pevent_find_function(pevent, addr);
1893
1894 if (val == NULL) {
1895 /* just use the hex of the string name */
1896 snprintf(hex, 64, "0x%llx", addr);
1897 val = hex;
1898 }
1899 }
1900
1901 return val;
1902}
1903
1904static int test_str(struct event_format *event, struct filter_arg *arg,
1905 struct pevent_record *record, enum pevent_errno *err)
1906{
1907 const char *val;
1908
1909 if (arg->str.field == &comm)
1910 val = get_comm(event, record);
1911 else
1912 val = get_field_str(arg, record);
1913
1914 switch (arg->str.type) {
1915 case FILTER_CMP_MATCH:
1916 return strcmp(val, arg->str.val) == 0;
1917
1918 case FILTER_CMP_NOT_MATCH:
1919 return strcmp(val, arg->str.val) != 0;
1920
1921 case FILTER_CMP_REGEX:
1922 /* Returns zero on match */
1923 return !regexec(&arg->str.reg, val, 0, NULL, 0);
1924
1925 case FILTER_CMP_NOT_REGEX:
1926 return regexec(&arg->str.reg, val, 0, NULL, 0);
1927
1928 default:
1929 if (!*err)
1930 *err = PEVENT_ERRNO__ILLEGAL_STRING_CMP;
1931 return 0;
1932 }
1933}
1934
1935static int test_op(struct event_format *event, struct filter_arg *arg,
1936 struct pevent_record *record, enum pevent_errno *err)
1937{
1938 switch (arg->op.type) {
1939 case FILTER_OP_AND:
1940 return test_filter(event, arg->op.left, record, err) &&
1941 test_filter(event, arg->op.right, record, err);
1942
1943 case FILTER_OP_OR:
1944 return test_filter(event, arg->op.left, record, err) ||
1945 test_filter(event, arg->op.right, record, err);
1946
1947 case FILTER_OP_NOT:
1948 return !test_filter(event, arg->op.right, record, err);
1949
1950 default:
1951 if (!*err)
1952 *err = PEVENT_ERRNO__INVALID_OP_TYPE;
1953 return 0;
1954 }
1955}
1956
1957static int test_filter(struct event_format *event, struct filter_arg *arg,
1958 struct pevent_record *record, enum pevent_errno *err)
1959{
1960 if (*err) {
1961 /*
1962 * There was an error, no need to process anymore.
1963 */
1964 return 0;
1965 }
1966
1967 switch (arg->type) {
1968 case FILTER_ARG_BOOLEAN:
1969 /* easy case */
1970 return arg->boolean.value;
1971
1972 case FILTER_ARG_OP:
1973 return test_op(event, arg, record, err);
1974
1975 case FILTER_ARG_NUM:
1976 return test_num(event, arg, record, err);
1977
1978 case FILTER_ARG_STR:
1979 return test_str(event, arg, record, err);
1980
1981 case FILTER_ARG_EXP:
1982 case FILTER_ARG_VALUE:
1983 case FILTER_ARG_FIELD:
1984 /*
1985 * Expressions, fields and values evaluate
1986 * to true if they return non zero
1987 */
1988 return !!get_arg_value(event, arg, record, err);
1989
1990 default:
1991 if (!*err)
1992 *err = PEVENT_ERRNO__INVALID_ARG_TYPE;
1993 return 0;
1994 }
1995}
1996
1997/**
1998 * pevent_event_filtered - return true if event has filter
1999 * @filter: filter struct with filter information
2000 * @event_id: event id to test if filter exists
2001 *
2002 * Returns 1 if filter found for @event_id
2003 * otherwise 0;
2004 */
2005int pevent_event_filtered(struct event_filter *filter, int event_id)
2006{
2007 struct filter_type *filter_type;
2008
2009 if (!filter->filters)
2010 return 0;
2011
2012 filter_type = find_filter_type(filter, event_id);
2013
2014 return filter_type ? 1 : 0;
2015}
2016
2017/**
2018 * pevent_filter_match - test if a record matches a filter
2019 * @filter: filter struct with filter information
2020 * @record: the record to test against the filter
2021 *
2022 * Returns: match result or error code (prefixed with PEVENT_ERRNO__)
2023 * FILTER_MATCH - filter found for event and @record matches
2024 * FILTER_MISS - filter found for event and @record does not match
2025 * FILTER_NOT_FOUND - no filter found for @record's event
2026 * NO_FILTER - if no filters exist
2027 * otherwise - error occurred during test
2028 */
2029enum pevent_errno pevent_filter_match(struct event_filter *filter,
2030 struct pevent_record *record)
2031{
2032 struct pevent *pevent = filter->pevent;
2033 struct filter_type *filter_type;
2034 int event_id;
2035 int ret;
2036 enum pevent_errno err = 0;
2037
2038 filter_init_error_buf(filter);
2039
2040 if (!filter->filters)
2041 return PEVENT_ERRNO__NO_FILTER;
2042
2043 event_id = pevent_data_type(pevent, record);
2044
2045 filter_type = find_filter_type(filter, event_id);
2046 if (!filter_type)
2047 return PEVENT_ERRNO__FILTER_NOT_FOUND;
2048
2049 ret = test_filter(filter_type->event, filter_type->filter, record, &err);
2050 if (err)
2051 return err;
2052
2053 return ret ? PEVENT_ERRNO__FILTER_MATCH : PEVENT_ERRNO__FILTER_MISS;
2054}
2055
2056static char *op_to_str(struct event_filter *filter, struct filter_arg *arg)
2057{
2058 char *str = NULL;
2059 char *left = NULL;
2060 char *right = NULL;
2061 char *op = NULL;
2062 int left_val = -1;
2063 int right_val = -1;
2064 int val;
2065
2066 switch (arg->op.type) {
2067 case FILTER_OP_AND:
2068 op = "&&";
2069 /* fall through */
2070 case FILTER_OP_OR:
2071 if (!op)
2072 op = "||";
2073
2074 left = arg_to_str(filter, arg->op.left);
2075 right = arg_to_str(filter, arg->op.right);
2076 if (!left || !right)
2077 break;
2078
2079 /* Try to consolidate boolean values */
2080 if (strcmp(left, "TRUE") == 0)
2081 left_val = 1;
2082 else if (strcmp(left, "FALSE") == 0)
2083 left_val = 0;
2084
2085 if (strcmp(right, "TRUE") == 0)
2086 right_val = 1;
2087 else if (strcmp(right, "FALSE") == 0)
2088 right_val = 0;
2089
2090 if (left_val >= 0) {
2091 if ((arg->op.type == FILTER_OP_AND && !left_val) ||
2092 (arg->op.type == FILTER_OP_OR && left_val)) {
2093 /* Just return left value */
2094 str = left;
2095 left = NULL;
2096 break;
2097 }
2098 if (right_val >= 0) {
2099 /* just evaluate this. */
2100 val = 0;
2101 switch (arg->op.type) {
2102 case FILTER_OP_AND:
2103 val = left_val && right_val;
2104 break;
2105 case FILTER_OP_OR:
2106 val = left_val || right_val;
2107 break;
2108 default:
2109 break;
2110 }
2111 asprintf(&str, val ? "TRUE" : "FALSE");
2112 break;
2113 }
2114 }
2115 if (right_val >= 0) {
2116 if ((arg->op.type == FILTER_OP_AND && !right_val) ||
2117 (arg->op.type == FILTER_OP_OR && right_val)) {
2118 /* Just return right value */
2119 str = right;
2120 right = NULL;
2121 break;
2122 }
2123 /* The right value is meaningless */
2124 str = left;
2125 left = NULL;
2126 break;
2127 }
2128
2129 asprintf(&str, "(%s) %s (%s)", left, op, right);
2130 break;
2131
2132 case FILTER_OP_NOT:
2133 op = "!";
2134 right = arg_to_str(filter, arg->op.right);
2135 if (!right)
2136 break;
2137
2138 /* See if we can consolidate */
2139 if (strcmp(right, "TRUE") == 0)
2140 right_val = 1;
2141 else if (strcmp(right, "FALSE") == 0)
2142 right_val = 0;
2143 if (right_val >= 0) {
2144 /* just return the opposite */
2145 asprintf(&str, right_val ? "FALSE" : "TRUE");
2146 break;
2147 }
2148 asprintf(&str, "%s(%s)", op, right);
2149 break;
2150
2151 default:
2152 /* ?? */
2153 break;
2154 }
2155 free(left);
2156 free(right);
2157 return str;
2158}
2159
2160static char *val_to_str(struct event_filter *filter, struct filter_arg *arg)
2161{
2162 char *str = NULL;
2163
2164 asprintf(&str, "%lld", arg->value.val);
2165
2166 return str;
2167}
2168
2169static char *field_to_str(struct event_filter *filter, struct filter_arg *arg)
2170{
2171 return strdup(arg->field.field->name);
2172}
2173
2174static char *exp_to_str(struct event_filter *filter, struct filter_arg *arg)
2175{
2176 char *lstr;
2177 char *rstr;
2178 char *op;
2179 char *str = NULL;
2180
2181 lstr = arg_to_str(filter, arg->exp.left);
2182 rstr = arg_to_str(filter, arg->exp.right);
2183 if (!lstr || !rstr)
2184 goto out;
2185
2186 switch (arg->exp.type) {
2187 case FILTER_EXP_ADD:
2188 op = "+";
2189 break;
2190 case FILTER_EXP_SUB:
2191 op = "-";
2192 break;
2193 case FILTER_EXP_MUL:
2194 op = "*";
2195 break;
2196 case FILTER_EXP_DIV:
2197 op = "/";
2198 break;
2199 case FILTER_EXP_MOD:
2200 op = "%";
2201 break;
2202 case FILTER_EXP_RSHIFT:
2203 op = ">>";
2204 break;
2205 case FILTER_EXP_LSHIFT:
2206 op = "<<";
2207 break;
2208 case FILTER_EXP_AND:
2209 op = "&";
2210 break;
2211 case FILTER_EXP_OR:
2212 op = "|";
2213 break;
2214 case FILTER_EXP_XOR:
2215 op = "^";
2216 break;
2217 default:
2218 op = "[ERROR IN EXPRESSION TYPE]";
2219 break;
2220 }
2221
2222 asprintf(&str, "%s %s %s", lstr, op, rstr);
2223out:
2224 free(lstr);
2225 free(rstr);
2226
2227 return str;
2228}
2229
2230static char *num_to_str(struct event_filter *filter, struct filter_arg *arg)
2231{
2232 char *lstr;
2233 char *rstr;
2234 char *str = NULL;
2235 char *op = NULL;
2236
2237 lstr = arg_to_str(filter, arg->num.left);
2238 rstr = arg_to_str(filter, arg->num.right);
2239 if (!lstr || !rstr)
2240 goto out;
2241
2242 switch (arg->num.type) {
2243 case FILTER_CMP_EQ:
2244 op = "==";
2245 /* fall through */
2246 case FILTER_CMP_NE:
2247 if (!op)
2248 op = "!=";
2249 /* fall through */
2250 case FILTER_CMP_GT:
2251 if (!op)
2252 op = ">";
2253 /* fall through */
2254 case FILTER_CMP_LT:
2255 if (!op)
2256 op = "<";
2257 /* fall through */
2258 case FILTER_CMP_GE:
2259 if (!op)
2260 op = ">=";
2261 /* fall through */
2262 case FILTER_CMP_LE:
2263 if (!op)
2264 op = "<=";
2265
2266 asprintf(&str, "%s %s %s", lstr, op, rstr);
2267 break;
2268
2269 default:
2270 /* ?? */
2271 break;
2272 }
2273
2274out:
2275 free(lstr);
2276 free(rstr);
2277 return str;
2278}
2279
2280static char *str_to_str(struct event_filter *filter, struct filter_arg *arg)
2281{
2282 char *str = NULL;
2283 char *op = NULL;
2284
2285 switch (arg->str.type) {
2286 case FILTER_CMP_MATCH:
2287 op = "==";
2288 /* fall through */
2289 case FILTER_CMP_NOT_MATCH:
2290 if (!op)
2291 op = "!=";
2292 /* fall through */
2293 case FILTER_CMP_REGEX:
2294 if (!op)
2295 op = "=~";
2296 /* fall through */
2297 case FILTER_CMP_NOT_REGEX:
2298 if (!op)
2299 op = "!~";
2300
2301 asprintf(&str, "%s %s \"%s\"",
2302 arg->str.field->name, op, arg->str.val);
2303 break;
2304
2305 default:
2306 /* ?? */
2307 break;
2308 }
2309 return str;
2310}
2311
2312static char *arg_to_str(struct event_filter *filter, struct filter_arg *arg)
2313{
2314 char *str = NULL;
2315
2316 switch (arg->type) {
2317 case FILTER_ARG_BOOLEAN:
2318 asprintf(&str, arg->boolean.value ? "TRUE" : "FALSE");
2319 return str;
2320
2321 case FILTER_ARG_OP:
2322 return op_to_str(filter, arg);
2323
2324 case FILTER_ARG_NUM:
2325 return num_to_str(filter, arg);
2326
2327 case FILTER_ARG_STR:
2328 return str_to_str(filter, arg);
2329
2330 case FILTER_ARG_VALUE:
2331 return val_to_str(filter, arg);
2332
2333 case FILTER_ARG_FIELD:
2334 return field_to_str(filter, arg);
2335
2336 case FILTER_ARG_EXP:
2337 return exp_to_str(filter, arg);
2338
2339 default:
2340 /* ?? */
2341 return NULL;
2342 }
2343
2344}
2345
2346/**
2347 * pevent_filter_make_string - return a string showing the filter
2348 * @filter: filter struct with filter information
2349 * @event_id: the event id to return the filter string with
2350 *
2351 * Returns a string that displays the filter contents.
2352 * This string must be freed with free(str).
2353 * NULL is returned if no filter is found or allocation failed.
2354 */
2355char *
2356pevent_filter_make_string(struct event_filter *filter, int event_id)
2357{
2358 struct filter_type *filter_type;
2359
2360 if (!filter->filters)
2361 return NULL;
2362
2363 filter_type = find_filter_type(filter, event_id);
2364
2365 if (!filter_type)
2366 return NULL;
2367
2368 return arg_to_str(filter, filter_type->filter);
2369}
2370
2371/**
2372 * pevent_filter_compare - compare two filters and return if they are the same
2373 * @filter1: Filter to compare with @filter2
2374 * @filter2: Filter to compare with @filter1
2375 *
2376 * Returns:
2377 * 1 if the two filters hold the same content.
2378 * 0 if they do not.
2379 */
2380int pevent_filter_compare(struct event_filter *filter1, struct event_filter *filter2)
2381{
2382 struct filter_type *filter_type1;
2383 struct filter_type *filter_type2;
2384 char *str1, *str2;
2385 int result;
2386 int i;
2387
2388 /* Do the easy checks first */
2389 if (filter1->filters != filter2->filters)
2390 return 0;
2391 if (!filter1->filters && !filter2->filters)
2392 return 1;
2393
2394 /*
2395 * Now take a look at each of the events to see if they have the same
2396 * filters to them.
2397 */
2398 for (i = 0; i < filter1->filters; i++) {
2399 filter_type1 = &filter1->event_filters[i];
2400 filter_type2 = find_filter_type(filter2, filter_type1->event_id);
2401 if (!filter_type2)
2402 break;
2403 if (filter_type1->filter->type != filter_type2->filter->type)
2404 break;
2405 switch (filter_type1->filter->type) {
2406 case FILTER_TRIVIAL_FALSE:
2407 case FILTER_TRIVIAL_TRUE:
2408 /* trivial types just need the type compared */
2409 continue;
2410 default:
2411 break;
2412 }
2413 /* The best way to compare complex filters is with strings */
2414 str1 = arg_to_str(filter1, filter_type1->filter);
2415 str2 = arg_to_str(filter2, filter_type2->filter);
2416 if (str1 && str2)
2417 result = strcmp(str1, str2) != 0;
2418 else
2419 /* bail out if allocation fails */
2420 result = 1;
2421
2422 free(str1);
2423 free(str2);
2424 if (result)
2425 break;
2426 }
2427
2428 if (i < filter1->filters)
2429 return 0;
2430 return 1;
2431}
2432
1/*
2 * Copyright (C) 2010 Red Hat Inc, Steven Rostedt <srostedt@redhat.com>
3 *
4 * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
5 * This program is free software; you can redistribute it and/or
6 * modify it under the terms of the GNU Lesser General Public
7 * License as published by the Free Software Foundation;
8 * version 2.1 of the License (not later!)
9 *
10 * This program is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 * GNU Lesser General Public License for more details.
14 *
15 * You should have received a copy of the GNU Lesser General Public
16 * License along with this program; if not, write to the Free Software
17 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
18 *
19 * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
20 */
21#include <stdio.h>
22#include <stdlib.h>
23#include <string.h>
24#include <stdarg.h>
25#include <errno.h>
26#include <sys/types.h>
27
28#include "event-parse.h"
29#include "event-utils.h"
30
31#define COMM "COMM"
32
33static struct format_field comm = {
34 .name = "COMM",
35};
36
37struct event_list {
38 struct event_list *next;
39 struct event_format *event;
40};
41
42#define MAX_ERR_STR_SIZE 256
43
44static void show_error(char **error_str, const char *fmt, ...)
45{
46 unsigned long long index;
47 const char *input;
48 char *error;
49 va_list ap;
50 int len;
51 int i;
52
53 if (!error_str)
54 return;
55
56 input = pevent_get_input_buf();
57 index = pevent_get_input_buf_ptr();
58 len = input ? strlen(input) : 0;
59
60 error = malloc_or_die(MAX_ERR_STR_SIZE + (len*2) + 3);
61
62 if (len) {
63 strcpy(error, input);
64 error[len] = '\n';
65 for (i = 1; i < len && i < index; i++)
66 error[len+i] = ' ';
67 error[len + i] = '^';
68 error[len + i + 1] = '\n';
69 len += i+2;
70 }
71
72 va_start(ap, fmt);
73 vsnprintf(error + len, MAX_ERR_STR_SIZE, fmt, ap);
74 va_end(ap);
75
76 *error_str = error;
77}
78
79static void free_token(char *token)
80{
81 pevent_free_token(token);
82}
83
84static enum event_type read_token(char **tok)
85{
86 enum event_type type;
87 char *token = NULL;
88
89 do {
90 free_token(token);
91 type = pevent_read_token(&token);
92 } while (type == EVENT_NEWLINE || type == EVENT_SPACE);
93
94 /* If token is = or ! check to see if the next char is ~ */
95 if (token &&
96 (strcmp(token, "=") == 0 || strcmp(token, "!") == 0) &&
97 pevent_peek_char() == '~') {
98 /* append it */
99 *tok = malloc(3);
100 sprintf(*tok, "%c%c", *token, '~');
101 free_token(token);
102 /* Now remove the '~' from the buffer */
103 pevent_read_token(&token);
104 free_token(token);
105 } else
106 *tok = token;
107
108 return type;
109}
110
111static int filter_cmp(const void *a, const void *b)
112{
113 const struct filter_type *ea = a;
114 const struct filter_type *eb = b;
115
116 if (ea->event_id < eb->event_id)
117 return -1;
118
119 if (ea->event_id > eb->event_id)
120 return 1;
121
122 return 0;
123}
124
125static struct filter_type *
126find_filter_type(struct event_filter *filter, int id)
127{
128 struct filter_type *filter_type;
129 struct filter_type key;
130
131 key.event_id = id;
132
133 filter_type = bsearch(&key, filter->event_filters,
134 filter->filters,
135 sizeof(*filter->event_filters),
136 filter_cmp);
137
138 return filter_type;
139}
140
141static struct filter_type *
142add_filter_type(struct event_filter *filter, int id)
143{
144 struct filter_type *filter_type;
145 int i;
146
147 filter_type = find_filter_type(filter, id);
148 if (filter_type)
149 return filter_type;
150
151 if (!filter->filters)
152 filter->event_filters =
153 malloc_or_die(sizeof(*filter->event_filters));
154 else {
155 filter->event_filters =
156 realloc(filter->event_filters,
157 sizeof(*filter->event_filters) *
158 (filter->filters + 1));
159 if (!filter->event_filters)
160 die("Could not allocate filter");
161 }
162
163 for (i = 0; i < filter->filters; i++) {
164 if (filter->event_filters[i].event_id > id)
165 break;
166 }
167
168 if (i < filter->filters)
169 memmove(&filter->event_filters[i+1],
170 &filter->event_filters[i],
171 sizeof(*filter->event_filters) *
172 (filter->filters - i));
173
174 filter_type = &filter->event_filters[i];
175 filter_type->event_id = id;
176 filter_type->event = pevent_find_event(filter->pevent, id);
177 filter_type->filter = NULL;
178
179 filter->filters++;
180
181 return filter_type;
182}
183
184/**
185 * pevent_filter_alloc - create a new event filter
186 * @pevent: The pevent that this filter is associated with
187 */
188struct event_filter *pevent_filter_alloc(struct pevent *pevent)
189{
190 struct event_filter *filter;
191
192 filter = malloc_or_die(sizeof(*filter));
193 memset(filter, 0, sizeof(*filter));
194 filter->pevent = pevent;
195 pevent_ref(pevent);
196
197 return filter;
198}
199
200static struct filter_arg *allocate_arg(void)
201{
202 struct filter_arg *arg;
203
204 arg = malloc_or_die(sizeof(*arg));
205 memset(arg, 0, sizeof(*arg));
206
207 return arg;
208}
209
210static void free_arg(struct filter_arg *arg)
211{
212 if (!arg)
213 return;
214
215 switch (arg->type) {
216 case FILTER_ARG_NONE:
217 case FILTER_ARG_BOOLEAN:
218 case FILTER_ARG_NUM:
219 break;
220
221 case FILTER_ARG_STR:
222 free(arg->str.val);
223 regfree(&arg->str.reg);
224 free(arg->str.buffer);
225 break;
226
227 case FILTER_ARG_OP:
228 free_arg(arg->op.left);
229 free_arg(arg->op.right);
230 default:
231 break;
232 }
233
234 free(arg);
235}
236
237static void add_event(struct event_list **events,
238 struct event_format *event)
239{
240 struct event_list *list;
241
242 list = malloc_or_die(sizeof(*list));
243 list->next = *events;
244 *events = list;
245 list->event = event;
246}
247
248static int event_match(struct event_format *event,
249 regex_t *sreg, regex_t *ereg)
250{
251 if (sreg) {
252 return !regexec(sreg, event->system, 0, NULL, 0) &&
253 !regexec(ereg, event->name, 0, NULL, 0);
254 }
255
256 return !regexec(ereg, event->system, 0, NULL, 0) ||
257 !regexec(ereg, event->name, 0, NULL, 0);
258}
259
260static int
261find_event(struct pevent *pevent, struct event_list **events,
262 char *sys_name, char *event_name)
263{
264 struct event_format *event;
265 regex_t ereg;
266 regex_t sreg;
267 int match = 0;
268 char *reg;
269 int ret;
270 int i;
271
272 if (!event_name) {
273 /* if no name is given, then swap sys and name */
274 event_name = sys_name;
275 sys_name = NULL;
276 }
277
278 reg = malloc_or_die(strlen(event_name) + 3);
279 sprintf(reg, "^%s$", event_name);
280
281 ret = regcomp(&ereg, reg, REG_ICASE|REG_NOSUB);
282 free(reg);
283
284 if (ret)
285 return -1;
286
287 if (sys_name) {
288 reg = malloc_or_die(strlen(sys_name) + 3);
289 sprintf(reg, "^%s$", sys_name);
290 ret = regcomp(&sreg, reg, REG_ICASE|REG_NOSUB);
291 free(reg);
292 if (ret) {
293 regfree(&ereg);
294 return -1;
295 }
296 }
297
298 for (i = 0; i < pevent->nr_events; i++) {
299 event = pevent->events[i];
300 if (event_match(event, sys_name ? &sreg : NULL, &ereg)) {
301 match = 1;
302 add_event(events, event);
303 }
304 }
305
306 regfree(&ereg);
307 if (sys_name)
308 regfree(&sreg);
309
310 if (!match)
311 return -1;
312
313 return 0;
314}
315
316static void free_events(struct event_list *events)
317{
318 struct event_list *event;
319
320 while (events) {
321 event = events;
322 events = events->next;
323 free(event);
324 }
325}
326
327static struct filter_arg *
328create_arg_item(struct event_format *event, const char *token,
329 enum event_type type, char **error_str)
330{
331 struct format_field *field;
332 struct filter_arg *arg;
333
334 arg = allocate_arg();
335
336 switch (type) {
337
338 case EVENT_SQUOTE:
339 case EVENT_DQUOTE:
340 arg->type = FILTER_ARG_VALUE;
341 arg->value.type =
342 type == EVENT_DQUOTE ? FILTER_STRING : FILTER_CHAR;
343 arg->value.str = strdup(token);
344 if (!arg->value.str)
345 die("malloc string");
346 break;
347 case EVENT_ITEM:
348 /* if it is a number, then convert it */
349 if (isdigit(token[0])) {
350 arg->type = FILTER_ARG_VALUE;
351 arg->value.type = FILTER_NUMBER;
352 arg->value.val = strtoull(token, NULL, 0);
353 break;
354 }
355 /* Consider this a field */
356 field = pevent_find_any_field(event, token);
357 if (!field) {
358 if (strcmp(token, COMM) != 0) {
359 /* not a field, Make it false */
360 arg->type = FILTER_ARG_BOOLEAN;
361 arg->boolean.value = FILTER_FALSE;
362 break;
363 }
364 /* If token is 'COMM' then it is special */
365 field = &comm;
366 }
367 arg->type = FILTER_ARG_FIELD;
368 arg->field.field = field;
369 break;
370 default:
371 free_arg(arg);
372 show_error(error_str, "expected a value but found %s",
373 token);
374 return NULL;
375 }
376 return arg;
377}
378
379static struct filter_arg *
380create_arg_op(enum filter_op_type btype)
381{
382 struct filter_arg *arg;
383
384 arg = allocate_arg();
385 arg->type = FILTER_ARG_OP;
386 arg->op.type = btype;
387
388 return arg;
389}
390
391static struct filter_arg *
392create_arg_exp(enum filter_exp_type etype)
393{
394 struct filter_arg *arg;
395
396 arg = allocate_arg();
397 arg->type = FILTER_ARG_EXP;
398 arg->op.type = etype;
399
400 return arg;
401}
402
403static struct filter_arg *
404create_arg_cmp(enum filter_exp_type etype)
405{
406 struct filter_arg *arg;
407
408 arg = allocate_arg();
409 /* Use NUM and change if necessary */
410 arg->type = FILTER_ARG_NUM;
411 arg->op.type = etype;
412
413 return arg;
414}
415
416static int add_right(struct filter_arg *op, struct filter_arg *arg,
417 char **error_str)
418{
419 struct filter_arg *left;
420 char *str;
421 int op_type;
422 int ret;
423
424 switch (op->type) {
425 case FILTER_ARG_EXP:
426 if (op->exp.right)
427 goto out_fail;
428 op->exp.right = arg;
429 break;
430
431 case FILTER_ARG_OP:
432 if (op->op.right)
433 goto out_fail;
434 op->op.right = arg;
435 break;
436
437 case FILTER_ARG_NUM:
438 if (op->op.right)
439 goto out_fail;
440 /*
441 * The arg must be num, str, or field
442 */
443 switch (arg->type) {
444 case FILTER_ARG_VALUE:
445 case FILTER_ARG_FIELD:
446 break;
447 default:
448 show_error(error_str,
449 "Illegal rvalue");
450 return -1;
451 }
452
453 /*
454 * Depending on the type, we may need to
455 * convert this to a string or regex.
456 */
457 switch (arg->value.type) {
458 case FILTER_CHAR:
459 /*
460 * A char should be converted to number if
461 * the string is 1 byte, and the compare
462 * is not a REGEX.
463 */
464 if (strlen(arg->value.str) == 1 &&
465 op->num.type != FILTER_CMP_REGEX &&
466 op->num.type != FILTER_CMP_NOT_REGEX) {
467 arg->value.type = FILTER_NUMBER;
468 goto do_int;
469 }
470 /* fall through */
471 case FILTER_STRING:
472
473 /* convert op to a string arg */
474 op_type = op->num.type;
475 left = op->num.left;
476 str = arg->value.str;
477
478 /* reset the op for the new field */
479 memset(op, 0, sizeof(*op));
480
481 /*
482 * If left arg was a field not found then
483 * NULL the entire op.
484 */
485 if (left->type == FILTER_ARG_BOOLEAN) {
486 free_arg(left);
487 free_arg(arg);
488 op->type = FILTER_ARG_BOOLEAN;
489 op->boolean.value = FILTER_FALSE;
490 break;
491 }
492
493 /* Left arg must be a field */
494 if (left->type != FILTER_ARG_FIELD) {
495 show_error(error_str,
496 "Illegal lvalue for string comparison");
497 return -1;
498 }
499
500 /* Make sure this is a valid string compare */
501 switch (op_type) {
502 case FILTER_CMP_EQ:
503 op_type = FILTER_CMP_MATCH;
504 break;
505 case FILTER_CMP_NE:
506 op_type = FILTER_CMP_NOT_MATCH;
507 break;
508
509 case FILTER_CMP_REGEX:
510 case FILTER_CMP_NOT_REGEX:
511 ret = regcomp(&op->str.reg, str, REG_ICASE|REG_NOSUB);
512 if (ret) {
513 show_error(error_str,
514 "RegEx '%s' did not compute",
515 str);
516 return -1;
517 }
518 break;
519 default:
520 show_error(error_str,
521 "Illegal comparison for string");
522 return -1;
523 }
524
525 op->type = FILTER_ARG_STR;
526 op->str.type = op_type;
527 op->str.field = left->field.field;
528 op->str.val = strdup(str);
529 if (!op->str.val)
530 die("malloc string");
531 /*
532 * Need a buffer to copy data for tests
533 */
534 op->str.buffer = malloc_or_die(op->str.field->size + 1);
535 /* Null terminate this buffer */
536 op->str.buffer[op->str.field->size] = 0;
537
538 /* We no longer have left or right args */
539 free_arg(arg);
540 free_arg(left);
541
542 break;
543
544 case FILTER_NUMBER:
545
546 do_int:
547 switch (op->num.type) {
548 case FILTER_CMP_REGEX:
549 case FILTER_CMP_NOT_REGEX:
550 show_error(error_str,
551 "Op not allowed with integers");
552 return -1;
553
554 default:
555 break;
556 }
557
558 /* numeric compare */
559 op->num.right = arg;
560 break;
561 default:
562 goto out_fail;
563 }
564 break;
565 default:
566 goto out_fail;
567 }
568
569 return 0;
570
571 out_fail:
572 show_error(error_str,
573 "Syntax error");
574 return -1;
575}
576
577static struct filter_arg *
578rotate_op_right(struct filter_arg *a, struct filter_arg *b)
579{
580 struct filter_arg *arg;
581
582 arg = a->op.right;
583 a->op.right = b;
584 return arg;
585}
586
587static int add_left(struct filter_arg *op, struct filter_arg *arg)
588{
589 switch (op->type) {
590 case FILTER_ARG_EXP:
591 if (arg->type == FILTER_ARG_OP)
592 arg = rotate_op_right(arg, op);
593 op->exp.left = arg;
594 break;
595
596 case FILTER_ARG_OP:
597 op->op.left = arg;
598 break;
599 case FILTER_ARG_NUM:
600 if (arg->type == FILTER_ARG_OP)
601 arg = rotate_op_right(arg, op);
602
603 /* left arg of compares must be a field */
604 if (arg->type != FILTER_ARG_FIELD &&
605 arg->type != FILTER_ARG_BOOLEAN)
606 return -1;
607 op->num.left = arg;
608 break;
609 default:
610 return -1;
611 }
612 return 0;
613}
614
615enum op_type {
616 OP_NONE,
617 OP_BOOL,
618 OP_NOT,
619 OP_EXP,
620 OP_CMP,
621};
622
623static enum op_type process_op(const char *token,
624 enum filter_op_type *btype,
625 enum filter_cmp_type *ctype,
626 enum filter_exp_type *etype)
627{
628 *btype = FILTER_OP_NOT;
629 *etype = FILTER_EXP_NONE;
630 *ctype = FILTER_CMP_NONE;
631
632 if (strcmp(token, "&&") == 0)
633 *btype = FILTER_OP_AND;
634 else if (strcmp(token, "||") == 0)
635 *btype = FILTER_OP_OR;
636 else if (strcmp(token, "!") == 0)
637 return OP_NOT;
638
639 if (*btype != FILTER_OP_NOT)
640 return OP_BOOL;
641
642 /* Check for value expressions */
643 if (strcmp(token, "+") == 0) {
644 *etype = FILTER_EXP_ADD;
645 } else if (strcmp(token, "-") == 0) {
646 *etype = FILTER_EXP_SUB;
647 } else if (strcmp(token, "*") == 0) {
648 *etype = FILTER_EXP_MUL;
649 } else if (strcmp(token, "/") == 0) {
650 *etype = FILTER_EXP_DIV;
651 } else if (strcmp(token, "%") == 0) {
652 *etype = FILTER_EXP_MOD;
653 } else if (strcmp(token, ">>") == 0) {
654 *etype = FILTER_EXP_RSHIFT;
655 } else if (strcmp(token, "<<") == 0) {
656 *etype = FILTER_EXP_LSHIFT;
657 } else if (strcmp(token, "&") == 0) {
658 *etype = FILTER_EXP_AND;
659 } else if (strcmp(token, "|") == 0) {
660 *etype = FILTER_EXP_OR;
661 } else if (strcmp(token, "^") == 0) {
662 *etype = FILTER_EXP_XOR;
663 } else if (strcmp(token, "~") == 0)
664 *etype = FILTER_EXP_NOT;
665
666 if (*etype != FILTER_EXP_NONE)
667 return OP_EXP;
668
669 /* Check for compares */
670 if (strcmp(token, "==") == 0)
671 *ctype = FILTER_CMP_EQ;
672 else if (strcmp(token, "!=") == 0)
673 *ctype = FILTER_CMP_NE;
674 else if (strcmp(token, "<") == 0)
675 *ctype = FILTER_CMP_LT;
676 else if (strcmp(token, ">") == 0)
677 *ctype = FILTER_CMP_GT;
678 else if (strcmp(token, "<=") == 0)
679 *ctype = FILTER_CMP_LE;
680 else if (strcmp(token, ">=") == 0)
681 *ctype = FILTER_CMP_GE;
682 else if (strcmp(token, "=~") == 0)
683 *ctype = FILTER_CMP_REGEX;
684 else if (strcmp(token, "!~") == 0)
685 *ctype = FILTER_CMP_NOT_REGEX;
686 else
687 return OP_NONE;
688
689 return OP_CMP;
690}
691
692static int check_op_done(struct filter_arg *arg)
693{
694 switch (arg->type) {
695 case FILTER_ARG_EXP:
696 return arg->exp.right != NULL;
697
698 case FILTER_ARG_OP:
699 return arg->op.right != NULL;
700
701 case FILTER_ARG_NUM:
702 return arg->num.right != NULL;
703
704 case FILTER_ARG_STR:
705 /* A string conversion is always done */
706 return 1;
707
708 case FILTER_ARG_BOOLEAN:
709 /* field not found, is ok */
710 return 1;
711
712 default:
713 return 0;
714 }
715}
716
717enum filter_vals {
718 FILTER_VAL_NORM,
719 FILTER_VAL_FALSE,
720 FILTER_VAL_TRUE,
721};
722
723void reparent_op_arg(struct filter_arg *parent, struct filter_arg *old_child,
724 struct filter_arg *arg)
725{
726 struct filter_arg *other_child;
727 struct filter_arg **ptr;
728
729 if (parent->type != FILTER_ARG_OP &&
730 arg->type != FILTER_ARG_OP)
731 die("can not reparent other than OP");
732
733 /* Get the sibling */
734 if (old_child->op.right == arg) {
735 ptr = &old_child->op.right;
736 other_child = old_child->op.left;
737 } else if (old_child->op.left == arg) {
738 ptr = &old_child->op.left;
739 other_child = old_child->op.right;
740 } else
741 die("Error in reparent op, find other child");
742
743 /* Detach arg from old_child */
744 *ptr = NULL;
745
746 /* Check for root */
747 if (parent == old_child) {
748 free_arg(other_child);
749 *parent = *arg;
750 /* Free arg without recussion */
751 free(arg);
752 return;
753 }
754
755 if (parent->op.right == old_child)
756 ptr = &parent->op.right;
757 else if (parent->op.left == old_child)
758 ptr = &parent->op.left;
759 else
760 die("Error in reparent op");
761 *ptr = arg;
762
763 free_arg(old_child);
764}
765
766enum filter_vals test_arg(struct filter_arg *parent, struct filter_arg *arg)
767{
768 enum filter_vals lval, rval;
769
770 switch (arg->type) {
771
772 /* bad case */
773 case FILTER_ARG_BOOLEAN:
774 return FILTER_VAL_FALSE + arg->boolean.value;
775
776 /* good cases: */
777 case FILTER_ARG_STR:
778 case FILTER_ARG_VALUE:
779 case FILTER_ARG_FIELD:
780 return FILTER_VAL_NORM;
781
782 case FILTER_ARG_EXP:
783 lval = test_arg(arg, arg->exp.left);
784 if (lval != FILTER_VAL_NORM)
785 return lval;
786 rval = test_arg(arg, arg->exp.right);
787 if (rval != FILTER_VAL_NORM)
788 return rval;
789 return FILTER_VAL_NORM;
790
791 case FILTER_ARG_NUM:
792 lval = test_arg(arg, arg->num.left);
793 if (lval != FILTER_VAL_NORM)
794 return lval;
795 rval = test_arg(arg, arg->num.right);
796 if (rval != FILTER_VAL_NORM)
797 return rval;
798 return FILTER_VAL_NORM;
799
800 case FILTER_ARG_OP:
801 if (arg->op.type != FILTER_OP_NOT) {
802 lval = test_arg(arg, arg->op.left);
803 switch (lval) {
804 case FILTER_VAL_NORM:
805 break;
806 case FILTER_VAL_TRUE:
807 if (arg->op.type == FILTER_OP_OR)
808 return FILTER_VAL_TRUE;
809 rval = test_arg(arg, arg->op.right);
810 if (rval != FILTER_VAL_NORM)
811 return rval;
812
813 reparent_op_arg(parent, arg, arg->op.right);
814 return FILTER_VAL_NORM;
815
816 case FILTER_VAL_FALSE:
817 if (arg->op.type == FILTER_OP_AND)
818 return FILTER_VAL_FALSE;
819 rval = test_arg(arg, arg->op.right);
820 if (rval != FILTER_VAL_NORM)
821 return rval;
822
823 reparent_op_arg(parent, arg, arg->op.right);
824 return FILTER_VAL_NORM;
825 }
826 }
827
828 rval = test_arg(arg, arg->op.right);
829 switch (rval) {
830 case FILTER_VAL_NORM:
831 break;
832 case FILTER_VAL_TRUE:
833 if (arg->op.type == FILTER_OP_OR)
834 return FILTER_VAL_TRUE;
835 if (arg->op.type == FILTER_OP_NOT)
836 return FILTER_VAL_FALSE;
837
838 reparent_op_arg(parent, arg, arg->op.left);
839 return FILTER_VAL_NORM;
840
841 case FILTER_VAL_FALSE:
842 if (arg->op.type == FILTER_OP_AND)
843 return FILTER_VAL_FALSE;
844 if (arg->op.type == FILTER_OP_NOT)
845 return FILTER_VAL_TRUE;
846
847 reparent_op_arg(parent, arg, arg->op.left);
848 return FILTER_VAL_NORM;
849 }
850
851 return FILTER_VAL_NORM;
852 default:
853 die("bad arg in filter tree");
854 }
855 return FILTER_VAL_NORM;
856}
857
858/* Remove any unknown event fields */
859static struct filter_arg *collapse_tree(struct filter_arg *arg)
860{
861 enum filter_vals ret;
862
863 ret = test_arg(arg, arg);
864 switch (ret) {
865 case FILTER_VAL_NORM:
866 return arg;
867
868 case FILTER_VAL_TRUE:
869 case FILTER_VAL_FALSE:
870 free_arg(arg);
871 arg = allocate_arg();
872 arg->type = FILTER_ARG_BOOLEAN;
873 arg->boolean.value = ret == FILTER_VAL_TRUE;
874 }
875
876 return arg;
877}
878
879static int
880process_filter(struct event_format *event, struct filter_arg **parg,
881 char **error_str, int not)
882{
883 enum event_type type;
884 char *token = NULL;
885 struct filter_arg *current_op = NULL;
886 struct filter_arg *current_exp = NULL;
887 struct filter_arg *left_item = NULL;
888 struct filter_arg *arg = NULL;
889 enum op_type op_type;
890 enum filter_op_type btype;
891 enum filter_exp_type etype;
892 enum filter_cmp_type ctype;
893 int ret;
894
895 *parg = NULL;
896
897 do {
898 free(token);
899 type = read_token(&token);
900 switch (type) {
901 case EVENT_SQUOTE:
902 case EVENT_DQUOTE:
903 case EVENT_ITEM:
904 arg = create_arg_item(event, token, type, error_str);
905 if (!arg)
906 goto fail;
907 if (!left_item)
908 left_item = arg;
909 else if (current_exp) {
910 ret = add_right(current_exp, arg, error_str);
911 if (ret < 0)
912 goto fail;
913 left_item = NULL;
914 /* Not's only one one expression */
915 if (not) {
916 arg = NULL;
917 if (current_op)
918 goto fail_print;
919 free(token);
920 *parg = current_exp;
921 return 0;
922 }
923 } else
924 goto fail_print;
925 arg = NULL;
926 break;
927
928 case EVENT_DELIM:
929 if (*token == ',') {
930 show_error(error_str,
931 "Illegal token ','");
932 goto fail;
933 }
934
935 if (*token == '(') {
936 if (left_item) {
937 show_error(error_str,
938 "Open paren can not come after item");
939 goto fail;
940 }
941 if (current_exp) {
942 show_error(error_str,
943 "Open paren can not come after expression");
944 goto fail;
945 }
946
947 ret = process_filter(event, &arg, error_str, 0);
948 if (ret != 1) {
949 if (ret == 0)
950 show_error(error_str,
951 "Unbalanced number of '('");
952 goto fail;
953 }
954 ret = 0;
955
956 /* A not wants just one expression */
957 if (not) {
958 if (current_op)
959 goto fail_print;
960 *parg = arg;
961 return 0;
962 }
963
964 if (current_op)
965 ret = add_right(current_op, arg, error_str);
966 else
967 current_exp = arg;
968
969 if (ret < 0)
970 goto fail;
971
972 } else { /* ')' */
973 if (!current_op && !current_exp)
974 goto fail_print;
975
976 /* Make sure everything is finished at this level */
977 if (current_exp && !check_op_done(current_exp))
978 goto fail_print;
979 if (current_op && !check_op_done(current_op))
980 goto fail_print;
981
982 if (current_op)
983 *parg = current_op;
984 else
985 *parg = current_exp;
986 return 1;
987 }
988 break;
989
990 case EVENT_OP:
991 op_type = process_op(token, &btype, &ctype, &etype);
992
993 /* All expect a left arg except for NOT */
994 switch (op_type) {
995 case OP_BOOL:
996 /* Logic ops need a left expression */
997 if (!current_exp && !current_op)
998 goto fail_print;
999 /* fall through */
1000 case OP_NOT:
1001 /* logic only processes ops and exp */
1002 if (left_item)
1003 goto fail_print;
1004 break;
1005 case OP_EXP:
1006 case OP_CMP:
1007 if (!left_item)
1008 goto fail_print;
1009 break;
1010 case OP_NONE:
1011 show_error(error_str,
1012 "Unknown op token %s", token);
1013 goto fail;
1014 }
1015
1016 ret = 0;
1017 switch (op_type) {
1018 case OP_BOOL:
1019 arg = create_arg_op(btype);
1020 if (current_op)
1021 ret = add_left(arg, current_op);
1022 else
1023 ret = add_left(arg, current_exp);
1024 current_op = arg;
1025 current_exp = NULL;
1026 break;
1027
1028 case OP_NOT:
1029 arg = create_arg_op(btype);
1030 if (current_op)
1031 ret = add_right(current_op, arg, error_str);
1032 if (ret < 0)
1033 goto fail;
1034 current_exp = arg;
1035 ret = process_filter(event, &arg, error_str, 1);
1036 if (ret < 0)
1037 goto fail;
1038 ret = add_right(current_exp, arg, error_str);
1039 if (ret < 0)
1040 goto fail;
1041 break;
1042
1043 case OP_EXP:
1044 case OP_CMP:
1045 if (op_type == OP_EXP)
1046 arg = create_arg_exp(etype);
1047 else
1048 arg = create_arg_cmp(ctype);
1049
1050 if (current_op)
1051 ret = add_right(current_op, arg, error_str);
1052 if (ret < 0)
1053 goto fail;
1054 ret = add_left(arg, left_item);
1055 if (ret < 0) {
1056 arg = NULL;
1057 goto fail_print;
1058 }
1059 current_exp = arg;
1060 break;
1061 default:
1062 break;
1063 }
1064 arg = NULL;
1065 if (ret < 0)
1066 goto fail_print;
1067 break;
1068 case EVENT_NONE:
1069 break;
1070 default:
1071 goto fail_print;
1072 }
1073 } while (type != EVENT_NONE);
1074
1075 if (!current_op && !current_exp)
1076 goto fail_print;
1077
1078 if (!current_op)
1079 current_op = current_exp;
1080
1081 current_op = collapse_tree(current_op);
1082
1083 *parg = current_op;
1084
1085 return 0;
1086
1087 fail_print:
1088 show_error(error_str, "Syntax error");
1089 fail:
1090 free_arg(current_op);
1091 free_arg(current_exp);
1092 free_arg(arg);
1093 free(token);
1094 return -1;
1095}
1096
1097static int
1098process_event(struct event_format *event, const char *filter_str,
1099 struct filter_arg **parg, char **error_str)
1100{
1101 int ret;
1102
1103 pevent_buffer_init(filter_str, strlen(filter_str));
1104
1105 ret = process_filter(event, parg, error_str, 0);
1106 if (ret == 1) {
1107 show_error(error_str,
1108 "Unbalanced number of ')'");
1109 return -1;
1110 }
1111 if (ret < 0)
1112 return ret;
1113
1114 /* If parg is NULL, then make it into FALSE */
1115 if (!*parg) {
1116 *parg = allocate_arg();
1117 (*parg)->type = FILTER_ARG_BOOLEAN;
1118 (*parg)->boolean.value = FILTER_FALSE;
1119 }
1120
1121 return 0;
1122}
1123
1124static int filter_event(struct event_filter *filter,
1125 struct event_format *event,
1126 const char *filter_str, char **error_str)
1127{
1128 struct filter_type *filter_type;
1129 struct filter_arg *arg;
1130 int ret;
1131
1132 if (filter_str) {
1133 ret = process_event(event, filter_str, &arg, error_str);
1134 if (ret < 0)
1135 return ret;
1136
1137 } else {
1138 /* just add a TRUE arg */
1139 arg = allocate_arg();
1140 arg->type = FILTER_ARG_BOOLEAN;
1141 arg->boolean.value = FILTER_TRUE;
1142 }
1143
1144 filter_type = add_filter_type(filter, event->id);
1145 if (filter_type->filter)
1146 free_arg(filter_type->filter);
1147 filter_type->filter = arg;
1148
1149 return 0;
1150}
1151
1152/**
1153 * pevent_filter_add_filter_str - add a new filter
1154 * @filter: the event filter to add to
1155 * @filter_str: the filter string that contains the filter
1156 * @error_str: string containing reason for failed filter
1157 *
1158 * Returns 0 if the filter was successfully added
1159 * -1 if there was an error.
1160 *
1161 * On error, if @error_str points to a string pointer,
1162 * it is set to the reason that the filter failed.
1163 * This string must be freed with "free".
1164 */
1165int pevent_filter_add_filter_str(struct event_filter *filter,
1166 const char *filter_str,
1167 char **error_str)
1168{
1169 struct pevent *pevent = filter->pevent;
1170 struct event_list *event;
1171 struct event_list *events = NULL;
1172 const char *filter_start;
1173 const char *next_event;
1174 char *this_event;
1175 char *event_name = NULL;
1176 char *sys_name = NULL;
1177 char *sp;
1178 int rtn = 0;
1179 int len;
1180 int ret;
1181
1182 /* clear buffer to reset show error */
1183 pevent_buffer_init("", 0);
1184
1185 if (error_str)
1186 *error_str = NULL;
1187
1188 filter_start = strchr(filter_str, ':');
1189 if (filter_start)
1190 len = filter_start - filter_str;
1191 else
1192 len = strlen(filter_str);
1193
1194
1195 do {
1196 next_event = strchr(filter_str, ',');
1197 if (next_event &&
1198 (!filter_start || next_event < filter_start))
1199 len = next_event - filter_str;
1200 else if (filter_start)
1201 len = filter_start - filter_str;
1202 else
1203 len = strlen(filter_str);
1204
1205 this_event = malloc_or_die(len + 1);
1206 memcpy(this_event, filter_str, len);
1207 this_event[len] = 0;
1208
1209 if (next_event)
1210 next_event++;
1211
1212 filter_str = next_event;
1213
1214 sys_name = strtok_r(this_event, "/", &sp);
1215 event_name = strtok_r(NULL, "/", &sp);
1216
1217 if (!sys_name) {
1218 show_error(error_str, "No filter found");
1219 /* This can only happen when events is NULL, but still */
1220 free_events(events);
1221 free(this_event);
1222 return -1;
1223 }
1224
1225 /* Find this event */
1226 ret = find_event(pevent, &events, strim(sys_name), strim(event_name));
1227 if (ret < 0) {
1228 if (event_name)
1229 show_error(error_str,
1230 "No event found under '%s.%s'",
1231 sys_name, event_name);
1232 else
1233 show_error(error_str,
1234 "No event found under '%s'",
1235 sys_name);
1236 free_events(events);
1237 free(this_event);
1238 return -1;
1239 }
1240 free(this_event);
1241 } while (filter_str);
1242
1243 /* Skip the ':' */
1244 if (filter_start)
1245 filter_start++;
1246
1247 /* filter starts here */
1248 for (event = events; event; event = event->next) {
1249 ret = filter_event(filter, event->event, filter_start,
1250 error_str);
1251 /* Failures are returned if a parse error happened */
1252 if (ret < 0)
1253 rtn = ret;
1254
1255 if (ret >= 0 && pevent->test_filters) {
1256 char *test;
1257 test = pevent_filter_make_string(filter, event->event->id);
1258 printf(" '%s: %s'\n", event->event->name, test);
1259 free(test);
1260 }
1261 }
1262
1263 free_events(events);
1264
1265 if (rtn >= 0 && pevent->test_filters)
1266 exit(0);
1267
1268 return rtn;
1269}
1270
1271static void free_filter_type(struct filter_type *filter_type)
1272{
1273 free_arg(filter_type->filter);
1274}
1275
1276/**
1277 * pevent_filter_remove_event - remove a filter for an event
1278 * @filter: the event filter to remove from
1279 * @event_id: the event to remove a filter for
1280 *
1281 * Removes the filter saved for an event defined by @event_id
1282 * from the @filter.
1283 *
1284 * Returns 1: if an event was removed
1285 * 0: if the event was not found
1286 */
1287int pevent_filter_remove_event(struct event_filter *filter,
1288 int event_id)
1289{
1290 struct filter_type *filter_type;
1291 unsigned long len;
1292
1293 if (!filter->filters)
1294 return 0;
1295
1296 filter_type = find_filter_type(filter, event_id);
1297
1298 if (!filter_type)
1299 return 0;
1300
1301 free_filter_type(filter_type);
1302
1303 /* The filter_type points into the event_filters array */
1304 len = (unsigned long)(filter->event_filters + filter->filters) -
1305 (unsigned long)(filter_type + 1);
1306
1307 memmove(filter_type, filter_type + 1, len);
1308 filter->filters--;
1309
1310 memset(&filter->event_filters[filter->filters], 0,
1311 sizeof(*filter_type));
1312
1313 return 1;
1314}
1315
1316/**
1317 * pevent_filter_reset - clear all filters in a filter
1318 * @filter: the event filter to reset
1319 *
1320 * Removes all filters from a filter and resets it.
1321 */
1322void pevent_filter_reset(struct event_filter *filter)
1323{
1324 int i;
1325
1326 for (i = 0; i < filter->filters; i++)
1327 free_filter_type(&filter->event_filters[i]);
1328
1329 free(filter->event_filters);
1330 filter->filters = 0;
1331 filter->event_filters = NULL;
1332}
1333
1334void pevent_filter_free(struct event_filter *filter)
1335{
1336 pevent_unref(filter->pevent);
1337
1338 pevent_filter_reset(filter);
1339
1340 free(filter);
1341}
1342
1343static char *arg_to_str(struct event_filter *filter, struct filter_arg *arg);
1344
1345static int copy_filter_type(struct event_filter *filter,
1346 struct event_filter *source,
1347 struct filter_type *filter_type)
1348{
1349 struct filter_arg *arg;
1350 struct event_format *event;
1351 const char *sys;
1352 const char *name;
1353 char *str;
1354
1355 /* Can't assume that the pevent's are the same */
1356 sys = filter_type->event->system;
1357 name = filter_type->event->name;
1358 event = pevent_find_event_by_name(filter->pevent, sys, name);
1359 if (!event)
1360 return -1;
1361
1362 str = arg_to_str(source, filter_type->filter);
1363 if (!str)
1364 return -1;
1365
1366 if (strcmp(str, "TRUE") == 0 || strcmp(str, "FALSE") == 0) {
1367 /* Add trivial event */
1368 arg = allocate_arg();
1369 arg->type = FILTER_ARG_BOOLEAN;
1370 if (strcmp(str, "TRUE") == 0)
1371 arg->boolean.value = 1;
1372 else
1373 arg->boolean.value = 0;
1374
1375 filter_type = add_filter_type(filter, event->id);
1376 filter_type->filter = arg;
1377
1378 free(str);
1379 return 0;
1380 }
1381
1382 filter_event(filter, event, str, NULL);
1383 free(str);
1384
1385 return 0;
1386}
1387
1388/**
1389 * pevent_filter_copy - copy a filter using another filter
1390 * @dest - the filter to copy to
1391 * @source - the filter to copy from
1392 *
1393 * Returns 0 on success and -1 if not all filters were copied
1394 */
1395int pevent_filter_copy(struct event_filter *dest, struct event_filter *source)
1396{
1397 int ret = 0;
1398 int i;
1399
1400 pevent_filter_reset(dest);
1401
1402 for (i = 0; i < source->filters; i++) {
1403 if (copy_filter_type(dest, source, &source->event_filters[i]))
1404 ret = -1;
1405 }
1406 return ret;
1407}
1408
1409
1410/**
1411 * pevent_update_trivial - update the trivial filters with the given filter
1412 * @dest - the filter to update
1413 * @source - the filter as the source of the update
1414 * @type - the type of trivial filter to update.
1415 *
1416 * Scan dest for trivial events matching @type to replace with the source.
1417 *
1418 * Returns 0 on success and -1 if there was a problem updating, but
1419 * events may have still been updated on error.
1420 */
1421int pevent_update_trivial(struct event_filter *dest, struct event_filter *source,
1422 enum filter_trivial_type type)
1423{
1424 struct pevent *src_pevent;
1425 struct pevent *dest_pevent;
1426 struct event_format *event;
1427 struct filter_type *filter_type;
1428 struct filter_arg *arg;
1429 char *str;
1430 int i;
1431
1432 src_pevent = source->pevent;
1433 dest_pevent = dest->pevent;
1434
1435 /* Do nothing if either of the filters has nothing to filter */
1436 if (!dest->filters || !source->filters)
1437 return 0;
1438
1439 for (i = 0; i < dest->filters; i++) {
1440 filter_type = &dest->event_filters[i];
1441 arg = filter_type->filter;
1442 if (arg->type != FILTER_ARG_BOOLEAN)
1443 continue;
1444 if ((arg->boolean.value && type == FILTER_TRIVIAL_FALSE) ||
1445 (!arg->boolean.value && type == FILTER_TRIVIAL_TRUE))
1446 continue;
1447
1448 event = filter_type->event;
1449
1450 if (src_pevent != dest_pevent) {
1451 /* do a look up */
1452 event = pevent_find_event_by_name(src_pevent,
1453 event->system,
1454 event->name);
1455 if (!event)
1456 return -1;
1457 }
1458
1459 str = pevent_filter_make_string(source, event->id);
1460 if (!str)
1461 continue;
1462
1463 /* Don't bother if the filter is trivial too */
1464 if (strcmp(str, "TRUE") != 0 && strcmp(str, "FALSE") != 0)
1465 filter_event(dest, event, str, NULL);
1466 free(str);
1467 }
1468 return 0;
1469}
1470
1471/**
1472 * pevent_filter_clear_trivial - clear TRUE and FALSE filters
1473 * @filter: the filter to remove trivial filters from
1474 * @type: remove only true, false, or both
1475 *
1476 * Removes filters that only contain a TRUE or FALES boolean arg.
1477 */
1478void pevent_filter_clear_trivial(struct event_filter *filter,
1479 enum filter_trivial_type type)
1480{
1481 struct filter_type *filter_type;
1482 int count = 0;
1483 int *ids;
1484 int i;
1485
1486 if (!filter->filters)
1487 return;
1488
1489 /*
1490 * Two steps, first get all ids with trivial filters.
1491 * then remove those ids.
1492 */
1493 for (i = 0; i < filter->filters; i++) {
1494 filter_type = &filter->event_filters[i];
1495 if (filter_type->filter->type != FILTER_ARG_BOOLEAN)
1496 continue;
1497 switch (type) {
1498 case FILTER_TRIVIAL_FALSE:
1499 if (filter_type->filter->boolean.value)
1500 continue;
1501 case FILTER_TRIVIAL_TRUE:
1502 if (!filter_type->filter->boolean.value)
1503 continue;
1504 default:
1505 break;
1506 }
1507 if (count)
1508 ids = realloc(ids, sizeof(*ids) * (count + 1));
1509 else
1510 ids = malloc(sizeof(*ids));
1511 if (!ids)
1512 die("Can't allocate ids");
1513 ids[count++] = filter_type->event_id;
1514 }
1515
1516 if (!count)
1517 return;
1518
1519 for (i = 0; i < count; i++)
1520 pevent_filter_remove_event(filter, ids[i]);
1521
1522 free(ids);
1523}
1524
1525/**
1526 * pevent_filter_event_has_trivial - return true event contains trivial filter
1527 * @filter: the filter with the information
1528 * @event_id: the id of the event to test
1529 * @type: trivial type to test for (TRUE, FALSE, EITHER)
1530 *
1531 * Returns 1 if the event contains a matching trivial type
1532 * otherwise 0.
1533 */
1534int pevent_filter_event_has_trivial(struct event_filter *filter,
1535 int event_id,
1536 enum filter_trivial_type type)
1537{
1538 struct filter_type *filter_type;
1539
1540 if (!filter->filters)
1541 return 0;
1542
1543 filter_type = find_filter_type(filter, event_id);
1544
1545 if (!filter_type)
1546 return 0;
1547
1548 if (filter_type->filter->type != FILTER_ARG_BOOLEAN)
1549 return 0;
1550
1551 switch (type) {
1552 case FILTER_TRIVIAL_FALSE:
1553 return !filter_type->filter->boolean.value;
1554
1555 case FILTER_TRIVIAL_TRUE:
1556 return filter_type->filter->boolean.value;
1557 default:
1558 return 1;
1559 }
1560}
1561
1562static int test_filter(struct event_format *event,
1563 struct filter_arg *arg, struct pevent_record *record);
1564
1565static const char *
1566get_comm(struct event_format *event, struct pevent_record *record)
1567{
1568 const char *comm;
1569 int pid;
1570
1571 pid = pevent_data_pid(event->pevent, record);
1572 comm = pevent_data_comm_from_pid(event->pevent, pid);
1573 return comm;
1574}
1575
1576static unsigned long long
1577get_value(struct event_format *event,
1578 struct format_field *field, struct pevent_record *record)
1579{
1580 unsigned long long val;
1581
1582 /* Handle our dummy "comm" field */
1583 if (field == &comm) {
1584 const char *name;
1585
1586 name = get_comm(event, record);
1587 return (unsigned long)name;
1588 }
1589
1590 pevent_read_number_field(field, record->data, &val);
1591
1592 if (!(field->flags & FIELD_IS_SIGNED))
1593 return val;
1594
1595 switch (field->size) {
1596 case 1:
1597 return (char)val;
1598 case 2:
1599 return (short)val;
1600 case 4:
1601 return (int)val;
1602 case 8:
1603 return (long long)val;
1604 }
1605 return val;
1606}
1607
1608static unsigned long long
1609get_arg_value(struct event_format *event, struct filter_arg *arg, struct pevent_record *record);
1610
1611static unsigned long long
1612get_exp_value(struct event_format *event, struct filter_arg *arg, struct pevent_record *record)
1613{
1614 unsigned long long lval, rval;
1615
1616 lval = get_arg_value(event, arg->exp.left, record);
1617 rval = get_arg_value(event, arg->exp.right, record);
1618
1619 switch (arg->exp.type) {
1620 case FILTER_EXP_ADD:
1621 return lval + rval;
1622
1623 case FILTER_EXP_SUB:
1624 return lval - rval;
1625
1626 case FILTER_EXP_MUL:
1627 return lval * rval;
1628
1629 case FILTER_EXP_DIV:
1630 return lval / rval;
1631
1632 case FILTER_EXP_MOD:
1633 return lval % rval;
1634
1635 case FILTER_EXP_RSHIFT:
1636 return lval >> rval;
1637
1638 case FILTER_EXP_LSHIFT:
1639 return lval << rval;
1640
1641 case FILTER_EXP_AND:
1642 return lval & rval;
1643
1644 case FILTER_EXP_OR:
1645 return lval | rval;
1646
1647 case FILTER_EXP_XOR:
1648 return lval ^ rval;
1649
1650 case FILTER_EXP_NOT:
1651 default:
1652 die("error in exp");
1653 }
1654 return 0;
1655}
1656
1657static unsigned long long
1658get_arg_value(struct event_format *event, struct filter_arg *arg, struct pevent_record *record)
1659{
1660 switch (arg->type) {
1661 case FILTER_ARG_FIELD:
1662 return get_value(event, arg->field.field, record);
1663
1664 case FILTER_ARG_VALUE:
1665 if (arg->value.type != FILTER_NUMBER)
1666 die("must have number field!");
1667 return arg->value.val;
1668
1669 case FILTER_ARG_EXP:
1670 return get_exp_value(event, arg, record);
1671
1672 default:
1673 die("oops in filter");
1674 }
1675 return 0;
1676}
1677
1678static int test_num(struct event_format *event,
1679 struct filter_arg *arg, struct pevent_record *record)
1680{
1681 unsigned long long lval, rval;
1682
1683 lval = get_arg_value(event, arg->num.left, record);
1684 rval = get_arg_value(event, arg->num.right, record);
1685
1686 switch (arg->num.type) {
1687 case FILTER_CMP_EQ:
1688 return lval == rval;
1689
1690 case FILTER_CMP_NE:
1691 return lval != rval;
1692
1693 case FILTER_CMP_GT:
1694 return lval > rval;
1695
1696 case FILTER_CMP_LT:
1697 return lval < rval;
1698
1699 case FILTER_CMP_GE:
1700 return lval >= rval;
1701
1702 case FILTER_CMP_LE:
1703 return lval <= rval;
1704
1705 default:
1706 /* ?? */
1707 return 0;
1708 }
1709}
1710
1711static const char *get_field_str(struct filter_arg *arg, struct pevent_record *record)
1712{
1713 const char *val = record->data + arg->str.field->offset;
1714
1715 /*
1716 * We need to copy the data since we can't be sure the field
1717 * is null terminated.
1718 */
1719 if (*(val + arg->str.field->size - 1)) {
1720 /* copy it */
1721 memcpy(arg->str.buffer, val, arg->str.field->size);
1722 /* the buffer is already NULL terminated */
1723 val = arg->str.buffer;
1724 }
1725 return val;
1726}
1727
1728static int test_str(struct event_format *event,
1729 struct filter_arg *arg, struct pevent_record *record)
1730{
1731 const char *val;
1732
1733 if (arg->str.field == &comm)
1734 val = get_comm(event, record);
1735 else
1736 val = get_field_str(arg, record);
1737
1738 switch (arg->str.type) {
1739 case FILTER_CMP_MATCH:
1740 return strcmp(val, arg->str.val) == 0;
1741
1742 case FILTER_CMP_NOT_MATCH:
1743 return strcmp(val, arg->str.val) != 0;
1744
1745 case FILTER_CMP_REGEX:
1746 /* Returns zero on match */
1747 return !regexec(&arg->str.reg, val, 0, NULL, 0);
1748
1749 case FILTER_CMP_NOT_REGEX:
1750 return regexec(&arg->str.reg, val, 0, NULL, 0);
1751
1752 default:
1753 /* ?? */
1754 return 0;
1755 }
1756}
1757
1758static int test_op(struct event_format *event,
1759 struct filter_arg *arg, struct pevent_record *record)
1760{
1761 switch (arg->op.type) {
1762 case FILTER_OP_AND:
1763 return test_filter(event, arg->op.left, record) &&
1764 test_filter(event, arg->op.right, record);
1765
1766 case FILTER_OP_OR:
1767 return test_filter(event, arg->op.left, record) ||
1768 test_filter(event, arg->op.right, record);
1769
1770 case FILTER_OP_NOT:
1771 return !test_filter(event, arg->op.right, record);
1772
1773 default:
1774 /* ?? */
1775 return 0;
1776 }
1777}
1778
1779static int test_filter(struct event_format *event,
1780 struct filter_arg *arg, struct pevent_record *record)
1781{
1782 switch (arg->type) {
1783 case FILTER_ARG_BOOLEAN:
1784 /* easy case */
1785 return arg->boolean.value;
1786
1787 case FILTER_ARG_OP:
1788 return test_op(event, arg, record);
1789
1790 case FILTER_ARG_NUM:
1791 return test_num(event, arg, record);
1792
1793 case FILTER_ARG_STR:
1794 return test_str(event, arg, record);
1795
1796 case FILTER_ARG_EXP:
1797 case FILTER_ARG_VALUE:
1798 case FILTER_ARG_FIELD:
1799 /*
1800 * Expressions, fields and values evaluate
1801 * to true if they return non zero
1802 */
1803 return !!get_arg_value(event, arg, record);
1804
1805 default:
1806 die("oops!");
1807 /* ?? */
1808 return 0;
1809 }
1810}
1811
1812/**
1813 * pevent_event_filtered - return true if event has filter
1814 * @filter: filter struct with filter information
1815 * @event_id: event id to test if filter exists
1816 *
1817 * Returns 1 if filter found for @event_id
1818 * otherwise 0;
1819 */
1820int pevent_event_filtered(struct event_filter *filter,
1821 int event_id)
1822{
1823 struct filter_type *filter_type;
1824
1825 if (!filter->filters)
1826 return 0;
1827
1828 filter_type = find_filter_type(filter, event_id);
1829
1830 return filter_type ? 1 : 0;
1831}
1832
1833/**
1834 * pevent_filter_match - test if a record matches a filter
1835 * @filter: filter struct with filter information
1836 * @record: the record to test against the filter
1837 *
1838 * Returns:
1839 * 1 - filter found for event and @record matches
1840 * 0 - filter found for event and @record does not match
1841 * -1 - no filter found for @record's event
1842 * -2 - if no filters exist
1843 */
1844int pevent_filter_match(struct event_filter *filter,
1845 struct pevent_record *record)
1846{
1847 struct pevent *pevent = filter->pevent;
1848 struct filter_type *filter_type;
1849 int event_id;
1850
1851 if (!filter->filters)
1852 return FILTER_NONE;
1853
1854 event_id = pevent_data_type(pevent, record);
1855
1856 filter_type = find_filter_type(filter, event_id);
1857
1858 if (!filter_type)
1859 return FILTER_NOEXIST;
1860
1861 return test_filter(filter_type->event, filter_type->filter, record) ?
1862 FILTER_MATCH : FILTER_MISS;
1863}
1864
1865static char *op_to_str(struct event_filter *filter, struct filter_arg *arg)
1866{
1867 char *str = NULL;
1868 char *left = NULL;
1869 char *right = NULL;
1870 char *op = NULL;
1871 int left_val = -1;
1872 int right_val = -1;
1873 int val;
1874 int len;
1875
1876 switch (arg->op.type) {
1877 case FILTER_OP_AND:
1878 op = "&&";
1879 /* fall through */
1880 case FILTER_OP_OR:
1881 if (!op)
1882 op = "||";
1883
1884 left = arg_to_str(filter, arg->op.left);
1885 right = arg_to_str(filter, arg->op.right);
1886 if (!left || !right)
1887 break;
1888
1889 /* Try to consolidate boolean values */
1890 if (strcmp(left, "TRUE") == 0)
1891 left_val = 1;
1892 else if (strcmp(left, "FALSE") == 0)
1893 left_val = 0;
1894
1895 if (strcmp(right, "TRUE") == 0)
1896 right_val = 1;
1897 else if (strcmp(right, "FALSE") == 0)
1898 right_val = 0;
1899
1900 if (left_val >= 0) {
1901 if ((arg->op.type == FILTER_OP_AND && !left_val) ||
1902 (arg->op.type == FILTER_OP_OR && left_val)) {
1903 /* Just return left value */
1904 str = left;
1905 left = NULL;
1906 break;
1907 }
1908 if (right_val >= 0) {
1909 /* just evaluate this. */
1910 val = 0;
1911 switch (arg->op.type) {
1912 case FILTER_OP_AND:
1913 val = left_val && right_val;
1914 break;
1915 case FILTER_OP_OR:
1916 val = left_val || right_val;
1917 break;
1918 default:
1919 break;
1920 }
1921 str = malloc_or_die(6);
1922 if (val)
1923 strcpy(str, "TRUE");
1924 else
1925 strcpy(str, "FALSE");
1926 break;
1927 }
1928 }
1929 if (right_val >= 0) {
1930 if ((arg->op.type == FILTER_OP_AND && !right_val) ||
1931 (arg->op.type == FILTER_OP_OR && right_val)) {
1932 /* Just return right value */
1933 str = right;
1934 right = NULL;
1935 break;
1936 }
1937 /* The right value is meaningless */
1938 str = left;
1939 left = NULL;
1940 break;
1941 }
1942
1943 len = strlen(left) + strlen(right) + strlen(op) + 10;
1944 str = malloc_or_die(len);
1945 snprintf(str, len, "(%s) %s (%s)",
1946 left, op, right);
1947 break;
1948
1949 case FILTER_OP_NOT:
1950 op = "!";
1951 right = arg_to_str(filter, arg->op.right);
1952 if (!right)
1953 break;
1954
1955 /* See if we can consolidate */
1956 if (strcmp(right, "TRUE") == 0)
1957 right_val = 1;
1958 else if (strcmp(right, "FALSE") == 0)
1959 right_val = 0;
1960 if (right_val >= 0) {
1961 /* just return the opposite */
1962 str = malloc_or_die(6);
1963 if (right_val)
1964 strcpy(str, "FALSE");
1965 else
1966 strcpy(str, "TRUE");
1967 break;
1968 }
1969 len = strlen(right) + strlen(op) + 3;
1970 str = malloc_or_die(len);
1971 snprintf(str, len, "%s(%s)", op, right);
1972 break;
1973
1974 default:
1975 /* ?? */
1976 break;
1977 }
1978 free(left);
1979 free(right);
1980 return str;
1981}
1982
1983static char *val_to_str(struct event_filter *filter, struct filter_arg *arg)
1984{
1985 char *str;
1986
1987 str = malloc_or_die(30);
1988
1989 snprintf(str, 30, "%lld", arg->value.val);
1990
1991 return str;
1992}
1993
1994static char *field_to_str(struct event_filter *filter, struct filter_arg *arg)
1995{
1996 return strdup(arg->field.field->name);
1997}
1998
1999static char *exp_to_str(struct event_filter *filter, struct filter_arg *arg)
2000{
2001 char *lstr;
2002 char *rstr;
2003 char *op;
2004 char *str;
2005 int len;
2006
2007 lstr = arg_to_str(filter, arg->exp.left);
2008 rstr = arg_to_str(filter, arg->exp.right);
2009
2010 switch (arg->exp.type) {
2011 case FILTER_EXP_ADD:
2012 op = "+";
2013 break;
2014 case FILTER_EXP_SUB:
2015 op = "-";
2016 break;
2017 case FILTER_EXP_MUL:
2018 op = "*";
2019 break;
2020 case FILTER_EXP_DIV:
2021 op = "/";
2022 break;
2023 case FILTER_EXP_MOD:
2024 op = "%";
2025 break;
2026 case FILTER_EXP_RSHIFT:
2027 op = ">>";
2028 break;
2029 case FILTER_EXP_LSHIFT:
2030 op = "<<";
2031 break;
2032 case FILTER_EXP_AND:
2033 op = "&";
2034 break;
2035 case FILTER_EXP_OR:
2036 op = "|";
2037 break;
2038 case FILTER_EXP_XOR:
2039 op = "^";
2040 break;
2041 default:
2042 die("oops in exp");
2043 }
2044
2045 len = strlen(op) + strlen(lstr) + strlen(rstr) + 4;
2046 str = malloc_or_die(len);
2047 snprintf(str, len, "%s %s %s", lstr, op, rstr);
2048 free(lstr);
2049 free(rstr);
2050
2051 return str;
2052}
2053
2054static char *num_to_str(struct event_filter *filter, struct filter_arg *arg)
2055{
2056 char *lstr;
2057 char *rstr;
2058 char *str = NULL;
2059 char *op = NULL;
2060 int len;
2061
2062 lstr = arg_to_str(filter, arg->num.left);
2063 rstr = arg_to_str(filter, arg->num.right);
2064
2065 switch (arg->num.type) {
2066 case FILTER_CMP_EQ:
2067 op = "==";
2068 /* fall through */
2069 case FILTER_CMP_NE:
2070 if (!op)
2071 op = "!=";
2072 /* fall through */
2073 case FILTER_CMP_GT:
2074 if (!op)
2075 op = ">";
2076 /* fall through */
2077 case FILTER_CMP_LT:
2078 if (!op)
2079 op = "<";
2080 /* fall through */
2081 case FILTER_CMP_GE:
2082 if (!op)
2083 op = ">=";
2084 /* fall through */
2085 case FILTER_CMP_LE:
2086 if (!op)
2087 op = "<=";
2088
2089 len = strlen(lstr) + strlen(op) + strlen(rstr) + 4;
2090 str = malloc_or_die(len);
2091 sprintf(str, "%s %s %s", lstr, op, rstr);
2092
2093 break;
2094
2095 default:
2096 /* ?? */
2097 break;
2098 }
2099
2100 free(lstr);
2101 free(rstr);
2102 return str;
2103}
2104
2105static char *str_to_str(struct event_filter *filter, struct filter_arg *arg)
2106{
2107 char *str = NULL;
2108 char *op = NULL;
2109 int len;
2110
2111 switch (arg->str.type) {
2112 case FILTER_CMP_MATCH:
2113 op = "==";
2114 /* fall through */
2115 case FILTER_CMP_NOT_MATCH:
2116 if (!op)
2117 op = "!=";
2118 /* fall through */
2119 case FILTER_CMP_REGEX:
2120 if (!op)
2121 op = "=~";
2122 /* fall through */
2123 case FILTER_CMP_NOT_REGEX:
2124 if (!op)
2125 op = "!~";
2126
2127 len = strlen(arg->str.field->name) + strlen(op) +
2128 strlen(arg->str.val) + 6;
2129 str = malloc_or_die(len);
2130 snprintf(str, len, "%s %s \"%s\"",
2131 arg->str.field->name,
2132 op, arg->str.val);
2133 break;
2134
2135 default:
2136 /* ?? */
2137 break;
2138 }
2139 return str;
2140}
2141
2142static char *arg_to_str(struct event_filter *filter, struct filter_arg *arg)
2143{
2144 char *str;
2145
2146 switch (arg->type) {
2147 case FILTER_ARG_BOOLEAN:
2148 str = malloc_or_die(6);
2149 if (arg->boolean.value)
2150 strcpy(str, "TRUE");
2151 else
2152 strcpy(str, "FALSE");
2153 return str;
2154
2155 case FILTER_ARG_OP:
2156 return op_to_str(filter, arg);
2157
2158 case FILTER_ARG_NUM:
2159 return num_to_str(filter, arg);
2160
2161 case FILTER_ARG_STR:
2162 return str_to_str(filter, arg);
2163
2164 case FILTER_ARG_VALUE:
2165 return val_to_str(filter, arg);
2166
2167 case FILTER_ARG_FIELD:
2168 return field_to_str(filter, arg);
2169
2170 case FILTER_ARG_EXP:
2171 return exp_to_str(filter, arg);
2172
2173 default:
2174 /* ?? */
2175 return NULL;
2176 }
2177
2178}
2179
2180/**
2181 * pevent_filter_make_string - return a string showing the filter
2182 * @filter: filter struct with filter information
2183 * @event_id: the event id to return the filter string with
2184 *
2185 * Returns a string that displays the filter contents.
2186 * This string must be freed with free(str).
2187 * NULL is returned if no filter is found.
2188 */
2189char *
2190pevent_filter_make_string(struct event_filter *filter, int event_id)
2191{
2192 struct filter_type *filter_type;
2193
2194 if (!filter->filters)
2195 return NULL;
2196
2197 filter_type = find_filter_type(filter, event_id);
2198
2199 if (!filter_type)
2200 return NULL;
2201
2202 return arg_to_str(filter, filter_type->filter);
2203}
2204
2205/**
2206 * pevent_filter_compare - compare two filters and return if they are the same
2207 * @filter1: Filter to compare with @filter2
2208 * @filter2: Filter to compare with @filter1
2209 *
2210 * Returns:
2211 * 1 if the two filters hold the same content.
2212 * 0 if they do not.
2213 */
2214int pevent_filter_compare(struct event_filter *filter1, struct event_filter *filter2)
2215{
2216 struct filter_type *filter_type1;
2217 struct filter_type *filter_type2;
2218 char *str1, *str2;
2219 int result;
2220 int i;
2221
2222 /* Do the easy checks first */
2223 if (filter1->filters != filter2->filters)
2224 return 0;
2225 if (!filter1->filters && !filter2->filters)
2226 return 1;
2227
2228 /*
2229 * Now take a look at each of the events to see if they have the same
2230 * filters to them.
2231 */
2232 for (i = 0; i < filter1->filters; i++) {
2233 filter_type1 = &filter1->event_filters[i];
2234 filter_type2 = find_filter_type(filter2, filter_type1->event_id);
2235 if (!filter_type2)
2236 break;
2237 if (filter_type1->filter->type != filter_type2->filter->type)
2238 break;
2239 switch (filter_type1->filter->type) {
2240 case FILTER_TRIVIAL_FALSE:
2241 case FILTER_TRIVIAL_TRUE:
2242 /* trivial types just need the type compared */
2243 continue;
2244 default:
2245 break;
2246 }
2247 /* The best way to compare complex filters is with strings */
2248 str1 = arg_to_str(filter1, filter_type1->filter);
2249 str2 = arg_to_str(filter2, filter_type2->filter);
2250 result = strcmp(str1, str2) != 0;
2251 free(str1);
2252 free(str2);
2253 if (result)
2254 break;
2255 }
2256
2257 if (i < filter1->filters)
2258 return 0;
2259 return 1;
2260}
2261