@@ -340,6 +340,11 @@ int migrate_compress_threads(void);
int migrate_decompress_threads(void);
bool migrate_use_events(void);
+int migrate_announce_initial(void);
+int migrate_announce_max(void);
+int migrate_announce_rounds(void);
+int migrate_announce_step(void);
+
/* Sending on the return path - generic and then for each message type */
void migrate_send_rp_message(MigrationIncomingState *mis,
enum mig_rp_message_type message_type,
@@ -1483,6 +1483,26 @@ int64_t migrate_xbzrle_cache_size(void)
return s->xbzrle_cache_size;
}
+int migrate_announce_initial(void)
+{
+ return migrate_get_current()->parameters.announce_initial;
+}
+
+int migrate_announce_max(void)
+{
+ return migrate_get_current()->parameters.announce_max;
+}
+
+int migrate_announce_rounds(void)
+{
+ return migrate_get_current()->parameters.announce_rounds;
+}
+
+int migrate_announce_step(void)
+{
+ return migrate_get_current()->parameters.announce_step;
+}
+
/* migration thread support */
/*
* Something bad happened to the RP stream, mark an error