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" |
15 | #include "tls.h" |
16 | #include "migration.h" |
17 | #include "qemu-file-channel.h" |
18 | #include "trace.h" |
19 | #include "qapi/error.h" |
20 | #include "io/channel-tls.h" |
21 | |
22 | /** |
23 | * @migration_channel_process_incoming - Create new incoming migration channel |
24 | * |
25 | * Notice that TLS is special. For it we listen in a listener socket, |
26 | * and then create a new client socket from the TLS library. |
27 | * |
28 | * @ioc: Channel to which we are connecting |
29 | */ |
30 | void migration_channel_process_incoming(QIOChannel *ioc) |
31 | { |
32 | MigrationState *s = migrate_get_current(); |
33 | Error *local_err = NULL; |
34 | |
35 | trace_migration_set_incoming_channel( |
36 | ioc, object_get_typename(OBJECT(ioc))); |
37 | |
38 | if (s->parameters.tls_creds && |
39 | *s->parameters.tls_creds && |
40 | !object_dynamic_cast(OBJECT(ioc), |
41 | TYPE_QIO_CHANNEL_TLS)) { |
42 | migration_tls_channel_process_incoming(s, ioc, &local_err); |
43 | } else { |
44 | migration_ioc_process_incoming(ioc, &local_err); |
45 | } |
46 | |
47 | if (local_err) { |
48 | error_report_err(local_err); |
49 | } |
50 | } |
51 | |
52 | |
53 | /** |
54 | * @migration_channel_connect - Create new outgoing migration channel |
55 | * |
56 | * @s: Current migration state |
57 | * @ioc: Channel to which we are connecting |
58 | * @hostname: Where we want to connect |
59 | * @error: Error indicating failure to connect, free'd here |
60 | */ |
61 | void migration_channel_connect(MigrationState *s, |
62 | QIOChannel *ioc, |
63 | const char *hostname, |
64 | Error *error) |
65 | { |
66 | trace_migration_set_outgoing_channel( |
67 | ioc, object_get_typename(OBJECT(ioc)), hostname, error); |
68 | |
69 | if (!error) { |
70 | if (s->parameters.tls_creds && |
71 | *s->parameters.tls_creds && |
72 | !object_dynamic_cast(OBJECT(ioc), |
73 | TYPE_QIO_CHANNEL_TLS)) { |
74 | migration_tls_channel_connect(s, ioc, hostname, &error); |
75 | |
76 | if (!error) { |
77 | /* tls_channel_connect will call back to this |
78 | * function after the TLS handshake, |
79 | * so we mustn't call migrate_fd_connect until then |
80 | */ |
81 | |
82 | return; |
83 | } |
84 | } else { |
85 | QEMUFile *f = qemu_fopen_channel_output(ioc); |
86 | |
87 | qemu_mutex_lock(&s->qemu_file_lock); |
88 | s->to_dst_file = f; |
89 | qemu_mutex_unlock(&s->qemu_file_lock); |
90 | } |
91 | } |
92 | migrate_fd_connect(s, error); |
93 | error_free(error); |
94 | } |
95 | |