aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAlex Elder <elder@inktank.com>2013-03-11 23:34:23 -0500
committerSage Weil <sage@inktank.com>2013-05-01 21:17:36 -0700
commit8ea299bcbc85aeaf5348d99614b35433287bec6b (patch)
treee6a0c2d656d96af9b0adb963b63a19bed812c9dc
parent143334ff446d634fcd3145919b5cddcc9148a74a (diff)
libceph: use only ceph_msg_data_advance()
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 <elder@inktank.com> Reviewed-by: Josh Durgin <josh.durgin@inktank.com>
-rw-r--r--net/ceph/messenger.c39
1 files changed, 3 insertions, 36 deletions
diff --git a/net/ceph/messenger.c b/net/ceph/messenger.c
index cb8b571ce79a..dd4b8226a48a 100644
--- a/net/ceph/messenger.c
+++ b/net/ceph/messenger.c
@@ -1383,40 +1383,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;
-
- 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)
@@ -1463,6 +1429,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,
@@ -1477,7 +1444,7 @@ static int write_partial_message_data(struct ceph_connection *con)
}
if (do_datacrc && cursor->need_crc)
crc = ceph_crc32c_page(crc, page, page_offset, length);
- out_msg_pos_next(con, page, length, (size_t) ret);
+ need_crc = ceph_msg_data_advance(&msg->data, (size_t) ret);
}
dout("%s %p msg %p done\n", __func__, con, msg);
@@ -2164,7 +2131,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);
}
if (do_datacrc)
con->in_data_crc = crc;

Privacy Policy