blob: 4b7aad8b6b599477bf19aa38d06b78d96c2db659 [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"
aliguori065e2812008-11-11 16:46:33 +000020#include "buffered_file.h"
21#include "block.h"
Blue Swirl0ffbba32010-06-04 20:01:07 +000022#include <sys/types.h>
23#include <sys/wait.h>
aliguori065e2812008-11-11 16:46:33 +000024
25//#define DEBUG_MIGRATION_EXEC
26
27#ifdef DEBUG_MIGRATION_EXEC
malcd0f2c4c2010-02-07 02:03:50 +030028#define DPRINTF(fmt, ...) \
aliguori065e2812008-11-11 16:46:33 +000029 do { printf("migration-exec: " fmt, ## __VA_ARGS__); } while (0)
30#else
malcd0f2c4c2010-02-07 02:03:50 +030031#define DPRINTF(fmt, ...) \
aliguori065e2812008-11-11 16:46:33 +000032 do { } while (0)
33#endif
34
35static int file_errno(FdMigrationState *s)
36{
37 return errno;
38}
39
40static int file_write(FdMigrationState *s, const void * buf, size_t size)
41{
42 return write(s->fd, buf, size);
43}
44
45static int exec_close(FdMigrationState *s)
46{
Anthony Liguori41ef56e2010-06-02 14:55:25 -050047 int ret = 0;
malcd0f2c4c2010-02-07 02:03:50 +030048 DPRINTF("exec_close\n");
aliguori065e2812008-11-11 16:46:33 +000049 if (s->opaque) {
Anthony Liguori41ef56e2010-06-02 14:55:25 -050050 ret = qemu_fclose(s->opaque);
aliguori065e2812008-11-11 16:46:33 +000051 s->opaque = NULL;
52 s->fd = -1;
Anthony Liguori41ef56e2010-06-02 14:55:25 -050053 if (ret != -1 &&
54 WIFEXITED(ret)
55 && WEXITSTATUS(ret) == 0) {
56 ret = 0;
57 } else {
58 ret = -1;
59 }
aliguori065e2812008-11-11 16:46:33 +000060 }
Anthony Liguori41ef56e2010-06-02 14:55:25 -050061 return ret;
aliguori065e2812008-11-11 16:46:33 +000062}
63
Jan Kiszkaf327aa02009-11-30 18:21:21 +010064MigrationState *exec_start_outgoing_migration(Monitor *mon,
65 const char *command,
lirans@il.ibm.comc163b5c2009-11-02 15:40:58 +020066 int64_t bandwidth_limit,
67 int detach,
68 int blk,
69 int inc)
aliguori065e2812008-11-11 16:46:33 +000070{
71 FdMigrationState *s;
72 FILE *f;
73
74 s = qemu_mallocz(sizeof(*s));
aliguori065e2812008-11-11 16:46:33 +000075
76 f = popen(command, "w");
77 if (f == NULL) {
malcd0f2c4c2010-02-07 02:03:50 +030078 DPRINTF("Unable to popen exec target\n");
aliguori065e2812008-11-11 16:46:33 +000079 goto err_after_alloc;
80 }
81
82 s->fd = fileno(f);
83 if (s->fd == -1) {
malcd0f2c4c2010-02-07 02:03:50 +030084 DPRINTF("Unable to retrieve file descriptor for popen'd handle\n");
aliguori065e2812008-11-11 16:46:33 +000085 goto err_after_open;
86 }
87
Chris Lalancette90750002009-08-05 17:07:35 +020088 socket_set_nonblock(s->fd);
aliguori065e2812008-11-11 16:46:33 +000089
90 s->opaque = qemu_popen(f, "w");
91
aliguori8ad9fa52008-11-12 22:29:11 +000092 s->close = exec_close;
aliguori065e2812008-11-11 16:46:33 +000093 s->get_error = file_errno;
94 s->write = file_write;
95 s->mig_state.cancel = migrate_fd_cancel;
96 s->mig_state.get_status = migrate_fd_get_status;
97 s->mig_state.release = migrate_fd_release;
98
lirans@il.ibm.comc163b5c2009-11-02 15:40:58 +020099 s->mig_state.blk = blk;
100 s->mig_state.shared = inc;
Jan Kiszkaf327aa02009-11-30 18:21:21 +0100101
aliguori065e2812008-11-11 16:46:33 +0000102 s->state = MIG_STATE_ACTIVE;
Jan Kiszkaf327aa02009-11-30 18:21:21 +0100103 s->mon = NULL;
aliguori065e2812008-11-11 16:46:33 +0000104 s->bandwidth_limit = bandwidth_limit;
105
Jan Kiszkaf327aa02009-11-30 18:21:21 +0100106 if (!detach) {
107 migrate_fd_monitor_suspend(s, mon);
108 }
aliguori065e2812008-11-11 16:46:33 +0000109
110 migrate_fd_connect(s);
111 return &s->mig_state;
112
113err_after_open:
114 pclose(f);
115err_after_alloc:
116 qemu_free(s);
aliguori065e2812008-11-11 16:46:33 +0000117 return NULL;
118}
119
Chris Lalancette8a43b1e2009-05-25 16:38:23 +0200120static void exec_accept_incoming_migration(void *opaque)
aliguori065e2812008-11-11 16:46:33 +0000121{
Chris Lalancette8a43b1e2009-05-25 16:38:23 +0200122 QEMUFile *f = opaque;
aliguori065e2812008-11-11 16:46:33 +0000123
Juan Quintela511c0232010-06-09 14:10:55 +0200124 process_incoming_migration(f);
Juan Quintelacfaf6d32010-03-10 00:10:35 +0100125 qemu_set_fd_handler2(qemu_stdio_fd(f), NULL, NULL, NULL, NULL);
aliguori065e2812008-11-11 16:46:33 +0000126 qemu_fclose(f);
Chris Lalancette8a43b1e2009-05-25 16:38:23 +0200127}
128
129int exec_start_incoming_migration(const char *command)
130{
131 QEMUFile *f;
132
malcd0f2c4c2010-02-07 02:03:50 +0300133 DPRINTF("Attempting to start an incoming migration\n");
Chris Lalancette8a43b1e2009-05-25 16:38:23 +0200134 f = qemu_popen_cmd(command, "r");
135 if(f == NULL) {
malcd0f2c4c2010-02-07 02:03:50 +0300136 DPRINTF("Unable to apply qemu wrapper to popen file\n");
Chris Lalancette8a43b1e2009-05-25 16:38:23 +0200137 return -errno;
138 }
139
Paolo Bonzini7f79dd22009-08-12 14:17:35 +0200140 qemu_set_fd_handler2(qemu_stdio_fd(f), NULL,
Juan Quintela1c39e2a2010-03-11 17:55:38 +0100141 exec_accept_incoming_migration, NULL, f);
Chris Lalancette8a43b1e2009-05-25 16:38:23 +0200142
143 return 0;
aliguori065e2812008-11-11 16:46:33 +0000144}