2 * QEMU live migration via socket
4 * Copyright Red Hat, Inc. 2009-2016
7 * Chris Lalancette <clalance@redhat.com>
8 * Daniel P. Berrange <berrange@redhat.com>
10 * This work is licensed under the terms of the GNU GPL, version 2. See
11 * the COPYING file in the top-level directory.
13 * Contributions after 2012-01-13 are licensed under the terms of the
14 * GNU GPL, version 2 or (at your option) any later version.
17 #include "qemu/osdep.h"
19 #include "qemu-common.h"
20 #include "qemu/error-report.h"
21 #include "qapi/error.h"
22 #include "migration/migration.h"
23 #include "migration/qemu-file.h"
24 #include "io/channel-socket.h"
28 static SocketAddress
*tcp_build_address(const char *host_port
, Error
**errp
)
30 InetSocketAddress
*iaddr
= inet_parse(host_port
, errp
);
37 saddr
= g_new0(SocketAddress
, 1);
38 saddr
->type
= SOCKET_ADDRESS_KIND_INET
;
39 saddr
->u
.inet
.data
= iaddr
;
45 static SocketAddress
*unix_build_address(const char *path
)
49 saddr
= g_new0(SocketAddress
, 1);
50 saddr
->type
= SOCKET_ADDRESS_KIND_UNIX
;
51 saddr
->u
.q_unix
.data
= g_new0(UnixSocketAddress
, 1);
52 saddr
->u
.q_unix
.data
->path
= g_strdup(path
);
58 struct SocketConnectData
{
63 static void socket_connect_data_free(void *opaque
)
65 struct SocketConnectData
*data
= opaque
;
69 g_free(data
->hostname
);
73 static void socket_outgoing_migration(Object
*src
,
77 struct SocketConnectData
*data
= opaque
;
78 QIOChannel
*sioc
= QIO_CHANNEL(src
);
81 trace_migration_socket_outgoing_error(error_get_pretty(err
));
82 data
->s
->to_dst_file
= NULL
;
83 migrate_fd_error(data
->s
, err
);
85 trace_migration_socket_outgoing_connected(data
->hostname
);
86 migration_channel_connect(data
->s
, sioc
, data
->hostname
);
91 static void socket_start_outgoing_migration(MigrationState
*s
,
95 QIOChannelSocket
*sioc
= qio_channel_socket_new();
96 struct SocketConnectData
*data
= g_new0(struct SocketConnectData
, 1);
99 if (saddr
->type
== SOCKET_ADDRESS_KIND_INET
) {
100 data
->hostname
= g_strdup(saddr
->u
.inet
.data
->host
);
103 qio_channel_socket_connect_async(sioc
,
105 socket_outgoing_migration
,
107 socket_connect_data_free
);
108 qapi_free_SocketAddress(saddr
);
111 void tcp_start_outgoing_migration(MigrationState
*s
,
112 const char *host_port
,
116 SocketAddress
*saddr
= tcp_build_address(host_port
, &err
);
118 socket_start_outgoing_migration(s
, saddr
, &err
);
120 error_propagate(errp
, err
);
123 void unix_start_outgoing_migration(MigrationState
*s
,
127 SocketAddress
*saddr
= unix_build_address(path
);
128 socket_start_outgoing_migration(s
, saddr
, errp
);
132 static gboolean
socket_accept_incoming_migration(QIOChannel
*ioc
,
133 GIOCondition condition
,
136 QIOChannelSocket
*sioc
;
139 sioc
= qio_channel_socket_accept(QIO_CHANNEL_SOCKET(ioc
),
142 error_report("could not accept migration connection (%s)",
143 error_get_pretty(err
));
147 trace_migration_socket_incoming_accepted();
149 migration_channel_process_incoming(migrate_get_current(),
151 object_unref(OBJECT(sioc
));
154 /* Close listening socket as its no longer needed */
155 qio_channel_close(ioc
, NULL
);
156 return FALSE
; /* unregister */
160 static void socket_start_incoming_migration(SocketAddress
*saddr
,
163 QIOChannelSocket
*listen_ioc
= qio_channel_socket_new();
165 if (qio_channel_socket_listen_sync(listen_ioc
, saddr
, errp
) < 0) {
166 object_unref(OBJECT(listen_ioc
));
167 qapi_free_SocketAddress(saddr
);
171 qio_channel_add_watch(QIO_CHANNEL(listen_ioc
),
173 socket_accept_incoming_migration
,
175 (GDestroyNotify
)object_unref
);
176 qapi_free_SocketAddress(saddr
);
179 void tcp_start_incoming_migration(const char *host_port
, Error
**errp
)
182 SocketAddress
*saddr
= tcp_build_address(host_port
, &err
);
184 socket_start_incoming_migration(saddr
, &err
);
186 error_propagate(errp
, err
);
189 void unix_start_incoming_migration(const char *path
, Error
**errp
)
191 SocketAddress
*saddr
= unix_build_address(path
);
192 socket_start_incoming_migration(saddr
, errp
);