root / migration-tcp.c @ 4144f122
History | View | Annotate | Download (3.3 kB)
1 | 34c9dd8e | aliguori | /*
|
---|---|---|---|
2 | 34c9dd8e | aliguori | * QEMU live migration
|
3 | 34c9dd8e | aliguori | *
|
4 | 34c9dd8e | aliguori | * Copyright IBM, Corp. 2008
|
5 | 34c9dd8e | aliguori | *
|
6 | 34c9dd8e | aliguori | * Authors:
|
7 | 34c9dd8e | aliguori | * Anthony Liguori <aliguori@us.ibm.com>
|
8 | 34c9dd8e | aliguori | *
|
9 | 34c9dd8e | aliguori | * This work is licensed under the terms of the GNU GPL, version 2. See
|
10 | 34c9dd8e | aliguori | * the COPYING file in the top-level directory.
|
11 | 34c9dd8e | aliguori | *
|
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 | 34c9dd8e | aliguori | */
|
15 | 34c9dd8e | aliguori | |
16 | 34c9dd8e | aliguori | #include "qemu-common.h" |
17 | 34c9dd8e | aliguori | #include "qemu_socket.h" |
18 | 34c9dd8e | aliguori | #include "migration.h" |
19 | 34c9dd8e | aliguori | #include "qemu-char.h" |
20 | 34c9dd8e | aliguori | #include "buffered_file.h" |
21 | 34c9dd8e | aliguori | #include "block.h" |
22 | 34c9dd8e | aliguori | |
23 | 34c9dd8e | aliguori | //#define DEBUG_MIGRATION_TCP
|
24 | 34c9dd8e | aliguori | |
25 | 34c9dd8e | aliguori | #ifdef DEBUG_MIGRATION_TCP
|
26 | d0f2c4c6 | malc | #define DPRINTF(fmt, ...) \
|
27 | 34c9dd8e | aliguori | do { printf("migration-tcp: " fmt, ## __VA_ARGS__); } while (0) |
28 | 34c9dd8e | aliguori | #else
|
29 | d0f2c4c6 | malc | #define DPRINTF(fmt, ...) \
|
30 | 34c9dd8e | aliguori | do { } while (0) |
31 | 34c9dd8e | aliguori | #endif
|
32 | 34c9dd8e | aliguori | |
33 | 22f00a44 | Juan Quintela | static int socket_errno(MigrationState *s) |
34 | 34c9dd8e | aliguori | { |
35 | 8ad9fa5d | aliguori | return socket_error();
|
36 | 34c9dd8e | aliguori | } |
37 | 34c9dd8e | aliguori | |
38 | 22f00a44 | Juan Quintela | static int socket_write(MigrationState *s, const void * buf, size_t size) |
39 | 34c9dd8e | aliguori | { |
40 | 065e2813 | aliguori | return send(s->fd, buf, size, 0); |
41 | 34c9dd8e | aliguori | } |
42 | 34c9dd8e | aliguori | |
43 | 22f00a44 | Juan Quintela | static int tcp_close(MigrationState *s) |
44 | 34c9dd8e | aliguori | { |
45 | 61a5872f | Eduardo Habkost | int r = 0; |
46 | d0f2c4c6 | malc | DPRINTF("tcp_close\n");
|
47 | 34c9dd8e | aliguori | if (s->fd != -1) { |
48 | 61a5872f | Eduardo Habkost | if (close(s->fd) < 0) { |
49 | 61a5872f | Eduardo Habkost | r = -errno; |
50 | 61a5872f | Eduardo Habkost | } |
51 | ff8d81d8 | aliguori | s->fd = -1;
|
52 | 34c9dd8e | aliguori | } |
53 | 61a5872f | Eduardo Habkost | return r;
|
54 | 34c9dd8e | aliguori | } |
55 | 34c9dd8e | aliguori | |
56 | 34c9dd8e | aliguori | static void tcp_wait_for_connect(void *opaque) |
57 | 34c9dd8e | aliguori | { |
58 | 22f00a44 | Juan Quintela | MigrationState *s = opaque; |
59 | 34c9dd8e | aliguori | int val, ret;
|
60 | 4761a48b | blueswir1 | socklen_t valsize = sizeof(val);
|
61 | 34c9dd8e | aliguori | |
62 | d0f2c4c6 | malc | DPRINTF("connect completed\n");
|
63 | 34c9dd8e | aliguori | do {
|
64 | 0a656f5f | malc | ret = getsockopt(s->fd, SOL_SOCKET, SO_ERROR, (void *) &val, &valsize);
|
65 | efab4718 | Juan Quintela | } while (ret == -1 && (socket_error()) == EINTR); |
66 | 34c9dd8e | aliguori | |
67 | 34c9dd8e | aliguori | if (ret < 0) { |
68 | 065e2813 | aliguori | migrate_fd_error(s); |
69 | 34c9dd8e | aliguori | return;
|
70 | 34c9dd8e | aliguori | } |
71 | 34c9dd8e | aliguori | |
72 | 34c9dd8e | aliguori | qemu_set_fd_handler2(s->fd, NULL, NULL, NULL, NULL); |
73 | 34c9dd8e | aliguori | |
74 | 34c9dd8e | aliguori | if (val == 0) |
75 | 065e2813 | aliguori | migrate_fd_connect(s); |
76 | 34c9dd8e | aliguori | else {
|
77 | d0f2c4c6 | malc | DPRINTF("error connecting %d\n", val);
|
78 | 065e2813 | aliguori | migrate_fd_error(s); |
79 | 34c9dd8e | aliguori | } |
80 | 34c9dd8e | aliguori | } |
81 | 34c9dd8e | aliguori | |
82 | d5c5dacc | Amos Kong | int tcp_start_outgoing_migration(MigrationState *s, const char *host_port, |
83 | d5c5dacc | Amos Kong | Error **errp) |
84 | 34c9dd8e | aliguori | { |
85 | 540c79fe | Luiz Capitulino | bool in_progress;
|
86 | 540c79fe | Luiz Capitulino | |
87 | 065e2813 | aliguori | s->get_error = socket_errno; |
88 | 065e2813 | aliguori | s->write = socket_write; |
89 | 065e2813 | aliguori | s->close = tcp_close; |
90 | 34c9dd8e | aliguori | |
91 | 540c79fe | Luiz Capitulino | s->fd = inet_connect(host_port, false, &in_progress, errp);
|
92 | 540c79fe | Luiz Capitulino | if (error_is_set(errp)) {
|
93 | 540c79fe | Luiz Capitulino | migrate_fd_error(s); |
94 | 540c79fe | Luiz Capitulino | return -1; |
95 | 540c79fe | Luiz Capitulino | } |
96 | 34c9dd8e | aliguori | |
97 | 540c79fe | Luiz Capitulino | if (in_progress) {
|
98 | d5c5dacc | Amos Kong | DPRINTF("connect in progress\n");
|
99 | d5c5dacc | Amos Kong | qemu_set_fd_handler2(s->fd, NULL, NULL, tcp_wait_for_connect, s); |
100 | d5c5dacc | Amos Kong | } else {
|
101 | 540c79fe | Luiz Capitulino | migrate_fd_connect(s); |
102 | 8414ff3b | Juan Quintela | } |
103 | d5c5dacc | Amos Kong | |
104 | 07af4452 | Juan Quintela | return 0; |
105 | 34c9dd8e | aliguori | } |
106 | 34c9dd8e | aliguori | |
107 | 34c9dd8e | aliguori | static void tcp_accept_incoming_migration(void *opaque) |
108 | 34c9dd8e | aliguori | { |
109 | 34c9dd8e | aliguori | struct sockaddr_in addr;
|
110 | 34c9dd8e | aliguori | socklen_t addrlen = sizeof(addr);
|
111 | e0efb993 | Stefan Weil | int s = (intptr_t)opaque;
|
112 | 34c9dd8e | aliguori | QEMUFile *f; |
113 | 511c0231 | Juan Quintela | int c;
|
114 | 34c9dd8e | aliguori | |
115 | 34c9dd8e | aliguori | do {
|
116 | 40ff6d7e | Kevin Wolf | c = qemu_accept(s, (struct sockaddr *)&addr, &addrlen);
|
117 | c1d36665 | aliguori | } while (c == -1 && socket_error() == EINTR); |
118 | 34c9dd8e | aliguori | |
119 | d0f2c4c6 | malc | DPRINTF("accepted migration\n");
|
120 | 34c9dd8e | aliguori | |
121 | 34c9dd8e | aliguori | if (c == -1) { |
122 | 34c9dd8e | aliguori | fprintf(stderr, "could not accept migration connection\n");
|
123 | d092c108 | Shahar Havivi | goto out2;
|
124 | 34c9dd8e | aliguori | } |
125 | 34c9dd8e | aliguori | |
126 | c1d36665 | aliguori | f = qemu_fopen_socket(c); |
127 | 34c9dd8e | aliguori | if (f == NULL) { |
128 | 34c9dd8e | aliguori | fprintf(stderr, "could not qemu_fopen socket\n");
|
129 | 34c9dd8e | aliguori | goto out;
|
130 | 34c9dd8e | aliguori | } |
131 | 34c9dd8e | aliguori | |
132 | 511c0231 | Juan Quintela | process_incoming_migration(f); |
133 | 34c9dd8e | aliguori | qemu_fclose(f); |
134 | 34c9dd8e | aliguori | out:
|
135 | d092c108 | Shahar Havivi | close(c); |
136 | d092c108 | Shahar Havivi | out2:
|
137 | cfaf6d36 | Juan Quintela | qemu_set_fd_handler2(s, NULL, NULL, NULL, NULL); |
138 | cfaf6d36 | Juan Quintela | close(s); |
139 | 34c9dd8e | aliguori | } |
140 | 34c9dd8e | aliguori | |
141 | d5c5dacc | Amos Kong | int tcp_start_incoming_migration(const char *host_port, Error **errp) |
142 | 34c9dd8e | aliguori | { |
143 | 34c9dd8e | aliguori | int s;
|
144 | 34c9dd8e | aliguori | |
145 | d5c5dacc | Amos Kong | s = inet_listen(host_port, NULL, 256, SOCK_STREAM, 0, errp); |
146 | 34c9dd8e | aliguori | |
147 | d5c5dacc | Amos Kong | if (s < 0) { |
148 | d5c5dacc | Amos Kong | return -1; |
149 | ee86c61f | Juan Quintela | } |
150 | 34c9dd8e | aliguori | |
151 | 34c9dd8e | aliguori | qemu_set_fd_handler2(s, NULL, tcp_accept_incoming_migration, NULL, |
152 | e0efb993 | Stefan Weil | (void *)(intptr_t)s);
|
153 | 34c9dd8e | aliguori | |
154 | 34c9dd8e | aliguori | return 0; |
155 | 34c9dd8e | aliguori | } |