Lines Matching refs:mds
682 int mds) in __ceph_lookup_mds_session() argument
684 if (mds >= mdsc->max_sessions || !mdsc->sessions[mds]) in __ceph_lookup_mds_session()
686 return ceph_get_mds_session(mdsc->sessions[mds]); in __ceph_lookup_mds_session()
689 static bool __have_session(struct ceph_mds_client *mdsc, int mds) in __have_session() argument
691 if (mds >= mdsc->max_sessions || !mdsc->sessions[mds]) in __have_session()
711 int mds) in register_session() argument
715 if (mds >= mdsc->mdsmap->possible_max_rank) in register_session()
722 if (mds >= mdsc->max_sessions) { in register_session()
723 int newmax = 1 << get_count_order(mds + 1); in register_session()
739 dout("%s: mds%d\n", __func__, mds); in register_session()
741 s->s_mds = mds; in register_session()
771 mdsc->sessions[mds] = s; in register_session()
775 ceph_con_open(&s->s_con, CEPH_ENTITY_TYPE_MDS, mds, in register_session()
776 ceph_mdsmap_get_addr(mdsc->mdsmap, mds)); in register_session()
816 int mds; in ceph_mdsc_iterate_sessions() local
819 for (mds = 0; mds < mdsc->max_sessions; ++mds) { in ceph_mdsc_iterate_sessions()
822 s = __ceph_lookup_mds_session(mdsc, mds); in ceph_mdsc_iterate_sessions()
1036 int mds = -1; in __choose_mds() local
1122 mds = frag.dist[r]; in __choose_mds()
1125 frag.frag, mds, (int)r, frag.ndist); in __choose_mds()
1126 if (ceph_mdsmap_get_state(mdsc->mdsmap, mds) >= in __choose_mds()
1128 !ceph_mdsmap_is_laggy(mdsc->mdsmap, mds)) in __choose_mds()
1135 if (frag.mds >= 0) { in __choose_mds()
1137 mds = frag.mds; in __choose_mds()
1140 frag.frag, mds); in __choose_mds()
1141 if (ceph_mdsmap_get_state(mdsc->mdsmap, mds) >= in __choose_mds()
1144 mds)) in __choose_mds()
1163 mds = cap->session->s_mds; in __choose_mds()
1165 inode, ceph_vinop(inode), mds, in __choose_mds()
1172 return mds; in __choose_mds()
1178 mds = ceph_mdsmap_get_random_mds(mdsc->mdsmap); in __choose_mds()
1179 dout("%s chose random mds%d\n", __func__, mds); in __choose_mds()
1180 return mds; in __choose_mds()
1398 int mds = session->s_mds; in __open_session() local
1401 mstate = ceph_mdsmap_get_state(mdsc->mdsmap, mds); in __open_session()
1402 dout("open_session to mds%d (%s)\n", mds, in __open_session()
1461 int i, mds = session->s_mds; in __open_export_target_sessions() local
1463 if (mds >= mdsc->mdsmap->possible_max_rank) in __open_export_target_sessions()
1466 mi = &mdsc->mdsmap->m_info[mds]; in __open_export_target_sessions()
2551 int mds, bool drop_cap_releases) in create_request_message() argument
2629 mds, req->r_inode_drop, req->r_inode_unless, in create_request_message()
2633 req->r_parent, mds, req->r_dentry_drop, in create_request_message()
2637 req->r_old_dentry_dir, mds, in create_request_message()
2643 mds, req->r_old_inode_drop, req->r_old_inode_unless, 0); in create_request_message()
2707 int mds, bool drop_cap_releases) in __prepare_send_request() argument
2716 ceph_get_cap_for_mds(ceph_inode(req->r_inode), mds); in __prepare_send_request()
2766 msg = create_request_message(mdsc, req, mds, drop_cap_releases); in __prepare_send_request()
2816 int mds = -1; in __do_request() local
2858 mds = __choose_mds(mdsc, req, &random); in __do_request()
2859 if (mds < 0 || in __do_request()
2860 ceph_mdsmap_get_state(mdsc->mdsmap, mds) < CEPH_MDS_STATE_ACTIVE) { in __do_request()
2871 session = __ceph_lookup_mds_session(mdsc, mds); in __do_request()
2873 session = register_session(mdsc, mds); in __do_request()
2881 dout("do_request mds%d session %p state %s\n", mds, session, in __do_request()
2905 req->r_resend_mds = mds; in __do_request()
2955 static void kick_requests(struct ceph_mds_client *mdsc, int mds) in kick_requests() argument
2960 dout("kick_requests mds%d\n", mds); in kick_requests()
2969 req->r_session->s_mds == mds) { in kick_requests()
3132 int mds = session->s_mds; in handle_reply() local
3164 head->safe ? "safe" : "unsafe", tid, mds); in handle_reply()
3170 tid, mds); in handle_reply()
3194 int mds = __choose_mds(mdsc, req, NULL); in handle_reply() local
3195 if (mds >= 0 && mds != req->r_session->s_mds) { in handle_reply()
3222 dout("got safe reply %llu, mds%d\n", tid, mds); in handle_reply()
3242 pr_err("mdsc_handle_reply got corrupt reply mds%d(tid:%lld)\n", mds, tid); in handle_reply()
3404 int mds = session->s_mds; in handle_session() local
3447 mds, ceph_session_op_name(op), session, in handle_session()
3522 pr_err("mdsc_handle_session bad op %d mds%d\n", op, mds); in handle_session()
3531 kick_requests(mdsc, mds); in handle_session()
3539 pr_err("mdsc_handle_session corrupt message mds%d len %d\n", mds, in handle_session()
3972 int mds = session->s_mds; in send_mds_reconnect() local
3979 pr_info("mds%d reconnect start\n", mds); in send_mds_reconnect()
4022 CEPH_ENTITY_TYPE_MDS, mds, in send_mds_reconnect()
4023 ceph_mdsmap_get_addr(mdsc->mdsmap, mds)); in send_mds_reconnect()
4132 pr_err("error %d preparing reconnect for mds%d\n", err, mds); in send_mds_reconnect()
4270 int mds = session->s_mds; in handle_lease() local
4277 dout("handle_lease from mds%d\n", mds); in handle_lease()
4862 int mds; in ceph_mdsc_force_umount() local
4867 for (mds = 0; mds < mdsc->max_sessions; mds++) { in ceph_mdsc_force_umount()
4868 session = __ceph_lookup_mds_session(mdsc, mds); in ceph_mdsc_force_umount()
4887 kick_requests(mdsc, mds); in ceph_mdsc_force_umount()