[Top][All Lists]
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PATCH] Only flush queue or call sent callback on successfu
From: |
Mark Wu |
Subject: |
[Qemu-devel] [PATCH] Only flush queue or call sent callback on successful delivery |
Date: |
Thu, 27 Oct 2011 16:50:16 +0800 |
Now queue flushing and sent callback could be invoked even on delivery
failure. We add a checking of receiver's return value to avoid this
case.
Signed-off-by: Mark Wu <address@hidden>
---
net/queue.c | 12 +++++++-----
1 files changed, 7 insertions(+), 5 deletions(-)
diff --git a/net/queue.c b/net/queue.c
index 1ab5247..c9a027c 100644
--- a/net/queue.c
+++ b/net/queue.c
@@ -190,8 +190,9 @@ ssize_t qemu_net_queue_send(NetQueue *queue,
qemu_net_queue_append(queue, sender, flags, data, size, sent_cb);
return 0;
}
-
- qemu_net_queue_flush(queue);
+ if (ret > 0) {
+ qemu_net_queue_flush(queue);
+ }
return ret;
}
@@ -214,8 +215,9 @@ ssize_t qemu_net_queue_send_iov(NetQueue *queue,
qemu_net_queue_append_iov(queue, sender, flags, iov, iovcnt, sent_cb);
return 0;
}
-
- qemu_net_queue_flush(queue);
+ if (ret > 0) {
+ qemu_net_queue_flush(queue);
+ }
return ret;
}
@@ -251,7 +253,7 @@ void qemu_net_queue_flush(NetQueue *queue)
break;
}
- if (packet->sent_cb) {
+ if (ret > 0 && packet->sent_cb) {
packet->sent_cb(packet->sender, ret);
}
--
1.7.1
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [Qemu-devel] [PATCH] Only flush queue or call sent callback on successful delivery,
Mark Wu <=