Lines Matching refs:ceph_msg

234 	ceph_msg_cache = KMEM_CACHE(ceph_msg, 0);  in ceph_msgr_slab_init()
648 static void ceph_msg_remove(struct ceph_msg *msg) in ceph_msg_remove()
657 struct ceph_msg *msg = list_first_entry(head, struct ceph_msg, in ceph_msg_remove_list()
1141 static void ceph_msg_data_cursor_init(struct ceph_msg *msg, size_t length) in ceph_msg_data_cursor_init()
1249 static void prepare_message_data(struct ceph_msg *msg, u32 data_len) in prepare_message_data()
1265 struct ceph_msg *m = con->out_msg; in prepare_write_message_footer()
1288 struct ceph_msg *m; in prepare_write_message()
1305 m = list_first_entry(&con->out_queue, struct ceph_msg, list_head); in prepare_write_message()
1586 struct ceph_msg *msg = con->out_msg; in write_partial_message_data()
2288 struct ceph_msg *m; in process_ack()
2300 m = list_first_entry(list, struct ceph_msg, list_head); in process_ack()
2341 struct ceph_msg *msg = con->in_msg; in read_partial_msg_data()
2388 struct ceph_msg *m = con->in_msg; in read_partial_message()
2549 struct ceph_msg *msg = con->in_msg; in process_message()
3085 static void msg_con_set(struct ceph_msg *msg, struct ceph_connection *con) in msg_con_set()
3109 void ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg) in ceph_con_send()
3149 void ceph_msg_revoke(struct ceph_msg *msg) in ceph_msg_revoke()
3195 void ceph_msg_revoke_incoming(struct ceph_msg *msg) in ceph_msg_revoke_incoming()
3287 void ceph_msg_data_add_pages(struct ceph_msg *msg, struct page **pages, in ceph_msg_data_add_pages()
3306 void ceph_msg_data_add_pagelist(struct ceph_msg *msg, in ceph_msg_data_add_pagelist()
3324 void ceph_msg_data_add_bio(struct ceph_msg *msg, struct ceph_bio_iter *bio_pos, in ceph_msg_data_add_bio()
3340 void ceph_msg_data_add_bvecs(struct ceph_msg *msg, in ceph_msg_data_add_bvecs()
3358 struct ceph_msg *ceph_msg_new(int type, int front_len, gfp_t flags, in ceph_msg_new()
3361 struct ceph_msg *m; in ceph_msg_new()
3413 static int ceph_alloc_middle(struct ceph_connection *con, struct ceph_msg *msg) in ceph_alloc_middle()
3448 struct ceph_msg *msg; in ceph_con_in_msg_alloc()
3495 static void ceph_msg_free(struct ceph_msg *m) in ceph_msg_free()
3504 struct ceph_msg *m = container_of(kref, struct ceph_msg, kref); in ceph_msg_release()
3530 struct ceph_msg *ceph_msg_get(struct ceph_msg *msg) in ceph_msg_get()
3539 void ceph_msg_put(struct ceph_msg *msg) in ceph_msg_put()
3547 void ceph_msg_dump(struct ceph_msg *msg) in ceph_msg_dump()