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 | #ifndef QEMU_MIGRATION_H |
| 15 | #define QEMU_MIGRATION_H |
| 16 | |
Luiz Capitulino | f96fc8a | 2009-08-28 15:27:12 -0300 | [diff] [blame] | 17 | #include "qdict.h" |
aliguori | 376253e | 2009-03-05 23:01:23 +0000 | [diff] [blame] | 18 | #include "qemu-common.h" |
Gerd Hoffmann | 99a0db9 | 2010-12-13 17:30:12 +0100 | [diff] [blame] | 19 | #include "notify.h" |
aliguori | 376253e | 2009-03-05 23:01:23 +0000 | [diff] [blame] | 20 | |
aliguori | 5bb7910 | 2008-10-13 03:12:02 +0000 | [diff] [blame] | 21 | #define MIG_STATE_ERROR -1 |
| 22 | #define MIG_STATE_COMPLETED 0 |
| 23 | #define MIG_STATE_CANCELLED 1 |
| 24 | #define MIG_STATE_ACTIVE 2 |
| 25 | |
| 26 | typedef struct MigrationState MigrationState; |
| 27 | |
| 28 | struct MigrationState |
| 29 | { |
| 30 | /* FIXME: add more accessors to print migration info */ |
| 31 | void (*cancel)(MigrationState *s); |
| 32 | int (*get_status)(MigrationState *s); |
| 33 | void (*release)(MigrationState *s); |
lirans@il.ibm.com | c163b5c | 2009-11-02 15:40:58 +0200 | [diff] [blame] | 34 | int blk; |
| 35 | int shared; |
aliguori | 5bb7910 | 2008-10-13 03:12:02 +0000 | [diff] [blame] | 36 | }; |
| 37 | |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 38 | typedef struct FdMigrationState FdMigrationState; |
| 39 | |
| 40 | struct FdMigrationState |
| 41 | { |
| 42 | MigrationState mig_state; |
| 43 | int64_t bandwidth_limit; |
| 44 | QEMUFile *file; |
| 45 | int fd; |
Jan Kiszka | f327aa0 | 2009-11-30 18:21:21 +0100 | [diff] [blame] | 46 | Monitor *mon; |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 47 | int state; |
| 48 | int (*get_error)(struct FdMigrationState*); |
| 49 | int (*close)(struct FdMigrationState*); |
| 50 | int (*write)(struct FdMigrationState*, const void *, size_t); |
| 51 | void *opaque; |
| 52 | }; |
| 53 | |
Juan Quintela | 511c023 | 2010-06-09 14:10:55 +0200 | [diff] [blame] | 54 | void process_incoming_migration(QEMUFile *f); |
| 55 | |
Juan Quintela | 8ca5e80 | 2010-06-09 14:10:54 +0200 | [diff] [blame] | 56 | int qemu_start_incoming_migration(const char *uri); |
aliguori | 5bb7910 | 2008-10-13 03:12:02 +0000 | [diff] [blame] | 57 | |
Luiz Capitulino | b5d17ad | 2010-02-10 23:49:57 -0200 | [diff] [blame] | 58 | int do_migrate(Monitor *mon, const QDict *qdict, QObject **ret_data); |
aliguori | 5bb7910 | 2008-10-13 03:12:02 +0000 | [diff] [blame] | 59 | |
Luiz Capitulino | ef4b7ee | 2010-02-10 23:49:48 -0200 | [diff] [blame] | 60 | int do_migrate_cancel(Monitor *mon, const QDict *qdict, QObject **ret_data); |
aliguori | 5bb7910 | 2008-10-13 03:12:02 +0000 | [diff] [blame] | 61 | |
Luiz Capitulino | ef4b7ee | 2010-02-10 23:49:48 -0200 | [diff] [blame] | 62 | int do_migrate_set_speed(Monitor *mon, const QDict *qdict, QObject **ret_data); |
aliguori | 5bb7910 | 2008-10-13 03:12:02 +0000 | [diff] [blame] | 63 | |
Glauber Costa | a0a3fd6 | 2009-05-28 15:22:57 -0400 | [diff] [blame] | 64 | uint64_t migrate_max_downtime(void); |
| 65 | |
Luiz Capitulino | ef4b7ee | 2010-02-10 23:49:48 -0200 | [diff] [blame] | 66 | int do_migrate_set_downtime(Monitor *mon, const QDict *qdict, |
| 67 | QObject **ret_data); |
Glauber Costa | 2ea4295 | 2009-05-28 15:22:58 -0400 | [diff] [blame] | 68 | |
Luiz Capitulino | c86a668 | 2009-12-10 17:16:05 -0200 | [diff] [blame] | 69 | void do_info_migrate_print(Monitor *mon, const QObject *data); |
| 70 | |
| 71 | void do_info_migrate(Monitor *mon, QObject **ret_data); |
aliguori | 5bb7910 | 2008-10-13 03:12:02 +0000 | [diff] [blame] | 72 | |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 73 | int exec_start_incoming_migration(const char *host_port); |
| 74 | |
Jan Kiszka | f327aa0 | 2009-11-30 18:21:21 +0100 | [diff] [blame] | 75 | MigrationState *exec_start_outgoing_migration(Monitor *mon, |
| 76 | const char *host_port, |
lirans@il.ibm.com | c163b5c | 2009-11-02 15:40:58 +0200 | [diff] [blame] | 77 | int64_t bandwidth_limit, |
| 78 | int detach, |
| 79 | int blk, |
| 80 | int inc); |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 81 | |
aliguori | 34c9dd8 | 2008-10-13 03:14:31 +0000 | [diff] [blame] | 82 | int tcp_start_incoming_migration(const char *host_port); |
| 83 | |
Jan Kiszka | f327aa0 | 2009-11-30 18:21:21 +0100 | [diff] [blame] | 84 | MigrationState *tcp_start_outgoing_migration(Monitor *mon, |
| 85 | const char *host_port, |
aliguori | 34c9dd8 | 2008-10-13 03:14:31 +0000 | [diff] [blame] | 86 | int64_t bandwidth_limit, |
lirans@il.ibm.com | c163b5c | 2009-11-02 15:40:58 +0200 | [diff] [blame] | 87 | int detach, |
| 88 | int blk, |
| 89 | int inc); |
aliguori | 34c9dd8 | 2008-10-13 03:14:31 +0000 | [diff] [blame] | 90 | |
Chris Lalancette | 4951f65 | 2009-08-05 17:24:29 +0200 | [diff] [blame] | 91 | int unix_start_incoming_migration(const char *path); |
| 92 | |
Jan Kiszka | f327aa0 | 2009-11-30 18:21:21 +0100 | [diff] [blame] | 93 | MigrationState *unix_start_outgoing_migration(Monitor *mon, |
| 94 | const char *path, |
Chris Lalancette | 4951f65 | 2009-08-05 17:24:29 +0200 | [diff] [blame] | 95 | int64_t bandwidth_limit, |
lirans@il.ibm.com | c163b5c | 2009-11-02 15:40:58 +0200 | [diff] [blame] | 96 | int detach, |
| 97 | int blk, |
| 98 | int inc); |
Chris Lalancette | 4951f65 | 2009-08-05 17:24:29 +0200 | [diff] [blame] | 99 | |
Paolo Bonzini | 5ac1fad | 2009-08-18 15:56:25 +0200 | [diff] [blame] | 100 | int fd_start_incoming_migration(const char *path); |
| 101 | |
| 102 | MigrationState *fd_start_outgoing_migration(Monitor *mon, |
| 103 | const char *fdname, |
| 104 | int64_t bandwidth_limit, |
lirans@il.ibm.com | c163b5c | 2009-11-02 15:40:58 +0200 | [diff] [blame] | 105 | int detach, |
| 106 | int blk, |
| 107 | int inc); |
Paolo Bonzini | 5ac1fad | 2009-08-18 15:56:25 +0200 | [diff] [blame] | 108 | |
Jan Kiszka | f327aa0 | 2009-11-30 18:21:21 +0100 | [diff] [blame] | 109 | void migrate_fd_monitor_suspend(FdMigrationState *s, Monitor *mon); |
aliguori | 731b036 | 2009-03-05 23:01:42 +0000 | [diff] [blame] | 110 | |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 111 | void migrate_fd_error(FdMigrationState *s); |
| 112 | |
Anthony Liguori | 41ef56e | 2010-06-02 14:55:25 -0500 | [diff] [blame] | 113 | int migrate_fd_cleanup(FdMigrationState *s); |
aliguori | 065e281 | 2008-11-11 16:46:33 +0000 | [diff] [blame] | 114 | |
| 115 | void migrate_fd_put_notify(void *opaque); |
| 116 | |
| 117 | ssize_t migrate_fd_put_buffer(void *opaque, const void *data, size_t size); |
| 118 | |
| 119 | void migrate_fd_connect(FdMigrationState *s); |
| 120 | |
| 121 | void migrate_fd_put_ready(void *opaque); |
| 122 | |
| 123 | int migrate_fd_get_status(MigrationState *mig_state); |
| 124 | |
| 125 | void migrate_fd_cancel(MigrationState *mig_state); |
| 126 | |
| 127 | void migrate_fd_release(MigrationState *mig_state); |
| 128 | |
| 129 | void migrate_fd_wait_for_unfreeze(void *opaque); |
| 130 | |
| 131 | int migrate_fd_close(void *opaque); |
| 132 | |
| 133 | static inline FdMigrationState *migrate_to_fms(MigrationState *mig_state) |
| 134 | { |
| 135 | return container_of(mig_state, FdMigrationState, mig_state); |
| 136 | } |
| 137 | |
Gerd Hoffmann | 99a0db9 | 2010-12-13 17:30:12 +0100 | [diff] [blame] | 138 | void add_migration_state_change_notifier(Notifier *notify); |
| 139 | void remove_migration_state_change_notifier(Notifier *notify); |
| 140 | int get_migration_state(void); |
| 141 | |
aliguori | 5bb7910 | 2008-10-13 03:12:02 +0000 | [diff] [blame] | 142 | #endif |