Lines Matching defs:osdc
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() local
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()
547 struct ceph_osd_client *osdc = req->r_osdc; in request_reinit() local
575 struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc, in ceph_osdc_alloc_request()
616 struct ceph_osd_client *osdc = req->r_osdc; in __ceph_osdc_alloc_messages() local
1063 struct ceph_osd_request *ceph_osdc_new_request(struct ceph_osd_client *osdc, in ceph_osdc_new_request()
1229 static struct ceph_osd *create_osd(struct ceph_osd_client *osdc, int onum) in create_osd()
1271 struct ceph_osd_client *osdc = osd->o_osdc; in DEFINE_RB_FUNCS() local
1292 struct ceph_osd_client *osdc = osd->o_osdc; in __remove_osd_from_lru() local
1308 struct ceph_osd_client *osdc = osd->o_osdc; in close_osd() local
1383 static struct ceph_osd *lookup_create_osd(struct ceph_osd_client *osdc, int o, in lookup_create_osd()
1455 static bool have_pool_full(struct ceph_osd_client *osdc) in have_pool_full()
1470 static bool pool_full(struct ceph_osd_client *osdc, s64 pool_id) in pool_full()
1485 static bool target_should_be_paused(struct ceph_osd_client *osdc, in target_should_be_paused()
1506 static enum calc_target_result calc_target(struct ceph_osd_client *osdc, in calc_target()
2254 static void maybe_request_map(struct ceph_osd_client *osdc) in maybe_request_map()
2280 struct ceph_osd_client *osdc = req->r_osdc; in __submit_request() local
2387 struct ceph_osd_client *osdc = req->r_osdc; in finish_request() local
2441 struct ceph_osd_client *osdc = req->r_osdc; in cancel_map_check() local
2485 void ceph_osdc_abort_requests(struct ceph_osd_client *osdc, int err) in ceph_osdc_abort_requests()
2495 void ceph_osdc_clear_abort_err(struct ceph_osd_client *osdc) in ceph_osdc_clear_abort_err()
2503 static void update_epoch_barrier(struct ceph_osd_client *osdc, u32 eb) in update_epoch_barrier()
2515 void ceph_osdc_update_epoch_barrier(struct ceph_osd_client *osdc, u32 eb) in ceph_osdc_update_epoch_barrier()
2537 struct ceph_osd_client *osdc = req->r_osdc; in abort_on_full_fn() local
2559 static void ceph_osdc_abort_on_full(struct ceph_osd_client *osdc) in ceph_osdc_abort_on_full()
2570 struct ceph_osd_client *osdc = req->r_osdc; in check_pool_dne() local
2604 struct ceph_osd_client *osdc = &greq->monc->client->osdc; in map_check_cb() local
2631 struct ceph_osd_client *osdc = req->r_osdc; in send_map_check() local
2689 linger_alloc(struct ceph_osd_client *osdc) in linger_alloc()
2768 struct ceph_osd_client *osdc = lreq->osdc; in linger_registered() local
2780 struct ceph_osd_client *osdc = lreq->osdc; in linger_register() local
2792 struct ceph_osd_client *osdc = lreq->osdc; in linger_unregister() local
2861 struct ceph_osd_client *osdc = lreq->osdc; in lwork_queue() local
3065 struct ceph_osd_client *osdc = lreq->osdc; in send_linger_ping() local
3102 struct ceph_osd_client *osdc = lreq->osdc; in linger_submit() local
3124 struct ceph_osd_client *osdc = lreq->osdc; in cancel_linger_map_check() local
3155 struct ceph_osd_client *osdc = lreq->osdc; in linger_cancel() local
3167 struct ceph_osd_client *osdc = lreq->osdc; in check_linger_pool_dne() local
3198 struct ceph_osd_client *osdc = &greq->monc->client->osdc; in linger_map_check_cb() local
3226 struct ceph_osd_client *osdc = lreq->osdc; in send_linger_map_check() local
3272 struct ceph_osd_client *osdc = in handle_timeout() local
3361 struct ceph_osd_client *osdc = in handle_osds_timeout() local
3595 struct ceph_osd_client *osdc = osd->o_osdc; in handle_reply() local
3702 static void set_pool_was_full(struct ceph_osd_client *osdc) in set_pool_was_full()
3714 static bool pool_cleared_full(struct ceph_osd_client *osdc, s64 pool_id) in pool_cleared_full()
3728 struct ceph_osd_client *osdc = lreq->osdc; in recalc_linger_target() local
3755 struct ceph_osd_client *osdc = osd->o_osdc; in scan_requests() local
3827 static int handle_one_map(struct ceph_osd_client *osdc, in handle_one_map()
3896 static void kick_requests(struct ceph_osd_client *osdc, in kick_requests()
3953 void ceph_osdc_handle_map(struct ceph_osd_client *osdc, struct ceph_msg *msg) in ceph_osdc_handle_map()
4099 struct ceph_osd_client *osdc = osd->o_osdc; in osd_fault() local
4333 struct ceph_osd_client *osdc = osd->o_osdc; in handle_backoff() local
4375 static void handle_watch_notify(struct ceph_osd_client *osdc, in handle_watch_notify()
4476 int ceph_osdc_start_request(struct ceph_osd_client *osdc, in ceph_osdc_start_request()
4494 struct ceph_osd_client *osdc = req->r_osdc; in ceph_osdc_cancel_request() local
4527 int ceph_osdc_wait_request(struct ceph_osd_client *osdc, in ceph_osdc_wait_request()
4537 void ceph_osdc_sync(struct ceph_osd_client *osdc) in ceph_osdc_sync()
4617 ceph_osdc_watch(struct ceph_osd_client *osdc, in ceph_osdc_watch()
4676 int ceph_osdc_unwatch(struct ceph_osd_client *osdc, in ceph_osdc_unwatch()
4741 int ceph_osdc_notify_ack(struct ceph_osd_client *osdc, in ceph_osdc_notify_ack()
4815 int ceph_osdc_notify(struct ceph_osd_client *osdc, in ceph_osdc_notify()
4893 int ceph_osdc_watch_check(struct ceph_osd_client *osdc, in ceph_osdc_watch_check()
4988 int ceph_osdc_list_watchers(struct ceph_osd_client *osdc, in ceph_osdc_list_watchers()
5040 void ceph_osdc_flush_notifies(struct ceph_osd_client *osdc) in ceph_osdc_flush_notifies()
5047 void ceph_osdc_maybe_request_map(struct ceph_osd_client *osdc) in ceph_osdc_maybe_request_map()
5061 int ceph_osdc_call(struct ceph_osd_client *osdc, in ceph_osdc_call()
5115 void ceph_osdc_reopen_osds(struct ceph_osd_client *osdc) in ceph_osdc_reopen_osds()
5133 int ceph_osdc_init(struct ceph_osd_client *osdc, struct ceph_client *client) in ceph_osdc_init()
5203 void ceph_osdc_stop(struct ceph_osd_client *osdc) in ceph_osdc_stop()
5237 int ceph_osdc_readpages(struct ceph_osd_client *osdc, in ceph_osdc_readpages()
5275 int ceph_osdc_writepages(struct ceph_osd_client *osdc, struct ceph_vino vino, in ceph_osdc_writepages()
5345 int ceph_osdc_copy_from(struct ceph_osd_client *osdc, in ceph_osdc_copy_from()
5411 struct ceph_osd_client *osdc = osd->o_osdc; in dispatch() local
5446 struct ceph_osd_client *osdc = osd->o_osdc; in get_reply() local
5587 struct ceph_osd_client *osdc = o->o_osdc; in get_authorizer() local
5615 struct ceph_osd_client *osdc = o->o_osdc; in add_authorizer_challenge() local
5625 struct ceph_osd_client *osdc = o->o_osdc; in verify_authorizer_reply() local
5634 struct ceph_osd_client *osdc = o->o_osdc; in invalidate_authorizer() local