]>
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" |
4951f65b | 29 | |
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 | ||
42 | int socket_send_channel_destroy(QIOChannel *send) | |
43 | { | |
44 | /* Remove channel */ | |
45 | object_unref(OBJECT(send)); | |
46 | if (outgoing_args.saddr) { | |
47 | qapi_free_SocketAddress(outgoing_args.saddr); | |
48 | outgoing_args.saddr = NULL; | |
49 | } | |
50 | return 0; | |
51 | } | |
52 | ||
e1226365 DB |
53 | struct SocketConnectData { |
54 | MigrationState *s; | |
55 | char *hostname; | |
56 | }; | |
57 | ||
58 | static void socket_connect_data_free(void *opaque) | |
59 | { | |
60 | struct SocketConnectData *data = opaque; | |
61 | if (!data) { | |
62 | return; | |
63 | } | |
64 | g_free(data->hostname); | |
65 | g_free(data); | |
66 | } | |
67 | ||
60e705c5 | 68 | static void socket_outgoing_migration(QIOTask *task, |
6f860ae7 | 69 | gpointer opaque) |
4951f65b | 70 | { |
e1226365 | 71 | struct SocketConnectData *data = opaque; |
60e705c5 DB |
72 | QIOChannel *sioc = QIO_CHANNEL(qio_task_get_source(task)); |
73 | Error *err = NULL; | |
4951f65b | 74 | |
60e705c5 | 75 | if (qio_task_propagate_error(task, &err)) { |
6f860ae7 | 76 | trace_migration_socket_outgoing_error(error_get_pretty(err)); |
e08c95ce | 77 | } else { |
e1226365 | 78 | trace_migration_socket_outgoing_connected(data->hostname); |
4951f65b | 79 | } |
688a3dcb | 80 | migration_channel_connect(data->s, sioc, data->hostname, err); |
60e705c5 | 81 | object_unref(OBJECT(sioc)); |
4951f65b CL |
82 | } |
83 | ||
d658f65c LM |
84 | static void |
85 | socket_start_outgoing_migration_internal(MigrationState *s, | |
86 | SocketAddress *saddr, | |
87 | Error **errp) | |
4951f65b | 88 | { |
6f860ae7 | 89 | QIOChannelSocket *sioc = qio_channel_socket_new(); |
e1226365 | 90 | struct SocketConnectData *data = g_new0(struct SocketConnectData, 1); |
474c624d | 91 | |
e1226365 | 92 | data->s = s; |
3854956a JQ |
93 | |
94 | /* in case previous migration leaked it */ | |
95 | qapi_free_SocketAddress(outgoing_args.saddr); | |
96 | outgoing_args.saddr = saddr; | |
97 | ||
bd269ebc MA |
98 | if (saddr->type == SOCKET_ADDRESS_TYPE_INET) { |
99 | data->hostname = g_strdup(saddr->u.inet.host); | |
e1226365 | 100 | } |
474c624d | 101 | |
6f01f136 | 102 | qio_channel_set_name(QIO_CHANNEL(sioc), "migration-socket-outgoing"); |
d984464e DB |
103 | qio_channel_socket_connect_async(sioc, |
104 | saddr, | |
6f860ae7 | 105 | socket_outgoing_migration, |
e1226365 | 106 | data, |
8005fdd8 PX |
107 | socket_connect_data_free, |
108 | NULL); | |
4951f65b CL |
109 | } |
110 | ||
d658f65c LM |
111 | void socket_start_outgoing_migration(MigrationState *s, |
112 | const char *str, | |
113 | Error **errp) | |
e65c67e4 | 114 | { |
9308ae54 | 115 | Error *err = NULL; |
d658f65c | 116 | SocketAddress *saddr = socket_parse(str, &err); |
9308ae54 | 117 | if (!err) { |
d658f65c | 118 | socket_start_outgoing_migration_internal(s, saddr, &err); |
9308ae54 DDAG |
119 | } |
120 | error_propagate(errp, err); | |
e65c67e4 DB |
121 | } |
122 | ||
bdd847a0 DB |
123 | static void socket_accept_incoming_migration(QIONetListener *listener, |
124 | QIOChannelSocket *cioc, | |
125 | gpointer opaque) | |
4951f65b | 126 | { |
6f860ae7 | 127 | trace_migration_socket_incoming_accepted(); |
d984464e | 128 | |
bdd847a0 DB |
129 | qio_channel_set_name(QIO_CHANNEL(cioc), "migration-socket-incoming"); |
130 | migration_channel_process_incoming(QIO_CHANNEL(cioc)); | |
ab52a824 | 131 | |
428d8908 JQ |
132 | if (migration_has_all_channels()) { |
133 | /* Close listening socket as its no longer needed */ | |
bdd847a0 | 134 | qio_net_listener_disconnect(listener); |
bdd847a0 | 135 | object_unref(OBJECT(listener)); |
428d8908 | 136 | } |
4951f65b CL |
137 | } |
138 | ||
d984464e | 139 | |
d658f65c LM |
140 | static void |
141 | socket_start_incoming_migration_internal(SocketAddress *saddr, | |
142 | Error **errp) | |
4951f65b | 143 | { |
bdd847a0 | 144 | QIONetListener *listener = qio_net_listener_new(); |
9aca82ba | 145 | size_t i; |
0705e564 | 146 | int num = 1; |
4951f65b | 147 | |
bdd847a0 | 148 | qio_net_listener_set_name(listener, "migration-socket-listener"); |
6f01f136 | 149 | |
0705e564 JQ |
150 | if (migrate_use_multifd()) { |
151 | num = migrate_multifd_channels(); | |
152 | } | |
153 | ||
154 | if (qio_net_listener_open_sync(listener, saddr, num, errp) < 0) { | |
bdd847a0 | 155 | object_unref(OBJECT(listener)); |
43eaae28 | 156 | return; |
4951f65b CL |
157 | } |
158 | ||
e89f5ff2 PX |
159 | qio_net_listener_set_client_func_full(listener, |
160 | socket_accept_incoming_migration, | |
161 | NULL, NULL, | |
162 | g_main_context_get_thread_default()); | |
9aca82ba JQ |
163 | |
164 | for (i = 0; i < listener->nsioc; i++) { | |
165 | SocketAddress *address = | |
166 | qio_channel_socket_get_local_address(listener->sioc[i], errp); | |
167 | if (!address) { | |
168 | return; | |
169 | } | |
170 | migrate_add_address(address); | |
5e78bc6a | 171 | qapi_free_SocketAddress(address); |
9aca82ba | 172 | } |
4951f65b | 173 | } |
6f860ae7 | 174 | |
d658f65c | 175 | void socket_start_incoming_migration(const char *str, Error **errp) |
e65c67e4 | 176 | { |
9308ae54 | 177 | Error *err = NULL; |
d658f65c | 178 | SocketAddress *saddr = socket_parse(str, &err); |
9308ae54 | 179 | if (!err) { |
d658f65c | 180 | socket_start_incoming_migration_internal(saddr, &err); |
9308ae54 | 181 | } |
9102d27e | 182 | qapi_free_SocketAddress(saddr); |
9308ae54 | 183 | error_propagate(errp, err); |
e65c67e4 | 184 | } |