[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
Re: [Qemu-devel] [PATCH v13 05/12] migration: Multifd channels always wa
From: |
Dr. David Alan Gilbert |
Subject: |
Re: [Qemu-devel] [PATCH v13 05/12] migration: Multifd channels always wait on the sem |
Date: |
Mon, 11 Jun 2018 18:13:12 +0100 |
User-agent: |
Mutt/1.10.0 (2018-05-17) |
* Juan Quintela (address@hidden) wrote:
> Either for quit, sync or packet, we first wake them.
>
> Signed-off-by: Juan Quintela <address@hidden>
Again, I'd prefer if this was merged in with later stuff that
changes it heavily; but I realise it's difficult to split, and those
do clean it up, so:
Reviewed-by: Dr. David Alan Gilbert <address@hidden>
> ---
> migration/ram.c | 13 +++++++++++--
> 1 file changed, 11 insertions(+), 2 deletions(-)
>
> diff --git a/migration/ram.c b/migration/ram.c
> index ab715cc148..90f62144e2 100644
> --- a/migration/ram.c
> +++ b/migration/ram.c
> @@ -868,6 +868,7 @@ static void *multifd_send_thread(void *opaque)
> p->num_packets = 1;
>
> while (true) {
> + qemu_sem_wait(&p->sem);
> qemu_mutex_lock(&p->mutex);
> multifd_send_fill_packet(p);
> if (p->quit) {
> @@ -875,7 +876,9 @@ static void *multifd_send_thread(void *opaque)
> break;
> }
> qemu_mutex_unlock(&p->mutex);
> - qemu_sem_wait(&p->sem);
> + /* this is impossible */
> + error_setg(&local_err, "multifd_send_thread: Unknown command");
> + break;
> }
>
> out:
> @@ -1019,6 +1022,7 @@ static void *multifd_recv_thread(void *opaque)
> trace_multifd_recv_thread_start(p->id);
>
> while (true) {
> + qemu_sem_wait(&p->sem);
> qemu_mutex_lock(&p->mutex);
> if (false) {
> /* ToDo: Packet reception goes here */
> @@ -1033,9 +1037,14 @@ static void *multifd_recv_thread(void *opaque)
> break;
> }
> qemu_mutex_unlock(&p->mutex);
> - qemu_sem_wait(&p->sem);
> + /* this is impossible */
> + error_setg(&local_err, "multifd_recv_thread: Unknown command");
> + break;
> }
>
> + if (local_err) {
> + multifd_recv_terminate_threads(local_err);
> + }
> qemu_mutex_lock(&p->mutex);
> p->running = false;
> qemu_mutex_unlock(&p->mutex);
> --
> 2.17.0
>
--
Dr. David Alan Gilbert / address@hidden / Manchester, UK
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- Re: [Qemu-devel] [PATCH v13 05/12] migration: Multifd channels always wait on the sem,
Dr. David Alan Gilbert <=