blob: b20ee58f558cb21758478cfac4baca68dee14615 [file] [log] [blame]
aliguori34c9dd82008-10-13 03:14:31 +00001/*
2 * QEMU live migration
3 *
4 * Copyright IBM, Corp. 2008
5 *
6 * Authors:
7 * Anthony Liguori <aliguori@us.ibm.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 *
Paolo Bonzini6b620ca2012-01-13 17:44:23 +010012 * Contributions after 2012-01-13 are licensed under the terms of the
13 * GNU GPL, version 2 or (at your option) any later version.
aliguori34c9dd82008-10-13 03:14:31 +000014 */
15
16#include "qemu-common.h"
Paolo Bonzini1de7afc2012-12-17 18:20:00 +010017#include "qemu/sockets.h"
Paolo Bonzinicaf71f82012-12-17 18:19:50 +010018#include "migration/migration.h"
Juan Quintela557ec5a2012-10-03 14:07:31 +020019#include "migration/qemu-file.h"
Paolo Bonzini737e1502012-12-17 18:19:44 +010020#include "block/block.h"
aliguori34c9dd82008-10-13 03:14:31 +000021
22//#define DEBUG_MIGRATION_TCP
23
aliguori34c9dd82008-10-13 03:14:31 +000024#ifdef DEBUG_MIGRATION_TCP
malcd0f2c4c2010-02-07 02:03:50 +030025#define DPRINTF(fmt, ...) \
aliguori34c9dd82008-10-13 03:14:31 +000026 do { printf("migration-tcp: " fmt, ## __VA_ARGS__); } while (0)
27#else
malcd0f2c4c2010-02-07 02:03:50 +030028#define DPRINTF(fmt, ...) \
aliguori34c9dd82008-10-13 03:14:31 +000029 do { } while (0)
30#endif
31
Orit Wasserman233aa5c2012-09-24 13:11:09 +020032static void tcp_wait_for_connect(int fd, void *opaque)
aliguori34c9dd82008-10-13 03:14:31 +000033{
Juan Quintela22f00a42010-05-11 15:56:35 +020034 MigrationState *s = opaque;
aliguori34c9dd82008-10-13 03:14:31 +000035
Orit Wasserman233aa5c2012-09-24 13:11:09 +020036 if (fd < 0) {
37 DPRINTF("migrate connect error\n");
Paolo Bonzinib3523652013-02-22 17:36:47 +010038 s->file = NULL;
aliguori065e2812008-11-11 16:46:33 +000039 migrate_fd_error(s);
Orit Wasserman233aa5c2012-09-24 13:11:09 +020040 } else {
41 DPRINTF("migrate connect success\n");
Paolo Bonzinib3523652013-02-22 17:36:47 +010042 s->file = qemu_fopen_socket(fd, "wb");
aliguori065e2812008-11-11 16:46:33 +000043 migrate_fd_connect(s);
aliguori34c9dd82008-10-13 03:14:31 +000044 }
45}
46
Paolo Bonzinif37afb52012-10-02 10:02:46 +020047void tcp_start_outgoing_migration(MigrationState *s, const char *host_port, Error **errp)
aliguori34c9dd82008-10-13 03:14:31 +000048{
Paolo Bonzinif8bbc122013-02-22 17:36:41 +010049 inet_nonblocking_connect(host_port, tcp_wait_for_connect, s, errp);
aliguori34c9dd82008-10-13 03:14:31 +000050}
51
52static void tcp_accept_incoming_migration(void *opaque)
53{
54 struct sockaddr_in addr;
55 socklen_t addrlen = sizeof(addr);
Stefan Weile0efb992011-02-23 19:09:16 +010056 int s = (intptr_t)opaque;
aliguori34c9dd82008-10-13 03:14:31 +000057 QEMUFile *f;
Juan Quintela511c0232010-06-09 14:10:55 +020058 int c;
aliguori34c9dd82008-10-13 03:14:31 +000059
60 do {
Kevin Wolf40ff6d72009-12-02 12:24:42 +010061 c = qemu_accept(s, (struct sockaddr *)&addr, &addrlen);
aliguoric1d36662008-10-24 21:55:17 +000062 } while (c == -1 && socket_error() == EINTR);
Paolo Bonzinia6ef2902012-08-07 10:49:13 +020063 qemu_set_fd_handler2(s, NULL, NULL, NULL, NULL);
Paolo Bonzini09bac732012-09-27 13:33:08 +020064 closesocket(s);
aliguori34c9dd82008-10-13 03:14:31 +000065
malcd0f2c4c2010-02-07 02:03:50 +030066 DPRINTF("accepted migration\n");
aliguori34c9dd82008-10-13 03:14:31 +000067
68 if (c == -1) {
69 fprintf(stderr, "could not accept migration connection\n");
Paolo Bonzinia6ef2902012-08-07 10:49:13 +020070 goto out;
aliguori34c9dd82008-10-13 03:14:31 +000071 }
72
Paolo Bonzini0cc3f3c2013-02-22 17:36:39 +010073 f = qemu_fopen_socket(c, "rb");
aliguori34c9dd82008-10-13 03:14:31 +000074 if (f == NULL) {
75 fprintf(stderr, "could not qemu_fopen socket\n");
76 goto out;
77 }
78
Juan Quintela511c0232010-06-09 14:10:55 +020079 process_incoming_migration(f);
Paolo Bonziniab52a822012-08-07 10:50:26 +020080 return;
81
aliguori34c9dd82008-10-13 03:14:31 +000082out:
Paolo Bonzini09bac732012-09-27 13:33:08 +020083 closesocket(c);
aliguori34c9dd82008-10-13 03:14:31 +000084}
85
Paolo Bonzini43eaae22012-10-02 18:21:18 +020086void tcp_start_incoming_migration(const char *host_port, Error **errp)
aliguori34c9dd82008-10-13 03:14:31 +000087{
aliguori34c9dd82008-10-13 03:14:31 +000088 int s;
89
Amos Kongd5c5dac2012-05-11 00:28:35 +080090 s = inet_listen(host_port, NULL, 256, SOCK_STREAM, 0, errp);
Amos Kongd5c5dac2012-05-11 00:28:35 +080091 if (s < 0) {
Paolo Bonzini43eaae22012-10-02 18:21:18 +020092 return;
Juan Quintelaee86c612011-02-23 20:44:29 +010093 }
aliguori34c9dd82008-10-13 03:14:31 +000094
95 qemu_set_fd_handler2(s, NULL, tcp_accept_incoming_migration, NULL,
Stefan Weile0efb992011-02-23 19:09:16 +010096 (void *)(intptr_t)s);
aliguori34c9dd82008-10-13 03:14:31 +000097}