Signed-off-by: Juan Quintela <quint...@redhat.com> --- migration/options.h | 1 + migration/migration.c | 2 +- migration/options.c | 9 +++++++++ 3 files changed, 11 insertions(+), 1 deletion(-)
diff --git a/migration/options.h b/migration/options.h index 4214bebcb7..17ac53429e 100644 --- a/migration/options.h +++ b/migration/options.h @@ -67,6 +67,7 @@ uint8_t migrate_cpu_throttle_initial(void); bool migrate_cpu_throttle_tailslow(void); int migrate_decompress_threads(void); uint8_t migrate_max_cpu_throttle(void); +uint64_t migrate_max_bandwidth(void); int64_t migrate_max_postcopy_bandwidth(void); int migrate_multifd_channels(void); MultiFDCompression migrate_multifd_compression(void); diff --git a/migration/migration.c b/migration/migration.c index e091663af9..40453ba454 100644 --- a/migration/migration.c +++ b/migration/migration.c @@ -3758,7 +3758,7 @@ void migrate_fd_connect(MigrationState *s, Error *error_in) XFER_LIMIT_RATIO; } else { /* This is a fresh new migration */ - rate_limit = s->parameters.max_bandwidth / XFER_LIMIT_RATIO; + rate_limit = migrate_max_bandwidth() / XFER_LIMIT_RATIO; /* Notify before starting migration thread */ notifier_list_notify(&migration_state_notifiers, s); diff --git a/migration/options.c b/migration/options.c index d9383afa35..4f6298bdc5 100644 --- a/migration/options.c +++ b/migration/options.c @@ -575,6 +575,15 @@ uint8_t migrate_max_cpu_throttle(void) return s->parameters.max_cpu_throttle; } +uint64_t migrate_max_bandwidth(void) +{ + MigrationState *s; + + s = migrate_get_current(); + + return s->parameters.max_bandwidth; +} + int64_t migrate_max_postcopy_bandwidth(void) { MigrationState *s; -- 2.39.2