Lines Matching refs:ceph_msg
582 struct ceph_msg *msg;
935 static void ceph_osdc_msg_data_add(struct ceph_msg *msg,
1980 struct ceph_msg *request_msg = req->r_request;
1981 struct ceph_msg *reply_msg = req->r_reply;
2081 struct ceph_msg *msg)
2157 static void encode_request_finish(struct ceph_msg *msg)
2867 struct ceph_msg *msg; /* for ceph_msg_put() */
3599 static int decode_MOSDOpReply(const struct ceph_msg *msg, struct MOSDOpReply *m)
3679 static void handle_reply(struct ceph_osd *osd, struct ceph_msg *msg)
4061 void ceph_osdc_handle_map(struct ceph_osd_client *osdc, struct ceph_msg *msg)
4234 static int decode_MOSDBackoff(const struct ceph_msg *msg, struct MOSDBackoff *m)
4284 static struct ceph_msg *create_backoff_message(
4288 struct ceph_msg *msg;
4326 struct ceph_msg *msg;
4439 static void handle_backoff(struct ceph_osd *osd, struct ceph_msg *msg)
4484 struct ceph_msg *msg)
5357 static void dispatch(struct ceph_connection *con, struct ceph_msg *msg)
5390 static struct ceph_msg *get_reply(struct ceph_connection *con,
5396 struct ceph_msg *m = NULL;
5452 static struct ceph_msg *alloc_msg_with_page_vector(struct ceph_msg_header *hdr)
5454 struct ceph_msg *m;
5479 static struct ceph_msg *alloc_msg(struct ceph_connection *con,
5584 static void osd_reencode_message(struct ceph_msg *msg)
5592 static int osd_sign_message(struct ceph_msg *msg)
5600 static int osd_check_message_signature(struct ceph_msg *msg)