]>
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" |
4951f65b | 30 | |
3854956a JQ |
31 | struct SocketOutgoingArgs { |
32 | SocketAddress *saddr; | |
33 | } outgoing_args; | |
34 | ||
35 | void socket_send_channel_create(QIOTaskFunc f, void *data) | |
36 | { | |
37 | QIOChannelSocket *sioc = qio_channel_socket_new(); | |
38 | qio_channel_socket_connect_async(sioc, outgoing_args.saddr, | |
39 | f, data, NULL, NULL); | |
40 | } | |
41 | ||
36f62f11 PX |
42 | QIOChannel *socket_send_channel_create_sync(Error **errp) |
43 | { | |
44 | QIOChannelSocket *sioc = qio_channel_socket_new(); | |
45 | ||
46 | if (!outgoing_args.saddr) { | |
47 | object_unref(OBJECT(sioc)); | |
48 | error_setg(errp, "Initial sock address not set!"); | |
49 | return NULL; | |
50 | } | |
51 | ||
52 | if (qio_channel_socket_connect_sync(sioc, outgoing_args.saddr, errp) < 0) { | |
53 | object_unref(OBJECT(sioc)); | |
54 | return NULL; | |
55 | } | |
56 | ||
57 | return QIO_CHANNEL(sioc); | |
58 | } | |
59 | ||
3854956a JQ |
60 | int socket_send_channel_destroy(QIOChannel *send) |
61 | { | |
62 | /* Remove channel */ | |
63 | object_unref(OBJECT(send)); | |
64 | if (outgoing_args.saddr) { | |
65 | qapi_free_SocketAddress(outgoing_args.saddr); | |
66 | outgoing_args.saddr = NULL; | |
67 | } | |
68 | return 0; | |
69 | } | |
70 | ||
e1226365 DB |
71 | struct SocketConnectData { |
72 | MigrationState *s; | |
73 | char *hostname; | |
74 | }; | |
75 | ||
76 | static void socket_connect_data_free(void *opaque) | |
77 | { | |
78 | struct SocketConnectData *data = opaque; | |
79 | if (!data) { | |
80 | return; | |
81 | } | |
82 | g_free(data->hostname); | |
83 | g_free(data); | |
84 | } | |
85 | ||
60e705c5 | 86 | static void socket_outgoing_migration(QIOTask *task, |
6f860ae7 | 87 | gpointer opaque) |
4951f65b | 88 | { |
e1226365 | 89 | struct SocketConnectData *data = opaque; |
60e705c5 DB |
90 | QIOChannel *sioc = QIO_CHANNEL(qio_task_get_source(task)); |
91 | Error *err = NULL; | |
4951f65b | 92 | |
60e705c5 | 93 | if (qio_task_propagate_error(task, &err)) { |
6f860ae7 | 94 | trace_migration_socket_outgoing_error(error_get_pretty(err)); |
abb6295b | 95 | goto out; |
4951f65b | 96 | } |
abb6295b LB |
97 | |
98 | trace_migration_socket_outgoing_connected(data->hostname); | |
99 | ||
5b1d9bab LB |
100 | if (migrate_use_zero_copy_send() && |
101 | !qio_channel_has_feature(sioc, QIO_CHANNEL_FEATURE_WRITE_ZERO_COPY)) { | |
102 | error_setg(&err, "Zero copy send feature not detected in host kernel"); | |
abb6295b LB |
103 | } |
104 | ||
105 | out: | |
688a3dcb | 106 | migration_channel_connect(data->s, sioc, data->hostname, err); |
60e705c5 | 107 | object_unref(OBJECT(sioc)); |
4951f65b CL |
108 | } |
109 | ||
d658f65c LM |
110 | static void |
111 | socket_start_outgoing_migration_internal(MigrationState *s, | |
112 | SocketAddress *saddr, | |
113 | Error **errp) | |
4951f65b | 114 | { |
6f860ae7 | 115 | QIOChannelSocket *sioc = qio_channel_socket_new(); |
e1226365 | 116 | struct SocketConnectData *data = g_new0(struct SocketConnectData, 1); |
474c624d | 117 | |
e1226365 | 118 | data->s = s; |
3854956a JQ |
119 | |
120 | /* in case previous migration leaked it */ | |
121 | qapi_free_SocketAddress(outgoing_args.saddr); | |
122 | outgoing_args.saddr = saddr; | |
123 | ||
bd269ebc MA |
124 | if (saddr->type == SOCKET_ADDRESS_TYPE_INET) { |
125 | data->hostname = g_strdup(saddr->u.inet.host); | |
e1226365 | 126 | } |
474c624d | 127 | |
6f01f136 | 128 | qio_channel_set_name(QIO_CHANNEL(sioc), "migration-socket-outgoing"); |
d984464e DB |
129 | qio_channel_socket_connect_async(sioc, |
130 | saddr, | |
6f860ae7 | 131 | socket_outgoing_migration, |
e1226365 | 132 | data, |
8005fdd8 PX |
133 | socket_connect_data_free, |
134 | NULL); | |
4951f65b CL |
135 | } |
136 | ||
d658f65c LM |
137 | void socket_start_outgoing_migration(MigrationState *s, |
138 | const char *str, | |
139 | Error **errp) | |
e65c67e4 | 140 | { |
9308ae54 | 141 | Error *err = NULL; |
d658f65c | 142 | SocketAddress *saddr = socket_parse(str, &err); |
9308ae54 | 143 | if (!err) { |
d658f65c | 144 | socket_start_outgoing_migration_internal(s, saddr, &err); |
9308ae54 DDAG |
145 | } |
146 | error_propagate(errp, err); | |
e65c67e4 DB |
147 | } |
148 | ||
bdd847a0 DB |
149 | static void socket_accept_incoming_migration(QIONetListener *listener, |
150 | QIOChannelSocket *cioc, | |
151 | gpointer opaque) | |
4951f65b | 152 | { |
6f860ae7 | 153 | trace_migration_socket_incoming_accepted(); |
d984464e | 154 | |
428d8908 | 155 | if (migration_has_all_channels()) { |
a59136f3 DDAG |
156 | error_report("%s: Extra incoming migration connection; ignoring", |
157 | __func__); | |
158 | return; | |
428d8908 | 159 | } |
a59136f3 DDAG |
160 | |
161 | qio_channel_set_name(QIO_CHANNEL(cioc), "migration-socket-incoming"); | |
162 | migration_channel_process_incoming(QIO_CHANNEL(cioc)); | |
4951f65b CL |
163 | } |
164 | ||
a59136f3 DDAG |
165 | static void |
166 | socket_incoming_migration_end(void *opaque) | |
167 | { | |
168 | QIONetListener *listener = opaque; | |
169 | ||
170 | qio_net_listener_disconnect(listener); | |
171 | object_unref(OBJECT(listener)); | |
172 | } | |
d984464e | 173 | |
d658f65c LM |
174 | static void |
175 | socket_start_incoming_migration_internal(SocketAddress *saddr, | |
176 | Error **errp) | |
4951f65b | 177 | { |
bdd847a0 | 178 | QIONetListener *listener = qio_net_listener_new(); |
a59136f3 | 179 | MigrationIncomingState *mis = migration_incoming_get_current(); |
9aca82ba | 180 | size_t i; |
0705e564 | 181 | int num = 1; |
4951f65b | 182 | |
bdd847a0 | 183 | qio_net_listener_set_name(listener, "migration-socket-listener"); |
6f01f136 | 184 | |
0705e564 JQ |
185 | if (migrate_use_multifd()) { |
186 | num = migrate_multifd_channels(); | |
36f62f11 PX |
187 | } else if (migrate_postcopy_preempt()) { |
188 | num = RAM_CHANNEL_MAX; | |
0705e564 JQ |
189 | } |
190 | ||
191 | if (qio_net_listener_open_sync(listener, saddr, num, errp) < 0) { | |
bdd847a0 | 192 | object_unref(OBJECT(listener)); |
43eaae28 | 193 | return; |
4951f65b CL |
194 | } |
195 | ||
a59136f3 DDAG |
196 | mis->transport_data = listener; |
197 | mis->transport_cleanup = socket_incoming_migration_end; | |
198 | ||
e89f5ff2 PX |
199 | qio_net_listener_set_client_func_full(listener, |
200 | socket_accept_incoming_migration, | |
201 | NULL, NULL, | |
202 | g_main_context_get_thread_default()); | |
9aca82ba JQ |
203 | |
204 | for (i = 0; i < listener->nsioc; i++) { | |
205 | SocketAddress *address = | |
206 | qio_channel_socket_get_local_address(listener->sioc[i], errp); | |
207 | if (!address) { | |
208 | return; | |
209 | } | |
210 | migrate_add_address(address); | |
5e78bc6a | 211 | qapi_free_SocketAddress(address); |
9aca82ba | 212 | } |
4951f65b | 213 | } |
6f860ae7 | 214 | |
d658f65c | 215 | void socket_start_incoming_migration(const char *str, Error **errp) |
e65c67e4 | 216 | { |
9308ae54 | 217 | Error *err = NULL; |
d658f65c | 218 | SocketAddress *saddr = socket_parse(str, &err); |
9308ae54 | 219 | if (!err) { |
d658f65c | 220 | socket_start_incoming_migration_internal(saddr, &err); |
9308ae54 | 221 | } |
9102d27e | 222 | qapi_free_SocketAddress(saddr); |
9308ae54 | 223 | error_propagate(errp, err); |
e65c67e4 | 224 | } |