Lines Matching defs:req
498 static void request_release_checks(struct ceph_osd_request *req) in request_release_checks()
508 struct ceph_osd_request *req = container_of(kref, in ceph_osdc_release_request() local
535 void ceph_osdc_get_request(struct ceph_osd_request *req) in ceph_osdc_get_request()
543 void ceph_osdc_put_request(struct ceph_osd_request *req) in ceph_osdc_put_request()
553 static void request_init(struct ceph_osd_request *req) in request_init()
573 struct ceph_osd_request *req; in ceph_osdc_alloc_request() local
604 static int __ceph_osdc_alloc_messages(struct ceph_osd_request *req, gfp_t gfp, in __ceph_osdc_alloc_messages()
675 static void get_num_data_items(struct ceph_osd_request *req, in get_num_data_items()
725 int ceph_osdc_alloc_messages(struct ceph_osd_request *req, gfp_t gfp) in ceph_osdc_alloc_messages()
911 static void osd_req_op_watch_init(struct ceph_osd_request *req, int which, in osd_req_op_watch_init()
926 static void osd_req_op_notify_init(struct ceph_osd_request *req, int which, in osd_req_op_notify_init()
1089 struct ceph_osd_request *req; in ceph_osdc_new_request() local
1207 struct ceph_osd_request *req = in DEFINE_RB_FUNCS() local
1217 struct ceph_osd_request *req = in DEFINE_RB_FUNCS() local
1375 struct ceph_osd_request *req = in close_osd() local
1426 struct ceph_osd_request *req = in reopen_osd() local
1474 static void link_request(struct ceph_osd *osd, struct ceph_osd_request *req) in link_request()
1493 static void unlink_request(struct ceph_osd *osd, struct ceph_osd_request *req) in unlink_request()
2035 static bool should_plug_request(struct ceph_osd_request *req) in should_plug_request()
2060 static void setup_request_data(struct ceph_osd_request *req) in setup_request_data()
2163 static void encode_request_partial(struct ceph_osd_request *req, in encode_request_partial()
2335 static void send_request(struct ceph_osd_request *req) in send_request()
2400 static void __submit_request(struct ceph_osd_request *req, bool wrlocked) in __submit_request()
2493 static void account_request(struct ceph_osd_request *req) in account_request()
2505 static void submit_request(struct ceph_osd_request *req, bool wrlocked) in submit_request()
2512 static void finish_request(struct ceph_osd_request *req) in finish_request()
2537 static void __complete_request(struct ceph_osd_request *req) in __complete_request()
2550 struct ceph_osd_request *req = in complete_request_workfn() local
2559 static void complete_request(struct ceph_osd_request *req, int err) in complete_request()
2570 static void cancel_map_check(struct ceph_osd_request *req) in cancel_map_check()
2586 static void cancel_request(struct ceph_osd_request *req) in cancel_request()
2596 static void abort_request(struct ceph_osd_request *req, int err) in abort_request()
2604 static int abort_fn(struct ceph_osd_request *req, void *arg) in abort_fn()
2666 static int abort_on_full_fn(struct ceph_osd_request *req, void *arg) in abort_on_full_fn()
2699 static void check_pool_dne(struct ceph_osd_request *req) in check_pool_dne()
2736 struct ceph_osd_request *req; in map_check_cb() local
2760 static void send_map_check(struct ceph_osd_request *req) in send_map_check()
2934 static void cancel_linger_request(struct ceph_osd_request *req) in cancel_linger_request()
3068 static void linger_commit_cb(struct ceph_osd_request *req) in linger_commit_cb()
3120 static void linger_reconnect_cb(struct ceph_osd_request *req) in linger_reconnect_cb()
3148 struct ceph_osd_request *req; in send_linger() local
3202 static void linger_ping_cb(struct ceph_osd_request *req) in linger_ping_cb()
3236 struct ceph_osd_request *req; in send_linger_ping() local
3471 struct ceph_osd_request *req = in handle_timeout() local
3508 struct ceph_osd_request *req = in handle_timeout() local
3771 struct ceph_osd_request *req; in handle_reply() local
3994 struct ceph_osd_request *req = in scan_requests() local
4106 struct ceph_osd_request *req = in kick_requests() local
4121 struct ceph_osd_request *req = in kick_requests() local
4273 struct ceph_osd_request *req = in kick_osd_requests() local
4512 struct ceph_osd_request *req = in handle_backoff_unblock() local
4675 struct ceph_osd_request *req) in ceph_osdc_start_request()
4692 void ceph_osdc_cancel_request(struct ceph_osd_request *req) in ceph_osdc_cancel_request()
4706 static int wait_request_timeout(struct ceph_osd_request *req, in wait_request_timeout()
4728 struct ceph_osd_request *req) in ceph_osdc_wait_request()
4749 struct ceph_osd_request *req = in ceph_osdc_sync() local
4831 struct ceph_osd_request *req; in ceph_osdc_unwatch() local
4860 static int osd_req_op_notify_ack_init(struct ceph_osd_request *req, int which, in osd_req_op_notify_ack_init()
4900 struct ceph_osd_request *req; in ceph_osdc_notify_ack() local
5110 struct ceph_osd_request *req; in ceph_osdc_list_watchers() local
5185 struct ceph_osd_request *req; in ceph_osdc_call() local
5349 int osd_req_op_copy_from_init(struct ceph_osd_request *req, in osd_req_op_copy_from_init()
5438 static u64 sparse_data_requested(struct ceph_osd_request *req) in sparse_data_requested()
5467 struct ceph_osd_request *req; in get_reply() local
5771 struct ceph_osd_request *req; in prep_next_sparse_read() local