Lines Matching refs:data_len
1213 static void prepare_message_data(struct ceph_msg *msg, u32 data_len) in prepare_message_data() argument
1216 BUG_ON(!data_len); in prepare_message_data()
1220 ceph_msg_data_cursor_init(msg, (size_t)data_len); in prepare_message_data()
1291 WARN_ON(m->data_length != le32_to_cpu(m->hdr.data_len)); in prepare_write_message()
2296 unsigned int front_len, middle_len, data_len; in read_partial_message() local
2324 data_len = le32_to_cpu(con->in_hdr.data_len); in read_partial_message()
2325 if (data_len > CEPH_MSG_MAX_DATA_LEN) in read_partial_message()
2335 con->in_base_pos = -front_len - middle_len - data_len - in read_partial_message()
2351 front_len, data_len); in read_partial_message()
2357 if (con->in_msg && data_len > con->in_msg->data_length) { in read_partial_message()
2359 __func__, data_len, con->in_msg->data_length); in read_partial_message()
2367 con->in_base_pos = -front_len - middle_len - data_len - in read_partial_message()
2383 if (data_len) in read_partial_message()
2384 prepare_message_data(con->in_msg, data_len); in read_partial_message()
2403 if (data_len) { in read_partial_message()
2427 m->footer.middle_crc, data_len, m->footer.data_crc); in read_partial_message()
2485 le32_to_cpu(msg->hdr.data_len), in process_message()
3027 le32_to_cpu(msg->hdr.data_len)); in ceph_con_send()
3108 unsigned int data_len = le32_to_cpu(con->in_hdr.data_len); in ceph_msg_revoke_incoming() local
3116 data_len - in ceph_msg_revoke_incoming()