/linux-5.19.10/net/phonet/ |
D | datagram.c | 79 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()
|
D | pep.c | 775 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-5.19.10/net/xfrm/ |
D | espintcp.c | 269 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-5.19.10/tools/testing/selftests/net/ |
D | udpgso_bench_rx.c | 171 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()
|
D | msg_zerocopy.c | 193 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()
|
D | udpgso.c | 497 if (ret == -1 && errno == EAGAIN && (flags & MSG_DONTWAIT)) in recv_one() 552 ret = recv_one(fdr, MSG_DONTWAIT); in run_one()
|
/linux-5.19.10/net/rds/ |
D | tcp_send.c | 63 .msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL, in rds_tcp_sendmsg() 116 int flags = MSG_DONTWAIT | MSG_NOSIGNAL | more; in rds_tcp_xmit()
|
/linux-5.19.10/net/mctp/test/ |
D | route-test.c | 355 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-5.19.10/net/caif/ |
D | caif_socket.c | 365 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-5.19.10/drivers/infiniband/sw/siw/ |
D | siw_qp_tx.c | 329 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-5.19.10/drivers/nvme/target/ |
D | tcp.c | 575 left, MSG_DONTWAIT | MSG_MORE | MSG_SENDPAGE_NOTLAST); in nvmet_try_send_data_pdu() 598 int flags = MSG_DONTWAIT; in nvmet_try_send_data() 644 int flags = MSG_DONTWAIT; in nvmet_try_send_response() 672 int flags = MSG_DONTWAIT; in nvmet_try_send_r2t() 698 struct msghdr msg = { .msg_flags = MSG_DONTWAIT }; in nvmet_try_send_ddgst() 1071 struct msghdr msg = { .msg_flags = MSG_DONTWAIT }; in nvmet_tcp_try_recv_pdu() 1161 struct msghdr msg = { .msg_flags = MSG_DONTWAIT }; in nvmet_tcp_try_recv_ddgst() 1339 c->recv_msg.msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL; in nvmet_tcp_alloc_cmd()
|
/linux-5.19.10/net/ipv4/ |
D | tcp_bpf.c | 213 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in tcp_bpf_recvmsg_parser() 259 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in tcp_bpf_recvmsg() 402 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in tcp_bpf_sendmsg()
|
D | udp_bpf.c | 86 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in udp_bpf_recvmsg()
|
/linux-5.19.10/net/x25/ |
D | x25_out.c | 52 int sent=0, noblock = X25_SKB_CB(skb)->flags & MSG_DONTWAIT; in x25_output()
|
/linux-5.19.10/net/rxrpc/ |
D | sendmsg.c | 301 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-5.19.10/net/sunrpc/ |
D | svcsock.c | 268 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-5.19.10/net/decnet/ |
D | af_decnet.c | 1682 long timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in dn_recvmsg() 1700 if (flags & ~(MSG_CMSG_COMPAT|MSG_PEEK|MSG_OOB|MSG_WAITALL|MSG_DONTWAIT|MSG_NOSIGNAL)) { in dn_recvmsg() 1742 if (flags & MSG_DONTWAIT) { in dn_recvmsg() 1923 if (flags & ~(MSG_TRYHARD|MSG_OOB|MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL|MSG_MORE|MSG_CMSG_COMPAT)) in dn_sendmsg() 1930 timeo = sock_sndtimeo(sk, flags & MSG_DONTWAIT); in dn_sendmsg() 1999 if (flags & MSG_DONTWAIT) { in dn_sendmsg() 2020 flags & MSG_DONTWAIT, &err); in dn_sendmsg()
|
/linux-5.19.10/net/unix/ |
D | unix_bpf.c | 75 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in unix_bpf_recvmsg()
|
D | af_unix.c | 1646 skb = skb_recv_datagram(sk, (flags & O_NONBLOCK) ? MSG_DONTWAIT : 0, in unix_accept() 1896 msg->msg_flags & MSG_DONTWAIT, &err, in unix_dgram_sendmsg() 1912 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in unix_dgram_sendmsg() 2058 skb = sock_alloc_send_skb(sock->sk, 1, msg->msg_flags & MSG_DONTWAIT, &err); in queue_oob() 2152 msg->msg_flags & MSG_DONTWAIT, &err, in unix_stream_sendmsg() 2234 newskb = sock_alloc_send_pskb(sk, 0, 0, flags & MSG_DONTWAIT, in unix_stream_sendpage() 2245 err = flags & MSG_DONTWAIT ? -EAGAIN : -ERESTARTSYS; in unix_stream_sendpage() 2384 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in __unix_dgram_recvmsg() 2501 skb = skb_recv_datagram(sk, MSG_DONTWAIT, &err); in unix_read_sock() 2671 int noblock = flags & MSG_DONTWAIT; in unix_stream_read_generic() [all …]
|
/linux-5.19.10/net/kcm/ |
D | kcmsock.c | 650 MSG_DONTWAIT); in kcm_write_msgs() 763 long timeo = sock_sndtimeo(sk, flags & MSG_DONTWAIT); in kcm_sendpage() 905 long timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in kcm_sendmsg() 1097 if ((flags & MSG_DONTWAIT) || !timeo) { in kcm_wait_data() 1125 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in kcm_recvmsg() 1185 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in kcm_splice_read()
|
/linux-5.19.10/drivers/net/ethernet/chelsio/inline_crypto/chtls/ |
D | chtls_io.c | 1020 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-5.19.10/samples/bpf/ |
D | xdpsock_user.c | 1346 ret = sendto(xsk_socket__fd(xsk->xsk), NULL, 0, MSG_DONTWAIT, NULL, 0); in kick_tx() 1388 recvfrom(xsk_socket__fd(xsk->xsk), NULL, 0, MSG_DONTWAIT, NULL, in complete_tx_l2fwd() 1435 recvfrom(xsk_socket__fd(xsk->xsk), NULL, 0, MSG_DONTWAIT, NULL, NULL); in rx_drop() 1446 recvfrom(xsk_socket__fd(xsk->xsk), NULL, 0, MSG_DONTWAIT, NULL, NULL); in rx_drop() 1678 recvfrom(xsk_socket__fd(xsk->xsk), NULL, 0, MSG_DONTWAIT, NULL, NULL); in l2fwd()
|
/linux-5.19.10/net/tls/ |
D | tls_sw.c | 926 long timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in tls_sw_sendmsg() 947 if (msg->msg_flags & ~(MSG_MORE | MSG_DONTWAIT | MSG_NOSIGNAL | in tls_sw_sendmsg() 1151 long timeo = sock_sndtimeo(sk, flags & MSG_DONTWAIT); in tls_sw_do_sendpage() 1267 if (flags & ~(MSG_MORE | MSG_DONTWAIT | MSG_NOSIGNAL | in tls_sw_sendpage_locked() 1281 if (flags & ~(MSG_MORE | MSG_DONTWAIT | MSG_NOSIGNAL | in tls_sw_sendpage() 1767 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in tls_sw_recvmsg() 1776 skb = tls_wait_data(sk, psock, flags & MSG_DONTWAIT, timeo, &err); in tls_sw_recvmsg()
|
/linux-5.19.10/net/tipc/ |
D | topsrv.c | 268 msg.msg_flags = MSG_DONTWAIT; in tipc_conn_send_to_sock() 398 ret = sock_recvmsg(con->sock, &msg, MSG_DONTWAIT); in tipc_conn_rcv_from_sock()
|
/linux-5.19.10/net/bluetooth/ |
D | af_bluetooth.c | 347 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in bt_sock_stream_recvmsg() 578 timeo = sock_sndtimeo(sk, !!(msg_flags & MSG_DONTWAIT)); in bt_sock_wait_ready()
|