aliguori | 5bb7910 | 2008-10-13 03:12:02 +0000 | [diff] [blame] | 1 | /* |
| 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 | * |
| 12 | */ |
| 13 | |
| 14 | #include "qemu-common.h" |
| 15 | #include "migration.h" |
aliguori | 376253e | 2009-03-05 23:01:23 +0000 | [diff] [blame] | 16 | #include "monitor.h" |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 17 | #include "buffered_file.h" |
| 18 | #include "sysemu.h" |
| 19 | #include "block.h" |
| 20 | #include "qemu_socket.h" |
Jan Kiszka | 25f2364 | 2009-11-30 18:21:21 +0100 | [diff] [blame] | 21 | #include "block-migration.h" |
Luiz Capitulino | c86a668 | 2009-12-10 17:16:05 -0200 | [diff] [blame] | 22 | #include "qemu-objects.h" |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 23 | |
| 24 | //#define DEBUG_MIGRATION |
| 25 | |
| 26 | #ifdef DEBUG_MIGRATION |
malc | d0f2c4c | 2010-02-07 02:03:50 +0300 | [diff] [blame] | 27 | #define DPRINTF(fmt, ...) \ |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 28 | do { printf("migration: " fmt, ## __VA_ARGS__); } while (0) |
| 29 | #else |
malc | d0f2c4c | 2010-02-07 02:03:50 +0300 | [diff] [blame] | 30 | #define DPRINTF(fmt, ...) \ |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 31 | do { } while (0) |
| 32 | #endif |
aliguori | 5bb7910 | 2008-10-13 03:12:02 +0000 | [diff] [blame] | 33 | |
| 34 | /* Migration speed throttling */ |
| 35 | static uint32_t max_throttle = (32 << 20); |
| 36 | |
| 37 | static MigrationState *current_migration; |
| 38 | |
Juan Quintela | 8ca5e80 | 2010-06-09 14:10:54 +0200 | [diff] [blame] | 39 | int qemu_start_incoming_migration(const char *uri) |
aliguori | 5bb7910 | 2008-10-13 03:12:02 +0000 | [diff] [blame] | 40 | { |
aliguori | 34c9dd8 | 2008-10-13 03:14:31 +0000 | [diff] [blame] | 41 | const char *p; |
Juan Quintela | 8ca5e80 | 2010-06-09 14:10:54 +0200 | [diff] [blame] | 42 | int ret; |
aliguori | 34c9dd8 | 2008-10-13 03:14:31 +0000 | [diff] [blame] | 43 | |
| 44 | if (strstart(uri, "tcp:", &p)) |
Juan Quintela | 8ca5e80 | 2010-06-09 14:10:54 +0200 | [diff] [blame] | 45 | ret = tcp_start_incoming_migration(p); |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 46 | #if !defined(WIN32) |
| 47 | else if (strstart(uri, "exec:", &p)) |
Juan Quintela | 8ca5e80 | 2010-06-09 14:10:54 +0200 | [diff] [blame] | 48 | ret = exec_start_incoming_migration(p); |
Chris Lalancette | 4951f65 | 2009-08-05 17:24:29 +0200 | [diff] [blame] | 49 | else if (strstart(uri, "unix:", &p)) |
Juan Quintela | 8ca5e80 | 2010-06-09 14:10:54 +0200 | [diff] [blame] | 50 | ret = unix_start_incoming_migration(p); |
Paolo Bonzini | 5ac1fad | 2009-08-18 15:56:25 +0200 | [diff] [blame] | 51 | else if (strstart(uri, "fd:", &p)) |
Juan Quintela | 8ca5e80 | 2010-06-09 14:10:54 +0200 | [diff] [blame] | 52 | ret = fd_start_incoming_migration(p); |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 53 | #endif |
Juan Quintela | 8ca5e80 | 2010-06-09 14:10:54 +0200 | [diff] [blame] | 54 | else { |
aliguori | 34c9dd8 | 2008-10-13 03:14:31 +0000 | [diff] [blame] | 55 | fprintf(stderr, "unknown migration protocol: %s\n", uri); |
Juan Quintela | 8ca5e80 | 2010-06-09 14:10:54 +0200 | [diff] [blame] | 56 | ret = -EPROTONOSUPPORT; |
| 57 | } |
| 58 | return ret; |
aliguori | 5bb7910 | 2008-10-13 03:12:02 +0000 | [diff] [blame] | 59 | } |
| 60 | |
Juan Quintela | 511c023 | 2010-06-09 14:10:55 +0200 | [diff] [blame] | 61 | void process_incoming_migration(QEMUFile *f) |
| 62 | { |
| 63 | if (qemu_loadvm_state(f) < 0) { |
| 64 | fprintf(stderr, "load of migration failed\n"); |
| 65 | exit(0); |
| 66 | } |
| 67 | qemu_announce_self(); |
| 68 | DPRINTF("successfully loaded vm state\n"); |
| 69 | |
Amit Shah | 8e84865 | 2010-07-27 15:49:19 +0530 | [diff] [blame] | 70 | incoming_expected = false; |
| 71 | |
Juan Quintela | 511c023 | 2010-06-09 14:10:55 +0200 | [diff] [blame] | 72 | if (autostart) |
| 73 | vm_start(); |
| 74 | } |
| 75 | |
Luiz Capitulino | b5d17ad | 2010-02-10 23:49:57 -0200 | [diff] [blame] | 76 | int do_migrate(Monitor *mon, const QDict *qdict, QObject **ret_data) |
aliguori | 5bb7910 | 2008-10-13 03:12:02 +0000 | [diff] [blame] | 77 | { |
aliguori | 34c9dd8 | 2008-10-13 03:14:31 +0000 | [diff] [blame] | 78 | MigrationState *s = NULL; |
| 79 | const char *p; |
Luiz Capitulino | eb159d1 | 2010-05-28 15:25:24 -0300 | [diff] [blame] | 80 | int detach = qdict_get_try_bool(qdict, "detach", 0); |
| 81 | int blk = qdict_get_try_bool(qdict, "blk", 0); |
| 82 | int inc = qdict_get_try_bool(qdict, "inc", 0); |
Luiz Capitulino | f18c16d | 2009-08-28 15:27:14 -0300 | [diff] [blame] | 83 | const char *uri = qdict_get_str(qdict, "uri"); |
Jan Kiszka | 1302425 | 2009-11-30 18:21:19 +0100 | [diff] [blame] | 84 | |
| 85 | if (current_migration && |
| 86 | current_migration->get_status(current_migration) == MIG_STATE_ACTIVE) { |
| 87 | monitor_printf(mon, "migration already in progress\n"); |
Luiz Capitulino | b5d17ad | 2010-02-10 23:49:57 -0200 | [diff] [blame] | 88 | return -1; |
Jan Kiszka | 1302425 | 2009-11-30 18:21:19 +0100 | [diff] [blame] | 89 | } |
| 90 | |
Luiz Capitulino | b5d17ad | 2010-02-10 23:49:57 -0200 | [diff] [blame] | 91 | if (strstart(uri, "tcp:", &p)) { |
Jan Kiszka | f327aa0 | 2009-11-30 18:21:21 +0100 | [diff] [blame] | 92 | s = tcp_start_outgoing_migration(mon, p, max_throttle, detach, |
Luiz Capitulino | eb159d1 | 2010-05-28 15:25:24 -0300 | [diff] [blame] | 93 | blk, inc); |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 94 | #if !defined(WIN32) |
Luiz Capitulino | b5d17ad | 2010-02-10 23:49:57 -0200 | [diff] [blame] | 95 | } else if (strstart(uri, "exec:", &p)) { |
Jan Kiszka | f327aa0 | 2009-11-30 18:21:21 +0100 | [diff] [blame] | 96 | s = exec_start_outgoing_migration(mon, p, max_throttle, detach, |
Luiz Capitulino | eb159d1 | 2010-05-28 15:25:24 -0300 | [diff] [blame] | 97 | blk, inc); |
Luiz Capitulino | b5d17ad | 2010-02-10 23:49:57 -0200 | [diff] [blame] | 98 | } else if (strstart(uri, "unix:", &p)) { |
Jan Kiszka | f327aa0 | 2009-11-30 18:21:21 +0100 | [diff] [blame] | 99 | s = unix_start_outgoing_migration(mon, p, max_throttle, detach, |
Luiz Capitulino | eb159d1 | 2010-05-28 15:25:24 -0300 | [diff] [blame] | 100 | blk, inc); |
Luiz Capitulino | b5d17ad | 2010-02-10 23:49:57 -0200 | [diff] [blame] | 101 | } else if (strstart(uri, "fd:", &p)) { |
lirans@il.ibm.com | c163b5c | 2009-11-02 15:40:58 +0200 | [diff] [blame] | 102 | s = fd_start_outgoing_migration(mon, p, max_throttle, detach, |
Luiz Capitulino | eb159d1 | 2010-05-28 15:25:24 -0300 | [diff] [blame] | 103 | blk, inc); |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 104 | #endif |
Luiz Capitulino | b5d17ad | 2010-02-10 23:49:57 -0200 | [diff] [blame] | 105 | } else { |
aliguori | 376253e | 2009-03-05 23:01:23 +0000 | [diff] [blame] | 106 | monitor_printf(mon, "unknown migration protocol: %s\n", uri); |
Luiz Capitulino | b5d17ad | 2010-02-10 23:49:57 -0200 | [diff] [blame] | 107 | return -1; |
aliguori | 34c9dd8 | 2008-10-13 03:14:31 +0000 | [diff] [blame] | 108 | } |
Luiz Capitulino | b5d17ad | 2010-02-10 23:49:57 -0200 | [diff] [blame] | 109 | |
| 110 | if (s == NULL) { |
| 111 | monitor_printf(mon, "migration failed\n"); |
| 112 | return -1; |
| 113 | } |
| 114 | |
| 115 | if (current_migration) { |
| 116 | current_migration->release(current_migration); |
| 117 | } |
| 118 | |
| 119 | current_migration = s; |
| 120 | return 0; |
aliguori | 5bb7910 | 2008-10-13 03:12:02 +0000 | [diff] [blame] | 121 | } |
| 122 | |
Luiz Capitulino | ef4b7ee | 2010-02-10 23:49:48 -0200 | [diff] [blame] | 123 | int do_migrate_cancel(Monitor *mon, const QDict *qdict, QObject **ret_data) |
aliguori | 5bb7910 | 2008-10-13 03:12:02 +0000 | [diff] [blame] | 124 | { |
| 125 | MigrationState *s = current_migration; |
| 126 | |
| 127 | if (s) |
aliguori | ff8d81d | 2008-10-24 22:10:31 +0000 | [diff] [blame] | 128 | s->cancel(s); |
Luiz Capitulino | ef4b7ee | 2010-02-10 23:49:48 -0200 | [diff] [blame] | 129 | |
| 130 | return 0; |
aliguori | 5bb7910 | 2008-10-13 03:12:02 +0000 | [diff] [blame] | 131 | } |
| 132 | |
Luiz Capitulino | ef4b7ee | 2010-02-10 23:49:48 -0200 | [diff] [blame] | 133 | int do_migrate_set_speed(Monitor *mon, const QDict *qdict, QObject **ret_data) |
aliguori | 5bb7910 | 2008-10-13 03:12:02 +0000 | [diff] [blame] | 134 | { |
| 135 | double d; |
Glauber Costa | daa91de | 2009-05-20 18:26:58 -0400 | [diff] [blame] | 136 | FdMigrationState *s; |
aliguori | 5bb7910 | 2008-10-13 03:12:02 +0000 | [diff] [blame] | 137 | |
Markus Armbruster | 5667c49 | 2010-01-25 14:23:04 +0100 | [diff] [blame] | 138 | d = qdict_get_double(qdict, "value"); |
| 139 | d = MAX(0, MIN(UINT32_MAX, d)); |
| 140 | max_throttle = d; |
Glauber Costa | daa91de | 2009-05-20 18:26:58 -0400 | [diff] [blame] | 141 | |
Jan Kiszka | 5d39c79 | 2009-11-30 18:21:19 +0100 | [diff] [blame] | 142 | s = migrate_to_fms(current_migration); |
| 143 | if (s && s->file) { |
Glauber Costa | daa91de | 2009-05-20 18:26:58 -0400 | [diff] [blame] | 144 | qemu_file_set_rate_limit(s->file, max_throttle); |
| 145 | } |
Luiz Capitulino | ef4b7ee | 2010-02-10 23:49:48 -0200 | [diff] [blame] | 146 | |
| 147 | return 0; |
aliguori | 5bb7910 | 2008-10-13 03:12:02 +0000 | [diff] [blame] | 148 | } |
| 149 | |
Glauber Costa | a0a3fd6 | 2009-05-28 15:22:57 -0400 | [diff] [blame] | 150 | /* amount of nanoseconds we are willing to wait for migration to be down. |
| 151 | * the choice of nanoseconds is because it is the maximum resolution that |
| 152 | * get_clock() can achieve. It is an internal measure. All user-visible |
| 153 | * units must be in seconds */ |
| 154 | static uint64_t max_downtime = 30000000; |
| 155 | |
| 156 | uint64_t migrate_max_downtime(void) |
| 157 | { |
| 158 | return max_downtime; |
| 159 | } |
| 160 | |
Luiz Capitulino | ef4b7ee | 2010-02-10 23:49:48 -0200 | [diff] [blame] | 161 | int do_migrate_set_downtime(Monitor *mon, const QDict *qdict, |
| 162 | QObject **ret_data) |
Glauber Costa | 2ea4295 | 2009-05-28 15:22:58 -0400 | [diff] [blame] | 163 | { |
Glauber Costa | 2ea4295 | 2009-05-28 15:22:58 -0400 | [diff] [blame] | 164 | double d; |
| 165 | |
Markus Armbruster | b0fbf7d | 2010-01-25 14:23:07 +0100 | [diff] [blame] | 166 | d = qdict_get_double(qdict, "value") * 1e9; |
| 167 | d = MAX(0, MIN(UINT64_MAX, d)); |
Glauber Costa | 2ea4295 | 2009-05-28 15:22:58 -0400 | [diff] [blame] | 168 | max_downtime = (uint64_t)d; |
Luiz Capitulino | ef4b7ee | 2010-02-10 23:49:48 -0200 | [diff] [blame] | 169 | |
| 170 | return 0; |
Glauber Costa | 2ea4295 | 2009-05-28 15:22:58 -0400 | [diff] [blame] | 171 | } |
| 172 | |
Luiz Capitulino | c86a668 | 2009-12-10 17:16:05 -0200 | [diff] [blame] | 173 | static void migrate_print_status(Monitor *mon, const char *name, |
| 174 | const QDict *status_dict) |
aliguori | 5bb7910 | 2008-10-13 03:12:02 +0000 | [diff] [blame] | 175 | { |
Luiz Capitulino | c86a668 | 2009-12-10 17:16:05 -0200 | [diff] [blame] | 176 | QDict *qdict; |
| 177 | |
| 178 | qdict = qobject_to_qdict(qdict_get(status_dict, name)); |
| 179 | |
| 180 | monitor_printf(mon, "transferred %s: %" PRIu64 " kbytes\n", name, |
| 181 | qdict_get_int(qdict, "transferred") >> 10); |
| 182 | monitor_printf(mon, "remaining %s: %" PRIu64 " kbytes\n", name, |
| 183 | qdict_get_int(qdict, "remaining") >> 10); |
| 184 | monitor_printf(mon, "total %s: %" PRIu64 " kbytes\n", name, |
| 185 | qdict_get_int(qdict, "total") >> 10); |
| 186 | } |
| 187 | |
| 188 | void do_info_migrate_print(Monitor *mon, const QObject *data) |
| 189 | { |
| 190 | QDict *qdict; |
| 191 | |
| 192 | qdict = qobject_to_qdict(data); |
| 193 | |
| 194 | monitor_printf(mon, "Migration status: %s\n", |
| 195 | qdict_get_str(qdict, "status")); |
| 196 | |
| 197 | if (qdict_haskey(qdict, "ram")) { |
| 198 | migrate_print_status(mon, "ram", qdict); |
| 199 | } |
| 200 | |
| 201 | if (qdict_haskey(qdict, "disk")) { |
| 202 | migrate_print_status(mon, "disk", qdict); |
| 203 | } |
| 204 | } |
| 205 | |
| 206 | static void migrate_put_status(QDict *qdict, const char *name, |
| 207 | uint64_t trans, uint64_t rem, uint64_t total) |
| 208 | { |
| 209 | QObject *obj; |
| 210 | |
| 211 | obj = qobject_from_jsonf("{ 'transferred': %" PRId64 ", " |
| 212 | "'remaining': %" PRId64 ", " |
| 213 | "'total': %" PRId64 " }", trans, rem, total); |
Luiz Capitulino | c86a668 | 2009-12-10 17:16:05 -0200 | [diff] [blame] | 214 | qdict_put_obj(qdict, name, obj); |
| 215 | } |
| 216 | |
Luiz Capitulino | c86a668 | 2009-12-10 17:16:05 -0200 | [diff] [blame] | 217 | void do_info_migrate(Monitor *mon, QObject **ret_data) |
| 218 | { |
| 219 | QDict *qdict; |
aliguori | 5bb7910 | 2008-10-13 03:12:02 +0000 | [diff] [blame] | 220 | MigrationState *s = current_migration; |
aliguori | 376253e | 2009-03-05 23:01:23 +0000 | [diff] [blame] | 221 | |
aliguori | 5bb7910 | 2008-10-13 03:12:02 +0000 | [diff] [blame] | 222 | if (s) { |
aliguori | ff8d81d | 2008-10-24 22:10:31 +0000 | [diff] [blame] | 223 | switch (s->get_status(s)) { |
| 224 | case MIG_STATE_ACTIVE: |
Luiz Capitulino | c86a668 | 2009-12-10 17:16:05 -0200 | [diff] [blame] | 225 | qdict = qdict_new(); |
| 226 | qdict_put(qdict, "status", qstring_from_str("active")); |
| 227 | |
| 228 | migrate_put_status(qdict, "ram", ram_bytes_transferred(), |
| 229 | ram_bytes_remaining(), ram_bytes_total()); |
| 230 | |
Jan Kiszka | 25f2364 | 2009-11-30 18:21:21 +0100 | [diff] [blame] | 231 | if (blk_mig_active()) { |
Luiz Capitulino | c86a668 | 2009-12-10 17:16:05 -0200 | [diff] [blame] | 232 | migrate_put_status(qdict, "disk", blk_mig_bytes_transferred(), |
| 233 | blk_mig_bytes_remaining(), |
| 234 | blk_mig_bytes_total()); |
Jan Kiszka | 25f2364 | 2009-11-30 18:21:21 +0100 | [diff] [blame] | 235 | } |
Luiz Capitulino | c86a668 | 2009-12-10 17:16:05 -0200 | [diff] [blame] | 236 | |
| 237 | *ret_data = QOBJECT(qdict); |
aliguori | ff8d81d | 2008-10-24 22:10:31 +0000 | [diff] [blame] | 238 | break; |
| 239 | case MIG_STATE_COMPLETED: |
Luiz Capitulino | c86a668 | 2009-12-10 17:16:05 -0200 | [diff] [blame] | 240 | *ret_data = qobject_from_jsonf("{ 'status': 'completed' }"); |
aliguori | ff8d81d | 2008-10-24 22:10:31 +0000 | [diff] [blame] | 241 | break; |
| 242 | case MIG_STATE_ERROR: |
Luiz Capitulino | c86a668 | 2009-12-10 17:16:05 -0200 | [diff] [blame] | 243 | *ret_data = qobject_from_jsonf("{ 'status': 'failed' }"); |
aliguori | ff8d81d | 2008-10-24 22:10:31 +0000 | [diff] [blame] | 244 | break; |
| 245 | case MIG_STATE_CANCELLED: |
Luiz Capitulino | c86a668 | 2009-12-10 17:16:05 -0200 | [diff] [blame] | 246 | *ret_data = qobject_from_jsonf("{ 'status': 'cancelled' }"); |
aliguori | ff8d81d | 2008-10-24 22:10:31 +0000 | [diff] [blame] | 247 | break; |
| 248 | } |
aliguori | 5bb7910 | 2008-10-13 03:12:02 +0000 | [diff] [blame] | 249 | } |
| 250 | } |
| 251 | |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 252 | /* shared migration helpers */ |
| 253 | |
Jan Kiszka | f327aa0 | 2009-11-30 18:21:21 +0100 | [diff] [blame] | 254 | void migrate_fd_monitor_suspend(FdMigrationState *s, Monitor *mon) |
aliguori | 731b036 | 2009-03-05 23:01:42 +0000 | [diff] [blame] | 255 | { |
Jan Kiszka | f327aa0 | 2009-11-30 18:21:21 +0100 | [diff] [blame] | 256 | s->mon = mon; |
| 257 | if (monitor_suspend(mon) == 0) { |
malc | d0f2c4c | 2010-02-07 02:03:50 +0300 | [diff] [blame] | 258 | DPRINTF("suspending monitor\n"); |
Jan Kiszka | f327aa0 | 2009-11-30 18:21:21 +0100 | [diff] [blame] | 259 | } else { |
| 260 | monitor_printf(mon, "terminal does not allow synchronous " |
aliguori | cde76ee | 2009-03-05 23:01:51 +0000 | [diff] [blame] | 261 | "migration, continuing detached\n"); |
Jan Kiszka | f327aa0 | 2009-11-30 18:21:21 +0100 | [diff] [blame] | 262 | } |
aliguori | 731b036 | 2009-03-05 23:01:42 +0000 | [diff] [blame] | 263 | } |
| 264 | |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 265 | void migrate_fd_error(FdMigrationState *s) |
| 266 | { |
malc | d0f2c4c | 2010-02-07 02:03:50 +0300 | [diff] [blame] | 267 | DPRINTF("setting error state\n"); |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 268 | s->state = MIG_STATE_ERROR; |
| 269 | migrate_fd_cleanup(s); |
| 270 | } |
| 271 | |
Anthony Liguori | 41ef56e | 2010-06-02 14:55:25 -0500 | [diff] [blame] | 272 | int migrate_fd_cleanup(FdMigrationState *s) |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 273 | { |
Anthony Liguori | 41ef56e | 2010-06-02 14:55:25 -0500 | [diff] [blame] | 274 | int ret = 0; |
| 275 | |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 276 | qemu_set_fd_handler2(s->fd, NULL, NULL, NULL, NULL); |
| 277 | |
| 278 | if (s->file) { |
malc | d0f2c4c | 2010-02-07 02:03:50 +0300 | [diff] [blame] | 279 | DPRINTF("closing file\n"); |
Anthony Liguori | 41ef56e | 2010-06-02 14:55:25 -0500 | [diff] [blame] | 280 | if (qemu_fclose(s->file) != 0) { |
| 281 | ret = -1; |
| 282 | } |
Jan Kiszka | 5d39c79 | 2009-11-30 18:21:19 +0100 | [diff] [blame] | 283 | s->file = NULL; |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 284 | } |
| 285 | |
| 286 | if (s->fd != -1) |
| 287 | close(s->fd); |
| 288 | |
| 289 | /* Don't resume monitor until we've flushed all of the buffers */ |
Jan Kiszka | f327aa0 | 2009-11-30 18:21:21 +0100 | [diff] [blame] | 290 | if (s->mon) { |
| 291 | monitor_resume(s->mon); |
| 292 | } |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 293 | |
| 294 | s->fd = -1; |
Anthony Liguori | 41ef56e | 2010-06-02 14:55:25 -0500 | [diff] [blame] | 295 | |
| 296 | return ret; |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 297 | } |
| 298 | |
| 299 | void migrate_fd_put_notify(void *opaque) |
| 300 | { |
| 301 | FdMigrationState *s = opaque; |
| 302 | |
| 303 | qemu_set_fd_handler2(s->fd, NULL, NULL, NULL, NULL); |
| 304 | qemu_file_put_notify(s->file); |
| 305 | } |
| 306 | |
| 307 | ssize_t migrate_fd_put_buffer(void *opaque, const void *data, size_t size) |
| 308 | { |
| 309 | FdMigrationState *s = opaque; |
| 310 | ssize_t ret; |
| 311 | |
| 312 | do { |
| 313 | ret = s->write(s, data, size); |
Uri Lublin | 95b134e | 2009-05-19 14:08:53 +0300 | [diff] [blame] | 314 | } while (ret == -1 && ((s->get_error(s)) == EINTR)); |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 315 | |
| 316 | if (ret == -1) |
| 317 | ret = -(s->get_error(s)); |
| 318 | |
Marcelo Tosatti | e447b1a | 2010-08-19 10:18:39 -0300 | [diff] [blame^] | 319 | if (ret == -EAGAIN) { |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 320 | qemu_set_fd_handler2(s->fd, NULL, NULL, migrate_fd_put_notify, s); |
Marcelo Tosatti | e447b1a | 2010-08-19 10:18:39 -0300 | [diff] [blame^] | 321 | } else if (ret < 0) { |
| 322 | if (s->mon) { |
| 323 | monitor_resume(s->mon); |
| 324 | } |
| 325 | s->state = MIG_STATE_ERROR; |
| 326 | } |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 327 | |
| 328 | return ret; |
| 329 | } |
| 330 | |
| 331 | void migrate_fd_connect(FdMigrationState *s) |
| 332 | { |
| 333 | int ret; |
| 334 | |
| 335 | s->file = qemu_fopen_ops_buffered(s, |
| 336 | s->bandwidth_limit, |
| 337 | migrate_fd_put_buffer, |
| 338 | migrate_fd_put_ready, |
| 339 | migrate_fd_wait_for_unfreeze, |
| 340 | migrate_fd_close); |
| 341 | |
malc | d0f2c4c | 2010-02-07 02:03:50 +0300 | [diff] [blame] | 342 | DPRINTF("beginning savevm\n"); |
Jan Kiszka | f327aa0 | 2009-11-30 18:21:21 +0100 | [diff] [blame] | 343 | ret = qemu_savevm_state_begin(s->mon, s->file, s->mig_state.blk, |
lirans@il.ibm.com | c163b5c | 2009-11-02 15:40:58 +0200 | [diff] [blame] | 344 | s->mig_state.shared); |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 345 | if (ret < 0) { |
malc | d0f2c4c | 2010-02-07 02:03:50 +0300 | [diff] [blame] | 346 | DPRINTF("failed, %d\n", ret); |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 347 | migrate_fd_error(s); |
| 348 | return; |
| 349 | } |
lirans@il.ibm.com | c163b5c | 2009-11-02 15:40:58 +0200 | [diff] [blame] | 350 | |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 351 | migrate_fd_put_ready(s); |
| 352 | } |
| 353 | |
| 354 | void migrate_fd_put_ready(void *opaque) |
| 355 | { |
| 356 | FdMigrationState *s = opaque; |
| 357 | |
| 358 | if (s->state != MIG_STATE_ACTIVE) { |
malc | d0f2c4c | 2010-02-07 02:03:50 +0300 | [diff] [blame] | 359 | DPRINTF("put_ready returning because of non-active state\n"); |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 360 | return; |
| 361 | } |
| 362 | |
malc | d0f2c4c | 2010-02-07 02:03:50 +0300 | [diff] [blame] | 363 | DPRINTF("iterate\n"); |
Jan Kiszka | f327aa0 | 2009-11-30 18:21:21 +0100 | [diff] [blame] | 364 | if (qemu_savevm_state_iterate(s->mon, s->file) == 1) { |
aliguori | b161d12 | 2009-04-05 19:30:33 +0000 | [diff] [blame] | 365 | int state; |
Anthony Liguori | eeb34af | 2009-07-09 13:25:47 -0500 | [diff] [blame] | 366 | int old_vm_running = vm_running; |
| 367 | |
malc | d0f2c4c | 2010-02-07 02:03:50 +0300 | [diff] [blame] | 368 | DPRINTF("done iterating\n"); |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 369 | vm_stop(0); |
| 370 | |
Glauber Costa | 0884657 | 2009-07-06 09:32:09 -0400 | [diff] [blame] | 371 | qemu_aio_flush(); |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 372 | bdrv_flush_all(); |
Jan Kiszka | f327aa0 | 2009-11-30 18:21:21 +0100 | [diff] [blame] | 373 | if ((qemu_savevm_state_complete(s->mon, s->file)) < 0) { |
Anthony Liguori | eeb34af | 2009-07-09 13:25:47 -0500 | [diff] [blame] | 374 | if (old_vm_running) { |
| 375 | vm_start(); |
| 376 | } |
aliguori | b161d12 | 2009-04-05 19:30:33 +0000 | [diff] [blame] | 377 | state = MIG_STATE_ERROR; |
| 378 | } else { |
| 379 | state = MIG_STATE_COMPLETED; |
| 380 | } |
Anthony Liguori | 41ef56e | 2010-06-02 14:55:25 -0500 | [diff] [blame] | 381 | if (migrate_fd_cleanup(s) < 0) { |
| 382 | if (old_vm_running) { |
| 383 | vm_start(); |
| 384 | } |
| 385 | state = MIG_STATE_ERROR; |
| 386 | } |
aliguori | b161d12 | 2009-04-05 19:30:33 +0000 | [diff] [blame] | 387 | s->state = state; |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 388 | } |
| 389 | } |
| 390 | |
| 391 | int migrate_fd_get_status(MigrationState *mig_state) |
| 392 | { |
| 393 | FdMigrationState *s = migrate_to_fms(mig_state); |
| 394 | return s->state; |
| 395 | } |
| 396 | |
| 397 | void migrate_fd_cancel(MigrationState *mig_state) |
| 398 | { |
| 399 | FdMigrationState *s = migrate_to_fms(mig_state); |
| 400 | |
| 401 | if (s->state != MIG_STATE_ACTIVE) |
| 402 | return; |
| 403 | |
malc | d0f2c4c | 2010-02-07 02:03:50 +0300 | [diff] [blame] | 404 | DPRINTF("cancelling migration\n"); |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 405 | |
| 406 | s->state = MIG_STATE_CANCELLED; |
Jan Kiszka | f327aa0 | 2009-11-30 18:21:21 +0100 | [diff] [blame] | 407 | qemu_savevm_state_cancel(s->mon, s->file); |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 408 | |
| 409 | migrate_fd_cleanup(s); |
| 410 | } |
| 411 | |
| 412 | void migrate_fd_release(MigrationState *mig_state) |
| 413 | { |
| 414 | FdMigrationState *s = migrate_to_fms(mig_state); |
| 415 | |
malc | d0f2c4c | 2010-02-07 02:03:50 +0300 | [diff] [blame] | 416 | DPRINTF("releasing state\n"); |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 417 | |
| 418 | if (s->state == MIG_STATE_ACTIVE) { |
| 419 | s->state = MIG_STATE_CANCELLED; |
| 420 | migrate_fd_cleanup(s); |
| 421 | } |
Yoshiaki Tamura | faa1f8d | 2010-06-09 14:44:31 +0900 | [diff] [blame] | 422 | qemu_free(s); |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 423 | } |
| 424 | |
| 425 | void migrate_fd_wait_for_unfreeze(void *opaque) |
| 426 | { |
| 427 | FdMigrationState *s = opaque; |
| 428 | int ret; |
| 429 | |
malc | d0f2c4c | 2010-02-07 02:03:50 +0300 | [diff] [blame] | 430 | DPRINTF("wait for unfreeze\n"); |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 431 | if (s->state != MIG_STATE_ACTIVE) |
| 432 | return; |
| 433 | |
| 434 | do { |
| 435 | fd_set wfds; |
| 436 | |
| 437 | FD_ZERO(&wfds); |
| 438 | FD_SET(s->fd, &wfds); |
| 439 | |
| 440 | ret = select(s->fd + 1, NULL, &wfds, NULL, NULL); |
| 441 | } while (ret == -1 && (s->get_error(s)) == EINTR); |
| 442 | } |
| 443 | |
| 444 | int migrate_fd_close(void *opaque) |
| 445 | { |
| 446 | FdMigrationState *s = opaque; |
Uri Lublin | e19252d | 2009-06-08 14:28:01 +0300 | [diff] [blame] | 447 | |
| 448 | qemu_set_fd_handler2(s->fd, NULL, NULL, NULL, NULL); |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 449 | return s->close(s); |
| 450 | } |