projects / mirror_qemu.git / blame
| 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" | |
| 21 | ||
| 8e1a1931 JQ |
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 | */ | |
| 54314711 | 30 | void migration_channel_process_incoming(QIOChannel *ioc) |
| dd4339c5 | 31 | { |
| 54314711 JQ |
32 | MigrationState *s = migrate_get_current(); |
| 33 | ||
| dd4339c5 JQ |
34 | trace_migration_set_incoming_channel( |
| 35 | ioc, object_get_typename(OBJECT(ioc))); | |
| 36 | ||
| 37 | if (s->parameters.tls_creds && | |
| 38 | *s->parameters.tls_creds && | |
| 39 | !object_dynamic_cast(OBJECT(ioc), | |
| 40 | TYPE_QIO_CHANNEL_TLS)) { | |
| 41 | Error *local_err = NULL; | |
| 42 | migration_tls_channel_process_incoming(s, ioc, &local_err); | |
| 43 | if (local_err) { | |
| 44 | error_report_err(local_err); | |
| 45 | } | |
| 46 | } else { | |
| 4f0fae7f | 47 | migration_ioc_process_incoming(ioc); |
| dd4339c5 JQ |
48 | } |
| 49 | } | |
| 50 | ||
| 51 | ||
| 8e1a1931 JQ |
52 | /** |
| 53 | * @migration_channel_connect - Create new outgoing migration channel | |
| 54 | * | |
| 55 | * @s: Current migration state | |
| 56 | * @ioc: Channel to which we are connecting | |
| 57 | * @hostname: Where we want to connect | |
| 58 | */ | |
| dd4339c5 JQ |
59 | void migration_channel_connect(MigrationState *s, |
| 60 | QIOChannel *ioc, | |
| 61 | const char *hostname) | |
| 62 | { | |
| 63 | trace_migration_set_outgoing_channel( | |
| 64 | ioc, object_get_typename(OBJECT(ioc)), hostname); | |
| 65 | ||
| 66 | if (s->parameters.tls_creds && | |
| 67 | *s->parameters.tls_creds && | |
| 68 | !object_dynamic_cast(OBJECT(ioc), | |
| 69 | TYPE_QIO_CHANNEL_TLS)) { | |
| 70 | Error *local_err = NULL; | |
| 71 | migration_tls_channel_connect(s, ioc, hostname, &local_err); | |
| 72 | if (local_err) { | |
| 73 | migrate_fd_error(s, local_err); | |
| 74 | error_free(local_err); | |
| 75 | } | |
| 76 | } else { | |
| 77 | QEMUFile *f = qemu_fopen_channel_output(ioc); | |
| 78 | ||
| 79 | s->to_dst_file = f; | |
| 80 | ||
| cce8040b | 81 | migrate_fd_connect(s, NULL); |
| dd4339c5 JQ |
82 | } |
| 83 | } |