679 						   int mds)  in __ceph_lookup_mds_session()  argument
681 	if (mds >= mdsc->max_sessions || !mdsc->sessions[mds])  in __ceph_lookup_mds_session()
683 	return ceph_get_mds_session(mdsc->sessions[mds]);  in __ceph_lookup_mds_session()
686 static bool __have_session(struct ceph_mds_client *mdsc, int mds)  in __have_session()  argument
688 	if (mds >= mdsc->max_sessions || !mdsc->sessions[mds])  in __have_session()
708 						 int mds)  in register_session()  argument
712 	if (mds >= mdsc->mdsmap->possible_max_rank)  in register_session()
719 	if (mds >= mdsc->max_sessions) {  in register_session()
720 		int newmax = 1 << get_count_order(mds + 1);  in register_session()
736 	dout("%s: mds%d\n", __func__, mds);  in register_session()
738 	s->s_mds = mds;  in register_session()
759 	mdsc->sessions[mds] = s;  in register_session()
763 	ceph_con_open(&s->s_con, CEPH_ENTITY_TYPE_MDS, mds,  in register_session()
764 		      ceph_mdsmap_get_addr(mdsc->mdsmap, mds));  in register_session()
804 	int mds;  in ceph_mdsc_iterate_sessions()  local
807 	for (mds = 0; mds < mdsc->max_sessions; ++mds) {  in ceph_mdsc_iterate_sessions()
810 		s = __ceph_lookup_mds_session(mdsc, mds);  in ceph_mdsc_iterate_sessions()
1022 	int mds = -1;  in __choose_mds()  local
1108 				mds = frag.dist[r];  in __choose_mds()
1111 				     frag.frag, mds, (int)r, frag.ndist);  in __choose_mds()
1112 				if (ceph_mdsmap_get_state(mdsc->mdsmap, mds) >=  in __choose_mds()
1114 				    !ceph_mdsmap_is_laggy(mdsc->mdsmap, mds))  in __choose_mds()
1121 			if (frag.mds >= 0) {  in __choose_mds()
1123 				mds = frag.mds;  in __choose_mds()
1126 				     frag.frag, mds);  in __choose_mds()
1127 				if (ceph_mdsmap_get_state(mdsc->mdsmap, mds) >=  in __choose_mds()
1130 								  mds))  in __choose_mds()
1149 	mds = cap->session->s_mds;  in __choose_mds()
1151 	     inode, ceph_vinop(inode), mds,  in __choose_mds()
1156 	return mds;  in __choose_mds()
1162 	mds = ceph_mdsmap_get_random_mds(mdsc->mdsmap);  in __choose_mds()
1163 	dout("%s chose random mds%d\n", __func__, mds);  in __choose_mds()
1164 	return mds;  in __choose_mds()
1379 	int mds = session->s_mds;  in __open_session()  local
1382 	mstate = ceph_mdsmap_get_state(mdsc->mdsmap, mds);  in __open_session()
1383 	dout("open_session to mds%d (%s)\n", mds,  in __open_session()
1442 	int i, mds = session->s_mds;  in __open_export_target_sessions()  local
1444 	if (mds >= mdsc->mdsmap->possible_max_rank)  in __open_export_target_sessions()
1447 	mi = &mdsc->mdsmap->m_info[mds];  in __open_export_target_sessions()
2547 	int mds = session->s_mds;  in create_request_message()  local
2644 		      mds, req->r_inode_drop, req->r_inode_unless,  in create_request_message()
2648 				req->r_parent, mds, req->r_dentry_drop,  in create_request_message()
2652 				req->r_old_dentry_dir, mds,  in create_request_message()
2658 		      mds, req->r_old_inode_drop, req->r_old_inode_unless, 0);  in create_request_message()
2731 	int mds = session->s_mds;  in __prepare_send_request()  local
2740 			ceph_get_cap_for_mds(ceph_inode(req->r_inode), mds);  in __prepare_send_request()
2836 	int mds = -1;  in __do_request()  local
2878 	mds = __choose_mds(mdsc, req, &random);  in __do_request()
2879 	if (mds < 0 ||  in __do_request()
2880 	    ceph_mdsmap_get_state(mdsc->mdsmap, mds) < CEPH_MDS_STATE_ACTIVE) {  in __do_request()
2891 	session = __ceph_lookup_mds_session(mdsc, mds);  in __do_request()
2893 		session = register_session(mdsc, mds);  in __do_request()
2901 	dout("do_request mds%d session %p state %s\n", mds, session,  in __do_request()
2935 				req->r_resend_mds = mds;  in __do_request()
2985 static void kick_requests(struct ceph_mds_client *mdsc, int mds)  in kick_requests()  argument
2990 	dout("kick_requests mds%d\n", mds);  in kick_requests()
2999 		    req->r_session->s_mds == mds) {  in kick_requests()
3161 	int mds = session->s_mds;  in handle_reply()  local
3193 			   head->safe ? "safe" : "unsafe", tid, mds);  in handle_reply()
3199 			   tid, mds);  in handle_reply()
3223 			int mds = __choose_mds(mdsc, req, NULL);  in handle_reply()  local
3224 			if (mds >= 0 && mds != req->r_session->s_mds) {  in handle_reply()
3251 			dout("got safe reply %llu, mds%d\n", tid, mds);  in handle_reply()
3288 		pr_err("mdsc_handle_reply got corrupt reply mds%d(tid:%lld)\n", mds, tid);  in handle_reply()
3450 	int mds = session->s_mds;  in handle_session()  local
3493 	     mds, ceph_session_op_name(op), session,  in handle_session()
3566 		pr_err("mdsc_handle_session bad op %d mds%d\n", op, mds);  in handle_session()
3575 			kick_requests(mdsc, mds);  in handle_session()
3583 	pr_err("mdsc_handle_session corrupt message mds%d len %d\n", mds,  in handle_session()
4017 	int mds = session->s_mds;  in send_mds_reconnect()  local
4024 	pr_info("mds%d reconnect start\n", mds);  in send_mds_reconnect()
4065 		      CEPH_ENTITY_TYPE_MDS, mds,  in send_mds_reconnect()
4066 		      ceph_mdsmap_get_addr(mdsc->mdsmap, mds));  in send_mds_reconnect()
4175 	pr_err("error %d preparing reconnect for mds%d\n", err, mds);  in send_mds_reconnect()
4367 	int mds = session->s_mds;  in handle_lease()  local
4374 	dout("handle_lease from mds%d\n", mds);  in handle_lease()
4945 	int mds;  in ceph_mdsc_force_umount()  local
4950 	for (mds = 0; mds < mdsc->max_sessions; mds++) {  in ceph_mdsc_force_umount()
4951 		session = __ceph_lookup_mds_session(mdsc, mds);  in ceph_mdsc_force_umount()
4970 		kick_requests(mdsc, mds);  in ceph_mdsc_force_umount()