Lines Matching refs:ceph_msg
609 struct ceph_msg *msg;
963 static void ceph_osdc_msg_data_add(struct ceph_msg *msg,
2060 struct ceph_msg *request_msg = req->r_request;
2061 struct ceph_msg *reply_msg = req->r_reply;
2162 struct ceph_msg *msg)
2238 static void encode_request_finish(struct ceph_msg *msg)
2954 struct ceph_msg *msg; /* for ceph_msg_put() */
3686 static int decode_MOSDOpReply(const struct ceph_msg *msg, struct MOSDOpReply *m)
3766 static void handle_reply(struct ceph_osd *osd, struct ceph_msg *msg)
4151 void ceph_osdc_handle_map(struct ceph_osd_client *osdc, struct ceph_msg *msg)
4324 static int decode_MOSDBackoff(const struct ceph_msg *msg, struct MOSDBackoff *m)
4374 static struct ceph_msg *create_backoff_message(
4378 struct ceph_msg *msg;
4416 struct ceph_msg *msg;
4529 static void handle_backoff(struct ceph_osd *osd, struct ceph_msg *msg)
4574 struct ceph_msg *msg)
5407 static void osd_dispatch(struct ceph_connection *con, struct ceph_msg *msg)
5458 static struct ceph_msg *get_reply(struct ceph_connection *con,
5464 struct ceph_msg *m = NULL;
5524 static struct ceph_msg *alloc_msg_with_page_vector(struct ceph_msg_header *hdr)
5526 struct ceph_msg *m;
5551 static struct ceph_msg *osd_alloc_msg(struct ceph_connection *con,
5723 static void osd_reencode_message(struct ceph_msg *msg)
5731 static int osd_sign_message(struct ceph_msg *msg)
5739 static int osd_check_message_signature(struct ceph_msg *msg)