blob: 94b7022fc856d3564954120eca9d737155f39eb2 [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
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"
Chris Lalancette4951f652009-08-05 17:24:29 +020021
22//#define DEBUG_MIGRATION_UNIX
23
24#ifdef DEBUG_MIGRATION_UNIX
malcd0f2c4c2010-02-07 02:03:50 +030025#define DPRINTF(fmt, ...) \
Chris Lalancette4951f652009-08-05 17:24:29 +020026 do { printf("migration-unix: " fmt, ## __VA_ARGS__); } while (0)
27#else
malcd0f2c4c2010-02-07 02:03:50 +030028#define DPRINTF(fmt, ...) \
Chris Lalancette4951f652009-08-05 17:24:29 +020029 do { } while (0)
30#endif
31
Paolo Bonzinie08c95c2012-10-03 14:05:49 +020032static void unix_wait_for_connect(int fd, void *opaque)
Chris Lalancette4951f652009-08-05 17:24:29 +020033{
Juan Quintela22f00a42010-05-11 15:56:35 +020034 MigrationState *s = opaque;
Chris Lalancette4951f652009-08-05 17:24:29 +020035
Paolo Bonzinie08c95c2012-10-03 14:05:49 +020036 if (fd < 0) {
37 DPRINTF("migrate connect error\n");
Paolo Bonzinib3523652013-02-22 17:36:47 +010038 s->file = NULL;
Chris Lalancette4951f652009-08-05 17:24:29 +020039 migrate_fd_error(s);
Paolo Bonzinie08c95c2012-10-03 14:05:49 +020040 } else {
41 DPRINTF("migrate connect success\n");
Paolo Bonzinib3523652013-02-22 17:36:47 +010042 s->file = qemu_fopen_socket(fd, "wb");
Chris Lalancette4951f652009-08-05 17:24:29 +020043 migrate_fd_connect(s);
Chris Lalancette4951f652009-08-05 17:24:29 +020044 }
45}
46
Paolo Bonzinif37afb52012-10-02 10:02:46 +020047void unix_start_outgoing_migration(MigrationState *s, const char *path, Error **errp)
Chris Lalancette4951f652009-08-05 17:24:29 +020048{
Paolo Bonzinif8bbc122013-02-22 17:36:41 +010049 unix_nonblocking_connect(path, unix_wait_for_connect, s, errp);
Chris Lalancette4951f652009-08-05 17:24:29 +020050}
51
52static void unix_accept_incoming_migration(void *opaque)
53{
54 struct sockaddr_un addr;
55 socklen_t addrlen = sizeof(addr);
Stefan Weile0efb992011-02-23 19:09:16 +010056 int s = (intptr_t)opaque;
Chris Lalancette4951f652009-08-05 17:24:29 +020057 QEMUFile *f;
Juan Quintela511c0232010-06-09 14:10:55 +020058 int c;
Chris Lalancette4951f652009-08-05 17:24:29 +020059
60 do {
Kevin Wolf40ff6d72009-12-02 12:24:42 +010061 c = qemu_accept(s, (struct sockaddr *)&addr, &addrlen);
Juan Quintelaefab4712011-02-23 11:52:12 +010062 } while (c == -1 && errno == EINTR);
Paolo Bonzinia6ef2902012-08-07 10:49:13 +020063 qemu_set_fd_handler2(s, NULL, NULL, NULL, NULL);
64 close(s);
Chris Lalancette4951f652009-08-05 17:24:29 +020065
malcd0f2c4c2010-02-07 02:03:50 +030066 DPRINTF("accepted migration\n");
Chris Lalancette4951f652009-08-05 17:24:29 +020067
68 if (c == -1) {
69 fprintf(stderr, "could not accept migration connection\n");
Paolo Bonzinia6ef2902012-08-07 10:49:13 +020070 goto out;
Chris Lalancette4951f652009-08-05 17:24:29 +020071 }
72
Paolo Bonzini0cc3f3c2013-02-22 17:36:39 +010073 f = qemu_fopen_socket(c, "rb");
Chris Lalancette4951f652009-08-05 17:24:29 +020074 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
Chris Lalancette4951f652009-08-05 17:24:29 +020082out:
Juan Quintelaee86c612011-02-23 20:44:29 +010083 close(c);
Chris Lalancette4951f652009-08-05 17:24:29 +020084}
85
Paolo Bonzini43eaae22012-10-02 18:21:18 +020086void unix_start_incoming_migration(const char *path, Error **errp)
Chris Lalancette4951f652009-08-05 17:24:29 +020087{
Juan Quintelaee86c612011-02-23 20:44:29 +010088 int s;
Chris Lalancette4951f652009-08-05 17:24:29 +020089
Paolo Bonzinie08c95c2012-10-03 14:05:49 +020090 s = unix_listen(path, NULL, 0, errp);
91 if (s < 0) {
Paolo Bonzini43eaae22012-10-02 18:21:18 +020092 return;
Chris Lalancette4951f652009-08-05 17:24:29 +020093 }
94
Juan Quintelaee86c612011-02-23 20:44:29 +010095 qemu_set_fd_handler2(s, NULL, unix_accept_incoming_migration, NULL,
96 (void *)(intptr_t)s);
Chris Lalancette4951f652009-08-05 17:24:29 +020097}