MSG_DONTWAIT
mmsg_vector->msg_hdr.msg_flags = MSG_DONTWAIT;
if (flags & MSG_DONTWAIT)
if (flags & MSG_DONTWAIT)
err = drbd_recv_short(connection->data.socket, buffer, size, MSG_NOSIGNAL|MSG_DONTWAIT);
rr = drbd_recv_short(*sock, tb, 4, MSG_DONTWAIT | MSG_PEEK);
err = netlink_unicast(rnet->nl_sock, skb, pid, MSG_DONTWAIT);
MSG_DONTWAIT);
MSG_DONTWAIT);
rcvd = ksock_recv(s, (char *)&word, sizeof(word), MSG_DONTWAIT);
to_rcv + 4, MSG_DONTWAIT);
struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_EOR };
.msg_flags = (MSG_MORE | MSG_DONTWAIT | MSG_SPLICE_PAGES),
rv = siw_tx_ctrl(c_tx, s, MSG_DONTWAIT | MSG_MORE);
rv = siw_sendmsg(s, MSG_DONTWAIT | MSG_EOR, &iov[seg],
rv = siw_sendmsg(s, MSG_DONTWAIT | MSG_EOR, iov, seg + 1,
msg_flags = MSG_DONTWAIT;
msg_flags = MSG_DONTWAIT | MSG_MORE;
if (msg->msg_flags & ~(MSG_DONTWAIT | MSG_NOSIGNAL)) {
msg->msg_flags & MSG_DONTWAIT, &ret, 0);
m->msg_flags & MSG_DONTWAIT);
if (flags & ~(MSG_DONTWAIT|MSG_TRUNC)) {
ret = tap_do_read(q, &m->msg_iter, flags & MSG_DONTWAIT, skb);
m->msg_flags & MSG_DONTWAIT,
if (flags & ~(MSG_DONTWAIT|MSG_TRUNC|MSG_ERRQUEUE)) {
ret = tun_do_read(tun, tfile, &m->msg_iter, flags & MSG_DONTWAIT, ptr);
.msg_flags = MSG_DONTWAIT | MSG_SPLICE_PAGES,
struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_SPLICE_PAGES, };
struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_MORE, };
struct msghdr msg = { .msg_flags = MSG_DONTWAIT };
struct msghdr msg = { .msg_flags = MSG_DONTWAIT };
struct msghdr msg = { .msg_flags = MSG_DONTWAIT };
c->recv_msg.msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL;
.msg_flags = MSG_DONTWAIT | MSG_MORE | MSG_SPLICE_PAGES,
.msg_flags = MSG_DONTWAIT | MSG_SPLICE_PAGES,
struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_SPLICE_PAGES, };
struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_SPLICE_PAGES, };
struct msghdr msg = { .msg_flags = MSG_DONTWAIT };
msg.msg_flags |= MSG_DONTWAIT;
iv.iov_len, MSG_DONTWAIT);
.msg_flags = MSG_DONTWAIT,
1, MSG_DONTWAIT | MSG_TRUNC);
sock_len, MSG_DONTWAIT | MSG_TRUNC);
.msg_flags = MSG_DONTWAIT,
.msg_flags = MSG_DONTWAIT,
ret = inet_recvmsg(map->sock, &msg, wanted, MSG_DONTWAIT);
msg.msg_flags |= MSG_DONTWAIT;
if ((flags & MSG_DONTWAIT) && !pvcalls_front_write_todo(map)) {
while (!(flags & MSG_DONTWAIT) && !pvcalls_front_read_todo(map)) {
ret = (flags & MSG_DONTWAIT) ? -EAGAIN : 0;
.msg_flags = MSG_SPLICE_PAGES | MSG_DONTWAIT | MSG_NOSIGNAL,
msg.msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL;
struct msghdr msg = { .msg_flags = MSG_DONTWAIT, };
return sock_recvmsg(sock, &msg, MSG_DONTWAIT);
msg.msg_flags = MSG_DONTWAIT | MSG_SPLICE_PAGES;
int msg_flags = server->noblocksnd ? MSG_DONTWAIT : 0;
smb_msg->msg_flags = MSG_DONTWAIT + MSG_NOSIGNAL;
msg.msg_flags |= MSG_DONTWAIT;
msg->msg_flags & MSG_DONTWAIT, &err);
err = netlink_unicast(sk, skb, portid, MSG_DONTWAIT);
flags |= MSG_DONTWAIT;
flags |= MSG_DONTWAIT;
flags |= MSG_DONTWAIT;
if (zc->msg_flags & MSG_DONTWAIT)
msg_flags |= MSG_DONTWAIT;
if (sr->msg_flags & MSG_DONTWAIT)
flags |= MSG_DONTWAIT;
flags |= MSG_DONTWAIT;
if (sr->msg_flags & MSG_DONTWAIT)
if (flags & ~(MSG_DONTWAIT | MSG_PEEK))
if (m->msg_flags & MSG_DONTWAIT) {
timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT);
timeo = sock_sndtimeo(sk, !!(msg_flags & MSG_DONTWAIT));
if (flags & ~(MSG_DONTWAIT | MSG_NOSIGNAL | MSG_ERRQUEUE | MSG_CMSG_COMPAT))
msg->msg_flags & MSG_DONTWAIT);
msg->msg_flags & MSG_DONTWAIT);
msg->msg_flags & MSG_DONTWAIT);
msg->msg_flags & MSG_DONTWAIT);
msg->msg_flags & MSG_DONTWAIT);
if (msg->msg_flags & MSG_DONTWAIT)
skb = sock_alloc_send_skb(sk, so->ll.mtu, msg->msg_flags & MSG_DONTWAIT,
if (flags & ~(MSG_DONTWAIT | MSG_TRUNC | MSG_PEEK | MSG_CMSG_COMPAT))
if (flags & ~(MSG_DONTWAIT | MSG_ERRQUEUE | MSG_CMSG_COMPAT))
msg->msg_flags & MSG_DONTWAIT, &ret);
skb = sock_alloc_send_skb(sk, size, msg->msg_flags & MSG_DONTWAIT,
struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL };
struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL };
struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL };
.msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL | more,
#define CEPH_MSG_FLAGS (MSG_DONTWAIT | MSG_NOSIGNAL)
sk_busy_loop(sk, flags & MSG_DONTWAIT);
timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT);
msg.msg_flags = MSG_DONTWAIT | flags;
.msg_flags = MSG_SPLICE_PAGES | MSG_DONTWAIT |
msg.msg_flags = MSG_DONTWAIT;
msg->msg_flags & MSG_DONTWAIT, &err);
msg->msg_flags & MSG_DONTWAIT,
ipc, rt, MSG_DONTWAIT) < 0) {
(flags & MSG_DONTWAIT), &err);
len, 0, &ipc, &rt, MSG_DONTWAIT);
flags & MSG_DONTWAIT, &err);
flags = (msg->msg_flags & MSG_DONTWAIT) ? O_NONBLOCK : 0;
timeo = sock_sndtimeo(sk, flags & MSG_DONTWAIT);
err = tcp_recvmsg_locked(sk, &msg, inq, MSG_DONTWAIT,
timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT);
sk_busy_loop(sk, flags & MSG_DONTWAIT);
timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT);
timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT);
timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT);
timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT);
sk_busy_loop(sk, flags & MSG_DONTWAIT);
skb = skb_recv_udp(sk, MSG_DONTWAIT, &err);
timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT);
dst_rt6_info(dst), MSG_DONTWAIT)) {
MSG_DONTWAIT)) {
(flags & MSG_DONTWAIT), &err);
MSG_DONTWAIT);
err = (flags&MSG_DONTWAIT) ? -EAGAIN : -EHOSTUNREACH;
flags & MSG_DONTWAIT, &err);
int noblock = msg->msg_flags & MSG_DONTWAIT;
flags = MSG_DONTWAIT;
.msg_flags = MSG_DONTWAIT | MSG_SPLICE_PAGES,
long timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT);
if (flags & ~(MSG_PEEK|MSG_DONTWAIT|MSG_TRUNC|MSG_CMSG_COMPAT))
const int nonblock = flags & MSG_DONTWAIT;
int noblock = flags & MSG_DONTWAIT;
msg->msg_flags & MSG_DONTWAIT, &rc);
if (flags & ~(MSG_DONTWAIT | MSG_TRUNC | MSG_PEEK))
skb2 = skb_recv_datagram(sock->sk, MSG_DONTWAIT, &rc);
MSG_DONTWAIT, &rc);
MSG_DONTWAIT, &rc);
skb2 = skb_recv_datagram(sock->sk, MSG_DONTWAIT, &rc);
skb2 = skb_recv_datagram(sock->sk, MSG_DONTWAIT, &rc);
skb2 = skb_recv_datagram(sock->sk, MSG_DONTWAIT, &rc);
skb2 = skb_recv_datagram(sock->sk, MSG_DONTWAIT, &rc);
rx_skb1 = skb_recv_datagram(t1.sock->sk, MSG_DONTWAIT, &rc);
rx_skb2 = skb_recv_datagram(t2.sock->sk, MSG_DONTWAIT, &rc);
rx_skb1 = skb_recv_datagram(t1.sock->sk, MSG_DONTWAIT, &rc);
rx_skb2 = skb_recv_datagram(t2.sock->sk, MSG_DONTWAIT, &rc);
rx_skb = skb_recv_datagram(sock->sk, MSG_DONTWAIT, &rc);
rx_skb = skb_recv_datagram(sock->sk, MSG_DONTWAIT, &rc);
skb_sk = skb_recv_datagram(sock->sk, MSG_DONTWAIT, &rc);
MSG_DONTWAIT | MSG_TRUNC);
msg->msg_flags |= MSG_DONTWAIT;
if (ret == -EINPROGRESS && !(msg->msg_flags & MSG_DONTWAIT)) {
msg->msg_flags &= MSG_MORE | MSG_DONTWAIT | MSG_NOSIGNAL |
timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT);
timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT);
struct msghdr msg = {.msg_flags = MSG_DONTWAIT|MSG_NOSIGNAL};
len = sock_recvmsg(sock, &msg, MSG_DONTWAIT);
err = netlink_unicast(sk, skb, dst_portid, msg->msg_flags & MSG_DONTWAIT);
skb = sock_alloc_send_skb(sk, total_size, flags & MSG_DONTWAIT, err);
skb = nfc_alloc_send_skb(sock->dev, &sock->sk, MSG_DONTWAIT,
bool need_wait = !(msg->msg_flags & MSG_DONTWAIT);
timeo = sock_sndtimeo(&po->sk, msg->msg_flags & MSG_DONTWAIT);
msg->msg_flags & MSG_DONTWAIT, &err);
if (flags & ~(MSG_PEEK|MSG_DONTWAIT|MSG_TRUNC|MSG_CMSG_COMPAT|MSG_ERRQUEUE))
if (flags & ~(MSG_PEEK|MSG_TRUNC|MSG_DONTWAIT|MSG_NOSIGNAL|
if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL|
msg->msg_flags & MSG_DONTWAIT, &err);
if ((msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL|
flags & MSG_DONTWAIT, &err);
timeo = sock_sndtimeo(sk, flags & MSG_DONTWAIT);
if (flags & ~(MSG_OOB|MSG_PEEK|MSG_TRUNC|MSG_DONTWAIT|MSG_WAITALL|
skb = skb_recv_datagram(sk, (arg->flags & O_NONBLOCK) ? MSG_DONTWAIT : 0,
if (msg->msg_flags & ~(MSG_DONTWAIT))
msg->msg_flags & MSG_DONTWAIT, &rc);
iv.iov_len, MSG_DONTWAIT);
int ret = 0, nonblock = msg_flags & MSG_DONTWAIT;
int nonblock = msg->msg_flags & MSG_DONTWAIT;
if (msg->msg_flags & ~(MSG_DONTWAIT | MSG_CMSG_COMPAT | MSG_ZEROCOPY)) {
msg.msg_flags = MSG_SPLICE_PAGES | MSG_DONTWAIT | MSG_NOSIGNAL;
.msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL,
timeo = sock_rcvtimeo(&rx->sk, flags & MSG_DONTWAIT);
if (flags & MSG_DONTWAIT)
timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT);
if (msg->msg_flags & MSG_DONTWAIT)
timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT);
timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT);
sk_busy_loop(sk, flags & MSG_DONTWAIT);
timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT);
skb = sctp_skb_recv_datagram(sk, MSG_PEEK | MSG_DONTWAIT, &err);
flags = MSG_DONTWAIT;
timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT);
timeo = sock_sndtimeo(sk, flags & MSG_DONTWAIT);
msg.msg_flags = MSG_DONTWAIT;
msg.msg_flags = MSG_DONTWAIT;
flags |= MSG_DONTWAIT;
flags |= MSG_DONTWAIT;
msg_sys->msg_flags |= MSG_DONTWAIT;
flags |= MSG_DONTWAIT;
flags |= MSG_DONTWAIT;
ret = sock_recvmsg(sock, &msg, MSG_DONTWAIT);
ret = sock_recvmsg(sock, msg, MSG_DONTWAIT);
.msg_flags = MSG_DONTWAIT,
0, 0, MSG_PEEK | MSG_DONTWAIT);
skb = skb_recv_udp(svsk->sk_sk, MSG_DONTWAIT, &err);
skb = skb_recv_udp(sk, MSG_DONTWAIT, &err);
ret = xs_read_stream(transport, MSG_DONTWAIT);
#define XS_SENDMSG_FLAGS (MSG_DONTWAIT | MSG_NOSIGNAL)
long timeout = sock_sndtimeo(sk, m->msg_flags & MSG_DONTWAIT);
long timeout = sock_sndtimeo(sk, m->msg_flags & MSG_DONTWAIT);
timeout = sock_rcvtimeo(sk, flags & MSG_DONTWAIT);
timeout = sock_rcvtimeo(sk, flags & MSG_DONTWAIT);
m.msg_flags = MSG_DONTWAIT;
msg.msg_flags = MSG_DONTWAIT;
ret = sock_recvmsg(con->sock, &msg, MSG_DONTWAIT);
~(MSG_MORE | MSG_DONTWAIT | MSG_NOSIGNAL |
timeo = sock_sndtimeo(sk, flags & MSG_DONTWAIT);
MSG_DONTWAIT | MSG_NOSIGNAL |
err = tls_rx_reader_lock(sk, ctx, flags & MSG_DONTWAIT);
err = tls_rx_rec_wait(sk, flags & MSG_DONTWAIT,
long timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT);
if (msg->msg_flags & ~(MSG_MORE | MSG_DONTWAIT | MSG_NOSIGNAL |
skb = skb_recv_datagram(sk, (arg->flags & O_NONBLOCK) ? MSG_DONTWAIT : 0,
msg->msg_flags & MSG_DONTWAIT, &err,
timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT);
skb = sock_alloc_send_skb(sk, 1, msg->msg_flags & MSG_DONTWAIT, &err);
msg->msg_flags & MSG_DONTWAIT,
msg->msg_flags & MSG_DONTWAIT, &err,
timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT);
skb = skb_recv_datagram(sk, MSG_DONTWAIT, &err);
int noblock = state->flags & MSG_DONTWAIT;
state.flags = MSG_DONTWAIT;
timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT);
timeout = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT);
timeout = sock_rcvtimeo(sk, flags & MSG_DONTWAIT);
timeout = sock_rcvtimeo(sk, flags & MSG_DONTWAIT);
skb = __skb_recv_datagram(sk, &vvs->rx_queue, MSG_DONTWAIT, &off, &err);
long timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT);
int noblock = msg->msg_flags & MSG_DONTWAIT;
if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_OOB|MSG_EOR|MSG_CMSG_COMPAT))
int sent=0, noblock = X25_SKB_CB(skb)->flags & MSG_DONTWAIT;
bool need_wait = !(m->msg_flags & MSG_DONTWAIT);
bool need_wait = !(flags & MSG_DONTWAIT);
return flags & MSG_DONTWAIT ? -EAGAIN : 0;
long timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT);
if (msg->msg_flags & ~MSG_DONTWAIT)
err = espintcp_push_msgs(sk, msg->msg_flags & MSG_DONTWAIT);
if (err != -EAGAIN || !(msg->msg_flags & MSG_DONTWAIT))
err = espintcp_push_msgs(sk, msg->msg_flags & MSG_DONTWAIT);
if (flags & MSG_DONTWAIT && errno == EAGAIN)
MSG_DONTWAIT);
ret = recv(fd, &rbuf, 1, MSG_DONTWAIT);
nread = recv(new_fd, &rcv_cmd, sizeof(rcv_cmd), MSG_DONTWAIT);
nread = recv(srv_fd, &rcv_cmd, sizeof(rcv_cmd), MSG_DONTWAIT);
int bytes = recv(sk[i], buf, 1, MSG_DONTWAIT | MSG_TRUNC);
recvd = recv_timeout(p1, rcv, sizeof(rcv), MSG_DONTWAIT, 1);
recvd = recv_timeout(p1, rcv, 1, MSG_DONTWAIT, 1);
recvd += recv_timeout(p1, rcv + 1, sizeof(rcv) - 1, MSG_DONTWAIT, 1);
recvd = recv(p1, rcv, sizeof(rcv), MSG_DONTWAIT);
recvd = recv(p0, rcv, sizeof(rcv), MSG_DONTWAIT);
recvd = recv_timeout(p1, rcv, expected, MSG_DONTWAIT, 1);
recvd = recv_timeout(p1, rcv, expected, MSG_DONTWAIT, 1);
n = recv(c1, &b, 1, MSG_DONTWAIT);
recvd = recv_timeout(c1, &buf, sizeof(buf), MSG_DONTWAIT, IO_TIMEOUT_SEC);
try_recv("bpf.recv(sd_send)", sd_send, MSG_DONTWAIT, false);
try_recv("bpf.recv(sd_in)", sd_in, MSG_DONTWAIT, false);
try_recv("bpf.recv(sd_out)", sd_out, MSG_DONTWAIT, false);
try_recv("bpf.recv(sd_recv)", sd_recv, MSG_DONTWAIT, false);
MSG_OOB | MSG_DONTWAIT, false);
MSG_OOB | MSG_DONTWAIT, false);
expected, MSG_DONTWAIT,
recvd = recv_timeout(p, rcv, total + 1, MSG_DONTWAIT, IO_TIMEOUT_SEC);
recvd = recv_timeout(p, rcv, sizeof(rcv), MSG_DONTWAIT, 1);
recvd = recv_timeout(p, rcv, sizeof(rcv), MSG_DONTWAIT, IO_TIMEOUT_SEC);
recvd = recv_timeout(p, rcv, sizeof(rcv), MSG_DONTWAIT, 1);
recvd = recv_timeout(p, rcv, sizeof(rcv), MSG_DONTWAIT, IO_TIMEOUT_SEC);
recvd = recv_timeout(p, rcv, sizeof(rcv), MSG_DONTWAIT,
recvd = recv_timeout(p, rcv, sizeof(rcv), MSG_DONTWAIT,
recvd = recv_timeout(c1, rcv, sizeof(rcv), MSG_DONTWAIT,
recvd = recv_timeout(c1, rcv, off, MSG_DONTWAIT,
recvd += recv_timeout(c1, rcv + off, sizeof(rcv) - off, MSG_DONTWAIT,
sendto(fd, buf, sizeof(buf), MSG_DONTWAIT,
*ret = sendto(xsk_socket__fd(xsk->xsk), NULL, 0, MSG_DONTWAIT, NULL, 0);
ret = sendto(xsk_socket__fd(xsk->xsk), NULL, 0, MSG_DONTWAIT, NULL, 0);
ret = recvfrom(xsk_socket__fd(xsk->xsk), NULL, 0, MSG_DONTWAIT, NULL, NULL);
ret = sendto(xsk_socket__fd(xsk->socket), NULL, 0, MSG_DONTWAIT, NULL, 0);
err = sendto(sock_fd, udp_payload, UDP_PAYLOAD_BYTES, MSG_DONTWAIT,
ret = recvfrom(xsk_socket__fd(xsk->socket), NULL, 0, MSG_DONTWAIT, NULL, NULL);
return sendto(xsk_socket__fd(xsk->socket), NULL, 0, MSG_DONTWAIT, NULL, 0);
return recvfrom(xsk_socket__fd(xsk->socket), NULL, 0, MSG_DONTWAIT, NULL, NULL);
ret = recv(fd, buf, sizeof(buf), MSG_DONTWAIT);
len = recvmsg(fd, &msg, MSG_DONTWAIT);
flags = MSG_DONTWAIT;
if (recvmsg(fd, &msg, MSG_DONTWAIT))
ret = recv(fd, NULL, 1 << 21, MSG_TRUNC | MSG_DONTWAIT);
ret = recv(fd, buf, sizeof(buf), MSG_DONTWAIT | MSG_TRUNC);
n = recv(netlink_sock, buf, sizeof(buf), MSG_DONTWAIT);
n = recv(netlink_sock, buf, sizeof(buf), MSG_DONTWAIT);
n = recv(netlink_sock, buf, sizeof(buf), MSG_DONTWAIT);
n = recv(netlink_sock, buf, sizeof(buf), MSG_DONTWAIT);
ret = recv(sk, q->buf, qlen, MSG_PEEK | MSG_DONTWAIT);
res = recvmsg(sock, &msg, recvmsg_flags|MSG_DONTWAIT);
EXPECT_EQ(recv(self->cfd, read_buf, sizeof(read_buf), MSG_DONTWAIT), -1);
EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_DONTWAIT), -1);
EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_DONTWAIT), -1);
EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_DONTWAIT), -1);
buf, sizeof(buf), MSG_DONTWAIT), ret);
EXPECT_EQ(recv(self->cfd2, buf, sizeof(buf), MSG_DONTWAIT), -1);
EXPECT_EQ(send(fd, buf, sizeof(buf), MSG_DONTWAIT), sizeof(buf));
} while (recv(cfd, buf, 1, MSG_PEEK | MSG_DONTWAIT) == 1);
EXPECT_EQ(recv(cfd, buf2, sizeof(buf2), MSG_DONTWAIT), -1);
EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1);
EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1);
EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1);
if (ret == -1 && errno == EAGAIN && (flags & MSG_DONTWAIT))
ret = recv_one(fdr, MSG_DONTWAIT);
ret = recv(fd, NULL, 1 << 21, MSG_TRUNC | MSG_DONTWAIT);
ret = recvmsg(fd, &msg, MSG_TRUNC | MSG_DONTWAIT);
ret = recv(fd, rbuf, len, MSG_TRUNC | MSG_DONTWAIT);
recv_buf(fd, buf + read, to_read, MSG_DONTWAIT, -EAGAIN);
recv_buf(fd, buf, recv_buf_size, MSG_DONTWAIT, recv_buf_size);
recv_buf(fd, buf_peek, sizeof(buf_peek), MSG_PEEK | MSG_DONTWAIT,
recv_buf(fd, buf, sizeof(buf), MSG_DONTWAIT, RCVLOWAT_BUF_SIZE);
recv_buf(fd, data, sizeof(data), MSG_DONTWAIT, expected_ret);