Home
last modified time | relevance | path

Searched refs:front_len (Results 1 – 4 of 4) sorted by relevance

/net/ceph/
Dmsgpool.c15 msg = ceph_msg_new(pool->type, pool->front_len, gfp_mask, true); in msgpool_alloc()
36 int front_len, int size, bool blocking, const char *name) in ceph_msgpool_init() argument
40 pool->front_len = front_len; in ceph_msgpool_init()
55 int front_len) in ceph_msgpool_get() argument
59 if (front_len > pool->front_len) { in ceph_msgpool_get()
61 pool->name, front_len, pool->front_len); in ceph_msgpool_get()
65 return ceph_msg_new(pool->type, front_len, GFP_NOFS, false); in ceph_msgpool_get()
78 msg->front.iov_len = pool->front_len; in ceph_msgpool_put()
79 msg->hdr.front_len = cpu_to_le32(pool->front_len); in ceph_msgpool_put()
Dmessenger.c1247 le32_to_cpu(m->hdr.front_len), le32_to_cpu(m->hdr.middle_len), in prepare_write_message()
1249 BUG_ON(le32_to_cpu(m->hdr.front_len) != m->front.iov_len); in prepare_write_message()
2261 unsigned int front_len, middle_len, data_len; in read_partial_message() local
2283 front_len = le32_to_cpu(con->in_hdr.front_len); in read_partial_message()
2284 if (front_len > CEPH_MSG_MAX_FRONT_LEN) in read_partial_message()
2300 con->in_base_pos = -front_len - middle_len - data_len - in read_partial_message()
2316 front_len, data_len); in read_partial_message()
2332 con->in_base_pos = -front_len - middle_len - data_len - in read_partial_message()
2353 ret = read_partial_message_section(con, &m->front, front_len, in read_partial_message()
2382 m, front_len, m->footer.front_crc, middle_len, in read_partial_message()
[all …]
Dmon_client.c108 monc->m_auth->hdr.front_len = cpu_to_le32(len); in __send_prepared_auth_request()
230 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in __send_subscribe()
1148 int front_len = le32_to_cpu(hdr->front_len); in mon_alloc_msg() local
1175 m = ceph_msg_new(type, front_len, GFP_NOFS, false); in mon_alloc_msg()
1184 } else if (front_len > m->front_alloc_len) { in mon_alloc_msg()
1186 front_len, m->front_alloc_len, in mon_alloc_msg()
1190 m = ceph_msg_new(type, front_len, GFP_NOFS, false); in mon_alloc_msg()
Dosd_client.c1886 (int)msg->front.iov_len, le32_to_cpu(msg->hdr.front_len)); in handle_reply()
2434 msg->hdr.front_len = cpu_to_le32(msg_size); in ceph_osdc_build_request()
2780 int front_len = le32_to_cpu(hdr->front_len); in get_reply() local
2800 if (front_len > req->r_reply->front_alloc_len) { in get_reply()
2802 front_len, req->r_reply->front_alloc_len, in get_reply()
2805 m = ceph_msg_new(CEPH_MSG_OSD_OPREPLY, front_len, GFP_NOFS, in get_reply()
2851 int front = le32_to_cpu(hdr->front_len); in alloc_msg()