[Top][All Lists]
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PATCH 6/6] migration: move process_incoming_migration to a
From: |
Paolo Bonzini |
Subject: |
[Qemu-devel] [PATCH 6/6] migration: move process_incoming_migration to a coroutine |
Date: |
Tue, 7 Aug 2012 17:51:47 +0200 |
Signed-off-by: Paolo Bonzini <address@hidden>
---
migration-exec.c | 2 +-
migration-fd.c | 2 +-
migration-tcp.c | 2 +-
migration-unix.c | 2 +-
migration.c | 17 ++++++++++++++++-
migration.h | 2 +-
6 file modificati, 21 inserzioni(+), 6 rimozioni(-)
diff --git a/migration-exec.c b/migration-exec.c
index 84796be..e8ed144 100644
--- a/migration-exec.c
+++ b/migration-exec.c
@@ -98,7 +98,7 @@ static void exec_accept_incoming_migration(void *opaque)
QEMUFile *f = opaque;
qemu_set_fd_handler2(qemu_stdio_fd(f), NULL, NULL, NULL, NULL);
- process_incoming_migration(f);
+ process_incoming_migration(f, qemu_stdio_fd(f));
}
int exec_start_incoming_migration(const char *command)
diff --git a/migration-fd.c b/migration-fd.c
index 21ad196..e9a06d9 100644
--- a/migration-fd.c
+++ b/migration-fd.c
@@ -104,7 +104,7 @@ static void fd_accept_incoming_migration(void *opaque)
QEMUFile *f = opaque;
qemu_set_fd_handler2(qemu_stdio_fd(f), NULL, NULL, NULL, NULL);
- process_incoming_migration(f);
+ process_incoming_migration(f, qemu_stdio_fd(f));
}
int fd_start_incoming_migration(const char *infd)
diff --git a/migration-tcp.c b/migration-tcp.c
index 62c9309..765970c 100644
--- a/migration-tcp.c
+++ b/migration-tcp.c
@@ -135,7 +135,7 @@ static void tcp_accept_incoming_migration(void *opaque)
goto out;
}
- process_incoming_migration(f);
+ process_incoming_migration(f, c);
return;
out:
diff --git a/migration-unix.c b/migration-unix.c
index d8d5dfa..071d4fb 100644
--- a/migration-unix.c
+++ b/migration-unix.c
@@ -145,7 +145,7 @@ static void unix_accept_incoming_migration(void *opaque)
goto out;
}
- process_incoming_migration(f);
+ process_incoming_migration(f, c);
return;
out:
diff --git a/migration.c b/migration.c
index a27ceb3..d821971 100644
--- a/migration.c
+++ b/migration.c
@@ -82,8 +82,9 @@ int qemu_start_incoming_migration(const char *uri, Error
**errp)
return ret;
}
-void process_incoming_migration(QEMUFile *f)
+static void process_incoming_migration_co(void *opaque)
{
+ QEMUFile *f = opaque;
int ret;
ret = qemu_loadvm_state(f);
@@ -106,6 +107,20 @@ void process_incoming_migration(QEMUFile *f)
}
}
+static void enter_migration_coroutine(void *opaque)
+{
+ Coroutine *co = opaque;
+ qemu_coroutine_enter(co, NULL);
+}
+
+void process_incoming_migration(QEMUFile *f, int fd)
+{
+ Coroutine *co = qemu_coroutine_create(process_incoming_migration_co);
+ socket_set_nonblock(fd);
+ qemu_set_fd_handler(fd, enter_migration_coroutine, NULL, co);
+ qemu_coroutine_enter(co, f);
+}
+
/* amount of nanoseconds we are willing to wait for migration to be down.
* the choice of nanoseconds is because it is the maximum resolution that
* get_clock() can achieve. It is an internal measure. All user-visible
diff --git a/migration.h b/migration.h
index 57572a6..4a35ea7 100644
--- a/migration.h
+++ b/migration.h
@@ -41,7 +41,7 @@ struct MigrationState
int64_t total_time;
};
-void process_incoming_migration(QEMUFile *f);
+void process_incoming_migration(QEMUFile *f, int fd);
int qemu_start_incoming_migration(const char *uri, Error **errp);
--
1.7.11.2
- [Qemu-devel] [RFC PATCH 0/6] Run incoming migration in a coroutine, Paolo Bonzini, 2012/08/07
- [Qemu-devel] [PATCH 2/6] migration: close socket QEMUFile from socket_close, Paolo Bonzini, 2012/08/07
- [Qemu-devel] [PATCH 3/6] migration: move qemu_fclose to process_incoming_migration, Paolo Bonzini, 2012/08/07
- [Qemu-devel] [PATCH 1/6] migration: clean up server sockets and handlers before invoking process_incoming_migration, Paolo Bonzini, 2012/08/07
- [Qemu-devel] [PATCH 4/6] migration: remove iohandlers before closing the file, Paolo Bonzini, 2012/08/07
- [Qemu-devel] [PATCH 5/6] migration: handle EAGAIN while reading QEMUFile, Paolo Bonzini, 2012/08/07
- [Qemu-devel] [PATCH 6/6] migration: move process_incoming_migration to a coroutine,
Paolo Bonzini <=