Lines Matching refs:kmsg
4684 struct io_async_msghdr *kmsg) in io_setup_async_msg() argument
4691 kfree(kmsg->free_iov); in io_setup_async_msg()
4696 memcpy(async_msg, kmsg, sizeof(*kmsg)); in io_setup_async_msg()
4700 if (!kmsg->free_iov) { in io_setup_async_msg()
4701 size_t fast_idx = kmsg->msg.msg_iter.iov - kmsg->fast_iov; in io_setup_async_msg()
4754 struct io_async_msghdr iomsg, *kmsg; in io_sendmsg() local
4765 kmsg = req->async_data; in io_sendmsg()
4766 if (!kmsg) { in io_sendmsg()
4770 kmsg = &iomsg; in io_sendmsg()
4777 min_ret = iov_iter_count(&kmsg->msg.msg_iter); in io_sendmsg()
4779 ret = __sys_sendmsg_sock(sock, &kmsg->msg, flags); in io_sendmsg()
4783 return io_setup_async_msg(req, kmsg); in io_sendmsg()
4789 return io_setup_async_msg(req, kmsg); in io_sendmsg()
4794 if (kmsg->free_iov) in io_sendmsg()
4795 kfree(kmsg->free_iov); in io_sendmsg()
5003 struct io_async_msghdr iomsg, *kmsg; in io_recvmsg() local
5016 kmsg = req->async_data; in io_recvmsg()
5017 if (!kmsg) { in io_recvmsg()
5021 kmsg = &iomsg; in io_recvmsg()
5028 kmsg->fast_iov[0].iov_base = u64_to_user_ptr(kbuf->addr); in io_recvmsg()
5029 kmsg->fast_iov[0].iov_len = req->sr_msg.len; in io_recvmsg()
5030 iov_iter_init(&kmsg->msg.msg_iter, READ, kmsg->fast_iov, in io_recvmsg()
5038 min_ret = iov_iter_count(&kmsg->msg.msg_iter); in io_recvmsg()
5040 ret = __sys_recvmsg_sock(sock, &kmsg->msg, req->sr_msg.umsg, in io_recvmsg()
5041 kmsg->uaddr, flags); in io_recvmsg()
5044 return io_setup_async_msg(req, kmsg); in io_recvmsg()
5050 return io_setup_async_msg(req, kmsg); in io_recvmsg()
5053 } else if ((flags & MSG_WAITALL) && (kmsg->msg.msg_flags & (MSG_TRUNC | MSG_CTRUNC))) { in io_recvmsg()
5060 if (kmsg->free_iov) in io_recvmsg()
5061 kfree(kmsg->free_iov); in io_recvmsg()