Lines Matching refs:ceph_msg

236 	ceph_msg_cache = KMEM_CACHE(ceph_msg, 0);  in ceph_msgr_slab_init()
627 static void ceph_msg_remove(struct ceph_msg *msg) in ceph_msg_remove()
636 struct ceph_msg *msg = list_first_entry(head, struct ceph_msg, in ceph_msg_remove_list()
1123 static void ceph_msg_data_cursor_init(struct ceph_msg *msg, size_t length) in ceph_msg_data_cursor_init()
1227 static void prepare_message_data(struct ceph_msg *msg, u32 data_len) in prepare_message_data()
1240 struct ceph_msg *m = con->out_msg; in prepare_write_message_footer()
1263 struct ceph_msg *m; in prepare_write_message()
1280 m = list_first_entry(&con->out_queue, struct ceph_msg, list_head); in prepare_write_message()
1561 struct ceph_msg *msg = con->out_msg; in write_partial_message_data()
2268 struct ceph_msg *m; in process_ack()
2280 m = list_first_entry(list, struct ceph_msg, list_head); in process_ack()
2321 struct ceph_msg *msg = con->in_msg; in read_partial_msg_data()
2367 struct ceph_msg *m = con->in_msg; in read_partial_message()
2528 struct ceph_msg *msg = con->in_msg; in process_message()
3070 static void msg_con_set(struct ceph_msg *msg, struct ceph_connection *con) in msg_con_set()
3094 void ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg) in ceph_con_send()
3134 void ceph_msg_revoke(struct ceph_msg *msg) in ceph_msg_revoke()
3180 void ceph_msg_revoke_incoming(struct ceph_msg *msg) in ceph_msg_revoke_incoming()
3245 static struct ceph_msg_data *ceph_msg_data_add(struct ceph_msg *msg) in ceph_msg_data_add()
3257 void ceph_msg_data_add_pages(struct ceph_msg *msg, struct page **pages, in ceph_msg_data_add_pages()
3275 void ceph_msg_data_add_pagelist(struct ceph_msg *msg, in ceph_msg_data_add_pagelist()
3293 void ceph_msg_data_add_bio(struct ceph_msg *msg, struct ceph_bio_iter *bio_pos, in ceph_msg_data_add_bio()
3308 void ceph_msg_data_add_bvecs(struct ceph_msg *msg, in ceph_msg_data_add_bvecs()
3325 struct ceph_msg *ceph_msg_new2(int type, int front_len, int max_data_items, in ceph_msg_new2()
3328 struct ceph_msg *m; in ceph_msg_new2()
3381 struct ceph_msg *ceph_msg_new(int type, int front_len, gfp_t flags, in ceph_msg_new()
3395 static int ceph_alloc_middle(struct ceph_connection *con, struct ceph_msg *msg) in ceph_alloc_middle()
3430 struct ceph_msg *msg; in ceph_con_in_msg_alloc()
3477 static void ceph_msg_free(struct ceph_msg *m) in ceph_msg_free()
3487 struct ceph_msg *m = container_of(kref, struct ceph_msg, kref); in ceph_msg_release()
3510 struct ceph_msg *ceph_msg_get(struct ceph_msg *msg) in ceph_msg_get()
3519 void ceph_msg_put(struct ceph_msg *msg) in ceph_msg_put()
3527 void ceph_msg_dump(struct ceph_msg *msg) in ceph_msg_dump()