blob: 825f29f93a57a960d742f55e0d7e143721fd3fc8 [file] [log] [blame]
Jakub Kicinski907b2232018-12-12 19:59:26 -08001// SPDX-License-Identifier: (GPL-2.0-only OR BSD-2-Clause)
Jakub Kicinskif412eed2018-05-03 18:37:16 -07002/* Copyright (C) 2018 Netronome Systems, Inc. */
3/* This program is free software; you can redistribute it and/or
4 * modify it under the terms of version 2 of the GNU General Public
5 * License as published by the Free Software Foundation.
6 */
7#include <errno.h>
8#include <fcntl.h>
Toke Høiland-Jørgensen229c3b42020-01-20 14:06:46 +01009#include <bpf/libbpf.h>
Jakub Kicinskif412eed2018-05-03 18:37:16 -070010#include <poll.h>
11#include <signal.h>
12#include <stdbool.h>
13#include <stdio.h>
14#include <stdlib.h>
15#include <string.h>
16#include <time.h>
17#include <unistd.h>
18#include <linux/bpf.h>
19#include <linux/perf_event.h>
20#include <sys/ioctl.h>
21#include <sys/mman.h>
22#include <sys/syscall.h>
23
Toke Høiland-Jørgensen229c3b42020-01-20 14:06:46 +010024#include <bpf/bpf.h>
Jakub Kicinskif412eed2018-05-03 18:37:16 -070025#include <perf-sys.h>
26
27#include "main.h"
28
29#define MMAP_PAGE_CNT 16
30
Andrii Nakryiko9b190f12019-07-06 11:06:27 -070031static volatile bool stop;
Jakub Kicinskif412eed2018-05-03 18:37:16 -070032
33struct event_ring_info {
34 int fd;
35 int key;
36 unsigned int cpu;
37 void *mem;
38};
39
40struct perf_event_sample {
41 struct perf_event_header header;
Quentin Monnet6e7e0342020-05-11 17:15:33 +010042 __u64 time;
Jakub Kicinskif412eed2018-05-03 18:37:16 -070043 __u32 size;
44 unsigned char data[];
45};
46
Andrii Nakryiko9b190f12019-07-06 11:06:27 -070047struct perf_event_lost {
48 struct perf_event_header header;
49 __u64 id;
50 __u64 lost;
51};
52
Jakub Kicinskif412eed2018-05-03 18:37:16 -070053static void int_exit(int signo)
54{
55 fprintf(stderr, "Stopping...\n");
56 stop = true;
57}
58
Andrii Nakryiko9b190f12019-07-06 11:06:27 -070059struct event_pipe_ctx {
60 bool all_cpus;
61 int cpu;
62 int idx;
63};
64
Daniel Borkmann3dca2112018-10-21 02:09:28 +020065static enum bpf_perf_event_ret
Andrii Nakryiko9b190f12019-07-06 11:06:27 -070066print_bpf_output(void *private_data, int cpu, struct perf_event_header *event)
Jakub Kicinskif412eed2018-05-03 18:37:16 -070067{
Andrii Nakryiko9b190f12019-07-06 11:06:27 -070068 struct perf_event_sample *e = container_of(event,
69 struct perf_event_sample,
Daniel Borkmann3dca2112018-10-21 02:09:28 +020070 header);
Andrii Nakryiko9b190f12019-07-06 11:06:27 -070071 struct perf_event_lost *lost = container_of(event,
72 struct perf_event_lost,
73 header);
74 struct event_pipe_ctx *ctx = private_data;
75 int idx = ctx->all_cpus ? cpu : ctx->idx;
Jakub Kicinskif412eed2018-05-03 18:37:16 -070076
77 if (json_output) {
78 jsonw_start_object(json_wtr);
Jakub Kicinskif412eed2018-05-03 18:37:16 -070079 jsonw_name(json_wtr, "type");
80 jsonw_uint(json_wtr, e->header.type);
81 jsonw_name(json_wtr, "cpu");
Andrii Nakryiko9b190f12019-07-06 11:06:27 -070082 jsonw_uint(json_wtr, cpu);
Jakub Kicinskif412eed2018-05-03 18:37:16 -070083 jsonw_name(json_wtr, "index");
Andrii Nakryiko9b190f12019-07-06 11:06:27 -070084 jsonw_uint(json_wtr, idx);
Jakub Kicinskif412eed2018-05-03 18:37:16 -070085 if (e->header.type == PERF_RECORD_SAMPLE) {
Jakub Kicinskie3687512018-05-10 10:24:37 -070086 jsonw_name(json_wtr, "timestamp");
87 jsonw_uint(json_wtr, e->time);
Jakub Kicinskif412eed2018-05-03 18:37:16 -070088 jsonw_name(json_wtr, "data");
89 print_data_json(e->data, e->size);
90 } else if (e->header.type == PERF_RECORD_LOST) {
91 jsonw_name(json_wtr, "lost");
92 jsonw_start_object(json_wtr);
93 jsonw_name(json_wtr, "id");
94 jsonw_uint(json_wtr, lost->id);
95 jsonw_name(json_wtr, "count");
96 jsonw_uint(json_wtr, lost->lost);
97 jsonw_end_object(json_wtr);
98 }
99 jsonw_end_object(json_wtr);
100 } else {
101 if (e->header.type == PERF_RECORD_SAMPLE) {
Jakub Kicinskie3687512018-05-10 10:24:37 -0700102 printf("== @%lld.%09lld CPU: %d index: %d =====\n",
103 e->time / 1000000000ULL, e->time % 1000000000ULL,
Andrii Nakryiko9b190f12019-07-06 11:06:27 -0700104 cpu, idx);
Jakub Kicinskif412eed2018-05-03 18:37:16 -0700105 fprint_hex(stdout, e->data, e->size, " ");
106 printf("\n");
107 } else if (e->header.type == PERF_RECORD_LOST) {
108 printf("lost %lld events\n", lost->lost);
109 } else {
110 printf("unknown event type=%d size=%d\n",
111 e->header.type, e->header.size);
112 }
113 }
Jakub Kicinskid0cabbb2018-05-10 10:24:40 -0700114
115 return LIBBPF_PERF_EVENT_CONT;
Jakub Kicinskif412eed2018-05-03 18:37:16 -0700116}
117
Andrii Nakryiko9b190f12019-07-06 11:06:27 -0700118int do_event_pipe(int argc, char **argv)
Jakub Kicinskif412eed2018-05-03 18:37:16 -0700119{
Andrii Nakryiko9b190f12019-07-06 11:06:27 -0700120 struct perf_event_attr perf_attr = {
Jakub Kicinskie3687512018-05-10 10:24:37 -0700121 .sample_type = PERF_SAMPLE_RAW | PERF_SAMPLE_TIME,
Jakub Kicinskif412eed2018-05-03 18:37:16 -0700122 .type = PERF_TYPE_SOFTWARE,
123 .config = PERF_COUNT_SW_BPF_OUTPUT,
Andrii Nakryiko9b190f12019-07-06 11:06:27 -0700124 .sample_period = 1,
125 .wakeup_events = 1,
Jakub Kicinskif412eed2018-05-03 18:37:16 -0700126 };
Jakub Kicinskif412eed2018-05-03 18:37:16 -0700127 struct bpf_map_info map_info = {};
Andrii Nakryiko9b190f12019-07-06 11:06:27 -0700128 struct perf_buffer_raw_opts opts = {};
129 struct event_pipe_ctx ctx = {
130 .all_cpus = true,
131 .cpu = -1,
132 .idx = -1,
133 };
134 struct perf_buffer *pb;
Jakub Kicinskif412eed2018-05-03 18:37:16 -0700135 __u32 map_info_len;
Andrii Nakryiko9b190f12019-07-06 11:06:27 -0700136 int err, map_fd;
Jakub Kicinskif412eed2018-05-03 18:37:16 -0700137
138 map_info_len = sizeof(map_info);
139 map_fd = map_parse_fd_and_info(&argc, &argv, &map_info, &map_info_len);
140 if (map_fd < 0)
141 return -1;
142
143 if (map_info.type != BPF_MAP_TYPE_PERF_EVENT_ARRAY) {
144 p_err("map is not a perf event array");
145 goto err_close_map;
146 }
147
148 while (argc) {
Quentin Monnet785e76d2018-08-23 17:46:25 +0100149 if (argc < 2) {
Jakub Kicinskif412eed2018-05-03 18:37:16 -0700150 BAD_ARG();
Quentin Monnet785e76d2018-08-23 17:46:25 +0100151 goto err_close_map;
152 }
Jakub Kicinskif412eed2018-05-03 18:37:16 -0700153
154 if (is_prefix(*argv, "cpu")) {
155 char *endptr;
156
157 NEXT_ARG();
Andrii Nakryiko9b190f12019-07-06 11:06:27 -0700158 ctx.cpu = strtoul(*argv, &endptr, 0);
Jakub Kicinskif412eed2018-05-03 18:37:16 -0700159 if (*endptr) {
Quentin Monnet9def2492019-08-15 15:32:15 +0100160 p_err("can't parse %s as CPU ID", *argv);
Jakub Kicinskif412eed2018-05-03 18:37:16 -0700161 goto err_close_map;
162 }
163
164 NEXT_ARG();
165 } else if (is_prefix(*argv, "index")) {
166 char *endptr;
167
168 NEXT_ARG();
Andrii Nakryiko9b190f12019-07-06 11:06:27 -0700169 ctx.idx = strtoul(*argv, &endptr, 0);
Jakub Kicinskif412eed2018-05-03 18:37:16 -0700170 if (*endptr) {
Quentin Monnet9def2492019-08-15 15:32:15 +0100171 p_err("can't parse %s as index", *argv);
Jakub Kicinskif412eed2018-05-03 18:37:16 -0700172 goto err_close_map;
173 }
174
175 NEXT_ARG();
176 } else {
177 BAD_ARG();
Quentin Monnet785e76d2018-08-23 17:46:25 +0100178 goto err_close_map;
Jakub Kicinskif412eed2018-05-03 18:37:16 -0700179 }
180
Andrii Nakryiko9b190f12019-07-06 11:06:27 -0700181 ctx.all_cpus = false;
Jakub Kicinskif412eed2018-05-03 18:37:16 -0700182 }
183
Andrii Nakryiko9b190f12019-07-06 11:06:27 -0700184 if (!ctx.all_cpus) {
185 if (ctx.idx == -1 || ctx.cpu == -1) {
Jakub Kicinskif412eed2018-05-03 18:37:16 -0700186 p_err("cpu and index must be specified together");
187 goto err_close_map;
188 }
Jakub Kicinskif412eed2018-05-03 18:37:16 -0700189 } else {
Andrii Nakryiko9b190f12019-07-06 11:06:27 -0700190 ctx.cpu = 0;
191 ctx.idx = 0;
Jakub Kicinskif412eed2018-05-03 18:37:16 -0700192 }
193
Andrii Nakryiko9b190f12019-07-06 11:06:27 -0700194 opts.attr = &perf_attr;
195 opts.event_cb = print_bpf_output;
196 opts.ctx = &ctx;
197 opts.cpu_cnt = ctx.all_cpus ? 0 : 1;
198 opts.cpus = &ctx.cpu;
199 opts.map_keys = &ctx.idx;
200
201 pb = perf_buffer__new_raw(map_fd, MMAP_PAGE_CNT, &opts);
202 err = libbpf_get_error(pb);
203 if (err) {
204 p_err("failed to create perf buffer: %s (%d)",
205 strerror(err), err);
Jakub Kicinskif412eed2018-05-03 18:37:16 -0700206 goto err_close_map;
Jakub Kicinskif412eed2018-05-03 18:37:16 -0700207 }
208
209 signal(SIGINT, int_exit);
210 signal(SIGHUP, int_exit);
211 signal(SIGTERM, int_exit);
212
213 if (json_output)
214 jsonw_start_array(json_wtr);
215
216 while (!stop) {
Andrii Nakryiko9b190f12019-07-06 11:06:27 -0700217 err = perf_buffer__poll(pb, 200);
218 if (err < 0 && err != -EINTR) {
219 p_err("perf buffer polling failed: %s (%d)",
220 strerror(err), err);
221 goto err_close_pb;
222 }
Jakub Kicinskif412eed2018-05-03 18:37:16 -0700223 }
Jakub Kicinskif412eed2018-05-03 18:37:16 -0700224
225 if (json_output)
226 jsonw_end_array(json_wtr);
227
Andrii Nakryiko9b190f12019-07-06 11:06:27 -0700228 perf_buffer__free(pb);
Jakub Kicinskif412eed2018-05-03 18:37:16 -0700229 close(map_fd);
230
231 return 0;
232
Andrii Nakryiko9b190f12019-07-06 11:06:27 -0700233err_close_pb:
234 perf_buffer__free(pb);
Jakub Kicinskif412eed2018-05-03 18:37:16 -0700235err_close_map:
236 close(map_fd);
237 return -1;
238}