2 * QEMU live migration via generic fd
4 * Copyright Red Hat, Inc. 2009
7 * Chris Lalancette <clalance@redhat.com>
9 * This work is licensed under the terms of the GNU GPL, version 2. See
10 * the COPYING file in the top-level directory.
14 #include "qemu-common.h"
15 #include "qemu_socket.h"
16 #include "migration.h"
18 #include "qemu-char.h"
19 #include "buffered_file.h"
21 #include "qemu_socket.h"
23 //#define DEBUG_MIGRATION_FD
25 #ifdef DEBUG_MIGRATION_FD
26 #define DPRINTF(fmt, ...) \
27 do { printf("migration-fd: " fmt, ## __VA_ARGS__); } while (0)
29 #define DPRINTF(fmt, ...) \
33 static int fd_errno(MigrationState
*s
)
38 static int fd_write(MigrationState
*s
, const void * buf
, size_t size
)
40 return write(s
->fd
, buf
, size
);
43 static int fd_close(MigrationState
*s
)
45 DPRINTF("fd_close\n");
53 MigrationState
*fd_start_outgoing_migration(Monitor
*mon
,
55 int64_t bandwidth_limit
,
62 s
= migrate_new(mon
, bandwidth_limit
, detach
, blk
, inc
);
64 s
->fd
= monitor_get_fd(mon
, fdname
);
66 DPRINTF("fd_migration: invalid file descriptor identifier\n");
70 if (fcntl(s
->fd
, F_SETFL
, O_NONBLOCK
) == -1) {
71 DPRINTF("Unable to set nonblocking mode on file descriptor\n");
75 s
->get_error
= fd_errno
;
79 migrate_fd_connect(s
);
89 static void fd_accept_incoming_migration(void *opaque
)
93 process_incoming_migration(f
);
94 qemu_set_fd_handler2(qemu_stdio_fd(f
), NULL
, NULL
, NULL
, NULL
);
98 int fd_start_incoming_migration(const char *infd
)
103 DPRINTF("Attempting to start an incoming migration via fd\n");
105 fd
= strtol(infd
, NULL
, 0);
106 f
= qemu_fdopen(fd
, "rb");
108 DPRINTF("Unable to apply qemu wrapper to file descriptor\n");
112 qemu_set_fd_handler2(fd
, NULL
, fd_accept_incoming_migration
, NULL
, f
);