Message ID | 20211124100617.19786-17-quintela@redhat.com |
---|---|
State | New |
Headers | show |
Series | Migration: Transmit and detect zero pages in the multifd threads | expand |
* Juan Quintela (quintela@redhat.com) wrote: > Signed-off-by: Juan Quintela <quintela@redhat.com> Reviewed-by: Dr. David Alan Gilbert <dgilbert@redhat.com> > --- > migration/multifd.c | 8 +++----- > 1 file changed, 3 insertions(+), 5 deletions(-) > > diff --git a/migration/multifd.c b/migration/multifd.c > index 65676d56fd..6983ba3e7c 100644 > --- a/migration/multifd.c > +++ b/migration/multifd.c > @@ -1059,7 +1059,6 @@ static void *multifd_recv_thread(void *opaque) > rcu_register_thread(); > > while (true) { > - uint32_t used; > uint32_t flags; > > if (p->quit) { > @@ -1082,17 +1081,16 @@ static void *multifd_recv_thread(void *opaque) > break; > } > > - used = p->pages->num; > flags = p->flags; > /* recv methods don't know how to handle the SYNC flag */ > p->flags &= ~MULTIFD_FLAG_SYNC; > - trace_multifd_recv(p->id, p->packet_num, used, flags, > + trace_multifd_recv(p->id, p->packet_num, p->pages->num, flags, > p->next_packet_size); > p->num_packets++; > - p->num_pages += used; > + p->num_pages += p->pages->num; > qemu_mutex_unlock(&p->mutex); > > - if (used) { > + if (p->pages->num) { > ret = multifd_recv_state->ops->recv_pages(p, &local_err); > if (ret != 0) { > break; > -- > 2.33.1 >
diff --git a/migration/multifd.c b/migration/multifd.c index 65676d56fd..6983ba3e7c 100644 --- a/migration/multifd.c +++ b/migration/multifd.c @@ -1059,7 +1059,6 @@ static void *multifd_recv_thread(void *opaque) rcu_register_thread(); while (true) { - uint32_t used; uint32_t flags; if (p->quit) { @@ -1082,17 +1081,16 @@ static void *multifd_recv_thread(void *opaque) break; } - used = p->pages->num; flags = p->flags; /* recv methods don't know how to handle the SYNC flag */ p->flags &= ~MULTIFD_FLAG_SYNC; - trace_multifd_recv(p->id, p->packet_num, used, flags, + trace_multifd_recv(p->id, p->packet_num, p->pages->num, flags, p->next_packet_size); p->num_packets++; - p->num_pages += used; + p->num_pages += p->pages->num; qemu_mutex_unlock(&p->mutex); - if (used) { + if (p->pages->num) { ret = multifd_recv_state->ops->recv_pages(p, &local_err); if (ret != 0) { break;
Signed-off-by: Juan Quintela <quintela@redhat.com> --- migration/multifd.c | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-)