]>
Commit | Line | Data |
---|---|---|
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 | ||
17 | #include "qdict.h" | |
18 | #include "qemu-common.h" | |
19 | #include "notify.h" | |
20 | ||
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); | |
34 | int blk; | |
35 | int shared; | |
36 | }; | |
37 | ||
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; | |
46 | Monitor *mon; | |
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 | ||
54 | void process_incoming_migration(QEMUFile *f); | |
55 | ||
56 | int qemu_start_incoming_migration(const char *uri); | |
57 | ||
58 | int do_migrate(Monitor *mon, const QDict *qdict, QObject **ret_data); | |
59 | ||
60 | int do_migrate_cancel(Monitor *mon, const QDict *qdict, QObject **ret_data); | |
61 | ||
62 | int do_migrate_set_speed(Monitor *mon, const QDict *qdict, QObject **ret_data); | |
63 | ||
64 | uint64_t migrate_max_downtime(void); | |
65 | ||
66 | int do_migrate_set_downtime(Monitor *mon, const QDict *qdict, | |
67 | QObject **ret_data); | |
68 | ||
69 | void do_info_migrate_print(Monitor *mon, const QObject *data); | |
70 | ||
71 | void do_info_migrate(Monitor *mon, QObject **ret_data); | |
72 | ||
73 | int exec_start_incoming_migration(const char *host_port); | |
74 | ||
75 | MigrationState *exec_start_outgoing_migration(Monitor *mon, | |
76 | const char *host_port, | |
77 | int64_t bandwidth_limit, | |
78 | int detach, | |
79 | int blk, | |
80 | int inc); | |
81 | ||
82 | int tcp_start_incoming_migration(const char *host_port); | |
83 | ||
84 | MigrationState *tcp_start_outgoing_migration(Monitor *mon, | |
85 | const char *host_port, | |
86 | int64_t bandwidth_limit, | |
87 | int detach, | |
88 | int blk, | |
89 | int inc); | |
90 | ||
91 | int unix_start_incoming_migration(const char *path); | |
92 | ||
93 | MigrationState *unix_start_outgoing_migration(Monitor *mon, | |
94 | const char *path, | |
95 | int64_t bandwidth_limit, | |
96 | int detach, | |
97 | int blk, | |
98 | int inc); | |
99 | ||
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, | |
105 | int detach, | |
106 | int blk, | |
107 | int inc); | |
108 | ||
109 | void migrate_fd_monitor_suspend(FdMigrationState *s, Monitor *mon); | |
110 | ||
111 | void migrate_fd_error(FdMigrationState *s); | |
112 | ||
113 | int migrate_fd_cleanup(FdMigrationState *s); | |
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 | ||
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 | ||
142 | #endif |