Home
last modified time | relevance | path

Searched refs:front_len (Results 1 - 22 of 22) sorted by relevance

/kernel/linux/linux-5.10/net/ceph/
H A Dmsgpool.c17 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()
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_item in ceph_msgpool_get()
38 ceph_msgpool_init(struct ceph_msgpool *pool, int type, int front_len, int max_data_items, int size, const char *name) ceph_msgpool_init() argument
[all...]
H A Dmessenger.c1295 le32_to_cpu(m->hdr.front_len), le32_to_cpu(m->hdr.middle_len), in prepare_write_message()
1297 WARN_ON(m->front.iov_len != le32_to_cpu(m->hdr.front_len)); in prepare_write_message()
2362 unsigned int front_len, middle_len, data_len; in read_partial_message() local
2384 front_len = le32_to_cpu(con->in_hdr.front_len); in read_partial_message()
2385 if (front_len > CEPH_MSG_MAX_FRONT_LEN) in read_partial_message()
2401 con->in_base_pos = -front_len - middle_len - data_len - in read_partial_message()
2417 front_len, data_len); in read_partial_message()
2426 con->in_base_pos = -front_len - middle_len - data_len - in read_partial_message()
2447 ret = read_partial_message_section(con, &m->front, front_len, in read_partial_message()
3187 unsigned int front_len = le32_to_cpu(con->in_hdr.front_len); ceph_msg_revoke_incoming() local
3326 ceph_msg_new2(int type, int front_len, int max_data_items, gfp_t flags, bool can_fail) ceph_msg_new2() argument
3382 ceph_msg_new(int type, int front_len, gfp_t flags, bool can_fail) ceph_msg_new() argument
[all...]
H A Dmon_client.c114 monc->m_auth->hdr.front_len = cpu_to_le32(len); in __send_prepared_auth_request()
306 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in __send_subscribe()
1335 int front_len = le32_to_cpu(hdr->front_len); in mon_alloc_msg() local
1364 m = ceph_msg_new(type, front_len, GFP_NOFS, false); in mon_alloc_msg()
1373 } else if (front_len > m->front_alloc_len) { in mon_alloc_msg()
1375 front_len, m->front_alloc_len, in mon_alloc_msg()
1379 m = ceph_msg_new(type, front_len, GFP_NOFS, false); in mon_alloc_msg()
H A Dauth_x.c836 __le32 front_len; in calc_signature() member
850 sigblock->front_len = msg->hdr.front_len; in calc_signature()
H A Dosd_client.c2142 /* front_len is finalized in encode_request_finish() */ in encode_request_partial()
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()
4317 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in create_backoff_message()
5398 int front_len = le32_to_cpu(hdr->front_len); in get_reply() local
5421 if (front_len > req->r_reply->front_alloc_len) { in get_reply()
5423 __func__, osd->o_osd, req->r_tid, front_len, in get_reply()
5425 m = ceph_msg_new(CEPH_MSG_OSD_OPREPLY, front_len, GFP_NOF in get_reply()
5456 u32 front_len = le32_to_cpu(hdr->front_len); alloc_msg_with_page_vector() local
[all...]
/kernel/linux/linux-6.6/net/ceph/
H A Dmsgpool.c17 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()
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_item in ceph_msgpool_get()
38 ceph_msgpool_init(struct ceph_msgpool *pool, int type, int front_len, int max_data_items, int size, const char *name) ceph_msgpool_init() argument
[all...]
H A Dmessenger_v2.c359 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()
412 static int __tail_onwire_len(int front_len, int middle_len, int data_len, in __tail_onwire_len() argument
415 BUG_ON(front_len < 0 || front_len > CEPH_MSG_MAX_FRONT_LEN || in __tail_onwire_len()
419 if (!front_len && !middle_len && !data_len) in __tail_onwire_len()
423 return front_len + middle_len + data_len + in __tail_onwire_len()
426 return padded_len(front_len) + padded_len(middle_len) + in __tail_onwire_len()
432 return __tail_onwire_len(front_len(msg), middle_len(msg), in tail_onwire_len()
605 int front_len, in in fill_header()
603 fill_header(struct ceph_msg_header *hdr, const struct ceph_msg_header2 *hdr2, int front_len, int middle_len, int data_len, const struct ceph_entity_name *peer_name) fill_header() argument
[all...]
H A Dmessenger.c1420 le32_to_cpu(msg->hdr.front_len), in ceph_con_process_message()
1734 BUG_ON(msg->front.iov_len != le32_to_cpu(msg->hdr.front_len)); in ceph_con_send()
1753 le32_to_cpu(msg->hdr.front_len), in ceph_con_send()
1964 struct ceph_msg *ceph_msg_new2(int type, int front_len, int max_data_items, in ceph_msg_new2() argument
1975 m->hdr.front_len = cpu_to_le32(front_len); in ceph_msg_new2()
1981 if (front_len) { in ceph_msg_new2()
1982 m->front.iov_base = kvmalloc(front_len, flags); in ceph_msg_new2()
1985 front_len); in ceph_msg_new2()
1991 m->front_alloc_len = m->front.iov_len = front_len; in ceph_msg_new2()
2020 ceph_msg_new(int type, int front_len, gfp_t flags, bool can_fail) ceph_msg_new() argument
[all...]
H A Dmessenger_v1.c218 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()
1153 unsigned int front_len, middle_len, data_len; in read_partial_message() local
1175 front_len = le32_to_cpu(con->v1.in_hdr.front_len); in read_partial_message()
1176 if (front_len > CEPH_MSG_MAX_FRONT_LEN) in read_partial_message()
1192 con->v1.in_base_pos = -front_len - middle_len - data_len - in read_partial_message()
1208 front_len, data_len); in read_partial_message()
1217 con->v1.in_base_pos = -front_len - middle_len - in read_partial_message()
1238 ret = read_partial_message_section(con, &m->front, front_len, in read_partial_message()
1592 unsigned int front_len = le32_to_cpu(con->v1.in_hdr.front_len); ceph_con_v1_revoke_incoming() local
[all...]
H A Dmon_client.c179 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()
H A Dauth_x.c993 __le32 front_len; in calc_signature() member
1007 sigblock->front_len = msg->hdr.front_len; in calc_signature()
H A Dosd_client.c2223 /* front_len is finalized in encode_request_finish() */ in encode_request_partial()
2225 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in encode_request_partial()
2322 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in encode_request_finish()
2325 le64_to_cpu(msg->hdr.tid), le32_to_cpu(msg->hdr.front_len), in encode_request_finish()
4407 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in create_backoff_message()
5466 int front_len = le32_to_cpu(hdr->front_len); in get_reply() local
5490 if (front_len > req->r_reply->front_alloc_len) { in get_reply()
5492 __func__, osd->o_osd, req->r_tid, front_len, in get_reply()
5494 m = ceph_msg_new(CEPH_MSG_OSD_OPREPLY, front_len, GFP_NOF in get_reply()
5528 u32 front_len = le32_to_cpu(hdr->front_len); alloc_msg_with_page_vector() local
[all...]
/kernel/linux/linux-5.10/include/linux/ceph/
H A Dmsgpool.h15 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,
H A Dmsgr.h140 __le32 front_len; /* bytes in main payload */ member
158 __le32 front_len; /* bytes in main payload */ member
H A Dmessenger.h371 struct ceph_msg *ceph_msg_new2(int type, int front_len, int max_data_items,
373 extern struct ceph_msg *ceph_msg_new(int type, int front_len, gfp_t flags,
/kernel/linux/linux-6.6/include/linux/ceph/
H A Dmsgpool.h15 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,
H A Dmsgr.h161 __le32 front_len; /* bytes in main payload */ member
179 __le32 front_len; /* bytes in main payload */ member
H A Dmessenger.h617 struct ceph_msg *ceph_msg_new2(int type, int front_len, int max_data_items,
619 extern struct ceph_msg *ceph_msg_new(int type, int front_len, gfp_t flags,
/kernel/linux/linux-5.10/fs/ceph/
H A Dmetric.c90 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in ceph_mdsc_send_metrics()
H A Dmds_client.c1383 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in create_session_open_msg()
2177 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in ceph_send_cap_releases()
2197 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in ceph_send_cap_releases()
2666 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in create_request_message()
2758 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in __prepare_send_request()
5229 int front_len = (int) le32_to_cpu(hdr->front_len); in mds_alloc_msg() local
5235 msg = ceph_msg_new(type, front_len, GFP_NOFS, false); in mds_alloc_msg()
5238 type, front_len); in mds_alloc_msg()
/kernel/linux/linux-6.6/fs/ceph/
H A Dmds_client.c1623 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in create_session_open_msg()
2326 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in ceph_send_cap_releases()
2346 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in ceph_send_cap_releases()
3053 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in create_request_message()
3172 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in __prepare_send_request()
5918 int front_len = (int) le32_to_cpu(hdr->front_len); in mds_alloc_msg() local
5924 msg = ceph_msg_new(type, front_len, GFP_NOFS, false); in mds_alloc_msg()
5927 type, front_len); in mds_alloc_msg()
H A Dmetric.c178 msg->hdr.front_len = cpu_to_le32(msg->front.iov_len); in ceph_mdsc_send_metrics()

Completed in 65 milliseconds