提交 23316a36 编写于 作者: Y Yonghong Song 提交者: Daniel Borkmann

tools/bpf: fix selftest get_cgroup_id_user

Commit f269099a ("tools/bpf: add a selftest for
bpf_get_current_cgroup_id() helper") added a test
for bpf_get_current_cgroup_id() helper. The bpf program
is attached to tracepoint syscalls/sys_enter_nanosleep
and will record the cgroup id if the tracepoint is hit.
The test program creates a cgroup and attachs itself to
this cgroup and expects that the test program process
cgroup id is the same as the cgroup_id retrieved
by the bpf program.

In a light system where no other processes called
nanosleep syscall, the test case can pass.
In a busy system where many different processes can hit
syscalls/sys_enter_nanosleep tracepoint, the cgroup id
recorded by bpf program may not match the test program
process cgroup_id.

This patch fixed an issue by communicating the test program
pid to bpf program. The bpf program only records
cgroup id if the current task pid is the same as
passed-in pid. This ensures that the recorded cgroup_id
is for the cgroup within which the test program resides.

Fixes: f269099a ("tools/bpf: add a selftest for bpf_get_current_cgroup_id() helper")
Signed-off-by: NYonghong Song <yhs@fb.com>
Signed-off-by: NDaniel Borkmann <daniel@iogearbox.net>
上级 58990d1f
...@@ -11,12 +11,24 @@ struct bpf_map_def SEC("maps") cg_ids = { ...@@ -11,12 +11,24 @@ struct bpf_map_def SEC("maps") cg_ids = {
.max_entries = 1, .max_entries = 1,
}; };
struct bpf_map_def SEC("maps") pidmap = {
.type = BPF_MAP_TYPE_ARRAY,
.key_size = sizeof(__u32),
.value_size = sizeof(__u32),
.max_entries = 1,
};
SEC("tracepoint/syscalls/sys_enter_nanosleep") SEC("tracepoint/syscalls/sys_enter_nanosleep")
int trace(void *ctx) int trace(void *ctx)
{ {
__u32 key = 0; __u32 pid = bpf_get_current_pid_tgid();
__u32 key = 0, *expected_pid;
__u64 *val; __u64 *val;
expected_pid = bpf_map_lookup_elem(&pidmap, &key);
if (!expected_pid || *expected_pid != pid)
return 0;
val = bpf_map_lookup_elem(&cg_ids, &key); val = bpf_map_lookup_elem(&cg_ids, &key);
if (val) if (val)
*val = bpf_get_current_cgroup_id(); *val = bpf_get_current_cgroup_id();
......
...@@ -50,13 +50,13 @@ int main(int argc, char **argv) ...@@ -50,13 +50,13 @@ int main(int argc, char **argv)
const char *probe_name = "syscalls/sys_enter_nanosleep"; const char *probe_name = "syscalls/sys_enter_nanosleep";
const char *file = "get_cgroup_id_kern.o"; const char *file = "get_cgroup_id_kern.o";
int err, bytes, efd, prog_fd, pmu_fd; int err, bytes, efd, prog_fd, pmu_fd;
int cgroup_fd, cgidmap_fd, pidmap_fd;
struct perf_event_attr attr = {}; struct perf_event_attr attr = {};
int cgroup_fd, cgidmap_fd;
struct bpf_object *obj; struct bpf_object *obj;
__u64 kcgid = 0, ucgid; __u64 kcgid = 0, ucgid;
__u32 key = 0, pid;
int exit_code = 1; int exit_code = 1;
char buf[256]; char buf[256];
__u32 key = 0;
err = setup_cgroup_environment(); err = setup_cgroup_environment();
if (CHECK(err, "setup_cgroup_environment", "err %d errno %d\n", err, if (CHECK(err, "setup_cgroup_environment", "err %d errno %d\n", err,
...@@ -81,6 +81,14 @@ int main(int argc, char **argv) ...@@ -81,6 +81,14 @@ int main(int argc, char **argv)
cgidmap_fd, errno)) cgidmap_fd, errno))
goto close_prog; goto close_prog;
pidmap_fd = bpf_find_map(__func__, obj, "pidmap");
if (CHECK(pidmap_fd < 0, "bpf_find_map", "err %d errno %d\n",
pidmap_fd, errno))
goto close_prog;
pid = getpid();
bpf_map_update_elem(pidmap_fd, &key, &pid, 0);
snprintf(buf, sizeof(buf), snprintf(buf, sizeof(buf),
"/sys/kernel/debug/tracing/events/%s/id", probe_name); "/sys/kernel/debug/tracing/events/%s/id", probe_name);
efd = open(buf, O_RDONLY, 0); efd = open(buf, O_RDONLY, 0);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册