Home
last modified time | relevance | path

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

12345

/Linux-v4.19/net/phonet/
Ddatagram.c92 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL| in pn_sendmsg()
106 msg->msg_flags & MSG_DONTWAIT, &err); in pn_sendmsg()
135 if (flags & ~(MSG_PEEK|MSG_TRUNC|MSG_DONTWAIT|MSG_NOSIGNAL| in pn_recvmsg()
Dpep.c1135 if ((msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL| in pep_sendmsg()
1141 flags & MSG_DONTWAIT, &err); in pep_sendmsg()
1151 timeo = sock_sndtimeo(sk, flags & MSG_DONTWAIT); in pep_sendmsg()
1256 if (flags & ~(MSG_OOB|MSG_PEEK|MSG_TRUNC|MSG_DONTWAIT|MSG_WAITALL| in pep_recvmsg()
/Linux-v4.19/tools/testing/selftests/net/
Dudpgso_bench_rx.c123 ret = recv(fd, NULL, 1 << 21, MSG_TRUNC | MSG_DONTWAIT); in do_flush_tcp()
176 ret = recv(fd, rbuf, len, MSG_TRUNC | MSG_DONTWAIT); in do_flush_udp()
Dmsg_zerocopy.c194 flags = MSG_DONTWAIT; in do_sendmsg()
372 if (recvmsg(fd, &msg, MSG_DONTWAIT)) in do_recvmsg_completion()
610 ret = recv(fd, NULL, 1 << 21, MSG_TRUNC | MSG_DONTWAIT); in do_flush_tcp()
629 ret = recv(fd, buf, sizeof(buf), MSG_DONTWAIT | MSG_TRUNC); in do_flush_datagram()
Dudpgso.c505 if (ret == -1 && errno == EAGAIN && (flags & MSG_DONTWAIT)) in recv_one()
560 ret = recv_one(fdr, MSG_DONTWAIT); in run_one()
Dtls.c161 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
163 EXPECT_EQ(recv(self->cfd, buf, send_len * 2, MSG_DONTWAIT), in TEST_F()
468 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_DONTWAIT), -1); in TEST_F()
/Linux-v4.19/net/rds/
Dtcp_send.c68 .msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL, in rds_tcp_sendmsg()
121 int flags = MSG_DONTWAIT | MSG_NOSIGNAL | more; in rds_tcp_xmit()
/Linux-v4.19/tools/testing/selftests/android/ion/
Dipcsocket.c150 ret = sendmsg(sockfd, &msgh, MSG_DONTWAIT); in sendtosocket()
202 ret = recvmsg(sockfd, &msgh, MSG_DONTWAIT); in receivefromsocket()
/Linux-v4.19/net/tls/
Dtls_sw.c359 long timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in tls_sw_sendmsg()
368 if (msg->msg_flags & ~(MSG_MORE | MSG_DONTWAIT | MSG_NOSIGNAL)) in tls_sw_sendmsg()
509 long timeo = sock_sndtimeo(sk, flags & MSG_DONTWAIT); in tls_sw_sendpage()
517 if (flags & ~(MSG_MORE | MSG_DONTWAIT | MSG_NOSIGNAL | in tls_sw_sendpage()
637 if ((flags & MSG_DONTWAIT) || !timeo) { in tls_wait_data()
869 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in tls_sw_recvmsg()
970 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in tls_sw_splice_read()
/Linux-v4.19/net/caif/
Dcaif_socket.c370 timeo = sock_rcvtimeo(sk, flags&MSG_DONTWAIT); in caif_stream_recvmsg()
544 noblock = msg->msg_flags & MSG_DONTWAIT; in caif_seqpkt_sendmsg()
610 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in caif_stream_sendmsg()
633 msg->msg_flags&MSG_DONTWAIT, in caif_stream_sendmsg()
654 msg->msg_flags&MSG_DONTWAIT, timeo); in caif_stream_sendmsg()
/Linux-v4.19/net/core/
Ddatagram.c281 sk_busy_loop(sk, flags & MSG_DONTWAIT); in __skb_try_recv_datagram()
300 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in __skb_recv_datagram()
322 return __skb_recv_datagram(sk, flags | (noblock ? MSG_DONTWAIT : 0), in skb_recv_datagram()
/Linux-v4.19/net/can/
Draw.c761 msg->msg_flags & MSG_DONTWAIT, &err); in raw_sendmsg()
804 noblock = flags & MSG_DONTWAIT; in raw_recvmsg()
805 flags &= ~MSG_DONTWAIT; in raw_recvmsg()
/Linux-v4.19/net/qrtr/
Dqrtr.c738 if (msg->msg_flags & ~(MSG_DONTWAIT)) in qrtr_sendmsg()
789 msg->msg_flags & MSG_DONTWAIT, &rc); in qrtr_sendmsg()
840 skb = skb_recv_datagram(sk, flags & ~MSG_DONTWAIT, in qrtr_recvmsg()
841 flags & MSG_DONTWAIT, &rc); in qrtr_recvmsg()
/Linux-v4.19/net/x25/
Dx25_out.c57 int sent=0, noblock = X25_SKB_CB(skb)->flags & MSG_DONTWAIT; in x25_output()
/Linux-v4.19/net/rxrpc/
Dsendmsg.c275 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in rxrpc_send_data()
311 if (msg->msg_flags & MSG_DONTWAIT) in rxrpc_send_data()
337 sk, size, msg->msg_flags & MSG_DONTWAIT, &ret); in rxrpc_send_data()
Drecvmsg.c446 timeo = sock_rcvtimeo(&rx->sk, flags & MSG_DONTWAIT); in rxrpc_recvmsg()
505 if (flags & MSG_DONTWAIT) in rxrpc_recvmsg()
/Linux-v4.19/net/decnet/
Daf_decnet.c1690 long timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in dn_recvmsg()
1708 if (flags & ~(MSG_CMSG_COMPAT|MSG_PEEK|MSG_OOB|MSG_WAITALL|MSG_DONTWAIT|MSG_NOSIGNAL)) { in dn_recvmsg()
1750 if (flags & MSG_DONTWAIT) { in dn_recvmsg()
1931 if (flags & ~(MSG_TRYHARD|MSG_OOB|MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL|MSG_MORE|MSG_CMSG_COMPAT)) in dn_sendmsg()
1938 timeo = sock_sndtimeo(sk, flags & MSG_DONTWAIT); in dn_sendmsg()
2007 if (flags & MSG_DONTWAIT) { in dn_sendmsg()
2028 flags & MSG_DONTWAIT, &err); in dn_sendmsg()
/Linux-v4.19/net/unix/
Daf_unix.c1678 msg->msg_flags & MSG_DONTWAIT, &err, in unix_dgram_sendmsg()
1694 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in unix_dgram_sendmsg()
1875 msg->msg_flags & MSG_DONTWAIT, &err, in unix_stream_sendmsg()
1947 newskb = sock_alloc_send_pskb(sk, 0, 0, flags & MSG_DONTWAIT, in unix_stream_sendpage()
1958 err = flags & MSG_DONTWAIT ? -EAGAIN : -ERESTARTSYS; in unix_stream_sendpage()
2097 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in unix_dgram_recvmsg()
2253 int noblock = flags & MSG_DONTWAIT; in unix_stream_read_generic()
2492 state.flags = MSG_DONTWAIT; in unix_stream_splice_read()
/Linux-v4.19/net/kcm/
Dkcmsock.c650 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-v4.19/drivers/vhost/
Dnet.c554 .msg_flags = MSG_DONTWAIT, in handle_tx_copy()
621 .msg_flags = MSG_DONTWAIT, in handle_tx_zerocopy()
909 .msg_flags = MSG_DONTWAIT, in handle_rx()
975 1, MSG_DONTWAIT | MSG_TRUNC); in handle_rx()
989 sock_len, MSG_DONTWAIT | MSG_TRUNC); in handle_rx()
/Linux-v4.19/net/netrom/
Daf_netrom.c1039 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_CMSG_COMPAT)) in nr_sendmsg()
1091 if ((skb = sock_alloc_send_skb(sk, size, msg->msg_flags & MSG_DONTWAIT, &err)) == NULL) in nr_sendmsg()
1158 if ((skb = skb_recv_datagram(sk, flags & ~MSG_DONTWAIT, flags & MSG_DONTWAIT, &er)) == NULL) { in nr_recvmsg()
/Linux-v4.19/drivers/infiniband/core/
Dnetlink.c267 err = netlink_unicast(nls, skb, pid, MSG_DONTWAIT); in rdma_nl_unicast()
/Linux-v4.19/net/netfilter/
Dnfnetlink_cttimeout.c292 MSG_DONTWAIT); in cttimeout_get_timeout()
481 ret = netlink_unicast(ctnl, skb2, NETLINK_CB(skb).portid, MSG_DONTWAIT); in cttimeout_default_get()
/Linux-v4.19/net/bluetooth/
Daf_bluetooth.c244 int noblock = flags & MSG_DONTWAIT; in bt_sock_recvmsg()
335 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in bt_sock_stream_recvmsg()
/Linux-v4.19/net/tipc/
Dtopsrv.c276 msg.msg_flags = MSG_DONTWAIT; in tipc_conn_send_to_sock()
404 ret = sock_recvmsg(con->sock, &msg, MSG_DONTWAIT); in tipc_conn_rcv_from_sock()

12345