|
11 | 11 | #include "mptcp_sock.skel.h" |
12 | 12 | #include "mptcpify.skel.h" |
13 | 13 | #include "mptcp_subflow.skel.h" |
14 | | -#include "mptcp_bpf_iters.skel.h" |
15 | 14 | #include "mptcp_bpf_first.skel.h" |
16 | 15 | #include "mptcp_bpf_bkup.skel.h" |
17 | 16 | #include "mptcp_bpf_rr.skel.h" |
|
41 | 40 | #ifndef MPTCP_INFO |
42 | 41 | #define MPTCP_INFO 1 |
43 | 42 | #endif |
44 | | -#ifndef TCP_IS_MPTCP |
45 | | -#define TCP_IS_MPTCP 43 /* Is MPTCP being used? */ |
46 | | -#endif |
47 | 43 | #ifndef MPTCP_INFO_FLAG_FALLBACK |
48 | 44 | #define MPTCP_INFO_FLAG_FALLBACK _BITUL(0) |
49 | 45 | #endif |
@@ -495,73 +491,6 @@ static void test_subflow(void) |
495 | 491 | close(cgroup_fd); |
496 | 492 | } |
497 | 493 |
|
498 | | -static void run_iters_subflow(void) |
499 | | -{ |
500 | | - int server_fd, client_fd; |
501 | | - int is_mptcp, err; |
502 | | - socklen_t len; |
503 | | - |
504 | | - server_fd = start_mptcp_server(AF_INET, ADDR_1, PORT_1, 0); |
505 | | - if (!ASSERT_OK_FD(server_fd, "start_mptcp_server")) |
506 | | - return; |
507 | | - |
508 | | - client_fd = connect_to_fd(server_fd, 0); |
509 | | - if (!ASSERT_OK_FD(client_fd, "connect_to_fd")) |
510 | | - goto close_server; |
511 | | - |
512 | | - send_byte(client_fd); |
513 | | - wait_for_new_subflows(client_fd); |
514 | | - |
515 | | - len = sizeof(is_mptcp); |
516 | | - /* mainly to trigger the BPF program */ |
517 | | - err = getsockopt(client_fd, SOL_TCP, TCP_IS_MPTCP, &is_mptcp, &len); |
518 | | - if (ASSERT_OK(err, "getsockopt(client_fd, TCP_IS_MPTCP)")) |
519 | | - ASSERT_EQ(is_mptcp, 1, "is_mptcp"); |
520 | | - |
521 | | - close(client_fd); |
522 | | -close_server: |
523 | | - close(server_fd); |
524 | | -} |
525 | | - |
526 | | -static void test_iters_subflow(void) |
527 | | -{ |
528 | | - struct mptcp_bpf_iters *skel; |
529 | | - struct netns_obj *netns; |
530 | | - int cgroup_fd; |
531 | | - |
532 | | - cgroup_fd = test__join_cgroup("/iters_subflow"); |
533 | | - if (!ASSERT_OK_FD(cgroup_fd, "join_cgroup: iters_subflow")) |
534 | | - return; |
535 | | - |
536 | | - skel = mptcp_bpf_iters__open_and_load(); |
537 | | - if (!ASSERT_OK_PTR(skel, "skel_open_load: iters_subflow")) |
538 | | - goto close_cgroup; |
539 | | - |
540 | | - skel->links.iters_subflow = bpf_program__attach_cgroup(skel->progs.iters_subflow, |
541 | | - cgroup_fd); |
542 | | - if (!ASSERT_OK_PTR(skel->links.iters_subflow, "attach getsockopt")) |
543 | | - goto skel_destroy; |
544 | | - |
545 | | - netns = netns_new(NS_TEST, true); |
546 | | - if (!ASSERT_OK_PTR(netns, "netns_new: iters_subflow")) |
547 | | - goto skel_destroy; |
548 | | - |
549 | | - if (endpoint_init("subflow", 4) < 0) |
550 | | - goto close_netns; |
551 | | - |
552 | | - run_iters_subflow(); |
553 | | - |
554 | | - /* 1 + 2 + 3 + 4 = 10 */ |
555 | | - ASSERT_EQ(skel->bss->ids, 10, "subflow ids"); |
556 | | - |
557 | | -close_netns: |
558 | | - netns_free(netns); |
559 | | -skel_destroy: |
560 | | - mptcp_bpf_iters__destroy(skel); |
561 | | -close_cgroup: |
562 | | - close(cgroup_fd); |
563 | | -} |
564 | | - |
565 | 494 | static int sched_init(char *flags, char *sched) |
566 | 495 | { |
567 | 496 | if (endpoint_init(flags, 2) < 0) |
@@ -754,8 +683,6 @@ void test_mptcp(void) |
754 | 683 | test_mptcpify(); |
755 | 684 | if (test__start_subtest("subflow")) |
756 | 685 | test_subflow(); |
757 | | - if (test__start_subtest("iters_subflow")) |
758 | | - test_iters_subflow(); |
759 | 686 | if (test__start_subtest("default")) |
760 | 687 | test_default(); |
761 | 688 | if (test__start_subtest("first")) |
|
0 commit comments