Lines Matching defs:req

471 static void request_release_checks(struct ceph_osd_request *req)  in request_release_checks()
481 struct ceph_osd_request *req = container_of(kref, in ceph_osdc_release_request() local
508 void ceph_osdc_get_request(struct ceph_osd_request *req) in ceph_osdc_get_request()
516 void ceph_osdc_put_request(struct ceph_osd_request *req) in ceph_osdc_put_request()
526 static void request_init(struct ceph_osd_request *req) in request_init()
546 struct ceph_osd_request *req; in ceph_osdc_alloc_request() local
577 static int __ceph_osdc_alloc_messages(struct ceph_osd_request *req, gfp_t gfp, in __ceph_osdc_alloc_messages()
648 static void get_num_data_items(struct ceph_osd_request *req, in get_num_data_items()
697 int ceph_osdc_alloc_messages(struct ceph_osd_request *req, gfp_t gfp) in ceph_osdc_alloc_messages()
883 static void osd_req_op_watch_init(struct ceph_osd_request *req, int which, in osd_req_op_watch_init()
898 static void osd_req_op_notify_init(struct ceph_osd_request *req, int which, in osd_req_op_notify_init()
1054 struct ceph_osd_request *req; in ceph_osdc_new_request() local
1142 struct ceph_osd_request *req = in DEFINE_RB_FUNCS() local
1152 struct ceph_osd_request *req = in DEFINE_RB_FUNCS() local
1297 struct ceph_osd_request *req = in close_osd() local
1348 struct ceph_osd_request *req = in reopen_osd() local
1396 static void link_request(struct ceph_osd *osd, struct ceph_osd_request *req) in link_request()
1413 static void unlink_request(struct ceph_osd *osd, struct ceph_osd_request *req) in unlink_request()
1953 static bool should_plug_request(struct ceph_osd_request *req) in should_plug_request()
1978 static void setup_request_data(struct ceph_osd_request *req) in setup_request_data()
2080 static void encode_request_partial(struct ceph_osd_request *req, in encode_request_partial()
2252 static void send_request(struct ceph_osd_request *req) in send_request()
2317 static void __submit_request(struct ceph_osd_request *req, bool wrlocked) in __submit_request()
2406 static void account_request(struct ceph_osd_request *req) in account_request()
2418 static void submit_request(struct ceph_osd_request *req, bool wrlocked) in submit_request()
2425 static void finish_request(struct ceph_osd_request *req) in finish_request()
2448 static void __complete_request(struct ceph_osd_request *req) in __complete_request()
2461 struct ceph_osd_request *req = in complete_request_workfn() local
2470 static void complete_request(struct ceph_osd_request *req, int err) in complete_request()
2481 static void cancel_map_check(struct ceph_osd_request *req) in cancel_map_check()
2497 static void cancel_request(struct ceph_osd_request *req) in cancel_request()
2507 static void abort_request(struct ceph_osd_request *req, int err) in abort_request()
2515 static int abort_fn(struct ceph_osd_request *req, void *arg) in abort_fn()
2577 static int abort_on_full_fn(struct ceph_osd_request *req, void *arg) in abort_on_full_fn()
2610 static void check_pool_dne(struct ceph_osd_request *req) in check_pool_dne()
2647 struct ceph_osd_request *req; in map_check_cb() local
2671 static void send_map_check(struct ceph_osd_request *req) in send_map_check()
2845 static void cancel_linger_request(struct ceph_osd_request *req) in cancel_linger_request()
2979 static void linger_commit_cb(struct ceph_osd_request *req) in linger_commit_cb()
3031 static void linger_reconnect_cb(struct ceph_osd_request *req) in linger_reconnect_cb()
3059 struct ceph_osd_request *req; in send_linger() local
3113 static void linger_ping_cb(struct ceph_osd_request *req) in linger_ping_cb()
3147 struct ceph_osd_request *req; in send_linger_ping() local
3375 struct ceph_osd_request *req = in handle_timeout() local
3412 struct ceph_osd_request *req = in handle_timeout() local
3675 struct ceph_osd_request *req; in handle_reply() local
3897 struct ceph_osd_request *req = in scan_requests() local
4007 struct ceph_osd_request *req = in kick_requests() local
4022 struct ceph_osd_request *req = in kick_requests() local
4174 struct ceph_osd_request *req = in kick_osd_requests() local
4413 struct ceph_osd_request *req = in handle_backoff_unblock() local
4576 struct ceph_osd_request *req, in ceph_osdc_start_request()
4591 void ceph_osdc_cancel_request(struct ceph_osd_request *req) in ceph_osdc_cancel_request()
4605 static int wait_request_timeout(struct ceph_osd_request *req, in wait_request_timeout()
4627 struct ceph_osd_request *req) in ceph_osdc_wait_request()
4648 struct ceph_osd_request *req = in ceph_osdc_sync() local
4730 struct ceph_osd_request *req; in ceph_osdc_unwatch() local
4759 static int osd_req_op_notify_ack_init(struct ceph_osd_request *req, int which, in osd_req_op_notify_ack_init()
4799 struct ceph_osd_request *req; in ceph_osdc_notify_ack() local
5008 struct ceph_osd_request *req; in ceph_osdc_list_watchers() local
5083 struct ceph_osd_request *req; in ceph_osdc_call() local
5247 static int osd_req_op_copy_from_init(struct ceph_osd_request *req, in osd_req_op_copy_from_init()
5295 struct ceph_osd_request *req; in ceph_osdc_copy_from() local
5389 struct ceph_osd_request *req; in get_reply() local