diff options
| author | Juan Quintela <quintela@redhat.com> | 2023-10-19 13:07:21 +0200 |
|---|---|---|
| committer | Juan Quintela <quintela@redhat.com> | 2023-10-30 17:41:55 +0100 |
| commit | 742ec5f338593f3bc9d526577d24976eb658dcc5 (patch) | |
| tree | f6758b1739b06426ac1cf43be26842be39308f57 | |
| parent | fb36fb275f455642599ac882fd5a96a8b00b062e (diff) | |
| download | qemu-742ec5f338593f3bc9d526577d24976eb658dcc5.zip qemu-742ec5f338593f3bc9d526577d24976eb658dcc5.tar.gz qemu-742ec5f338593f3bc9d526577d24976eb658dcc5.tar.bz2 | |
migration: Export send_queued_data()
This function is only used for compression. So we rename it as
compress_send_queued_data(). We put it on ram-compress.h because we
are moving it later to ram-compress.c.
Reviewed-by: Fabiano Rosas <farosas@suse.de>
Signed-off-by: Juan Quintela <quintela@redhat.com>
Message-ID: <20231019110724.15324-9-quintela@redhat.com>
| -rw-r--r-- | migration/ram-compress.h | 1 | ||||
| -rw-r--r-- | migration/ram.c | 6 |
2 files changed, 4 insertions, 3 deletions
diff --git a/migration/ram-compress.h b/migration/ram-compress.h index 76dacd3..636281e 100644 --- a/migration/ram-compress.h +++ b/migration/ram-compress.h @@ -72,5 +72,6 @@ void populate_compress(MigrationInfo *info); uint64_t ram_compressed_pages(void); void update_compress_thread_counts(const CompressParam *param, int bytes_xmit); void compress_update_rates(uint64_t page_count); +int compress_send_queued_data(CompressParam *param); #endif diff --git a/migration/ram.c b/migration/ram.c index f7daf22..b6d4853 100644 --- a/migration/ram.c +++ b/migration/ram.c @@ -1264,7 +1264,7 @@ static int ram_save_multifd_page(QEMUFile *file, RAMBlock *block, return 1; } -static int send_queued_data(CompressParam *param) +int compress_send_queued_data(CompressParam *param) { PageSearchStatus *pss = &ram_state->pss[RAM_CHANNEL_PRECOPY]; MigrationState *ms = migrate_get_current(); @@ -1306,7 +1306,7 @@ static void ram_flush_compressed_data(void) return; } - flush_compressed_data(send_queued_data); + flush_compressed_data(compress_send_queued_data); } #define PAGE_ALL_CLEAN 0 @@ -2041,7 +2041,7 @@ static bool save_compress_page(RAMState *rs, PageSearchStatus *pss, } return compress_page_with_multi_thread(pss->block, offset, - send_queued_data); + compress_send_queued_data); } /** |