[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PATCH 2/5] migration: add the interface to set get_return_
From: |
Lidong Chen |
Subject: |
[Qemu-devel] [PATCH 2/5] migration: add the interface to set get_return_path |
Date: |
Sat, 7 Apr 2018 16:26:31 +0800 |
The default get_return_path function of iochannel does not work for
RDMA live migration. So add the interface to set get_return_path.
Signed-off-by: Lidong Chen <address@hidden>
---
migration/qemu-file-channel.c | 12 ++++++++----
migration/qemu-file.c | 10 ++++++++--
migration/qemu-file.h | 2 +-
3 files changed, 17 insertions(+), 7 deletions(-)
diff --git a/migration/qemu-file-channel.c b/migration/qemu-file-channel.c
index e202d73..d4dd8c4 100644
--- a/migration/qemu-file-channel.c
+++ b/migration/qemu-file-channel.c
@@ -156,7 +156,6 @@ static const QEMUFileOps channel_input_ops = {
.close = channel_close,
.shut_down = channel_shutdown,
.set_blocking = channel_set_blocking,
- .get_return_path = channel_get_input_return_path,
};
@@ -165,18 +164,23 @@ static const QEMUFileOps channel_output_ops = {
.close = channel_close,
.shut_down = channel_shutdown,
.set_blocking = channel_set_blocking,
- .get_return_path = channel_get_output_return_path,
};
QEMUFile *qemu_fopen_channel_input(QIOChannel *ioc)
{
+ QEMUFile *f;
object_ref(OBJECT(ioc));
- return qemu_fopen_ops(ioc, &channel_input_ops);
+ f = qemu_fopen_ops(ioc, &channel_input_ops);
+ qemu_file_set_return_path(f, channel_get_input_return_path);
+ return f;
}
QEMUFile *qemu_fopen_channel_output(QIOChannel *ioc)
{
+ QEMUFile *f;
object_ref(OBJECT(ioc));
- return qemu_fopen_ops(ioc, &channel_output_ops);
+ f = qemu_fopen_ops(ioc, &channel_output_ops);
+ qemu_file_set_return_path(f, channel_get_output_return_path);
+ return f;
}
diff --git a/migration/qemu-file.c b/migration/qemu-file.c
index bb63c77..8acb574 100644
--- a/migration/qemu-file.c
+++ b/migration/qemu-file.c
@@ -36,6 +36,7 @@
struct QEMUFile {
const QEMUFileOps *ops;
const QEMUFileHooks *hooks;
+ QEMURetPathFunc *get_return_path;
void *opaque;
int64_t bytes_xfer;
@@ -72,10 +73,15 @@ int qemu_file_shutdown(QEMUFile *f)
*/
QEMUFile *qemu_file_get_return_path(QEMUFile *f)
{
- if (!f->ops->get_return_path) {
+ if (!f->get_return_path) {
return NULL;
}
- return f->ops->get_return_path(f->opaque);
+ return f->get_return_path(f->opaque);
+}
+
+void qemu_file_set_return_path(QEMUFile *f, QEMURetPathFunc *get_return_path)
+{
+ f->get_return_path = get_return_path;
}
bool qemu_file_mode_is_not_valid(const char *mode)
diff --git a/migration/qemu-file.h b/migration/qemu-file.h
index f4f356a..74210b7 100644
--- a/migration/qemu-file.h
+++ b/migration/qemu-file.h
@@ -102,7 +102,6 @@ typedef struct QEMUFileOps {
QEMUFileCloseFunc *close;
QEMUFileSetBlocking *set_blocking;
QEMUFileWritevBufferFunc *writev_buffer;
- QEMURetPathFunc *get_return_path;
QEMUFileShutdownFunc *shut_down;
} QEMUFileOps;
@@ -114,6 +113,7 @@ typedef struct QEMUFileHooks {
} QEMUFileHooks;
QEMUFile *qemu_fopen_ops(void *opaque, const QEMUFileOps *ops);
+void qemu_file_set_return_path(QEMUFile *f, QEMURetPathFunc *get_return_path);
void qemu_file_set_hooks(QEMUFile *f, const QEMUFileHooks *hooks);
int qemu_get_fd(QEMUFile *f);
int qemu_fclose(QEMUFile *f);
--
1.8.3.1
[Qemu-devel] [PATCH 5/5] migration: disable RDMA WRITR after postcopy started., Lidong Chen, 2018/04/07