* Juan Quintela (quintela@redhat.com) wrote:
> Either for quit, sync or packet, we first wake them.
>
> Signed-off-by: Juan Quintela <quintela@redhat.com>
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 <dgilbert@redhat.com>
> ---
> 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 / dgilbert@redhat.com / Manchester, UK