motorhead/qemu
1
0
Fork 0
mirror of https://github.com/Motorhead1991/qemu.git synced 2025-08-05 00:33:55 -06:00
Code Issues Projects Releases Packages Wiki Activity Actions

migration: Move update_compress_threads_counts() to ram-compress.c

Browse source 
Signed-off-by: Juan Quintela <quintela@redhat.com>
Reviewed-by: Lukas Straub <lukasstraub2@web.de>
Message-ID: <20230613145757.10131-9-quintela@redhat.com>
This commit is contained in:
Juan Quintela 2023-06-13 16:57:47 +02:00
parent f504789de5
commit 1fd03d41b8
3 changed files with 18 additions and 15 deletions
Download patch file Download diff file Expand all files Collapse all files

17
migration/ram-compress.c
View file

@ -32,11 +32,14 @@
#include "ram-compress.h" #include "ram-compress.h"
#include "qemu/error-report.h" #include "qemu/error-report.h"
#include "qemu/stats64.h"
#include "migration.h" #include "migration.h"
#include "options.h" #include "options.h"
#include "io/channel-null.h" #include "io/channel-null.h"
#include "exec/target_page.h" #include "exec/target_page.h"
#include "exec/ramblock.h" #include "exec/ramblock.h"
#include "ram.h"
#include "migration-stats.h"
CompressionStats compression_counters; CompressionStats compression_counters;
@ -507,3 +510,17 @@ uint64_t ram_compressed_pages(void)
return compression_counters.pages; return compression_counters.pages;
} }
void update_compress_thread_counts(const CompressParam *param, int bytes_xmit)
{
ram_transferred_add(bytes_xmit);
if (param->result == RES_ZEROPAGE) {
stat64_add(&mig_stats.zero_pages, 1);
return;
}
/* 8 means a header with RAM_SAVE_FLAG_CONTINUE. */
compression_counters.compressed_size += bytes_xmit - 8;
compression_counters.pages++;
}

1
migration/ram-compress.h
View file

@ -70,5 +70,6 @@ void decompress_data_with_multi_threads(QEMUFile *f, void *host, int len);
void populate_compress(MigrationInfo *info); 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);
#endif #endif

15
migration/ram.c
View file

@ -1292,21 +1292,6 @@ static int ram_save_multifd_page(QEMUFile *file, RAMBlock *block,
return 1; return 1;
} }
static void
update_compress_thread_counts(const CompressParam *param, int bytes_xmit)
{
ram_transferred_add(bytes_xmit);
if (param->result == RES_ZEROPAGE) {
stat64_add(&mig_stats.zero_pages, 1);
return;
}
/* 8 means a header with RAM_SAVE_FLAG_CONTINUE. */
compression_counters.compressed_size += bytes_xmit - 8;
compression_counters.pages++;
}
static bool save_page_use_compression(RAMState *rs); static bool save_page_use_compression(RAMState *rs);
static int send_queued_data(CompressParam *param) static int send_queued_data(CompressParam *param)