2011/2/23 Juan Quintela <quint...@redhat.com>:
> Signed-off-by: Juan Quintela <quint...@redhat.com>
> ---
> migration-exec.c | 10 +++++-----
> migration-fd.c | 10 +++++-----
> migration-tcp.c | 10 +++++-----
> migration-unix.c | 10 +++++-----
> migration.c | 11 +++++------
> migration.h | 23 +++++------------------
> 6 files changed, 30 insertions(+), 44 deletions(-)
>
> diff --git a/migration-exec.c b/migration-exec.c
> index b49a475..02b0667 100644
> --- a/migration-exec.c
> +++ b/migration-exec.c
> @@ -93,12 +93,12 @@ FdMigrationState *exec_start_outgoing_migration(Monitor
> *mon,
> s->close = exec_close;
> s->get_error = file_errno;
> s->write = file_write;
> - s->mig_state.cancel = migrate_fd_cancel;
> - s->mig_state.get_status = migrate_fd_get_status;
> - s->mig_state.release = migrate_fd_release;
> + s->cancel = migrate_fd_cancel;
> + s->get_status = migrate_fd_get_status;
> + s->release = migrate_fd_release;
>
> - s->mig_state.blk = blk;
> - s->mig_state.shared = inc;
> + s->blk = blk;
> + s->shared = inc;
>
> s->state = MIG_STATE_ACTIVE;
> s->mon = NULL;
> diff --git a/migration-fd.c b/migration-fd.c
> index bd5e8a9..ccba86b 100644
> --- a/migration-fd.c
> +++ b/migration-fd.c
> @@ -76,12 +76,12 @@ FdMigrationState *fd_start_outgoing_migration(Monitor
> *mon,
> s->get_error = fd_errno;
> s->write = fd_write;
> s->close = fd_close;
> - s->mig_state.cancel = migrate_fd_cancel;
> - s->mig_state.get_status = migrate_fd_get_status;
> - s->mig_state.release = migrate_fd_release;
> + s->cancel = migrate_fd_cancel;
> + s->get_status = migrate_fd_get_status;
> + s->release = migrate_fd_release;
>
> - s->mig_state.blk = blk;
> - s->mig_state.shared = inc;
> + s->blk = blk;
> + s->shared = inc;
>
> s->state = MIG_STATE_ACTIVE;
> s->mon = NULL;
> diff --git a/migration-tcp.c b/migration-tcp.c
> index 355bc37..02b01ed 100644
> --- a/migration-tcp.c
> +++ b/migration-tcp.c
> @@ -95,12 +95,12 @@ FdMigrationState *tcp_start_outgoing_migration(Monitor
> *mon,
> s->get_error = socket_errno;
> s->write = socket_write;
> s->close = tcp_close;
> - s->mig_state.cancel = migrate_fd_cancel;
> - s->mig_state.get_status = migrate_fd_get_status;
> - s->mig_state.release = migrate_fd_release;
> + s->cancel = migrate_fd_cancel;
> + s->get_status = migrate_fd_get_status;
> + s->release = migrate_fd_release;
>
> - s->mig_state.blk = blk;
> - s->mig_state.shared = inc;
> + s->blk = blk;
> + s->shared = inc;
>
> s->state = MIG_STATE_ACTIVE;
> s->mon = NULL;
> diff --git a/migration-unix.c b/migration-unix.c
> index b9b0dbf..fb73f46 100644
> --- a/migration-unix.c
> +++ b/migration-unix.c
> @@ -94,12 +94,12 @@ FdMigrationState *unix_start_outgoing_migration(Monitor
> *mon,
> s->get_error = unix_errno;
> s->write = unix_write;
> s->close = unix_close;
> - s->mig_state.cancel = migrate_fd_cancel;
> - s->mig_state.get_status = migrate_fd_get_status;
> - s->mig_state.release = migrate_fd_release;
> + s->cancel = migrate_fd_cancel;
> + s->get_status = migrate_fd_get_status;
> + s->release = migrate_fd_release;
>
> - s->mig_state.blk = blk;
> - s->mig_state.shared = inc;
> + s->blk = blk;
> + s->shared = inc;
>
> s->state = MIG_STATE_ACTIVE;
> s->mon = NULL;
> diff --git a/migration.c b/migration.c
> index 3a371a3..dd4cdab 100644
> --- a/migration.c
> +++ b/migration.c
> @@ -86,7 +86,7 @@ int do_migrate(Monitor *mon, const QDict *qdict, QObject
> **ret_data)
> const char *uri = qdict_get_str(qdict, "uri");
>
> if (current_migration &&
> - current_migration->mig_state.get_status(current_migration) ==
> MIG_STATE_ACTIVE) {
> + current_migration->get_status(current_migration) ==
> MIG_STATE_ACTIVE) {
> monitor_printf(mon, "migration already in progress\n");
> return -1;
> }
> @@ -120,7 +120,7 @@ int do_migrate(Monitor *mon, const QDict *qdict, QObject
> **ret_data)
> }
>
> if (current_migration) {
> - current_migration->mig_state.release(current_migration);
> + current_migration->release(current_migration);
> }
>
> current_migration = s;
> @@ -133,7 +133,7 @@ int do_migrate_cancel(Monitor *mon, const QDict *qdict,
> QObject **ret_data)
> FdMigrationState *s = current_migration;
>
> if (s)
> - s->mig_state.cancel(s);
> + s->cancel(s);
>
> return 0;
> }
> @@ -229,7 +229,7 @@ void do_info_migrate(Monitor *mon, QObject **ret_data)
> QDict *qdict;
>
> if (current_migration) {
> - MigrationState *s = ¤t_migration->mig_state;
> + FdMigrationState *s = current_migration;
>
> switch (s->get_status(current_migration)) {
> case MIG_STATE_ACTIVE:
> @@ -353,8 +353,7 @@ void migrate_fd_connect(FdMigrationState *s)
> migrate_fd_close);
>
> DPRINTF("beginning savevm\n");
> - ret = qemu_savevm_state_begin(s->mon, s->file, s->mig_state.blk,
> - s->mig_state.shared);
> + ret = qemu_savevm_state_begin(s->mon, s->file, s->blk, s->shared);
> if (ret < 0) {
> DPRINTF("failed, %d\n", ret);
> migrate_fd_error(s);
> diff --git a/migration.h b/migration.h
> index f49a9e2..93441e4 100644
> --- a/migration.h
> +++ b/migration.h
> @@ -23,23 +23,10 @@
> #define MIG_STATE_CANCELLED 1
> #define MIG_STATE_ACTIVE 2
>
> -typedef struct MigrationState MigrationState;
> -
> typedef struct FdMigrationState FdMigrationState;
>
> -struct MigrationState
> -{
> - /* FIXME: add more accessors to print migration info */
> - void (*cancel)(FdMigrationState *s);
> - int (*get_status)(FdMigrationState *s);
> - void (*release)(FdMigrationState *s);
> - int blk;
> - int shared;
> -};
> -
> struct FdMigrationState
> {
> - MigrationState mig_state;
> int64_t bandwidth_limit;
> QEMUFile *file;
> int fd;
> @@ -48,7 +35,12 @@ struct FdMigrationState
> int (*get_error)(struct FdMigrationState*);
> int (*close)(struct FdMigrationState*);
> int (*write)(struct FdMigrationState*, const void *, size_t);
> + void (*cancel)(FdMigrationState *s);
> + int (*get_status)(FdMigrationState *s);
> + void (*release)(FdMigrationState *s);
> void *opaque;
> + int blk;
> + int shared;
> };
Although I don't have objections for folding MigrationState into
FdMigrationState, it would be good to ask why the original author
split it intentionally.
Thanks,
Yoshi
>
> void process_incoming_migration(QEMUFile *f);
> @@ -130,11 +122,6 @@ void migrate_fd_wait_for_unfreeze(void *opaque);
>
> int migrate_fd_close(void *opaque);
>
> -static inline FdMigrationState *migrate_to_fms(MigrationState *mig_state)
> -{
> - return container_of(mig_state, FdMigrationState, mig_state);
> -}
> -
> void add_migration_state_change_notifier(Notifier *notify);
> void remove_migration_state_change_notifier(Notifier *notify);
> int get_migration_state(void);
> --
> 1.7.4
>
>
>
