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