path: root/qemu-coroutine-io.c
diff options
authorMichael Tokarev <mjt@tls.msk.ru>2012-03-14 11:18:54 +0400
committerMichael Tokarev <mjt@tls.msk.ru>2012-06-11 23:12:11 +0400
commit25e5e4c7e9d5ec3e95c9526d1abaca40ada50ab0 (patch)
tree0c224d409dd20ca4c613d3ee35fab755ca13c1a2 /qemu-coroutine-io.c
parent2fc8ae1dd77fbc55146b602f703add6dc314dea4 (diff)
rewrite iov_send_recv() and move it to iov.c
Make it much more understandable, add a missing iov_cnt argument (number of iovs in the iov), and add comments to it. The new implementation has been extensively tested by splitting a large buffer into many small randomly-sized chunks, sending it over socket to another, slow process and verifying the receiving data is the same. Also add a unit test for iov_send_recv(), sending/ receiving data between two processes over a socketpair using random vectors and random sizes. Signed-off-by: Michael Tokarev <mjt@tls.msk.ru>
Diffstat (limited to 'qemu-coroutine-io.c')
1 files changed, 1 insertions, 1 deletions
diff --git a/qemu-coroutine-io.c b/qemu-coroutine-io.c
index 6693c7824b..5734965003 100644
--- a/qemu-coroutine-io.c
+++ b/qemu-coroutine-io.c
@@ -34,7 +34,7 @@ qemu_co_sendv_recvv(int sockfd, struct iovec *iov, unsigned iov_cnt,
size_t done = 0;
ssize_t ret;
while (done < bytes) {
- ret = iov_send_recv(sockfd, iov,
+ ret = iov_send_recv(sockfd, iov, iov_cnt,
offset + done, bytes - done, do_send);
if (ret > 0) {
done += ret;