[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PATCH 02/13] migration: Pass TCP args in an struct
From: |
Juan Quintela |
Subject: |
[Qemu-devel] [PATCH 02/13] migration: Pass TCP args in an struct |
Date: |
Wed, 20 Apr 2016 16:44:30 +0200 |
Both for incomming and outgoing migration.
Signed-off-by: Juan Quintela <address@hidden>
---
migration/tcp.c | 29 ++++++++++++++++++++++-------
1 file changed, 22 insertions(+), 7 deletions(-)
diff --git a/migration/tcp.c b/migration/tcp.c
index e1fa7f8..5d42c96 100644
--- a/migration/tcp.c
+++ b/migration/tcp.c
@@ -33,10 +33,16 @@
do { } while (0)
#endif
+struct OutgoingArgs {
+ MigrationState *s;
+};
+
static void tcp_wait_for_connect(int fd, Error *err, void *opaque)
{
- MigrationState *s = opaque;
+ struct OutgoingArgs *args = opaque;
+ MigrationState *s = args->s;
+ g_free(args);
if (fd < 0) {
DPRINTF("migrate connect error: %s\n", error_get_pretty(err));
s->to_dst_file = NULL;
@@ -50,17 +56,26 @@ static void tcp_wait_for_connect(int fd, Error *err, void
*opaque)
void tcp_start_outgoing_migration(MigrationState *s, const char *host_port,
Error **errp)
{
- inet_nonblocking_connect(host_port, tcp_wait_for_connect, s, errp);
+ struct OutgoingArgs *args = g_new0(struct OutgoingArgs, 1);
+
+ args->s = s;
+ inet_nonblocking_connect(host_port, tcp_wait_for_connect, args, errp);
}
+struct IncomingArgs {
+ int s;
+};
+
static void tcp_accept_incoming_migration(void *opaque)
{
+ struct IncomingArgs *args = opaque;
struct sockaddr_in addr;
socklen_t addrlen = sizeof(addr);
- int s = (intptr_t)opaque;
+ int s = args->s;
QEMUFile *f;
int c;
+ g_free(args);
do {
c = qemu_accept(s, (struct sockaddr *)&addr, &addrlen);
} while (c < 0 && errno == EINTR);
@@ -80,7 +95,6 @@ static void tcp_accept_incoming_migration(void *opaque)
error_report("could not qemu_fopen socket");
goto out;
}
-
process_incoming_migration(f);
return;
@@ -90,13 +104,14 @@ out:
void tcp_start_incoming_migration(const char *host_port, Error **errp)
{
+ struct IncomingArgs *args = g_new0(struct IncomingArgs, 1);
int s;
s = inet_listen(host_port, NULL, 256, SOCK_STREAM, 0, errp);
if (s < 0) {
+ g_free(args);
return;
}
-
- qemu_set_fd_handler(s, tcp_accept_incoming_migration, NULL,
- (void *)(intptr_t)s);
+ args->s = s;
+ qemu_set_fd_handler(s, tcp_accept_incoming_migration, NULL, args);
}
--
2.5.5
- [Qemu-devel] [RFC 00/13] Multiple fd migration support, Juan Quintela, 2016/04/20
- [Qemu-devel] [PATCH 01/13] migration: create Migration Incoming State at init time, Juan Quintela, 2016/04/20
- [Qemu-devel] [PATCH 03/13] migration: [HACK] Don't create decompression threads if not enabled, Juan Quintela, 2016/04/20
- [Qemu-devel] [PATCH 02/13] migration: Pass TCP args in an struct,
Juan Quintela <=
- [Qemu-devel] [PATCH 09/13] migration: Create thread infrastructure for multifd send side, Juan Quintela, 2016/04/20
- [Qemu-devel] [PATCH 06/13] migration: create multifd migration threads, Juan Quintela, 2016/04/20
- [Qemu-devel] [PATCH 07/13] migration: Start of multiple fd work, Juan Quintela, 2016/04/20
- [Qemu-devel] [PATCH 04/13] migration: Add multifd capability, Juan Quintela, 2016/04/20
- [Qemu-devel] [PATCH 05/13] migration: Create x-multifd-threads parameter, Juan Quintela, 2016/04/20
- [Qemu-devel] [PATCH 08/13] migration: create ram_multifd_page, Juan Quintela, 2016/04/20
- [Qemu-devel] [PATCH 10/13] migration: Send the fd number which we are going to use for this page, Juan Quintela, 2016/04/20
- [Qemu-devel] [PATCH 12/13] migration: Test new fd infrastructure, Juan Quintela, 2016/04/20
- [Qemu-devel] [PATCH 13/13] migration: [HACK]Transfer pages over new channels, Juan Quintela, 2016/04/20