aboutsummaryrefslogtreecommitdiffstats
path: root/net
diff options
context:
space:
mode:
Diffstat (limited to 'net')
-rw-r--r--net/ceph/messenger.c20
1 files changed, 9 insertions, 11 deletions
diff --git a/net/ceph/messenger.c b/net/ceph/messenger.c
index 1965d785cf83..f48e2af95005 100644
--- a/net/ceph/messenger.c
+++ b/net/ceph/messenger.c
@@ -809,11 +809,10 @@ static void prepare_write_message(struct ceph_connection *con)
809 m->bio_iter = NULL; 809 m->bio_iter = NULL;
810#endif 810#endif
811 811
812 dout("prepare_write_message %p seq %lld type %d len %d+%d+%d %d pgs\n", 812 dout("prepare_write_message %p seq %lld type %d len %d+%d+%d (%zd)\n",
813 m, con->out_seq, le16_to_cpu(m->hdr.type), 813 m, con->out_seq, le16_to_cpu(m->hdr.type),
814 le32_to_cpu(m->hdr.front_len), le32_to_cpu(m->hdr.middle_len), 814 le32_to_cpu(m->hdr.front_len), le32_to_cpu(m->hdr.middle_len),
815 le32_to_cpu(m->hdr.data_len), 815 le32_to_cpu(m->hdr.data_len), m->length);
816 m->page_count);
817 BUG_ON(le32_to_cpu(m->hdr.front_len) != m->front.iov_len); 816 BUG_ON(le32_to_cpu(m->hdr.front_len) != m->front.iov_len);
818 817
819 /* tag + hdr + front + middle */ 818 /* tag + hdr + front + middle */
@@ -1091,9 +1090,8 @@ static int write_partial_msg_pages(struct ceph_connection *con)
1091 const size_t trail_len = (msg->trail ? msg->trail->length : 0); 1090 const size_t trail_len = (msg->trail ? msg->trail->length : 0);
1092 const size_t trail_off = data_len - trail_len; 1091 const size_t trail_off = data_len - trail_len;
1093 1092
1094 dout("write_partial_msg_pages %p msg %p page %d/%d offset %d\n", 1093 dout("write_partial_msg_pages %p msg %p page %d offset %d\n",
1095 con, msg, con->out_msg_pos.page, msg->page_count, 1094 con, msg, con->out_msg_pos.page, con->out_msg_pos.page_pos);
1096 con->out_msg_pos.page_pos);
1097 1095
1098 /* 1096 /*
1099 * Iterate through each page that contains data to be 1097 * Iterate through each page that contains data to be
@@ -2695,10 +2693,10 @@ void ceph_msg_data_set_pages(struct ceph_msg *msg, struct page **pages,
2695 /* BUG_ON(!pages); */ 2693 /* BUG_ON(!pages); */
2696 /* BUG_ON(!length); */ 2694 /* BUG_ON(!length); */
2697 /* BUG_ON(msg->pages); */ 2695 /* BUG_ON(msg->pages); */
2698 /* BUG_ON(msg->page_count); */ 2696 /* BUG_ON(msg->length); */
2699 2697
2700 msg->pages = pages; 2698 msg->pages = pages;
2701 msg->page_count = calc_pages_for((u64)alignment, (u64)length); 2699 msg->length = length;
2702 msg->page_alignment = alignment & ~PAGE_MASK; 2700 msg->page_alignment = alignment & ~PAGE_MASK;
2703} 2701}
2704EXPORT_SYMBOL(ceph_msg_data_set_pages); 2702EXPORT_SYMBOL(ceph_msg_data_set_pages);
@@ -2906,7 +2904,7 @@ void ceph_msg_last_put(struct kref *kref)
2906 ceph_buffer_put(m->middle); 2904 ceph_buffer_put(m->middle);
2907 m->middle = NULL; 2905 m->middle = NULL;
2908 } 2906 }
2909 m->page_count = 0; 2907 m->length = 0;
2910 m->pages = NULL; 2908 m->pages = NULL;
2911 2909
2912 if (m->pagelist) { 2910 if (m->pagelist) {
@@ -2926,8 +2924,8 @@ EXPORT_SYMBOL(ceph_msg_last_put);
2926 2924
2927void ceph_msg_dump(struct ceph_msg *msg) 2925void ceph_msg_dump(struct ceph_msg *msg)
2928{ 2926{
2929 pr_debug("msg_dump %p (front_max %d page_count %d)\n", msg, 2927 pr_debug("msg_dump %p (front_max %d length %zd)\n", msg,
2930 msg->front_max, msg->page_count); 2928 msg->front_max, msg->length);
2931 print_hex_dump(KERN_DEBUG, "header: ", 2929 print_hex_dump(KERN_DEBUG, "header: ",
2932 DUMP_PREFIX_OFFSET, 16, 1, 2930 DUMP_PREFIX_OFFSET, 16, 1,
2933 &msg->hdr, sizeof(msg->hdr), true); 2931 &msg->hdr, sizeof(msg->hdr), true);