diff options
| author | Lukas Straub <lukasstraub2@web.de> | 2021-09-09 09:18:08 +0200 |
|---|---|---|
| committer | Juan Quintela <quintela@redhat.com> | 2021-10-19 08:39:04 +0200 |
| commit | 20171ea8950c619f00dc5cfa6136fd489998ffc5 (patch) | |
| tree | ee6a87b409fb8cf2b214860b2d17572dcc95112d | |
| parent | 362534a643b4a34bcb223996538ce9de5cdab946 (diff) | |
| download | qemu-20171ea8950c619f00dc5cfa6136fd489998ffc5.zip qemu-20171ea8950c619f00dc5cfa6136fd489998ffc5.tar.gz qemu-20171ea8950c619f00dc5cfa6136fd489998ffc5.tar.bz2 | |
multifd: Implement yank for multifd send side
To: qemu-devel <qemu-devel@nongnu.org>
Cc: "Dr. David Alan Gilbert" <dgilbert@redhat.com>, Juan Quintela
<quintela@redhat.com>, Peter Xu <peterx@redhat.com>, Leonardo Bras Soares
Passos <lsoaresp@redhat.com>
Date: Wed, 1 Sep 2021 17:58:57 +0200 (1 week, 15 hours, 17 minutes ago)
[[PGP Signed Part:No public key for 35AB0B289C5DB258 created at 2021-09-01T17:58:57+0200 using RSA]]
When introducing yank functionality in the migration code I forgot
to cover the multifd send side.
Signed-off-by: Lukas Straub <lukasstraub2@web.de>
Tested-by: Leonardo Bras <leobras@redhat.com>
Reviewed-by: Leonardo Bras <leobras@redhat.com>
Reviewed-by: Juan Quintela <quintela@redhat.com>
Signed-off-by: Juan Quintela <quintela@redhat.com>
| -rw-r--r-- | migration/multifd.c | 6 | ||||
| -rw-r--r-- | migration/multifd.h | 2 |
2 files changed, 7 insertions, 1 deletions
diff --git a/migration/multifd.c b/migration/multifd.c index 377da78..5a4f158 100644 --- a/migration/multifd.c +++ b/migration/multifd.c @@ -546,6 +546,9 @@ void multifd_save_cleanup(void) MultiFDSendParams *p = &multifd_send_state->params[i]; Error *local_err = NULL; + if (p->registered_yank) { + migration_ioc_unregister_yank(p->c); + } socket_send_channel_destroy(p->c); p->c = NULL; qemu_mutex_destroy(&p->mutex); @@ -813,7 +816,8 @@ static bool multifd_channel_connect(MultiFDSendParams *p, return false; } } else { - /* update for tls qio channel */ + migration_ioc_register_yank(ioc); + p->registered_yank = true; p->c = ioc; qemu_thread_create(&p->thread, p->name, multifd_send_thread, p, QEMU_THREAD_JOINABLE); diff --git a/migration/multifd.h b/migration/multifd.h index 8d6751f..16c4d11 100644 --- a/migration/multifd.h +++ b/migration/multifd.h @@ -85,6 +85,8 @@ typedef struct { bool running; /* should this thread finish */ bool quit; + /* is the yank function registered */ + bool registered_yank; /* thread has work to do */ int pending_job; /* array of pages to sent */ |