]> git.proxmox.com Git - mirror_qemu.git/blame - migration-unix.c
pseries: Fix qdev.id handling in the VIO bus code
[mirror_qemu.git] / migration-unix.c
CommitLineData
4951f65b
CL
1/*
2 * QEMU live migration via Unix Domain Sockets
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 *
12 */
13
14#include "qemu-common.h"
15#include "qemu_socket.h"
16#include "migration.h"
17#include "qemu-char.h"
4951f65b
CL
18#include "buffered_file.h"
19#include "block.h"
20
21//#define DEBUG_MIGRATION_UNIX
22
23#ifdef DEBUG_MIGRATION_UNIX
d0f2c4c6 24#define DPRINTF(fmt, ...) \
4951f65b
CL
25 do { printf("migration-unix: " fmt, ## __VA_ARGS__); } while (0)
26#else
d0f2c4c6 27#define DPRINTF(fmt, ...) \
4951f65b
CL
28 do { } while (0)
29#endif
30
22f00a44 31static int unix_errno(MigrationState *s)
4951f65b
CL
32{
33 return errno;
34}
35
22f00a44 36static int unix_write(MigrationState *s, const void * buf, size_t size)
4951f65b
CL
37{
38 return write(s->fd, buf, size);
39}
40
22f00a44 41static int unix_close(MigrationState *s)
4951f65b 42{
d0f2c4c6 43 DPRINTF("unix_close\n");
4951f65b
CL
44 if (s->fd != -1) {
45 close(s->fd);
46 s->fd = -1;
47 }
48 return 0;
49}
50
51static void unix_wait_for_connect(void *opaque)
52{
22f00a44 53 MigrationState *s = opaque;
4951f65b
CL
54 int val, ret;
55 socklen_t valsize = sizeof(val);
56
d0f2c4c6 57 DPRINTF("connect completed\n");
4951f65b
CL
58 do {
59 ret = getsockopt(s->fd, SOL_SOCKET, SO_ERROR, (void *) &val, &valsize);
efab4718 60 } while (ret == -1 && errno == EINTR);
4951f65b
CL
61
62 if (ret < 0) {
63 migrate_fd_error(s);
64 return;
65 }
66
67 qemu_set_fd_handler2(s->fd, NULL, NULL, NULL, NULL);
68
69 if (val == 0)
70 migrate_fd_connect(s);
71 else {
d0f2c4c6 72 DPRINTF("error connecting %d\n", val);
4951f65b
CL
73 migrate_fd_error(s);
74 }
75}
76
07af4452 77int unix_start_outgoing_migration(MigrationState *s, const char *path)
4951f65b 78{
4951f65b
CL
79 struct sockaddr_un addr;
80 int ret;
81
82 addr.sun_family = AF_UNIX;
83 snprintf(addr.sun_path, sizeof(addr.sun_path), "%s", path);
4951f65b
CL
84 s->get_error = unix_errno;
85 s->write = unix_write;
86 s->close = unix_close;
4951f65b 87
40ff6d7e 88 s->fd = qemu_socket(PF_UNIX, SOCK_STREAM, 0);
ee86c61f 89 if (s->fd == -1) {
d0f2c4c6 90 DPRINTF("Unable to open socket");
8414ff3b 91 return -errno;
4951f65b
CL
92 }
93
94 socket_set_nonblock(s->fd);
95
4951f65b
CL
96 do {
97 ret = connect(s->fd, (struct sockaddr *)&addr, sizeof(addr));
8414ff3b 98 if (ret == -1) {
efab4718 99 ret = -errno;
8414ff3b
JQ
100 }
101 if (ret == -EINPROGRESS || ret == -EWOULDBLOCK) {
4951f65b 102 qemu_set_fd_handler2(s->fd, NULL, NULL, unix_wait_for_connect, s);
8414ff3b
JQ
103 return 0;
104 }
4951f65b
CL
105 } while (ret == -EINTR);
106
8414ff3b 107 if (ret < 0) {
d0f2c4c6 108 DPRINTF("connect failed\n");
8414ff3b
JQ
109 migrate_fd_error(s);
110 return ret;
2dd650e5 111 }
8414ff3b 112 migrate_fd_connect(s);
07af4452 113 return 0;
4951f65b
CL
114}
115
116static void unix_accept_incoming_migration(void *opaque)
117{
118 struct sockaddr_un addr;
119 socklen_t addrlen = sizeof(addr);
e0efb993 120 int s = (intptr_t)opaque;
4951f65b 121 QEMUFile *f;
511c0231 122 int c;
4951f65b
CL
123
124 do {
40ff6d7e 125 c = qemu_accept(s, (struct sockaddr *)&addr, &addrlen);
efab4718 126 } while (c == -1 && errno == EINTR);
4951f65b 127
d0f2c4c6 128 DPRINTF("accepted migration\n");
4951f65b
CL
129
130 if (c == -1) {
131 fprintf(stderr, "could not accept migration connection\n");
ee86c61f 132 goto out2;
4951f65b
CL
133 }
134
135 f = qemu_fopen_socket(c);
136 if (f == NULL) {
137 fprintf(stderr, "could not qemu_fopen socket\n");
138 goto out;
139 }
140
511c0231 141 process_incoming_migration(f);
4951f65b
CL
142 qemu_fclose(f);
143out:
ee86c61f
JQ
144 close(c);
145out2:
cfaf6d36
JQ
146 qemu_set_fd_handler2(s, NULL, NULL, NULL, NULL);
147 close(s);
4951f65b
CL
148}
149
150int unix_start_incoming_migration(const char *path)
151{
ee86c61f
JQ
152 struct sockaddr_un addr;
153 int s;
154 int ret;
4951f65b 155
d0f2c4c6 156 DPRINTF("Attempting to start an incoming migration\n");
4951f65b 157
ee86c61f
JQ
158 s = qemu_socket(PF_UNIX, SOCK_STREAM, 0);
159 if (s == -1) {
4951f65b 160 fprintf(stderr, "Could not open unix socket: %s\n", strerror(errno));
ee86c61f 161 return -errno;
4951f65b
CL
162 }
163
ee86c61f
JQ
164 memset(&addr, 0, sizeof(addr));
165 addr.sun_family = AF_UNIX;
166 snprintf(addr.sun_path, sizeof(addr.sun_path), "%s", path);
4951f65b 167
ee86c61f
JQ
168 unlink(addr.sun_path);
169 if (bind(s, (struct sockaddr *) &addr, sizeof(addr)) < 0) {
170 ret = -errno;
171 fprintf(stderr, "bind(unix:%s): %s\n", addr.sun_path, strerror(errno));
4951f65b
CL
172 goto err;
173 }
ee86c61f
JQ
174 if (listen(s, 1) == -1) {
175 fprintf(stderr, "listen(unix:%s): %s\n", addr.sun_path,
176 strerror(errno));
177 ret = -errno;
4951f65b
CL
178 goto err;
179 }
180
ee86c61f
JQ
181 qemu_set_fd_handler2(s, NULL, unix_accept_incoming_migration, NULL,
182 (void *)(intptr_t)s);
4951f65b
CL
183
184 return 0;
185
186err:
ee86c61f
JQ
187 close(s);
188 return ret;
4951f65b 189}