2 * QEMU I/O channels block driver
4 * Copyright (c) 2022 Red Hat, Inc.
6 * This library is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU Lesser General Public
8 * License as published by the Free Software Foundation; either
9 * version 2.1 of the License, or (at your option) any later version.
11 * This library is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 * Lesser General Public License for more details.
16 * You should have received a copy of the GNU Lesser General Public
17 * License along with this library; if not, see <http://www.gnu.org/licenses/>.
21 #include "qemu/osdep.h"
22 #include "migration/channel-block.h"
23 #include "qapi/error.h"
24 #include "block/block.h"
28 qio_channel_block_new(BlockDriverState
*bs
)
32 ioc
= QIO_CHANNEL_BLOCK(object_new(TYPE_QIO_CHANNEL_BLOCK
));
42 qio_channel_block_finalize(Object
*obj
)
44 QIOChannelBlock
*ioc
= QIO_CHANNEL_BLOCK(obj
);
46 g_clear_pointer(&ioc
->bs
, bdrv_unref
);
51 qio_channel_block_readv(QIOChannel
*ioc
,
52 const struct iovec
*iov
,
58 QIOChannelBlock
*bioc
= QIO_CHANNEL_BLOCK(ioc
);
62 qemu_iovec_init_external(&qiov
, (struct iovec
*)iov
, niov
);
63 ret
= bdrv_readv_vmstate(bioc
->bs
, &qiov
, bioc
->offset
);
65 error_setg_errno(errp
, -ret
, "bdrv_readv_vmstate failed");
69 bioc
->offset
+= qiov
.size
;
75 qio_channel_block_writev(QIOChannel
*ioc
,
76 const struct iovec
*iov
,
83 QIOChannelBlock
*bioc
= QIO_CHANNEL_BLOCK(ioc
);
87 qemu_iovec_init_external(&qiov
, (struct iovec
*)iov
, niov
);
88 ret
= bdrv_writev_vmstate(bioc
->bs
, &qiov
, bioc
->offset
);
90 error_setg_errno(errp
, -ret
, "bdrv_writev_vmstate failed");
94 bioc
->offset
+= qiov
.size
;
100 qio_channel_block_set_blocking(QIOChannel
*ioc
,
105 error_setg(errp
, "Non-blocking mode not supported for block devices");
113 qio_channel_block_seek(QIOChannel
*ioc
,
118 QIOChannelBlock
*bioc
= QIO_CHANNEL_BLOCK(ioc
);
122 bioc
->offset
= offset
;
125 bioc
->offset
+= whence
;
128 error_setg(errp
, "Size of VMstate region is unknown");
131 g_assert_not_reached();
139 qio_channel_block_close(QIOChannel
*ioc
,
142 QIOChannelBlock
*bioc
= QIO_CHANNEL_BLOCK(ioc
);
143 int rv
= bdrv_flush(bioc
->bs
);
146 error_setg_errno(errp
, -rv
,
147 "Unable to flush VMState");
151 g_clear_pointer(&bioc
->bs
, bdrv_unref
);
159 qio_channel_block_set_aio_fd_handler(QIOChannel
*ioc
,
165 /* XXX anything we can do here ? */
170 qio_channel_block_class_init(ObjectClass
*klass
,
171 void *class_data G_GNUC_UNUSED
)
173 QIOChannelClass
*ioc_klass
= QIO_CHANNEL_CLASS(klass
);
175 ioc_klass
->io_writev
= qio_channel_block_writev
;
176 ioc_klass
->io_readv
= qio_channel_block_readv
;
177 ioc_klass
->io_set_blocking
= qio_channel_block_set_blocking
;
178 ioc_klass
->io_seek
= qio_channel_block_seek
;
179 ioc_klass
->io_close
= qio_channel_block_close
;
180 ioc_klass
->io_set_aio_fd_handler
= qio_channel_block_set_aio_fd_handler
;
183 static const TypeInfo qio_channel_block_info
= {
184 .parent
= TYPE_QIO_CHANNEL
,
185 .name
= TYPE_QIO_CHANNEL_BLOCK
,
186 .instance_size
= sizeof(QIOChannelBlock
),
187 .instance_finalize
= qio_channel_block_finalize
,
188 .class_init
= qio_channel_block_class_init
,
192 qio_channel_block_register_types(void)
194 type_register_static(&qio_channel_block_info
);
197 type_init(qio_channel_block_register_types
);