blob: c83066959a4e2fc2a8197328cfe6cdc9960933d6 [file] [log] [blame]
aliguori065e2812008-11-11 16:46:33 +00001/*
2 * QEMU live migration
3 *
4 * Copyright IBM, Corp. 2008
5 * Copyright Dell MessageOne 2008
6 *
7 * Authors:
8 * Anthony Liguori <aliguori@us.ibm.com>
9 * Charles Duffy <charles_duffy@messageone.com>
10 *
11 * This work is licensed under the terms of the GNU GPL, version 2. See
12 * the COPYING file in the top-level directory.
13 *
14 */
15
16#include "qemu-common.h"
17#include "qemu_socket.h"
18#include "migration.h"
19#include "qemu-char.h"
20#include "sysemu.h"
aliguori065e2812008-11-11 16:46:33 +000021#include "buffered_file.h"
22#include "block.h"
23
24//#define DEBUG_MIGRATION_EXEC
25
26#ifdef DEBUG_MIGRATION_EXEC
27#define dprintf(fmt, ...) \
28 do { printf("migration-exec: " fmt, ## __VA_ARGS__); } while (0)
29#else
30#define dprintf(fmt, ...) \
31 do { } while (0)
32#endif
33
34static int file_errno(FdMigrationState *s)
35{
36 return errno;
37}
38
39static int file_write(FdMigrationState *s, const void * buf, size_t size)
40{
41 return write(s->fd, buf, size);
42}
43
44static int exec_close(FdMigrationState *s)
45{
46 dprintf("exec_close\n");
47 if (s->opaque) {
48 qemu_fclose(s->opaque);
49 s->opaque = NULL;
50 s->fd = -1;
51 }
52 return 0;
53}
54
55MigrationState *exec_start_outgoing_migration(const char *command,
lirans@il.ibm.comc163b5c2009-11-02 15:40:58 +020056 int64_t bandwidth_limit,
57 int detach,
58 int blk,
59 int inc)
aliguori065e2812008-11-11 16:46:33 +000060{
61 FdMigrationState *s;
62 FILE *f;
63
64 s = qemu_mallocz(sizeof(*s));
aliguori065e2812008-11-11 16:46:33 +000065
66 f = popen(command, "w");
67 if (f == NULL) {
68 dprintf("Unable to popen exec target\n");
69 goto err_after_alloc;
70 }
71
72 s->fd = fileno(f);
73 if (s->fd == -1) {
74 dprintf("Unable to retrieve file descriptor for popen'd handle\n");
75 goto err_after_open;
76 }
77
Chris Lalancette90750002009-08-05 17:07:35 +020078 socket_set_nonblock(s->fd);
aliguori065e2812008-11-11 16:46:33 +000079
80 s->opaque = qemu_popen(f, "w");
81
aliguori8ad9fa52008-11-12 22:29:11 +000082 s->close = exec_close;
aliguori065e2812008-11-11 16:46:33 +000083 s->get_error = file_errno;
84 s->write = file_write;
85 s->mig_state.cancel = migrate_fd_cancel;
86 s->mig_state.get_status = migrate_fd_get_status;
87 s->mig_state.release = migrate_fd_release;
88
lirans@il.ibm.comc163b5c2009-11-02 15:40:58 +020089 s->mig_state.blk = blk;
90 s->mig_state.shared = inc;
91
aliguori065e2812008-11-11 16:46:33 +000092 s->state = MIG_STATE_ACTIVE;
aliguori731b0362009-03-05 23:01:42 +000093 s->mon_resume = NULL;
aliguori065e2812008-11-11 16:46:33 +000094 s->bandwidth_limit = bandwidth_limit;
95
aliguori731b0362009-03-05 23:01:42 +000096 if (!detach)
97 migrate_fd_monitor_suspend(s);
aliguori065e2812008-11-11 16:46:33 +000098
99 migrate_fd_connect(s);
100 return &s->mig_state;
101
102err_after_open:
103 pclose(f);
104err_after_alloc:
105 qemu_free(s);
aliguori065e2812008-11-11 16:46:33 +0000106 return NULL;
107}
108
Chris Lalancette8a43b1e2009-05-25 16:38:23 +0200109static void exec_accept_incoming_migration(void *opaque)
aliguori065e2812008-11-11 16:46:33 +0000110{
Chris Lalancette8a43b1e2009-05-25 16:38:23 +0200111 QEMUFile *f = opaque;
aliguori065e2812008-11-11 16:46:33 +0000112 int ret;
aliguori065e2812008-11-11 16:46:33 +0000113
aliguori065e2812008-11-11 16:46:33 +0000114 ret = qemu_loadvm_state(f);
115 if (ret < 0) {
116 fprintf(stderr, "load of migration failed\n");
117 goto err;
118 }
119 qemu_announce_self();
120 dprintf("successfully loaded vm state\n");
Chris Lalancette8a43b1e2009-05-25 16:38:23 +0200121 /* we've successfully migrated, close the fd */
Paolo Bonzini7f79dd22009-08-12 14:17:35 +0200122 qemu_set_fd_handler2(qemu_stdio_fd(f), NULL, NULL, NULL, NULL);
Paolo Bonzinid399f672009-07-27 23:17:51 +0200123 if (autostart)
124 vm_start();
aliguori065e2812008-11-11 16:46:33 +0000125
126err:
127 qemu_fclose(f);
Chris Lalancette8a43b1e2009-05-25 16:38:23 +0200128}
129
130int exec_start_incoming_migration(const char *command)
131{
132 QEMUFile *f;
133
134 dprintf("Attempting to start an incoming migration\n");
135 f = qemu_popen_cmd(command, "r");
136 if(f == NULL) {
137 dprintf("Unable to apply qemu wrapper to popen file\n");
138 return -errno;
139 }
140
Paolo Bonzini7f79dd22009-08-12 14:17:35 +0200141 qemu_set_fd_handler2(qemu_stdio_fd(f), NULL,
Chris Lalancette8a43b1e2009-05-25 16:38:23 +0200142 exec_accept_incoming_migration, NULL,
143 (void *)(unsigned long)f);
144
145 return 0;
aliguori065e2812008-11-11 16:46:33 +0000146}