49 static void link_request(struct ceph_osd *osd, struct ceph_osd_request *req);
50 static void unlink_request(struct ceph_osd *osd, struct ceph_osd_request *req);
51 static void link_linger(struct ceph_osd *osd,
53 static void unlink_linger(struct ceph_osd *osd,
55 static void clear_backoffs(struct ceph_osd *osd);
77 static inline void verify_osd_locked(struct ceph_osd *osd)  in verify_osd_locked()  argument
79 	struct ceph_osd_client *osdc = osd->o_osdc;  in verify_osd_locked()
81 	WARN_ON(!(mutex_is_locked(&osd->lock) &&  in verify_osd_locked()
92 static inline void verify_osd_locked(struct ceph_osd *osd) { }  in verify_osd_locked()  argument
428 	t->osd = CEPH_HOMELESS_OSD;  in target_init()
457 	dest->osd = src->osd;  in target_copy()
1160 		struct ceph_osd *osd = rb_entry(n, struct ceph_osd, o_node);  in DEFINE_RB_FUNCS()  local
1162 		for (p = rb_first(&osd->o_requests); p; ) {  in DEFINE_RB_FUNCS()
1182 static bool osd_homeless(struct ceph_osd *osd)  in osd_homeless()  argument
1184 	return osd->o_osd == CEPH_HOMELESS_OSD;  in osd_homeless()
1187 static bool osd_registered(struct ceph_osd *osd)  in osd_registered()  argument
1189 	verify_osdc_locked(osd->o_osdc);  in osd_registered()
1191 	return !RB_EMPTY_NODE(&osd->o_node);  in osd_registered()
1197 static void osd_init(struct ceph_osd *osd)  in osd_init()  argument
1199 	refcount_set(&osd->o_ref, 1);  in osd_init()
1200 	RB_CLEAR_NODE(&osd->o_node);  in osd_init()
1201 	osd->o_requests = RB_ROOT;  in osd_init()
1202 	osd->o_linger_requests = RB_ROOT;  in osd_init()
1203 	osd->o_backoff_mappings = RB_ROOT;  in osd_init()
1204 	osd->o_backoffs_by_id = RB_ROOT;  in osd_init()
1205 	INIT_LIST_HEAD(&osd->o_osd_lru);  in osd_init()
1206 	INIT_LIST_HEAD(&osd->o_keepalive_item);  in osd_init()
1207 	osd->o_incarnation = 1;  in osd_init()
1208 	mutex_init(&osd->lock);  in osd_init()
1211 static void osd_cleanup(struct ceph_osd *osd)  in osd_cleanup()  argument
1213 	WARN_ON(!RB_EMPTY_NODE(&osd->o_node));  in osd_cleanup()
1214 	WARN_ON(!RB_EMPTY_ROOT(&osd->o_requests));  in osd_cleanup()
1215 	WARN_ON(!RB_EMPTY_ROOT(&osd->o_linger_requests));  in osd_cleanup()
1216 	WARN_ON(!RB_EMPTY_ROOT(&osd->o_backoff_mappings));  in osd_cleanup()
1217 	WARN_ON(!RB_EMPTY_ROOT(&osd->o_backoffs_by_id));  in osd_cleanup()
1218 	WARN_ON(!list_empty(&osd->o_osd_lru));  in osd_cleanup()
1219 	WARN_ON(!list_empty(&osd->o_keepalive_item));  in osd_cleanup()
1221 	if (osd->o_auth.authorizer) {  in osd_cleanup()
1222 		WARN_ON(osd_homeless(osd));  in osd_cleanup()
1223 		ceph_auth_destroy_authorizer(osd->o_auth.authorizer);  in osd_cleanup()
1232 	struct ceph_osd *osd;  in create_osd()  local
1236 	osd = kzalloc(sizeof(*osd), GFP_NOIO | __GFP_NOFAIL);  in create_osd()
1237 	osd_init(osd);  in create_osd()
1238 	osd->o_osdc = osdc;  in create_osd()
1239 	osd->o_osd = onum;  in create_osd()
1241 	ceph_con_init(&osd->o_con, osd, &osd_con_ops, &osdc->client->msgr);  in create_osd()
1243 	return osd;  in create_osd()
1246 static struct ceph_osd *get_osd(struct ceph_osd *osd)  in get_osd()  argument
1248 	if (refcount_inc_not_zero(&osd->o_ref)) {  in get_osd()
1249 		dout("get_osd %p %d -> %d\n", osd, refcount_read(&osd->o_ref)-1,  in get_osd()
1250 		     refcount_read(&osd->o_ref));  in get_osd()
1251 		return osd;  in get_osd()
1253 		dout("get_osd %p FAIL\n", osd);  in get_osd()
1258 static void put_osd(struct ceph_osd *osd)  in put_osd()  argument
1260 	dout("put_osd %p %d -> %d\n", osd, refcount_read(&osd->o_ref),  in put_osd()
1261 	     refcount_read(&osd->o_ref) - 1);  in put_osd()
1262 	if (refcount_dec_and_test(&osd->o_ref)) {  in put_osd()
1263 		osd_cleanup(osd);  in put_osd()
1264 		kfree(osd);  in put_osd()
1268 DEFINE_RB_FUNCS(osd, struct ceph_osd, o_osd, o_node)  in DEFINE_RB_FUNCS()  argument
1270 static void __move_osd_to_lru(struct ceph_osd *osd)  in DEFINE_RB_FUNCS()
1272 	struct ceph_osd_client *osdc = osd->o_osdc;  in DEFINE_RB_FUNCS()
1274 	dout("%s osd %p osd%d\n", __func__, osd, osd->o_osd);  in DEFINE_RB_FUNCS()
1275 	BUG_ON(!list_empty(&osd->o_osd_lru));  in DEFINE_RB_FUNCS()
1278 	list_add_tail(&osd->o_osd_lru, &osdc->osd_lru);  in DEFINE_RB_FUNCS()
1281 	osd->lru_ttl = jiffies + osdc->client->options->osd_idle_ttl;  in DEFINE_RB_FUNCS()
1284 static void maybe_move_osd_to_lru(struct ceph_osd *osd)  in maybe_move_osd_to_lru()  argument
1286 	if (RB_EMPTY_ROOT(&osd->o_requests) &&  in maybe_move_osd_to_lru()
1287 	    RB_EMPTY_ROOT(&osd->o_linger_requests))  in maybe_move_osd_to_lru()
1288 		__move_osd_to_lru(osd);  in maybe_move_osd_to_lru()
1291 static void __remove_osd_from_lru(struct ceph_osd *osd)  in __remove_osd_from_lru()  argument
1293 	struct ceph_osd_client *osdc = osd->o_osdc;  in __remove_osd_from_lru()
1295 	dout("%s osd %p osd%d\n", __func__, osd, osd->o_osd);  in __remove_osd_from_lru()
1298 	if (!list_empty(&osd->o_osd_lru))  in __remove_osd_from_lru()
1299 		list_del_init(&osd->o_osd_lru);  in __remove_osd_from_lru()
1307 static void close_osd(struct ceph_osd *osd)  in close_osd()  argument
1309 	struct ceph_osd_client *osdc = osd->o_osdc;  in close_osd()
1313 	dout("%s osd %p osd%d\n", __func__, osd, osd->o_osd);  in close_osd()
1315 	ceph_con_close(&osd->o_con);  in close_osd()
1317 	for (n = rb_first(&osd->o_requests); n; ) {  in close_osd()
1324 		unlink_request(osd, req);  in close_osd()
1327 	for (n = rb_first(&osd->o_linger_requests); n; ) {  in close_osd()
1335 		unlink_linger(osd, lreq);  in close_osd()
1338 	clear_backoffs(osd);  in close_osd()
1340 	__remove_osd_from_lru(osd);  in close_osd()
1341 	erase_osd(&osdc->osds, osd);  in close_osd()
1342 	put_osd(osd);  in close_osd()
1348 static int reopen_osd(struct ceph_osd *osd)  in reopen_osd()  argument
1352 	dout("%s osd %p osd%d\n", __func__, osd, osd->o_osd);  in reopen_osd()
1354 	if (RB_EMPTY_ROOT(&osd->o_requests) &&  in reopen_osd()
1355 	    RB_EMPTY_ROOT(&osd->o_linger_requests)) {  in reopen_osd()
1356 		close_osd(osd);  in reopen_osd()
1360 	peer_addr = &osd->o_osdc->osdmap->osd_addr[osd->o_osd];  in reopen_osd()
1361 	if (!memcmp(peer_addr, &osd->o_con.peer_addr, sizeof (*peer_addr)) &&  in reopen_osd()
1362 			!ceph_con_opened(&osd->o_con)) {  in reopen_osd()
1368 		for (n = rb_first(&osd->o_requests); n; n = rb_next(n)) {  in reopen_osd()
1377 	ceph_con_close(&osd->o_con);  in reopen_osd()
1378 	ceph_con_open(&osd->o_con, CEPH_ENTITY_TYPE_OSD, osd->o_osd, peer_addr);  in reopen_osd()
1379 	osd->o_incarnation++;  in reopen_osd()
1387 	struct ceph_osd *osd;  in lookup_create_osd()  local
1395 		osd = lookup_osd(&osdc->osds, o);  in lookup_create_osd()
1397 		osd = &osdc->homeless_osd;  in lookup_create_osd()
1398 	if (!osd) {  in lookup_create_osd()
1402 		osd = create_osd(osdc, o);  in lookup_create_osd()
1403 		insert_osd(&osdc->osds, osd);  in lookup_create_osd()
1404 		ceph_con_open(&osd->o_con, CEPH_ENTITY_TYPE_OSD, osd->o_osd,  in lookup_create_osd()
1405 			      &osdc->osdmap->osd_addr[osd->o_osd]);  in lookup_create_osd()
1408 	dout("%s osdc %p osd%d -> osd %p\n", __func__, osdc, o, osd);  in lookup_create_osd()
1409 	return osd;  in lookup_create_osd()
1417 static void link_request(struct ceph_osd *osd, struct ceph_osd_request *req)  in link_request()  argument
1419 	verify_osd_locked(osd);  in link_request()
1421 	dout("%s osd %p osd%d req %p tid %llu\n", __func__, osd, osd->o_osd,  in link_request()
1424 	if (!osd_homeless(osd))  in link_request()
1425 		__remove_osd_from_lru(osd);  in link_request()
1427 		atomic_inc(&osd->o_osdc->num_homeless);  in link_request()
1429 	get_osd(osd);  in link_request()
1430 	insert_request(&osd->o_requests, req);  in link_request()
1431 	req->r_osd = osd;  in link_request()
1434 static void unlink_request(struct ceph_osd *osd, struct ceph_osd_request *req)  in unlink_request()  argument
1436 	verify_osd_locked(osd);  in unlink_request()
1437 	WARN_ON(req->r_osd != osd);  in unlink_request()
1438 	dout("%s osd %p osd%d req %p tid %llu\n", __func__, osd, osd->o_osd,  in unlink_request()
1442 	erase_request(&osd->o_requests, req);  in unlink_request()
1443 	put_osd(osd);  in unlink_request()
1445 	if (!osd_homeless(osd))  in unlink_request()
1446 		maybe_move_osd_to_lru(osd);  in unlink_request()
1448 		atomic_dec(&osd->o_osdc->num_homeless);  in unlink_request()
1567 		t->osd = CEPH_HOMELESS_OSD;  in calc_target()
1592 			t->osd = CEPH_HOMELESS_OSD;  in calc_target()
1655 			t->osd = acting.osds[pos];  in calc_target()
1658 			t->osd = acting.primary;  in calc_target()
1670 	     legacy_change, force_resend, split, ct_res, t->osd);  in calc_target()
1929 static void clear_backoffs(struct ceph_osd *osd)  in DEFINE_RB_FUNCS()
1931 	while (!RB_EMPTY_ROOT(&osd->o_backoff_mappings)) {  in DEFINE_RB_FUNCS()
1933 		    rb_entry(rb_first(&osd->o_backoff_mappings),  in DEFINE_RB_FUNCS()
1942 			erase_backoff_by_id(&osd->o_backoffs_by_id, backoff);  in DEFINE_RB_FUNCS()
1945 		erase_spg_mapping(&osd->o_backoff_mappings, spg);  in DEFINE_RB_FUNCS()
1976 	struct ceph_osd *osd = req->r_osd;  in should_plug_request()  local
1981 	spg = lookup_spg_mapping(&osd->o_backoff_mappings, &req->r_t.spgid);  in should_plug_request()
1991 	     __func__, req, req->r_tid, osd->o_osd, backoff->spgid.pgid.pool,  in should_plug_request()
2275 	struct ceph_osd *osd = req->r_osd;  in send_request()  local
2277 	verify_osd_locked(osd);  in send_request()
2278 	WARN_ON(osd->o_osd != req->r_t.osd);  in send_request()
2302 	     req->r_t.spgid.shard, osd->o_osd, req->r_t.epoch, req->r_flags,  in send_request()
2309 	req->r_sent = osd->o_incarnation;  in send_request()
2311 	ceph_con_send(&osd->o_con, ceph_msg_get(req->r_request));  in send_request()
2341 	struct ceph_osd *osd;  in __submit_request()  local
2355 	osd = lookup_create_osd(osdc, req->r_t.osd, wrlocked);  in __submit_request()
2356 	if (IS_ERR(osd)) {  in __submit_request()
2357 		WARN_ON(PTR_ERR(osd) != -EAGAIN || wrlocked);  in __submit_request()
2392 	} else if (!osd_homeless(osd)) {  in __submit_request()
2398 	mutex_lock(&osd->lock);  in __submit_request()
2405 	link_request(osd, req);  in __submit_request()
2410 	mutex_unlock(&osd->lock);  in __submit_request()
2728 	WARN_ON(lreq->osd);  in linger_release()
2786 static void link_linger(struct ceph_osd *osd,  in DEFINE_RB_INSDEL_FUNCS()
2789 	verify_osd_locked(osd);  in DEFINE_RB_INSDEL_FUNCS()
2790 	WARN_ON(!lreq->linger_id || lreq->osd);  in DEFINE_RB_INSDEL_FUNCS()
2791 	dout("%s osd %p osd%d lreq %p linger_id %llu\n", __func__, osd,  in DEFINE_RB_INSDEL_FUNCS()
2792 	     osd->o_osd, lreq, lreq->linger_id);  in DEFINE_RB_INSDEL_FUNCS()
2794 	if (!osd_homeless(osd))  in DEFINE_RB_INSDEL_FUNCS()
2795 		__remove_osd_from_lru(osd);  in DEFINE_RB_INSDEL_FUNCS()
2797 		atomic_inc(&osd->o_osdc->num_homeless);  in DEFINE_RB_INSDEL_FUNCS()
2799 	get_osd(osd);  in DEFINE_RB_INSDEL_FUNCS()
2800 	insert_linger(&osd->o_linger_requests, lreq);  in DEFINE_RB_INSDEL_FUNCS()
2801 	lreq->osd = osd;  in DEFINE_RB_INSDEL_FUNCS()
2804 static void unlink_linger(struct ceph_osd *osd,  in unlink_linger()  argument
2807 	verify_osd_locked(osd);  in unlink_linger()
2808 	WARN_ON(lreq->osd != osd);  in unlink_linger()
2809 	dout("%s osd %p osd%d lreq %p linger_id %llu\n", __func__, osd,  in unlink_linger()
2810 	     osd->o_osd, lreq, lreq->linger_id);  in unlink_linger()
2812 	lreq->osd = NULL;  in unlink_linger()
2813 	erase_linger(&osd->o_linger_requests, lreq);  in unlink_linger()
2814 	put_osd(osd);  in unlink_linger()
2816 	if (!osd_homeless(osd))  in unlink_linger()
2817 		maybe_move_osd_to_lru(osd);  in unlink_linger()
2819 		atomic_dec(&osd->o_osdc->num_homeless);  in unlink_linger()
3157 	link_request(lreq->osd, req);  in send_linger_ping()
3164 	struct ceph_osd *osd;  in linger_submit()  local
3176 	osd = lookup_create_osd(osdc, lreq->t.osd, true);  in linger_submit()
3177 	link_linger(osd, lreq);  in linger_submit()
3210 	unlink_linger(lreq->osd, lreq);  in __linger_cancel()
3350 		struct ceph_osd *osd = rb_entry(n, struct ceph_osd, o_node);  in handle_timeout()  local
3353 		for (p = rb_first(&osd->o_requests); p; ) {  in handle_timeout()
3361 				     req, req->r_tid, osd->o_osd);  in handle_timeout()
3367 				       req->r_tid, osd->o_osd);  in handle_timeout()
3371 		for (p = rb_first(&osd->o_linger_requests); p; p = rb_next(p)) {  in handle_timeout()
3376 			     lreq, lreq->linger_id, osd->o_osd);  in handle_timeout()
3386 			list_move_tail(&osd->o_keepalive_item, &slow_osds);  in handle_timeout()
3408 		struct ceph_osd *osd = list_first_entry(&slow_osds,  in handle_timeout()  local
3411 		list_del_init(&osd->o_keepalive_item);  in handle_timeout()
3412 		ceph_con_keepalive(&osd->o_con);  in handle_timeout()
3426 	struct ceph_osd *osd, *nosd;  in handle_osds_timeout()  local
3430 	list_for_each_entry_safe(osd, nosd, &osdc->osd_lru, o_osd_lru) {  in handle_osds_timeout()
3431 		if (time_before(jiffies, osd->lru_ttl))  in handle_osds_timeout()
3434 		WARN_ON(!RB_EMPTY_ROOT(&osd->o_requests));  in handle_osds_timeout()
3435 		WARN_ON(!RB_EMPTY_ROOT(&osd->o_linger_requests));  in handle_osds_timeout()
3436 		close_osd(osd);  in handle_osds_timeout()
3651 static void handle_reply(struct ceph_osd *osd, struct ceph_msg *msg)  in handle_reply()  argument
3653 	struct ceph_osd_client *osdc = osd->o_osdc;  in handle_reply()
3664 	if (!osd_registered(osd)) {  in handle_reply()
3665 		dout("%s osd%d unknown\n", __func__, osd->o_osd);  in handle_reply()
3668 	WARN_ON(osd->o_osd != le64_to_cpu(msg->hdr.src.num));  in handle_reply()
3670 	mutex_lock(&osd->lock);  in handle_reply()
3671 	req = lookup_request(&osd->o_requests, tid);  in handle_reply()
3673 		dout("%s osd%d tid %llu unknown\n", __func__, osd->o_osd, tid);  in handle_reply()
3705 		unlink_request(osd, req);  in handle_reply()
3706 		mutex_unlock(&osd->lock);  in handle_reply()
3723 		unlink_request(osd, req);  in handle_reply()
3724 		mutex_unlock(&osd->lock);  in handle_reply()
3768 	mutex_unlock(&osd->lock);  in handle_reply()
3777 	mutex_unlock(&osd->lock);  in handle_reply()
3813 		struct ceph_osd *osd;  in recalc_linger_target()  local
3815 		osd = lookup_create_osd(osdc, lreq->t.osd, true);  in recalc_linger_target()
3816 		if (osd != lreq->osd) {  in recalc_linger_target()
3817 			unlink_linger(lreq->osd, lreq);  in recalc_linger_target()
3818 			link_linger(osd, lreq);  in recalc_linger_target()
3828 static void scan_requests(struct ceph_osd *osd,  in scan_requests()  argument
3835 	struct ceph_osd_client *osdc = osd->o_osdc;  in scan_requests()
3839 	for (n = rb_first(&osd->o_linger_requests); n; ) {  in scan_requests()
3875 	for (n = rb_first(&osd->o_requests); n; ) {  in scan_requests()
3897 			unlink_request(osd, req);  in scan_requests()
3960 		struct ceph_osd *osd = rb_entry(n, struct ceph_osd, o_node);  in handle_one_map()  local
3964 		scan_requests(osd, skipped_map, was_full, true, need_resend,  in handle_one_map()
3966 		if (!ceph_osd_is_up(osdc->osdmap, osd->o_osd) ||  in handle_one_map()
3967 		    memcmp(&osd->o_con.peer_addr,  in handle_one_map()
3968 			   ceph_osd_addr(osdc->osdmap, osd->o_osd),  in handle_one_map()
3970 			close_osd(osd);  in handle_one_map()
4003 		struct ceph_osd *osd;  in kick_requests()  local
4008 		osd = lookup_create_osd(osdc, req->r_t.osd, true);  in kick_requests()
4009 		link_request(osd, req);  in kick_requests()
4011 			if (!osd_homeless(osd) && !req->r_t.paused)  in kick_requests()
4019 		if (!osd_homeless(lreq->osd))  in kick_requests()
4146 static void kick_osd_requests(struct ceph_osd *osd)  in kick_osd_requests()  argument
4150 	clear_backoffs(osd);  in kick_osd_requests()
4152 	for (n = rb_first(&osd->o_requests); n; ) {  in kick_osd_requests()
4165 	for (n = rb_first(&osd->o_linger_requests); n; n = rb_next(n)) {  in kick_osd_requests()
4178 	struct ceph_osd *osd = con->private;  in osd_fault()  local
4179 	struct ceph_osd_client *osdc = osd->o_osdc;  in osd_fault()
4181 	dout("%s osd %p osd%d\n", __func__, osd, osd->o_osd);  in osd_fault()
4184 	if (!osd_registered(osd)) {  in osd_fault()
4185 		dout("%s osd%d unknown\n", __func__, osd->o_osd);  in osd_fault()
4189 	if (!reopen_osd(osd))  in osd_fault()
4190 		kick_osd_requests(osd);  in osd_fault()
4294 static void handle_backoff_block(struct ceph_osd *osd, struct MOSDBackoff *m)  in handle_backoff_block()  argument
4300 	dout("%s osd%d spgid %llu.%xs%d id %llu\n", __func__, osd->o_osd,  in handle_backoff_block()
4303 	spg = lookup_spg_mapping(&osd->o_backoff_mappings, &m->spgid);  in handle_backoff_block()
4311 		insert_spg_mapping(&osd->o_backoff_mappings, spg);  in handle_backoff_block()
4327 	insert_backoff_by_id(&osd->o_backoffs_by_id, backoff);  in handle_backoff_block()
4338 	ceph_con_send(&osd->o_con, msg);  in handle_backoff_block()
4353 static void handle_backoff_unblock(struct ceph_osd *osd,  in handle_backoff_unblock()  argument
4360 	dout("%s osd%d spgid %llu.%xs%d id %llu\n", __func__, osd->o_osd,  in handle_backoff_unblock()
4363 	backoff = lookup_backoff_by_id(&osd->o_backoffs_by_id, m->id);  in handle_backoff_unblock()
4366 		       __func__, osd->o_osd, m->spgid.pgid.pool,  in handle_backoff_unblock()
4374 		       __func__, osd->o_osd, m->spgid.pgid.pool,  in handle_backoff_unblock()
4379 	spg = lookup_spg_mapping(&osd->o_backoff_mappings, &backoff->spgid);  in handle_backoff_unblock()
4383 	erase_backoff_by_id(&osd->o_backoffs_by_id, backoff);  in handle_backoff_unblock()
4387 		erase_spg_mapping(&osd->o_backoff_mappings, spg);  in handle_backoff_unblock()
4391 	for (n = rb_first(&osd->o_requests); n; n = rb_next(n)) {  in handle_backoff_unblock()
4411 static void handle_backoff(struct ceph_osd *osd, struct ceph_msg *msg)  in handle_backoff()  argument
4413 	struct ceph_osd_client *osdc = osd->o_osdc;  in handle_backoff()
4418 	if (!osd_registered(osd)) {  in handle_backoff()
4419 		dout("%s osd%d unknown\n", __func__, osd->o_osd);  in handle_backoff()
4423 	WARN_ON(osd->o_osd != le64_to_cpu(msg->hdr.src.num));  in handle_backoff()
4425 	mutex_lock(&osd->lock);  in handle_backoff()
4435 		handle_backoff_block(osd, &m);  in handle_backoff()
4438 		handle_backoff_unblock(osd, &m);  in handle_backoff()
4441 		pr_err("%s osd%d unknown op %d\n", __func__, osd->o_osd, m.op);  in handle_backoff()
4448 	mutex_unlock(&osd->lock);  in handle_backoff()
4623 		struct ceph_osd *osd = rb_entry(n, struct ceph_osd, o_node);  in ceph_osdc_sync()  local
4625 		mutex_lock(&osd->lock);  in ceph_osdc_sync()
4626 		for (p = rb_first(&osd->o_requests); p; p = rb_next(p)) {  in ceph_osdc_sync()
4637 			mutex_unlock(&osd->lock);  in ceph_osdc_sync()
4646 		mutex_unlock(&osd->lock);  in ceph_osdc_sync()
5199 		struct ceph_osd *osd = rb_entry(n, struct ceph_osd, o_node);  in ceph_osdc_reopen_osds()  local
5202 		if (!reopen_osd(osd))  in ceph_osdc_reopen_osds()
5203 			kick_osd_requests(osd);  in ceph_osdc_reopen_osds()
5290 		struct ceph_osd *osd = rb_entry(rb_first(&osdc->osds),  in ceph_osdc_stop()  local
5292 		close_osd(osd);  in ceph_osdc_stop()
5415 	struct ceph_osd *osd = con->private;  in dispatch()  local
5416 	struct ceph_osd_client *osdc = osd->o_osdc;  in dispatch()
5424 		handle_reply(osd, msg);  in dispatch()
5427 		handle_backoff(osd, msg);  in dispatch()
5450 	struct ceph_osd *osd = con->private;  in get_reply()  local
5451 	struct ceph_osd_client *osdc = osd->o_osdc;  in get_reply()
5459 	if (!osd_registered(osd)) {  in get_reply()
5460 		dout("%s osd%d unknown, skipping\n", __func__, osd->o_osd);  in get_reply()
5464 	WARN_ON(osd->o_osd != le64_to_cpu(hdr->src.num));  in get_reply()
5466 	mutex_lock(&osd->lock);  in get_reply()
5467 	req = lookup_request(&osd->o_requests, tid);  in get_reply()
5470 		     osd->o_osd, tid);  in get_reply()
5479 			__func__, osd->o_osd, req->r_tid, front_len,  in get_reply()
5491 			__func__, osd->o_osd, req->r_tid, data_len,  in get_reply()
5502 	mutex_unlock(&osd->lock);  in get_reply()
5539 	struct ceph_osd *osd = con->private;  in alloc_msg()  local
5552 			osd->o_osd, type);  in alloc_msg()
5563 	struct ceph_osd *osd = con->private;  in get_osd_con()  local
5564 	if (get_osd(osd))  in get_osd_con()
5571 	struct ceph_osd *osd = con->private;  in put_osd_con()  local
5572 	put_osd(osd);  in put_osd_con()