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 */
30void 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 */
61void 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