From nobody Sun Nov 2 11:47:00 2025 Delivered-To: importer@patchew.org Received-SPF: pass (zoho.com: domain of gnu.org designates 208.118.235.17 as permitted sender) client-ip=208.118.235.17; envelope-from=qemu-devel-bounces+importer=patchew.org@nongnu.org; helo=lists.gnu.org; Authentication-Results: mx.zohomail.com; dkim=fail; spf=pass (zoho.com: domain of gnu.org designates 208.118.235.17 as permitted sender) smtp.mailfrom=qemu-devel-bounces+importer=patchew.org@nongnu.org; dmarc=fail(p=none dis=none) header.from=gmail.com Return-Path: Received: from lists.gnu.org (208.118.235.17 [208.118.235.17]) by mx.zohomail.com with SMTPS id 1527673912058449.3612086403581; Wed, 30 May 2018 02:51:52 -0700 (PDT) Received: from localhost ([::1]:37275 helo=lists.gnu.org) by lists.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1fNxli-0005tH-9J for importer@patchew.org; Wed, 30 May 2018 05:51:46 -0400 Received: from eggs.gnu.org ([2001:4830:134:3::10]:40336) by lists.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1fNxeJ-0000Rh-Gc for qemu-devel@nongnu.org; Wed, 30 May 2018 05:44:09 -0400 Received: from Debian-exim by eggs.gnu.org with spam-scanned (Exim 4.71) (envelope-from ) id 1fNxeH-0006qf-Fj for qemu-devel@nongnu.org; Wed, 30 May 2018 05:44:07 -0400 Received: from mail-pf0-x241.google.com ([2607:f8b0:400e:c00::241]:36562) by eggs.gnu.org with esmtps (TLS1.0:RSA_AES_128_CBC_SHA1:16) (Exim 4.71) (envelope-from ) id 1fNxeH-0006qT-6p for qemu-devel@nongnu.org; Wed, 30 May 2018 05:44:05 -0400 Received: by mail-pf0-x241.google.com with SMTP id w129-v6so8756929pfd.3 for ; Wed, 30 May 2018 02:44:05 -0700 (PDT) Received: from VM_93_245_centos.localdomain ([150.109.57.149]) by smtp.gmail.com with ESMTPSA id 29-v6sm60565257pfj.14.2018.05.30.02.44.01 (version=TLS1_2 cipher=ECDHE-RSA-AES128-GCM-SHA256 bits=128/128); Wed, 30 May 2018 02:44:03 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=from:to:cc:subject:date:message-id:in-reply-to:references; bh=xoNXjkhSRfGFabOTEuJXpjBSwWuY76cIvudGti5sy9w=; b=Ey53oR8lL+3yYjpmVML/M5isWmrcx7T8LDlkeTnENDOeKQXrS1g15oMi4YJxPwxTxD /G1aDt67Tgj4/XmdIx0WIYiCyFdszA6sMk86V0SF6YXwaq2dhuLpvmwu0i3zhzKcwMqF HvtPDl0yJmquLl7B+cqas0X13X4E3Jmbi+EYv14DycLdOgWEI2YpRFOCqVTP8g1dOr2a I/pu6WpYttfgMh+3fIf0YUrAfC+U72j5XNf7UZWkwimrzcd1b55wFw7vTQ4LFW1eW5b4 W8AAkXM/6D7xpP/1qOuCXAPD2+o4oRHKoEnYcG4EFEmUVhht4U2S6oMiM5Z53hbGS0kQ BX9Q== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:from:to:cc:subject:date:message-id:in-reply-to :references; bh=xoNXjkhSRfGFabOTEuJXpjBSwWuY76cIvudGti5sy9w=; b=fg6DRbADoEJ/5XX25akTLaGYNdQXtO2N1KYp2wK5a+t5tB77ofTgWL80jvfvKzlk5q F0eDKSsBXEfv9ZWzy5zvvGyVYin1MshH/p3b4/uU2yjPLalXYN6I0AB2Cm5OJZweDB5T NmFrfDiD4NUlcI/WiLJu42EW5Y+DaqeeQtRh6rnNlal/Bl9yHBlq6YmAAYg8w+7Z7UPJ p9z/hypsvLnCX4q+FzSFbtR12mpeWnSS2RuPNzHhZrQynklCJ1amnQvZaivJU74US+2A T+lL7pASDAha/eyB2+wSXgd7DDDBFFQmLXTLlOvzgqea35MuNUPYj4u+lGNcIEz7/x6I 1iDA== X-Gm-Message-State: ALKqPwc1QatrhOhxzrrYTZFSnfuurB4AmINZfYp+lXIWaRrjxb2DGpQg cC95G1rJWLtffyAaP1FLTmQ= X-Google-Smtp-Source: ADUXVKLhTag8vaC7SbG9Oox30jq3xTvZ0baxwQbAGTgKcok04Vkqp8LIDqUFHsTadr71HxPYvp3/Xg== X-Received: by 2002:a62:b204:: with SMTP id x4-v6mr2086404pfe.21.1527673444138; Wed, 30 May 2018 02:44:04 -0700 (PDT) From: Lidong Chen X-Google-Original-From: Lidong Chen To: zhang.zhanghailiang@huawei.com, quintela@redhat.com, dgilbert@redhat.com, berrange@redhat.com, aviadye@mellanox.com, pbonzini@redhat.com Date: Wed, 30 May 2018 17:43:29 +0800 Message-Id: <1527673416-31268-6-git-send-email-lidongchen@tencent.com> X-Mailer: git-send-email 1.8.3.1 In-Reply-To: <1527673416-31268-1-git-send-email-lidongchen@tencent.com> References: <1527673416-31268-1-git-send-email-lidongchen@tencent.com> X-detected-operating-system: by eggs.gnu.org: Genre and OS details not recognized. X-Received-From: 2607:f8b0:400e:c00::241 Subject: [Qemu-devel] [PATCH v4 05/12] migration: implement bi-directional RDMA QIOChannel X-BeenThere: qemu-devel@nongnu.org X-Mailman-Version: 2.1.21 Precedence: list List-Id: List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Cc: Lidong Chen , adido@mellanox.com, qemu-devel@nongnu.org, Lidong Chen Errors-To: qemu-devel-bounces+importer=patchew.org@nongnu.org Sender: "Qemu-devel" X-ZohoMail-DKIM: fail (Header signature does not verify) X-ZohoMail: RDKM_2 RSF_0 Z_629925259 SPT_0 Content-Transfer-Encoding: quoted-printable MIME-Version: 1.0 Content-Type: text/plain; charset="utf-8" From: Lidong Chen This patch implements bi-directional RDMA QIOChannel. Because different threads may access RDMAQIOChannel currently, this patch use RCU to protect = it. Signed-off-by: Lidong Chen --- migration/colo.c | 2 + migration/migration.c | 2 + migration/postcopy-ram.c | 2 + migration/ram.c | 4 + migration/rdma.c | 196 ++++++++++++++++++++++++++++++++++++++++---= ---- migration/savevm.c | 3 + 6 files changed, 183 insertions(+), 26 deletions(-) diff --git a/migration/colo.c b/migration/colo.c index 4381067..88936f5 100644 --- a/migration/colo.c +++ b/migration/colo.c @@ -534,6 +534,7 @@ void *colo_process_incoming_thread(void *opaque) uint64_t value; Error *local_err =3D NULL; =20 + rcu_register_thread(); qemu_sem_init(&mis->colo_incoming_sem, 0); =20 migrate_set_state(&mis->state, MIGRATION_STATUS_ACTIVE, @@ -666,5 +667,6 @@ out: } migration_incoming_exit_colo(); =20 + rcu_unregister_thread(); return NULL; } diff --git a/migration/migration.c b/migration/migration.c index 05aec2c..6217ef1 100644 --- a/migration/migration.c +++ b/migration/migration.c @@ -2008,6 +2008,7 @@ static void *source_return_path_thread(void *opaque) int res; =20 trace_source_return_path_thread_entry(); + rcu_register_thread(); =20 retry: while (!ms->rp_state.error && !qemu_file_get_error(rp) && @@ -2147,6 +2148,7 @@ out: trace_source_return_path_thread_end(); ms->rp_state.from_dst_file =3D NULL; qemu_fclose(rp); + rcu_unregister_thread(); return NULL; } =20 diff --git a/migration/postcopy-ram.c b/migration/postcopy-ram.c index 658b750..a5de61d 100644 --- a/migration/postcopy-ram.c +++ b/migration/postcopy-ram.c @@ -853,6 +853,7 @@ static void *postcopy_ram_fault_thread(void *opaque) RAMBlock *rb =3D NULL; =20 trace_postcopy_ram_fault_thread_entry(); + rcu_register_thread(); mis->last_rb =3D NULL; /* last RAMBlock we sent part of */ qemu_sem_post(&mis->fault_thread_sem); =20 @@ -1059,6 +1060,7 @@ retry: } } } + rcu_unregister_thread(); trace_postcopy_ram_fault_thread_exit(); g_free(pfd); return NULL; diff --git a/migration/ram.c b/migration/ram.c index c53e836..85c8c39 100644 --- a/migration/ram.c +++ b/migration/ram.c @@ -678,6 +678,7 @@ static void *multifd_send_thread(void *opaque) MultiFDSendParams *p =3D opaque; Error *local_err =3D NULL; =20 + rcu_register_thread(); if (multifd_send_initial_packet(p, &local_err) < 0) { goto out; } @@ -701,6 +702,7 @@ out: p->running =3D false; qemu_mutex_unlock(&p->mutex); =20 + rcu_unregister_thread(); return NULL; } =20 @@ -814,6 +816,7 @@ static void *multifd_recv_thread(void *opaque) { MultiFDRecvParams *p =3D opaque; =20 + rcu_register_thread(); while (true) { qemu_mutex_lock(&p->mutex); if (p->quit) { @@ -828,6 +831,7 @@ static void *multifd_recv_thread(void *opaque) p->running =3D false; qemu_mutex_unlock(&p->mutex); =20 + rcu_unregister_thread(); return NULL; } =20 diff --git a/migration/rdma.c b/migration/rdma.c index 9b6da4d..45f01e6 100644 --- a/migration/rdma.c +++ b/migration/rdma.c @@ -86,6 +86,7 @@ static uint32_t known_capabilities =3D RDMA_CAPABILITY_PI= N_ALL; " to abort!"); \ rdma->error_reported =3D 1; \ } \ + rcu_read_unlock(); \ return rdma->error_state; \ } \ } while (0) @@ -402,7 +403,8 @@ typedef struct QIOChannelRDMA QIOChannelRDMA; =20 struct QIOChannelRDMA { QIOChannel parent; - RDMAContext *rdma; + RDMAContext *rdmain; + RDMAContext *rdmaout; QEMUFile *file; bool blocking; /* XXX we don't actually honour this yet */ }; @@ -2638,12 +2640,20 @@ static ssize_t qio_channel_rdma_writev(QIOChannel *= ioc, { QIOChannelRDMA *rioc =3D QIO_CHANNEL_RDMA(ioc); QEMUFile *f =3D rioc->file; - RDMAContext *rdma =3D rioc->rdma; + RDMAContext *rdma; int ret; ssize_t done =3D 0; size_t i; size_t len =3D 0; =20 + rcu_read_lock(); + rdma =3D atomic_rcu_read(&rioc->rdmaout); + + if (!rdma) { + rcu_read_unlock(); + return -EIO; + } + CHECK_ERROR_STATE(); =20 /* @@ -2653,6 +2663,7 @@ static ssize_t qio_channel_rdma_writev(QIOChannel *io= c, ret =3D qemu_rdma_write_flush(f, rdma); if (ret < 0) { rdma->error_state =3D ret; + rcu_read_unlock(); return ret; } =20 @@ -2672,6 +2683,7 @@ static ssize_t qio_channel_rdma_writev(QIOChannel *io= c, =20 if (ret < 0) { rdma->error_state =3D ret; + rcu_read_unlock(); return ret; } =20 @@ -2680,6 +2692,7 @@ static ssize_t qio_channel_rdma_writev(QIOChannel *io= c, } } =20 + rcu_read_unlock(); return done; } =20 @@ -2713,12 +2726,20 @@ static ssize_t qio_channel_rdma_readv(QIOChannel *i= oc, Error **errp) { QIOChannelRDMA *rioc =3D QIO_CHANNEL_RDMA(ioc); - RDMAContext *rdma =3D rioc->rdma; + RDMAContext *rdma; RDMAControlHeader head; int ret =3D 0; ssize_t i; size_t done =3D 0; =20 + rcu_read_lock(); + rdma =3D atomic_rcu_read(&rioc->rdmain); + + if (!rdma) { + rcu_read_unlock(); + return -EIO; + } + CHECK_ERROR_STATE(); =20 for (i =3D 0; i < niov; i++) { @@ -2730,7 +2751,7 @@ static ssize_t qio_channel_rdma_readv(QIOChannel *ioc, * were given and dish out the bytes until we run * out of bytes. */ - ret =3D qemu_rdma_fill(rioc->rdma, data, want, 0); + ret =3D qemu_rdma_fill(rdma, data, want, 0); done +=3D ret; want -=3D ret; /* Got what we needed, so go to next iovec */ @@ -2752,25 +2773,28 @@ static ssize_t qio_channel_rdma_readv(QIOChannel *i= oc, =20 if (ret < 0) { rdma->error_state =3D ret; + rcu_read_unlock(); return ret; } =20 /* * SEND was received with new bytes, now try again. */ - ret =3D qemu_rdma_fill(rioc->rdma, data, want, 0); + ret =3D qemu_rdma_fill(rdma, data, want, 0); done +=3D ret; want -=3D ret; =20 /* Still didn't get enough, so lets just return */ if (want) { if (done =3D=3D 0) { + rcu_read_unlock(); return QIO_CHANNEL_ERR_BLOCK; } else { break; } } } + rcu_read_unlock(); return done; } =20 @@ -2822,15 +2846,29 @@ qio_channel_rdma_source_prepare(GSource *source, gint *timeout) { QIOChannelRDMASource *rsource =3D (QIOChannelRDMASource *)source; - RDMAContext *rdma =3D rsource->rioc->rdma; + RDMAContext *rdma; GIOCondition cond =3D 0; *timeout =3D -1; =20 + rcu_read_lock(); + if (rsource->condition =3D=3D G_IO_IN) { + rdma =3D atomic_rcu_read(&rsource->rioc->rdmain); + } else { + rdma =3D atomic_rcu_read(&rsource->rioc->rdmaout); + } + + if (!rdma) { + error_report("RDMAContext is NULL when prepare Gsource"); + rcu_read_unlock(); + return FALSE; + } + if (rdma->wr_data[0].control_len) { cond |=3D G_IO_IN; } cond |=3D G_IO_OUT; =20 + rcu_read_unlock(); return cond & rsource->condition; } =20 @@ -2838,14 +2876,28 @@ static gboolean qio_channel_rdma_source_check(GSource *source) { QIOChannelRDMASource *rsource =3D (QIOChannelRDMASource *)source; - RDMAContext *rdma =3D rsource->rioc->rdma; + RDMAContext *rdma; GIOCondition cond =3D 0; =20 + rcu_read_lock(); + if (rsource->condition =3D=3D G_IO_IN) { + rdma =3D atomic_rcu_read(&rsource->rioc->rdmain); + } else { + rdma =3D atomic_rcu_read(&rsource->rioc->rdmaout); + } + + if (!rdma) { + error_report("RDMAContext is NULL when check Gsource"); + rcu_read_unlock(); + return FALSE; + } + if (rdma->wr_data[0].control_len) { cond |=3D G_IO_IN; } cond |=3D G_IO_OUT; =20 + rcu_read_unlock(); return cond & rsource->condition; } =20 @@ -2856,14 +2908,28 @@ qio_channel_rdma_source_dispatch(GSource *source, { QIOChannelFunc func =3D (QIOChannelFunc)callback; QIOChannelRDMASource *rsource =3D (QIOChannelRDMASource *)source; - RDMAContext *rdma =3D rsource->rioc->rdma; + RDMAContext *rdma; GIOCondition cond =3D 0; =20 + rcu_read_lock(); + if (rsource->condition =3D=3D G_IO_IN) { + rdma =3D atomic_rcu_read(&rsource->rioc->rdmain); + } else { + rdma =3D atomic_rcu_read(&rsource->rioc->rdmaout); + } + + if (!rdma) { + error_report("RDMAContext is NULL when dispatch Gsource"); + rcu_read_unlock(); + return FALSE; + } + if (rdma->wr_data[0].control_len) { cond |=3D G_IO_IN; } cond |=3D G_IO_OUT; =20 + rcu_read_unlock(); return (*func)(QIO_CHANNEL(rsource->rioc), (cond & rsource->condition), user_data); @@ -2908,15 +2974,32 @@ static int qio_channel_rdma_close(QIOChannel *ioc, Error **errp) { QIOChannelRDMA *rioc =3D QIO_CHANNEL_RDMA(ioc); + RDMAContext *rdmain, *rdmaout; trace_qemu_rdma_close(); - if (rioc->rdma) { - if (!rioc->rdma->error_state) { - rioc->rdma->error_state =3D qemu_file_get_error(rioc->file); - } - qemu_rdma_cleanup(rioc->rdma); - g_free(rioc->rdma); - rioc->rdma =3D NULL; + + rdmain =3D rioc->rdmain; + if (rdmain) { + atomic_rcu_set(&rioc->rdmain, NULL); + } + + rdmaout =3D rioc->rdmaout; + if (rdmaout) { + atomic_rcu_set(&rioc->rdmaout, NULL); } + + synchronize_rcu(); + + if (rdmain) { + qemu_rdma_cleanup(rdmain); + } + + if (rdmaout) { + qemu_rdma_cleanup(rdmaout); + } + + g_free(rdmain); + g_free(rdmaout); + return 0; } =20 @@ -2959,12 +3042,21 @@ static size_t qemu_rdma_save_page(QEMUFile *f, void= *opaque, size_t size, uint64_t *bytes_sent) { QIOChannelRDMA *rioc =3D QIO_CHANNEL_RDMA(opaque); - RDMAContext *rdma =3D rioc->rdma; + RDMAContext *rdma; int ret; =20 + rcu_read_lock(); + rdma =3D atomic_rcu_read(&rioc->rdmaout); + + if (!rdma) { + rcu_read_unlock(); + return -EIO; + } + CHECK_ERROR_STATE(); =20 if (migrate_get_current()->state =3D=3D MIGRATION_STATUS_POSTCOPY_ACTI= VE) { + rcu_read_unlock(); return RAM_SAVE_CONTROL_NOT_SUPP; } =20 @@ -3049,9 +3141,11 @@ static size_t qemu_rdma_save_page(QEMUFile *f, void = *opaque, } } =20 + rcu_read_unlock(); return RAM_SAVE_CONTROL_DELAYED; err: rdma->error_state =3D ret; + rcu_read_unlock(); return ret; } =20 @@ -3227,8 +3321,8 @@ static int qemu_rdma_registration_handle(QEMUFile *f,= void *opaque) RDMAControlHeader blocks =3D { .type =3D RDMA_CONTROL_RAM_BLOCKS_RESUL= T, .repeat =3D 1 }; QIOChannelRDMA *rioc =3D QIO_CHANNEL_RDMA(opaque); - RDMAContext *rdma =3D rioc->rdma; - RDMALocalBlocks *local =3D &rdma->local_ram_blocks; + RDMAContext *rdma; + RDMALocalBlocks *local; RDMAControlHeader head; RDMARegister *reg, *registers; RDMACompress *comp; @@ -3241,8 +3335,17 @@ static int qemu_rdma_registration_handle(QEMUFile *f= , void *opaque) int count =3D 0; int i =3D 0; =20 + rcu_read_lock(); + rdma =3D atomic_rcu_read(&rioc->rdmain); + + if (!rdma) { + rcu_read_unlock(); + return -EIO; + } + CHECK_ERROR_STATE(); =20 + local =3D &rdma->local_ram_blocks; do { trace_qemu_rdma_registration_handle_wait(); =20 @@ -3476,6 +3579,7 @@ out: if (ret < 0) { rdma->error_state =3D ret; } + rcu_read_unlock(); return ret; } =20 @@ -3489,10 +3593,18 @@ out: static int rdma_block_notification_handle(QIOChannelRDMA *rioc, const char *name) { - RDMAContext *rdma =3D rioc->rdma; + RDMAContext *rdma; int curr; int found =3D -1; =20 + rcu_read_lock(); + rdma =3D atomic_rcu_read(&rioc->rdmain); + + if (!rdma) { + rcu_read_unlock(); + return -EIO; + } + /* Find the matching RAMBlock in our local list */ for (curr =3D 0; curr < rdma->local_ram_blocks.nb_blocks; curr++) { if (!strcmp(rdma->local_ram_blocks.block[curr].block_name, name)) { @@ -3503,6 +3615,7 @@ rdma_block_notification_handle(QIOChannelRDMA *rioc, = const char *name) =20 if (found =3D=3D -1) { error_report("RAMBlock '%s' not found on destination", name); + rcu_read_unlock(); return -ENOENT; } =20 @@ -3510,6 +3623,7 @@ rdma_block_notification_handle(QIOChannelRDMA *rioc, = const char *name) trace_rdma_block_notification_handle(name, rdma->next_src_index); rdma->next_src_index++; =20 + rcu_read_unlock(); return 0; } =20 @@ -3532,11 +3646,19 @@ static int qemu_rdma_registration_start(QEMUFile *f= , void *opaque, uint64_t flags, void *data) { QIOChannelRDMA *rioc =3D QIO_CHANNEL_RDMA(opaque); - RDMAContext *rdma =3D rioc->rdma; + RDMAContext *rdma; + + rcu_read_lock(); + rdma =3D atomic_rcu_read(&rioc->rdmaout); + if (!rdma) { + rcu_read_unlock(); + return -EIO; + } =20 CHECK_ERROR_STATE(); =20 if (migrate_get_current()->state =3D=3D MIGRATION_STATUS_POSTCOPY_ACTI= VE) { + rcu_read_unlock(); return 0; } =20 @@ -3544,6 +3666,7 @@ static int qemu_rdma_registration_start(QEMUFile *f, = void *opaque, qemu_put_be64(f, RAM_SAVE_FLAG_HOOK); qemu_fflush(f); =20 + rcu_read_unlock(); return 0; } =20 @@ -3556,13 +3679,21 @@ static int qemu_rdma_registration_stop(QEMUFile *f,= void *opaque, { Error *local_err =3D NULL, **errp =3D &local_err; QIOChannelRDMA *rioc =3D QIO_CHANNEL_RDMA(opaque); - RDMAContext *rdma =3D rioc->rdma; + RDMAContext *rdma; RDMAControlHeader head =3D { .len =3D 0, .repeat =3D 1 }; int ret =3D 0; =20 + rcu_read_lock(); + rdma =3D atomic_rcu_read(&rioc->rdmaout); + if (!rdma) { + rcu_read_unlock(); + return -EIO; + } + CHECK_ERROR_STATE(); =20 if (migrate_get_current()->state =3D=3D MIGRATION_STATUS_POSTCOPY_ACTI= VE) { + rcu_read_unlock(); return 0; } =20 @@ -3594,6 +3725,7 @@ static int qemu_rdma_registration_stop(QEMUFile *f, v= oid *opaque, qemu_rdma_reg_whole_ram_blocks : NULL); if (ret < 0) { ERROR(errp, "receiving remote info!"); + rcu_read_unlock(); return ret; } =20 @@ -3617,6 +3749,7 @@ static int qemu_rdma_registration_stop(QEMUFile *f, v= oid *opaque, "not identical on both the source and destination.= ", local->nb_blocks, nb_dest_blocks); rdma->error_state =3D -EINVAL; + rcu_read_unlock(); return -EINVAL; } =20 @@ -3633,6 +3766,7 @@ static int qemu_rdma_registration_stop(QEMUFile *f, v= oid *opaque, local->block[i].length, rdma->dest_blocks[i].length); rdma->error_state =3D -EINVAL; + rcu_read_unlock(); return -EINVAL; } local->block[i].remote_host_addr =3D @@ -3650,9 +3784,11 @@ static int qemu_rdma_registration_stop(QEMUFile *f, = void *opaque, goto err; } =20 + rcu_read_unlock(); return 0; err: rdma->error_state =3D ret; + rcu_read_unlock(); return ret; } =20 @@ -3670,10 +3806,15 @@ static const QEMUFileHooks rdma_write_hooks =3D { static void qio_channel_rdma_finalize(Object *obj) { QIOChannelRDMA *rioc =3D QIO_CHANNEL_RDMA(obj); - if (rioc->rdma) { - qemu_rdma_cleanup(rioc->rdma); - g_free(rioc->rdma); - rioc->rdma =3D NULL; + if (rioc->rdmain) { + qemu_rdma_cleanup(rioc->rdmain); + g_free(rioc->rdmain); + rioc->rdmain =3D NULL; + } + if (rioc->rdmaout) { + qemu_rdma_cleanup(rioc->rdmaout); + g_free(rioc->rdmaout); + rioc->rdmaout =3D NULL; } } =20 @@ -3713,13 +3854,16 @@ static QEMUFile *qemu_fopen_rdma(RDMAContext *rdma,= const char *mode) } =20 rioc =3D QIO_CHANNEL_RDMA(object_new(TYPE_QIO_CHANNEL_RDMA)); - rioc->rdma =3D rdma; =20 if (mode[0] =3D=3D 'w') { rioc->file =3D qemu_fopen_channel_output(QIO_CHANNEL(rioc)); + rioc->rdmaout =3D rdma; + rioc->rdmain =3D rdma->return_path; qemu_file_set_hooks(rioc->file, &rdma_write_hooks); } else { rioc->file =3D qemu_fopen_channel_input(QIO_CHANNEL(rioc)); + rioc->rdmain =3D rdma; + rioc->rdmaout =3D rdma->return_path; qemu_file_set_hooks(rioc->file, &rdma_read_hooks); } =20 diff --git a/migration/savevm.c b/migration/savevm.c index 4251125..90cd00f 100644 --- a/migration/savevm.c +++ b/migration/savevm.c @@ -1621,6 +1621,7 @@ static void *postcopy_ram_listen_thread(void *opaque) qemu_sem_post(&mis->listen_thread_sem); trace_postcopy_ram_listen_thread_start(); =20 + rcu_register_thread(); /* * Because we're a thread and not a coroutine we can't yield * in qemu_file, and thus we must be blocking now. @@ -1661,6 +1662,7 @@ static void *postcopy_ram_listen_thread(void *opaque) * to leave the guest running and fire MCEs for pages that never * arrived as a desperate recovery step. */ + rcu_unregister_thread(); exit(EXIT_FAILURE); } =20 @@ -1675,6 +1677,7 @@ static void *postcopy_ram_listen_thread(void *opaque) migration_incoming_state_destroy(); qemu_loadvm_state_cleanup(); =20 + rcu_unregister_thread(); return NULL; } =20 --=20 1.8.3.1