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);
125 struct ceph_osd_request *__oreq = (oreq); \
132 osd_req_op_raw_data_in(struct ceph_osd_request *osd_req, unsigned int which) in osd_req_op_raw_data_in()
140 osd_req_op_extent_osd_data(struct ceph_osd_request *osd_req, in osd_req_op_extent_osd_data()
148 osd_req_op_cls_response_data(struct ceph_osd_request *osd_req, in osd_req_op_cls_response_data()
155 void osd_req_op_raw_data_in_pages(struct ceph_osd_request *osd_req, in osd_req_op_raw_data_in_pages()
168 void osd_req_op_extent_osd_data_pages(struct ceph_osd_request *osd_req, in osd_req_op_extent_osd_data_pages()
181 void osd_req_op_extent_osd_data_pagelist(struct ceph_osd_request *osd_req, in osd_req_op_extent_osd_data_pagelist()
192 void osd_req_op_extent_osd_data_bio(struct ceph_osd_request *osd_req, in osd_req_op_extent_osd_data_bio()
204 struct ceph_osd_request *osd_req, in osd_req_op_cls_request_info_pagelist()
214 struct ceph_osd_request *osd_req, in osd_req_op_cls_request_data_pagelist()
224 void osd_req_op_cls_request_data_pages(struct ceph_osd_request *osd_req, in osd_req_op_cls_request_data_pages()
236 void osd_req_op_cls_response_data_pages(struct ceph_osd_request *osd_req, in osd_req_op_cls_response_data_pages()
279 static void osd_req_op_data_release(struct ceph_osd_request *osd_req, in osd_req_op_data_release()
315 struct ceph_osd_request *req = container_of(kref, in ceph_osdc_release_request()
316 struct ceph_osd_request, r_kref); in ceph_osdc_release_request()
346 void ceph_osdc_get_request(struct ceph_osd_request *req) in ceph_osdc_get_request()
354 void ceph_osdc_put_request(struct ceph_osd_request *req) in ceph_osdc_put_request()
362 struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc, in ceph_osdc_alloc_request()
368 struct ceph_osd_request *req; in ceph_osdc_alloc_request()
458 _osd_req_op_init(struct ceph_osd_request *osd_req, unsigned int which, in _osd_req_op_init()
474 void osd_req_op_init(struct ceph_osd_request *osd_req, in osd_req_op_init()
481 void osd_req_op_extent_init(struct ceph_osd_request *osd_req, in osd_req_op_extent_init()
505 void osd_req_op_extent_update(struct ceph_osd_request *osd_req, in osd_req_op_extent_update()
524 void osd_req_op_cls_init(struct ceph_osd_request *osd_req, unsigned int which, in osd_req_op_cls_init()
561 int osd_req_op_xattr_init(struct ceph_osd_request *osd_req, unsigned int which, in osd_req_op_xattr_init()
595 void osd_req_op_watch_init(struct ceph_osd_request *osd_req, in osd_req_op_watch_init()
611 void osd_req_op_alloc_hint_init(struct ceph_osd_request *osd_req, in osd_req_op_alloc_hint_init()
654 static u64 osd_req_encode_op(struct ceph_osd_request *req, in osd_req_encode_op()
769 struct ceph_osd_request *ceph_osdc_new_request(struct ceph_osd_client *osdc, in ceph_osdc_new_request()
780 struct ceph_osd_request *req; in ceph_osdc_new_request()
836 struct ceph_osd_request *new) in __insert_request()
840 struct ceph_osd_request *req = NULL; in __insert_request()
844 req = rb_entry(parent, struct ceph_osd_request, r_node); in __insert_request()
857 static struct ceph_osd_request *__lookup_request(struct ceph_osd_client *osdc, in __lookup_request()
860 struct ceph_osd_request *req; in __lookup_request()
864 req = rb_entry(n, struct ceph_osd_request, r_node); in __lookup_request()
875 static struct ceph_osd_request *
879 struct ceph_osd_request *req; in __lookup_request_ge()
883 req = rb_entry(n, struct ceph_osd_request, r_node); in __lookup_request_ge()
897 static void __kick_linger_request(struct ceph_osd_request *req) in __kick_linger_request()
934 struct ceph_osd_request *req, *nreq; in __kick_osd_requests()
1158 struct ceph_osd_request *req; in __reset_osd()
1231 struct ceph_osd_request *req) in __register_request()
1249 struct ceph_osd_request *req) in __unregister_request()
1284 static void __cancel_request(struct ceph_osd_request *req) in __cancel_request()
1293 struct ceph_osd_request *req) in __register_linger_request()
1306 struct ceph_osd_request *req) in __unregister_linger_request()
1329 struct ceph_osd_request *req) in ceph_osdc_set_request_linger()
1345 struct ceph_osd_request *req) in __req_should_be_paused()
1358 struct ceph_osd_request *req, in __calc_request_pg()
1393 static void __enqueue_request(struct ceph_osd_request *req) in __enqueue_request()
1420 struct ceph_osd_request *req, int force_resend) in __map_request()
1498 struct ceph_osd_request *req) in __send_request()
1532 struct ceph_osd_request *req, *tmp; in __send_queued()
1543 struct ceph_osd_request *req, in __ceph_osdc_start_request()
1587 struct ceph_osd_request *req; in handle_timeout()
1746 static void complete_request(struct ceph_osd_request *req) in complete_request()
1758 struct ceph_osd_request *req; in handle_reply()
1974 struct ceph_osd_request *req, *nreq; in kick_requests()
1984 req = rb_entry(p, struct ceph_osd_request, r_node); in kick_requests()
2402 void ceph_osdc_build_request(struct ceph_osd_request *req, u64 off, in ceph_osdc_build_request()
2501 struct ceph_osd_request *req, in ceph_osdc_start_request()
2523 void ceph_osdc_cancel_request(struct ceph_osd_request *req) in ceph_osdc_cancel_request()
2541 struct ceph_osd_request *req) in ceph_osdc_wait_request()
2566 struct ceph_osd_request *req; in ceph_osdc_sync()
2640 sizeof(struct ceph_osd_request)); in ceph_osdc_init()
2698 struct ceph_osd_request *req; in ceph_osdc_readpages()
2741 struct ceph_osd_request *req; in ceph_osdc_writepages()
2777 sizeof (struct ceph_osd_request), in ceph_osdc_setup()
2778 __alignof__(struct ceph_osd_request), in ceph_osdc_setup()
2837 struct ceph_osd_request *req; in get_reply()