Lines Matching refs:ceph_msg

213 	ceph_msg_cache = KMEM_CACHE(ceph_msg, 0);  in ceph_msgr_slab_init()
533 static void ceph_msg_remove(struct ceph_msg *msg) in ceph_msg_remove()
543 struct ceph_msg *msg = list_first_entry(head, struct ceph_msg, in ceph_msg_remove_list()
668 struct ceph_msg *msg; in ceph_con_discard_sent()
673 msg = list_first_entry(&con->out_sent, struct ceph_msg, in ceph_con_discard_sent()
693 struct ceph_msg *msg; in ceph_con_discard_requeued()
698 msg = list_first_entry(&con->out_queue, struct ceph_msg, in ceph_con_discard_requeued()
1003 struct ceph_msg *msg, size_t length) in ceph_msg_data_cursor_init()
1331 struct ceph_msg *msg = con->in_msg; in ceph_con_process_message()
1632 static void msg_con_set(struct ceph_msg *msg, struct ceph_connection *con) in msg_con_set()
1658 void ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg) in ceph_con_send()
1698 void ceph_msg_revoke(struct ceph_msg *msg) in ceph_msg_revoke()
1738 void ceph_msg_revoke_incoming(struct ceph_msg *msg) in ceph_msg_revoke_incoming()
1795 static struct ceph_msg_data *ceph_msg_data_add(struct ceph_msg *msg) in ceph_msg_data_add()
1811 void ceph_msg_data_add_pages(struct ceph_msg *msg, struct page **pages, in ceph_msg_data_add_pages()
1830 void ceph_msg_data_add_pagelist(struct ceph_msg *msg, in ceph_msg_data_add_pagelist()
1848 void ceph_msg_data_add_bio(struct ceph_msg *msg, struct ceph_bio_iter *bio_pos, in ceph_msg_data_add_bio()
1863 void ceph_msg_data_add_bvecs(struct ceph_msg *msg, in ceph_msg_data_add_bvecs()
1880 struct ceph_msg *ceph_msg_new2(int type, int front_len, int max_data_items, in ceph_msg_new2()
1883 struct ceph_msg *m; in ceph_msg_new2()
1936 struct ceph_msg *ceph_msg_new(int type, int front_len, gfp_t flags, in ceph_msg_new()
1950 static int ceph_alloc_middle(struct ceph_connection *con, struct ceph_msg *msg) in ceph_alloc_middle()
1985 struct ceph_msg *msg; in ceph_con_in_msg_alloc()
2030 struct ceph_msg *msg; in ceph_con_get_out_msg()
2033 msg = list_first_entry(&con->out_queue, struct ceph_msg, list_head); in ceph_con_get_out_msg()
2065 static void ceph_msg_free(struct ceph_msg *m) in ceph_msg_free()
2075 struct ceph_msg *m = container_of(kref, struct ceph_msg, kref); in ceph_msg_release()
2098 struct ceph_msg *ceph_msg_get(struct ceph_msg *msg) in ceph_msg_get()
2107 void ceph_msg_put(struct ceph_msg *msg) in ceph_msg_put()
2115 void ceph_msg_dump(struct ceph_msg *msg) in ceph_msg_dump()