Home
last modified time | relevance | path

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

/tools/testing/selftests/bpf/prog_tests/
A Dsockmap_strp.c145 expected, MSG_DONTWAIT, in test_sockmap_strp_dispatch_pkt()
207 recvd = recv_timeout(p, rcv, total + 1, MSG_DONTWAIT, IO_TIMEOUT_SEC); in test_sockmap_strp_multiple_pkt()
253 recvd = recv_timeout(p, rcv, sizeof(rcv), MSG_DONTWAIT, 1); in test_sockmap_strp_partial_read()
259 recvd = recv_timeout(p, rcv, sizeof(rcv), MSG_DONTWAIT, IO_TIMEOUT_SEC); in test_sockmap_strp_partial_read()
270 recvd = recv_timeout(p, rcv, sizeof(rcv), MSG_DONTWAIT, 1); in test_sockmap_strp_partial_read()
276 recvd = recv_timeout(p, rcv, sizeof(rcv), MSG_DONTWAIT, IO_TIMEOUT_SEC); in test_sockmap_strp_partial_read()
333 recvd = recv_timeout(p, rcv, sizeof(rcv), MSG_DONTWAIT, in test_sockmap_strp_pass()
351 recvd = recv_timeout(p, rcv, sizeof(rcv), MSG_DONTWAIT, in test_sockmap_strp_pass()
401 recvd = recv_timeout(c1, rcv, sizeof(rcv), MSG_DONTWAIT, in test_sockmap_strp_verdict()
415 recvd = recv_timeout(c1, rcv, off, MSG_DONTWAIT, in test_sockmap_strp_verdict()
[all …]
A Dsockmap_redir.c191 try_recv("bpf.recv(sd_send)", sd_send, MSG_DONTWAIT, false); in handle_unsupported()
193 try_recv("bpf.recv(sd_in)", sd_in, MSG_DONTWAIT, false); in handle_unsupported()
195 try_recv("bpf.recv(sd_out)", sd_out, MSG_DONTWAIT, false); in handle_unsupported()
197 try_recv("bpf.recv(sd_recv)", sd_recv, MSG_DONTWAIT, false); in handle_unsupported()
261 MSG_OOB | MSG_DONTWAIT, false); in test_send_redir_recv()
268 MSG_OOB | MSG_DONTWAIT, false); in test_send_redir_recv()
A Dsockmap_ktls.c210 recvd = recv_timeout(p, rcv, sizeof(rcv), MSG_DONTWAIT, 1); in test_sockmap_ktls_tx_cork()
219 recvd = recv_timeout(p, rcv, sizeof(rcv), MSG_DONTWAIT, 1); in test_sockmap_ktls_tx_cork()
301 err = sendmsg(c, &msg, MSG_DONTWAIT); in test_sockmap_ktls_tx_no_buf()
374 recvd = recv_timeout(p, rcv, sizeof(rcv), MSG_DONTWAIT, 1); in test_sockmap_ktls_tx_pop()
A Dxdp_metadata.c196 ret = sendto(xsk_socket__fd(xsk->socket), NULL, 0, MSG_DONTWAIT, NULL, 0); in generate_packet()
219 err = sendto(sock_fd, udp_payload, UDP_PAYLOAD_BYTES, MSG_DONTWAIT, in generate_packet_inet()
273 ret = recvfrom(xsk_socket__fd(xsk->socket), NULL, 0, MSG_DONTWAIT, NULL, NULL); in verify_xsk_metadata()
A Dselect_reuseport.c426 nread = recv(new_fd, &rcv_cmd, sizeof(rcv_cmd), MSG_DONTWAIT); in do_test()
434 nread = recv(srv_fd, &rcv_cmd, sizeof(rcv_cmd), MSG_DONTWAIT); in do_test()
A Dsockmap_basic.c529 n = recv(c1, &b, 1, MSG_DONTWAIT); in test_sockmap_skb_verdict_shutdown()
584 recvd = recv_timeout(c1, &buf, sizeof(buf), MSG_DONTWAIT, IO_TIMEOUT_SEC); in test_sockmap_skb_verdict_fionread()
A Dflow_dissector_classification.c433 ret = recv(fd, &rbuf, 1, MSG_DONTWAIT); in do_rx()
/tools/testing/selftests/net/
A Dnetlink-dumps.c129 n = recv(netlink_sock, buf, sizeof(buf), MSG_DONTWAIT); in TEST()
136 n = recv(netlink_sock, buf, sizeof(buf), MSG_DONTWAIT); in TEST()
187 n = recv(netlink_sock, buf, sizeof(buf), MSG_DONTWAIT); in TEST()
190 n = recv(netlink_sock, buf, sizeof(buf), MSG_DONTWAIT); in TEST()
A 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()
A Dmsg_zerocopy.c196 flags = MSG_DONTWAIT; in do_sendmsg()
375 if (recvmsg(fd, &msg, MSG_DONTWAIT)) in do_recvmsg_completion()
619 ret = recv(fd, NULL, 1 << 21, MSG_TRUNC | MSG_DONTWAIT); in do_flush_tcp()
638 ret = recv(fd, buf, sizeof(buf), MSG_DONTWAIT | MSG_TRUNC); in do_flush_datagram()
A Dudpgso.c421 if (ret == -1 && errno == EAGAIN && (flags & MSG_DONTWAIT)) in recv_one()
492 ret = recv_one(fdr, MSG_DONTWAIT); in run_one()
A Dtls.c543 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
557 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
1041 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_DONTWAIT), -1); in TEST_F()
1829 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_DONTWAIT), -1); in TEST_F()
1902 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_DONTWAIT), -1); in TEST_F()
2228 EXPECT_EQ(recv(self->cfd2, buf, sizeof(buf), MSG_DONTWAIT), -1); in TEST_F()
2699 EXPECT_EQ(send(fd, buf, sizeof(buf), MSG_DONTWAIT), sizeof(buf)); in TEST()
2762 EXPECT_EQ(recv(cfd, buf2, sizeof(buf2), MSG_DONTWAIT), -1); in TEST()
A Dtimestamping.c300 res = recvmsg(sock, &msg, recvmsg_flags|MSG_DONTWAIT); in recvpacket()
/tools/testing/selftests/net/tcp_ao/lib/
A Drepair.c64 ret = recv(sk, q->buf, qlen, MSG_PEEK | MSG_DONTWAIT); in test_sock_checkpoint_queue()
/tools/testing/vsock/
A Dvsock_test.c302 recv_buf(fd, buf_peek, sizeof(buf_peek), MSG_PEEK | MSG_DONTWAIT, in test_msg_peek_server()
886 recv_buf(fd, buf, sizeof(buf), MSG_DONTWAIT, RCVLOWAT_BUF_SIZE); in test_stream_poll_rcvlowat_client()
924 recv_buf(fd, data, sizeof(data), MSG_DONTWAIT, expected_ret); in test_inv_buf_client()
1034 recv_buf(fd, buf + read, to_read, MSG_DONTWAIT, -EAGAIN); in test_stream_virtio_skb_merge_server()
1537 recv_buf(fd, buf, recv_buf_size, MSG_DONTWAIT, recv_buf_size); in test_stream_credit_update_test()
/tools/testing/selftests/bpf/
A Dxdp_hw_metadata.c176 return sendto(xsk_socket__fd(xsk->socket), NULL, 0, MSG_DONTWAIT, NULL, 0); in kick_tx()
181 return recvfrom(xsk_socket__fd(xsk->socket), NULL, 0, MSG_DONTWAIT, NULL, NULL); in kick_rx()
A Dxskxceiver.c1109 *ret = sendto(xsk_socket__fd(xsk->xsk), NULL, 0, MSG_DONTWAIT, NULL, 0); in kick_tx_with_check()
1133 ret = sendto(xsk_socket__fd(xsk->xsk), NULL, 0, MSG_DONTWAIT, NULL, 0); in kick_tx()
1148 ret = recvfrom(xsk_socket__fd(xsk->xsk), NULL, 0, MSG_DONTWAIT, NULL, NULL); in kick_rx()
/tools/testing/selftests/net/lib/
A Dcsum.c577 ret = recv(fd, buf, sizeof(buf), MSG_DONTWAIT); in recv_udp()
745 len = recvmsg(fd, &msg, MSG_DONTWAIT); in recv_packet()
/tools/perf/trace/beauty/include/linux/
A Dsocket.h311 #define MSG_DONTWAIT 0x40 /* Nonblocking io */ macro
/tools/net/ynl/lib/
A Dynl.c570 if (flags & MSG_DONTWAIT && errno == EAGAIN) in __ynl_sock_read_msgs()
926 MSG_DONTWAIT); in ynl_ntf_check()
/tools/net/ynl/pyynl/lib/
A Dynl.py975 reply = self.sock.recv(self._recv_size, socket.MSG_DONTWAIT)

Completed in 56 milliseconds