Home
last modified time | relevance | path

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

12345

/linux-6.1.9/net/phonet/
Ddatagram.c79 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL| in pn_sendmsg()
93 msg->msg_flags & MSG_DONTWAIT, &err); in pn_sendmsg()
122 if (flags & ~(MSG_PEEK|MSG_TRUNC|MSG_DONTWAIT|MSG_NOSIGNAL| in pn_recvmsg()
Dpep.c775 skb = skb_recv_datagram(sk, (flags & O_NONBLOCK) ? MSG_DONTWAIT : 0, in pep_sock_accept()
1126 if ((msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL| in pep_sendmsg()
1132 flags & MSG_DONTWAIT, &err); in pep_sendmsg()
1142 timeo = sock_sndtimeo(sk, flags & MSG_DONTWAIT); in pep_sendmsg()
1247 if (flags & ~(MSG_OOB|MSG_PEEK|MSG_TRUNC|MSG_DONTWAIT|MSG_WAITALL| in pep_recvmsg()
/linux-6.1.9/net/xfrm/
Despintcp.c269 return flags & MSG_DONTWAIT ? -EAGAIN : 0; in espintcp_push_msgs()
315 long timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in espintcp_sendmsg()
324 if (msg->msg_flags & ~MSG_DONTWAIT) in espintcp_sendmsg()
335 err = espintcp_push_msgs(sk, msg->msg_flags & MSG_DONTWAIT); in espintcp_sendmsg()
337 if (err != -EAGAIN || !(msg->msg_flags & MSG_DONTWAIT)) in espintcp_sendmsg()
375 err = espintcp_push_msgs(sk, msg->msg_flags & MSG_DONTWAIT); in espintcp_sendmsg()
/linux-6.1.9/tools/testing/selftests/net/
Dudpgso_bench_rx.c171 ret = recv(fd, NULL, 1 << 21, MSG_TRUNC | MSG_DONTWAIT); in do_flush_tcp()
234 ret = recvmsg(fd, &msg, MSG_TRUNC | MSG_DONTWAIT); in recv_msg()
259 ret = recv(fd, rbuf, len, MSG_TRUNC | MSG_DONTWAIT); in do_flush_udp()
Dmsg_zerocopy.c193 flags = MSG_DONTWAIT; in do_sendmsg()
371 if (recvmsg(fd, &msg, MSG_DONTWAIT)) in do_recvmsg_completion()
609 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()
Dudpgso.c497 if (ret == -1 && errno == EAGAIN && (flags & MSG_DONTWAIT)) in recv_one()
552 ret = recv_one(fdr, MSG_DONTWAIT); in run_one()
/linux-6.1.9/net/rds/
Dtcp_send.c63 .msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL, in rds_tcp_sendmsg()
116 int flags = MSG_DONTWAIT | MSG_NOSIGNAL | more; in rds_tcp_xmit()
/linux-6.1.9/io_uring/
Dnet.c258 if (sr->msg_flags & MSG_DONTWAIT) in io_sendmsg_prep()
297 flags |= MSG_DONTWAIT; in io_sendmsg()
373 flags |= MSG_DONTWAIT; in io_send()
557 if (sr->msg_flags & MSG_DONTWAIT) in io_recvmsg_prep()
679 flags |= MSG_DONTWAIT; in io_recvmsg_multishot()
772 flags |= MSG_DONTWAIT; in io_recvmsg()
875 flags |= MSG_DONTWAIT; in io_recv()
990 if (zc->msg_flags & MSG_DONTWAIT) in io_send_zc_prep()
1118 msg_flags |= MSG_DONTWAIT; in io_send_zc()
1188 flags |= MSG_DONTWAIT; in io_sendmsg_zc()
/linux-6.1.9/net/mctp/test/
Droute-test.c355 skb2 = skb_recv_datagram(sock->sk, MSG_DONTWAIT, &rc); in mctp_test_route_input_sk()
363 skb2 = skb_recv_datagram(sock->sk, MSG_DONTWAIT, &rc); in mctp_test_route_input_sk()
426 skb2 = skb_recv_datagram(sock->sk, MSG_DONTWAIT, &rc); in mctp_test_route_input_sk_reasm()
585 skb2 = skb_recv_datagram(sock->sk, MSG_DONTWAIT, &rc); in mctp_test_route_input_sk_keys()
/linux-6.1.9/net/caif/
Dcaif_socket.c365 timeo = sock_rcvtimeo(sk, flags&MSG_DONTWAIT); in caif_stream_recvmsg()
540 noblock = msg->msg_flags & MSG_DONTWAIT; in caif_seqpkt_sendmsg()
606 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in caif_stream_sendmsg()
629 msg->msg_flags&MSG_DONTWAIT, in caif_stream_sendmsg()
650 msg->msg_flags&MSG_DONTWAIT, timeo); in caif_stream_sendmsg()
/linux-6.1.9/drivers/infiniband/sw/siw/
Dsiw_qp_tx.c329 flags = MSG_MORE | MSG_DONTWAIT | MSG_SENDPAGE_NOTLAST; in siw_tcp_sendpages()
335 flags = MSG_MORE | MSG_DONTWAIT; in siw_tcp_sendpages()
437 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_EOR }; in siw_tx_hdt()
447 rv = siw_tx_ctrl(c_tx, s, MSG_DONTWAIT | MSG_MORE); in siw_tx_hdt()
884 msg_flags = MSG_DONTWAIT; in siw_qp_sq_proc_tx()
886 msg_flags = MSG_DONTWAIT | MSG_MORE; in siw_qp_sq_proc_tx()
/linux-6.1.9/drivers/nvme/target/
Dtcp.c559 left, MSG_DONTWAIT | MSG_MORE | MSG_SENDPAGE_NOTLAST); in nvmet_try_send_data_pdu()
582 int flags = MSG_DONTWAIT; in nvmet_try_send_data()
628 int flags = MSG_DONTWAIT; in nvmet_try_send_response()
656 int flags = MSG_DONTWAIT; in nvmet_try_send_r2t()
682 struct msghdr msg = { .msg_flags = MSG_DONTWAIT }; in nvmet_try_send_ddgst()
1069 struct msghdr msg = { .msg_flags = MSG_DONTWAIT }; in nvmet_tcp_try_recv_pdu()
1158 struct msghdr msg = { .msg_flags = MSG_DONTWAIT }; in nvmet_tcp_try_recv_ddgst()
1337 c->recv_msg.msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL; in nvmet_tcp_alloc_cmd()
/linux-6.1.9/net/ipv4/
Dtcp_bpf.c215 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in tcp_bpf_recvmsg_parser()
261 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in tcp_bpf_recvmsg()
409 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in tcp_bpf_sendmsg()
Dudp_bpf.c86 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in udp_bpf_recvmsg()
/linux-6.1.9/net/x25/
Dx25_out.c52 int sent=0, noblock = X25_SKB_CB(skb)->flags & MSG_DONTWAIT; in x25_output()
/linux-6.1.9/net/rxrpc/
Dsendmsg.c301 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in rxrpc_send_data()
359 sk, bufsize, msg->msg_flags & MSG_DONTWAIT, &ret); in rxrpc_send_data()
474 if (msg->msg_flags & MSG_DONTWAIT) in rxrpc_send_data()
/linux-6.1.9/net/sunrpc/
Dsvcsock.c268 len = sock_recvmsg(svsk->sk_sock, &msg, MSG_DONTWAIT); in svc_tcp_read_msg()
435 .msg_flags = MSG_DONTWAIT, in svc_udp_recvfrom()
453 0, 0, MSG_PEEK | MSG_DONTWAIT); in svc_udp_recvfrom()
456 skb = skb_recv_udp(svsk->sk_sk, MSG_DONTWAIT, &err); in svc_udp_recvfrom()
878 len = sock_recvmsg(svsk->sk_sock, &msg, MSG_DONTWAIT); in svc_tcp_read_marker()
/linux-6.1.9/net/unix/
Daf_unix.c1696 skb = skb_recv_datagram(sk, (flags & O_NONBLOCK) ? MSG_DONTWAIT : 0, in unix_accept()
1944 msg->msg_flags & MSG_DONTWAIT, &err, in unix_dgram_sendmsg()
1960 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in unix_dgram_sendmsg()
2113 skb = sock_alloc_send_skb(sock->sk, 1, msg->msg_flags & MSG_DONTWAIT, &err); in queue_oob()
2207 msg->msg_flags & MSG_DONTWAIT, &err, in unix_stream_sendmsg()
2289 newskb = sock_alloc_send_pskb(sk, 0, 0, flags & MSG_DONTWAIT, in unix_stream_sendpage()
2300 err = flags & MSG_DONTWAIT ? -EAGAIN : -ERESTARTSYS; in unix_stream_sendpage()
2439 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in __unix_dgram_recvmsg()
2552 skb = skb_recv_datagram(sk, MSG_DONTWAIT, &err); in unix_read_skb()
2707 int noblock = flags & MSG_DONTWAIT; in unix_stream_read_generic()
[all …]
Dunix_bpf.c75 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in unix_bpf_recvmsg()
/linux-6.1.9/drivers/net/ethernet/chelsio/inline_crypto/chtls/
Dchtls_io.c1020 timeo = sock_sndtimeo(sk, flags & MSG_DONTWAIT); in chtls_sendmsg()
1244 timeo = sock_sndtimeo(sk, flags & MSG_DONTWAIT); in chtls_sendpage()
1444 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in chtls_pt_recvmsg()
1629 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in peekmsg()
1761 sk_busy_loop(sk, flags & MSG_DONTWAIT); in chtls_recvmsg()
1769 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in chtls_recvmsg()
/linux-6.1.9/net/mctp/
Daf_mctp.c161 msg->msg_flags & MSG_DONTWAIT, &rc); in mctp_sendmsg()
216 if (flags & ~(MSG_DONTWAIT | MSG_TRUNC | MSG_PEEK)) in mctp_recvmsg()
/linux-6.1.9/net/core/
Ddatagram.c274 sk_busy_loop(sk, flags & MSG_DONTWAIT); in __skb_try_recv_datagram()
292 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in __skb_recv_datagram()
/linux-6.1.9/net/bluetooth/
Daf_bluetooth.c349 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in bt_sock_stream_recvmsg()
580 timeo = sock_sndtimeo(sk, !!(msg_flags & MSG_DONTWAIT)); in bt_sock_wait_ready()
/linux-6.1.9/net/tipc/
Dtopsrv.c270 msg.msg_flags = MSG_DONTWAIT; in tipc_conn_send_to_sock()
400 ret = sock_recvmsg(con->sock, &msg, MSG_DONTWAIT); in tipc_conn_rcv_from_sock()
/linux-6.1.9/drivers/infiniband/core/
Dnetlink.c267 err = netlink_unicast(rnet->nl_sock, skb, pid, MSG_DONTWAIT); in rdma_nl_unicast()

12345