4 * Copyright IBM, Corp. 2008
7 * Anthony Liguori <aliguori@us.ibm.com>
9 * This work is licensed under the terms of the GNU GPL, version 2. See
10 * the COPYING file in the top-level directory.
14 #ifndef QEMU_MIGRATION_H
15 #define QEMU_MIGRATION_H
18 #include "qemu-common.h"
21 #define MIG_STATE_ERROR -1
22 #define MIG_STATE_COMPLETED 0
23 #define MIG_STATE_CANCELLED 1
24 #define MIG_STATE_ACTIVE 2
26 typedef struct FdMigrationState FdMigrationState
;
28 struct FdMigrationState
30 int64_t bandwidth_limit
;
35 int (*get_error
)(struct FdMigrationState
*);
36 int (*close
)(struct FdMigrationState
*);
37 int (*write
)(struct FdMigrationState
*, const void *, size_t);
38 void (*cancel
)(FdMigrationState
*s
);
39 int (*get_status
)(FdMigrationState
*s
);
40 void (*release
)(FdMigrationState
*s
);
46 void process_incoming_migration(QEMUFile
*f
);
48 int qemu_start_incoming_migration(const char *uri
);
50 int do_migrate(Monitor
*mon
, const QDict
*qdict
, QObject
**ret_data
);
52 int do_migrate_cancel(Monitor
*mon
, const QDict
*qdict
, QObject
**ret_data
);
54 int do_migrate_set_speed(Monitor
*mon
, const QDict
*qdict
, QObject
**ret_data
);
56 uint64_t migrate_max_downtime(void);
58 int do_migrate_set_downtime(Monitor
*mon
, const QDict
*qdict
,
61 void do_info_migrate_print(Monitor
*mon
, const QObject
*data
);
63 void do_info_migrate(Monitor
*mon
, QObject
**ret_data
);
65 int exec_start_incoming_migration(const char *host_port
);
67 FdMigrationState
*exec_start_outgoing_migration(Monitor
*mon
,
68 const char *host_port
,
69 int64_t bandwidth_limit
,
74 int tcp_start_incoming_migration(const char *host_port
);
76 FdMigrationState
*tcp_start_outgoing_migration(Monitor
*mon
,
77 const char *host_port
,
78 int64_t bandwidth_limit
,
83 int unix_start_incoming_migration(const char *path
);
85 FdMigrationState
*unix_start_outgoing_migration(Monitor
*mon
,
87 int64_t bandwidth_limit
,
92 int fd_start_incoming_migration(const char *path
);
94 FdMigrationState
*fd_start_outgoing_migration(Monitor
*mon
,
96 int64_t bandwidth_limit
,
101 void migrate_fd_monitor_suspend(FdMigrationState
*s
, Monitor
*mon
);
103 void migrate_fd_error(FdMigrationState
*s
);
105 int migrate_fd_cleanup(FdMigrationState
*s
);
107 void migrate_fd_put_notify(void *opaque
);
109 ssize_t
migrate_fd_put_buffer(void *opaque
, const void *data
, size_t size
);
111 void migrate_fd_connect(FdMigrationState
*s
);
113 void migrate_fd_put_ready(void *opaque
);
115 int migrate_fd_get_status(FdMigrationState
*mig_state
);
117 void migrate_fd_cancel(FdMigrationState
*mig_state
);
119 void migrate_fd_release(FdMigrationState
*mig_state
);
121 void migrate_fd_wait_for_unfreeze(void *opaque
);
123 int migrate_fd_close(void *opaque
);
125 void add_migration_state_change_notifier(Notifier
*notify
);
126 void remove_migration_state_change_notifier(Notifier
*notify
);
127 int get_migration_state(void);
129 uint64_t ram_bytes_remaining(void);
130 uint64_t ram_bytes_transferred(void);
131 uint64_t ram_bytes_total(void);
133 int ram_save_live(Monitor
*mon
, QEMUFile
*f
, int stage
, void *opaque
);
134 int ram_load(QEMUFile
*f
, void *opaque
, int version_id
);
136 extern int incoming_expected
;