]>
Commit | Line | Data |
---|---|---|
5bb7910a AL |
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 | ||
7b1b5d19 | 17 | #include "qapi/qmp/qdict.h" |
376253ec | 18 | #include "qemu-common.h" |
9848a404 | 19 | #include "qemu/thread.h" |
1de7afc9 | 20 | #include "qemu/notify.h" |
7b1b5d19 | 21 | #include "qapi/error.h" |
caf71f86 | 22 | #include "migration/vmstate.h" |
bbf6da32 | 23 | #include "qapi-types.h" |
376253ec | 24 | |
6607ae23 IY |
25 | struct MigrationParams { |
26 | bool blk; | |
27 | bool shared; | |
28 | }; | |
29 | ||
22f00a44 | 30 | typedef struct MigrationState MigrationState; |
dc7acc61 | 31 | |
22f00a44 | 32 | struct MigrationState |
065e2813 | 33 | { |
065e2813 | 34 | int64_t bandwidth_limit; |
9848a404 JQ |
35 | size_t bytes_xfer; |
36 | size_t xfer_limit; | |
9848a404 | 37 | QemuThread thread; |
bb1fadc4 | 38 | QEMUBH *cleanup_bh; |
065e2813 | 39 | QEMUFile *file; |
f8bbc128 | 40 | |
f8bbc128 | 41 | int state; |
6607ae23 | 42 | MigrationParams params; |
7e114f8c | 43 | double mbps; |
d5f8a570 | 44 | int64_t total_time; |
9c5a9fcf | 45 | int64_t downtime; |
2c52ddf1 | 46 | int64_t expected_downtime; |
8d017193 | 47 | int64_t dirty_pages_rate; |
90f8ae72 | 48 | int64_t dirty_bytes_rate; |
bbf6da32 | 49 | bool enabled_capabilities[MIGRATION_CAPABILITY_MAX]; |
17ad9b35 | 50 | int64_t xbzrle_cache_size; |
065e2813 AL |
51 | }; |
52 | ||
511c0231 JQ |
53 | void process_incoming_migration(QEMUFile *f); |
54 | ||
43eaae28 | 55 | void qemu_start_incoming_migration(const char *uri, Error **errp); |
5bb7910a | 56 | |
a0a3fd60 GC |
57 | uint64_t migrate_max_downtime(void); |
58 | ||
c86a6683 LC |
59 | void do_info_migrate_print(Monitor *mon, const QObject *data); |
60 | ||
61 | void do_info_migrate(Monitor *mon, QObject **ret_data); | |
5bb7910a | 62 | |
43eaae28 | 63 | void exec_start_incoming_migration(const char *host_port, Error **errp); |
065e2813 | 64 | |
f37afb5a | 65 | void exec_start_outgoing_migration(MigrationState *s, const char *host_port, Error **errp); |
065e2813 | 66 | |
43eaae28 | 67 | void tcp_start_incoming_migration(const char *host_port, Error **errp); |
34c9dd8e | 68 | |
f37afb5a | 69 | void tcp_start_outgoing_migration(MigrationState *s, const char *host_port, Error **errp); |
34c9dd8e | 70 | |
43eaae28 | 71 | void unix_start_incoming_migration(const char *path, Error **errp); |
4951f65b | 72 | |
f37afb5a | 73 | void unix_start_outgoing_migration(MigrationState *s, const char *path, Error **errp); |
4951f65b | 74 | |
43eaae28 | 75 | void fd_start_incoming_migration(const char *path, Error **errp); |
5ac1fad3 | 76 | |
f37afb5a | 77 | void fd_start_outgoing_migration(MigrationState *s, const char *fdname, Error **errp); |
5ac1fad3 | 78 | |
22f00a44 | 79 | void migrate_fd_error(MigrationState *s); |
065e2813 | 80 | |
22f00a44 | 81 | void migrate_fd_connect(MigrationState *s); |
065e2813 | 82 | |
11c76741 | 83 | int migrate_fd_close(MigrationState *s); |
c87b015b | 84 | |
99a0db9b GH |
85 | void add_migration_state_change_notifier(Notifier *notify); |
86 | void remove_migration_state_change_notifier(Notifier *notify); | |
afe2df69 | 87 | bool migration_is_active(MigrationState *); |
7073693b | 88 | bool migration_has_finished(MigrationState *); |
afe2df69 | 89 | bool migration_has_failed(MigrationState *); |
859bc756 | 90 | MigrationState *migrate_get_current(void); |
99a0db9b | 91 | |
adc56dda BS |
92 | uint64_t ram_bytes_remaining(void); |
93 | uint64_t ram_bytes_transferred(void); | |
94 | uint64_t ram_bytes_total(void); | |
95 | ||
2b0ce079 MH |
96 | void acct_update_position(QEMUFile *f, size_t size, bool zero); |
97 | ||
7908c78d | 98 | extern SaveVMHandlers savevm_ram_handlers; |
adc56dda | 99 | |
004d4c10 OW |
100 | uint64_t dup_mig_bytes_transferred(void); |
101 | uint64_t dup_mig_pages_transferred(void); | |
f1c72795 PL |
102 | uint64_t skipped_mig_bytes_transferred(void); |
103 | uint64_t skipped_mig_pages_transferred(void); | |
004d4c10 OW |
104 | uint64_t norm_mig_bytes_transferred(void); |
105 | uint64_t norm_mig_pages_transferred(void); | |
f36d55af OW |
106 | uint64_t xbzrle_mig_bytes_transferred(void); |
107 | uint64_t xbzrle_mig_pages_transferred(void); | |
108 | uint64_t xbzrle_mig_pages_overflow(void); | |
109 | uint64_t xbzrle_mig_pages_cache_miss(void); | |
004d4c10 | 110 | |
fa2756b7 AL |
111 | /** |
112 | * @migrate_add_blocker - prevent migration from proceeding | |
113 | * | |
114 | * @reason - an error to be returned whenever migration is attempted | |
115 | */ | |
116 | void migrate_add_blocker(Error *reason); | |
117 | ||
118 | /** | |
119 | * @migrate_del_blocker - remove a blocking error from migration | |
120 | * | |
121 | * @reason - the error blocking migration | |
122 | */ | |
123 | void migrate_del_blocker(Error *reason); | |
124 | ||
302dfbeb OW |
125 | int xbzrle_encode_buffer(uint8_t *old_buf, uint8_t *new_buf, int slen, |
126 | uint8_t *dst, int dlen); | |
127 | int xbzrle_decode_buffer(uint8_t *src, int slen, uint8_t *dst, int dlen); | |
128 | ||
17ad9b35 OW |
129 | int migrate_use_xbzrle(void); |
130 | int64_t migrate_xbzrle_cache_size(void); | |
131 | ||
9e1ba4cc | 132 | int64_t xbzrle_cache_resize(int64_t new_size); |
5bb7910a | 133 | #endif |