@samitouri / QOSamiQemu / commits / 8bfb2f6d09

multifd: Move ram state receive into multifd_ram_state_recv()

This is in preparation for the next patch. Reviewed-by: Peter Xu <peterx@redhat.com> Reviewed-by: Fabiano Rosas <farosas@suse.de> Signed-off-by: Lukas Straub <lukasstraub2@web.de> Link: https://lore.kernel.org/qemu-devel/20260302-colo_unit_test_multifd-v11-7-d653fb3b1d80@web.de Signed-off-by: Fabiano Rosas <farosas@suse.de>

Lukas Straub committed Mar 2, 2026 at 12:43 UTC 8bfb2f6d09d0af8bb851f3fac60d6a04e4656056
1 file changed +10 -1
migration/multifd.c
+10 -1
@@ -1253,6 +1253,15 @@ static int multifd_device_state_recv(MultiFDRecvParams *p, Error **errp)
1253 return ret;
1254 }
1255
1256 +static int multifd_ram_state_recv(MultiFDRecvParams *p, Error **errp)
1257 +{
1258 + int ret;
1259 +
1260 + ret = multifd_recv_state->ops->recv(p, errp);
1261 +
1262 + return ret;
1263 +}
1264 +
1265 static void *multifd_recv_thread(void *opaque)
1266 {
1267 MigrationState *s = migrate_get_current();
@@ -1387,7 +1396,7 @@ static void *multifd_recv_thread(void *opaque)
1396 assert(use_packets);
1397 ret = multifd_device_state_recv(p, &local_err);
1398 } else {
1390 - ret = multifd_recv_state->ops->recv(p, &local_err);
1399 + ret = multifd_ram_state_recv(p, &local_err);
1400 }
1401 if (ret != 0) {
1402 break;