]>
Commit | Line | Data |
---|---|---|
dd4339c5 JQ |
1 | /* |
2 | * QEMU live migration channel operations | |
3 | * | |
4 | * Copyright Red Hat, Inc. 2016 | |
5 | * | |
6 | * Authors: | |
7 | * Daniel P. Berrange <berrange@redhat.com> | |
8 | * | |
9 | * Contributions after 2012-01-13 are licensed under the terms of the | |
10 | * GNU GPL, version 2 or (at your option) any later version. | |
11 | */ | |
12 | ||
13 | #include "qemu/osdep.h" | |
14 | #include "channel.h" | |
41d64227 | 15 | #include "tls.h" |
6666c96a | 16 | #include "migration.h" |
40014d81 | 17 | #include "qemu-file-channel.h" |
dd4339c5 JQ |
18 | #include "trace.h" |
19 | #include "qapi/error.h" | |
20 | #include "io/channel-tls.h" | |
b5eea99e LS |
21 | #include "io/channel-socket.h" |
22 | #include "qemu/yank.h" | |
1a92d6d5 | 23 | #include "yank_functions.h" |
dd4339c5 | 24 | |
8e1a1931 JQ |
25 | /** |
26 | * @migration_channel_process_incoming - Create new incoming migration channel | |
27 | * | |
28 | * Notice that TLS is special. For it we listen in a listener socket, | |
29 | * and then create a new client socket from the TLS library. | |
30 | * | |
31 | * @ioc: Channel to which we are connecting | |
32 | */ | |
54314711 | 33 | void migration_channel_process_incoming(QIOChannel *ioc) |
dd4339c5 | 34 | { |
54314711 | 35 | MigrationState *s = migrate_get_current(); |
49ed0d24 | 36 | Error *local_err = NULL; |
54314711 | 37 | |
dd4339c5 JQ |
38 | trace_migration_set_incoming_channel( |
39 | ioc, object_get_typename(OBJECT(ioc))); | |
40 | ||
41 | if (s->parameters.tls_creds && | |
42 | *s->parameters.tls_creds && | |
43 | !object_dynamic_cast(OBJECT(ioc), | |
44 | TYPE_QIO_CHANNEL_TLS)) { | |
dd4339c5 | 45 | migration_tls_channel_process_incoming(s, ioc, &local_err); |
dd4339c5 | 46 | } else { |
7de2e856 LB |
47 | if (object_dynamic_cast(OBJECT(ioc), TYPE_QIO_CHANNEL_SOCKET) || |
48 | object_dynamic_cast(OBJECT(ioc), TYPE_QIO_CHANNEL_TLS)) { | |
49 | yank_register_function(MIGRATION_YANK_INSTANCE, | |
50 | migration_yank_iochannel, | |
51 | QIO_CHANNEL(ioc)); | |
52 | } | |
53 | ||
49ed0d24 FL |
54 | migration_ioc_process_incoming(ioc, &local_err); |
55 | } | |
56 | ||
57 | if (local_err) { | |
58 | error_report_err(local_err); | |
dd4339c5 JQ |
59 | } |
60 | } | |
61 | ||
62 | ||
8e1a1931 JQ |
63 | /** |
64 | * @migration_channel_connect - Create new outgoing migration channel | |
65 | * | |
66 | * @s: Current migration state | |
67 | * @ioc: Channel to which we are connecting | |
68 | * @hostname: Where we want to connect | |
688a3dcb | 69 | * @error: Error indicating failure to connect, free'd here |
8e1a1931 | 70 | */ |
dd4339c5 JQ |
71 | void migration_channel_connect(MigrationState *s, |
72 | QIOChannel *ioc, | |
688a3dcb DDAG |
73 | const char *hostname, |
74 | Error *error) | |
dd4339c5 JQ |
75 | { |
76 | trace_migration_set_outgoing_channel( | |
688a3dcb | 77 | ioc, object_get_typename(OBJECT(ioc)), hostname, error); |
dd4339c5 | 78 | |
688a3dcb DDAG |
79 | if (!error) { |
80 | if (s->parameters.tls_creds && | |
81 | *s->parameters.tls_creds && | |
82 | !object_dynamic_cast(OBJECT(ioc), | |
83 | TYPE_QIO_CHANNEL_TLS)) { | |
84 | migration_tls_channel_connect(s, ioc, hostname, &error); | |
8b7bf2ba DDAG |
85 | |
86 | if (!error) { | |
87 | /* tls_channel_connect will call back to this | |
88 | * function after the TLS handshake, | |
89 | * so we mustn't call migrate_fd_connect until then | |
90 | */ | |
91 | ||
92 | return; | |
93 | } | |
688a3dcb DDAG |
94 | } else { |
95 | QEMUFile *f = qemu_fopen_channel_output(ioc); | |
dd4339c5 | 96 | |
7de2e856 LB |
97 | if (object_dynamic_cast(OBJECT(ioc), TYPE_QIO_CHANNEL_SOCKET) || |
98 | object_dynamic_cast(OBJECT(ioc), TYPE_QIO_CHANNEL_TLS)) { | |
99 | yank_register_function(MIGRATION_YANK_INSTANCE, | |
100 | migration_yank_iochannel, | |
101 | QIO_CHANNEL(ioc)); | |
102 | } | |
103 | ||
62df066f | 104 | qemu_mutex_lock(&s->qemu_file_lock); |
688a3dcb | 105 | s->to_dst_file = f; |
62df066f | 106 | qemu_mutex_unlock(&s->qemu_file_lock); |
688a3dcb | 107 | } |
dd4339c5 | 108 | } |
688a3dcb | 109 | migrate_fd_connect(s, error); |
d8053e73 | 110 | g_free(s->hostname); |
688a3dcb | 111 | error_free(error); |
dd4339c5 | 112 | } |