root / migration-unix.c @ 067404be
History | View | Annotate | Download (2.3 kB)
1 | 4951f65b | Chris Lalancette | /*
|
---|---|---|---|
2 | 4951f65b | Chris Lalancette | * QEMU live migration via Unix Domain Sockets
|
3 | 4951f65b | Chris Lalancette | *
|
4 | 4951f65b | Chris Lalancette | * Copyright Red Hat, Inc. 2009
|
5 | 4951f65b | Chris Lalancette | *
|
6 | 4951f65b | Chris Lalancette | * Authors:
|
7 | 4951f65b | Chris Lalancette | * Chris Lalancette <clalance@redhat.com>
|
8 | 4951f65b | Chris Lalancette | *
|
9 | 4951f65b | Chris Lalancette | * This work is licensed under the terms of the GNU GPL, version 2. See
|
10 | 4951f65b | Chris Lalancette | * the COPYING file in the top-level directory.
|
11 | 4951f65b | Chris Lalancette | *
|
12 | 6b620ca3 | Paolo Bonzini | * Contributions after 2012-01-13 are licensed under the terms of the
|
13 | 6b620ca3 | Paolo Bonzini | * GNU GPL, version 2 or (at your option) any later version.
|
14 | 4951f65b | Chris Lalancette | */
|
15 | 4951f65b | Chris Lalancette | |
16 | 4951f65b | Chris Lalancette | #include "qemu-common.h" |
17 | 1de7afc9 | Paolo Bonzini | #include "qemu/sockets.h" |
18 | 6a1751b7 | Alex Bligh | #include "qemu/main-loop.h" |
19 | caf71f86 | Paolo Bonzini | #include "migration/migration.h" |
20 | 557ec5a0 | Juan Quintela | #include "migration/qemu-file.h" |
21 | 737e150e | Paolo Bonzini | #include "block/block.h" |
22 | 4951f65b | Chris Lalancette | |
23 | 4951f65b | Chris Lalancette | //#define DEBUG_MIGRATION_UNIX
|
24 | 4951f65b | Chris Lalancette | |
25 | 4951f65b | Chris Lalancette | #ifdef DEBUG_MIGRATION_UNIX
|
26 | d0f2c4c6 | malc | #define DPRINTF(fmt, ...) \
|
27 | 4951f65b | Chris Lalancette | do { printf("migration-unix: " fmt, ## __VA_ARGS__); } while (0) |
28 | 4951f65b | Chris Lalancette | #else
|
29 | d0f2c4c6 | malc | #define DPRINTF(fmt, ...) \
|
30 | 4951f65b | Chris Lalancette | do { } while (0) |
31 | 4951f65b | Chris Lalancette | #endif
|
32 | 4951f65b | Chris Lalancette | |
33 | e08c95ce | Paolo Bonzini | static void unix_wait_for_connect(int fd, void *opaque) |
34 | 4951f65b | Chris Lalancette | { |
35 | 22f00a44 | Juan Quintela | MigrationState *s = opaque; |
36 | 4951f65b | Chris Lalancette | |
37 | e08c95ce | Paolo Bonzini | if (fd < 0) { |
38 | e08c95ce | Paolo Bonzini | DPRINTF("migrate connect error\n");
|
39 | b352365f | Paolo Bonzini | s->file = NULL;
|
40 | 4951f65b | Chris Lalancette | migrate_fd_error(s); |
41 | e08c95ce | Paolo Bonzini | } else {
|
42 | e08c95ce | Paolo Bonzini | DPRINTF("migrate connect success\n");
|
43 | b352365f | Paolo Bonzini | s->file = qemu_fopen_socket(fd, "wb");
|
44 | 4951f65b | Chris Lalancette | migrate_fd_connect(s); |
45 | 4951f65b | Chris Lalancette | } |
46 | 4951f65b | Chris Lalancette | } |
47 | 4951f65b | Chris Lalancette | |
48 | f37afb5a | Paolo Bonzini | void unix_start_outgoing_migration(MigrationState *s, const char *path, Error **errp) |
49 | 4951f65b | Chris Lalancette | { |
50 | f8bbc128 | Paolo Bonzini | unix_nonblocking_connect(path, unix_wait_for_connect, s, errp); |
51 | 4951f65b | Chris Lalancette | } |
52 | 4951f65b | Chris Lalancette | |
53 | 4951f65b | Chris Lalancette | static void unix_accept_incoming_migration(void *opaque) |
54 | 4951f65b | Chris Lalancette | { |
55 | 4951f65b | Chris Lalancette | struct sockaddr_un addr;
|
56 | 4951f65b | Chris Lalancette | socklen_t addrlen = sizeof(addr);
|
57 | e0efb993 | Stefan Weil | int s = (intptr_t)opaque;
|
58 | 4951f65b | Chris Lalancette | QEMUFile *f; |
59 | 511c0231 | Juan Quintela | int c;
|
60 | 4951f65b | Chris Lalancette | |
61 | 4951f65b | Chris Lalancette | do {
|
62 | 40ff6d7e | Kevin Wolf | c = qemu_accept(s, (struct sockaddr *)&addr, &addrlen);
|
63 | efab4718 | Juan Quintela | } while (c == -1 && errno == EINTR); |
64 | a6ef2909 | Paolo Bonzini | qemu_set_fd_handler2(s, NULL, NULL, NULL, NULL); |
65 | a6ef2909 | Paolo Bonzini | close(s); |
66 | 4951f65b | Chris Lalancette | |
67 | d0f2c4c6 | malc | DPRINTF("accepted migration\n");
|
68 | 4951f65b | Chris Lalancette | |
69 | 4951f65b | Chris Lalancette | if (c == -1) { |
70 | 4951f65b | Chris Lalancette | fprintf(stderr, "could not accept migration connection\n");
|
71 | a6ef2909 | Paolo Bonzini | goto out;
|
72 | 4951f65b | Chris Lalancette | } |
73 | 4951f65b | Chris Lalancette | |
74 | 0cc3f3cc | Paolo Bonzini | f = qemu_fopen_socket(c, "rb");
|
75 | 4951f65b | Chris Lalancette | if (f == NULL) { |
76 | 4951f65b | Chris Lalancette | fprintf(stderr, "could not qemu_fopen socket\n");
|
77 | 4951f65b | Chris Lalancette | goto out;
|
78 | 4951f65b | Chris Lalancette | } |
79 | 4951f65b | Chris Lalancette | |
80 | 511c0231 | Juan Quintela | process_incoming_migration(f); |
81 | ab52a824 | Paolo Bonzini | return;
|
82 | ab52a824 | Paolo Bonzini | |
83 | 4951f65b | Chris Lalancette | out:
|
84 | ee86c61f | Juan Quintela | close(c); |
85 | 4951f65b | Chris Lalancette | } |
86 | 4951f65b | Chris Lalancette | |
87 | 43eaae28 | Paolo Bonzini | void unix_start_incoming_migration(const char *path, Error **errp) |
88 | 4951f65b | Chris Lalancette | { |
89 | ee86c61f | Juan Quintela | int s;
|
90 | 4951f65b | Chris Lalancette | |
91 | e08c95ce | Paolo Bonzini | s = unix_listen(path, NULL, 0, errp); |
92 | e08c95ce | Paolo Bonzini | if (s < 0) { |
93 | 43eaae28 | Paolo Bonzini | return;
|
94 | 4951f65b | Chris Lalancette | } |
95 | 4951f65b | Chris Lalancette | |
96 | ee86c61f | Juan Quintela | qemu_set_fd_handler2(s, NULL, unix_accept_incoming_migration, NULL, |
97 | ee86c61f | Juan Quintela | (void *)(intptr_t)s);
|
98 | 4951f65b | Chris Lalancette | } |