mirror/xdp-project-bpf-examples
1
0
Fork 0
mirror of https://github.com/xdp-project/bpf-examples.git synced 2024-05-06 15:54:53 +00:00
Code Issues Projects Releases Wiki Activity

tc-policy: Be more verbose, but add --quiet option

Browse Source 
Signed-off-by: Jesper Dangaard Brouer <brouer@redhat.com>
This commit is contained in:
Jesper Dangaard Brouer
2022-01-31 17:29:52 +01:00
parent 78515fdd2e
commit a00ed96ed6
1 changed files with 26 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
tc-policy/tc_txq_policy.c
View File

@ -27,6 +27,7 @@ static const struct option long_options[] = {
{ "interface", required_argument, NULL, 'i' }, { "interface", required_argument, NULL, 'i' },
{ "unload", no_argument, NULL, 'u' }, { "unload", no_argument, NULL, 'u' },
{ "destroy-hook", no_argument, NULL, 'f' }, { "destroy-hook", no_argument, NULL, 'f' },
{ "quiet", no_argument, NULL, 'q' },
{ 0, 0, NULL, 0 } { 0, 0, NULL, 0 }
}; };
@ -72,7 +73,7 @@ static int parse_arguments(int argc, char *argv[],
cfg->ifindex = 0; cfg->ifindex = 0;
while ((opt = getopt_long(argc, argv, "i:hu", long_options, while ((opt = getopt_long(argc, argv, "i:hufq", long_options,
NULL)) != -1) { NULL)) != -1) {
switch (opt) { switch (opt) {
case 'i': case 'i':
@ -97,6 +98,9 @@ static int parse_arguments(int argc, char *argv[],
case 'f': case 'f':
cfg->flush_hook = true; cfg->flush_hook = true;
break; break;
case 'q':
verbose = 0;
break;
default: default:
print_usage(argv); print_usage(argv);
fprintf(stderr, "Unknown option %s\n", argv[optind]); fprintf(stderr, "Unknown option %s\n", argv[optind]);
@ -221,6 +225,10 @@ int tc_attach_egress(struct user_config *cfg, struct tc_txq_policy_kern *obj)
"ifindex %d (err:%d)\n", cfg->ifindex, err); "ifindex %d (err:%d)\n", cfg->ifindex, err);
goto out; goto out;
} }
if (verbose && err == -EEXIST) {
printf("Success: TC-BPF hook already existed "
"(Ignore: \"libbpf: Kernel error message\")\n");
}
hook.attach_point = BPF_TC_EGRESS; hook.attach_point = BPF_TC_EGRESS;
attach_egress.flags = BPF_TC_F_REPLACE; attach_egress.flags = BPF_TC_F_REPLACE;
@ -233,6 +241,23 @@ int tc_attach_egress(struct user_config *cfg, struct tc_txq_policy_kern *obj)
goto out; goto out;
} }
/* Let check BPF prog got attached */
attach_egress.flags = 0;
attach_egress.prog_fd = 0;
attach_egress.prog_id = 0;
attach_egress.handle = EGRESS_HANDLE;
attach_egress.priority = EGRESS_PRIORITY;
err = bpf_tc_query(&hook, &attach_egress);
if (err) {
fprintf(stderr, "No egress program is attached "
"for ifindex %d (err:%d)\n", cfg->ifindex, err);
goto out;
}
if (verbose) {
printf("Attached TC-BPF program id:%d\n",
attach_egress.prog_id);
}
out: out:
return err; return err;
} }