aboutsummaryrefslogtreecommitdiffstats
path: root/net/ceph
diff options
context:
space:
mode:
authorAlex Elder <elder@dreamhost.com>2012-02-15 08:43:54 -0500
committerAlex Elder <elder@dreamhost.com>2012-03-22 11:47:51 -0400
commitf42299e6c3883c69c14079b8c88fe33815b2dcc3 (patch)
treef94d09a6438705bff01311dbe7cd426d1a800ff5 /net/ceph
parentfe3ad593e2c34457ffa6233014ab19f4d36f85f2 (diff)
libceph: small refactor in write_partial_kvec()
Make a small change in the code that counts down kvecs consumed by a ceph_tcp_sendmsg() call. Same functionality, just blocked out a little differently. Signed-off-by: Alex Elder <elder@dreamhost.com> Signed-off-by: Sage Weil <sage@newdream.net>
Diffstat (limited to 'net/ceph')
-rw-r--r--net/ceph/messenger.c23
1 files changed, 12 insertions, 11 deletions
diff --git a/net/ceph/messenger.c b/net/ceph/messenger.c
index 575511a29eb7..e8f236e87f38 100644
--- a/net/ceph/messenger.c
+++ b/net/ceph/messenger.c
@@ -747,17 +747,18 @@ static int write_partial_kvec(struct ceph_connection *con)
747 con->out_kvec_bytes -= ret; 747 con->out_kvec_bytes -= ret;
748 if (con->out_kvec_bytes == 0) 748 if (con->out_kvec_bytes == 0)
749 break; /* done */ 749 break; /* done */
750 while (ret > 0) { 750
751 if (ret >= con->out_kvec_cur->iov_len) { 751 /* account for full iov entries consumed */
752 ret -= con->out_kvec_cur->iov_len; 752 while (ret >= con->out_kvec_cur->iov_len) {
753 con->out_kvec_cur++; 753 BUG_ON(!con->out_kvec_left);
754 con->out_kvec_left--; 754 ret -= con->out_kvec_cur->iov_len;
755 } else { 755 con->out_kvec_cur++;
756 con->out_kvec_cur->iov_len -= ret; 756 con->out_kvec_left--;
757 con->out_kvec_cur->iov_base += ret; 757 }
758 ret = 0; 758 /* and for a partially-consumed entry */
759 break; 759 if (ret) {
760 } 760 con->out_kvec_cur->iov_len -= ret;
761 con->out_kvec_cur->iov_base += ret;
761 } 762 }
762 } 763 }
763 con->out_kvec_left = 0; 764 con->out_kvec_left = 0;