mirror of
https://github.com/AuxXxilium/linux_dsm_epyc7002.git
synced 2024-11-24 03:00:54 +07:00
bpf, selftests: Use single cgroup helpers for both test_sockmap/progs
Nearly every user of cgroup helpers does the same sequence of API calls. So push these into a single helper cgroup_setup_and_join. The cases that do a bit of extra logic are test_progs which currently uses an env variable to decide if it needs to setup the cgroup environment or can use an existingi environment. And then tests that are doing cgroup tests themselves. We skip these cases for now. Signed-off-by: John Fastabend <john.fastabend@gmail.com> Signed-off-by: Alexei Starovoitov <ast@kernel.org> Acked-by: Andrii Nakryiko <andriin@fb.com> Link: https://lore.kernel.org/bpf/159623335418.30208.15807461815525100199.stgit@john-XPS-13-9370
This commit is contained in:
parent
ffba964e4d
commit
4939b2847d
@ -290,3 +290,26 @@ unsigned long long get_cgroup_id(const char *path)
|
||||
free(fhp);
|
||||
return ret;
|
||||
}
|
||||
|
||||
int cgroup_setup_and_join(const char *path) {
|
||||
int cg_fd;
|
||||
|
||||
if (setup_cgroup_environment()) {
|
||||
fprintf(stderr, "Failed to setup cgroup environment\n");
|
||||
return -EINVAL;
|
||||
}
|
||||
|
||||
cg_fd = create_and_get_cgroup(path);
|
||||
if (cg_fd < 0) {
|
||||
fprintf(stderr, "Failed to create test cgroup\n");
|
||||
cleanup_cgroup_environment();
|
||||
return cg_fd;
|
||||
}
|
||||
|
||||
if (join_cgroup(path)) {
|
||||
fprintf(stderr, "Failed to join cgroup\n");
|
||||
cleanup_cgroup_environment();
|
||||
return -EINVAL;
|
||||
}
|
||||
return cg_fd;
|
||||
}
|
||||
|
@ -9,6 +9,7 @@
|
||||
__FILE__, __LINE__, clean_errno(), ##__VA_ARGS__)
|
||||
|
||||
|
||||
int cgroup_setup_and_join(const char *path);
|
||||
int create_and_get_cgroup(const char *path);
|
||||
int join_cgroup(const char *path);
|
||||
int setup_cgroup_environment(void);
|
||||
|
@ -58,20 +58,10 @@ int main(int argc, char **argv)
|
||||
int exit_code = 1;
|
||||
char buf[256];
|
||||
|
||||
err = setup_cgroup_environment();
|
||||
if (CHECK(err, "setup_cgroup_environment", "err %d errno %d\n", err,
|
||||
errno))
|
||||
cgroup_fd = cgroup_setup_and_join(TEST_CGROUP);
|
||||
if (CHECK(cgroup_fd < 0, "cgroup_setup_and_join", "err %d errno %d\n", cgroup_fd, errno))
|
||||
return 1;
|
||||
|
||||
cgroup_fd = create_and_get_cgroup(TEST_CGROUP);
|
||||
if (CHECK(cgroup_fd < 0, "create_and_get_cgroup", "err %d errno %d\n",
|
||||
cgroup_fd, errno))
|
||||
goto cleanup_cgroup_env;
|
||||
|
||||
err = join_cgroup(TEST_CGROUP);
|
||||
if (CHECK(err, "join_cgroup", "err %d errno %d\n", err, errno))
|
||||
goto cleanup_cgroup_env;
|
||||
|
||||
err = bpf_prog_load(file, BPF_PROG_TYPE_TRACEPOINT, &obj, &prog_fd);
|
||||
if (CHECK(err, "bpf_prog_load", "err %d errno %d\n", err, errno))
|
||||
goto cleanup_cgroup_env;
|
||||
|
@ -74,22 +74,7 @@ int main(int argc, char **argv)
|
||||
goto out;
|
||||
}
|
||||
|
||||
if (setup_cgroup_environment()) {
|
||||
printf("Failed to setup cgroup environment\n");
|
||||
goto err;
|
||||
}
|
||||
|
||||
/* Create a cgroup, get fd, and join it */
|
||||
cgroup_fd = create_and_get_cgroup(TEST_CGROUP);
|
||||
if (cgroup_fd < 0) {
|
||||
printf("Failed to create test cgroup\n");
|
||||
goto err;
|
||||
}
|
||||
|
||||
if (join_cgroup(TEST_CGROUP)) {
|
||||
printf("Failed to join cgroup\n");
|
||||
goto err;
|
||||
}
|
||||
cgroup_fd = cgroup_setup_and_join(TEST_CGROUP);
|
||||
|
||||
/* Attach the bpf program */
|
||||
if (bpf_prog_attach(prog_fd, cgroup_fd, BPF_CGROUP_INET_EGRESS, 0)) {
|
||||
|
@ -33,21 +33,10 @@ int main(int argc, char **argv)
|
||||
goto out;
|
||||
}
|
||||
|
||||
if (setup_cgroup_environment()) {
|
||||
printf("Failed to load DEV_CGROUP program\n");
|
||||
goto err;
|
||||
}
|
||||
|
||||
/* Create a cgroup, get fd, and join it */
|
||||
cgroup_fd = create_and_get_cgroup(TEST_CGROUP);
|
||||
cgroup_fd = cgroup_setup_and_join(TEST_CGROUP);
|
||||
if (cgroup_fd < 0) {
|
||||
printf("Failed to create test cgroup\n");
|
||||
goto err;
|
||||
}
|
||||
|
||||
if (join_cgroup(TEST_CGROUP)) {
|
||||
printf("Failed to join cgroup\n");
|
||||
goto err;
|
||||
goto out;
|
||||
}
|
||||
|
||||
/* Attach bpf program */
|
||||
|
@ -58,22 +58,9 @@ int main(int argc, char **argv)
|
||||
goto out;
|
||||
}
|
||||
|
||||
if (setup_cgroup_environment()) {
|
||||
printf("Failed to load bpf program\n");
|
||||
cgroup_fd = cgroup_setup_and_join(TEST_CGROUP);
|
||||
if (cgroup_fd < 0)
|
||||
goto err;
|
||||
}
|
||||
|
||||
/* Create a cgroup, get fd, and join it */
|
||||
cgroup_fd = create_and_get_cgroup(TEST_CGROUP);
|
||||
if (cgroup_fd < 0) {
|
||||
printf("Failed to create test cgroup\n");
|
||||
goto err;
|
||||
}
|
||||
|
||||
if (join_cgroup(TEST_CGROUP)) {
|
||||
printf("Failed to join cgroup\n");
|
||||
goto err;
|
||||
}
|
||||
|
||||
/* Attach bpf program */
|
||||
if (bpf_prog_attach(prog_fd, cgroup_fd, BPF_CGROUP_INET_EGRESS, 0)) {
|
||||
|
@ -160,16 +160,10 @@ int main(int argc, char **argv)
|
||||
exit(EXIT_FAILURE);
|
||||
}
|
||||
|
||||
if (setup_cgroup_environment())
|
||||
goto err;
|
||||
|
||||
cgfd = create_and_get_cgroup(CGROUP_PATH);
|
||||
cgfd = cgroup_setup_and_join(CGROUP_PATH);
|
||||
if (cgfd < 0)
|
||||
goto err;
|
||||
|
||||
if (join_cgroup(CGROUP_PATH))
|
||||
goto err;
|
||||
|
||||
if (send_packet(argv[1]))
|
||||
goto err;
|
||||
|
||||
|
@ -464,16 +464,10 @@ int main(int argc, char **argv)
|
||||
int cgfd = -1;
|
||||
int err = 0;
|
||||
|
||||
if (setup_cgroup_environment())
|
||||
goto err;
|
||||
|
||||
cgfd = create_and_get_cgroup(CG_PATH);
|
||||
cgfd = cgroup_setup_and_join(CG_PATH);
|
||||
if (cgfd < 0)
|
||||
goto err;
|
||||
|
||||
if (join_cgroup(CG_PATH))
|
||||
goto err;
|
||||
|
||||
if (run_tests(cgfd))
|
||||
goto err;
|
||||
|
||||
|
@ -1638,16 +1638,10 @@ int main(int argc, char **argv)
|
||||
exit(err);
|
||||
}
|
||||
|
||||
if (setup_cgroup_environment())
|
||||
goto err;
|
||||
|
||||
cgfd = create_and_get_cgroup(CG_PATH);
|
||||
cgfd = cgroup_setup_and_join(CG_PATH);
|
||||
if (cgfd < 0)
|
||||
goto err;
|
||||
|
||||
if (join_cgroup(CG_PATH))
|
||||
goto err;
|
||||
|
||||
if (run_tests(cgfd))
|
||||
goto err;
|
||||
|
||||
|
@ -421,19 +421,11 @@ int main(int argc, char **argv)
|
||||
struct bpf_object *obj;
|
||||
struct bpf_map *map;
|
||||
|
||||
err = setup_cgroup_environment();
|
||||
CHECK(err, "setup_cgroup_environment()", "err:%d errno:%d",
|
||||
err, errno);
|
||||
|
||||
atexit(cleanup_cgroup_environment);
|
||||
|
||||
/* Create a cgroup, get fd, and join it */
|
||||
cgroup_fd = create_and_get_cgroup(TEST_CGROUP);
|
||||
CHECK(cgroup_fd == -1, "create_and_get_cgroup()",
|
||||
cgroup_fd = cgroup_setup_and_join(TEST_CGROUP);
|
||||
CHECK(cgroup_fd < 0, "cgroup_setup_and_join()",
|
||||
"cgroup_fd:%d errno:%d", cgroup_fd, errno);
|
||||
|
||||
err = join_cgroup(TEST_CGROUP);
|
||||
CHECK(err, "join_cgroup", "err:%d errno:%d", err, errno);
|
||||
atexit(cleanup_cgroup_environment);
|
||||
|
||||
err = bpf_prog_load_xattr(&attr, &obj, &egress_fd);
|
||||
CHECK(err, "bpf_prog_load_xattr()", "err:%d", err);
|
||||
|
@ -191,16 +191,10 @@ int main(int argc, char **argv)
|
||||
int cgfd = -1;
|
||||
int err = 0;
|
||||
|
||||
if (setup_cgroup_environment())
|
||||
goto err;
|
||||
|
||||
cgfd = create_and_get_cgroup(CG_PATH);
|
||||
cgfd = cgroup_setup_and_join(CG_PATH);
|
||||
if (cgfd < 0)
|
||||
goto err;
|
||||
|
||||
if (join_cgroup(CG_PATH))
|
||||
goto err;
|
||||
|
||||
if (run_test(cgfd))
|
||||
goto err;
|
||||
|
||||
|
@ -1963,23 +1963,9 @@ int main(int argc, char **argv)
|
||||
}
|
||||
|
||||
if (!cg_fd) {
|
||||
if (setup_cgroup_environment()) {
|
||||
fprintf(stderr, "ERROR: cgroup env failed\n");
|
||||
return -EINVAL;
|
||||
}
|
||||
|
||||
cg_fd = create_and_get_cgroup(CG_PATH);
|
||||
if (cg_fd < 0) {
|
||||
fprintf(stderr,
|
||||
"ERROR: (%i) open cg path failed: %s\n",
|
||||
cg_fd, strerror(errno));
|
||||
cg_fd = cgroup_setup_and_join(CG_PATH);
|
||||
if (cg_fd < 0)
|
||||
return cg_fd;
|
||||
}
|
||||
|
||||
if (join_cgroup(CG_PATH)) {
|
||||
fprintf(stderr, "ERROR: failed to join cgroup\n");
|
||||
return -EINVAL;
|
||||
}
|
||||
cg_created = 1;
|
||||
}
|
||||
|
||||
|
@ -1619,16 +1619,10 @@ int main(int argc, char **argv)
|
||||
int cgfd = -1;
|
||||
int err = 0;
|
||||
|
||||
if (setup_cgroup_environment())
|
||||
goto err;
|
||||
|
||||
cgfd = create_and_get_cgroup(CG_PATH);
|
||||
cgfd = cgroup_setup_and_join(CG_PATH);
|
||||
if (cgfd < 0)
|
||||
goto err;
|
||||
|
||||
if (join_cgroup(CG_PATH))
|
||||
goto err;
|
||||
|
||||
if (run_tests(cgfd))
|
||||
goto err;
|
||||
|
||||
|
@ -102,16 +102,10 @@ int main(int argc, char **argv)
|
||||
__u32 key = 0;
|
||||
int rv;
|
||||
|
||||
if (setup_cgroup_environment())
|
||||
goto err;
|
||||
|
||||
cg_fd = create_and_get_cgroup(cg_path);
|
||||
cg_fd = cgroup_setup_and_join(cg_path);
|
||||
if (cg_fd < 0)
|
||||
goto err;
|
||||
|
||||
if (join_cgroup(cg_path))
|
||||
goto err;
|
||||
|
||||
if (bpf_prog_load(file, BPF_PROG_TYPE_SOCK_OPS, &obj, &prog_fd)) {
|
||||
printf("FAILED: load_bpf_file failed for: %s\n", file);
|
||||
goto err;
|
||||
|
@ -86,16 +86,10 @@ int main(int argc, char **argv)
|
||||
CPU_SET(0, &cpuset);
|
||||
pthread_setaffinity_np(pthread_self(), sizeof(cpu_set_t), &cpuset);
|
||||
|
||||
if (setup_cgroup_environment())
|
||||
goto err;
|
||||
|
||||
cg_fd = create_and_get_cgroup(cg_path);
|
||||
cg_fd = cgroup_setup_and_join(cg_path);
|
||||
if (cg_fd < 0)
|
||||
goto err;
|
||||
|
||||
if (join_cgroup(cg_path))
|
||||
goto err;
|
||||
|
||||
if (bpf_prog_load(file, BPF_PROG_TYPE_SOCK_OPS, &obj, &prog_fd)) {
|
||||
printf("FAILED: load_bpf_file failed for: %s\n", file);
|
||||
goto err;
|
||||
|
Loading…
Reference in New Issue
Block a user