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