Lines Matching refs:ceph_msg

242 					sizeof (struct ceph_msg),  in ceph_msgr_slab_init()
243 __alignof__(struct ceph_msg), 0, NULL); in ceph_msgr_slab_init()
637 static void ceph_msg_remove(struct ceph_msg *msg) in ceph_msg_remove()
646 struct ceph_msg *msg = list_first_entry(head, struct ceph_msg, in ceph_msg_remove_list()
1108 static void ceph_msg_data_cursor_init(struct ceph_msg *msg, size_t length) in ceph_msg_data_cursor_init()
1210 static void prepare_message_data(struct ceph_msg *msg, u32 data_len) in prepare_message_data()
1226 struct ceph_msg *m = con->out_msg; in prepare_write_message_footer()
1255 struct ceph_msg *m; in prepare_write_message()
1272 m = list_first_entry(&con->out_queue, struct ceph_msg, list_head); in prepare_write_message()
1556 struct ceph_msg *msg = con->out_msg; in write_partial_message_data()
2218 struct ceph_msg *m; in process_ack()
2223 m = list_first_entry(&con->out_sent, struct ceph_msg, in process_ack()
2262 struct ceph_msg *msg = con->in_msg; in read_partial_msg_data()
2304 struct ceph_msg *m = con->in_msg; in read_partial_message()
2469 struct ceph_msg *msg = con->in_msg; in process_message()
3003 static void msg_con_set(struct ceph_msg *msg, struct ceph_connection *con) in msg_con_set()
3027 void ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg) in ceph_con_send()
3067 void ceph_msg_revoke(struct ceph_msg *msg) in ceph_msg_revoke()
3116 void ceph_msg_revoke_incoming(struct ceph_msg *msg) in ceph_msg_revoke_incoming()
3205 void ceph_msg_data_add_pages(struct ceph_msg *msg, struct page **pages, in ceph_msg_data_add_pages()
3224 void ceph_msg_data_add_pagelist(struct ceph_msg *msg, in ceph_msg_data_add_pagelist()
3242 void ceph_msg_data_add_bio(struct ceph_msg *msg, struct bio *bio, in ceph_msg_data_add_bio()
3264 struct ceph_msg *ceph_msg_new(int type, int front_len, gfp_t flags, in ceph_msg_new()
3267 struct ceph_msg *m; in ceph_msg_new()
3319 static int ceph_alloc_middle(struct ceph_connection *con, struct ceph_msg *msg) in ceph_alloc_middle()
3354 struct ceph_msg *msg; in ceph_con_in_msg_alloc()
3401 static void ceph_msg_free(struct ceph_msg *m) in ceph_msg_free()
3410 struct ceph_msg *m = container_of(kref, struct ceph_msg, kref); in ceph_msg_release()
3442 struct ceph_msg *ceph_msg_get(struct ceph_msg *msg) in ceph_msg_get()
3451 void ceph_msg_put(struct ceph_msg *msg) in ceph_msg_put()
3459 void ceph_msg_dump(struct ceph_msg *msg) in ceph_msg_dump()