1 | /* |
2 | * QEMU live migration via generic fd |
3 | * |
4 | * Copyright Red Hat, Inc. 2009-2016 |
5 | * |
6 | * Authors: |
7 | * Chris Lalancette <clalance@redhat.com> |
8 | * Daniel P. Berrange <berrange@redhat.com> |
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 | * |
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. |
15 | */ |
16 | |
17 | #include "qemu/osdep.h" |
18 | #include "channel.h" |
19 | #include "fd.h" |
20 | #include "migration.h" |
21 | #include "monitor/monitor.h" |
22 | #include "io/channel-util.h" |
23 | #include "trace.h" |
24 | |
25 | |
26 | void fd_start_outgoing_migration(MigrationState *s, const char *fdname, Error **errp) |
27 | { |
28 | QIOChannel *ioc; |
29 | int fd = monitor_get_fd(cur_mon, fdname, errp); |
30 | if (fd == -1) { |
31 | return; |
32 | } |
33 | |
34 | trace_migration_fd_outgoing(fd); |
35 | ioc = qio_channel_new_fd(fd, errp); |
36 | if (!ioc) { |
37 | close(fd); |
38 | return; |
39 | } |
40 | |
41 | qio_channel_set_name(QIO_CHANNEL(ioc), "migration-fd-outgoing" ); |
42 | migration_channel_connect(s, ioc, NULL, NULL); |
43 | object_unref(OBJECT(ioc)); |
44 | } |
45 | |
46 | static gboolean fd_accept_incoming_migration(QIOChannel *ioc, |
47 | GIOCondition condition, |
48 | gpointer opaque) |
49 | { |
50 | migration_channel_process_incoming(ioc); |
51 | object_unref(OBJECT(ioc)); |
52 | return G_SOURCE_REMOVE; |
53 | } |
54 | |
55 | void fd_start_incoming_migration(const char *fdname, Error **errp) |
56 | { |
57 | QIOChannel *ioc; |
58 | int fd = monitor_fd_param(cur_mon, fdname, errp); |
59 | if (fd == -1) { |
60 | return; |
61 | } |
62 | |
63 | trace_migration_fd_incoming(fd); |
64 | |
65 | ioc = qio_channel_new_fd(fd, errp); |
66 | if (!ioc) { |
67 | close(fd); |
68 | return; |
69 | } |
70 | |
71 | qio_channel_set_name(QIO_CHANNEL(ioc), "migration-fd-incoming" ); |
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()); |
76 | } |
77 | |