[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[PULL 1/5] migration/qemu-file: Add qemu_file_get_to_fd()
From: |
Juan Quintela |
Subject: |
[PULL 1/5] migration/qemu-file: Add qemu_file_get_to_fd() |
Date: |
Wed, 15 Feb 2023 21:05:50 +0100 |
From: Avihai Horon <avihaih@nvidia.com>
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>
Reviewed-by: Vladimir Sementsov-Ogievskiy <vsementsov@yandex-team.ru>
Reviewed-by: Cédric Le Goater <clg@redhat.com>
Reviewed-by: Juan Quintela <quintela@redhat.com>
Signed-off-by: Juan Quintela <quintela@redhat.com>
---
migration/qemu-file.h | 1 +
migration/qemu-file.c | 34 ++++++++++++++++++++++++++++++++++
2 files changed, 35 insertions(+)
diff --git a/migration/qemu-file.h b/migration/qemu-file.h
index fa13d04d78..9d0155a2a1 100644
--- a/migration/qemu-file.h
+++ b/migration/qemu-file.h
@@ -148,6 +148,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);
diff --git a/migration/qemu-file.c b/migration/qemu-file.c
index 2d5f74ffc2..102ab3b439 100644
--- a/migration/qemu-file.c
+++ b/migration/qemu-file.c
@@ -940,3 +940,37 @@ QIOChannel *qemu_file_get_ioc(QEMUFile *file)
{
return file->ioc;
}
+
+/*
+ * 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 -EIO;
+ }
+ continue;
+ }
+
+ rc = write(fd, f->buf + f->buf_index, MIN(pending, size));
+ if (rc < 0) {
+ return -errno;
+ }
+ if (rc == 0) {
+ return -EIO;
+ }
+ f->buf_index += rc;
+ size -= rc;
+ }
+
+ return 0;
+}
--
2.39.1
- [PULL 0/5] Migration 20230215 patches, Juan Quintela, 2023/02/15
- [PULL 1/5] migration/qemu-file: Add qemu_file_get_to_fd(),
Juan Quintela <=
- [PULL 2/5] migration/block: Convert remaining DPRINTF() debug macro to trace events, Juan Quintela, 2023/02/15
- [PULL 3/5] migration: In case of postcopy, the memory ends in res_postcopy_only, Juan Quintela, 2023/02/15
- [PULL 5/5] migration: Rename res_{postcopy,precopy}_only, Juan Quintela, 2023/02/15
- [PULL 4/5] migration: Remove unused res_compatible, Juan Quintela, 2023/02/15
- Re: [PULL 0/5] Migration 20230215 patches, Peter Maydell, 2023/02/16