Lines Matching refs:ceph_osd_client
29 static void __send_queued(struct ceph_osd_client *osdc);
30 static int __reset_osd(struct ceph_osd_client *osdc, struct ceph_osd *osd);
31 static void __register_request(struct ceph_osd_client *osdc,
33 static void __unregister_request(struct ceph_osd_client *osdc,
35 static void __unregister_linger_request(struct ceph_osd_client *osdc,
38 static void __send_request(struct ceph_osd_client *osdc,
356 struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc, in ceph_osdc_alloc_request()
753 struct ceph_osd_request *ceph_osdc_new_request(struct ceph_osd_client *osdc, in ceph_osdc_new_request()
819 static void __insert_request(struct ceph_osd_client *osdc, in __insert_request()
841 static struct ceph_osd_request *__lookup_request(struct ceph_osd_client *osdc, in __lookup_request()
860 __lookup_request_ge(struct ceph_osd_client *osdc, in __lookup_request_ge()
883 struct ceph_osd_client *osdc = req->r_osdc; in __kick_linger_request()
915 static void __kick_osd_requests(struct ceph_osd_client *osdc, in __kick_osd_requests()
982 struct ceph_osd_client *osdc; in osd_reset()
999 static struct ceph_osd *create_osd(struct ceph_osd_client *osdc, int onum) in create_osd()
1050 static void __remove_osd(struct ceph_osd_client *osdc, struct ceph_osd *osd) in __remove_osd()
1061 static void remove_osd(struct ceph_osd_client *osdc, struct ceph_osd *osd) in remove_osd()
1072 static void remove_all_osds(struct ceph_osd_client *osdc) in remove_all_osds()
1084 static void __move_osd_to_lru(struct ceph_osd_client *osdc, in __move_osd_to_lru()
1094 static void maybe_move_osd_to_lru(struct ceph_osd_client *osdc, in maybe_move_osd_to_lru()
1111 static void remove_old_osds(struct ceph_osd_client *osdc) in remove_old_osds()
1128 static int __reset_osd(struct ceph_osd_client *osdc, struct ceph_osd *osd) in __reset_osd()
1160 static void __insert_osd(struct ceph_osd_client *osdc, struct ceph_osd *new) in __insert_osd()
1182 static struct ceph_osd *__lookup_osd(struct ceph_osd_client *osdc, int o) in __lookup_osd()
1199 static void __schedule_osd_timeout(struct ceph_osd_client *osdc) in __schedule_osd_timeout()
1205 static void __cancel_osd_timeout(struct ceph_osd_client *osdc) in __cancel_osd_timeout()
1214 static void __register_request(struct ceph_osd_client *osdc, in __register_request()
1232 static void __unregister_request(struct ceph_osd_client *osdc, in __unregister_request()
1276 static void __register_linger_request(struct ceph_osd_client *osdc, in __register_linger_request()
1289 static void __unregister_linger_request(struct ceph_osd_client *osdc, in __unregister_linger_request()
1312 void ceph_osdc_set_request_linger(struct ceph_osd_client *osdc, in ceph_osdc_set_request_linger()
1328 static bool __req_should_be_paused(struct ceph_osd_client *osdc, in __req_should_be_paused()
1379 struct ceph_osd_client *osdc = req->r_osdc; in __enqueue_request()
1403 static int __map_request(struct ceph_osd_client *osdc, in __map_request()
1481 static void __send_request(struct ceph_osd_client *osdc, in __send_request()
1514 static void __send_queued(struct ceph_osd_client *osdc) in __send_queued()
1526 static int __ceph_osdc_start_request(struct ceph_osd_client *osdc, in __ceph_osdc_start_request()
1568 struct ceph_osd_client *osdc = in handle_timeout()
1569 container_of(work, struct ceph_osd_client, timeout_work.work); in handle_timeout()
1613 struct ceph_osd_client *osdc = in handle_osds_timeout()
1614 container_of(work, struct ceph_osd_client, in handle_osds_timeout()
1740 static void handle_reply(struct ceph_osd_client *osdc, struct ceph_msg *msg, in handle_reply()
1933 static void reset_changed_osds(struct ceph_osd_client *osdc) in reset_changed_osds()
1957 static void kick_requests(struct ceph_osd_client *osdc, bool force_resend, in kick_requests()
2059 void ceph_osdc_handle_map(struct ceph_osd_client *osdc, struct ceph_msg *msg) in ceph_osdc_handle_map()
2216 static void __insert_event(struct ceph_osd_client *osdc, in __insert_event()
2238 static struct ceph_osd_event *__find_event(struct ceph_osd_client *osdc, in __find_event()
2260 struct ceph_osd_client *osdc = event->osdc; in __remove_event()
2271 int ceph_osdc_create_event(struct ceph_osd_client *osdc, in ceph_osdc_create_event()
2303 struct ceph_osd_client *osdc = event->osdc; in ceph_osdc_cancel_event()
2334 static void handle_watch_notify(struct ceph_osd_client *osdc, in handle_watch_notify()
2486 int ceph_osdc_start_request(struct ceph_osd_client *osdc, in ceph_osdc_start_request()
2511 struct ceph_osd_client *osdc = req->r_osdc; in ceph_osdc_cancel_request()
2526 int ceph_osdc_wait_request(struct ceph_osd_client *osdc, in ceph_osdc_wait_request()
2550 void ceph_osdc_sync(struct ceph_osd_client *osdc) in ceph_osdc_sync()
2585 void ceph_osdc_flush_notifies(struct ceph_osd_client *osdc) in ceph_osdc_flush_notifies()
2595 int ceph_osdc_init(struct ceph_osd_client *osdc, struct ceph_client *client) in ceph_osdc_init()
2658 void ceph_osdc_stop(struct ceph_osd_client *osdc) in ceph_osdc_stop()
2678 int ceph_osdc_readpages(struct ceph_osd_client *osdc, in ceph_osdc_readpages()
2719 int ceph_osdc_writepages(struct ceph_osd_client *osdc, struct ceph_vino vino, in ceph_osdc_writepages()
2785 struct ceph_osd_client *osdc; in dispatch()
2820 struct ceph_osd_client *osdc = osd->o_osdc; in get_reply()
2939 struct ceph_osd_client *osdc = o->o_osdc; in get_authorizer()
2967 struct ceph_osd_client *osdc = o->o_osdc; in verify_authorizer_reply()
2976 struct ceph_osd_client *osdc = o->o_osdc; in invalidate_authorizer()