1
2
3
4
5
6
7
8
9
10
11
12
13
14#ifndef QEMU_MIGRATION_H
15#define QEMU_MIGRATION_H
16
17#include "qemu-common.h"
18#include "qemu/thread.h"
19#include "qapi-types.h"
20#include "exec/cpu-common.h"
21#include "qemu/coroutine_int.h"
22#include "hw/qdev.h"
23
24
25struct MigrationIncomingState {
26 QEMUFile *from_src_file;
27
28
29
30
31
32 QemuEvent main_thread_load_event;
33
34 size_t largest_page_size;
35 bool have_fault_thread;
36 QemuThread fault_thread;
37 QemuSemaphore fault_thread_sem;
38
39 bool have_listen_thread;
40 QemuThread listen_thread;
41 QemuSemaphore listen_thread_sem;
42
43
44 int userfault_fd;
45
46 int userfault_quit_fd;
47 QEMUFile *to_src_file;
48 QemuMutex rp_mutex;
49 void *postcopy_tmp_page;
50 void *postcopy_tmp_zero_page;
51
52 QEMUBH *bh;
53
54 int state;
55
56 bool have_colo_incoming_thread;
57 QemuThread colo_incoming_thread;
58
59 Coroutine *migration_incoming_co;
60 QemuSemaphore colo_incoming_sem;
61};
62
63MigrationIncomingState *migration_incoming_get_current(void);
64void migration_incoming_state_destroy(void);
65
66#define TYPE_MIGRATION "migration"
67
68#define MIGRATION_CLASS(klass) \
69 OBJECT_CLASS_CHECK(MigrationClass, (klass), TYPE_MIGRATION)
70#define MIGRATION_OBJ(obj) \
71 OBJECT_CHECK(MigrationState, (obj), TYPE_MIGRATION)
72#define MIGRATION_GET_CLASS(obj) \
73 OBJECT_GET_CLASS(MigrationClass, (obj), TYPE_MIGRATION)
74
75typedef struct MigrationClass {
76
77 DeviceClass parent_class;
78} MigrationClass;
79
80struct MigrationState
81{
82
83 DeviceState parent_obj;
84
85
86 size_t bytes_xfer;
87 size_t xfer_limit;
88 QemuThread thread;
89 QEMUBH *cleanup_bh;
90 QEMUFile *to_dst_file;
91
92
93 MigrationParameters parameters;
94
95 int state;
96
97
98 struct {
99 QEMUFile *from_dst_file;
100 QemuThread rp_thread;
101 bool error;
102 } rp_state;
103
104 double mbps;
105 int64_t total_time;
106 int64_t downtime;
107 int64_t expected_downtime;
108 bool enabled_capabilities[MIGRATION_CAPABILITY__MAX];
109 int64_t xbzrle_cache_size;
110 int64_t setup_time;
111
112
113 bool start_postcopy;
114
115 bool postcopy_after_devices;
116
117
118 bool migration_thread_running;
119
120
121 bool block_inactive;
122
123
124 QemuSemaphore colo_exit_sem;
125
126
127 QemuSemaphore colo_checkpoint_sem;
128 int64_t colo_checkpoint_time;
129 QEMUTimer *colo_delay_timer;
130
131
132 Error *error;
133
134
135 bool must_remove_block_options;
136
137
138
139
140
141 bool store_global_state;
142
143
144 bool only_migratable;
145
146
147 bool send_configuration;
148
149 bool send_section_footer;
150};
151
152void migrate_set_state(int *state, int old_state, int new_state);
153
154void migration_fd_process_incoming(QEMUFile *f);
155
156uint64_t migrate_max_downtime(void);
157
158void migrate_fd_error(MigrationState *s, const Error *error);
159
160void migrate_fd_connect(MigrationState *s);
161
162MigrationState *migrate_init(void);
163bool migration_is_blocked(Error **errp);
164
165bool migration_in_postcopy(void);
166MigrationState *migrate_get_current(void);
167
168bool migrate_release_ram(void);
169bool migrate_postcopy_ram(void);
170bool migrate_zero_blocks(void);
171
172bool migrate_auto_converge(void);
173
174int migrate_use_xbzrle(void);
175int64_t migrate_xbzrle_cache_size(void);
176bool migrate_colo_enabled(void);
177
178bool migrate_use_block(void);
179bool migrate_use_block_incremental(void);
180bool migrate_use_return_path(void);
181
182bool migrate_use_compression(void);
183int migrate_compress_level(void);
184int migrate_compress_threads(void);
185int migrate_decompress_threads(void);
186bool migrate_use_events(void);
187
188
189void migrate_send_rp_shut(MigrationIncomingState *mis,
190 uint32_t value);
191void migrate_send_rp_pong(MigrationIncomingState *mis,
192 uint32_t value);
193void migrate_send_rp_req_pages(MigrationIncomingState *mis, const char* rbname,
194 ram_addr_t start, size_t len);
195
196#endif
197