diff options
author | Michael Tokarev <mjt@tls.msk.ru> | 2012-03-14 11:18:54 +0400 |
---|---|---|
committer | Michael Tokarev <mjt@tls.msk.ru> | 2012-06-11 23:12:11 +0400 |
commit | 25e5e4c7e9d5ec3e95c9526d1abaca40ada50ab0 (patch) | |
tree | 0c224d409dd20ca4c613d3ee35fab755ca13c1a2 /qemu-coroutine-io.c | |
parent | 2fc8ae1dd77fbc55146b602f703add6dc314dea4 (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')
-rw-r--r-- | qemu-coroutine-io.c | 2 |
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; |