|
@@ -435,7 +435,7 @@ static int multifd_send_pages(QEMUFile *f)
|
|
p->pages = pages;
|
|
p->pages = pages;
|
|
transferred = ((uint64_t) pages->num) * qemu_target_page_size()
|
|
transferred = ((uint64_t) pages->num) * qemu_target_page_size()
|
|
+ p->packet_len;
|
|
+ p->packet_len;
|
|
- qemu_file_update_transfer(f, transferred);
|
|
|
|
|
|
+ qemu_file_acct_rate_limit(f, transferred);
|
|
ram_counters.multifd_bytes += transferred;
|
|
ram_counters.multifd_bytes += transferred;
|
|
ram_counters.transferred += transferred;
|
|
ram_counters.transferred += transferred;
|
|
qemu_mutex_unlock(&p->mutex);
|
|
qemu_mutex_unlock(&p->mutex);
|
|
@@ -610,7 +610,7 @@ int multifd_send_sync_main(QEMUFile *f)
|
|
p->packet_num = multifd_send_state->packet_num++;
|
|
p->packet_num = multifd_send_state->packet_num++;
|
|
p->flags |= MULTIFD_FLAG_SYNC;
|
|
p->flags |= MULTIFD_FLAG_SYNC;
|
|
p->pending_job++;
|
|
p->pending_job++;
|
|
- qemu_file_update_transfer(f, p->packet_len);
|
|
|
|
|
|
+ qemu_file_acct_rate_limit(f, p->packet_len);
|
|
ram_counters.multifd_bytes += p->packet_len;
|
|
ram_counters.multifd_bytes += p->packet_len;
|
|
ram_counters.transferred += p->packet_len;
|
|
ram_counters.transferred += p->packet_len;
|
|
qemu_mutex_unlock(&p->mutex);
|
|
qemu_mutex_unlock(&p->mutex);
|