H A D | osd_client.c | 69 static inline void verify_osdc_locked(struct ceph_osd_client *osdc) argument 73 static inline void verify_osdc_wrlocked(struct ceph_osd_client *osdc) argument 79 struct ceph_osd_client *osdc = osd->o_osdc; local 90 static inline void verify_osdc_locked(struct ceph_osd_client *osdc) { } argument 91 static inline void verify_osdc_wrlocked(struct ceph_osd_client *osdc) { } argument 567 struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc, argument 608 struct ceph_osd_client *osdc = req->r_osdc; local 1078 ceph_osdc_new_request(struct ceph_osd_client *osdc, struct ceph_file_layout *layout, struct ceph_vino vino, u64 off, u64 *plen, unsigned int which, int num_ops, int opcode, int flags, struct ceph_snap_context *snapc, u32 truncate_seq, u64 truncate_size, bool use_mempool) argument 1195 for_each_request(struct ceph_osd_client *osdc, int (*fn)(struct ceph_osd_request *req, void *arg), void *arg) argument 1282 create_osd(struct ceph_osd_client *osdc, int onum) argument 1327 struct ceph_osd_client *osdc = osd->o_osdc; local 1348 struct ceph_osd_client *osdc = osd->o_osdc; local 1364 struct ceph_osd_client *osdc = osd->o_osdc; local 1439 lookup_create_osd(struct ceph_osd_client *osdc, int o, bool wrlocked) argument 1515 have_pool_full(struct ceph_osd_client *osdc) argument 1530 pool_full(struct ceph_osd_client *osdc, s64 pool_id) argument 1545 target_should_be_paused(struct ceph_osd_client *osdc, const struct ceph_osd_request_target *t, struct ceph_pg_pool_info *pi) argument 1574 pick_closest_replica(struct ceph_osd_client *osdc, const struct ceph_osds *acting) argument 1605 calc_target(struct ceph_osd_client *osdc, struct ceph_osd_request_target *t, bool any_change) argument 2374 maybe_request_map(struct ceph_osd_client *osdc) argument 2400 struct ceph_osd_client *osdc = req->r_osdc; local 2512 struct ceph_osd_client *osdc = req->r_osdc; local 2570 struct ceph_osd_client *osdc = req->r_osdc; local 2614 ceph_osdc_abort_requests(struct ceph_osd_client *osdc, int err) argument 2624 ceph_osdc_clear_abort_err(struct ceph_osd_client *osdc) argument 2632 update_epoch_barrier(struct ceph_osd_client *osdc, u32 eb) argument 2644 ceph_osdc_update_epoch_barrier(struct ceph_osd_client *osdc, u32 eb) argument 2666 struct ceph_osd_client *osdc = req->r_osdc; local 2688 ceph_osdc_abort_on_full(struct ceph_osd_client *osdc) argument 2699 struct ceph_osd_client *osdc = req->r_osdc; local 2733 struct ceph_osd_client *osdc = &greq->monc->client->osdc; local 2760 struct ceph_osd_client *osdc = req->r_osdc; local 2821 linger_alloc(struct ceph_osd_client *osdc) argument 2900 struct ceph_osd_client *osdc = lreq->osdc; local 2912 struct ceph_osd_client *osdc = lreq->osdc; local 2924 struct ceph_osd_client *osdc = lreq->osdc; local 2993 struct ceph_osd_client *osdc = lreq->osdc; local 3145 struct ceph_osd_client *osdc = lreq->osdc; local 3233 struct ceph_osd_client *osdc = lreq->osdc; local 3277 struct ceph_osd_client *osdc = lreq->osdc; local 3293 struct ceph_osd_client *osdc = lreq->osdc; local 3324 struct ceph_osd_client *osdc = lreq->osdc; local 3336 struct ceph_osd_client *osdc = lreq->osdc; local 3367 struct ceph_osd_client *osdc = &greq->monc->client->osdc; local 3395 struct ceph_osd_client *osdc = lreq->osdc; local 3448 struct ceph_osd_client *osdc = local 3537 struct ceph_osd_client *osdc = local 3768 struct ceph_osd_client *osdc = osd->o_osdc; local 3898 set_pool_was_full(struct ceph_osd_client *osdc) argument 3910 pool_cleared_full(struct ceph_osd_client *osdc, s64 pool_id) argument 3924 struct ceph_osd_client *osdc = lreq->osdc; local 3951 struct ceph_osd_client *osdc = osd->o_osdc; local 4023 handle_one_map(struct ceph_osd_client *osdc, void *p, void *end, bool incremental, struct rb_root *need_resend, struct list_head *need_resend_linger) argument 4094 kick_requests(struct ceph_osd_client *osdc, struct rb_root *need_resend, struct list_head *need_resend_linger) argument 4151 ceph_osdc_handle_map(struct ceph_osd_client *osdc, struct ceph_msg *msg) argument 4297 struct ceph_osd_client *osdc = osd->o_osdc; local 4531 struct ceph_osd_client *osdc = osd->o_osdc; local 4573 handle_watch_notify(struct ceph_osd_client *osdc, struct ceph_msg *msg) argument 4672 ceph_osdc_start_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument 4692 struct ceph_osd_client *osdc = req->r_osdc; local 4725 ceph_osdc_wait_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req) argument 4735 ceph_osdc_sync(struct ceph_osd_client *osdc) argument 4778 ceph_osdc_watch(struct ceph_osd_client *osdc, struct ceph_object_id *oid, struct ceph_object_locator *oloc, rados_watchcb2_t wcb, rados_watcherrcb_t errcb, void *data) argument 4825 ceph_osdc_unwatch(struct ceph_osd_client *osdc, struct ceph_osd_linger_request *lreq) argument 4890 ceph_osdc_notify_ack(struct ceph_osd_client *osdc, struct ceph_object_id *oid, struct ceph_object_locator *oloc, u64 notify_id, u64 cookie, void *payload, u32 payload_len) argument 4935 ceph_osdc_notify(struct ceph_osd_client *osdc, struct ceph_object_id *oid, struct ceph_object_locator *oloc, void *payload, u32 payload_len, u32 timeout, struct page ***preply_pages, size_t *preply_len) argument 5007 ceph_osdc_watch_check(struct ceph_osd_client *osdc, struct ceph_osd_linger_request *lreq) argument 5102 ceph_osdc_list_watchers(struct ceph_osd_client *osdc, struct ceph_object_id *oid, struct ceph_object_locator *oloc, struct ceph_watch_item **watchers, u32 *num_watchers) argument 5154 ceph_osdc_flush_notifies(struct ceph_osd_client *osdc) argument 5161 ceph_osdc_maybe_request_map(struct ceph_osd_client *osdc) argument 5175 ceph_osdc_call(struct ceph_osd_client *osdc, struct ceph_object_id *oid, struct ceph_object_locator *oloc, const char *class, const char *method, unsigned int flags, struct page *req_page, size_t req_len, struct page **resp_pages, size_t *resp_len) argument 5229 ceph_osdc_reopen_osds(struct ceph_osd_client *osdc) argument 5247 ceph_osdc_init(struct ceph_osd_client *osdc, struct ceph_client *client) argument 5317 ceph_osdc_stop(struct ceph_osd_client *osdc) argument 5410 struct ceph_osd_client *osdc = osd->o_osdc; local 5463 struct ceph_osd_client *osdc = osd->o_osdc; local 5603 struct ceph_osd_client *osdc = o->o_osdc; local 5620 struct ceph_osd_client *osdc = o->o_osdc; local 5630 struct ceph_osd_client *osdc = o->o_osdc; local 5642 struct ceph_osd_client *osdc = o->o_osdc; local [all...] |