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()
1768 int ceph_alloc_readdir_reply_buffer(struct ceph_mds_request *req, in ceph_alloc_readdir_reply_buffer()
1808 struct ceph_mds_request *
1811 struct ceph_mds_request *req = kzalloc(sizeof(*req), GFP_NOFS); in ceph_mdsc_create_request()
1844 static struct ceph_mds_request *__get_oldest_req(struct ceph_mds_client *mdsc) in __get_oldest_req()
1849 struct ceph_mds_request, r_node); in __get_oldest_req()
2029 struct ceph_mds_request *req, in create_request_message()
2163 struct ceph_mds_request *req) in complete_request()
2175 struct ceph_mds_request *req, in __prepare_send_request()
2261 struct ceph_mds_request *req) in __do_request()
2370 struct ceph_mds_request *req; in __wake_requests()
2377 struct ceph_mds_request, r_wait); in __wake_requests()
2390 struct ceph_mds_request *req; in kick_requests()
2395 req = rb_entry(p, struct ceph_mds_request, r_node); in kick_requests()
2411 struct ceph_mds_request *req) in ceph_mdsc_submit_request()
2426 struct ceph_mds_request *req) in ceph_mdsc_do_request()
2503 void ceph_invalidate_dir_request(struct ceph_mds_request *req) in ceph_invalidate_dir_request()
2529 struct ceph_mds_request *req; in handle_reply()
2723 struct ceph_mds_request *req; in handle_forward()
2898 struct ceph_mds_request *req, *nreq; in replay_unsafe_requests()
2919 req = rb_entry(p, struct ceph_mds_request, r_node); in replay_unsafe_requests()
3687 struct ceph_mds_request *req; in wait_requests()
3734 struct ceph_mds_request *req = NULL, *nextreq; in wait_unsafe_requests()
3745 nextreq = rb_entry(n, struct ceph_mds_request, r_node); in wait_unsafe_requests()