Home
last modified time | relevance | path

Searched refs:MSG_WAITALL (Results 1 – 25 of 26) sorted by relevance

12

/linux/tools/testing/selftests/net/
H A Dtls.c446 EXPECT_EQ(recv(self->cfd, recv_buf, to_send, MSG_WAITALL), to_send); in TEST_F()
450 EXPECT_EQ(recv(self->cfd, buf, st.st_size, MSG_WAITALL), st.st_size); in TEST_F()
482 EXPECT_EQ(recv(self->cfd, buf, test_payload_size, MSG_WAITALL), in chunked_sendfile()
545 EXPECT_EQ(recv(self->cfd, buf, send_len * 2, MSG_WAITALL), in TEST_F()
567 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len); in TEST_F()
586 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len); in TEST_F()
611 EXPECT_EQ(recv(self->cfd, buf, SEND_LEN * frags, MSG_WAITALL), in TEST_F()
727 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len); in TEST_F()
761 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len); in TEST_F()
777 EXPECT_EQ(recv(self->cfd, buf, send_len2, MSG_WAITALL), send_len2); in TEST_F()
[all …]
H A Dio_uring_zerocopy_tx.c127 unsigned msg_flags = MSG_WAITALL; in do_tx()
/linux/io_uring/
H A Dnet.c155 if (!(flags & MSG_WAITALL)) in io_net_retry()
435 sr->msg_flags |= MSG_WAITALL; in io_sendmsg_prep()
560 if (flags & MSG_WAITALL) in io_sendmsg()
671 if (flags & MSG_WAITALL || sr->flags & IORING_RECVSEND_BUNDLE) in io_send()
813 if (sr->msg_flags & MSG_WAITALL) in io_recvmsg_prep()
1065 if (flags & MSG_WAITALL && !kmsg->msg.msg_controllen) in io_recvmsg()
1086 } else if ((flags & MSG_WAITALL) && (kmsg->msg.msg_flags & (MSG_TRUNC | MSG_CTRUNC))) { in io_recvmsg()
1212 if (flags & MSG_WAITALL) in io_recv()
1232 } else if ((flags & MSG_WAITALL) && (kmsg->msg.msg_flags & (MSG_TRUNC | MSG_CTRUNC))) { in io_recv()
1492 if (msg_flags & MSG_WAITALL) in io_send_zc()
[all …]
/linux/tools/usb/usbip/src/
H A Dusbip_network.c108 nbytes = recv(sockfd, buff, bufflen, MSG_WAITALL); in usbip_net_xmit()
/linux/tools/testing/selftests/coredump/
H A Dstackdump_test.c597 ret = recv(fd, &mark, sizeof(mark), MSG_WAITALL); in recv_marker()
643 ret = recv(fd, req, field_size, MSG_PEEK | MSG_WAITALL); in read_coredump_req()
656 ret = recv(fd, req, ack_size, MSG_WAITALL); in read_coredump_req()
678 ret = recv(fd, buffer, sizeof(buffer), MSG_WAITALL); in read_coredump_req()
/linux/tools/perf/trace/beauty/include/linux/
H A Dsocket.h313 #define MSG_WAITALL 0x100 /* Wait for a full request */ macro
/linux/net/smc/
H A Dsmc_rx.c370 target = sock_rcvlowat(sk, flags & MSG_WAITALL, len); in smc_rx_recvmsg()
H A Dsmc_clc.c709 krflags = MSG_PEEK | MSG_WAITALL; in smc_clc_wait_msg()
759 krflags = MSG_WAITALL; in smc_clc_wait_msg()
/linux/fs/
H A Dcoredump.c813 MSG_PEEK | MSG_WAITALL)) in coredump_sock_request()
829 if (!coredump_sock_recv(cprm->file, &ack, usize, MSG_WAITALL)) in coredump_sock_request()
/linux/tools/testing/selftests/bpf/
H A Dxdp_features.c234 n = recvfrom(sockfd, buf, sizeof(buf), MSG_WAITALL, in dut_echo_thread()
/linux/drivers/usb/usbip/
H A Dusbip_common.c320 result = sock_recvmsg(sock, &msg, MSG_WAITALL); in usbip_recv()
/linux/net/bluetooth/
H A Daf_bluetooth.c429 target = sock_rcvlowat(sk, flags & MSG_WAITALL, size); in bt_sock_stream_recvmsg()
/linux/fs/afs/
H A Drxrpc.c405 msg.msg_flags = MSG_WAITALL | (call->write_iter ? MSG_MORE : 0); in afs_make_call()
/linux/drivers/net/ethernet/chelsio/inline_crypto/chtls/
H A Dchtls_io.c1358 target = sock_rcvlowat(sk, flags & MSG_WAITALL, len); in chtls_pt_recvmsg()
1696 target = sock_rcvlowat(sk, flags & MSG_WAITALL, len); in chtls_recvmsg()
/linux/net/caif/
H A Dcaif_socket.c365 target = sock_rcvlowat(sk, flags&MSG_WAITALL, size); in caif_stream_recvmsg()
/linux/drivers/target/iscsi/
H A Discsi_target_util.c1228 rx_loop = sock_recvmsg(conn->sock, &msg, MSG_WAITALL); in rx_data()
/linux/net/phonet/
H A Dpep.c1269 if (flags & ~(MSG_OOB|MSG_PEEK|MSG_TRUNC|MSG_DONTWAIT|MSG_WAITALL| in pep_recvmsg()
/linux/net/vmw_vsock/
H A Daf_vsock.c2268 target = sock_rcvlowat(sk, flags & MSG_WAITALL, len); in __vsock_stream_recvmsg()
/linux/net/tls/
H A Dtls_sw.c2058 target = sock_rcvlowat(sk, flags & MSG_WAITALL, len); in tls_sw_recvmsg()
/linux/drivers/nvme/host/
H A Dtcp.c1505 msg.msg_flags = MSG_WAITALL; in nvme_tcp_init_connection()
/linux/net/unix/
H A Daf_unix.c2950 target = sock_rcvlowat(sk, flags & MSG_WAITALL, size); in unix_stream_read_generic()
/linux/net/tipc/
H A Dsocket.c2033 required = sock_rcvlowat(sk, flags & MSG_WAITALL, buflen); in tipc_recvstream()
/linux/Documentation/networking/
H A Drxrpc.rst284 (#) MSG_WAITALL can be set to tell sendmsg to ignore signals if the peer is
/linux/net/mptcp/
H A Dprotocol.c2137 target = sock_rcvlowat(sk, flags & MSG_WAITALL, len); in mptcp_recvmsg()
/linux/net/ipv4/
H A Dtcp.c2663 target = sock_rcvlowat(sk, flags & MSG_WAITALL, len); in tcp_recvmsg_locked()

12