aboutsummaryrefslogtreecommitdiff
path: root/migration/multifd.c
diff options
context:
space:
mode:
authorJuan Quintela <quintela@redhat.com>2021-11-19 15:08:16 +0100
committerJuan Quintela <quintela@redhat.com>2022-01-28 15:38:23 +0100
commit468fcb5dd0c965e1af0da9efab09b1462631da18 (patch)
tree87ebcc3540bb6a1113397db453fea4a99250eef1 /migration/multifd.c
parent0a818b89eb8eaf79ae651405907d8110a0935cfd (diff)
downloadqemu-468fcb5dd0c965e1af0da9efab09b1462631da18.zip
qemu-468fcb5dd0c965e1af0da9efab09b1462631da18.tar.gz
qemu-468fcb5dd0c965e1af0da9efab09b1462631da18.tar.bz2
multifd: Remove send_write() method
Everything use now iov's. Signed-off-by: Juan Quintela <quintela@redhat.com> Reviewed-by: Dr. David Alan Gilbert <dgilbert@redhat.com>
Diffstat (limited to 'migration/multifd.c')
-rw-r--r--migration/multifd.c20
1 files changed, 2 insertions, 18 deletions
diff --git a/migration/multifd.c b/migration/multifd.c
index f75bd3c..96b9cc0 100644
--- a/migration/multifd.c
+++ b/migration/multifd.c
@@ -101,22 +101,6 @@ static int nocomp_send_prepare(MultiFDSendParams *p, Error **errp)
}
/**
- * nocomp_send_write: do the actual write of the data
- *
- * For no compression we just have to write the data.
- *
- * Returns 0 for success or -1 for error
- *
- * @p: Params for the channel that we are using
- * @used: number of pages used
- * @errp: pointer to an error
- */
-static int nocomp_send_write(MultiFDSendParams *p, uint32_t used, Error **errp)
-{
- return qio_channel_writev_all(p->c, p->iov, p->iovs_num, errp);
-}
-
-/**
* nocomp_recv_setup: setup receive side
*
* For no compression this function does nothing.
@@ -173,7 +157,6 @@ static MultiFDMethods multifd_nocomp_ops = {
.send_setup = nocomp_send_setup,
.send_cleanup = nocomp_send_cleanup,
.send_prepare = nocomp_send_prepare,
- .send_write = nocomp_send_write,
.recv_setup = nocomp_recv_setup,
.recv_cleanup = nocomp_recv_cleanup,
.recv_pages = nocomp_recv_pages
@@ -690,7 +673,8 @@ static void *multifd_send_thread(void *opaque)
}
if (used) {
- ret = multifd_send_state->ops->send_write(p, used, &local_err);
+ ret = qio_channel_writev_all(p->c, p->iov, p->iovs_num,
+ &local_err);
if (ret != 0) {
break;
}