net/ceph/osd_client.c

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