EAGAIN

fix

Signed-off-by: Geliang Tang <[email protected]>

net/mptcp/protocol.c

@@ -2272,6 +2272,7 @@ static int mptcp_recvmsg(struct sock *sk, struct msghdr *msg, size_t len,
 
 			if (!timeo) {
 				copied = -EAGAIN;
+				pr_info("%s return EAGAIN\n", __func__);
 				break;
 			}
 

tools/testing/selftests/bpf/network_helpers.c

@@ -652,6 +652,8 @@ static void *send_recv_server(void *arg)
 		if (nr_sent == -1 && errno == EINTR)
 			continue;
 		if (nr_sent == -1) {
+			//if (errno == EAGAIN)
+			//	continue;
 			err = -errno;
 			break;
 		}
@@ -701,6 +703,8 @@ int send_recv_data(int lfd, int fd, uint32_t total_bytes, int timeout_ms)
 		if (nr_recv == -1 && errno == EINTR)
 			continue;
 		if (nr_recv == -1) {
+			//if (errno == EAGAIN)
+			//	continue;
 			err = -errno;
 			break;
 		}

tools/testing/selftests/bpf/prog_tests/mptcp.c

@@ -1200,7 +1200,7 @@ static void send_data_and_verify(char *sched, bool addr1, bool addr2)
 	if (!ASSERT_OK_FD(server_fd, "start_mptcp_server"))
 		goto skel_destroy;
 
-	client_fd = connect_to_fd(server_fd, 0);
+	client_fd = connect_to_fd(server_fd, 30000);
 	if (!ASSERT_OK_FD(client_fd, "connect_to_fd"))
 		goto close_server;
 

tools/testing/selftests/bpf/progs/mptcp_bpf_bytes.c

@@ -21,6 +21,9 @@ int BPF_PROG(trace_mptcp_sched_get_send, struct mptcp_sock *msk)
 	if (!msk->pm.server_side)
 		return 0;
 
+	bytes_sent_1 = 0;
+	bytes_sent_2 = 0;
+
 	mptcp_for_each_subflow(msk, subflow) {
 		struct tcp_sock *tp;
 		struct sock *ssk;