MSG_WAITALL
.msg_flags = (flags ? flags : MSG_WAITALL | MSG_NOSIGNAL)
result = __sock_xmit(nbd, sock, 0, &to, MSG_WAITALL, NULL);
result = sock_xmit(nbd, index, 0, &to, MSG_WAITALL, NULL);
target = sock_rcvlowat(sk, flags & MSG_WAITALL, len);
target = sock_rcvlowat(sk, flags & MSG_WAITALL, len);
msg.msg_flags = MSG_WAITALL;
rx_loop = sock_recvmsg(conn->sock, &msg, MSG_WAITALL);
result = sock_recvmsg(sock, &msg, MSG_WAITALL);
msg.msg_flags = MSG_WAITALL | (call->write_iter ? MSG_MORE : 0);
MSG_PEEK | MSG_WAITALL))
if (!coredump_sock_recv(cprm->file, &ack, usize, MSG_WAITALL))
if (flags & MSG_WAITALL && !kmsg->msg.msg_controllen)
} else if ((flags & MSG_WAITALL) && (kmsg->msg.msg_flags & (MSG_TRUNC | MSG_CTRUNC))) {
if (flags & MSG_WAITALL)
} else if ((flags & MSG_WAITALL) && (kmsg->msg.msg_flags & (MSG_TRUNC | MSG_CTRUNC))) {
if (msg_flags & MSG_WAITALL)
if (!(flags & MSG_WAITALL))
if (flags & MSG_WAITALL)
sr->msg_flags |= MSG_WAITALL;
if (flags & MSG_WAITALL)
if (flags & MSG_WAITALL || sr->flags & IORING_RECVSEND_BUNDLE)
if (sr->msg_flags & MSG_WAITALL)
target = sock_rcvlowat(sk, flags & MSG_WAITALL, size);
target = sock_rcvlowat(sk, flags&MSG_WAITALL, size);
target = sock_rcvlowat(sk, flags & MSG_WAITALL, len);
target = sock_rcvlowat(sk, flags & MSG_WAITALL, len);
target = sock_rcvlowat(sk, flags & MSG_WAITALL, len);
if (flags & ~(MSG_OOB|MSG_PEEK|MSG_TRUNC|MSG_DONTWAIT|MSG_WAITALL|
msg->msg_flags & MSG_WAITALL);
krflags = MSG_PEEK | MSG_WAITALL;
krflags = MSG_WAITALL;
target = sock_rcvlowat(sk, flags & MSG_WAITALL, len);
required = sock_rcvlowat(sk, flags & MSG_WAITALL, buflen);
target = sock_rcvlowat(sk, flags & MSG_WAITALL, len);
target = sock_rcvlowat(sk, flags & MSG_WAITALL, size);
target = sock_rcvlowat(sk, flags & MSG_WAITALL, len);
n = recvfrom(sockfd, buf, sizeof(buf), MSG_WAITALL,
ret = recv(fd, &mark, sizeof(mark), MSG_WAITALL);
ret = recv(fd, req, field_size, MSG_PEEK | MSG_WAITALL);
ret = recv(fd, req, ack_size, MSG_WAITALL);
ret = recv(fd, buffer, sizeof(buffer), MSG_WAITALL);
send(sock, "ack", 4, MSG_WAITALL);
send(sock, "err", 4, MSG_WAITALL);
send(sock, buf, ret + 1, MSG_WAITALL);
MSG_WAITALL);
send(data_sock, info, sz, MSG_WAITALL);
sz = recv(data_sock, info, sz, MSG_WAITALL);
unsigned msg_flags = MSG_WAITALL;
EXPECT_EQ(recv(self->cfd, recv_mem, total_len, MSG_WAITALL), total_len);
MSG_WAITALL), strlen(test_str_first));
MSG_WAITALL), strlen(test_str_second));
EXPECT_EQ(recv(self->cfd, buf, len, MSG_PEEK | MSG_WAITALL), len);
EXPECT_EQ(recv(self->cfd, buf, len, MSG_WAITALL), len);
EXPECT_EQ(recv(self->cfd, buf, len, MSG_PEEK | MSG_WAITALL), len);
MSG_PEEK | MSG_WAITALL)), -1);
EXPECT_EQ(recv(self->cfd, recv_mem, 1, MSG_WAITALL), 1);
EXPECT_EQ(recv(self->cfd, recv_mem + 1, 6, MSG_WAITALL), 6);
EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len);
EXPECT_EQ(recv(self->cfd, recv_mem, send_len, MSG_WAITALL), send_len);
EXPECT_EQ(recv(self->cfd, recv_mem, sizeof(recv_mem), MSG_WAITALL),
buf, sizeof(buf), MSG_WAITALL | MSG_PEEK),
buf, sizeof(buf), MSG_WAITALL),
EXPECT_EQ(recv(cfd, buf2, sizeof(buf2), MSG_WAITALL), sizeof(buf2));
EXPECT_EQ(recv(cfd, buf, sizeof(buf) / 2 + 1, MSG_WAITALL),
EXPECT_EQ(recv(self->cfd, recv_buf, to_send, MSG_WAITALL), to_send);
EXPECT_EQ(recv(self->cfd, buf, st.st_size, MSG_WAITALL), st.st_size);
EXPECT_EQ(recv(self->cfd, buf, test_payload_size, MSG_WAITALL),
EXPECT_EQ(recv(self->cfd, buf, send_len * 2, MSG_WAITALL),
buf, sizeof(buf), MSG_WAITALL),
EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len);
EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len);
EXPECT_EQ(recv(self->cfd, buf, SEND_LEN * frags, MSG_WAITALL),
EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len);
EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len);
EXPECT_EQ(recv(self->cfd, buf, send_len2, MSG_WAITALL), send_len2);
EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len);
buf, sizeof(buf), MSG_WAITALL),
buf, sizeof(buf), MSG_WAITALL),
EXPECT_EQ(recv(self->cfd, mem_recv, half, MSG_WAITALL), half);
MSG_WAITALL | MSG_PEEK),
nbytes = recv(sockfd, buff, bufflen, MSG_WAITALL);