migration.h

   1 /*
   2  * QEMU live migration
   3  *
   4  * Copyright IBM, Corp. 2008
   5  *
   6  * Authors:
   7  *  Anthony Liguori   <[email protected]>
   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     int64_t bandwidth_limit;
  31     QEMUFile *file;
  32     int fd;
  33     Monitor *mon;
  34     int state;
  35     int (*get_error)(MigrationState *s);
  36     int (*close)(MigrationState *s);
  37     int (*write)(MigrationState *s, const void *buff, size_t size);
  38     void (*cancel)(MigrationState *s);
  39     int (*get_status)(MigrationState *s);
  40     void (*release)(MigrationState *s);
  41     void *opaque;
  42     int blk;
  43     int shared;
  44 };
  45
  46 void process_incoming_migration(QEMUFile *f);
  47
  48 int qemu_start_incoming_migration(const char *uri);
  49
  50 int do_migrate(Monitor *mon, const QDict *qdict, QObject **ret_data);
  51
  52 int do_migrate_cancel(Monitor *mon, const QDict *qdict, QObject **ret_data);
  53
  54 int do_migrate_set_speed(Monitor *mon, const QDict *qdict, QObject **ret_data);
  55
  56 uint64_t migrate_max_downtime(void);
  57
  58 int do_migrate_set_downtime(Monitor *mon, const QDict *qdict,
  59                             QObject **ret_data);
  60
  61 void do_info_migrate_print(Monitor *mon, const QObject *data);
  62
  63 void do_info_migrate(Monitor *mon, QObject **ret_data);
  64
  65 int exec_start_incoming_migration(const char *host_port);
  66
  67 int exec_start_outgoing_migration(MigrationState *s, const char *host_port);
  68
  69 int tcp_start_incoming_migration(const char *host_port);
  70
  71 int tcp_start_outgoing_migration(MigrationState *s, const char *host_port);
  72
  73 int unix_start_incoming_migration(const char *path);
  74
  75 int unix_start_outgoing_migration(MigrationState *s, const char *path);
  76
  77 int fd_start_incoming_migration(const char *path);
  78
  79 int fd_start_outgoing_migration(MigrationState *s, const char *fdname);
  80
  81 void migrate_fd_error(MigrationState *s);
  82
  83 void migrate_fd_connect(MigrationState *s);
  84
  85 void add_migration_state_change_notifier(Notifier *notify);
  86 void remove_migration_state_change_notifier(Notifier *notify);
  87 int get_migration_state(void);
  88
  89 uint64_t ram_bytes_remaining(void);
  90 uint64_t ram_bytes_transferred(void);
  91 uint64_t ram_bytes_total(void);
  92
  93 int ram_save_live(Monitor *mon, QEMUFile *f, int stage, void *opaque);
  94 int ram_load(QEMUFile *f, void *opaque, int version_id);
  95
  96 extern int incoming_expected;
  97
  98 #endif