|
227 | 227 | u32 tid = id; // Cast and get the lower part |
228 | 228 | u32 uid = bpf_get_current_uid_gid(); |
229 | 229 |
|
230 | | - PID_TID_FILTER |
231 | | - UID_FILTER |
232 | | - FLAGS_FILTER |
| 230 | + KPROBE_PID_TID_FILTER |
| 231 | + KPROBE_UID_FILTER |
| 232 | + KPROBE_FLAGS_FILTER |
233 | 233 |
|
234 | 234 | if (container_should_be_filtered()) { |
235 | 235 | return 0; |
|
327 | 327 | if (!data) |
328 | 328 | return 0; |
329 | 329 |
|
330 | | - PID_TID_FILTER |
331 | | - UID_FILTER |
332 | | - FLAGS_FILTER |
| 330 | + KFUNC_PID_TID_FILTER |
| 331 | + KFUNC_UID_FILTER |
| 332 | + KFUNC_FLAGS_FILTER |
333 | 333 | if (container_should_be_filtered()) { |
| 334 | + events.ringbuf_discard(data, 0); |
334 | 335 | return 0; |
335 | 336 | } |
336 | 337 |
|
|
389 | 390 | bpf_text += bpf_text_kprobe_body |
390 | 391 |
|
391 | 392 | if args.tid: # TID trumps PID |
392 | | - bpf_text = bpf_text.replace('PID_TID_FILTER', |
| 393 | + bpf_text = bpf_text.replace('KPROBE_PID_TID_FILTER', |
393 | 394 | 'if (tid != %s) { return 0; }' % args.tid) |
| 395 | + bpf_text = bpf_text.replace('KFUNC_PID_TID_FILTER', |
| 396 | + 'if (tid != %s) { events.ringbuf_discard(data, 0); return 0; }' % args.tid) |
394 | 397 | elif args.pid: |
395 | | - bpf_text = bpf_text.replace('PID_TID_FILTER', |
| 398 | + bpf_text = bpf_text.replace('KPROBE_PID_TID_FILTER', |
396 | 399 | 'if (pid != %s) { return 0; }' % args.pid) |
| 400 | + bpf_text = bpf_text.replace('KFUNC_PID_TID_FILTER', |
| 401 | + 'if (pid != %s) { events.ringbuf_discard(data, 0); return 0; }' % args.pid) |
397 | 402 | else: |
398 | | - bpf_text = bpf_text.replace('PID_TID_FILTER', '') |
| 403 | + bpf_text = bpf_text.replace('KPROBE_PID_TID_FILTER', '') |
| 404 | + bpf_text = bpf_text.replace('KFUNC_PID_TID_FILTER', '') |
399 | 405 | if args.uid: |
400 | | - bpf_text = bpf_text.replace('UID_FILTER', |
| 406 | + bpf_text = bpf_text.replace('KPROBE_UID_FILTER', |
401 | 407 | 'if (uid != %s) { return 0; }' % args.uid) |
| 408 | + bpf_text = bpf_text.replace('KFUNC_UID_FILTER', |
| 409 | + 'if (uid != %s) { events.ringbuf_discard(data, 0); return 0; }' % args.uid) |
402 | 410 | else: |
403 | | - bpf_text = bpf_text.replace('UID_FILTER', '') |
| 411 | + bpf_text = bpf_text.replace('KPROBE_UID_FILTER', '') |
| 412 | + bpf_text = bpf_text.replace('KFUNC_UID_FILTER', '') |
404 | 413 | if args.buffer_pages: |
405 | 414 | bpf_text = bpf_text.replace('BUFFER_PAGES', '%s' % args.buffer_pages) |
406 | 415 | else: |
407 | 416 | bpf_text = bpf_text.replace('BUFFER_PAGES', '%d' % 64) |
408 | 417 | bpf_text = filter_by_containers(args) + bpf_text |
409 | 418 | if args.flag_filter: |
410 | | - bpf_text = bpf_text.replace('FLAGS_FILTER', |
| 419 | + bpf_text = bpf_text.replace('KPROBE_FLAGS_FILTER', |
411 | 420 | 'if (!(flags & %d)) { return 0; }' % flag_filter_mask) |
| 421 | + bpf_text = bpf_text.replace('KFUNC_FLAGS_FILTER', |
| 422 | + 'if (!(flags & %d)) { events.ringbuf_discard(data, 0); return 0; }' % flag_filter_mask) |
412 | 423 | else: |
413 | | - bpf_text = bpf_text.replace('FLAGS_FILTER', '') |
| 424 | + bpf_text = bpf_text.replace('KPROBE_FLAGS_FILTER', '') |
| 425 | + bpf_text = bpf_text.replace('KFUNC_FLAGS_FILTER', '') |
414 | 426 | if not (args.extended_fields or args.flag_filter): |
415 | 427 | bpf_text = '\n'.join(x for x in bpf_text.split('\n') |
416 | 428 | if 'EXTENDED_STRUCT_MEMBER' not in x) |
|
0 commit comments