Home
last modified time | relevance | path

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

12

/freebsd/tests/sys/kern/
H A Dunix_seqpacket_test.c221 rsize = recv(sv[1], recv_buf, pktsize, MSG_WAITALL); in test_sendrecv_symmetric_buffers()
277 rsize = recv(sv[1], rcvbuf, pktsize, MSG_WAITALL); in test_pipe_simulator()
343 rsize = recv(td->so, rcvbuf, td->pktsize, MSG_WAITALL); in test_pipe_reader()
739 rsize = recv(sv[1], recv_buf, bufsize, MSG_WAITALL); in ATF_TC_BODY()
784 rsize = recvfrom(sv[1], recv_buf, bufsize, MSG_WAITALL, in ATF_TC_BODY()
832 rsize = recv(sv[1], recv_buf, bufsize, MSG_WAITALL); in ATF_TC_BODY()
912 rsize = recv(sv[1], recv_buf, bufsize, MSG_WAITALL); in ATF_TC_BODY()
926 rsize = recv(sv[1], recv_buf, bufsize, MSG_WAITALL); in ATF_TC_BODY()
1002 rsize = recv(sv[1], recv_buf, pktsize, MSG_WAITALL); in ATF_TC_BODY()
1016 rsize = recv(sv[1], recv_buf, pktsize, MSG_WAITALL); in ATF_TC_BODY()
[all …]
H A Dsocket_msg_waitall.c51 n = recv(s, buf, buflen, MSG_WAITALL); in close_test_client()
/freebsd/tests/sys/netlink/
H A Dnetlink_socket.c87 ATF_REQUIRE(recv(fd, buf, sizeof(hdr), MSG_WAITALL | MSG_PEEK) == in fullsocket()
156 ss = recv(fd, buf, 0, MSG_WAITALL | MSG_PEEK | MSG_TRUNC); in ATF_TC_BODY()
158 ATF_REQUIRE(recv(fd, buf, ss, MSG_WAITALL) == ss); in ATF_TC_BODY()
218 ss = recvmsg(fd, &msg, MSG_WAITALL | MSG_PEEK | MSG_TRUNC); in ATF_TC_BODY()
/freebsd/sbin/ggate/ggatec/
H A Dggatec.c233 numbytesprocd = g_gate_recv(recvfd, &hdr, sizeof(hdr), MSG_WAITALL); in recv_thread()
268 ggio.gctl_length, MSG_WAITALL); in recv_thread()
343 if (g_gate_recv(sfd, &ver, sizeof(ver), MSG_WAITALL) == -1) { in handshake()
382 if (g_gate_recv(sfd, &sinit, sizeof(sinit), MSG_WAITALL) == -1) { in handshake()
/freebsd/sbin/devd/tests/
H A Dclient_test.c112 len = recv(s, event, sizeof(event) - 1, MSG_WAITALL); in ATF_TC_BODY()
/freebsd/sbin/ggate/ggated/
H A Dggated.c709 MSG_WAITALL); in recv_thread()
737 MSG_WAITALL); in recv_thread()
931 data = g_gate_recv(sfd, &ver, sizeof(ver), MSG_WAITALL); in handshake()
961 data = g_gate_recv(sfd, &cinit, sizeof(cinit), MSG_WAITALL); in handshake()
/freebsd/contrib/netbsd-tests/lib/libc/sys/
H A Dt_recvmmsg.c114 MSG_WAITALL, &ts); in ATF_TC_BODY()
/freebsd/contrib/openbsm/bin/auditdistd/
H A Dproto_common.c213 done = recv(sock, data, size, MSG_WAITALL); in proto_common_recv()
H A Dproto_tls.c588 MSG_WAITALL)) { in tls_connect_wait()
/freebsd/lib/libdevdctl/
H A Dconsumer.cc140 len = ::recv(m_devdSockFD, buf, MAX_EVENT_SIZE, MSG_WAITALL); in ReadEvent()
/freebsd/sbin/hastd/
H A Dproto_common.c213 done = recv(sock, data, size, MSG_WAITALL); in proto_common_recv()
/freebsd/tools/regression/netinet/tcpstream/
H A Dtcpstream.c155 i * sizeof(long), MSG_WAITALL); in tcpstream_server()
/freebsd/tools/test/stress2/misc/
H A Djumbo.sh136 if ((n = recvfrom(msgsock, buf, i, MSG_WAITALL, NULL,
/freebsd/contrib/ofed/librdmacm/examples/
H A Driostream.c566 flags = (flags & ~MSG_DONTWAIT) | MSG_WAITALL; in set_test_opt()
581 flags = (flags & ~MSG_DONTWAIT) | MSG_WAITALL; in set_test_opt()
H A Drstream.c578 flags = (flags & ~MSG_DONTWAIT) | MSG_WAITALL; in set_test_opt()
602 flags = (flags & ~MSG_DONTWAIT) | MSG_WAITALL; in set_test_opt()
/freebsd/sys/netsmb/
H A Dsmb_trantcp.c376 rcvflg = MSG_WAITALL; in nbssn_recv()
386 rcvflg = MSG_WAITALL; in nbssn_recv()
/freebsd/sys/sys/
H A Dsocket.h455 #define MSG_WAITALL 0x00000040 /* wait for full request or error */ macro
/freebsd/sys/ofed/drivers/infiniband/ulp/sdp/
H A Dsdp_main.c1300 if (sbavail(sb) && !(flags & MSG_WAITALL) && in sdp_sorecv()
1310 if ((flags & MSG_WAITALL) && in sdp_sorecv()
1400 if ((flags & MSG_WAITALL) && uio->uio_resid > 0) in sdp_sorecv()
/freebsd/tools/regression/sockets/unix_cmsg/
H A Duc_common.c324 ssize = recvmsg(fd, msghdr, MSG_WAITALL); in uc_message_recv()
/freebsd/lib/libradius/
H A Dradlib.c696 MSGSIZE, MSG_WAITALL, (struct sockaddr *)&from, &fromlen); in rad_continue_send_request()
807 MSGSIZE, MSG_WAITALL, (struct sockaddr *)&from, &fromlen); in rad_receive_request()
/freebsd/sys/kern/
H A Duipc_socket.c3110 while (flags & MSG_WAITALL && m == NULL && uio->uio_resid > 0 &&
3284 if (sbavail(sb) > 0 && !(flags & MSG_WAITALL) &&
3294 if ((flags & MSG_WAITALL) &&
3381 (((flags & MSG_WAITALL) && uio->uio_resid > 0) ||
3394 if ((flags & MSG_WAITALL) && uio->uio_resid > 0)
/freebsd/tests/sys/aio/
H A Daio_test.c1239 done = recv(s[0], buffer[0], buffer_size, MSG_WAITALL); in aio_socket_blocking_short_write_test()
1397 done = recv(s[0], buffer[0], buffer_size, MSG_WAITALL); in ATF_TC_BODY()
/freebsd/sys/dev/hyperv/hvsock/
H A Dhv_sock.c729 if (!(flags & MSG_WAITALL) && orig_resid > uio->uio_resid) in hvs_trans_soreceive()
/freebsd/usr.sbin/ppp/
H A Dbundle.c1428 if ((got = recvmsg(s, &msg, MSG_WAITALL)) != (ssize_t)iov[0].iov_len) { in bundle_ReceiveDatalink()
/freebsd/sys/compat/linux/
H A Dlinux_socket.c621 ret_flags |= MSG_WAITALL; in linux_to_bsd_msg_flags()

12