Lines Matching refs:mds

433 static struct ceph_cap *__get_cap_for_mds(struct ceph_inode_info *ci, int mds)  in __get_cap_for_mds()  argument
440 if (mds < cap->mds) in __get_cap_for_mds()
442 else if (mds > cap->mds) in __get_cap_for_mds()
450 struct ceph_cap *ceph_get_cap_for_mds(struct ceph_inode_info *ci, int mds) in ceph_get_cap_for_mds() argument
455 cap = __get_cap_for_mds(ci, mds); in ceph_get_cap_for_mds()
473 if (new->mds < cap->mds) in __insert_cap_node()
475 else if (new->mds > cap->mds) in __insert_cap_node()
639 int mds = session->s_mds; in ceph_add_cap() local
652 cap = __get_cap_for_mds(ci, mds); in ceph_add_cap()
659 cap->mds = mds; in ceph_add_cap()
764 ceph_cap_string(issued|cap->issued), seq, mds); in ceph_add_cap()
1632 int mds; in ceph_flush_snaps() local
1648 mds = ci->i_auth_cap->session->s_mds; in ceph_flush_snaps()
1649 if (session && session->s_mds != mds) { in ceph_flush_snaps()
1658 session = __ceph_lookup_mds_session(mdsc, mds); in ceph_flush_snaps()
1911 int mds = -1; /* keep track of how far we've gone through i_caps list in ceph_check_caps() local
2014 if (mds >= cap->mds || in ceph_check_caps()
2030 cap->mds, cap, ceph_cap_string(cap_used), in ceph_check_caps()
2155 mds = cap->mds; /* remember mds, so we don't repeat */ in ceph_check_caps()
2744 inode, ceph_cap_string(need), ci->i_auth_cap->mds); in try_get_cap_refs()
3717 int mds = session->s_mds; in handle_cap_trunc() local
3732 inode, mds, seq, truncate_size, truncate_seq); in handle_cap_trunc()
3758 int mds = session->s_mds; in handle_cap_export() local
3764 target = le32_to_cpu(ph->mds); in handle_cap_export()
3771 inode, ci, mds, mseq, target); in handle_cap_export()
3774 cap = __get_cap_for_mds(ci, mds); in handle_cap_export()
3793 ceph_vinop(inode), mds, cap->seq, cap->mseq, in handle_cap_export()
3841 if (mds > target) { in handle_cap_export()
3883 int mds = session->s_mds; in handle_cap_import() local
3896 peer = le32_to_cpu(ph->mds); in handle_cap_import()
3903 inode, ci, mds, mseq, peer); in handle_cap_import()
3905 cap = __get_cap_for_mds(ci, mds); in handle_cap_import()
3939 ocap->mseq, mds, le32_to_cpu(ph->seq), in handle_cap_import()
4254 int mds; in iterate_sessions() local
4257 for (mds = 0; mds < mdsc->max_sessions; ++mds) { in iterate_sessions()
4260 if (!mdsc->sessions[mds]) in iterate_sessions()
4263 s = ceph_get_mds_session(mdsc->sessions[mds]); in iterate_sessions()
4394 int mds, int drop, int unless, int force) in ceph_encode_inode_release() argument
4407 inode, mds, ceph_cap_string(used|dirty), ceph_cap_string(drop), in ceph_encode_inode_release()
4413 cap = __get_cap_for_mds(ci, mds); in ceph_encode_inode_release()
4471 int mds, int drop, int unless) in ceph_encode_dentry_release() argument
4486 if (di->lease_session && di->lease_session->s_mds == mds) in ceph_encode_dentry_release()
4494 ret = ceph_encode_inode_release(p, dir, mds, drop, unless, force); in ceph_encode_dentry_release()
4498 if (ret && di->lease_session && di->lease_session->s_mds == mds) { in ceph_encode_dentry_release()
4500 dentry, mds, (int)di->lease_seq); in ceph_encode_dentry_release()