| /Linux-v4.19/net/ceph/ |
| D | msgpool.c | 17 msg = ceph_msg_new(pool->type, pool->front_len, gfp_mask, true); in msgpool_alloc()
38 int front_len, int size, bool blocking, const char *name) in ceph_msgpool_init() argument
42 pool->front_len = front_len; in ceph_msgpool_init()
57 int front_len) in ceph_msgpool_get() argument
61 if (front_len > pool->front_len) { in ceph_msgpool_get()
63 pool->name, front_len, pool->front_len); in ceph_msgpool_get()
67 return ceph_msg_new(pool->type, front_len, GFP_NOFS, false); in ceph_msgpool_get()
80 msg->front.iov_len = pool->front_len; in ceph_msgpool_put()
81 msg->hdr.front_len = cpu_to_le32(pool->front_len); in ceph_msgpool_put()
|
| D | messenger.c | 1327 le32_to_cpu(m->hdr.front_len), le32_to_cpu(m->hdr.middle_len), in prepare_write_message()
1329 WARN_ON(m->front.iov_len != le32_to_cpu(m->hdr.front_len)); in prepare_write_message()
2392 unsigned int front_len, middle_len, data_len; in read_partial_message() local
2414 front_len = le32_to_cpu(con->in_hdr.front_len); in read_partial_message()
2415 if (front_len > CEPH_MSG_MAX_FRONT_LEN) in read_partial_message()
2431 con->in_base_pos = -front_len - middle_len - data_len - in read_partial_message()
2447 front_len, data_len); in read_partial_message()
2456 con->in_base_pos = -front_len - middle_len - data_len - in read_partial_message()
2477 ret = read_partial_message_section(con, &m->front, front_len, in read_partial_message()
2511 m, front_len, m->footer.front_crc, middle_len, in read_partial_message()
[all …]
|
| D | mon_client.c | 108 monc->m_auth->hdr.front_len = cpu_to_le32(len); in __send_prepared_auth_request()
293 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in __send_subscribe()
1268 int front_len = le32_to_cpu(hdr->front_len); in mon_alloc_msg() local
1297 m = ceph_msg_new(type, front_len, GFP_NOFS, false); in mon_alloc_msg()
1306 } else if (front_len > m->front_alloc_len) { in mon_alloc_msg()
1308 front_len, m->front_alloc_len, in mon_alloc_msg()
1312 m = ceph_msg_new(type, front_len, GFP_NOFS, false); in mon_alloc_msg()
|
| D | auth_x.c | 836 __le32 front_len; in calc_signature() member
850 sigblock->front_len = msg->hdr.front_len; in calc_signature()
|
| D | osd_client.c | 2012 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in encode_request_partial()
2109 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in encode_request_finish()
2112 le64_to_cpu(msg->hdr.tid), le32_to_cpu(msg->hdr.front_len), in encode_request_finish()
4099 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in create_backoff_message()
5234 int front_len = le32_to_cpu(hdr->front_len); in get_reply() local
5257 if (front_len > req->r_reply->front_alloc_len) { in get_reply()
5259 __func__, osd->o_osd, req->r_tid, front_len, in get_reply()
5261 m = ceph_msg_new(CEPH_MSG_OSD_OPREPLY, front_len, GFP_NOFS, in get_reply()
5295 u32 front_len = le32_to_cpu(hdr->front_len); in alloc_msg_with_page_vector() local
5298 m = ceph_msg_new(type, front_len, GFP_NOIO, false); in alloc_msg_with_page_vector()
|
| /Linux-v4.19/include/linux/ceph/ |
| D | msgpool.h | 15 int front_len; /* preallocated payload size */ member
19 int front_len, int size, bool blocking,
23 int front_len);
|
| D | msgr.h | 133 __le32 front_len; /* bytes in main payload */ member
151 __le32 front_len; /* bytes in main payload */ member
|
| D | messenger.h | 384 extern struct ceph_msg *ceph_msg_new(int type, int front_len, gfp_t flags,
|
| /Linux-v4.19/fs/ceph/ |
| D | mds_client.c | 1003 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in create_session_open_msg()
1730 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in ceph_send_cap_releases()
1750 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in ceph_send_cap_releases()
2135 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in create_request_message()
2227 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in __prepare_send_request()
4223 int front_len = (int) le32_to_cpu(hdr->front_len); in mds_alloc_msg() local
4229 msg = ceph_msg_new(type, front_len, GFP_NOFS, false); in mds_alloc_msg()
4232 type, front_len); in mds_alloc_msg()
|
