"Dr. David Alan Gilbert" <dgilb...@redhat.com> wrote:
> * Juan Quintela (quint...@redhat.com) wrote:
>> We make the locking and the transfer of information specific, even if we
>> are still receiving things through the main thread.
>>
>> Signed-off-by: Juan Quintela <quint...@redhat.com>
>>
>> --
>>
>> We split when we create the main channel and where we start the main
>> migration thread, so we wait for the creation of the other threads.
>>
>> @@ -668,12 +676,20 @@ static void *multifd_recv_thread(void *opaque)
>> {
>> MultiFDRecvParams *p = opaque;
>>
>> + qemu_sem_post(&p->ready);
>> while (true) {
>> qemu_mutex_lock(&p->mutex);
>> if (p->quit) {
>> qemu_mutex_unlock(&p->mutex);
>> break;
>> }
>> + if (p->pages.num) {
>> + p->pages.num = 0;
>
> This could do with some TODO comments in - since this code
> doesn't do anything useful yet and is confusing, but gets clearer
> when you add the filling in the later patches.
Added.
>> + p->done = true;
>> + qemu_mutex_unlock(&p->mutex);
>> + qemu_sem_post(&p->ready);
>> + continue;
>> + }
>> qemu_mutex_unlock(&p->mutex);
>> qemu_sem_wait(&p->sem);
>> }
>> @@ -714,13 +730,21 @@ void multifd_new_channel(QIOChannel *ioc)
>> }
>> qemu_mutex_init(&p->mutex);
>> qemu_sem_init(&p->sem, 0);
>> + qemu_sem_init(&p->ready, 0);
>> p->quit = false;
>> p->id = msg.id;
>> + p->done = false;
>> + multifd_init_pages(&p->pages);
>> p->c = ioc;
>> multifd_recv_state->count++;
>> p->name = g_strdup_printf("multifdrecv_%d", msg.id);
>> + object_ref(OBJECT(ioc));
>
> It would be good to comment to say where that gets unref'd.
Added this on Start of multiple fd work patch.
It belongs there, and there is where the unref is done.
Thanks, Juan.
