motorhead/qemu
1
0
Fork 0
mirror of https://github.com/Motorhead1991/qemu.git synced 2025-09-01 14:31:52 -06:00
Code Issues Projects Releases Packages Wiki Activity Actions

migration/rdma: Split the zero page case from acct_update_position

Browse source 
Now that we have atomic counters, we can do it on the place that we
need it, no need to do it inside ram.c.

Signed-off-by: Juan Quintela <quintela@redhat.com>
Reviewed-by: Lukas Straub <lukasstraub2@web.de>
This commit is contained in:
Juan Quintela 2023-04-27 10:35:26 +02:00
parent 96820df24e
commit c61d2faa93
3 changed files with 10 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

12
migration/ram.c
View file

@ -2629,17 +2629,13 @@ static int ram_find_and_save_block(RAMState *rs)
return pages; return pages;
} }
void acct_update_position(QEMUFile *f, size_t size, bool zero) void acct_update_position(QEMUFile *f, size_t size)
{ {
uint64_t pages = size / TARGET_PAGE_SIZE; uint64_t pages = size / TARGET_PAGE_SIZE;
if (zero) { stat64_add(&mig_stats.normal_pages, pages);
stat64_add(&mig_stats.zero_pages, pages); ram_transferred_add(size);
} else { qemu_file_credit_transfer(f, size);
stat64_add(&mig_stats.normal_pages, pages);
ram_transferred_add(size);
qemu_file_credit_transfer(f, size);
}
} }
static uint64_t ram_bytes_total_with_ignored(void) static uint64_t ram_bytes_total_with_ignored(void)

2
migration/ram.h
View file

@ -53,7 +53,7 @@ void mig_throttle_counter_reset(void);
uint64_t ram_pagesize_summary(void); uint64_t ram_pagesize_summary(void);
int ram_save_queue_pages(const char *rbname, ram_addr_t start, ram_addr_t len); int ram_save_queue_pages(const char *rbname, ram_addr_t start, ram_addr_t len);
void acct_update_position(QEMUFile *f, size_t size, bool zero); void acct_update_position(QEMUFile *f, size_t size);
void ram_postcopy_migrated_memory_release(MigrationState *ms); void ram_postcopy_migrated_memory_release(MigrationState *ms);
/* For outgoing discard bitmap */ /* For outgoing discard bitmap */
void ram_postcopy_send_discard_bitmap(MigrationState *ms); void ram_postcopy_send_discard_bitmap(MigrationState *ms);

7
migration/rdma.c
View file

@ -17,8 +17,10 @@
#include "qemu/osdep.h" #include "qemu/osdep.h"
#include "qapi/error.h" #include "qapi/error.h"
#include "qemu/cutils.h" #include "qemu/cutils.h"
#include "exec/target_page.h"
#include "rdma.h" #include "rdma.h"
#include "migration.h" #include "migration.h"
#include "migration-stats.h"
#include "qemu-file.h" #include "qemu-file.h"
#include "ram.h" #include "ram.h"
#include "qemu/error-report.h" #include "qemu/error-report.h"
@ -2120,7 +2122,8 @@ retry:
return -EIO; return -EIO;
} }
acct_update_position(f, sge.length, true); stat64_add(&mig_stats.zero_pages,
sge.length / qemu_target_page_size());
return 1; return 1;
} }
@ -2228,7 +2231,7 @@ retry:
} }
set_bit(chunk, block->transit_bitmap); set_bit(chunk, block->transit_bitmap);
acct_update_position(f, sge.length, false); acct_update_position(f, sge.length);
rdma->total_writes++; rdma->total_writes++;
return 0; return 0;