[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
Re: [Qemu-devel] [PATCH v10 19/24] migration: Create multifd channels
From: |
Juan Quintela |
Subject: |
Re: [Qemu-devel] [PATCH v10 19/24] migration: Create multifd channels |
Date: |
Fri, 16 Mar 2018 09:43:46 +0100 |
User-agent: |
Gnus/5.13 (Gnus v5.13) Emacs/25.3 (gnu/linux) |
Peter Xu <address@hidden> wrote:
> On Thu, Mar 15, 2018 at 01:57:54PM +0100, Juan Quintela wrote:
>> Peter Xu <address@hidden> wrote:
>> > On Wed, Mar 07, 2018 at 12:00:05PM +0100, Juan Quintela wrote:
>> >> In both sides. We still don't transmit anything through them.
>> >
>> > s/In/On/?
>> >> +static void multifd_new_send_channel_async(QIOTask *task, gpointer
>> >> opaque)
>> >> +{
>> >> + MultiFDSendParams *p = opaque;
>> >> + QIOChannel *sioc = QIO_CHANNEL(qio_task_get_source(task));
>> >> + Error *local_err = NULL;
>> >> +
>> >> + if (qio_task_propagate_error(task, &local_err)) {
>> >> + if (multifd_save_cleanup(&local_err) != 0) {
>> >
>> > Do we need to call multifd_save_cleanup() explicitly here?
>>
>> Is the easiest way of stoping all multifd threads, no?
>
> Yeah, but again, I thought it would be called later too, since...
But we are not stopping the threads. Only if you preffer to call there
terminate_multifd_send_threads(). Probably it is better to call
terminate_multifd_send_threads(), it is what we do on the rest of
errors.
Changing it.
>> > Asked since I saw that it would also be called in migrate_fd_cleanup(),
>> > and it seems that we should call migrate_fd_cleanup() soon too when
>> > this happens?
>>
>> We need to stop migraiton. thtat migrate_set_error() is only used for
>> reporting in info migrate, it is not acted upon.
>>
>> Yes, perhaps it should, but as it is, it is not. So, I think it is
>> right O:-)
>
> ... after Dave's 688a3dcba9 ("migration: Route errors down through
> migration_channel_connect", 2018-02-06), all these channel errors
> should finally be routed to migrate_fd_connect(), and in that we have:
>
> void migrate_fd_connect(MigrationState *s, Error *error_in)
> {
> s->expected_downtime = s->parameters.downtime_limit;
> s->cleanup_bh = qemu_bh_new(migrate_fd_cleanup, s);
> if (error_in) {
> migrate_fd_error(s, error_in);
> migrate_fd_cleanup(s);
> return;
> }
> ...
> }
>
> Then, in migrate_fd_cleanup() we have multifd_save_cleanup(). That's
> why I thought we can skip the cleanup here since after all we'll do it
> in other places (and we can keep the cleanup code unified).
Ok, it is better, changing to terminate_multifd_send_threads.
Thanks, Juan.
- [Qemu-devel] [PATCH v10 13/24] migration: Introduce multifd_recv_new_channel(), (continued)
- [Qemu-devel] [PATCH v10 13/24] migration: Introduce multifd_recv_new_channel(), Juan Quintela, 2018/03/07
- [Qemu-devel] [PATCH v10 18/24] migration: Add multifd traces for start/end thread, Juan Quintela, 2018/03/07
- [Qemu-devel] [PATCH v10 16/24] migration: Synchronize recv threads, Juan Quintela, 2018/03/07
- [Qemu-devel] [PATCH v10 15/24] migration: Synchronize send threads, Juan Quintela, 2018/03/07
- [Qemu-devel] [PATCH v10 19/24] migration: Create multifd channels, Juan Quintela, 2018/03/07
[Qemu-devel] [PATCH v10 23/24] migration: Create pages structure for reception, Juan Quintela, 2018/03/07
[Qemu-devel] [PATCH v10 21/24] migration: Transmit initial package through the multifd channels, Juan Quintela, 2018/03/07
[Qemu-devel] [PATCH v10 20/24] migration: Delay start of migration main routines, Juan Quintela, 2018/03/07
[Qemu-devel] [PATCH v10 22/24] migration: Create ram_multifd_page, Juan Quintela, 2018/03/07
[Qemu-devel] [PATCH v10 17/24] migration: Export functions to create send channels, Juan Quintela, 2018/03/07
[Qemu-devel] [PATCH v10 24/24] [RFC] migration: Send pages through the multifd channels, Juan Quintela, 2018/03/07