Lines Matching refs:ceph_osd_client

69 static inline void verify_osdc_locked(struct ceph_osd_client *osdc)  in verify_osdc_locked()
73 static inline void verify_osdc_wrlocked(struct ceph_osd_client *osdc) in verify_osdc_wrlocked()
79 struct ceph_osd_client *osdc = osd->o_osdc; in verify_osd_locked()
90 static inline void verify_osdc_locked(struct ceph_osd_client *osdc) { } in verify_osdc_locked()
91 static inline void verify_osdc_wrlocked(struct ceph_osd_client *osdc) { } in verify_osdc_wrlocked()
567 struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc, in ceph_osdc_alloc_request()
608 struct ceph_osd_client *osdc = req->r_osdc; in __ceph_osdc_alloc_messages()
1078 struct ceph_osd_request *ceph_osdc_new_request(struct ceph_osd_client *osdc, in ceph_osdc_new_request()
1195 static void for_each_request(struct ceph_osd_client *osdc, in DEFINE_RB_FUNCS()
1282 static struct ceph_osd *create_osd(struct ceph_osd_client *osdc, int onum) in create_osd()
1327 struct ceph_osd_client *osdc = osd->o_osdc; in DEFINE_RB_FUNCS()
1348 struct ceph_osd_client *osdc = osd->o_osdc; in __remove_osd_from_lru()
1364 struct ceph_osd_client *osdc = osd->o_osdc; in close_osd()
1439 static struct ceph_osd *lookup_create_osd(struct ceph_osd_client *osdc, int o, in lookup_create_osd()
1515 static bool have_pool_full(struct ceph_osd_client *osdc) in have_pool_full()
1530 static bool pool_full(struct ceph_osd_client *osdc, s64 pool_id) in pool_full()
1545 static bool target_should_be_paused(struct ceph_osd_client *osdc, in target_should_be_paused()
1574 static int pick_closest_replica(struct ceph_osd_client *osdc, in pick_closest_replica()
1605 static enum calc_target_result calc_target(struct ceph_osd_client *osdc, in calc_target()
2374 static void maybe_request_map(struct ceph_osd_client *osdc) in maybe_request_map()
2400 struct ceph_osd_client *osdc = req->r_osdc; in __submit_request()
2512 struct ceph_osd_client *osdc = req->r_osdc; in finish_request()
2570 struct ceph_osd_client *osdc = req->r_osdc; in cancel_map_check()
2614 void ceph_osdc_abort_requests(struct ceph_osd_client *osdc, int err) in ceph_osdc_abort_requests()
2624 void ceph_osdc_clear_abort_err(struct ceph_osd_client *osdc) in ceph_osdc_clear_abort_err()
2632 static void update_epoch_barrier(struct ceph_osd_client *osdc, u32 eb) in update_epoch_barrier()
2644 void ceph_osdc_update_epoch_barrier(struct ceph_osd_client *osdc, u32 eb) in ceph_osdc_update_epoch_barrier()
2666 struct ceph_osd_client *osdc = req->r_osdc; in abort_on_full_fn()
2688 static void ceph_osdc_abort_on_full(struct ceph_osd_client *osdc) in ceph_osdc_abort_on_full()
2699 struct ceph_osd_client *osdc = req->r_osdc; in check_pool_dne()
2733 struct ceph_osd_client *osdc = &greq->monc->client->osdc; in map_check_cb()
2760 struct ceph_osd_client *osdc = req->r_osdc; in send_map_check()
2821 linger_alloc(struct ceph_osd_client *osdc) in linger_alloc()
2900 struct ceph_osd_client *osdc = lreq->osdc; in linger_registered()
2912 struct ceph_osd_client *osdc = lreq->osdc; in linger_register()
2924 struct ceph_osd_client *osdc = lreq->osdc; in linger_unregister()
2993 struct ceph_osd_client *osdc = lreq->osdc; in lwork_queue()
3145 struct ceph_osd_client *osdc = lreq->osdc; in send_linger()
3233 struct ceph_osd_client *osdc = lreq->osdc; in send_linger_ping()
3277 struct ceph_osd_client *osdc = lreq->osdc; in linger_submit()
3293 struct ceph_osd_client *osdc = lreq->osdc; in cancel_linger_map_check()
3324 struct ceph_osd_client *osdc = lreq->osdc; in linger_cancel()
3336 struct ceph_osd_client *osdc = lreq->osdc; in check_linger_pool_dne()
3367 struct ceph_osd_client *osdc = &greq->monc->client->osdc; in linger_map_check_cb()
3395 struct ceph_osd_client *osdc = lreq->osdc; in send_linger_map_check()
3448 struct ceph_osd_client *osdc = in handle_timeout()
3449 container_of(work, struct ceph_osd_client, timeout_work.work); in handle_timeout()
3537 struct ceph_osd_client *osdc = in handle_osds_timeout()
3538 container_of(work, struct ceph_osd_client, in handle_osds_timeout()
3768 struct ceph_osd_client *osdc = osd->o_osdc; in handle_reply()
3898 static void set_pool_was_full(struct ceph_osd_client *osdc) in set_pool_was_full()
3910 static bool pool_cleared_full(struct ceph_osd_client *osdc, s64 pool_id) in pool_cleared_full()
3924 struct ceph_osd_client *osdc = lreq->osdc; in recalc_linger_target()
3951 struct ceph_osd_client *osdc = osd->o_osdc; in scan_requests()
4023 static int handle_one_map(struct ceph_osd_client *osdc, in handle_one_map()
4094 static void kick_requests(struct ceph_osd_client *osdc, in kick_requests()
4151 void ceph_osdc_handle_map(struct ceph_osd_client *osdc, struct ceph_msg *msg) in ceph_osdc_handle_map()
4297 struct ceph_osd_client *osdc = osd->o_osdc; in osd_fault()
4531 struct ceph_osd_client *osdc = osd->o_osdc; in handle_backoff()
4573 static void handle_watch_notify(struct ceph_osd_client *osdc, in handle_watch_notify()
4672 void ceph_osdc_start_request(struct ceph_osd_client *osdc, in ceph_osdc_start_request()
4692 struct ceph_osd_client *osdc = req->r_osdc; in ceph_osdc_cancel_request()
4725 int ceph_osdc_wait_request(struct ceph_osd_client *osdc, in ceph_osdc_wait_request()
4735 void ceph_osdc_sync(struct ceph_osd_client *osdc) in ceph_osdc_sync()
4778 ceph_osdc_watch(struct ceph_osd_client *osdc, in ceph_osdc_watch()
4825 int ceph_osdc_unwatch(struct ceph_osd_client *osdc, in ceph_osdc_unwatch()
4890 int ceph_osdc_notify_ack(struct ceph_osd_client *osdc, in ceph_osdc_notify_ack()
4935 int ceph_osdc_notify(struct ceph_osd_client *osdc, in ceph_osdc_notify()
5007 int ceph_osdc_watch_check(struct ceph_osd_client *osdc, in ceph_osdc_watch_check()
5102 int ceph_osdc_list_watchers(struct ceph_osd_client *osdc, in ceph_osdc_list_watchers()
5154 void ceph_osdc_flush_notifies(struct ceph_osd_client *osdc) in ceph_osdc_flush_notifies()
5161 void ceph_osdc_maybe_request_map(struct ceph_osd_client *osdc) in ceph_osdc_maybe_request_map()
5175 int ceph_osdc_call(struct ceph_osd_client *osdc, in ceph_osdc_call()
5229 void ceph_osdc_reopen_osds(struct ceph_osd_client *osdc) in ceph_osdc_reopen_osds()
5247 int ceph_osdc_init(struct ceph_osd_client *osdc, struct ceph_client *client) in ceph_osdc_init()
5317 void ceph_osdc_stop(struct ceph_osd_client *osdc) in ceph_osdc_stop()
5410 struct ceph_osd_client *osdc = osd->o_osdc; in osd_dispatch()
5463 struct ceph_osd_client *osdc = osd->o_osdc; in get_reply()
5603 struct ceph_osd_client *osdc = o->o_osdc; in osd_get_authorizer()
5620 struct ceph_osd_client *osdc = o->o_osdc; in osd_add_authorizer_challenge()
5630 struct ceph_osd_client *osdc = o->o_osdc; in osd_verify_authorizer_reply()
5642 struct ceph_osd_client *osdc = o->o_osdc; in osd_invalidate_authorizer()