1 // SPDX-License-Identifier: GPL-2.0
13 #include <linux/bpf.h>
14 #include <linux/filter.h>
15 #include <linux/perf_event.h>
16 #include <linux/netlink.h>
17 #include <linux/rtnetlink.h>
18 #include <linux/types.h>
19 #include <sys/types.h>
20 #include <sys/socket.h>
21 #include <sys/syscall.h>
22 #include <sys/ioctl.h>
31 #define DEBUGFS "/sys/kernel/debug/tracing/"
33 static char license
[128];
34 static int kern_version
;
35 static bool processed_sec
[128];
36 char bpf_log_buf
[BPF_LOG_BUF_SIZE
];
38 int prog_fd
[MAX_PROGS
];
39 int event_fd
[MAX_PROGS
];
41 int prog_array_fd
= -1;
43 struct bpf_map_data map_data
[MAX_MAPS
];
44 int map_data_count
= 0;
46 static int populate_prog_array(const char *event
, int prog_fd
)
48 int ind
= atoi(event
), err
;
50 err
= bpf_map_update_elem(prog_array_fd
, &ind
, &prog_fd
, BPF_ANY
);
52 printf("failed to store prog_fd in prog_array\n");
58 static int load_and_attach(const char *event
, struct bpf_insn
*prog
, int size
)
60 bool is_socket
= strncmp(event
, "socket", 6) == 0;
61 bool is_kprobe
= strncmp(event
, "kprobe/", 7) == 0;
62 bool is_kretprobe
= strncmp(event
, "kretprobe/", 10) == 0;
63 bool is_tracepoint
= strncmp(event
, "tracepoint/", 11) == 0;
64 bool is_xdp
= strncmp(event
, "xdp", 3) == 0;
65 bool is_perf_event
= strncmp(event
, "perf_event", 10) == 0;
66 bool is_cgroup_skb
= strncmp(event
, "cgroup/skb", 10) == 0;
67 bool is_cgroup_sk
= strncmp(event
, "cgroup/sock", 11) == 0;
68 bool is_sockops
= strncmp(event
, "sockops", 7) == 0;
69 bool is_sk_skb
= strncmp(event
, "sk_skb", 6) == 0;
70 size_t insns_cnt
= size
/ sizeof(struct bpf_insn
);
71 enum bpf_prog_type prog_type
;
74 struct perf_event_attr attr
= {};
76 attr
.type
= PERF_TYPE_TRACEPOINT
;
77 attr
.sample_type
= PERF_SAMPLE_RAW
;
78 attr
.sample_period
= 1;
79 attr
.wakeup_events
= 1;
82 prog_type
= BPF_PROG_TYPE_SOCKET_FILTER
;
83 } else if (is_kprobe
|| is_kretprobe
) {
84 prog_type
= BPF_PROG_TYPE_KPROBE
;
85 } else if (is_tracepoint
) {
86 prog_type
= BPF_PROG_TYPE_TRACEPOINT
;
88 prog_type
= BPF_PROG_TYPE_XDP
;
89 } else if (is_perf_event
) {
90 prog_type
= BPF_PROG_TYPE_PERF_EVENT
;
91 } else if (is_cgroup_skb
) {
92 prog_type
= BPF_PROG_TYPE_CGROUP_SKB
;
93 } else if (is_cgroup_sk
) {
94 prog_type
= BPF_PROG_TYPE_CGROUP_SOCK
;
95 } else if (is_sockops
) {
96 prog_type
= BPF_PROG_TYPE_SOCK_OPS
;
97 } else if (is_sk_skb
) {
98 prog_type
= BPF_PROG_TYPE_SK_SKB
;
100 printf("Unknown event '%s'\n", event
);
104 fd
= bpf_load_program(prog_type
, prog
, insns_cnt
, license
, kern_version
,
105 bpf_log_buf
, BPF_LOG_BUF_SIZE
);
107 printf("bpf_load_program() err=%d\n%s", errno
, bpf_log_buf
);
111 prog_fd
[prog_cnt
++] = fd
;
113 if (is_xdp
|| is_perf_event
|| is_cgroup_skb
|| is_cgroup_sk
)
116 if (is_socket
|| is_sockops
|| is_sk_skb
) {
124 if (!isdigit(*event
)) {
125 printf("invalid prog number\n");
128 return populate_prog_array(event
, fd
);
131 if (is_kprobe
|| is_kretprobe
) {
138 printf("event name cannot be empty\n");
143 return populate_prog_array(event
, fd
);
145 snprintf(buf
, sizeof(buf
),
146 "echo '%c:%s %s' >> /sys/kernel/debug/tracing/kprobe_events",
147 is_kprobe
? 'p' : 'r', event
, event
);
150 printf("failed to create kprobe '%s' error '%s'\n",
151 event
, strerror(errno
));
155 strcpy(buf
, DEBUGFS
);
156 strcat(buf
, "events/kprobes/");
159 } else if (is_tracepoint
) {
163 printf("event name cannot be empty\n");
166 strcpy(buf
, DEBUGFS
);
167 strcat(buf
, "events/");
172 efd
= open(buf
, O_RDONLY
, 0);
174 printf("failed to open event %s\n", event
);
178 err
= read(efd
, buf
, sizeof(buf
));
179 if (err
< 0 || err
>= sizeof(buf
)) {
180 printf("read from '%s' failed '%s'\n", event
, strerror(errno
));
190 efd
= sys_perf_event_open(&attr
, -1/*pid*/, 0/*cpu*/, -1/*group_fd*/, 0);
192 printf("event %d fd %d err %s\n", id
, efd
, strerror(errno
));
195 event_fd
[prog_cnt
- 1] = efd
;
196 err
= ioctl(efd
, PERF_EVENT_IOC_ENABLE
, 0);
198 printf("ioctl PERF_EVENT_IOC_ENABLE failed err %s\n",
202 err
= ioctl(efd
, PERF_EVENT_IOC_SET_BPF
, fd
);
204 printf("ioctl PERF_EVENT_IOC_SET_BPF failed err %s\n",
212 static int load_maps(struct bpf_map_data
*maps
, int nr_maps
,
213 fixup_map_cb fixup_map
)
217 for (i
= 0; i
< nr_maps
; i
++) {
219 fixup_map(&maps
[i
], i
);
220 /* Allow userspace to assign map FD prior to creation */
221 if (maps
[i
].fd
!= -1) {
222 map_fd
[i
] = maps
[i
].fd
;
227 numa_node
= maps
[i
].def
.map_flags
& BPF_F_NUMA_NODE
?
228 maps
[i
].def
.numa_node
: -1;
230 if (maps
[i
].def
.type
== BPF_MAP_TYPE_ARRAY_OF_MAPS
||
231 maps
[i
].def
.type
== BPF_MAP_TYPE_HASH_OF_MAPS
) {
232 int inner_map_fd
= map_fd
[maps
[i
].def
.inner_map_idx
];
234 map_fd
[i
] = bpf_create_map_in_map_node(maps
[i
].def
.type
,
236 maps
[i
].def
.key_size
,
238 maps
[i
].def
.max_entries
,
239 maps
[i
].def
.map_flags
,
242 map_fd
[i
] = bpf_create_map_node(maps
[i
].def
.type
,
244 maps
[i
].def
.key_size
,
245 maps
[i
].def
.value_size
,
246 maps
[i
].def
.max_entries
,
247 maps
[i
].def
.map_flags
,
251 printf("failed to create a map: %d %s\n",
252 errno
, strerror(errno
));
255 maps
[i
].fd
= map_fd
[i
];
257 if (maps
[i
].def
.type
== BPF_MAP_TYPE_PROG_ARRAY
)
258 prog_array_fd
= map_fd
[i
];
263 static int get_sec(Elf
*elf
, int i
, GElf_Ehdr
*ehdr
, char **shname
,
264 GElf_Shdr
*shdr
, Elf_Data
**data
)
268 scn
= elf_getscn(elf
, i
);
272 if (gelf_getshdr(scn
, shdr
) != shdr
)
275 *shname
= elf_strptr(elf
, ehdr
->e_shstrndx
, shdr
->sh_name
);
276 if (!*shname
|| !shdr
->sh_size
)
279 *data
= elf_getdata(scn
, 0);
280 if (!*data
|| elf_getdata(scn
, *data
) != NULL
)
286 static int parse_relo_and_apply(Elf_Data
*data
, Elf_Data
*symbols
,
287 GElf_Shdr
*shdr
, struct bpf_insn
*insn
,
288 struct bpf_map_data
*maps
, int nr_maps
)
292 nrels
= shdr
->sh_size
/ shdr
->sh_entsize
;
294 for (i
= 0; i
< nrels
; i
++) {
297 unsigned int insn_idx
;
301 gelf_getrel(data
, i
, &rel
);
303 insn_idx
= rel
.r_offset
/ sizeof(struct bpf_insn
);
305 gelf_getsym(symbols
, GELF_R_SYM(rel
.r_info
), &sym
);
307 if (insn
[insn_idx
].code
!= (BPF_LD
| BPF_IMM
| BPF_DW
)) {
308 printf("invalid relo for insn[%d].code 0x%x\n",
309 insn_idx
, insn
[insn_idx
].code
);
312 insn
[insn_idx
].src_reg
= BPF_PSEUDO_MAP_FD
;
314 /* Match FD relocation against recorded map_data[] offset */
315 for (map_idx
= 0; map_idx
< nr_maps
; map_idx
++) {
316 if (maps
[map_idx
].elf_offset
== sym
.st_value
) {
322 insn
[insn_idx
].imm
= maps
[map_idx
].fd
;
324 printf("invalid relo for insn[%d] no map_data match\n",
333 static int cmp_symbols(const void *l
, const void *r
)
335 const GElf_Sym
*lsym
= (const GElf_Sym
*)l
;
336 const GElf_Sym
*rsym
= (const GElf_Sym
*)r
;
338 if (lsym
->st_value
< rsym
->st_value
)
340 else if (lsym
->st_value
> rsym
->st_value
)
346 static int load_elf_maps_section(struct bpf_map_data
*maps
, int maps_shndx
,
347 Elf
*elf
, Elf_Data
*symbols
, int strtabidx
)
349 int map_sz_elf
, map_sz_copy
;
350 bool validate_zero
= false;
362 /* Get data for maps section via elf index */
363 scn
= elf_getscn(elf
, maps_shndx
);
365 data_maps
= elf_getdata(scn
, NULL
);
366 if (!scn
|| !data_maps
) {
367 printf("Failed to get Elf_Data from maps section %d\n",
372 /* For each map get corrosponding symbol table entry */
373 sym
= calloc(MAX_MAPS
+1, sizeof(GElf_Sym
));
374 for (i
= 0, nr_maps
= 0; i
< symbols
->d_size
/ sizeof(GElf_Sym
); i
++) {
375 assert(nr_maps
< MAX_MAPS
+1);
376 if (!gelf_getsym(symbols
, i
, &sym
[nr_maps
]))
378 if (sym
[nr_maps
].st_shndx
!= maps_shndx
)
380 /* Only increment iif maps section */
384 /* Align to map_fd[] order, via sort on offset in sym.st_value */
385 qsort(sym
, nr_maps
, sizeof(GElf_Sym
), cmp_symbols
);
387 /* Keeping compatible with ELF maps section changes
388 * ------------------------------------------------
389 * The program size of struct bpf_map_def is known by loader
390 * code, but struct stored in ELF file can be different.
392 * Unfortunately sym[i].st_size is zero. To calculate the
393 * struct size stored in the ELF file, assume all struct have
394 * the same size, and simply divide with number of map
397 map_sz_elf
= data_maps
->d_size
/ nr_maps
;
398 map_sz_copy
= sizeof(struct bpf_map_def
);
399 if (map_sz_elf
< map_sz_copy
) {
401 * Backward compat, loading older ELF file with
402 * smaller struct, keeping remaining bytes zero.
404 map_sz_copy
= map_sz_elf
;
405 } else if (map_sz_elf
> map_sz_copy
) {
407 * Forward compat, loading newer ELF file with larger
408 * struct with unknown features. Assume zero means
409 * feature not used. Thus, validate rest of struct
412 validate_zero
= true;
415 /* Memcpy relevant part of ELF maps data to loader maps */
416 for (i
= 0; i
< nr_maps
; i
++) {
417 unsigned char *addr
, *end
;
418 struct bpf_map_def
*def
;
419 const char *map_name
;
422 map_name
= elf_strptr(elf
, strtabidx
, sym
[i
].st_name
);
423 maps
[i
].name
= strdup(map_name
);
425 printf("strdup(%s): %s(%d)\n", map_name
,
426 strerror(errno
), errno
);
431 /* Symbol value is offset into ELF maps section data area */
432 offset
= sym
[i
].st_value
;
433 def
= (struct bpf_map_def
*)(data_maps
->d_buf
+ offset
);
434 maps
[i
].elf_offset
= offset
;
435 memset(&maps
[i
].def
, 0, sizeof(struct bpf_map_def
));
436 memcpy(&maps
[i
].def
, def
, map_sz_copy
);
438 /* Verify no newer features were requested */
440 addr
= (unsigned char*) def
+ map_sz_copy
;
441 end
= (unsigned char*) def
+ map_sz_elf
;
442 for (; addr
< end
; addr
++) {
455 static int do_load_bpf_file(const char *path
, fixup_map_cb fixup_map
)
457 int fd
, i
, ret
, maps_shndx
= -1, strtabidx
= -1;
460 GElf_Shdr shdr
, shdr_prog
;
461 Elf_Data
*data
, *data_prog
, *data_maps
= NULL
, *symbols
= NULL
;
462 char *shname
, *shname_prog
;
465 /* reset global variables */
467 memset(license
, 0, sizeof(license
));
468 memset(processed_sec
, 0, sizeof(processed_sec
));
470 if (elf_version(EV_CURRENT
) == EV_NONE
)
473 fd
= open(path
, O_RDONLY
, 0);
477 elf
= elf_begin(fd
, ELF_C_READ
, NULL
);
482 if (gelf_getehdr(elf
, &ehdr
) != &ehdr
)
485 /* clear all kprobes */
486 i
= system("echo \"\" > /sys/kernel/debug/tracing/kprobe_events");
488 /* scan over all elf sections to get license and map info */
489 for (i
= 1; i
< ehdr
.e_shnum
; i
++) {
491 if (get_sec(elf
, i
, &ehdr
, &shname
, &shdr
, &data
))
494 if (0) /* helpful for llvm debugging */
495 printf("section %d:%s data %p size %zd link %d flags %d\n",
496 i
, shname
, data
->d_buf
, data
->d_size
,
497 shdr
.sh_link
, (int) shdr
.sh_flags
);
499 if (strcmp(shname
, "license") == 0) {
500 processed_sec
[i
] = true;
501 memcpy(license
, data
->d_buf
, data
->d_size
);
502 } else if (strcmp(shname
, "version") == 0) {
503 processed_sec
[i
] = true;
504 if (data
->d_size
!= sizeof(int)) {
505 printf("invalid size of version section %zd\n",
509 memcpy(&kern_version
, data
->d_buf
, sizeof(int));
510 } else if (strcmp(shname
, "maps") == 0) {
515 for (j
= 0; j
< MAX_MAPS
; j
++)
517 } else if (shdr
.sh_type
== SHT_SYMTAB
) {
518 strtabidx
= shdr
.sh_link
;
526 printf("missing SHT_SYMTAB section\n");
531 nr_maps
= load_elf_maps_section(map_data
, maps_shndx
,
532 elf
, symbols
, strtabidx
);
534 printf("Error: Failed loading ELF maps (errno:%d):%s\n",
535 nr_maps
, strerror(-nr_maps
));
539 if (load_maps(map_data
, nr_maps
, fixup_map
))
541 map_data_count
= nr_maps
;
543 processed_sec
[maps_shndx
] = true;
546 /* process all relo sections, and rewrite bpf insns for maps */
547 for (i
= 1; i
< ehdr
.e_shnum
; i
++) {
548 if (processed_sec
[i
])
551 if (get_sec(elf
, i
, &ehdr
, &shname
, &shdr
, &data
))
554 if (shdr
.sh_type
== SHT_REL
) {
555 struct bpf_insn
*insns
;
557 /* locate prog sec that need map fixup (relocations) */
558 if (get_sec(elf
, shdr
.sh_info
, &ehdr
, &shname_prog
,
559 &shdr_prog
, &data_prog
))
562 if (shdr_prog
.sh_type
!= SHT_PROGBITS
||
563 !(shdr_prog
.sh_flags
& SHF_EXECINSTR
))
566 insns
= (struct bpf_insn
*) data_prog
->d_buf
;
567 processed_sec
[i
] = true; /* relo section */
569 if (parse_relo_and_apply(data
, symbols
, &shdr
, insns
,
576 for (i
= 1; i
< ehdr
.e_shnum
; i
++) {
578 if (processed_sec
[i
])
581 if (get_sec(elf
, i
, &ehdr
, &shname
, &shdr
, &data
))
584 if (memcmp(shname
, "kprobe/", 7) == 0 ||
585 memcmp(shname
, "kretprobe/", 10) == 0 ||
586 memcmp(shname
, "tracepoint/", 11) == 0 ||
587 memcmp(shname
, "xdp", 3) == 0 ||
588 memcmp(shname
, "perf_event", 10) == 0 ||
589 memcmp(shname
, "socket", 6) == 0 ||
590 memcmp(shname
, "cgroup/", 7) == 0 ||
591 memcmp(shname
, "sockops", 7) == 0 ||
592 memcmp(shname
, "sk_skb", 6) == 0) {
593 ret
= load_and_attach(shname
, data
->d_buf
,
606 int load_bpf_file(char *path
)
608 return do_load_bpf_file(path
, NULL
);
611 int load_bpf_file_fixup_map(const char *path
, fixup_map_cb fixup_map
)
613 return do_load_bpf_file(path
, fixup_map
);
616 void read_trace_pipe(void)
620 trace_fd
= open(DEBUGFS
"trace_pipe", O_RDONLY
, 0);
625 static char buf
[4096];
628 sz
= read(trace_fd
, buf
, sizeof(buf
));
636 #define MAX_SYMS 300000
637 static struct ksym syms
[MAX_SYMS
];
640 static int ksym_cmp(const void *p1
, const void *p2
)
642 return ((struct ksym
*)p1
)->addr
- ((struct ksym
*)p2
)->addr
;
645 int load_kallsyms(void)
647 FILE *f
= fopen("/proc/kallsyms", "r");
648 char func
[256], buf
[256];
657 if (!fgets(buf
, sizeof(buf
), f
))
659 if (sscanf(buf
, "%p %c %s", &addr
, &symbol
, func
) != 3)
663 syms
[i
].addr
= (long) addr
;
664 syms
[i
].name
= strdup(func
);
668 qsort(syms
, sym_cnt
, sizeof(struct ksym
), ksym_cmp
);
672 struct ksym
*ksym_search(long key
)
674 int start
= 0, end
= sym_cnt
;
677 while (start
< end
) {
678 size_t mid
= start
+ (end
- start
) / 2;
680 result
= key
- syms
[mid
].addr
;
689 if (start
>= 1 && syms
[start
- 1].addr
< key
&&
690 key
< syms
[start
].addr
)
692 return &syms
[start
- 1];
694 /* out of range. return _stext */