H A D | osd_client.c | 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, 352 struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc, argument 376 req = mempool_alloc(osdc->req_mempool, gfp_flags); 384 req->r_osdc = osdc; 403 msg = ceph_msgpool_get(&osdc 705 ceph_osdc_new_request(struct ceph_osd_client *osdc, struct ceph_file_layout *layout, struct ceph_vino vino, u64 off, u64 *plen, int num_ops, int opcode, int flags, struct ceph_snap_context *snapc, u32 truncate_seq, u64 truncate_size, bool use_mempool) argument 777 __insert_request(struct ceph_osd_client *osdc, struct ceph_osd_request *new) argument 799 __lookup_request(struct ceph_osd_client *osdc, u64 tid) argument 818 __lookup_request_ge(struct ceph_osd_client *osdc, u64 tid) argument 841 struct ceph_osd_client *osdc = req->r_osdc; local 873 __kick_osd_requests(struct ceph_osd_client *osdc, struct ceph_osd *osd) argument 940 struct ceph_osd_client *osdc; local 957 create_osd(struct ceph_osd_client *osdc, int onum) argument 1007 __remove_osd(struct ceph_osd_client *osdc, struct ceph_osd *osd) argument 1019 remove_all_osds(struct ceph_osd_client *osdc) argument 1031 __move_osd_to_lru(struct ceph_osd_client *osdc, struct ceph_osd *osd) argument 1041 maybe_move_osd_to_lru(struct ceph_osd_client *osdc, struct ceph_osd *osd) argument 1058 remove_old_osds(struct ceph_osd_client *osdc) argument 1075 __reset_osd(struct ceph_osd_client *osdc, struct ceph_osd *osd) argument 1108 __insert_osd(struct ceph_osd_client *osdc, struct ceph_osd *new) argument 1130 __lookup_osd(struct ceph_osd_client *osdc, int o) argument 1147 __schedule_osd_timeout(struct ceph_osd_client *osdc) argument 1153 __cancel_osd_timeout(struct ceph_osd_client *osdc) argument 1162 __register_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument 1180 __unregister_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument 1224 __register_linger_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument 1237 __unregister_linger_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument 1262 ceph_osdc_set_request_linger(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument 1278 __req_should_be_paused(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument 1329 struct ceph_osd_client *osdc = req->r_osdc; local 1353 __map_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req, int force_resend) argument 1431 __send_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument 1464 __send_queued(struct ceph_osd_client *osdc) argument 1476 __ceph_osdc_start_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req, bool nofail) argument 1518 struct ceph_osd_client *osdc = local 1563 struct ceph_osd_client *osdc = local 1690 handle_reply(struct ceph_osd_client *osdc, struct ceph_msg *msg, struct ceph_connection *con) argument 1883 reset_changed_osds(struct ceph_osd_client *osdc) argument 1906 kick_requests(struct ceph_osd_client *osdc, bool force_resend, bool force_resend_writes) argument 1999 ceph_osdc_handle_map(struct ceph_osd_client *osdc, struct ceph_msg *msg) argument 2156 __insert_event(struct ceph_osd_client *osdc, struct ceph_osd_event *new) argument 2178 __find_event(struct ceph_osd_client *osdc, u64 cookie) argument 2200 struct ceph_osd_client *osdc = event->osdc; local 2211 ceph_osdc_create_event(struct ceph_osd_client *osdc, void (*event_cb)(u64, u64, u8, void *), void *data, struct ceph_osd_event **pevent) argument 2243 struct ceph_osd_client *osdc = event->osdc; local 2274 handle_watch_notify(struct ceph_osd_client *osdc, struct ceph_msg *msg) argument 2426 ceph_osdc_start_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req, bool nofail) argument 2451 struct ceph_osd_client *osdc = req->r_osdc; local 2466 ceph_osdc_wait_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument 2490 ceph_osdc_sync(struct ceph_osd_client *osdc) argument 2525 ceph_osdc_flush_notifies(struct ceph_osd_client *osdc) argument 2535 ceph_osdc_init(struct ceph_osd_client *osdc, struct ceph_client *client) argument 2598 ceph_osdc_stop(struct ceph_osd_client *osdc) argument 2618 ceph_osdc_readpages(struct ceph_osd_client *osdc, struct ceph_vino vino, struct ceph_file_layout *layout, u64 off, u64 *plen, u32 truncate_seq, u64 truncate_size, struct page **pages, int num_pages, int page_align) argument 2659 ceph_osdc_writepages(struct ceph_osd_client *osdc, struct ceph_vino vino, struct ceph_file_layout *layout, struct ceph_snap_context *snapc, u64 off, u64 len, u32 truncate_seq, u64 truncate_size, struct timespec *mtime, struct page **pages, int num_pages) argument 2725 struct ceph_osd_client *osdc; local 2760 struct ceph_osd_client *osdc = osd->o_osdc; local 2879 struct ceph_osd_client *osdc = o->o_osdc; local 2907 struct ceph_osd_client *osdc = o->o_osdc; local 2916 struct ceph_osd_client *osdc = o->o_osdc; local [all...] |