[PATCH 4/4] libceph: use only ceph_msg_data_advance()

[Alex Elder]

The *_msg_pos_next() functions do little more than call
ceph_msg_data_advance().  Replace those wrapper functions with
a simple call to ceph_msg_data_advance().

This cleanup is related to:
    http://tracker.ceph.com/issues/4428

Signed-off-by: Alex Elder <el...@inktank.com>
---
 net/ceph/messenger.c |   39 +++------------------------------------
 1 file changed, 3 insertions(+), 36 deletions(-)

diff --git a/net/ceph/messenger.c b/net/ceph/messenger.c
index 3180f82..8e07ac4 100644
--- a/net/ceph/messenger.c
+++ b/net/ceph/messenger.c
@@ -1365,40 +1365,6 @@ out:
        return ret;  /* done! */
 }

-static void out_msg_pos_next(struct ceph_connection *con, struct page
*page,
-                       size_t len, size_t sent)
-{
-       struct ceph_msg *msg = con->out_msg;
-       bool need_crc = false;
-
-       BUG_ON(!msg);
-       BUG_ON(!sent);
-
-       need_crc = ceph_msg_data_advance(&msg->data, sent);
-       BUG_ON(need_crc && sent != len);
-
-       if (sent < len)
-               return;
-
-       BUG_ON(sent != len);
-}
-
-static void in_msg_pos_next(struct ceph_connection *con, size_t len,
-                               size_t received)
-{
-       struct ceph_msg *msg = con->in_msg;
-
-       BUG_ON(!msg);
-       BUG_ON(!received);
-
-       (void) ceph_msg_data_advance(&msg->data, received);
-
-       if (received < len)
-               return;
-
-       BUG_ON(received != len);
-}
-
 static u32 ceph_crc32c_page(u32 crc, struct page *page,
                                unsigned int page_offset,
                                unsigned int length)
@@ -1445,6 +1411,7 @@ static int write_partial_message_data(struct
ceph_connection *con)
                size_t page_offset;
                size_t length;
                bool last_piece;
+               bool need_crc;
                int ret;

                page = ceph_msg_data_next(&msg->data, &page_offset, &length,
@@ -1458,7 +1425,7 @@ static int write_partial_message_data(struct
ceph_connection *con)

                        return ret;
                }
-               out_msg_pos_next(con, page, length, (size_t) ret);
+               need_crc = ceph_msg_data_advance(&msg->data, (size_t) ret);
        }
        msg->footer.data_crc = cpu_to_le32(crc);

@@ -2133,7 +2100,7 @@ static int read_partial_msg_data(struct
ceph_connection *con)

                if (do_datacrc)
                        crc = ceph_crc32c_page(crc, page, page_offset, ret);
-               in_msg_pos_next(con, length, ret);
+               (void) ceph_msg_data_advance(&msg->data, (size_t) ret);
        }
        con->in_data_crc = crc;

-- 
1.7.9.5

--
To unsubscribe from this list: send the line "unsubscribe ceph-devel" in
the body of a message to majord...@vger.kernel.org
More majordomo info at  http://vger.kernel.org/majordomo-info.html