]>
Commit | Line | Data |
---|---|---|
4951f65b | 1 | /* |
474c624d | 2 | * QEMU live migration via socket |
4951f65b | 3 | * |
d984464e | 4 | * Copyright Red Hat, Inc. 2009-2016 |
4951f65b CL |
5 | * |
6 | * Authors: | |
7 | * Chris Lalancette <clalance@redhat.com> | |
d984464e | 8 | * Daniel P. Berrange <berrange@redhat.com> |
4951f65b CL |
9 | * |
10 | * This work is licensed under the terms of the GNU GPL, version 2. See | |
11 | * the COPYING file in the top-level directory. | |
12 | * | |
6b620ca3 PB |
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. | |
4951f65b CL |
15 | */ |
16 | ||
1393a485 | 17 | #include "qemu/osdep.h" |
9aca82ba | 18 | #include "qemu/cutils.h" |
d99598cc | 19 | |
d99598cc | 20 | #include "qemu/error-report.h" |
d984464e | 21 | #include "qapi/error.h" |
dd4339c5 | 22 | #include "channel.h" |
61e8b148 | 23 | #include "socket.h" |
6666c96a | 24 | #include "migration.h" |
08a0aee1 | 25 | #include "qemu-file.h" |
d984464e | 26 | #include "io/channel-socket.h" |
bdd847a0 | 27 | #include "io/net-listener.h" |
d984464e | 28 | #include "trace.h" |
36f62f11 | 29 | #include "postcopy-ram.h" |
1f0776f1 | 30 | #include "options.h" |
34dfc5e4 HG |
31 | #include "qapi/clone-visitor.h" |
32 | #include "qapi/qapi-visit-sockets.h" | |
4951f65b | 33 | |
3854956a JQ |
34 | struct SocketOutgoingArgs { |
35 | SocketAddress *saddr; | |
36 | } outgoing_args; | |
37 | ||
38 | void socket_send_channel_create(QIOTaskFunc f, void *data) | |
39 | { | |
40 | QIOChannelSocket *sioc = qio_channel_socket_new(); | |
41 | qio_channel_socket_connect_async(sioc, outgoing_args.saddr, | |
42 | f, data, NULL, NULL); | |
43 | } | |
44 | ||
36f62f11 PX |
45 | QIOChannel *socket_send_channel_create_sync(Error **errp) |
46 | { | |
47 | QIOChannelSocket *sioc = qio_channel_socket_new(); | |
48 | ||
49 | if (!outgoing_args.saddr) { | |
50 | object_unref(OBJECT(sioc)); | |
51 | error_setg(errp, "Initial sock address not set!"); | |
52 | return NULL; | |
53 | } | |
54 | ||
55 | if (qio_channel_socket_connect_sync(sioc, outgoing_args.saddr, errp) < 0) { | |
56 | object_unref(OBJECT(sioc)); | |
57 | return NULL; | |
58 | } | |
59 | ||
60 | return QIO_CHANNEL(sioc); | |
61 | } | |
62 | ||
3854956a JQ |
63 | int socket_send_channel_destroy(QIOChannel *send) |
64 | { | |
65 | /* Remove channel */ | |
66 | object_unref(OBJECT(send)); | |
67 | if (outgoing_args.saddr) { | |
68 | qapi_free_SocketAddress(outgoing_args.saddr); | |
69 | outgoing_args.saddr = NULL; | |
70 | } | |
71 | return 0; | |
72 | } | |
73 | ||
e1226365 DB |
74 | struct SocketConnectData { |
75 | MigrationState *s; | |
76 | char *hostname; | |
77 | }; | |
78 | ||
79 | static void socket_connect_data_free(void *opaque) | |
80 | { | |
81 | struct SocketConnectData *data = opaque; | |
82 | if (!data) { | |
83 | return; | |
84 | } | |
85 | g_free(data->hostname); | |
86 | g_free(data); | |
87 | } | |
88 | ||
60e705c5 | 89 | static void socket_outgoing_migration(QIOTask *task, |
6f860ae7 | 90 | gpointer opaque) |
4951f65b | 91 | { |
e1226365 | 92 | struct SocketConnectData *data = opaque; |
60e705c5 DB |
93 | QIOChannel *sioc = QIO_CHANNEL(qio_task_get_source(task)); |
94 | Error *err = NULL; | |
4951f65b | 95 | |
60e705c5 | 96 | if (qio_task_propagate_error(task, &err)) { |
6f860ae7 | 97 | trace_migration_socket_outgoing_error(error_get_pretty(err)); |
abb6295b | 98 | goto out; |
4951f65b | 99 | } |
abb6295b LB |
100 | |
101 | trace_migration_socket_outgoing_connected(data->hostname); | |
102 | ||
b4bc342c | 103 | if (migrate_zero_copy_send() && |
5b1d9bab LB |
104 | !qio_channel_has_feature(sioc, QIO_CHANNEL_FEATURE_WRITE_ZERO_COPY)) { |
105 | error_setg(&err, "Zero copy send feature not detected in host kernel"); | |
abb6295b LB |
106 | } |
107 | ||
108 | out: | |
688a3dcb | 109 | migration_channel_connect(data->s, sioc, data->hostname, err); |
60e705c5 | 110 | object_unref(OBJECT(sioc)); |
4951f65b CL |
111 | } |
112 | ||
34dfc5e4 HG |
113 | void socket_start_outgoing_migration(MigrationState *s, |
114 | SocketAddress *saddr, | |
115 | Error **errp) | |
4951f65b | 116 | { |
6f860ae7 | 117 | QIOChannelSocket *sioc = qio_channel_socket_new(); |
e1226365 | 118 | struct SocketConnectData *data = g_new0(struct SocketConnectData, 1); |
34dfc5e4 | 119 | SocketAddress *addr = QAPI_CLONE(SocketAddress, saddr); |
474c624d | 120 | |
e1226365 | 121 | data->s = s; |
3854956a JQ |
122 | |
123 | /* in case previous migration leaked it */ | |
124 | qapi_free_SocketAddress(outgoing_args.saddr); | |
34dfc5e4 | 125 | outgoing_args.saddr = addr; |
3854956a | 126 | |
bd269ebc MA |
127 | if (saddr->type == SOCKET_ADDRESS_TYPE_INET) { |
128 | data->hostname = g_strdup(saddr->u.inet.host); | |
e1226365 | 129 | } |
474c624d | 130 | |
6f01f136 | 131 | qio_channel_set_name(QIO_CHANNEL(sioc), "migration-socket-outgoing"); |
d984464e DB |
132 | qio_channel_socket_connect_async(sioc, |
133 | saddr, | |
6f860ae7 | 134 | socket_outgoing_migration, |
e1226365 | 135 | data, |
8005fdd8 PX |
136 | socket_connect_data_free, |
137 | NULL); | |
4951f65b CL |
138 | } |
139 | ||
bdd847a0 DB |
140 | static void socket_accept_incoming_migration(QIONetListener *listener, |
141 | QIOChannelSocket *cioc, | |
142 | gpointer opaque) | |
4951f65b | 143 | { |
6f860ae7 | 144 | trace_migration_socket_incoming_accepted(); |
d984464e | 145 | |
428d8908 | 146 | if (migration_has_all_channels()) { |
a59136f3 DDAG |
147 | error_report("%s: Extra incoming migration connection; ignoring", |
148 | __func__); | |
149 | return; | |
428d8908 | 150 | } |
a59136f3 DDAG |
151 | |
152 | qio_channel_set_name(QIO_CHANNEL(cioc), "migration-socket-incoming"); | |
153 | migration_channel_process_incoming(QIO_CHANNEL(cioc)); | |
4951f65b CL |
154 | } |
155 | ||
a59136f3 DDAG |
156 | static void |
157 | socket_incoming_migration_end(void *opaque) | |
158 | { | |
159 | QIONetListener *listener = opaque; | |
160 | ||
161 | qio_net_listener_disconnect(listener); | |
162 | object_unref(OBJECT(listener)); | |
163 | } | |
d984464e | 164 | |
34dfc5e4 HG |
165 | void socket_start_incoming_migration(SocketAddress *saddr, |
166 | Error **errp) | |
4951f65b | 167 | { |
bdd847a0 | 168 | QIONetListener *listener = qio_net_listener_new(); |
a59136f3 | 169 | MigrationIncomingState *mis = migration_incoming_get_current(); |
9aca82ba | 170 | size_t i; |
0705e564 | 171 | int num = 1; |
4951f65b | 172 | |
bdd847a0 | 173 | qio_net_listener_set_name(listener, "migration-socket-listener"); |
6f01f136 | 174 | |
51b07548 | 175 | if (migrate_multifd()) { |
0705e564 | 176 | num = migrate_multifd_channels(); |
36f62f11 PX |
177 | } else if (migrate_postcopy_preempt()) { |
178 | num = RAM_CHANNEL_MAX; | |
0705e564 JQ |
179 | } |
180 | ||
181 | if (qio_net_listener_open_sync(listener, saddr, num, errp) < 0) { | |
bdd847a0 | 182 | object_unref(OBJECT(listener)); |
43eaae28 | 183 | return; |
4951f65b CL |
184 | } |
185 | ||
a59136f3 DDAG |
186 | mis->transport_data = listener; |
187 | mis->transport_cleanup = socket_incoming_migration_end; | |
188 | ||
e89f5ff2 PX |
189 | qio_net_listener_set_client_func_full(listener, |
190 | socket_accept_incoming_migration, | |
191 | NULL, NULL, | |
192 | g_main_context_get_thread_default()); | |
9aca82ba JQ |
193 | |
194 | for (i = 0; i < listener->nsioc; i++) { | |
195 | SocketAddress *address = | |
196 | qio_channel_socket_get_local_address(listener->sioc[i], errp); | |
197 | if (!address) { | |
198 | return; | |
199 | } | |
200 | migrate_add_address(address); | |
5e78bc6a | 201 | qapi_free_SocketAddress(address); |
9aca82ba | 202 | } |
4951f65b | 203 | } |
6f860ae7 | 204 |