Home
last modified time | relevance | path

Searched refs:recv (Results 1 – 25 of 35) sorted by relevance

12

/tools/testing/selftests/net/
Dtls.c135 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
264 EXPECT_EQ(recv(self->cfd, recv_buf, to_send, MSG_WAITALL), to_send); in TEST_F()
268 EXPECT_EQ(recv(self->cfd, buf, st.st_size, MSG_WAITALL), st.st_size); in TEST_F()
300 EXPECT_EQ(recv(self->cfd, buf, test_payload_size, MSG_WAITALL), in chunked_sendfile()
338 EXPECT_NE(recv(self->cfd, recv_mem, send_len, 0), -1); in TEST_F()
350 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
361 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
363 EXPECT_EQ(recv(self->cfd, buf, send_len * 2, MSG_WAITALL), in TEST_F()
375 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
393 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len); in TEST_F()
[all …]
Dreuseport_dualstack.c116 i = recv(fd, buf, sizeof(buf), 0); in receive_once()
119 i = recv(ev.data.fd, buf, sizeof(buf), 0); in receive_once()
Dreuseport_bpf_numa.c175 i = recv(fd, buf, sizeof(buf), 0); in receive_on_node()
178 i = recv(ev.data.fd, buf, sizeof(buf), 0); in receive_on_node()
Dreuseport_addr_any.c182 i = recv(fd, buf, sizeof(buf), 0); in receive_once()
185 i = recv(ev.data.fd, buf, sizeof(buf), 0); in receive_once()
Dreuseport_bpf_cpu.c165 i = recv(fd, buf, sizeof(buf), 0); in receive_on_cpu()
168 i = recv(ev.data.fd, buf, sizeof(buf), 0); in receive_on_cpu()
Dudpgso_bench_rx.c171 ret = recv(fd, NULL, 1 << 21, MSG_TRUNC | MSG_DONTWAIT); in do_flush_tcp()
257 ret = recv(fd, rbuf, len, MSG_TRUNC | MSG_DONTWAIT); in do_flush_udp()
Dipsec.c254 if (recv(sock, &answer, sizeof(answer), 0) < 0) { in netlink_check_answer()
651 r_bytes = recv(sock[0], sock_buf, buf_len, 0); in udp_ping_send()
679 r_bytes = recv(sock[0], sock_buf, buf_len, 0); in udp_ping_reply()
1061 if (recv(xfrm_sock, &answer, sizeof(answer), 0) < 0) { in xfrm_state_check()
1319 if (recv(xfrm_sock, &answer, sizeof(answer), 0) < 0) { in xfrm_state_allocspi()
1417 if (recv(xfrm_sock, &req, sizeof(req), 0) < 0) { in xfrm_monitor_acquire()
1431 if (recv(xfrm_listen, &req, sizeof(req), 0) < 0) { in xfrm_monitor_acquire()
1491 if (recv(xfrm_sock, &req, sizeof(req), 0) < 0) { in xfrm_expire_state()
1505 if (recv(xfrm_listen, &req, sizeof(req), 0) < 0) { in xfrm_expire_state()
1569 if (recv(xfrm_sock, &req, sizeof(req), 0) < 0) { in xfrm_expire_policy()
[all …]
Dioam6_parser.c640 recv: in main()
641 size = recv(fd, buffer, sizeof(buffer), 0); in main()
649 goto recv; in main()
Dso_txtime.c120 ret = recv(fdr, rbuf, sizeof(rbuf), 0); in do_recv_one()
146 ret = recv(fdr, rbuf, sizeof(rbuf), 0); in do_recv_verify_empty()
Dpsock_snd.c278 ret = recv(fd, rbuf, sizeof(rbuf), 0); in do_rx()
Dmsg_zerocopy.c609 ret = recv(fd, NULL, 1 << 21, MSG_TRUNC | MSG_DONTWAIT); in do_flush_tcp()
628 ret = recv(fd, buf, sizeof(buf), MSG_DONTWAIT | MSG_TRUNC); in do_flush_datagram()
Dtcp_fastopen_backup_key.c282 i = recv(ev.data.fd, buf, sizeof(buf), 0); in run_one_test()
/tools/testing/selftests/bpf/prog_tests/
Dtcpbpf_user.c81 rv = recv(accept_fd, buf, 1000, 0); in run_test()
93 rv = recv(cli_fd, buf, 500, 0); in run_test()
102 err = recv(cli_fd, buf, 1, 0); in run_test()
107 err = recv(accept_fd, buf, 1, 0); in run_test()
Dsock_fields.c320 err = recv(cli_fd, buf, DATA_LEN, 0); in test()
327 err = recv(accept_fd, buf, 1, 0); in test()
332 err = recv(cli_fd, buf, 1, 0); in test()
Dsk_lookup.c304 n = recv(fd, buf, sizeof(buf), 0); in recv_byte()
324 n = recv(fd, buf, sizeof(buf), 0); in tcp_recv_send()
894 n = recv(client_fd, NULL, 0, 0); in drop_on_lookup()
987 n = recv(client, NULL, 0, 0); in drop_on_reuseport()
Dbpf_tcp_ca.c148 nr_recv = recv(fd, &batch, in do_test()
/tools/testing/selftests/pidfd/
Dpidfd_getfd_test.c68 while ((ret = recv(sk, &buf, sizeof(buf), 0)) > 0) { in __child()
162 ret = recv(sk_pair[0], &self->remote_fd, sizeof(self->remote_fd), 0); in FIXTURE_SETUP()
190 ASSERT_EQ(1, recv(self->sk, &c, 1, 0)); in TEST_F()
/tools/testing/selftests/net/af_unix/
Dtest_unix_oob.c87 if (recv(fd, c, sizeof(*c), MSG_OOB) < 0) { in read_oob()
244 len = recv(pfd, buf, 1024, MSG_PEEK); in main()
268 len = recv(pfd, buf, 1024, MSG_PEEK); in main()
369 len = recv(pfd, buf, 1024, MSG_PEEK); in main()
401 len = recv(pfd, buf, 1024, MSG_PEEK); in main()
/tools/testing/selftests/nci/
Dnci_dev.c194 resp_len = recv(sd, &ans, sizeof(ans), 0); in get_family_id()
261 resp_len = recv(sd, msg, sizeof(*msg), 0); in get_nci_devid()
663 resp_len = recv(sd, &ans, sizeof(ans), 0); in get_taginfo()
729 resp_len = recv(sd, evt_data, sizeof(evt_data), 0); in connect_tag()
757 len = recv(nfc_sock, buf, rsp_len - 2, 0); in read_write_nci_cmd()
827 len = recv(nfc_sock, buf, sizeof(nci_t4t_rsp_ok), 0); in disconnect_tag()
/tools/testing/vsock/
Dcontrol.c175 ret = recv(control_fd, &buf[idx], 1, 0); in control_readln()
Dutil.c277 nread = recv(fd, &byte, sizeof(byte), flags); in recv_byte()
/tools/accounting/
Dgetdelays.c182 rep_len = recv(sd, &ans, sizeof(ans), 0); in get_family_id()
452 rep_len = recv(nl_sd, &msg, sizeof(msg), 0); in main()
/tools/usb/usbip/src/
Dusbip_network.c108 nbytes = recv(sockfd, buff, bufflen, MSG_WAITALL); in usbip_net_xmit()
/tools/testing/selftests/bpf/
Dtest_sockmap.c592 int slct, recvp = 0, recv, max_fd = fd; in msg_loop() local
657 recv = recvmsg(fd, &msg, flags); in msg_loop()
658 if (recv < 0) { in msg_loop()
666 s->bytes_recvd += recv; in msg_loop()
673 errno = msg_verify_data(&msg, recv, chunk_sz); in msg_loop()
867 rc = recv(i, buf, sizeof(buf), 0); in forever_ping_pong()
/tools/testing/selftests/net/forwarding/
Dtc_actions.sh179 ip vrf exec v$h1 ncat --recv-only -w10 -l -p 12345 -o $mirred_e2i_tf2 &

12