Lines Matching defs:msg
466 * msg as we can squeeze in, and set MSG_CTRUNC.
539 static int rds_cmsg_recv(struct rds_incoming *inc, struct msghdr *msg,
545 ret = put_cmsg(msg, SOL_RDS, RDS_CMSG_RDMA_DEST,
558 ret = put_cmsg(msg, SOL_SOCKET, SO_TIMESTAMP_OLD,
566 ret = put_cmsg(msg, SOL_SOCKET, SO_TIMESTAMP_NEW,
588 ret = put_cmsg(msg, SOL_RDS, RDS_CMSG_RXPATH_LATENCY,
598 static bool rds_recvmsg_zcookie(struct rds_sock *rs, struct msghdr *msg)
605 if (!msg->msg_control)
609 msg->msg_controllen < CMSG_SPACE(sizeof(*done)))
622 if (put_cmsg(msg, SOL_RDS, RDS_CMSG_ZCOPY_COMPLETION, sizeof(*done),
633 int rds_recvmsg(struct socket *sock, struct msghdr *msg, size_t size,
640 DECLARE_SOCKADDR(struct sockaddr_in6 *, sin6, msg->msg_name);
641 DECLARE_SOCKADDR(struct sockaddr_in *, sin, msg->msg_name);
652 return sock_recv_errqueue(sk, msg, size, SOL_IP, IP_RECVERR);
657 ret = rds_notify_queue_get(rs, msg);
662 ret = rds_notify_cong(rs, msg);
668 bool reaped = rds_recvmsg_zcookie(rs, msg);
692 ret = inc->i_conn->c_trans->inc_copy_to_user(inc, &msg->msg_iter);
705 iov_iter_revert(&msg->msg_iter, ret);
712 msg->msg_flags |= MSG_TRUNC;
715 if (rds_cmsg_recv(inc, msg, rs)) {
719 rds_recvmsg_zcookie(rs, msg);
723 if (msg->msg_name) {
725 sin = (struct sockaddr_in *)msg->msg_name;
732 msg->msg_namelen = sizeof(*sin);
734 sin6 = (struct sockaddr_in6 *)msg->msg_name;
741 msg->msg_namelen = sizeof(*sin6);