Merge remote-tracking branch 'remotes/pmaydell/tags/pull-target-arm-20200123-4' into...
[qemu.git] / migration / channel.c
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 }