]> git.proxmox.com Git - mirror_qemu.git/blame - migration/fd.c
ivshmem: Fix 64 bit memory bar configuration
[mirror_qemu.git] / migration / fd.c
CommitLineData
5ac1fad3
PB
1/*
2 * QEMU live migration via generic fd
3 *
64802ee5 4 * Copyright Red Hat, Inc. 2009-2016
5ac1fad3
PB
5 *
6 * Authors:
7 * Chris Lalancette <clalance@redhat.com>
64802ee5 8 * Daniel P. Berrange <berrange@redhat.com>
5ac1fad3
PB
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 *
6b620ca3
PB
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.
5ac1fad3
PB
15 */
16
1393a485 17#include "qemu/osdep.h"
da34e65c 18#include "qapi/error.h"
5ac1fad3 19#include "qemu-common.h"
caf71f86 20#include "migration/migration.h"
83c9089e 21#include "monitor/monitor.h"
64802ee5
DB
22#include "io/channel-util.h"
23#include "trace.h"
5ac1fad3 24
131fe9b8 25
f37afb5a 26void fd_start_outgoing_migration(MigrationState *s, const char *fdname, Error **errp)
5ac1fad3 27{
64802ee5 28 QIOChannel *ioc;
f8bbc128
PB
29 int fd = monitor_get_fd(cur_mon, fdname, errp);
30 if (fd == -1) {
f37afb5a 31 return;
5ac1fad3 32 }
131fe9b8 33
64802ee5
DB
34 trace_migration_fd_outgoing(fd);
35 ioc = qio_channel_new_fd(fd, errp);
36 if (!ioc) {
37 close(fd);
38 return;
131fe9b8 39 }
5ac1fad3 40
22724f49 41 migration_channel_connect(s, ioc, NULL);
64802ee5 42 object_unref(OBJECT(ioc));
5ac1fad3
PB
43}
44
64802ee5
DB
45static gboolean fd_accept_incoming_migration(QIOChannel *ioc,
46 GIOCondition condition,
47 gpointer opaque)
5ac1fad3 48{
22724f49 49 migration_channel_process_incoming(migrate_get_current(), ioc);
64802ee5
DB
50 object_unref(OBJECT(ioc));
51 return FALSE; /* unregister */
5ac1fad3
PB
52}
53
43eaae28 54void fd_start_incoming_migration(const char *infd, Error **errp)
5ac1fad3 55{
64802ee5 56 QIOChannel *ioc;
5ac1fad3 57 int fd;
5ac1fad3
PB
58
59 fd = strtol(infd, NULL, 0);
64802ee5
DB
60 trace_migration_fd_incoming(fd);
61
62 ioc = qio_channel_new_fd(fd, errp);
63 if (!ioc) {
64 close(fd);
43eaae28 65 return;
5ac1fad3
PB
66 }
67
64802ee5
DB
68 qio_channel_add_watch(ioc,
69 G_IO_IN,
70 fd_accept_incoming_migration,
71 NULL,
72 NULL);
5ac1fad3 73}