Signed-off-by: Juan Quintela <quintela@redhat.com>
Reviewed-by: Dr. David Alan Gilbert <dgilbert@redhat.com>
rcu_register_thread();
while (true) {
- uint32_t used;
uint32_t flags;
if (p->quit) {
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;