[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
Re: [PATCH RFC 06/14] migration/rdma: Transmit initial packet
From: |
Dr. David Alan Gilbert |
Subject: |
Re: [PATCH RFC 06/14] migration/rdma: Transmit initial packet |
Date: |
Fri, 14 Feb 2020 16:31:31 +0000 |
User-agent: |
Mutt/1.13.3 (2020-01-12) |
* Zhimin Feng (address@hidden) wrote:
> Transmit initial packet through the multifd RDMA channels,
> so that we can identify the multifd channels.
>
> Signed-off-by: Zhimin Feng <address@hidden>
> ---
> migration/multifd.c | 33 +++++++++++++++++++++------------
> migration/rdma.c | 2 ++
> 2 files changed, 23 insertions(+), 12 deletions(-)
>
> diff --git a/migration/multifd.c b/migration/multifd.c
> index acdfd3d5b3..a57d7a2eab 100644
> --- a/migration/multifd.c
> +++ b/migration/multifd.c
> @@ -483,6 +483,13 @@ void multifd_send_sync_main(QEMUFile *f)
> static void *multifd_rdma_send_thread(void *opaque)
> {
> MultiFDSendParams *p = opaque;
> + Error *local_err = NULL;
> +
> + trace_multifd_send_thread_start(p->id);
> +
> + if (multifd_send_initial_packet(p, &local_err) < 0) {
> + goto out;
> + }
>
> while (true) {
> qemu_mutex_lock(&p->mutex);
> @@ -494,6 +501,12 @@ static void *multifd_rdma_send_thread(void *opaque)
> qemu_sem_wait(&p->sem);
> }
>
> +out:
> + if (local_err) {
> + trace_multifd_send_error(p->id);
> + multifd_send_terminate_threads(local_err);
> + }
> +
> qemu_mutex_lock(&p->mutex);
> p->running = false;
> qemu_mutex_unlock(&p->mutex);
> @@ -964,18 +977,14 @@ bool multifd_recv_new_channel(QIOChannel *ioc, Error
> **errp)
> Error *local_err = NULL;
> int id;
>
> - if (migrate_use_rdma()) {
> - id = multifd_recv_state->count;
> - } else {
> - id = multifd_recv_initial_packet(ioc, &local_err);
> - if (id < 0) {
> - multifd_recv_terminate_threads(local_err);
> - error_propagate_prepend(errp, local_err,
> - "failed to receive packet"
> - " via multifd channel %d: ",
> - atomic_read(&multifd_recv_state->count));
> - return false;
> - }
> + id = multifd_recv_initial_packet(ioc, &local_err);
> + if (id < 0) {
> + multifd_recv_terminate_threads(local_err);
> + error_propagate_prepend(errp, local_err,
> + "failed to receive packet"
> + " via multifd channel %d: ",
> + atomic_read(&multifd_recv_state->count));
> + return false;
I'm confused; hasn't that just undone part of patch 5 ?
Dave
> }
>
> trace_multifd_recv_new_channel(id);
> diff --git a/migration/rdma.c b/migration/rdma.c
> index 48615fcaad..2f1e69197f 100644
> --- a/migration/rdma.c
> +++ b/migration/rdma.c
> @@ -4003,6 +4003,8 @@ int multifd_channel_rdma_connect(void *opaque)
> goto out;
> }
>
> + p->c = QIO_CHANNEL(getQIOChannel(p->file));
> +
> out:
> if (local_err) {
> trace_multifd_send_error(p->id);
> --
> 2.19.1
>
>
--
Dr. David Alan Gilbert / address@hidden / Manchester, UK
- Re: [PATCH RFC 01/14] migration: add the 'migrate_use_rdma_pin_all' function, (continued)
- [PATCH RFC 02/14] migration: judge whether or not the RDMA is used for migration, Zhimin Feng, 2020/02/13
- [PATCH RFC 03/14] migration/rdma: Create multiFd migration threads, Zhimin Feng, 2020/02/13
- [PATCH RFC 11/14] migration/rdma: use multifd to migrate VM for rdma-pin-all mode, Zhimin Feng, 2020/02/13
- [PATCH RFC 10/14] migration/rdma: Wait for all multifd to complete registration, Zhimin Feng, 2020/02/13
- [PATCH RFC 12/14] migration/rdma: use multifd to migrate VM for NOT rdma-pin-all mode, Zhimin Feng, 2020/02/13
- [PATCH RFC 06/14] migration/rdma: Transmit initial packet, Zhimin Feng, 2020/02/13
- Re: [PATCH RFC 06/14] migration/rdma: Transmit initial packet,
Dr. David Alan Gilbert <=
- [PATCH RFC 07/14] migration/rdma: Export the 'qemu_rdma_registration_handle' and 'qemu_rdma_exchange_send' functions, Zhimin Feng, 2020/02/13
- [PATCH RFC 05/14] migration/rdma: Create the multifd channels for RDMA, Zhimin Feng, 2020/02/13
- [PATCH RFC 04/14] migration/rdma: Export the RDMAContext struct, Zhimin Feng, 2020/02/13
- [PATCH RFC 09/14] migration/rdma: register memory for multifd RDMA channels, Zhimin Feng, 2020/02/13
- [PATCH RFC 08/14] migration/rdma: Add the function for dynamic page registration, Zhimin Feng, 2020/02/13
- [PATCH RFC 13/14] migration/rdma: only register the memory for multifd channels, Zhimin Feng, 2020/02/13
- [PATCH RFC 14/14] migration/rdma: RDMA cleanup for multifd migration, Zhimin Feng, 2020/02/13
- Re: [PATCH RFC 00/14] *** multifd for RDMA v2 ***, no-reply, 2020/02/13