xsk_reattach_xdp calls exit_on_error() on failures. This exits the
program immediately and can lead to memory leaks.

Add a return value to the functions handling XDP attachments to handle
errors more smoothly.

Signed-off-by: Bastien Curutchet (eBPF Foundation) 
<bastien.curutc...@bootlin.com>
---
 tools/testing/selftests/bpf/xskxceiver.c | 28 +++++++++++++++++++---------
 1 file changed, 19 insertions(+), 9 deletions(-)

diff --git a/tools/testing/selftests/bpf/xskxceiver.c 
b/tools/testing/selftests/bpf/xskxceiver.c
index 
01a0ddbf1cf52760a4a4d168da2fec1859e6b4b8..e2c136fc23ce40ff485de78dac18a4d8ba73353d
 100644
--- a/tools/testing/selftests/bpf/xskxceiver.c
+++ b/tools/testing/selftests/bpf/xskxceiver.c
@@ -1834,7 +1834,7 @@ static bool xdp_prog_changed_tx(struct test_spec *test)
        return ifobj->xdp_prog != test->xdp_prog_tx || ifobj->mode != 
test->mode;
 }
 
-static void xsk_reattach_xdp(struct ifobject *ifobj, struct bpf_program 
*xdp_prog,
+static int xsk_reattach_xdp(struct ifobject *ifobj, struct bpf_program 
*xdp_prog,
                             struct bpf_map *xskmap, enum test_mode mode)
 {
        int err;
@@ -1843,31 +1843,40 @@ static void xsk_reattach_xdp(struct ifobject *ifobj, 
struct bpf_program *xdp_pro
        err = xsk_attach_xdp_program(xdp_prog, ifobj->ifindex, 
mode_to_xdp_flags(mode));
        if (err) {
                print_msg("Error attaching XDP program\n");
-               exit_with_error(-err);
+               return err;
        }
 
        if (ifobj->mode != mode && (mode == TEST_MODE_DRV || mode == 
TEST_MODE_ZC))
                if (!xsk_is_in_mode(ifobj->ifindex, XDP_FLAGS_DRV_MODE)) {
                        print_msg("ERROR: XDP prog not in DRV mode\n");
-                       exit_with_error(EINVAL);
+                       return -EINVAL;
                }
 
        ifobj->xdp_prog = xdp_prog;
        ifobj->xskmap = xskmap;
        ifobj->mode = mode;
+
+       return 0;
 }
 
-static void xsk_attach_xdp_progs(struct test_spec *test, struct ifobject 
*ifobj_rx,
+static int xsk_attach_xdp_progs(struct test_spec *test, struct ifobject 
*ifobj_rx,
                                 struct ifobject *ifobj_tx)
 {
-       if (xdp_prog_changed_rx(test))
-               xsk_reattach_xdp(ifobj_rx, test->xdp_prog_rx, test->xskmap_rx, 
test->mode);
+       int err = 0;
+
+       if (xdp_prog_changed_rx(test)) {
+               err = xsk_reattach_xdp(ifobj_rx, test->xdp_prog_rx, 
test->xskmap_rx, test->mode);
+               if (err)
+                       return err;
+       }
 
        if (!ifobj_tx || ifobj_tx->shared_umem)
-               return;
+               return 0;
 
        if (xdp_prog_changed_tx(test))
-               xsk_reattach_xdp(ifobj_tx, test->xdp_prog_tx, test->xskmap_tx, 
test->mode);
+               err = xsk_reattach_xdp(ifobj_tx, test->xdp_prog_tx, 
test->xskmap_tx, test->mode);
+
+       return err;
 }
 
 static int __testapp_validate_traffic(struct test_spec *test, struct ifobject 
*ifobj1,
@@ -1965,7 +1974,8 @@ static int testapp_validate_traffic(struct test_spec 
*test)
                }
        }
 
-       xsk_attach_xdp_progs(test, ifobj_rx, ifobj_tx);
+       if (xsk_attach_xdp_progs(test, ifobj_rx, ifobj_tx))
+               return TEST_FAILURE;
        return __testapp_validate_traffic(test, ifobj_rx, ifobj_tx);
 }
 

-- 
2.48.1


Reply via email to