Loading migration/migration.c +5 −1 Original line number Diff line number Diff line Loading @@ -462,7 +462,11 @@ void migration_ioc_process_incoming(QIOChannel *ioc) */ bool migration_has_all_channels(void) { return true; bool all_channels; all_channels = multifd_recv_all_channels_created(); return all_channels; } /* Loading migration/ram.c +11 −0 Original line number Diff line number Diff line Loading @@ -671,6 +671,17 @@ int multifd_load_setup(void) return 0; } bool multifd_recv_all_channels_created(void) { int thread_count = migrate_multifd_channels(); if (!migrate_use_multifd()) { return true; } return thread_count == atomic_read(&multifd_recv_state->count); } void multifd_recv_new_channel(QIOChannel *ioc) { /* nothing to do yet */ Loading migration/ram.h +1 −0 Original line number Diff line number Diff line Loading @@ -45,6 +45,7 @@ int multifd_save_setup(void); int multifd_save_cleanup(Error **errp); int multifd_load_setup(void); int multifd_load_cleanup(Error **errp); bool multifd_recv_all_channels_created(void); void multifd_recv_new_channel(QIOChannel *ioc); uint64_t ram_pagesize_summary(void); Loading Loading
migration/migration.c +5 −1 Original line number Diff line number Diff line Loading @@ -462,7 +462,11 @@ void migration_ioc_process_incoming(QIOChannel *ioc) */ bool migration_has_all_channels(void) { return true; bool all_channels; all_channels = multifd_recv_all_channels_created(); return all_channels; } /* Loading
migration/ram.c +11 −0 Original line number Diff line number Diff line Loading @@ -671,6 +671,17 @@ int multifd_load_setup(void) return 0; } bool multifd_recv_all_channels_created(void) { int thread_count = migrate_multifd_channels(); if (!migrate_use_multifd()) { return true; } return thread_count == atomic_read(&multifd_recv_state->count); } void multifd_recv_new_channel(QIOChannel *ioc) { /* nothing to do yet */ Loading
migration/ram.h +1 −0 Original line number Diff line number Diff line Loading @@ -45,6 +45,7 @@ int multifd_save_setup(void); int multifd_save_cleanup(Error **errp); int multifd_load_setup(void); int multifd_load_cleanup(Error **errp); bool multifd_recv_all_channels_created(void); void multifd_recv_new_channel(QIOChannel *ioc); uint64_t ram_pagesize_summary(void); Loading