]>
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" | |
1de7afc9 | 17 | #include "qemu/sockets.h" |
caf71f86 | 18 | #include "migration/migration.h" |
83c9089e | 19 | #include "monitor/monitor.h" |
557ec5a0 | 20 | #include "migration/qemu-file.h" |
737e150e | 21 | #include "block/block.h" |
5ac1fad3 PB |
22 | |
23 | //#define DEBUG_MIGRATION_FD | |
24 | ||
25 | #ifdef DEBUG_MIGRATION_FD | |
d0f2c4c6 | 26 | #define DPRINTF(fmt, ...) \ |
5ac1fad3 PB |
27 | do { printf("migration-fd: " fmt, ## __VA_ARGS__); } while (0) |
28 | #else | |
d0f2c4c6 | 29 | #define DPRINTF(fmt, ...) \ |
5ac1fad3 PB |
30 | do { } while (0) |
31 | #endif | |
32 | ||
f37afb5a | 33 | void fd_start_outgoing_migration(MigrationState *s, const char *fdname, Error **errp) |
5ac1fad3 | 34 | { |
f8bbc128 PB |
35 | int fd = monitor_get_fd(cur_mon, fdname, errp); |
36 | if (fd == -1) { | |
f37afb5a | 37 | return; |
5ac1fad3 | 38 | } |
b352365f | 39 | s->file = qemu_fdopen(fd, "wb"); |
5ac1fad3 | 40 | |
5ac1fad3 | 41 | migrate_fd_connect(s); |
5ac1fad3 PB |
42 | } |
43 | ||
44 | static void fd_accept_incoming_migration(void *opaque) | |
45 | { | |
46 | QEMUFile *f = opaque; | |
5ac1fad3 | 47 | |
d263a20b | 48 | qemu_set_fd_handler2(qemu_get_fd(f), NULL, NULL, NULL, NULL); |
a6ef2909 | 49 | process_incoming_migration(f); |
5ac1fad3 PB |
50 | } |
51 | ||
43eaae28 | 52 | void fd_start_incoming_migration(const char *infd, Error **errp) |
5ac1fad3 PB |
53 | { |
54 | int fd; | |
55 | QEMUFile *f; | |
56 | ||
d0f2c4c6 | 57 | DPRINTF("Attempting to start an incoming migration via fd\n"); |
5ac1fad3 PB |
58 | |
59 | fd = strtol(infd, NULL, 0); | |
60 | f = qemu_fdopen(fd, "rb"); | |
61 | if(f == NULL) { | |
43eaae28 PB |
62 | error_setg_errno(errp, errno, "failed to open the source descriptor"); |
63 | return; | |
5ac1fad3 PB |
64 | } |
65 | ||
1c39e2a2 | 66 | qemu_set_fd_handler2(fd, NULL, fd_accept_incoming_migration, NULL, f); |
5ac1fad3 | 67 | } |