pet...@redhat.com writes:
> From: Peter Xu <pet...@redhat.com>
>
> Most of the multifd code uses send/recv to represent the two sides, but
> some rare cases use save/load.
>
> Since send/recv is the majority, replacing the save/load use cases to use
> send/recv globally. Now we reach a consensus on the naming.
>
> Signed-off-by: Peter Xu <pet...@redhat.com>
Good!
Reviewed-by: Fabiano Rosas <faro...@suse.de>
> ---
> migration/multifd.h | 10 +++++-----
> migration/migration.c | 12 ++++++------
> migration/multifd.c | 10 +++++-----
> 3 files changed, 16 insertions(+), 16 deletions(-)
>
> diff --git a/migration/multifd.h b/migration/multifd.h
> index a320c53a6f..9b40a53cb6 100644
> --- a/migration/multifd.h
> +++ b/migration/multifd.h
> @@ -13,11 +13,11 @@
> #ifndef QEMU_MIGRATION_MULTIFD_H
> #define QEMU_MIGRATION_MULTIFD_H
>
> -int multifd_save_setup(Error **errp);
> -void multifd_save_cleanup(void);
> -int multifd_load_setup(Error **errp);
> -void multifd_load_cleanup(void);
> -void multifd_load_shutdown(void);
> +int multifd_send_setup(Error **errp);
> +void multifd_send_shutdown(void);
> +int multifd_recv_setup(Error **errp);
> +void multifd_recv_cleanup(void);
> +void multifd_recv_shutdown(void);
> bool multifd_recv_all_channels_created(void);
> void multifd_recv_new_channel(QIOChannel *ioc, Error **errp);
> void multifd_recv_sync_main(void);
> diff --git a/migration/migration.c b/migration/migration.c
> index d5f705ceef..ba99772e76 100644
> --- a/migration/migration.c
> +++ b/migration/migration.c
> @@ -311,7 +311,7 @@ void migration_incoming_state_destroy(void)
> {
> struct MigrationIncomingState *mis = migration_incoming_get_current();
>
> - multifd_load_cleanup();
> + multifd_recv_cleanup();
> compress_threads_load_cleanup();
>
> if (mis->to_src_file) {
> @@ -662,7 +662,7 @@ static void process_incoming_migration_bh(void *opaque)
>
> trace_vmstate_downtime_checkpoint("dst-precopy-bh-announced");
>
> - multifd_load_shutdown();
> + multifd_recv_shutdown();
>
> dirty_bitmap_mig_before_vm_start();
>
> @@ -759,7 +759,7 @@ fail:
> MIGRATION_STATUS_FAILED);
> qemu_fclose(mis->from_src_file);
>
> - multifd_load_cleanup();
> + multifd_recv_cleanup();
> compress_threads_load_cleanup();
>
> exit(EXIT_FAILURE);
> @@ -885,7 +885,7 @@ void migration_ioc_process_incoming(QIOChannel *ioc,
> Error **errp)
> default_channel = !mis->from_src_file;
> }
>
> - if (multifd_load_setup(errp) != 0) {
> + if (multifd_recv_setup(errp) != 0) {
> return;
> }
>
> @@ -1331,7 +1331,7 @@ static void migrate_fd_cleanup(MigrationState *s)
> }
> bql_lock();
>
> - multifd_save_cleanup();
> + multifd_send_shutdown();
> qemu_mutex_lock(&s->qemu_file_lock);
> tmp = s->to_dst_file;
> s->to_dst_file = NULL;
> @@ -3623,7 +3623,7 @@ void migrate_fd_connect(MigrationState *s, Error
> *error_in)
> return;
> }
>
> - if (multifd_save_setup(&local_err) != 0) {
> + if (multifd_send_setup(&local_err) != 0) {
> migrate_set_error(s, local_err);
> error_report_err(local_err);
> migrate_set_state(&s->state, MIGRATION_STATUS_SETUP,
> diff --git a/migration/multifd.c b/migration/multifd.c
> index e2dd2f6e04..130f86a1fb 100644
> --- a/migration/multifd.c
> +++ b/migration/multifd.c
> @@ -663,7 +663,7 @@ static void multifd_send_cleanup_state(void)
> multifd_send_state = NULL;
> }
>
> -void multifd_save_cleanup(void)
> +void multifd_send_shutdown(void)
> {
> int i;
>
> @@ -965,7 +965,7 @@ static void multifd_new_send_channel_create(gpointer
> opaque)
> socket_send_channel_create(multifd_new_send_channel_async, opaque);
> }
>
> -int multifd_save_setup(Error **errp)
> +int multifd_send_setup(Error **errp)
> {
> int thread_count;
> uint32_t page_count = MULTIFD_PACKET_SIZE / qemu_target_page_size();
> @@ -1063,7 +1063,7 @@ static void multifd_recv_terminate_threads(Error *err)
> }
> }
>
> -void multifd_load_shutdown(void)
> +void multifd_recv_shutdown(void)
> {
> if (migrate_multifd()) {
> multifd_recv_terminate_threads(NULL);
> @@ -1098,7 +1098,7 @@ static void multifd_recv_cleanup_state(void)
> multifd_recv_state = NULL;
> }
>
> -void multifd_load_cleanup(void)
> +void multifd_recv_cleanup(void)
> {
> int i;
>
> @@ -1213,7 +1213,7 @@ static void *multifd_recv_thread(void *opaque)
> return NULL;
> }
>
> -int multifd_load_setup(Error **errp)
> +int multifd_recv_setup(Error **errp)
> {
> int thread_count;
> uint32_t page_count = MULTIFD_PACKET_SIZE / qemu_target_page_size();
