[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[PATCH v2 4/6] migration: Introduce migrate_send_rp_message_req_pages()
From: |
Peter Xu |
Subject: |
[PATCH v2 4/6] migration: Introduce migrate_send_rp_message_req_pages() |
Date: |
Tue, 8 Sep 2020 16:30:20 -0400 |
This is another layer wrapper for sending a page request to the source VM. The
new migrate_send_rp_message_req_pages() will be used elsewhere in coming
patches.
Reviewed-by: Dr. David Alan Gilbert <dgilbert@redhat.com>
Signed-off-by: Peter Xu <peterx@redhat.com>
---
migration/migration.c | 10 ++++++++--
migration/migration.h | 2 ++
2 files changed, 10 insertions(+), 2 deletions(-)
diff --git a/migration/migration.c b/migration/migration.c
index 2e6b21544b..6e06b6f4e6 100644
--- a/migration/migration.c
+++ b/migration/migration.c
@@ -319,8 +319,8 @@ error:
* Start: Address offset within the RB
* Len: Length in bytes required - must be a multiple of pagesize
*/
-int migrate_send_rp_req_pages(MigrationIncomingState *mis, RAMBlock *rb,
- ram_addr_t start)
+int migrate_send_rp_message_req_pages(MigrationIncomingState *mis,
+ RAMBlock *rb, ram_addr_t start)
{
uint8_t bufc[12 + 1 + 255]; /* start (8), len (4), rbname up to 256 */
size_t msglen = 12; /* start + len */
@@ -356,6 +356,12 @@ int migrate_send_rp_req_pages(MigrationIncomingState *mis,
RAMBlock *rb,
return migrate_send_rp_message(mis, msg_type, msglen, bufc);
}
+int migrate_send_rp_req_pages(MigrationIncomingState *mis,
+ RAMBlock *rb, ram_addr_t start)
+{
+ return migrate_send_rp_message_req_pages(mis, rb, start);
+}
+
static bool migration_colo_enabled;
bool migration_incoming_colo_enabled(void)
{
diff --git a/migration/migration.h b/migration/migration.h
index ca8dc4c773..f552725305 100644
--- a/migration/migration.h
+++ b/migration/migration.h
@@ -330,6 +330,8 @@ void migrate_send_rp_pong(MigrationIncomingState *mis,
uint32_t value);
int migrate_send_rp_req_pages(MigrationIncomingState *mis, RAMBlock *rb,
ram_addr_t start);
+int migrate_send_rp_message_req_pages(MigrationIncomingState *mis,
+ RAMBlock *rb, ram_addr_t start);
void migrate_send_rp_recv_bitmap(MigrationIncomingState *mis,
char *block_name);
void migrate_send_rp_resume_ack(MigrationIncomingState *mis, uint32_t value);
--
2.26.2
- [PATCH v2 0/6] migration/postcopy: Sync faulted addresses after network recovered, Peter Xu, 2020/09/08
- [PATCH v2 1/6] migration: Properly destroy variables on incoming side, Peter Xu, 2020/09/08
- [PATCH v2 2/6] migration: Rework migrate_send_rp_req_pages() function, Peter Xu, 2020/09/08
- [PATCH v2 6/6] migration: Sync requested pages after postcopy recovery, Peter Xu, 2020/09/08
- [PATCH v2 5/6] migration: Maintain postcopy faulted addresses, Peter Xu, 2020/09/08
- [PATCH v2 4/6] migration: Introduce migrate_send_rp_message_req_pages(),
Peter Xu <=
- [PATCH v2 3/6] migration: Pass incoming state into qemu_ufd_copy_ioctl(), Peter Xu, 2020/09/08
- Re: [PATCH v2 0/6] migration/postcopy: Sync faulted addresses after network recovered, Dr. David Alan Gilbert, 2020/09/23