Lines Matching defs:msg
839 * rs_snd_bytes here to allow the last msg to exceed the buffer,
872 rdsdebug("queued msg %p len %d, rs %p bytes %d seq %llu\n",
888 static int rds_rm_size(struct msghdr *msg, int num_sgs,
901 for_each_cmsghdr(cmsg, msg) {
902 if (!CMSG_OK(msg, cmsg))
958 if ((msg->msg_flags & MSG_ZEROCOPY) && !zcopy_cookie)
984 struct msghdr *msg, int *allocated_mr,
990 for_each_cmsghdr(cmsg, msg) {
991 if (!CMSG_OK(msg, cmsg))
1077 static int rds_rdma_bytes(struct msghdr *msg, size_t *rdma_bytes)
1082 for_each_cmsghdr(cmsg, msg) {
1083 if (!CMSG_OK(msg, cmsg))
1100 int rds_sendmsg(struct socket *sock, struct msghdr *msg, size_t payload_len)
1104 DECLARE_SOCKADDR(struct sockaddr_in6 *, sin6, msg->msg_name);
1105 DECLARE_SOCKADDR(struct sockaddr_in *, usin, msg->msg_name);
1111 int nonblock = msg->msg_flags & MSG_DONTWAIT;
1117 bool zcopy = ((msg->msg_flags & MSG_ZEROCOPY) &&
1131 if (msg->msg_flags & ~(MSG_DONTWAIT | MSG_CMSG_COMPAT | MSG_ZEROCOPY)) {
1136 namelen = msg->msg_namelen;
1241 ret = rds_rdma_bytes(msg, &rdma_payload_len);
1260 num_sgs = iov_iter_npages(&msg->msg_iter, INT_MAX);
1263 ret = rds_rm_size(msg, num_sgs, &vct);
1280 ret = rds_message_copy_from_user(rm, &msg->msg_iter, zcopy);
1314 ret = rds_cmsg_send(rs, rm, msg, &allocated_mr, &vct);