root / migration-unix.c @ 058f8f16
History | View | Annotate | Download (4.4 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 | 4951f65b | Chris Lalancette | #include "qemu_socket.h" |
18 | 4951f65b | Chris Lalancette | #include "migration.h" |
19 | 4951f65b | Chris Lalancette | #include "qemu-char.h" |
20 | 4951f65b | Chris Lalancette | #include "buffered_file.h" |
21 | 4951f65b | Chris Lalancette | #include "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 | 22f00a44 | Juan Quintela | static int unix_errno(MigrationState *s) |
34 | 4951f65b | Chris Lalancette | { |
35 | 4951f65b | Chris Lalancette | return errno;
|
36 | 4951f65b | Chris Lalancette | } |
37 | 4951f65b | Chris Lalancette | |
38 | 22f00a44 | Juan Quintela | static int unix_write(MigrationState *s, const void * buf, size_t size) |
39 | 4951f65b | Chris Lalancette | { |
40 | 4951f65b | Chris Lalancette | return write(s->fd, buf, size);
|
41 | 4951f65b | Chris Lalancette | } |
42 | 4951f65b | Chris Lalancette | |
43 | 22f00a44 | Juan Quintela | static int unix_close(MigrationState *s) |
44 | 4951f65b | Chris Lalancette | { |
45 | 8160bfbc | Eduardo Habkost | int r = 0; |
46 | d0f2c4c6 | malc | DPRINTF("unix_close\n");
|
47 | 4951f65b | Chris Lalancette | if (s->fd != -1) { |
48 | 8160bfbc | Eduardo Habkost | if (close(s->fd) < 0) { |
49 | 8160bfbc | Eduardo Habkost | r = -errno; |
50 | 8160bfbc | Eduardo Habkost | } |
51 | 4951f65b | Chris Lalancette | s->fd = -1;
|
52 | 4951f65b | Chris Lalancette | } |
53 | 8160bfbc | Eduardo Habkost | return r;
|
54 | 4951f65b | Chris Lalancette | } |
55 | 4951f65b | Chris Lalancette | |
56 | 4951f65b | Chris Lalancette | static void unix_wait_for_connect(void *opaque) |
57 | 4951f65b | Chris Lalancette | { |
58 | 22f00a44 | Juan Quintela | MigrationState *s = opaque; |
59 | 4951f65b | Chris Lalancette | int val, ret;
|
60 | 4951f65b | Chris Lalancette | socklen_t valsize = sizeof(val);
|
61 | 4951f65b | Chris Lalancette | |
62 | d0f2c4c6 | malc | DPRINTF("connect completed\n");
|
63 | 4951f65b | Chris Lalancette | do {
|
64 | 4951f65b | Chris Lalancette | ret = getsockopt(s->fd, SOL_SOCKET, SO_ERROR, (void *) &val, &valsize);
|
65 | efab4718 | Juan Quintela | } while (ret == -1 && errno == EINTR); |
66 | 4951f65b | Chris Lalancette | |
67 | 4951f65b | Chris Lalancette | if (ret < 0) { |
68 | 4951f65b | Chris Lalancette | migrate_fd_error(s); |
69 | 4951f65b | Chris Lalancette | return;
|
70 | 4951f65b | Chris Lalancette | } |
71 | 4951f65b | Chris Lalancette | |
72 | 4951f65b | Chris Lalancette | qemu_set_fd_handler2(s->fd, NULL, NULL, NULL, NULL); |
73 | 4951f65b | Chris Lalancette | |
74 | 4951f65b | Chris Lalancette | if (val == 0) |
75 | 4951f65b | Chris Lalancette | migrate_fd_connect(s); |
76 | 4951f65b | Chris Lalancette | else {
|
77 | d0f2c4c6 | malc | DPRINTF("error connecting %d\n", val);
|
78 | 4951f65b | Chris Lalancette | migrate_fd_error(s); |
79 | 4951f65b | Chris Lalancette | } |
80 | 4951f65b | Chris Lalancette | } |
81 | 4951f65b | Chris Lalancette | |
82 | 07af4452 | Juan Quintela | int unix_start_outgoing_migration(MigrationState *s, const char *path) |
83 | 4951f65b | Chris Lalancette | { |
84 | 4951f65b | Chris Lalancette | struct sockaddr_un addr;
|
85 | 4951f65b | Chris Lalancette | int ret;
|
86 | 4951f65b | Chris Lalancette | |
87 | 4951f65b | Chris Lalancette | addr.sun_family = AF_UNIX; |
88 | 4951f65b | Chris Lalancette | snprintf(addr.sun_path, sizeof(addr.sun_path), "%s", path); |
89 | 4951f65b | Chris Lalancette | s->get_error = unix_errno; |
90 | 4951f65b | Chris Lalancette | s->write = unix_write; |
91 | 4951f65b | Chris Lalancette | s->close = unix_close; |
92 | 4951f65b | Chris Lalancette | |
93 | 40ff6d7e | Kevin Wolf | s->fd = qemu_socket(PF_UNIX, SOCK_STREAM, 0);
|
94 | ee86c61f | Juan Quintela | if (s->fd == -1) { |
95 | d0f2c4c6 | malc | DPRINTF("Unable to open socket");
|
96 | 8414ff3b | Juan Quintela | return -errno;
|
97 | 4951f65b | Chris Lalancette | } |
98 | 4951f65b | Chris Lalancette | |
99 | 4951f65b | Chris Lalancette | socket_set_nonblock(s->fd); |
100 | 4951f65b | Chris Lalancette | |
101 | 4951f65b | Chris Lalancette | do {
|
102 | 4951f65b | Chris Lalancette | ret = connect(s->fd, (struct sockaddr *)&addr, sizeof(addr)); |
103 | 8414ff3b | Juan Quintela | if (ret == -1) { |
104 | efab4718 | Juan Quintela | ret = -errno; |
105 | 8414ff3b | Juan Quintela | } |
106 | 8414ff3b | Juan Quintela | if (ret == -EINPROGRESS || ret == -EWOULDBLOCK) {
|
107 | 4951f65b | Chris Lalancette | qemu_set_fd_handler2(s->fd, NULL, NULL, unix_wait_for_connect, s); |
108 | 8414ff3b | Juan Quintela | return 0; |
109 | 8414ff3b | Juan Quintela | } |
110 | 4951f65b | Chris Lalancette | } while (ret == -EINTR);
|
111 | 4951f65b | Chris Lalancette | |
112 | 8414ff3b | Juan Quintela | if (ret < 0) { |
113 | d0f2c4c6 | malc | DPRINTF("connect failed\n");
|
114 | 8414ff3b | Juan Quintela | migrate_fd_error(s); |
115 | 8414ff3b | Juan Quintela | return ret;
|
116 | 2dd650e5 | Daniel P. Berrange | } |
117 | 8414ff3b | Juan Quintela | migrate_fd_connect(s); |
118 | 07af4452 | Juan Quintela | return 0; |
119 | 4951f65b | Chris Lalancette | } |
120 | 4951f65b | Chris Lalancette | |
121 | 4951f65b | Chris Lalancette | static void unix_accept_incoming_migration(void *opaque) |
122 | 4951f65b | Chris Lalancette | { |
123 | 4951f65b | Chris Lalancette | struct sockaddr_un addr;
|
124 | 4951f65b | Chris Lalancette | socklen_t addrlen = sizeof(addr);
|
125 | e0efb993 | Stefan Weil | int s = (intptr_t)opaque;
|
126 | 4951f65b | Chris Lalancette | QEMUFile *f; |
127 | 511c0231 | Juan Quintela | int c;
|
128 | 4951f65b | Chris Lalancette | |
129 | 4951f65b | Chris Lalancette | do {
|
130 | 40ff6d7e | Kevin Wolf | c = qemu_accept(s, (struct sockaddr *)&addr, &addrlen);
|
131 | efab4718 | Juan Quintela | } while (c == -1 && errno == EINTR); |
132 | 4951f65b | Chris Lalancette | |
133 | d0f2c4c6 | malc | DPRINTF("accepted migration\n");
|
134 | 4951f65b | Chris Lalancette | |
135 | 4951f65b | Chris Lalancette | if (c == -1) { |
136 | 4951f65b | Chris Lalancette | fprintf(stderr, "could not accept migration connection\n");
|
137 | ee86c61f | Juan Quintela | goto out2;
|
138 | 4951f65b | Chris Lalancette | } |
139 | 4951f65b | Chris Lalancette | |
140 | 4951f65b | Chris Lalancette | f = qemu_fopen_socket(c); |
141 | 4951f65b | Chris Lalancette | if (f == NULL) { |
142 | 4951f65b | Chris Lalancette | fprintf(stderr, "could not qemu_fopen socket\n");
|
143 | 4951f65b | Chris Lalancette | goto out;
|
144 | 4951f65b | Chris Lalancette | } |
145 | 4951f65b | Chris Lalancette | |
146 | 511c0231 | Juan Quintela | process_incoming_migration(f); |
147 | 4951f65b | Chris Lalancette | qemu_fclose(f); |
148 | 4951f65b | Chris Lalancette | out:
|
149 | ee86c61f | Juan Quintela | close(c); |
150 | ee86c61f | Juan Quintela | out2:
|
151 | cfaf6d36 | Juan Quintela | qemu_set_fd_handler2(s, NULL, NULL, NULL, NULL); |
152 | cfaf6d36 | Juan Quintela | close(s); |
153 | 4951f65b | Chris Lalancette | } |
154 | 4951f65b | Chris Lalancette | |
155 | 4951f65b | Chris Lalancette | int unix_start_incoming_migration(const char *path) |
156 | 4951f65b | Chris Lalancette | { |
157 | ee86c61f | Juan Quintela | struct sockaddr_un addr;
|
158 | ee86c61f | Juan Quintela | int s;
|
159 | ee86c61f | Juan Quintela | int ret;
|
160 | 4951f65b | Chris Lalancette | |
161 | d0f2c4c6 | malc | DPRINTF("Attempting to start an incoming migration\n");
|
162 | 4951f65b | Chris Lalancette | |
163 | ee86c61f | Juan Quintela | s = qemu_socket(PF_UNIX, SOCK_STREAM, 0);
|
164 | ee86c61f | Juan Quintela | if (s == -1) { |
165 | 4951f65b | Chris Lalancette | fprintf(stderr, "Could not open unix socket: %s\n", strerror(errno));
|
166 | ee86c61f | Juan Quintela | return -errno;
|
167 | 4951f65b | Chris Lalancette | } |
168 | 4951f65b | Chris Lalancette | |
169 | ee86c61f | Juan Quintela | memset(&addr, 0, sizeof(addr)); |
170 | ee86c61f | Juan Quintela | addr.sun_family = AF_UNIX; |
171 | ee86c61f | Juan Quintela | snprintf(addr.sun_path, sizeof(addr.sun_path), "%s", path); |
172 | 4951f65b | Chris Lalancette | |
173 | ee86c61f | Juan Quintela | unlink(addr.sun_path); |
174 | ee86c61f | Juan Quintela | if (bind(s, (struct sockaddr *) &addr, sizeof(addr)) < 0) { |
175 | ee86c61f | Juan Quintela | ret = -errno; |
176 | ee86c61f | Juan Quintela | fprintf(stderr, "bind(unix:%s): %s\n", addr.sun_path, strerror(errno));
|
177 | 4951f65b | Chris Lalancette | goto err;
|
178 | 4951f65b | Chris Lalancette | } |
179 | ee86c61f | Juan Quintela | if (listen(s, 1) == -1) { |
180 | ee86c61f | Juan Quintela | fprintf(stderr, "listen(unix:%s): %s\n", addr.sun_path,
|
181 | ee86c61f | Juan Quintela | strerror(errno)); |
182 | ee86c61f | Juan Quintela | ret = -errno; |
183 | 4951f65b | Chris Lalancette | goto err;
|
184 | 4951f65b | Chris Lalancette | } |
185 | 4951f65b | Chris Lalancette | |
186 | ee86c61f | Juan Quintela | qemu_set_fd_handler2(s, NULL, unix_accept_incoming_migration, NULL, |
187 | ee86c61f | Juan Quintela | (void *)(intptr_t)s);
|
188 | 4951f65b | Chris Lalancette | |
189 | 4951f65b | Chris Lalancette | return 0; |
190 | 4951f65b | Chris Lalancette | |
191 | 4951f65b | Chris Lalancette | err:
|
192 | ee86c61f | Juan Quintela | close(s); |
193 | ee86c61f | Juan Quintela | return ret;
|
194 | 4951f65b | Chris Lalancette | } |