Merge remote-tracking branch 'remotes/mst/tags/for_upstream' into staging
[qemu.git] / migration / fd.c
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 }