Lines Matching refs:ceph_osd_request
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);
175 osd_req_op_raw_data_in(struct ceph_osd_request *osd_req, unsigned int which) in osd_req_op_raw_data_in()
183 osd_req_op_extent_osd_data(struct ceph_osd_request *osd_req, in osd_req_op_extent_osd_data()
190 void osd_req_op_raw_data_in_pages(struct ceph_osd_request *osd_req, in osd_req_op_raw_data_in_pages()
203 void osd_req_op_extent_osd_data_pages(struct ceph_osd_request *osd_req, in osd_req_op_extent_osd_data_pages()
216 void osd_req_op_extent_osd_data_pagelist(struct ceph_osd_request *osd_req, in osd_req_op_extent_osd_data_pagelist()
227 void osd_req_op_extent_osd_data_bio(struct ceph_osd_request *osd_req, in osd_req_op_extent_osd_data_bio()
240 void osd_req_op_extent_osd_data_bvecs(struct ceph_osd_request *osd_req, in osd_req_op_extent_osd_data_bvecs()
256 void osd_req_op_extent_osd_data_bvec_pos(struct ceph_osd_request *osd_req, in osd_req_op_extent_osd_data_bvec_pos()
268 struct ceph_osd_request *osd_req, in osd_req_op_cls_request_info_pagelist()
278 struct ceph_osd_request *osd_req, in osd_req_op_cls_request_data_pagelist()
290 void osd_req_op_cls_request_data_pages(struct ceph_osd_request *osd_req, in osd_req_op_cls_request_data_pages()
304 void osd_req_op_cls_request_data_bvecs(struct ceph_osd_request *osd_req, in osd_req_op_cls_request_data_bvecs()
322 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()
469 static void request_release_checks(struct ceph_osd_request *req) in request_release_checks()
479 struct ceph_osd_request *req = container_of(kref, in ceph_osdc_release_request()
480 struct ceph_osd_request, r_kref); in ceph_osdc_release_request()
506 void ceph_osdc_get_request(struct ceph_osd_request *req) in ceph_osdc_get_request()
514 void ceph_osdc_put_request(struct ceph_osd_request *req) in ceph_osdc_put_request()
524 static void request_init(struct ceph_osd_request *req) in request_init()
545 static void request_reinit(struct ceph_osd_request *req) in request_reinit()
575 struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc, in ceph_osdc_alloc_request()
581 struct ceph_osd_request *req; in ceph_osdc_alloc_request()
612 static int __ceph_osdc_alloc_messages(struct ceph_osd_request *req, gfp_t gfp, in __ceph_osdc_alloc_messages()
683 static void get_num_data_items(struct ceph_osd_request *req, in get_num_data_items()
732 int ceph_osdc_alloc_messages(struct ceph_osd_request *req, gfp_t gfp) in ceph_osdc_alloc_messages()
748 _osd_req_op_init(struct ceph_osd_request *osd_req, unsigned int which, in _osd_req_op_init()
764 void osd_req_op_init(struct ceph_osd_request *osd_req, in osd_req_op_init()
771 void osd_req_op_extent_init(struct ceph_osd_request *osd_req, in osd_req_op_extent_init()
795 void osd_req_op_extent_update(struct ceph_osd_request *osd_req, in osd_req_op_extent_update()
815 void osd_req_op_extent_dup_last(struct ceph_osd_request *osd_req, in osd_req_op_extent_dup_last()
837 int osd_req_op_cls_init(struct ceph_osd_request *osd_req, unsigned int which, in osd_req_op_cls_init()
880 int osd_req_op_xattr_init(struct ceph_osd_request *osd_req, unsigned int which, in osd_req_op_xattr_init()
924 static void osd_req_op_watch_init(struct ceph_osd_request *req, int which, in osd_req_op_watch_init()
935 void osd_req_op_alloc_hint_init(struct ceph_osd_request *osd_req, in osd_req_op_alloc_hint_init()
1063 struct ceph_osd_request *ceph_osdc_new_request(struct ceph_osd_client *osdc, in ceph_osdc_new_request()
1074 struct ceph_osd_request *req; in ceph_osdc_new_request()
1146 DEFINE_RB_FUNCS(request, struct ceph_osd_request, r_tid, r_node) in DEFINE_RB_FUNCS() argument
1147 DEFINE_RB_FUNCS(request_mc, struct ceph_osd_request, r_tid, r_mc_node) in DEFINE_RB_FUNCS()
1153 int (*fn)(struct ceph_osd_request *req, void *arg), in DEFINE_RB_FUNCS()
1162 struct ceph_osd_request *req = in DEFINE_RB_FUNCS()
1163 rb_entry(p, struct ceph_osd_request, r_node); in DEFINE_RB_FUNCS()
1172 struct ceph_osd_request *req = in DEFINE_RB_FUNCS()
1173 rb_entry(p, struct ceph_osd_request, r_node); in DEFINE_RB_FUNCS()
1317 struct ceph_osd_request *req = in close_osd()
1318 rb_entry(n, struct ceph_osd_request, r_node); in close_osd()
1368 struct ceph_osd_request *req = in reopen_osd()
1369 rb_entry(n, struct ceph_osd_request, r_node); in reopen_osd()
1416 static void link_request(struct ceph_osd *osd, struct ceph_osd_request *req) in link_request()
1433 static void unlink_request(struct ceph_osd *osd, struct ceph_osd_request *req) in unlink_request()
1914 static bool should_plug_request(struct ceph_osd_request *req) in should_plug_request()
1939 static void setup_request_data(struct ceph_osd_request *req) in setup_request_data()
2041 static void encode_request_partial(struct ceph_osd_request *req, in encode_request_partial()
2213 static void send_request(struct ceph_osd_request *req) in send_request()
2275 static void complete_request(struct ceph_osd_request *req, int err);
2276 static void send_map_check(struct ceph_osd_request *req);
2278 static void __submit_request(struct ceph_osd_request *req, bool wrlocked) in __submit_request()
2367 static void account_request(struct ceph_osd_request *req) in account_request()
2378 static void submit_request(struct ceph_osd_request *req, bool wrlocked) in submit_request()
2385 static void finish_request(struct ceph_osd_request *req) in finish_request()
2406 static void __complete_request(struct ceph_osd_request *req) in __complete_request()
2419 struct ceph_osd_request *req = in complete_request_workfn()
2420 container_of(work, struct ceph_osd_request, r_complete_work); in complete_request_workfn()
2428 static void complete_request(struct ceph_osd_request *req, int err) in complete_request()
2439 static void cancel_map_check(struct ceph_osd_request *req) in cancel_map_check()
2442 struct ceph_osd_request *lookup_req; in cancel_map_check()
2455 static void cancel_request(struct ceph_osd_request *req) in cancel_request()
2465 static void abort_request(struct ceph_osd_request *req, int err) in abort_request()
2473 static int abort_fn(struct ceph_osd_request *req, void *arg) in abort_fn()
2535 static int abort_on_full_fn(struct ceph_osd_request *req, void *arg) in abort_on_full_fn()
2568 static void check_pool_dne(struct ceph_osd_request *req) in check_pool_dne()
2605 struct ceph_osd_request *req; in map_check_cb()
2629 static void send_map_check(struct ceph_osd_request *req) in send_map_check()
2632 struct ceph_osd_request *lookup_req; in send_map_check()
2800 static void cancel_linger_request(struct ceph_osd_request *req) in cancel_linger_request()
2934 static void linger_commit_cb(struct ceph_osd_request *req) in linger_commit_cb()
2979 static void linger_reconnect_cb(struct ceph_osd_request *req) in linger_reconnect_cb()
2999 struct ceph_osd_request *req = lreq->reg_req; in send_linger()
3039 static void linger_ping_cb(struct ceph_osd_request *req) in linger_ping_cb()
3066 struct ceph_osd_request *req = lreq->ping_req; in send_linger_ping()
3293 struct ceph_osd_request *req = in handle_timeout()
3294 rb_entry(p, struct ceph_osd_request, r_node); in handle_timeout()
3330 struct ceph_osd_request *req = in handle_timeout()
3331 rb_entry(p, struct ceph_osd_request, r_node); in handle_timeout()
3596 struct ceph_osd_request *req; in handle_reply()
3796 struct ceph_osd_request *req = in scan_requests()
3797 rb_entry(n, struct ceph_osd_request, r_node); in scan_requests()
3906 struct ceph_osd_request *req = in kick_requests()
3907 rb_entry(n, struct ceph_osd_request, r_node); in kick_requests()
3921 struct ceph_osd_request *req = in kick_requests()
3922 rb_entry(n, struct ceph_osd_request, r_node); in kick_requests()
4073 struct ceph_osd_request *req = in kick_osd_requests()
4074 rb_entry(n, struct ceph_osd_request, r_node); in kick_osd_requests()
4312 struct ceph_osd_request *req = in handle_backoff_unblock()
4313 rb_entry(n, struct ceph_osd_request, r_node); in handle_backoff_unblock()
4477 struct ceph_osd_request *req, in ceph_osdc_start_request()
4492 void ceph_osdc_cancel_request(struct ceph_osd_request *req) in ceph_osdc_cancel_request()
4506 static int wait_request_timeout(struct ceph_osd_request *req, in wait_request_timeout()
4528 struct ceph_osd_request *req) in ceph_osdc_wait_request()
4549 struct ceph_osd_request *req = in ceph_osdc_sync()
4550 rb_entry(p, struct ceph_osd_request, r_node); in ceph_osdc_sync()
4576 static struct ceph_osd_request *
4579 struct ceph_osd_request *req; in alloc_linger_request()
4590 static struct ceph_osd_request *
4593 struct ceph_osd_request *req; in alloc_watch_request()
4680 struct ceph_osd_request *req; in ceph_osdc_unwatch()
4709 static int osd_req_op_notify_ack_init(struct ceph_osd_request *req, int which, in osd_req_op_notify_ack_init()
4749 struct ceph_osd_request *req; in ceph_osdc_notify_ack()
4778 static int osd_req_op_notify_init(struct ceph_osd_request *req, int which, in osd_req_op_notify_init()
4994 struct ceph_osd_request *req; in ceph_osdc_list_watchers()
5069 struct ceph_osd_request *req; in ceph_osdc_call()
5243 struct ceph_osd_request *req; in ceph_osdc_readpages()
5283 struct ceph_osd_request *req; in ceph_osdc_writepages()
5312 static int osd_req_op_copy_from_init(struct ceph_osd_request *req, in osd_req_op_copy_from_init()
5355 struct ceph_osd_request *req; in ceph_osdc_copy_from()
5388 size_t size = sizeof(struct ceph_osd_request) + in ceph_osdc_setup()
5448 struct ceph_osd_request *req; in get_reply()