Lines Matching refs:ceph_mds_request
515 static void put_request_session(struct ceph_mds_request *req) in put_request_session()
525 struct ceph_mds_request *req = container_of(kref, in ceph_mdsc_release_request()
526 struct ceph_mds_request, in ceph_mdsc_release_request()
569 static struct ceph_mds_request *__lookup_request(struct ceph_mds_client *mdsc, in __lookup_request()
572 struct ceph_mds_request *req; in __lookup_request()
576 req = rb_entry(n, struct ceph_mds_request, r_node); in __lookup_request()
590 struct ceph_mds_request *new) in __insert_request()
594 struct ceph_mds_request *req = NULL; in __insert_request()
598 req = rb_entry(parent, struct ceph_mds_request, r_node); in __insert_request()
618 struct ceph_mds_request *req, in __register_request()
642 struct ceph_mds_request *req) in __unregister_request()
650 struct ceph_mds_request *next_req = in __unregister_request()
651 rb_entry(p, struct ceph_mds_request, r_node); in __unregister_request()
708 struct ceph_mds_request *req) in __choose_mds()
1045 struct ceph_mds_request *req; in cleanup_session_requests()
1052 struct ceph_mds_request, r_unsafe_item); in cleanup_session_requests()
1061 req = rb_entry(p, struct ceph_mds_request, r_node); in cleanup_session_requests()
1662 int ceph_alloc_readdir_reply_buffer(struct ceph_mds_request *req, in ceph_alloc_readdir_reply_buffer()
1703 struct ceph_mds_request *
1706 struct ceph_mds_request *req = kzalloc(sizeof(*req), GFP_NOFS); in ceph_mdsc_create_request()
1736 static struct ceph_mds_request *__get_oldest_req(struct ceph_mds_client *mdsc) in __get_oldest_req()
1741 struct ceph_mds_request, r_node); in __get_oldest_req()
1915 struct ceph_mds_request *req, in create_request_message()
2045 struct ceph_mds_request *req) in complete_request()
2057 struct ceph_mds_request *req, in __prepare_send_request()
2143 struct ceph_mds_request *req) in __do_request()
2230 struct ceph_mds_request *req; in __wake_requests()
2237 struct ceph_mds_request, r_wait); in __wake_requests()
2250 struct ceph_mds_request *req; in kick_requests()
2255 req = rb_entry(p, struct ceph_mds_request, r_node); in kick_requests()
2271 struct ceph_mds_request *req) in ceph_mdsc_submit_request()
2286 struct ceph_mds_request *req) in ceph_mdsc_do_request()
2363 void ceph_invalidate_dir_request(struct ceph_mds_request *req) in ceph_invalidate_dir_request()
2386 struct ceph_mds_request *req; in handle_reply()
2578 struct ceph_mds_request *req; in handle_forward()
2740 struct ceph_mds_request *req, *nreq; in replay_unsafe_requests()
2761 req = rb_entry(p, struct ceph_mds_request, r_node); in replay_unsafe_requests()
3494 struct ceph_mds_request *req; in wait_requests()
3541 struct ceph_mds_request *req = NULL, *nextreq; in wait_unsafe_requests()
3552 nextreq = rb_entry(n, struct ceph_mds_request, r_node); in wait_unsafe_requests()