[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[PATCH v2 03/11] migration/qemu-file: Add qemu_file_get_to_fd()
From: |
Avihai Horon |
Subject: |
[PATCH v2 03/11] migration/qemu-file: Add qemu_file_get_to_fd() |
Date: |
Mon, 30 May 2022 20:07:31 +0300 |
Add new function qemu_file_get_to_fd() that allows reading data from
QEMUFile and writing it straight into a given fd.
This will be used later in VFIO migration code.
Signed-off-by: Avihai Horon <avihaih@nvidia.com>
---
migration/qemu-file.c | 34 ++++++++++++++++++++++++++++++++++
migration/qemu-file.h | 1 +
2 files changed, 35 insertions(+)
diff --git a/migration/qemu-file.c b/migration/qemu-file.c
index 1479cddad9..cad3d32eb3 100644
--- a/migration/qemu-file.c
+++ b/migration/qemu-file.c
@@ -867,3 +867,37 @@ QIOChannel *qemu_file_get_ioc(QEMUFile *file)
{
return file->has_ioc ? QIO_CHANNEL(file->opaque) : NULL;
}
+
+/*
+ * Read size bytes from QEMUFile f and write them to fd.
+ */
+int qemu_file_get_to_fd(QEMUFile *f, int fd, size_t size)
+{
+ while (size) {
+ size_t pending = f->buf_size - f->buf_index;
+ ssize_t rc;
+
+ if (!pending) {
+ rc = qemu_fill_buffer(f);
+ if (rc < 0) {
+ return rc;
+ }
+ if (rc == 0) {
+ return -1;
+ }
+ continue;
+ }
+
+ rc = write(fd, f->buf + f->buf_index, MIN(pending, size));
+ if (rc < 0) {
+ return rc;
+ }
+ if (rc == 0) {
+ return -1;
+ }
+ f->buf_index += rc;
+ size -= rc;
+ }
+
+ return 0;
+}
diff --git a/migration/qemu-file.h b/migration/qemu-file.h
index 3f36d4dc8c..dd26037450 100644
--- a/migration/qemu-file.h
+++ b/migration/qemu-file.h
@@ -162,6 +162,7 @@ int qemu_file_shutdown(QEMUFile *f);
QEMUFile *qemu_file_get_return_path(QEMUFile *f);
void qemu_fflush(QEMUFile *f);
void qemu_file_set_blocking(QEMUFile *f, bool block);
+int qemu_file_get_to_fd(QEMUFile *f, int fd, size_t size);
void ram_control_before_iterate(QEMUFile *f, uint64_t flags);
void ram_control_after_iterate(QEMUFile *f, uint64_t flags);
--
2.21.3
- [PATCH v2 00/11] vfio/migration: Implement VFIO migration protocol v2, Avihai Horon, 2022/05/30
- [PATCH v2 01/11] vfio/migration: Fix NULL pointer dereference bug, Avihai Horon, 2022/05/30
- [PATCH v2 02/11] vfio/migration: Skip pre-copy if dirty page tracking is not supported, Avihai Horon, 2022/05/30
- [PATCH v2 03/11] migration/qemu-file: Add qemu_file_get_to_fd(),
Avihai Horon <=
- [PATCH v2 04/11] vfio/common: Change vfio_devices_all_running_and_saving() logic to equivalent one, Avihai Horon, 2022/05/30
- [PATCH v2 05/11] vfio/migration: Move migration v1 logic to vfio_migration_init(), Avihai Horon, 2022/05/30
- [PATCH v2 06/11] vfio/migration: Rename functions/structs related to v1 protocol, Avihai Horon, 2022/05/30
- [PATCH v2 07/11] vfio/migration: Implement VFIO migration protocol v2, Avihai Horon, 2022/05/30
- [PATCH v2 08/11] vfio/migration: Remove VFIO migration protocol v1, Avihai Horon, 2022/05/30
- [PATCH v2 09/11] vfio/migration: Reset device if setting recover state fails, Avihai Horon, 2022/05/30
- [PATCH v2 10/11] vfio: Alphabetize migration section of VFIO trace-events file, Avihai Horon, 2022/05/30
- [PATCH v2 11/11] docs/devel: Align vfio-migration docs to VFIO migration v2, Avihai Horon, 2022/05/30