OpenE2K/qemu-e2k
13
4
Fork 0
Code Issues 4 Pull Requests Projects 2 Releases Activity

migration: Export send_queued_data()

Browse Source 
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>
This commit is contained in:
Juan Quintela 2023-10-19 13:07:21 +02:00
parent fb36fb275f
commit 742ec5f338
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
migration/ram-compress.h
View File

@ -72,5 +72,6 @@ void populate_compress(MigrationInfo *info);
uint64_t ram_compressed_pages(void); uint64_t ram_compressed_pages(void);
void update_compress_thread_counts(const CompressParam *param, int bytes_xmit); void update_compress_thread_counts(const CompressParam *param, int bytes_xmit);
void compress_update_rates(uint64_t page_count); void compress_update_rates(uint64_t page_count);
int compress_send_queued_data(CompressParam *param);
#endif #endif

6
migration/ram.c
View File

@ -1264,7 +1264,7 @@ static int ram_save_multifd_page(QEMUFile *file, RAMBlock *block,
return 1; return 1;
} }
static int send_queued_data(CompressParam *param) int compress_send_queued_data(CompressParam *param)
{ {
PageSearchStatus *pss = &ram_state->pss[RAM_CHANNEL_PRECOPY]; PageSearchStatus *pss = &ram_state->pss[RAM_CHANNEL_PRECOPY];
MigrationState *ms = migrate_get_current(); MigrationState *ms = migrate_get_current();
@ -1306,7 +1306,7 @@ static void ram_flush_compressed_data(void)
return; return;
} }
flush_compressed_data(send_queued_data); flush_compressed_data(compress_send_queued_data);
} }
#define PAGE_ALL_CLEAN 0 #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, return compress_page_with_multi_thread(pss->block, offset,
send_queued_data); compress_send_queued_data);
} }
/** /**