Home
last modified time | relevance | path

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

12345

/linux-6.15/tools/testing/selftests/bpf/prog_tests/
H 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 …]
H 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()
/linux-6.15/tools/testing/selftests/net/
H 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()
H 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()
H A 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()
H A Dudpgso.c421 if (ret == -1 && errno == EAGAIN && (flags & MSG_DONTWAIT)) in recv_one()
492 ret = recv_one(fdr, MSG_DONTWAIT); in run_one()
/linux-6.15/net/phonet/
H A Ddatagram.c76 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL| in pn_sendmsg()
90 msg->msg_flags & MSG_DONTWAIT, &err); in pn_sendmsg()
119 if (flags & ~(MSG_PEEK|MSG_TRUNC|MSG_DONTWAIT|MSG_NOSIGNAL| in pn_recvmsg()
H A Dpep.c775 skb = skb_recv_datagram(sk, (arg->flags & O_NONBLOCK) ? MSG_DONTWAIT : 0, in pep_sock_accept()
1148 if ((msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL| in pep_sendmsg()
1154 flags & MSG_DONTWAIT, &err); in pep_sendmsg()
1164 timeo = sock_sndtimeo(sk, flags & MSG_DONTWAIT); in pep_sendmsg()
1269 if (flags & ~(MSG_OOB|MSG_PEEK|MSG_TRUNC|MSG_DONTWAIT|MSG_WAITALL| in pep_recvmsg()
/linux-6.15/net/xfrm/
H A Despintcp.c280 return flags & MSG_DONTWAIT ? -EAGAIN : 0; in espintcp_push_msgs()
326 long timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in espintcp_sendmsg()
335 if (msg->msg_flags & ~MSG_DONTWAIT) in espintcp_sendmsg()
346 err = espintcp_push_msgs(sk, msg->msg_flags & MSG_DONTWAIT); in espintcp_sendmsg()
348 if (err != -EAGAIN || !(msg->msg_flags & MSG_DONTWAIT)) in espintcp_sendmsg()
386 err = espintcp_push_msgs(sk, msg->msg_flags & MSG_DONTWAIT); in espintcp_sendmsg()
/linux-6.15/net/mctp/test/
H A Droute-test.c367 skb2 = skb_recv_datagram(sock->sk, MSG_DONTWAIT, &rc); in mctp_test_route_input_sk()
375 skb2 = skb_recv_datagram(sock->sk, MSG_DONTWAIT, &rc); in mctp_test_route_input_sk()
437 skb2 = skb_recv_datagram(sock->sk, MSG_DONTWAIT, &rc); in mctp_test_route_input_sk_reasm()
598 skb2 = skb_recv_datagram(sock->sk, MSG_DONTWAIT, &rc); in mctp_test_route_input_sk_keys()
739 rx_skb1 = skb_recv_datagram(t1.sock->sk, MSG_DONTWAIT, &rc); in mctp_test_route_input_multiple_nets_bind()
747 rx_skb2 = skb_recv_datagram(t2.sock->sk, MSG_DONTWAIT, &rc); in mctp_test_route_input_multiple_nets_bind()
820 rx_skb1 = skb_recv_datagram(t1.sock->sk, MSG_DONTWAIT, &rc); in mctp_test_route_input_multiple_nets_key()
828 rx_skb2 = skb_recv_datagram(t2.sock->sk, MSG_DONTWAIT, &rc); in mctp_test_route_input_multiple_nets_key()
996 rx_skb = skb_recv_datagram(sock->sk, MSG_DONTWAIT, &rc); in mctp_test_route_input_cloned_frag()
1010 rx_skb = skb_recv_datagram(sock->sk, MSG_DONTWAIT, &rc); in mctp_test_route_input_cloned_frag()
/linux-6.15/net/rds/
H A Dtcp_send.c63 .msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL, in rds_tcp_sendmsg()
116 msg.msg_flags = MSG_SPLICE_PAGES | MSG_DONTWAIT | MSG_NOSIGNAL; in rds_tcp_xmit()
/linux-6.15/io_uring/
H A Dnet.c410 if (sr->msg_flags & MSG_DONTWAIT) in io_sendmsg_prep()
533 flags |= MSG_DONTWAIT; in io_sendmsg()
631 flags |= MSG_DONTWAIT; in io_send()
773 if (sr->msg_flags & MSG_DONTWAIT) in io_recvmsg_prep()
927 flags |= MSG_DONTWAIT; in io_recvmsg_multishot()
987 flags |= MSG_DONTWAIT; in io_recvmsg()
1140 flags |= MSG_DONTWAIT; in io_recv()
1242 ret = io_zcrx_recv(req, zc->ifq, sock, zc->msg_flags | MSG_DONTWAIT, in io_recvzc()
1319 if (zc->msg_flags & MSG_DONTWAIT) in io_send_zc_prep()
1439 msg_flags |= MSG_DONTWAIT; in io_send_zc()
[all …]
/linux-6.15/net/handshake/
H A Dalert.c54 msg.msg_flags = MSG_DONTWAIT; in tls_alert_send()
/linux-6.15/net/caif/
H A Dcaif_socket.c366 timeo = sock_rcvtimeo(sk, flags&MSG_DONTWAIT); in caif_stream_recvmsg()
537 noblock = msg->msg_flags & MSG_DONTWAIT; in caif_seqpkt_sendmsg()
603 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in caif_stream_sendmsg()
626 msg->msg_flags&MSG_DONTWAIT, in caif_stream_sendmsg()
647 msg->msg_flags&MSG_DONTWAIT, timeo); in caif_stream_sendmsg()
/linux-6.15/drivers/infiniband/sw/siw/
H A Dsiw_qp_tx.c320 .msg_flags = (MSG_MORE | MSG_DONTWAIT | MSG_SPLICE_PAGES), in siw_tcp_sendpages()
436 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_EOR }; in siw_tx_hdt()
446 rv = siw_tx_ctrl(c_tx, s, MSG_DONTWAIT | MSG_MORE); in siw_tx_hdt()
867 msg_flags = MSG_DONTWAIT; in siw_qp_sq_proc_tx()
869 msg_flags = MSG_DONTWAIT | MSG_MORE; in siw_qp_sq_proc_tx()
/linux-6.15/net/ipv4/
H A Dtcp_bpf.c301 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in tcp_bpf_recvmsg_parser()
361 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in tcp_bpf_recvmsg()
512 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in tcp_bpf_sendmsg()
H A Dudp_bpf.c89 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in udp_bpf_recvmsg()
/linux-6.15/net/x25/
H A Dx25_out.c52 int sent=0, noblock = X25_SKB_CB(skb)->flags & MSG_DONTWAIT; in x25_output()
/linux-6.15/net/vmw_vsock/
H A Dvsock_bpf.c103 long timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in vsock_bpf_recvmsg()
/linux-6.15/tools/testing/vsock/
H A Dvsock_test.c300 recv_buf(fd, buf_peek, sizeof(buf_peek), MSG_PEEK | MSG_DONTWAIT, in test_msg_peek_server()
884 recv_buf(fd, buf, sizeof(buf), MSG_DONTWAIT, RCVLOWAT_BUF_SIZE); in test_stream_poll_rcvlowat_client()
922 recv_buf(fd, data, sizeof(data), MSG_DONTWAIT, expected_ret); in test_inv_buf_client()
1032 recv_buf(fd, buf + read, to_read, MSG_DONTWAIT, -EAGAIN); in test_stream_virtio_skb_merge_server()
1447 recv_buf(fd, buf, recv_buf_size, MSG_DONTWAIT, recv_buf_size); in test_stream_credit_update_test()
/linux-6.15/drivers/nvme/target/
H A Dtcp.c612 .msg_flags = MSG_DONTWAIT | MSG_MORE | MSG_SPLICE_PAGES, in nvmet_try_send_data_pdu()
643 .msg_flags = MSG_DONTWAIT | MSG_SPLICE_PAGES, in nvmet_try_send_data()
692 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_SPLICE_PAGES, }; in nvmet_try_send_response()
722 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_SPLICE_PAGES, }; in nvmet_try_send_r2t()
752 struct msghdr msg = { .msg_flags = MSG_DONTWAIT }; in nvmet_try_send_ddgst()
1189 struct msghdr msg = { .msg_flags = MSG_DONTWAIT }; in nvmet_tcp_try_recv_pdu()
1294 struct msghdr msg = { .msg_flags = MSG_DONTWAIT }; in nvmet_tcp_try_recv_ddgst()
1499 c->recv_msg.msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL; in nvmet_tcp_alloc_cmd()
/linux-6.15/net/unix/
H A Dunix_bpf.c82 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in unix_bpf_recvmsg()
H A Daf_unix.c1750 skb = skb_recv_datagram(sk, (arg->flags & O_NONBLOCK) ? MSG_DONTWAIT : 0, in unix_accept()
2008 msg->msg_flags & MSG_DONTWAIT, &err, in unix_dgram_sendmsg()
2024 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in unix_dgram_sendmsg()
2185 skb = sock_alloc_send_skb(sock->sk, 1, msg->msg_flags & MSG_DONTWAIT, &err); in queue_oob()
2274 msg->msg_flags & MSG_DONTWAIT, in unix_stream_sendmsg()
2288 msg->msg_flags & MSG_DONTWAIT, &err, in unix_stream_sendmsg()
2414 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in __unix_dgram_recvmsg()
2532 skb = skb_recv_datagram(sk, MSG_DONTWAIT, &err); in unix_read_skb()
2702 skb = skb_recv_datagram(sk, MSG_DONTWAIT, &err); in unix_stream_read_skb()
2747 int noblock = flags & MSG_DONTWAIT; in unix_stream_read_generic()
[all …]
/linux-6.15/net/rxrpc/
H A Drecvmsg.c296 timeo = sock_rcvtimeo(&rx->sk, flags & MSG_DONTWAIT); in rxrpc_recvmsg()
368 if (flags & MSG_DONTWAIT) in rxrpc_recvmsg()
/linux-6.15/drivers/vhost/
H A Dnet.c752 .msg_flags = MSG_DONTWAIT, in handle_tx_copy()
842 .msg_flags = MSG_DONTWAIT, in handle_tx_zerocopy()
1098 .msg_flags = MSG_DONTWAIT, in handle_rx()
1170 1, MSG_DONTWAIT | MSG_TRUNC); in handle_rx()
1184 sock_len, MSG_DONTWAIT | MSG_TRUNC); in handle_rx()

12345