Lines Matching refs:ceph_msg
236 ceph_msg_cache = KMEM_CACHE(ceph_msg, 0); in ceph_msgr_slab_init()
620 static void ceph_msg_remove(struct ceph_msg *msg) in ceph_msg_remove()
629 struct ceph_msg *msg = list_first_entry(head, struct ceph_msg, in ceph_msg_remove_list()
1116 static void ceph_msg_data_cursor_init(struct ceph_msg *msg, size_t length) in ceph_msg_data_cursor_init()
1220 static void prepare_message_data(struct ceph_msg *msg, u32 data_len) in prepare_message_data()
1233 struct ceph_msg *m = con->out_msg; in prepare_write_message_footer()
1256 struct ceph_msg *m; in prepare_write_message()
1273 m = list_first_entry(&con->out_queue, struct ceph_msg, list_head); in prepare_write_message()
1554 struct ceph_msg *msg = con->out_msg; in write_partial_message_data()
2259 struct ceph_msg *m; in process_ack()
2271 m = list_first_entry(list, struct ceph_msg, list_head); in process_ack()
2312 struct ceph_msg *msg = con->in_msg; in read_partial_msg_data()
2358 struct ceph_msg *m = con->in_msg; in read_partial_message()
2519 struct ceph_msg *msg = con->in_msg; in process_message()
3066 static void msg_con_set(struct ceph_msg *msg, struct ceph_connection *con) in msg_con_set()
3090 void ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg) in ceph_con_send()
3130 void ceph_msg_revoke(struct ceph_msg *msg) in ceph_msg_revoke()
3176 void ceph_msg_revoke_incoming(struct ceph_msg *msg) in ceph_msg_revoke_incoming()
3241 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()
3276 void ceph_msg_data_add_pagelist(struct ceph_msg *msg, in ceph_msg_data_add_pagelist()
3294 void ceph_msg_data_add_bio(struct ceph_msg *msg, struct ceph_bio_iter *bio_pos, in ceph_msg_data_add_bio()
3309 void ceph_msg_data_add_bvecs(struct ceph_msg *msg, in ceph_msg_data_add_bvecs()
3326 struct ceph_msg *ceph_msg_new2(int type, int front_len, int max_data_items, in ceph_msg_new2()
3329 struct ceph_msg *m; in ceph_msg_new2()
3382 struct ceph_msg *ceph_msg_new(int type, int front_len, gfp_t flags, in ceph_msg_new()
3396 static int ceph_alloc_middle(struct ceph_connection *con, struct ceph_msg *msg) in ceph_alloc_middle()
3431 struct ceph_msg *msg; in ceph_con_in_msg_alloc()
3478 static void ceph_msg_free(struct ceph_msg *m) in ceph_msg_free()
3488 struct ceph_msg *m = container_of(kref, struct ceph_msg, kref); in ceph_msg_release()
3511 struct ceph_msg *ceph_msg_get(struct ceph_msg *msg) in ceph_msg_get()
3520 void ceph_msg_put(struct ceph_msg *msg) in ceph_msg_put()
3528 void ceph_msg_dump(struct ceph_msg *msg) in ceph_msg_dump()