]>
Commit | Line | Data |
---|---|---|
5ac1fad3 PB |
1 | /* |
2 | * QEMU live migration via generic fd | |
3 | * | |
4 | * Copyright Red Hat, Inc. 2009 | |
5 | * | |
6 | * Authors: | |
7 | * Chris Lalancette <[email protected]> | |
8 | * | |
9 | * This work is licensed under the terms of the GNU GPL, version 2. See | |
10 | * the COPYING file in the top-level directory. | |
11 | * | |
6b620ca3 PB |
12 | * Contributions after 2012-01-13 are licensed under the terms of the |
13 | * GNU GPL, version 2 or (at your option) any later version. | |
5ac1fad3 PB |
14 | */ |
15 | ||
16 | #include "qemu-common.h" | |
6a1751b7 | 17 | #include "qemu/main-loop.h" |
1de7afc9 | 18 | #include "qemu/sockets.h" |
caf71f86 | 19 | #include "migration/migration.h" |
83c9089e | 20 | #include "monitor/monitor.h" |
557ec5a0 | 21 | #include "migration/qemu-file.h" |
737e150e | 22 | #include "block/block.h" |
5ac1fad3 PB |
23 | |
24 | //#define DEBUG_MIGRATION_FD | |
25 | ||
26 | #ifdef DEBUG_MIGRATION_FD | |
d0f2c4c6 | 27 | #define DPRINTF(fmt, ...) \ |
5ac1fad3 PB |
28 | do { printf("migration-fd: " fmt, ## __VA_ARGS__); } while (0) |
29 | #else | |
d0f2c4c6 | 30 | #define DPRINTF(fmt, ...) \ |
5ac1fad3 PB |
31 | do { } while (0) |
32 | #endif | |
33 | ||
f37afb5a | 34 | void fd_start_outgoing_migration(MigrationState *s, const char *fdname, Error **errp) |
5ac1fad3 | 35 | { |
f8bbc128 PB |
36 | int fd = monitor_get_fd(cur_mon, fdname, errp); |
37 | if (fd == -1) { | |
f37afb5a | 38 | return; |
5ac1fad3 | 39 | } |
b352365f | 40 | s->file = qemu_fdopen(fd, "wb"); |
5ac1fad3 | 41 | |
5ac1fad3 | 42 | migrate_fd_connect(s); |
5ac1fad3 PB |
43 | } |
44 | ||
45 | static void fd_accept_incoming_migration(void *opaque) | |
46 | { | |
47 | QEMUFile *f = opaque; | |
5ac1fad3 | 48 | |
d263a20b | 49 | qemu_set_fd_handler2(qemu_get_fd(f), NULL, NULL, NULL, NULL); |
a6ef2909 | 50 | process_incoming_migration(f); |
5ac1fad3 PB |
51 | } |
52 | ||
43eaae28 | 53 | void fd_start_incoming_migration(const char *infd, Error **errp) |
5ac1fad3 PB |
54 | { |
55 | int fd; | |
56 | QEMUFile *f; | |
57 | ||
d0f2c4c6 | 58 | DPRINTF("Attempting to start an incoming migration via fd\n"); |
5ac1fad3 PB |
59 | |
60 | fd = strtol(infd, NULL, 0); | |
61 | f = qemu_fdopen(fd, "rb"); | |
62 | if(f == NULL) { | |
43eaae28 PB |
63 | error_setg_errno(errp, errno, "failed to open the source descriptor"); |
64 | return; | |
5ac1fad3 PB |
65 | } |
66 | ||
1c39e2a2 | 67 | qemu_set_fd_handler2(fd, NULL, fd_accept_incoming_migration, NULL, f); |
5ac1fad3 | 68 | } |