Paolo Bonzini | 5ac1fad | 2009-08-18 15:56:25 +0200 | [diff] [blame] | 1 | /* |
| 2 | * QEMU live migration via generic fd |
| 3 | * |
Daniel P. Berrange | 64802ee | 2016-04-27 11:05:05 +0100 | [diff] [blame] | 4 | * Copyright Red Hat, Inc. 2009-2016 |
Paolo Bonzini | 5ac1fad | 2009-08-18 15:56:25 +0200 | [diff] [blame] | 5 | * |
| 6 | * Authors: |
| 7 | * Chris Lalancette <clalance@redhat.com> |
Daniel P. Berrange | 64802ee | 2016-04-27 11:05:05 +0100 | [diff] [blame] | 8 | * Daniel P. Berrange <berrange@redhat.com> |
Paolo Bonzini | 5ac1fad | 2009-08-18 15:56:25 +0200 | [diff] [blame] | 9 | * |
| 10 | * This work is licensed under the terms of the GNU GPL, version 2. See |
| 11 | * the COPYING file in the top-level directory. |
| 12 | * |
Paolo Bonzini | 6b620ca | 2012-01-13 17:44:23 +0100 | [diff] [blame] | 13 | * Contributions after 2012-01-13 are licensed under the terms of the |
| 14 | * GNU GPL, version 2 or (at your option) any later version. |
Paolo Bonzini | 5ac1fad | 2009-08-18 15:56:25 +0200 | [diff] [blame] | 15 | */ |
| 16 | |
Peter Maydell | 1393a48 | 2016-01-26 18:16:54 +0000 | [diff] [blame] | 17 | #include "qemu/osdep.h" |
Juan Quintela | dd4339c | 2017-04-17 17:07:04 +0200 | [diff] [blame] | 18 | #include "channel.h" |
Juan Quintela | 7fcac4a | 2017-04-05 15:58:29 +0200 | [diff] [blame] | 19 | #include "fd.h" |
Juan Quintela | 0efc914 | 2018-05-23 11:14:11 +0200 | [diff] [blame] | 20 | #include "migration.h" |
Paolo Bonzini | 83c9089 | 2012-12-17 18:19:49 +0100 | [diff] [blame] | 21 | #include "monitor/monitor.h" |
Daniel P. Berrange | 64802ee | 2016-04-27 11:05:05 +0100 | [diff] [blame] | 22 | #include "io/channel-util.h" |
| 23 | #include "trace.h" |
Paolo Bonzini | 5ac1fad | 2009-08-18 15:56:25 +0200 | [diff] [blame] | 24 | |
Cristian Klein | 131fe9b | 2015-01-08 11:11:31 +0000 | [diff] [blame] | 25 | |
Paolo Bonzini | f37afb5 | 2012-10-02 10:02:46 +0200 | [diff] [blame] | 26 | void fd_start_outgoing_migration(MigrationState *s, const char *fdname, Error **errp) |
Paolo Bonzini | 5ac1fad | 2009-08-18 15:56:25 +0200 | [diff] [blame] | 27 | { |
Daniel P. Berrange | 64802ee | 2016-04-27 11:05:05 +0100 | [diff] [blame] | 28 | QIOChannel *ioc; |
Kevin Wolf | 947e474 | 2020-10-05 17:58:44 +0200 | [diff] [blame] | 29 | int fd = monitor_get_fd(monitor_cur(), fdname, errp); |
Paolo Bonzini | f8bbc12 | 2013-02-22 17:36:41 +0100 | [diff] [blame] | 30 | if (fd == -1) { |
Paolo Bonzini | f37afb5 | 2012-10-02 10:02:46 +0200 | [diff] [blame] | 31 | return; |
Paolo Bonzini | 5ac1fad | 2009-08-18 15:56:25 +0200 | [diff] [blame] | 32 | } |
Cristian Klein | 131fe9b | 2015-01-08 11:11:31 +0000 | [diff] [blame] | 33 | |
Daniel P. Berrange | 64802ee | 2016-04-27 11:05:05 +0100 | [diff] [blame] | 34 | trace_migration_fd_outgoing(fd); |
| 35 | ioc = qio_channel_new_fd(fd, errp); |
| 36 | if (!ioc) { |
| 37 | close(fd); |
| 38 | return; |
Cristian Klein | 131fe9b | 2015-01-08 11:11:31 +0000 | [diff] [blame] | 39 | } |
Paolo Bonzini | 5ac1fad | 2009-08-18 15:56:25 +0200 | [diff] [blame] | 40 | |
Daniel P. Berrange | 6f01f13 | 2016-09-30 11:57:14 +0100 | [diff] [blame] | 41 | qio_channel_set_name(QIO_CHANNEL(ioc), "migration-fd-outgoing"); |
Dr. David Alan Gilbert | 688a3dc | 2017-12-15 17:16:55 +0000 | [diff] [blame] | 42 | migration_channel_connect(s, ioc, NULL, NULL); |
Daniel P. Berrange | 64802ee | 2016-04-27 11:05:05 +0100 | [diff] [blame] | 43 | object_unref(OBJECT(ioc)); |
Paolo Bonzini | 5ac1fad | 2009-08-18 15:56:25 +0200 | [diff] [blame] | 44 | } |
| 45 | |
Daniel P. Berrange | 64802ee | 2016-04-27 11:05:05 +0100 | [diff] [blame] | 46 | static gboolean fd_accept_incoming_migration(QIOChannel *ioc, |
| 47 | GIOCondition condition, |
| 48 | gpointer opaque) |
Paolo Bonzini | 5ac1fad | 2009-08-18 15:56:25 +0200 | [diff] [blame] | 49 | { |
Juan Quintela | 5431471 | 2017-04-17 17:15:02 +0200 | [diff] [blame] | 50 | migration_channel_process_incoming(ioc); |
Daniel P. Berrange | 64802ee | 2016-04-27 11:05:05 +0100 | [diff] [blame] | 51 | object_unref(OBJECT(ioc)); |
Juan Quintela | 2a543bf | 2017-07-24 12:51:59 +0200 | [diff] [blame] | 52 | return G_SOURCE_REMOVE; |
Paolo Bonzini | 5ac1fad | 2009-08-18 15:56:25 +0200 | [diff] [blame] | 53 | } |
| 54 | |
Yury Kotov | 61053d4 | 2019-05-28 12:16:32 +0300 | [diff] [blame] | 55 | void fd_start_incoming_migration(const char *fdname, Error **errp) |
Paolo Bonzini | 5ac1fad | 2009-08-18 15:56:25 +0200 | [diff] [blame] | 56 | { |
Daniel P. Berrange | 64802ee | 2016-04-27 11:05:05 +0100 | [diff] [blame] | 57 | QIOChannel *ioc; |
Kevin Wolf | 947e474 | 2020-10-05 17:58:44 +0200 | [diff] [blame] | 58 | int fd = monitor_fd_param(monitor_cur(), fdname, errp); |
Yury Kotov | 61053d4 | 2019-05-28 12:16:32 +0300 | [diff] [blame] | 59 | if (fd == -1) { |
| 60 | return; |
| 61 | } |
Paolo Bonzini | 5ac1fad | 2009-08-18 15:56:25 +0200 | [diff] [blame] | 62 | |
Daniel P. Berrange | 64802ee | 2016-04-27 11:05:05 +0100 | [diff] [blame] | 63 | trace_migration_fd_incoming(fd); |
| 64 | |
| 65 | ioc = qio_channel_new_fd(fd, errp); |
| 66 | if (!ioc) { |
| 67 | close(fd); |
Paolo Bonzini | 43eaae2 | 2012-10-02 18:21:18 +0200 | [diff] [blame] | 68 | return; |
Paolo Bonzini | 5ac1fad | 2009-08-18 15:56:25 +0200 | [diff] [blame] | 69 | } |
| 70 | |
Daniel P. Berrange | 6f01f13 | 2016-09-30 11:57:14 +0100 | [diff] [blame] | 71 | qio_channel_set_name(QIO_CHANNEL(ioc), "migration-fd-incoming"); |
Peter Xu | e89f5ff | 2018-05-02 18:47:17 +0800 | [diff] [blame] | 72 | qio_channel_add_watch_full(ioc, G_IO_IN, |
| 73 | fd_accept_incoming_migration, |
| 74 | NULL, NULL, |
| 75 | g_main_context_get_thread_default()); |
Paolo Bonzini | 5ac1fad | 2009-08-18 15:56:25 +0200 | [diff] [blame] | 76 | } |