Lines Matching refs:ceph_mds_request
552 static void put_request_session(struct ceph_mds_request *req) in put_request_session()
562 struct ceph_mds_request *req = container_of(kref, in ceph_mdsc_release_request()
563 struct ceph_mds_request, in ceph_mdsc_release_request()
601 DEFINE_RB_FUNCS(request, struct ceph_mds_request, r_tid, r_node) in DEFINE_RB_FUNCS() argument
608 static struct ceph_mds_request * in DEFINE_RB_FUNCS()
611 struct ceph_mds_request *req; in DEFINE_RB_FUNCS()
627 struct ceph_mds_request *req, in __register_request()
661 struct ceph_mds_request *req) in __unregister_request()
672 struct ceph_mds_request *next_req = in __unregister_request()
673 rb_entry(p, struct ceph_mds_request, r_node); in __unregister_request()
740 struct ceph_mds_request *req) in __choose_mds()
1130 struct ceph_mds_request *req; in cleanup_session_requests()
1137 struct ceph_mds_request, r_unsafe_item); in cleanup_session_requests()
1145 req = rb_entry(p, struct ceph_mds_request, r_node); in cleanup_session_requests()
1777 int ceph_alloc_readdir_reply_buffer(struct ceph_mds_request *req, in ceph_alloc_readdir_reply_buffer()
1817 struct ceph_mds_request *
1820 struct ceph_mds_request *req = kzalloc(sizeof(*req), GFP_NOFS); in ceph_mdsc_create_request()
1853 static struct ceph_mds_request *__get_oldest_req(struct ceph_mds_client *mdsc) in __get_oldest_req()
1858 struct ceph_mds_request, r_node); in __get_oldest_req()
2074 struct ceph_mds_request *req, in create_request_message()
2211 struct ceph_mds_request *req) in complete_request()
2223 struct ceph_mds_request *req, in __prepare_send_request()
2309 struct ceph_mds_request *req) in __do_request()
2417 struct ceph_mds_request *req; in __wake_requests()
2424 struct ceph_mds_request, r_wait); in __wake_requests()
2437 struct ceph_mds_request *req; in kick_requests()
2442 req = rb_entry(p, struct ceph_mds_request, r_node); in kick_requests()
2458 struct ceph_mds_request *req) in ceph_mdsc_submit_request()
2473 struct ceph_mds_request *req) in ceph_mdsc_do_request()
2550 void ceph_invalidate_dir_request(struct ceph_mds_request *req) in ceph_invalidate_dir_request()
2576 struct ceph_mds_request *req; in handle_reply()
2770 struct ceph_mds_request *req; in handle_forward()
2945 struct ceph_mds_request *req, *nreq; in replay_unsafe_requests()
2966 req = rb_entry(p, struct ceph_mds_request, r_node); in replay_unsafe_requests()
3740 struct ceph_mds_request *req; in wait_requests()
3787 struct ceph_mds_request *req = NULL, *nextreq; in wait_unsafe_requests()
3798 nextreq = rb_entry(n, struct ceph_mds_request, r_node); in wait_unsafe_requests()