Lines Matching refs:ceph_osd_request
32 struct ceph_osd_request *req);
34 struct ceph_osd_request *req);
36 struct ceph_osd_request *req);
37 static void __enqueue_request(struct ceph_osd_request *req);
39 struct ceph_osd_request *req);
130 osd_req_op_raw_data_in(struct ceph_osd_request *osd_req, unsigned int which) in osd_req_op_raw_data_in()
138 osd_req_op_extent_osd_data(struct ceph_osd_request *osd_req, in osd_req_op_extent_osd_data()
146 osd_req_op_cls_response_data(struct ceph_osd_request *osd_req, in osd_req_op_cls_response_data()
153 void osd_req_op_raw_data_in_pages(struct ceph_osd_request *osd_req, in osd_req_op_raw_data_in_pages()
166 void osd_req_op_extent_osd_data_pages(struct ceph_osd_request *osd_req, in osd_req_op_extent_osd_data_pages()
179 void osd_req_op_extent_osd_data_pagelist(struct ceph_osd_request *osd_req, in osd_req_op_extent_osd_data_pagelist()
190 void osd_req_op_extent_osd_data_bio(struct ceph_osd_request *osd_req, in osd_req_op_extent_osd_data_bio()
202 struct ceph_osd_request *osd_req, in osd_req_op_cls_request_info_pagelist()
212 struct ceph_osd_request *osd_req, in osd_req_op_cls_request_data_pagelist()
222 void osd_req_op_cls_request_data_pages(struct ceph_osd_request *osd_req, in osd_req_op_cls_request_data_pages()
234 void osd_req_op_cls_response_data_pages(struct ceph_osd_request *osd_req, in osd_req_op_cls_response_data_pages()
277 static void osd_req_op_data_release(struct ceph_osd_request *osd_req, in osd_req_op_data_release()
309 struct ceph_osd_request *req = container_of(kref, in ceph_osdc_release_request()
310 struct ceph_osd_request, r_kref); in ceph_osdc_release_request()
340 void ceph_osdc_get_request(struct ceph_osd_request *req) in ceph_osdc_get_request()
348 void ceph_osdc_put_request(struct ceph_osd_request *req) in ceph_osdc_put_request()
356 struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc, in ceph_osdc_alloc_request()
362 struct ceph_osd_request *req; in ceph_osdc_alloc_request()
452 _osd_req_op_init(struct ceph_osd_request *osd_req, unsigned int which, in _osd_req_op_init()
467 void osd_req_op_init(struct ceph_osd_request *osd_req, in osd_req_op_init()
474 void osd_req_op_extent_init(struct ceph_osd_request *osd_req, in osd_req_op_extent_init()
496 void osd_req_op_extent_update(struct ceph_osd_request *osd_req, in osd_req_op_extent_update()
515 void osd_req_op_cls_init(struct ceph_osd_request *osd_req, unsigned int which, in osd_req_op_cls_init()
551 int osd_req_op_xattr_init(struct ceph_osd_request *osd_req, unsigned int which, in osd_req_op_xattr_init()
584 void osd_req_op_watch_init(struct ceph_osd_request *osd_req, in osd_req_op_watch_init()
599 void osd_req_op_alloc_hint_init(struct ceph_osd_request *osd_req, in osd_req_op_alloc_hint_init()
641 static u64 osd_req_encode_op(struct ceph_osd_request *req, in osd_req_encode_op()
753 struct ceph_osd_request *ceph_osdc_new_request(struct ceph_osd_client *osdc, in ceph_osdc_new_request()
764 struct ceph_osd_request *req; in ceph_osdc_new_request()
820 struct ceph_osd_request *new) in __insert_request()
824 struct ceph_osd_request *req = NULL; in __insert_request()
828 req = rb_entry(parent, struct ceph_osd_request, r_node); in __insert_request()
841 static struct ceph_osd_request *__lookup_request(struct ceph_osd_client *osdc, in __lookup_request()
844 struct ceph_osd_request *req; in __lookup_request()
848 req = rb_entry(n, struct ceph_osd_request, r_node); in __lookup_request()
859 static struct ceph_osd_request *
863 struct ceph_osd_request *req; in __lookup_request_ge()
867 req = rb_entry(n, struct ceph_osd_request, r_node); in __lookup_request_ge()
881 static void __kick_linger_request(struct ceph_osd_request *req) in __kick_linger_request()
918 struct ceph_osd_request *req, *nreq; in __kick_osd_requests()
1142 struct ceph_osd_request *req; in __reset_osd()
1215 struct ceph_osd_request *req) in __register_request()
1233 struct ceph_osd_request *req) in __unregister_request()
1268 static void __cancel_request(struct ceph_osd_request *req) in __cancel_request()
1277 struct ceph_osd_request *req) in __register_linger_request()
1290 struct ceph_osd_request *req) in __unregister_linger_request()
1313 struct ceph_osd_request *req) in ceph_osdc_set_request_linger()
1329 struct ceph_osd_request *req) in __req_should_be_paused()
1342 struct ceph_osd_request *req, in __calc_request_pg()
1377 static void __enqueue_request(struct ceph_osd_request *req) in __enqueue_request()
1404 struct ceph_osd_request *req, int force_resend) in __map_request()
1482 struct ceph_osd_request *req) in __send_request()
1516 struct ceph_osd_request *req, *tmp; in __send_queued()
1527 struct ceph_osd_request *req, in __ceph_osdc_start_request()
1570 struct ceph_osd_request *req; in handle_timeout()
1731 static void complete_request(struct ceph_osd_request *req) in complete_request()
1744 struct ceph_osd_request *req; in handle_reply()
1960 struct ceph_osd_request *req, *nreq; in kick_requests()
1970 req = rb_entry(p, struct ceph_osd_request, r_node); in kick_requests()
2388 void ceph_osdc_build_request(struct ceph_osd_request *req, u64 off, in ceph_osdc_build_request()
2487 struct ceph_osd_request *req, in ceph_osdc_start_request()
2509 void ceph_osdc_cancel_request(struct ceph_osd_request *req) in ceph_osdc_cancel_request()
2527 struct ceph_osd_request *req) in ceph_osdc_wait_request()
2552 struct ceph_osd_request *req; in ceph_osdc_sync()
2626 sizeof(struct ceph_osd_request)); in ceph_osdc_init()
2684 struct ceph_osd_request *req; in ceph_osdc_readpages()
2727 struct ceph_osd_request *req; in ceph_osdc_writepages()
2763 sizeof (struct ceph_osd_request), in ceph_osdc_setup()
2764 __alignof__(struct ceph_osd_request), in ceph_osdc_setup()
2822 struct ceph_osd_request *req; in get_reply()