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,
362 struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc, in ceph_osdc_alloc_request()
769 struct ceph_osd_request *ceph_osdc_new_request(struct ceph_osd_client *osdc, in ceph_osdc_new_request()
835 static void __insert_request(struct ceph_osd_client *osdc, in __insert_request()
857 static struct ceph_osd_request *__lookup_request(struct ceph_osd_client *osdc, in __lookup_request()
876 __lookup_request_ge(struct ceph_osd_client *osdc, in __lookup_request_ge()
899 struct ceph_osd_client *osdc = req->r_osdc; in __kick_linger_request()
931 static void __kick_osd_requests(struct ceph_osd_client *osdc, in __kick_osd_requests()
998 struct ceph_osd_client *osdc; in osd_reset()
1015 static struct ceph_osd *create_osd(struct ceph_osd_client *osdc, int onum) in create_osd()
1066 static void __remove_osd(struct ceph_osd_client *osdc, struct ceph_osd *osd) in __remove_osd()
1077 static void remove_osd(struct ceph_osd_client *osdc, struct ceph_osd *osd) in remove_osd()
1088 static void remove_all_osds(struct ceph_osd_client *osdc) in remove_all_osds()
1100 static void __move_osd_to_lru(struct ceph_osd_client *osdc, in __move_osd_to_lru()
1110 static void maybe_move_osd_to_lru(struct ceph_osd_client *osdc, in maybe_move_osd_to_lru()
1127 static void remove_old_osds(struct ceph_osd_client *osdc) in remove_old_osds()
1144 static int __reset_osd(struct ceph_osd_client *osdc, struct ceph_osd *osd) in __reset_osd()
1176 static void __insert_osd(struct ceph_osd_client *osdc, struct ceph_osd *new) in __insert_osd()
1198 static struct ceph_osd *__lookup_osd(struct ceph_osd_client *osdc, int o) in __lookup_osd()
1215 static void __schedule_osd_timeout(struct ceph_osd_client *osdc) in __schedule_osd_timeout()
1221 static void __cancel_osd_timeout(struct ceph_osd_client *osdc) in __cancel_osd_timeout()
1230 static void __register_request(struct ceph_osd_client *osdc, in __register_request()
1248 static void __unregister_request(struct ceph_osd_client *osdc, in __unregister_request()
1292 static void __register_linger_request(struct ceph_osd_client *osdc, in __register_linger_request()
1305 static void __unregister_linger_request(struct ceph_osd_client *osdc, in __unregister_linger_request()
1328 void ceph_osdc_set_request_linger(struct ceph_osd_client *osdc, in ceph_osdc_set_request_linger()
1344 static bool __req_should_be_paused(struct ceph_osd_client *osdc, in __req_should_be_paused()
1395 struct ceph_osd_client *osdc = req->r_osdc; in __enqueue_request()
1419 static int __map_request(struct ceph_osd_client *osdc, in __map_request()
1497 static void __send_request(struct ceph_osd_client *osdc, in __send_request()
1530 static void __send_queued(struct ceph_osd_client *osdc) in __send_queued()
1542 static int __ceph_osdc_start_request(struct ceph_osd_client *osdc, in __ceph_osdc_start_request()
1584 struct ceph_osd_client *osdc = in handle_timeout()
1585 container_of(work, struct ceph_osd_client, timeout_work.work); in handle_timeout()
1629 struct ceph_osd_client *osdc = in handle_osds_timeout()
1630 container_of(work, struct ceph_osd_client, in handle_osds_timeout()
1755 static void handle_reply(struct ceph_osd_client *osdc, struct ceph_msg *msg) in handle_reply()
1947 static void reset_changed_osds(struct ceph_osd_client *osdc) in reset_changed_osds()
1971 static void kick_requests(struct ceph_osd_client *osdc, bool force_resend, in kick_requests()
2073 void ceph_osdc_handle_map(struct ceph_osd_client *osdc, struct ceph_msg *msg) in ceph_osdc_handle_map()
2230 static void __insert_event(struct ceph_osd_client *osdc, in __insert_event()
2252 static struct ceph_osd_event *__find_event(struct ceph_osd_client *osdc, in __find_event()
2274 struct ceph_osd_client *osdc = event->osdc; in __remove_event()
2285 int ceph_osdc_create_event(struct ceph_osd_client *osdc, in ceph_osdc_create_event()
2317 struct ceph_osd_client *osdc = event->osdc; in ceph_osdc_cancel_event()
2348 static void handle_watch_notify(struct ceph_osd_client *osdc, in handle_watch_notify()
2500 int ceph_osdc_start_request(struct ceph_osd_client *osdc, in ceph_osdc_start_request()
2525 struct ceph_osd_client *osdc = req->r_osdc; in ceph_osdc_cancel_request()
2540 int ceph_osdc_wait_request(struct ceph_osd_client *osdc, in ceph_osdc_wait_request()
2564 void ceph_osdc_sync(struct ceph_osd_client *osdc) in ceph_osdc_sync()
2599 void ceph_osdc_flush_notifies(struct ceph_osd_client *osdc) in ceph_osdc_flush_notifies()
2609 int ceph_osdc_init(struct ceph_osd_client *osdc, struct ceph_client *client) in ceph_osdc_init()
2672 void ceph_osdc_stop(struct ceph_osd_client *osdc) in ceph_osdc_stop()
2692 int ceph_osdc_readpages(struct ceph_osd_client *osdc, in ceph_osdc_readpages()
2733 int ceph_osdc_writepages(struct ceph_osd_client *osdc, struct ceph_vino vino, in ceph_osdc_writepages()
2799 struct ceph_osd_client *osdc; in dispatch()
2835 struct ceph_osd_client *osdc = osd->o_osdc; in get_reply()
2935 struct ceph_osd_client *osdc = o->o_osdc; in get_authorizer()
2963 struct ceph_osd_client *osdc = o->o_osdc; in verify_authorizer_reply()
2972 struct ceph_osd_client *osdc = o->o_osdc; in invalidate_authorizer()