Lines Matching refs:ceph_msg
553 struct ceph_msg *request_msg = req->r_request; in request_reinit()
554 struct ceph_msg *reply_msg = req->r_reply; in request_reinit()
617 struct ceph_msg *msg; in __ceph_osdc_alloc_messages()
956 static void ceph_osdc_msg_data_add(struct ceph_msg *msg, in ceph_osdc_msg_data_add()
1941 struct ceph_msg *request_msg = req->r_request; in setup_request_data()
1942 struct ceph_msg *reply_msg = req->r_reply; in setup_request_data()
2042 struct ceph_msg *msg) in encode_request_partial()
2118 static void encode_request_finish(struct ceph_msg *msg) in encode_request_finish()
2822 struct ceph_msg *msg; /* for ceph_msg_put() */
3513 static int decode_MOSDOpReply(const struct ceph_msg *msg, struct MOSDOpReply *m) in decode_MOSDOpReply()
3593 static void handle_reply(struct ceph_osd *osd, struct ceph_msg *msg) in handle_reply()
3953 void ceph_osdc_handle_map(struct ceph_osd_client *osdc, struct ceph_msg *msg) in ceph_osdc_handle_map()
4126 static int decode_MOSDBackoff(const struct ceph_msg *msg, struct MOSDBackoff *m) in decode_MOSDBackoff()
4176 static struct ceph_msg *create_backoff_message( in create_backoff_message()
4180 struct ceph_msg *msg; in create_backoff_message()
4218 struct ceph_msg *msg; in handle_backoff_block()
4331 static void handle_backoff(struct ceph_osd *osd, struct ceph_msg *msg) in handle_backoff()
4376 struct ceph_msg *msg) in handle_watch_notify()
5408 static void dispatch(struct ceph_connection *con, struct ceph_msg *msg) in dispatch()
5441 static struct ceph_msg *get_reply(struct ceph_connection *con, in get_reply()
5447 struct ceph_msg *m = NULL; in get_reply()
5506 static struct ceph_msg *alloc_msg_with_page_vector(struct ceph_msg_header *hdr) in alloc_msg_with_page_vector()
5508 struct ceph_msg *m; in alloc_msg_with_page_vector()
5536 static struct ceph_msg *alloc_msg(struct ceph_connection *con, in alloc_msg()
5641 static void osd_reencode_message(struct ceph_msg *msg) in osd_reencode_message()
5649 static int osd_sign_message(struct ceph_msg *msg) in osd_sign_message()
5657 static int osd_check_message_signature(struct ceph_msg *msg) in osd_check_message_signature()