49 static void link_request(struct ceph_osd *osd, struct ceph_osd_request *req);
50 static void unlink_request(struct ceph_osd *osd, struct ceph_osd_request *req);
170 	struct ceph_osd_request *__oreq = (oreq);			\
177 osd_req_op_raw_data_in(struct ceph_osd_request *osd_req, unsigned int which)  in osd_req_op_raw_data_in()
185 osd_req_op_extent_osd_data(struct ceph_osd_request *osd_req,  in osd_req_op_extent_osd_data()
192 void osd_req_op_raw_data_in_pages(struct ceph_osd_request *osd_req,  in osd_req_op_raw_data_in_pages()
205 void osd_req_op_extent_osd_data_pages(struct ceph_osd_request *osd_req,  in osd_req_op_extent_osd_data_pages()
218 void osd_req_op_extent_osd_data_pagelist(struct ceph_osd_request *osd_req,  in osd_req_op_extent_osd_data_pagelist()
229 void osd_req_op_extent_osd_data_bio(struct ceph_osd_request *osd_req,  in osd_req_op_extent_osd_data_bio()
242 void osd_req_op_extent_osd_data_bvecs(struct ceph_osd_request *osd_req,  in osd_req_op_extent_osd_data_bvecs()
258 void osd_req_op_extent_osd_data_bvec_pos(struct ceph_osd_request *osd_req,  in osd_req_op_extent_osd_data_bvec_pos()
270 			struct ceph_osd_request *osd_req,  in osd_req_op_cls_request_info_pagelist()
280 			struct ceph_osd_request *osd_req,  in osd_req_op_cls_request_data_pagelist()
292 void osd_req_op_cls_request_data_pages(struct ceph_osd_request *osd_req,  in osd_req_op_cls_request_data_pages()
306 void osd_req_op_cls_request_data_bvecs(struct ceph_osd_request *osd_req,  in osd_req_op_cls_request_data_bvecs()
324 void osd_req_op_cls_response_data_pages(struct ceph_osd_request *osd_req,  in osd_req_op_cls_response_data_pages()
369 static void osd_req_op_data_release(struct ceph_osd_request *osd_req,  in osd_req_op_data_release()
466 static void request_release_checks(struct ceph_osd_request *req)  in request_release_checks()
476 	struct ceph_osd_request *req = container_of(kref,  in ceph_osdc_release_request()
477 					    struct ceph_osd_request, r_kref);  in ceph_osdc_release_request()
503 void ceph_osdc_get_request(struct ceph_osd_request *req)  in ceph_osdc_get_request()
511 void ceph_osdc_put_request(struct ceph_osd_request *req)  in ceph_osdc_put_request()
521 static void request_init(struct ceph_osd_request *req)  in request_init()
542 static void request_reinit(struct ceph_osd_request *req)  in request_reinit()
572 struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc,  in ceph_osdc_alloc_request()
578 	struct ceph_osd_request *req;  in ceph_osdc_alloc_request()
609 int ceph_osdc_alloc_messages(struct ceph_osd_request *req, gfp_t gfp)  in ceph_osdc_alloc_messages()
680 _osd_req_op_init(struct ceph_osd_request *osd_req, unsigned int which,  in _osd_req_op_init()
696 void osd_req_op_init(struct ceph_osd_request *osd_req,  in osd_req_op_init()
703 void osd_req_op_extent_init(struct ceph_osd_request *osd_req,  in osd_req_op_extent_init()
727 void osd_req_op_extent_update(struct ceph_osd_request *osd_req,  in osd_req_op_extent_update()
747 void osd_req_op_extent_dup_last(struct ceph_osd_request *osd_req,  in osd_req_op_extent_dup_last()
769 int osd_req_op_cls_init(struct ceph_osd_request *osd_req, unsigned int which,  in osd_req_op_cls_init()
807 int osd_req_op_xattr_init(struct ceph_osd_request *osd_req, unsigned int which,  in osd_req_op_xattr_init()
844 static void osd_req_op_watch_init(struct ceph_osd_request *req, int which,  in osd_req_op_watch_init()
855 void osd_req_op_alloc_hint_init(struct ceph_osd_request *osd_req,  in osd_req_op_alloc_hint_init()
981 struct ceph_osd_request *ceph_osdc_new_request(struct ceph_osd_client *osdc,  in ceph_osdc_new_request()
992 	struct ceph_osd_request *req;  in ceph_osdc_new_request()
1056 DEFINE_RB_FUNCS(request, struct ceph_osd_request, r_tid, r_node)  in DEFINE_RB_FUNCS()  argument
1057 DEFINE_RB_FUNCS(request_mc, struct ceph_osd_request, r_tid, r_mc_node)  in DEFINE_RB_FUNCS()
1063 			int (*fn)(struct ceph_osd_request *req, void *arg),  in DEFINE_RB_FUNCS()
1072 			struct ceph_osd_request *req =  in DEFINE_RB_FUNCS()
1073 			    rb_entry(p, struct ceph_osd_request, r_node);  in DEFINE_RB_FUNCS()
1082 		struct ceph_osd_request *req =  in DEFINE_RB_FUNCS()
1083 		    rb_entry(p, struct ceph_osd_request, r_node);  in DEFINE_RB_FUNCS()
1227 		struct ceph_osd_request *req =  in close_osd()
1228 		    rb_entry(n, struct ceph_osd_request, r_node);  in close_osd()
1278 			struct ceph_osd_request *req =  in reopen_osd()
1279 			    rb_entry(n, struct ceph_osd_request, r_node);  in reopen_osd()
1326 static void link_request(struct ceph_osd *osd, struct ceph_osd_request *req)  in link_request()
1343 static void unlink_request(struct ceph_osd *osd, struct ceph_osd_request *req)  in unlink_request()
1826 static bool should_plug_request(struct ceph_osd_request *req)  in should_plug_request()
1848 static void setup_request_data(struct ceph_osd_request *req,  in setup_request_data()
1948 static void encode_request_partial(struct ceph_osd_request *req,  in encode_request_partial()
2120 static void send_request(struct ceph_osd_request *req)  in send_request()
2182 static void complete_request(struct ceph_osd_request *req, int err);
2183 static void send_map_check(struct ceph_osd_request *req);
2185 static void __submit_request(struct ceph_osd_request *req, bool wrlocked)  in __submit_request()
2274 static void account_request(struct ceph_osd_request *req)  in account_request()
2285 static void submit_request(struct ceph_osd_request *req, bool wrlocked)  in submit_request()
2292 static void finish_request(struct ceph_osd_request *req)  in finish_request()
2313 static void __complete_request(struct ceph_osd_request *req)  in __complete_request()
2326 	struct ceph_osd_request *req =  in complete_request_workfn()
2327 	    container_of(work, struct ceph_osd_request, r_complete_work);  in complete_request_workfn()
2335 static void complete_request(struct ceph_osd_request *req, int err)  in complete_request()
2346 static void cancel_map_check(struct ceph_osd_request *req)  in cancel_map_check()
2349 	struct ceph_osd_request *lookup_req;  in cancel_map_check()
2362 static void cancel_request(struct ceph_osd_request *req)  in cancel_request()
2372 static void abort_request(struct ceph_osd_request *req, int err)  in abort_request()
2380 static int abort_fn(struct ceph_osd_request *req, void *arg)  in abort_fn()
2434 static int abort_on_full_fn(struct ceph_osd_request *req, void *arg)  in abort_on_full_fn()
2467 static void check_pool_dne(struct ceph_osd_request *req)  in check_pool_dne()
2504 	struct ceph_osd_request *req;  in map_check_cb()
2528 static void send_map_check(struct ceph_osd_request *req)  in send_map_check()
2531 	struct ceph_osd_request *lookup_req;  in send_map_check()
2699 static void cancel_linger_request(struct ceph_osd_request *req)  in cancel_linger_request()
2833 static void linger_commit_cb(struct ceph_osd_request *req)  in linger_commit_cb()
2878 static void linger_reconnect_cb(struct ceph_osd_request *req)  in linger_reconnect_cb()
2898 	struct ceph_osd_request *req = lreq->reg_req;  in send_linger()
2938 static void linger_ping_cb(struct ceph_osd_request *req)  in linger_ping_cb()
2965 	struct ceph_osd_request *req = lreq->ping_req;  in send_linger_ping()
3182 			struct ceph_osd_request *req =  in handle_timeout()
3183 			    rb_entry(p, struct ceph_osd_request, r_node);  in handle_timeout()
3219 			struct ceph_osd_request *req =  in handle_timeout()
3220 			    rb_entry(p, struct ceph_osd_request, r_node);  in handle_timeout()
3485 	struct ceph_osd_request *req;  in handle_reply()
3685 		struct ceph_osd_request *req =  in scan_requests()
3686 		    rb_entry(n, struct ceph_osd_request, r_node);  in scan_requests()
3796 		struct ceph_osd_request *req =  in kick_requests()
3797 		    rb_entry(n, struct ceph_osd_request, r_node);  in kick_requests()
3811 		struct ceph_osd_request *req =  in kick_requests()
3812 		    rb_entry(n, struct ceph_osd_request, r_node);  in kick_requests()
3963 		struct ceph_osd_request *req =  in kick_osd_requests()
3964 		    rb_entry(n, struct ceph_osd_request, r_node);  in kick_osd_requests()
4202 		struct ceph_osd_request *req =  in handle_backoff_unblock()
4203 		    rb_entry(n, struct ceph_osd_request, r_node);  in handle_backoff_unblock()
4369 			    struct ceph_osd_request *req,  in ceph_osdc_start_request()
4384 void ceph_osdc_cancel_request(struct ceph_osd_request *req)  in ceph_osdc_cancel_request()
4398 static int wait_request_timeout(struct ceph_osd_request *req,  in wait_request_timeout()
4420 			   struct ceph_osd_request *req)  in ceph_osdc_wait_request()
4441 			struct ceph_osd_request *req =  in ceph_osdc_sync()
4442 			    rb_entry(p, struct ceph_osd_request, r_node);  in ceph_osdc_sync()
4468 static struct ceph_osd_request *
4471 	struct ceph_osd_request *req;  in alloc_linger_request()
4563 	struct ceph_osd_request *req;  in ceph_osdc_unwatch()
4592 static int osd_req_op_notify_ack_init(struct ceph_osd_request *req, int which,  in osd_req_op_notify_ack_init()
4633 	struct ceph_osd_request *req;  in ceph_osdc_notify_ack()
4662 static int osd_req_op_notify_init(struct ceph_osd_request *req, int which,  in osd_req_op_notify_init()
4872 	struct ceph_osd_request *req;  in ceph_osdc_list_watchers()
4947 	struct ceph_osd_request *req;  in ceph_osdc_call()
5102 	struct ceph_osd_request *req;  in ceph_osdc_readpages()
5142 	struct ceph_osd_request *req;  in ceph_osdc_writepages()
5173 	size_t size = sizeof(struct ceph_osd_request) +  in ceph_osdc_setup()
5233 	struct ceph_osd_request *req;  in get_reply()