/linux-6.1.9/net/ceph/ |
D | msgpool.c | 17 msg = ceph_msg_new2(pool->type, pool->front_len, pool->max_data_items, in msgpool_alloc() 39 int front_len, int max_data_items, int size, in ceph_msgpool_init() argument 44 pool->front_len = front_len; in ceph_msgpool_init() 59 struct ceph_msg *ceph_msgpool_get(struct ceph_msgpool *pool, int front_len, in ceph_msgpool_get() argument 64 if (front_len > pool->front_len || in ceph_msgpool_get() 67 __func__, front_len, max_data_items, pool->name, in ceph_msgpool_get() 68 pool->front_len, pool->max_data_items); in ceph_msgpool_get() 72 return ceph_msg_new2(pool->type, front_len, max_data_items, in ceph_msgpool_get() 86 msg->front.iov_len = pool->front_len; in ceph_msgpool_put() 87 msg->hdr.front_len = cpu_to_le32(pool->front_len); in ceph_msgpool_put()
|
D | messenger_v2.c | 359 static int front_len(const struct ceph_msg *msg) in front_len() function 361 return le32_to_cpu(msg->hdr.front_len); in front_len() 410 static int __tail_onwire_len(int front_len, int middle_len, int data_len, in __tail_onwire_len() argument 413 if (!front_len && !middle_len && !data_len) in __tail_onwire_len() 417 return front_len + middle_len + data_len + in __tail_onwire_len() 420 return padded_len(front_len) + padded_len(middle_len) + in __tail_onwire_len() 426 return __tail_onwire_len(front_len(msg), middle_len(msg), in tail_onwire_len() 594 int front_len, int middle_len, int data_len, in fill_header() argument 602 hdr->front_len = cpu_to_le32(front_len); in fill_header() 650 if (front_len(con->in_msg)) { in verify_epilogue_crcs() [all …]
|
D | messenger_v1.c | 218 le32_to_cpu(m->hdr.front_len), le32_to_cpu(m->hdr.middle_len), in prepare_write_message() 220 WARN_ON(m->front.iov_len != le32_to_cpu(m->hdr.front_len)); in prepare_write_message() 1079 unsigned int front_len, middle_len, data_len; in read_partial_message() local 1101 front_len = le32_to_cpu(con->v1.in_hdr.front_len); in read_partial_message() 1102 if (front_len > CEPH_MSG_MAX_FRONT_LEN) in read_partial_message() 1118 con->v1.in_base_pos = -front_len - middle_len - data_len - in read_partial_message() 1134 front_len, data_len); in read_partial_message() 1143 con->v1.in_base_pos = -front_len - middle_len - in read_partial_message() 1164 ret = read_partial_message_section(con, &m->front, front_len, in read_partial_message() 1204 m, front_len, m->footer.front_crc, middle_len, in read_partial_message() [all …]
|
D | messenger.c | 1348 le32_to_cpu(msg->hdr.front_len), in ceph_con_process_message() 1662 BUG_ON(msg->front.iov_len != le32_to_cpu(msg->hdr.front_len)); in ceph_con_send() 1681 le32_to_cpu(msg->hdr.front_len), in ceph_con_send() 1880 struct ceph_msg *ceph_msg_new2(int type, int front_len, int max_data_items, in ceph_msg_new2() argument 1891 m->hdr.front_len = cpu_to_le32(front_len); in ceph_msg_new2() 1897 if (front_len) { in ceph_msg_new2() 1898 m->front.iov_base = kvmalloc(front_len, flags); in ceph_msg_new2() 1901 front_len); in ceph_msg_new2() 1907 m->front_alloc_len = m->front.iov_len = front_len; in ceph_msg_new2() 1918 dout("ceph_msg_new %p front %d\n", m, front_len); in ceph_msg_new2() [all …]
|
D | mon_client.c | 179 monc->m_auth->hdr.front_len = cpu_to_le32(len); in __send_prepared_auth_request() 377 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in __send_subscribe() 1490 int front_len = le32_to_cpu(hdr->front_len); in mon_alloc_msg() local 1519 m = ceph_msg_new(type, front_len, GFP_NOFS, false); in mon_alloc_msg() 1528 } else if (front_len > m->front_alloc_len) { in mon_alloc_msg() 1530 front_len, m->front_alloc_len, in mon_alloc_msg() 1534 m = ceph_msg_new(type, front_len, GFP_NOFS, false); in mon_alloc_msg()
|
D | auth_x.c | 993 __le32 front_len; in calc_signature() member 1007 sigblock->front_len = msg->hdr.front_len; in calc_signature()
|
D | osd_client.c | 2144 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in encode_request_partial() 2241 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in encode_request_finish() 2244 le64_to_cpu(msg->hdr.tid), le32_to_cpu(msg->hdr.front_len), in encode_request_finish() 4316 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in create_backoff_message() 5356 int front_len = le32_to_cpu(hdr->front_len); in get_reply() local 5379 if (front_len > req->r_reply->front_alloc_len) { in get_reply() 5381 __func__, osd->o_osd, req->r_tid, front_len, in get_reply() 5383 m = ceph_msg_new(CEPH_MSG_OSD_OPREPLY, front_len, GFP_NOFS, in get_reply() 5414 u32 front_len = le32_to_cpu(hdr->front_len); in alloc_msg_with_page_vector() local 5417 m = ceph_msg_new2(type, front_len, 1, GFP_NOIO, false); in alloc_msg_with_page_vector()
|
/linux-6.1.9/include/linux/ceph/ |
D | msgpool.h | 15 int front_len; /* preallocated payload size */ member 20 int front_len, int max_data_items, int size, 23 struct ceph_msg *ceph_msgpool_get(struct ceph_msgpool *pool, int front_len,
|
D | msgr.h | 161 __le32 front_len; /* bytes in main payload */ member 179 __le32 front_len; /* bytes in main payload */ member
|
D | messenger.h | 577 struct ceph_msg *ceph_msg_new2(int type, int front_len, int max_data_items, 579 extern struct ceph_msg *ceph_msg_new(int type, int front_len, gfp_t flags,
|
/linux-6.1.9/fs/ceph/ |
D | metric.c | 170 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in ceph_mdsc_send_metrics()
|
D | mds_client.c | 1464 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in create_session_open_msg() 2149 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in ceph_send_cap_releases() 2169 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in ceph_send_cap_releases() 2672 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in create_request_message() 2796 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in __prepare_send_request() 5495 int front_len = (int) le32_to_cpu(hdr->front_len); in mds_alloc_msg() local 5501 msg = ceph_msg_new(type, front_len, GFP_NOFS, false); in mds_alloc_msg() 5504 type, front_len); in mds_alloc_msg()
|