Lines Matching defs:kmsg
4725 struct io_async_msghdr *kmsg)
4732 kfree(kmsg->free_iov);
4737 memcpy(async_msg, kmsg, sizeof(*kmsg));
4741 if (!kmsg->free_iov) {
4742 size_t fast_idx = kmsg->msg.msg_iter.iov - kmsg->fast_iov;
4801 struct io_async_msghdr iomsg, *kmsg;
4812 kmsg = req->async_data;
4813 if (!kmsg) {
4817 kmsg = &iomsg;
4819 kmsg->msg.msg_control = sr->msg_control;
4826 min_ret = iov_iter_count(&kmsg->msg.msg_iter);
4828 ret = __sys_sendmsg_sock(sock, &kmsg->msg, flags);
4832 return io_setup_async_msg(req, kmsg);
4838 return io_setup_async_msg(req, kmsg);
4843 if (kmsg->free_iov)
4844 kfree(kmsg->free_iov);
5052 struct io_async_msghdr iomsg, *kmsg;
5065 kmsg = req->async_data;
5066 if (!kmsg) {
5070 kmsg = &iomsg;
5077 kmsg->fast_iov[0].iov_base = u64_to_user_ptr(kbuf->addr);
5078 kmsg->fast_iov[0].iov_len = req->sr_msg.len;
5079 iov_iter_init(&kmsg->msg.msg_iter, READ, kmsg->fast_iov,
5086 if (flags & MSG_WAITALL && !kmsg->msg.msg_controllen)
5087 min_ret = iov_iter_count(&kmsg->msg.msg_iter);
5089 ret = __sys_recvmsg_sock(sock, &kmsg->msg, req->sr_msg.umsg,
5090 kmsg->uaddr, flags);
5093 return io_setup_async_msg(req, kmsg);
5097 kmsg->msg.msg_controllen = 0;
5098 kmsg->msg.msg_control = NULL;
5101 return io_setup_async_msg(req, kmsg);
5104 } else if ((flags & MSG_WAITALL) && (kmsg->msg.msg_flags & (MSG_TRUNC | MSG_CTRUNC))) {
5111 if (kmsg->free_iov)
5112 kfree(kmsg->free_iov);