Lines Matching refs:data_len
1147 static void prepare_message_data(struct ceph_msg *msg, u32 data_len) in prepare_message_data() argument
1150 BUG_ON(!data_len); in prepare_message_data()
1154 ceph_msg_data_cursor_init(msg, (size_t)data_len); in prepare_message_data()
1217 WARN_ON(m->data_length != le32_to_cpu(m->hdr.data_len)); in prepare_write_message()
2219 unsigned int front_len, middle_len, data_len; in read_partial_message() local
2247 data_len = le32_to_cpu(con->in_hdr.data_len); in read_partial_message()
2248 if (data_len > CEPH_MSG_MAX_DATA_LEN) in read_partial_message()
2258 con->in_base_pos = -front_len - middle_len - data_len - in read_partial_message()
2274 front_len, data_len); in read_partial_message()
2280 if (con->in_msg && data_len > con->in_msg->data_length) { in read_partial_message()
2282 __func__, data_len, con->in_msg->data_length); in read_partial_message()
2290 con->in_base_pos = -front_len - middle_len - data_len - in read_partial_message()
2306 if (data_len) in read_partial_message()
2307 prepare_message_data(con->in_msg, data_len); in read_partial_message()
2326 if (data_len) { in read_partial_message()
2341 m->footer.middle_crc, data_len, m->footer.data_crc); in read_partial_message()
2393 le32_to_cpu(msg->hdr.data_len), in process_message()
2922 le32_to_cpu(msg->hdr.data_len)); in ceph_con_send()
2988 unsigned int data_len = le32_to_cpu(con->in_hdr.data_len); in ceph_msg_revoke_incoming() local
2996 data_len - in ceph_msg_revoke_incoming()