blob: 0a5f8a133247582d1d5ec843dc67cf842748a146 [file] [log] [blame]
Chris Lalancette4951f652009-08-05 17:24:29 +02001/*
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 *
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.
Chris Lalancette4951f652009-08-05 17:24:29 +020014 */
15
Dr. David Alan Gilbertd99598c2014-03-19 13:34:28 +000016#include <string.h>
17
Chris Lalancette4951f652009-08-05 17:24:29 +020018#include "qemu-common.h"
Dr. David Alan Gilbertd99598c2014-03-19 13:34:28 +000019#include "qemu/error-report.h"
Paolo Bonzini1de7afc2012-12-17 18:20:00 +010020#include "qemu/sockets.h"
Alex Bligh6a1751b2013-08-21 16:02:47 +010021#include "qemu/main-loop.h"
Paolo Bonzinicaf71f82012-12-17 18:19:50 +010022#include "migration/migration.h"
Juan Quintela557ec5a2012-10-03 14:07:31 +020023#include "migration/qemu-file.h"
Paolo Bonzini737e1502012-12-17 18:19:44 +010024#include "block/block.h"
Chris Lalancette4951f652009-08-05 17:24:29 +020025
26//#define DEBUG_MIGRATION_UNIX
27
28#ifdef DEBUG_MIGRATION_UNIX
malcd0f2c4c2010-02-07 02:03:50 +030029#define DPRINTF(fmt, ...) \
Chris Lalancette4951f652009-08-05 17:24:29 +020030 do { printf("migration-unix: " fmt, ## __VA_ARGS__); } while (0)
31#else
malcd0f2c4c2010-02-07 02:03:50 +030032#define DPRINTF(fmt, ...) \
Chris Lalancette4951f652009-08-05 17:24:29 +020033 do { } while (0)
34#endif
35
Paolo Bonzinie08c95c2012-10-03 14:05:49 +020036static void unix_wait_for_connect(int fd, void *opaque)
Chris Lalancette4951f652009-08-05 17:24:29 +020037{
Juan Quintela22f00a42010-05-11 15:56:35 +020038 MigrationState *s = opaque;
Chris Lalancette4951f652009-08-05 17:24:29 +020039
Paolo Bonzinie08c95c2012-10-03 14:05:49 +020040 if (fd < 0) {
41 DPRINTF("migrate connect error\n");
Paolo Bonzinib3523652013-02-22 17:36:47 +010042 s->file = NULL;
Chris Lalancette4951f652009-08-05 17:24:29 +020043 migrate_fd_error(s);
Paolo Bonzinie08c95c2012-10-03 14:05:49 +020044 } else {
45 DPRINTF("migrate connect success\n");
Paolo Bonzinib3523652013-02-22 17:36:47 +010046 s->file = qemu_fopen_socket(fd, "wb");
Chris Lalancette4951f652009-08-05 17:24:29 +020047 migrate_fd_connect(s);
Chris Lalancette4951f652009-08-05 17:24:29 +020048 }
49}
50
Paolo Bonzinif37afb52012-10-02 10:02:46 +020051void unix_start_outgoing_migration(MigrationState *s, const char *path, Error **errp)
Chris Lalancette4951f652009-08-05 17:24:29 +020052{
Paolo Bonzinif8bbc122013-02-22 17:36:41 +010053 unix_nonblocking_connect(path, unix_wait_for_connect, s, errp);
Chris Lalancette4951f652009-08-05 17:24:29 +020054}
55
56static void unix_accept_incoming_migration(void *opaque)
57{
58 struct sockaddr_un addr;
59 socklen_t addrlen = sizeof(addr);
Stefan Weile0efb992011-02-23 19:09:16 +010060 int s = (intptr_t)opaque;
Chris Lalancette4951f652009-08-05 17:24:29 +020061 QEMUFile *f;
Dr. David Alan Gilbertd99598c2014-03-19 13:34:28 +000062 int c, err;
Chris Lalancette4951f652009-08-05 17:24:29 +020063
64 do {
Kevin Wolf40ff6d72009-12-02 12:24:42 +010065 c = qemu_accept(s, (struct sockaddr *)&addr, &addrlen);
Dr. David Alan Gilbertd99598c2014-03-19 13:34:28 +000066 err = errno;
67 } while (c < 0 && err == EINTR);
Paolo Bonzinia6ef2902012-08-07 10:49:13 +020068 qemu_set_fd_handler2(s, NULL, NULL, NULL, NULL);
69 close(s);
Chris Lalancette4951f652009-08-05 17:24:29 +020070
malcd0f2c4c2010-02-07 02:03:50 +030071 DPRINTF("accepted migration\n");
Chris Lalancette4951f652009-08-05 17:24:29 +020072
Dr. David Alan Gilbertd99598c2014-03-19 13:34:28 +000073 if (c < 0) {
74 error_report("could not accept migration connection (%s)",
75 strerror(err));
76 return;
Chris Lalancette4951f652009-08-05 17:24:29 +020077 }
78
Paolo Bonzini0cc3f3c2013-02-22 17:36:39 +010079 f = qemu_fopen_socket(c, "rb");
Chris Lalancette4951f652009-08-05 17:24:29 +020080 if (f == NULL) {
Dr. David Alan Gilbertd99598c2014-03-19 13:34:28 +000081 error_report("could not qemu_fopen socket");
Chris Lalancette4951f652009-08-05 17:24:29 +020082 goto out;
83 }
84
Juan Quintela511c0232010-06-09 14:10:55 +020085 process_incoming_migration(f);
Paolo Bonziniab52a822012-08-07 10:50:26 +020086 return;
87
Chris Lalancette4951f652009-08-05 17:24:29 +020088out:
Juan Quintelaee86c612011-02-23 20:44:29 +010089 close(c);
Chris Lalancette4951f652009-08-05 17:24:29 +020090}
91
Paolo Bonzini43eaae22012-10-02 18:21:18 +020092void unix_start_incoming_migration(const char *path, Error **errp)
Chris Lalancette4951f652009-08-05 17:24:29 +020093{
Juan Quintelaee86c612011-02-23 20:44:29 +010094 int s;
Chris Lalancette4951f652009-08-05 17:24:29 +020095
Paolo Bonzinie08c95c2012-10-03 14:05:49 +020096 s = unix_listen(path, NULL, 0, errp);
97 if (s < 0) {
Paolo Bonzini43eaae22012-10-02 18:21:18 +020098 return;
Chris Lalancette4951f652009-08-05 17:24:29 +020099 }
100
Juan Quintelaee86c612011-02-23 20:44:29 +0100101 qemu_set_fd_handler2(s, NULL, unix_accept_incoming_migration, NULL,
102 (void *)(intptr_t)s);
Chris Lalancette4951f652009-08-05 17:24:29 +0200103}