Lines Matching refs:ceph_osd_client
26 static void send_queued(struct ceph_osd_client *osdc);
27 static int __reset_osd(struct ceph_osd_client *osdc, struct ceph_osd *osd);
28 static void __register_request(struct ceph_osd_client *osdc,
30 static void __unregister_linger_request(struct ceph_osd_client *osdc,
32 static void __send_request(struct ceph_osd_client *osdc,
55 int ceph_calc_raw_layout(struct ceph_osd_client *osdc, in ceph_calc_raw_layout()
118 static int calc_layout(struct ceph_osd_client *osdc, in calc_layout()
192 struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc, in ceph_osdc_alloc_request()
450 struct ceph_osd_request *ceph_osdc_new_request(struct ceph_osd_client *osdc, in ceph_osdc_new_request()
509 static void __insert_request(struct ceph_osd_client *osdc, in __insert_request()
531 static struct ceph_osd_request *__lookup_request(struct ceph_osd_client *osdc, in __lookup_request()
550 __lookup_request_ge(struct ceph_osd_client *osdc, in __lookup_request_ge()
574 static void __kick_osd_requests(struct ceph_osd_client *osdc, in __kick_osd_requests()
615 struct ceph_osd_client *osdc; in osd_reset()
632 static struct ceph_osd *create_osd(struct ceph_osd_client *osdc, int onum) in create_osd()
682 static void __remove_osd(struct ceph_osd_client *osdc, struct ceph_osd *osd) in __remove_osd()
692 static void remove_all_osds(struct ceph_osd_client *osdc) in remove_all_osds()
704 static void __move_osd_to_lru(struct ceph_osd_client *osdc, in __move_osd_to_lru()
720 static void remove_old_osds(struct ceph_osd_client *osdc) in remove_old_osds()
737 static int __reset_osd(struct ceph_osd_client *osdc, struct ceph_osd *osd) in __reset_osd()
766 static void __insert_osd(struct ceph_osd_client *osdc, struct ceph_osd *new) in __insert_osd()
788 static struct ceph_osd *__lookup_osd(struct ceph_osd_client *osdc, int o) in __lookup_osd()
805 static void __schedule_osd_timeout(struct ceph_osd_client *osdc) in __schedule_osd_timeout()
811 static void __cancel_osd_timeout(struct ceph_osd_client *osdc) in __cancel_osd_timeout()
820 static void __register_request(struct ceph_osd_client *osdc, in __register_request()
835 static void register_request(struct ceph_osd_client *osdc, in register_request()
846 static void __unregister_request(struct ceph_osd_client *osdc, in __unregister_request()
893 static void __register_linger_request(struct ceph_osd_client *osdc, in __register_linger_request()
903 static void __unregister_linger_request(struct ceph_osd_client *osdc, in __unregister_linger_request()
921 void ceph_osdc_unregister_linger_request(struct ceph_osd_client *osdc, in ceph_osdc_unregister_linger_request()
933 void ceph_osdc_set_request_linger(struct ceph_osd_client *osdc, in ceph_osdc_set_request_linger()
958 static int __map_request(struct ceph_osd_client *osdc, in __map_request()
1038 static void __send_request(struct ceph_osd_client *osdc, in __send_request()
1062 static void send_queued(struct ceph_osd_client *osdc) in send_queued()
1085 struct ceph_osd_client *osdc = in handle_timeout()
1086 container_of(work, struct ceph_osd_client, timeout_work.work); in handle_timeout()
1130 struct ceph_osd_client *osdc = in handle_osds_timeout()
1131 container_of(work, struct ceph_osd_client, in handle_osds_timeout()
1156 static void handle_reply(struct ceph_osd_client *osdc, struct ceph_msg *msg, in handle_reply()
1249 static void reset_changed_osds(struct ceph_osd_client *osdc) in reset_changed_osds()
1272 static void kick_requests(struct ceph_osd_client *osdc, bool force_resend, in kick_requests()
1363 void ceph_osdc_handle_map(struct ceph_osd_client *osdc, struct ceph_msg *msg) in ceph_osdc_handle_map()
1515 static void __insert_event(struct ceph_osd_client *osdc, in __insert_event()
1537 static struct ceph_osd_event *__find_event(struct ceph_osd_client *osdc, in __find_event()
1559 struct ceph_osd_client *osdc = event->osdc; in __remove_event()
1570 int ceph_osdc_create_event(struct ceph_osd_client *osdc, in ceph_osdc_create_event()
1604 struct ceph_osd_client *osdc = event->osdc; in ceph_osdc_cancel_event()
1636 void handle_watch_notify(struct ceph_osd_client *osdc, struct ceph_msg *msg) in handle_watch_notify()
1711 int ceph_osdc_start_request(struct ceph_osd_client *osdc, in ceph_osdc_start_request()
1764 int ceph_osdc_wait_request(struct ceph_osd_client *osdc, in ceph_osdc_wait_request()
1788 void ceph_osdc_sync(struct ceph_osd_client *osdc) in ceph_osdc_sync()
1822 int ceph_osdc_init(struct ceph_osd_client *osdc, struct ceph_client *client) in ceph_osdc_init()
1885 void ceph_osdc_stop(struct ceph_osd_client *osdc) in ceph_osdc_stop()
1906 int ceph_osdc_readpages(struct ceph_osd_client *osdc, in ceph_osdc_readpages()
1943 int ceph_osdc_writepages(struct ceph_osd_client *osdc, struct ceph_vino vino, in ceph_osdc_writepages()
1990 struct ceph_osd_client *osdc; in dispatch()
2025 struct ceph_osd_client *osdc = osd->o_osdc; in get_reply()
2142 struct ceph_osd_client *osdc = o->o_osdc; in get_authorizer()
2170 struct ceph_osd_client *osdc = o->o_osdc; in verify_authorizer_reply()
2179 struct ceph_osd_client *osdc = o->o_osdc; in invalidate_authorizer()