]>
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 <clalance@redhat.com> | |
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 | ||
22f00a44 | 33 | static int fd_errno(MigrationState *s) |
5ac1fad3 PB |
34 | { |
35 | return errno; | |
36 | } | |
37 | ||
22f00a44 | 38 | static int fd_write(MigrationState *s, const void * buf, size_t size) |
5ac1fad3 PB |
39 | { |
40 | return write(s->fd, buf, size); | |
41 | } | |
42 | ||
f37afb5a | 43 | void fd_start_outgoing_migration(MigrationState *s, const char *fdname, Error **errp) |
5ac1fad3 | 44 | { |
f8bbc128 PB |
45 | int fd = monitor_get_fd(cur_mon, fdname, errp); |
46 | if (fd == -1) { | |
f37afb5a | 47 | return; |
5ac1fad3 | 48 | } |
f8bbc128 | 49 | s->migration_file = qemu_fdopen(fd, "wb"); |
5ac1fad3 PB |
50 | |
51 | s->get_error = fd_errno; | |
52 | s->write = fd_write; | |
5ac1fad3 | 53 | migrate_fd_connect(s); |
5ac1fad3 PB |
54 | } |
55 | ||
56 | static void fd_accept_incoming_migration(void *opaque) | |
57 | { | |
58 | QEMUFile *f = opaque; | |
5ac1fad3 | 59 | |
d263a20b | 60 | qemu_set_fd_handler2(qemu_get_fd(f), NULL, NULL, NULL, NULL); |
a6ef2909 | 61 | process_incoming_migration(f); |
5ac1fad3 PB |
62 | } |
63 | ||
43eaae28 | 64 | void fd_start_incoming_migration(const char *infd, Error **errp) |
5ac1fad3 PB |
65 | { |
66 | int fd; | |
67 | QEMUFile *f; | |
68 | ||
d0f2c4c6 | 69 | DPRINTF("Attempting to start an incoming migration via fd\n"); |
5ac1fad3 PB |
70 | |
71 | fd = strtol(infd, NULL, 0); | |
72 | f = qemu_fdopen(fd, "rb"); | |
73 | if(f == NULL) { | |
43eaae28 PB |
74 | error_setg_errno(errp, errno, "failed to open the source descriptor"); |
75 | return; | |
5ac1fad3 PB |
76 | } |
77 | ||
1c39e2a2 | 78 | qemu_set_fd_handler2(fd, NULL, fd_accept_incoming_migration, NULL, f); |
5ac1fad3 | 79 | } |