Lines Matching refs:ceph_msg
604 static int parse_reply_info(struct ceph_mds_session *s, struct ceph_msg *msg, in parse_reply_info()
1268 struct ceph_msg *ceph_create_session_msg(u32 op, u64 seq) in ceph_create_session_msg()
1270 struct ceph_msg *msg; in ceph_create_session_msg()
1364 static struct ceph_msg *create_session_open_msg(struct ceph_mds_client *mdsc, u64 seq) in create_session_open_msg()
1366 struct ceph_msg *msg; in create_session_open_msg()
1477 struct ceph_msg *msg; in __open_session()
1817 struct ceph_msg *msg; in send_renew_caps()
1847 struct ceph_msg *msg; in send_flushmsg_ack()
1898 struct ceph_msg *msg; in request_close_session()
2092 struct ceph_msg *msg = NULL; in ceph_send_cap_releases()
2539 static struct ceph_msg *create_request_message(struct ceph_mds_session *session, in create_request_message()
2545 struct ceph_msg *msg; in create_request_message()
2730 struct ceph_msg *msg; in __prepare_send_request()
3238 static void handle_reply(struct ceph_mds_session *session, struct ceph_msg *msg) in handle_reply()
3425 struct ceph_msg *msg) in handle_forward()
3533 struct ceph_msg *msg) in handle_session()
3775 struct ceph_msg *reply; in send_reconnect_partial()
4137 struct ceph_msg *reply; in send_mds_reconnect()
4482 struct ceph_msg *msg) in handle_lease()
4589 struct ceph_msg *msg; in ceph_mdsc_lease_send_msg()
4861 struct ceph_msg *msg; in send_flush_mdlog()
5146 void ceph_mdsc_handle_fsmap(struct ceph_mds_client *mdsc, struct ceph_msg *msg) in ceph_mdsc_handle_fsmap()
5217 void ceph_mdsc_handle_mdsmap(struct ceph_mds_client *mdsc, struct ceph_msg *msg) in ceph_mdsc_handle_mdsmap()
5307 static void mds_dispatch(struct ceph_connection *con, struct ceph_msg *msg) in mds_dispatch()
5490 static struct ceph_msg *mds_alloc_msg(struct ceph_connection *con, in mds_alloc_msg()
5493 struct ceph_msg *msg; in mds_alloc_msg()
5511 static int mds_sign_message(struct ceph_msg *msg) in mds_sign_message()
5519 static int mds_check_message_signature(struct ceph_msg *msg) in mds_check_message_signature()