/openbmc/linux/net/phonet/ |
H A D | datagram.c | 76 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 D | pep.c | 775 skb = skb_recv_datagram(sk, (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()
|
/openbmc/linux/net/xfrm/ |
H A D | espintcp.c | 276 return flags & MSG_DONTWAIT ? -EAGAIN : 0; in espintcp_push_msgs() 322 long timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in espintcp_sendmsg() 331 if (msg->msg_flags & ~MSG_DONTWAIT) in espintcp_sendmsg() 342 err = espintcp_push_msgs(sk, msg->msg_flags & MSG_DONTWAIT); in espintcp_sendmsg() 344 if (err != -EAGAIN || !(msg->msg_flags & MSG_DONTWAIT)) in espintcp_sendmsg() 382 err = espintcp_push_msgs(sk, msg->msg_flags & MSG_DONTWAIT); in espintcp_sendmsg()
|
/openbmc/linux/tools/testing/selftests/net/ |
H A D | udpgso_bench_rx.c | 171 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 D | msg_zerocopy.c | 195 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 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()
|
/openbmc/linux/net/rds/ |
H A D | tcp_send.c | 63 .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()
|
/openbmc/linux/io_uring/ |
H A D | net.c | 390 if (sr->msg_flags & MSG_DONTWAIT) in io_sendmsg_prep() 430 flags |= MSG_DONTWAIT; in io_sendmsg() 507 flags |= MSG_DONTWAIT; in io_send() 628 if (sr->msg_flags & MSG_DONTWAIT) in io_recvmsg_prep() 773 flags |= MSG_DONTWAIT; in io_recvmsg_multishot() 865 flags |= MSG_DONTWAIT; in io_recvmsg() 974 flags |= MSG_DONTWAIT; in io_recv() 1092 if (zc->msg_flags & MSG_DONTWAIT) in io_send_zc_prep() 1219 msg_flags |= MSG_DONTWAIT; in io_send_zc() 1293 flags |= MSG_DONTWAIT; in io_sendmsg_zc()
|
/openbmc/linux/net/handshake/ |
H A D | alert.c | 54 msg.msg_flags = MSG_DONTWAIT; in tls_alert_send()
|
/openbmc/linux/net/mctp/test/ |
H A 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()
|
/openbmc/linux/net/caif/ |
H A D | caif_socket.c | 365 timeo = sock_rcvtimeo(sk, flags&MSG_DONTWAIT); in caif_stream_recvmsg() 536 noblock = msg->msg_flags & MSG_DONTWAIT; in caif_seqpkt_sendmsg() 602 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in caif_stream_sendmsg() 625 msg->msg_flags&MSG_DONTWAIT, in caif_stream_sendmsg() 646 msg->msg_flags&MSG_DONTWAIT, timeo); in caif_stream_sendmsg()
|
/openbmc/linux/tools/testing/selftests/bpf/prog_tests/ |
H A D | xdp_metadata.c | 188 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()
|
/openbmc/obmc-console/ |
H A D | socket-handler.c | 145 flags |= MSG_DONTWAIT; in send_all() 278 rc = recv(client->fd, buf, sizeof(buf), MSG_DONTWAIT); in client_poll()
|
/openbmc/linux/tools/testing/vsock/ |
H A D | vsock_test.c | 318 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()
|
/openbmc/linux/drivers/nvme/target/ |
H A D | tcp.c | 583 .msg_flags = MSG_DONTWAIT | MSG_MORE | MSG_SPLICE_PAGES, in nvmet_try_send_data_pdu() 614 .msg_flags = MSG_DONTWAIT | MSG_SPLICE_PAGES, in nvmet_try_send_data() 663 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_SPLICE_PAGES, }; in nvmet_try_send_response() 693 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_SPLICE_PAGES, }; in nvmet_try_send_r2t() 723 struct msghdr msg = { .msg_flags = MSG_DONTWAIT }; in nvmet_try_send_ddgst() 1120 struct msghdr msg = { .msg_flags = MSG_DONTWAIT }; in nvmet_tcp_try_recv_pdu() 1209 struct msghdr msg = { .msg_flags = MSG_DONTWAIT }; in nvmet_tcp_try_recv_ddgst() 1388 c->recv_msg.msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL; in nvmet_tcp_alloc_cmd()
|
/openbmc/linux/drivers/infiniband/sw/siw/ |
H A D | siw_qp_tx.c | 328 .msg_flags = (MSG_MORE | MSG_DONTWAIT | MSG_SPLICE_PAGES), in siw_tcp_sendpages() 442 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_EOR }; in siw_tx_hdt() 452 rv = siw_tx_ctrl(c_tx, s, MSG_DONTWAIT | MSG_MORE); in siw_tx_hdt() 883 msg_flags = MSG_DONTWAIT; in siw_qp_sq_proc_tx() 885 msg_flags = MSG_DONTWAIT | MSG_MORE; in siw_qp_sq_proc_tx()
|
/openbmc/linux/net/ipv4/ |
H A D | tcp_bpf.c | 298 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in tcp_bpf_recvmsg_parser() 358 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 D | udp_bpf.c | 89 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in udp_bpf_recvmsg()
|
/openbmc/linux/net/x25/ |
H A D | x25_out.c | 52 int sent=0, noblock = X25_SKB_CB(skb)->flags & MSG_DONTWAIT; in x25_output()
|
/openbmc/linux/net/vmw_vsock/ |
H A D | vsock_bpf.c | 95 long timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in vsock_bpf_recvmsg()
|
/openbmc/linux/net/unix/ |
H A D | unix_bpf.c | 81 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in unix_bpf_recvmsg()
|
H A D | af_unix.c | 1697 skb = skb_recv_datagram(sk, (flags & O_NONBLOCK) ? MSG_DONTWAIT : 0, in unix_accept() 1931 msg->msg_flags & MSG_DONTWAIT, &err, in unix_dgram_sendmsg() 1947 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in unix_dgram_sendmsg() 2101 skb = sock_alloc_send_skb(sock->sk, 1, msg->msg_flags & MSG_DONTWAIT, &err); in queue_oob() 2193 msg->msg_flags & MSG_DONTWAIT, in unix_stream_sendmsg() 2207 msg->msg_flags & MSG_DONTWAIT, &err, in unix_stream_sendmsg() 2335 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in __unix_dgram_recvmsg() 2448 skb = skb_recv_datagram(sk, MSG_DONTWAIT, &err); in unix_read_skb() 2612 skb = skb_recv_datagram(sk, MSG_DONTWAIT, &err); in unix_stream_read_skb() 2658 int noblock = flags & MSG_DONTWAIT; in unix_stream_read_generic() [all …]
|
/openbmc/linux/net/rxrpc/ |
H A D | recvmsg.c | 296 timeo = sock_rcvtimeo(&rx->sk, flags & MSG_DONTWAIT); in rxrpc_recvmsg() 368 if (flags & MSG_DONTWAIT) in rxrpc_recvmsg()
|
/openbmc/linux/net/tipc/ |
H A D | topsrv.c | 271 msg.msg_flags = MSG_DONTWAIT; in tipc_conn_send_to_sock() 401 ret = sock_recvmsg(con->sock, &msg, MSG_DONTWAIT); in tipc_conn_rcv_from_sock()
|
/openbmc/linux/net/mctp/ |
H A D | af_mctp.c | 161 msg->msg_flags & MSG_DONTWAIT, &rc); in mctp_sendmsg() 216 if (flags & ~(MSG_DONTWAIT | MSG_TRUNC | MSG_PEEK)) in mctp_recvmsg()
|