|
@@ -677,7 +677,7 @@ static void *multifd_send_thread(void *opaque)
|
|
|
|
|
|
if (p->pending_job) {
|
|
if (p->pending_job) {
|
|
uint64_t packet_num = p->packet_num;
|
|
uint64_t packet_num = p->packet_num;
|
|
- uint32_t flags = p->flags;
|
|
|
|
|
|
+ uint32_t flags;
|
|
p->normal_num = 0;
|
|
p->normal_num = 0;
|
|
|
|
|
|
if (use_zero_copy_send) {
|
|
if (use_zero_copy_send) {
|
|
@@ -699,6 +699,7 @@ static void *multifd_send_thread(void *opaque)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
multifd_send_fill_packet(p);
|
|
multifd_send_fill_packet(p);
|
|
|
|
+ flags = p->flags;
|
|
p->flags = 0;
|
|
p->flags = 0;
|
|
p->num_packets++;
|
|
p->num_packets++;
|
|
p->total_normal_pages += p->normal_num;
|
|
p->total_normal_pages += p->normal_num;
|