Home
last modified time | relevance | path

Searched refs:MSG_DONTWAIT (Results 1 – 13 of 13) sorted by relevance

/tools/testing/selftests/net/
Dudpgso_bench_rx.c171 ret = recv(fd, NULL, 1 << 21, MSG_TRUNC | MSG_DONTWAIT); in do_flush_tcp()
233 ret = recvmsg(fd, &msg, MSG_TRUNC | MSG_DONTWAIT); in recv_msg()
257 ret = recv(fd, rbuf, len, MSG_TRUNC | MSG_DONTWAIT); in do_flush_udp()
Dmsg_zerocopy.c195 flags = MSG_DONTWAIT; in do_sendmsg()
374 if (recvmsg(fd, &msg, MSG_DONTWAIT)) in do_recvmsg_completion()
616 ret = recv(fd, NULL, 1 << 21, MSG_TRUNC | MSG_DONTWAIT); in do_flush_tcp()
635 ret = recv(fd, buf, sizeof(buf), MSG_DONTWAIT | MSG_TRUNC); in do_flush_datagram()
Dudpgso.c497 if (ret == -1 && errno == EAGAIN && (flags & MSG_DONTWAIT)) in recv_one()
552 ret = recv_one(fdr, MSG_DONTWAIT); in run_one()
Dcsum.c577 ret = recv(fd, buf, sizeof(buf), MSG_DONTWAIT); in recv_udp()
734 len = recvmsg(fd, &msg, MSG_DONTWAIT); in recv_packet()
Dtimestamping.c300 res = recvmsg(sock, &msg, recvmsg_flags|MSG_DONTWAIT); in recvpacket()
Dtls.c522 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
536 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
1020 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_DONTWAIT), -1); in TEST_F()
1634 EXPECT_EQ(recv(self->cfd2, buf, sizeof(buf), MSG_DONTWAIT), -1); in TEST_F()
2105 EXPECT_EQ(send(fd, buf, sizeof(buf), MSG_DONTWAIT), sizeof(buf)); in TEST()
/tools/testing/selftests/bpf/prog_tests/
Dxdp_metadata.c188 ret = sendto(xsk_socket__fd(xsk->socket), NULL, 0, MSG_DONTWAIT, NULL, 0); in generate_packet()
232 ret = recvfrom(xsk_socket__fd(xsk->socket), NULL, 0, MSG_DONTWAIT, NULL, NULL); in verify_xsk_metadata()
Dselect_reuseport.c436 nread = recv(new_fd, &rcv_cmd, sizeof(rcv_cmd), MSG_DONTWAIT); in do_test()
444 nread = recv(srv_fd, &rcv_cmd, sizeof(rcv_cmd), MSG_DONTWAIT); in do_test()
/tools/testing/vsock/
Dvsock_test.c318 res = recv(fd, buf_peek, sizeof(buf_peek), MSG_PEEK | MSG_DONTWAIT); in test_msg_peek_server()
965 read_res = recv(fd, buf, sizeof(buf), MSG_DONTWAIT); in test_stream_poll_rcvlowat_client()
1009 ret = recv(fd, data, sizeof(data), MSG_DONTWAIT); in test_inv_buf_client()
1154 res = recv(fd, buf, sizeof(buf) - 8 - 2, MSG_DONTWAIT); in test_stream_virtio_skb_merge_server()
/tools/perf/trace/beauty/include/linux/
Dsocket.h310 #define MSG_DONTWAIT 0x40 /* Nonblocking io */ macro
/tools/testing/selftests/bpf/
Dtest_flow_dissector.c498 ret = recv(fd, &rbuf, 1, MSG_DONTWAIT); in do_rx()
Dxskxceiver.c923 ret = sendto(xsk_socket__fd(xsk->xsk), NULL, 0, MSG_DONTWAIT, NULL, 0); in kick_tx()
937 ret = recvfrom(xsk_socket__fd(xsk->xsk), NULL, 0, MSG_DONTWAIT, NULL, NULL); in kick_rx()
/tools/net/ynl/lib/
Dynl.py630 reply = self.sock.recv(128 * 1024, socket.MSG_DONTWAIT)