blob: 782572de82923cbe69acd98de163629bae0d3831 [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"
Alex Bligh6a1751b2013-08-21 16:02:47 +010021#include "qemu/main-loop.h"
aliguori34c9dd82008-10-13 03:14:31 +000022
23//#define DEBUG_MIGRATION_TCP
24
aliguori34c9dd82008-10-13 03:14:31 +000025#ifdef DEBUG_MIGRATION_TCP
malcd0f2c4c2010-02-07 02:03:50 +030026#define DPRINTF(fmt, ...) \
aliguori34c9dd82008-10-13 03:14:31 +000027 do { printf("migration-tcp: " fmt, ## __VA_ARGS__); } while (0)
28#else
malcd0f2c4c2010-02-07 02:03:50 +030029#define DPRINTF(fmt, ...) \
aliguori34c9dd82008-10-13 03:14:31 +000030 do { } while (0)
31#endif
32
Orit Wasserman233aa5c2012-09-24 13:11:09 +020033static void tcp_wait_for_connect(int fd, void *opaque)
aliguori34c9dd82008-10-13 03:14:31 +000034{
Juan Quintela22f00a42010-05-11 15:56:35 +020035 MigrationState *s = opaque;
aliguori34c9dd82008-10-13 03:14:31 +000036
Orit Wasserman233aa5c2012-09-24 13:11:09 +020037 if (fd < 0) {
38 DPRINTF("migrate connect error\n");
Paolo Bonzinib3523652013-02-22 17:36:47 +010039 s->file = NULL;
aliguori065e2812008-11-11 16:46:33 +000040 migrate_fd_error(s);
Orit Wasserman233aa5c2012-09-24 13:11:09 +020041 } else {
42 DPRINTF("migrate connect success\n");
Paolo Bonzinib3523652013-02-22 17:36:47 +010043 s->file = qemu_fopen_socket(fd, "wb");
aliguori065e2812008-11-11 16:46:33 +000044 migrate_fd_connect(s);
aliguori34c9dd82008-10-13 03:14:31 +000045 }
46}
47
Paolo Bonzinif37afb52012-10-02 10:02:46 +020048void tcp_start_outgoing_migration(MigrationState *s, const char *host_port, Error **errp)
aliguori34c9dd82008-10-13 03:14:31 +000049{
Paolo Bonzinif8bbc122013-02-22 17:36:41 +010050 inet_nonblocking_connect(host_port, tcp_wait_for_connect, s, errp);
aliguori34c9dd82008-10-13 03:14:31 +000051}
52
53static void tcp_accept_incoming_migration(void *opaque)
54{
55 struct sockaddr_in addr;
56 socklen_t addrlen = sizeof(addr);
Stefan Weile0efb992011-02-23 19:09:16 +010057 int s = (intptr_t)opaque;
aliguori34c9dd82008-10-13 03:14:31 +000058 QEMUFile *f;
Juan Quintela511c0232010-06-09 14:10:55 +020059 int c;
aliguori34c9dd82008-10-13 03:14:31 +000060
61 do {
Kevin Wolf40ff6d72009-12-02 12:24:42 +010062 c = qemu_accept(s, (struct sockaddr *)&addr, &addrlen);
aliguoric1d36662008-10-24 21:55:17 +000063 } while (c == -1 && socket_error() == EINTR);
Paolo Bonzinia6ef2902012-08-07 10:49:13 +020064 qemu_set_fd_handler2(s, NULL, NULL, NULL, NULL);
Paolo Bonzini09bac732012-09-27 13:33:08 +020065 closesocket(s);
aliguori34c9dd82008-10-13 03:14:31 +000066
malcd0f2c4c2010-02-07 02:03:50 +030067 DPRINTF("accepted migration\n");
aliguori34c9dd82008-10-13 03:14:31 +000068
69 if (c == -1) {
70 fprintf(stderr, "could not accept migration connection\n");
Paolo Bonzinia6ef2902012-08-07 10:49:13 +020071 goto out;
aliguori34c9dd82008-10-13 03:14:31 +000072 }
73
Paolo Bonzini0cc3f3c2013-02-22 17:36:39 +010074 f = qemu_fopen_socket(c, "rb");
aliguori34c9dd82008-10-13 03:14:31 +000075 if (f == NULL) {
76 fprintf(stderr, "could not qemu_fopen socket\n");
77 goto out;
78 }
79
Juan Quintela511c0232010-06-09 14:10:55 +020080 process_incoming_migration(f);
Paolo Bonziniab52a822012-08-07 10:50:26 +020081 return;
82
aliguori34c9dd82008-10-13 03:14:31 +000083out:
Paolo Bonzini09bac732012-09-27 13:33:08 +020084 closesocket(c);
aliguori34c9dd82008-10-13 03:14:31 +000085}
86
Paolo Bonzini43eaae22012-10-02 18:21:18 +020087void tcp_start_incoming_migration(const char *host_port, Error **errp)
aliguori34c9dd82008-10-13 03:14:31 +000088{
aliguori34c9dd82008-10-13 03:14:31 +000089 int s;
90
Amos Kongd5c5dac2012-05-11 00:28:35 +080091 s = inet_listen(host_port, NULL, 256, SOCK_STREAM, 0, errp);
Amos Kongd5c5dac2012-05-11 00:28:35 +080092 if (s < 0) {
Paolo Bonzini43eaae22012-10-02 18:21:18 +020093 return;
Juan Quintelaee86c612011-02-23 20:44:29 +010094 }
aliguori34c9dd82008-10-13 03:14:31 +000095
96 qemu_set_fd_handler2(s, NULL, tcp_accept_incoming_migration, NULL,
Stefan Weile0efb992011-02-23 19:09:16 +010097 (void *)(intptr_t)s);
aliguori34c9dd82008-10-13 03:14:31 +000098}