Lines Matching refs:mds

314 static struct ceph_cap *__get_cap_for_mds(struct ceph_inode_info *ci, int mds)  in __get_cap_for_mds()  argument
321 if (mds < cap->mds) in __get_cap_for_mds()
323 else if (mds > cap->mds) in __get_cap_for_mds()
331 struct ceph_cap *ceph_get_cap_for_mds(struct ceph_inode_info *ci, int mds) in ceph_get_cap_for_mds() argument
336 cap = __get_cap_for_mds(ci, mds); in ceph_get_cap_for_mds()
347 int mds = -1; in __ceph_get_cap_mds() local
353 mds = cap->mds; in __ceph_get_cap_mds()
359 return mds; in __ceph_get_cap_mds()
365 int mds; in ceph_get_cap_mds() local
367 mds = __ceph_get_cap_mds(ceph_inode(inode)); in ceph_get_cap_mds()
369 return mds; in ceph_get_cap_mds()
385 if (new->mds < cap->mds) in __insert_cap_node()
387 else if (new->mds > cap->mds) in __insert_cap_node()
522 int mds = session->s_mds; in ceph_add_cap() local
537 cap = __get_cap_for_mds(ci, mds); in ceph_add_cap()
552 cap->mds = mds; in ceph_add_cap()
559 if (ci->i_cap_exporting_mds == mds) { in ceph_add_cap()
617 ceph_cap_string(issued|cap->issued), seq, mds); in ceph_add_cap()
1211 int mds; in __ceph_flush_snaps() local
1255 mds = ci->i_auth_cap->session->s_mds; in __ceph_flush_snaps()
1258 if (session && session->s_mds != mds) { in __ceph_flush_snaps()
1267 session = __ceph_lookup_mds_session(mdsc, mds); in __ceph_flush_snaps()
1464 int mds = -1; /* keep track of how far we've gone through i_caps list in ceph_check_caps() local
1558 if (mds >= cap->mds || in ceph_check_caps()
1566 cap->mds, cap, ceph_cap_string(cap->issued), in ceph_check_caps()
1667 mds = cap->mds; /* remember mds, so we don't repeat */ in ceph_check_caps()
2311 int mds = session->s_mds; in handle_cap_grant() local
2325 inode, cap, mds, seq, ceph_cap_string(newcaps)); in handle_cap_grant()
2607 int mds = session->s_mds; in handle_cap_trunc() local
2620 inode, mds, seq, truncate_size, truncate_seq); in handle_cap_trunc()
2643 int mds = session->s_mds; in handle_cap_export() local
2650 inode, ci, mds, mseq); in handle_cap_export()
2662 if (t->session->s_mds == mds) in handle_cap_export()
2669 ci->i_cap_exporting_mds = mds; in handle_cap_export()
2711 int mds = session->s_mds; in handle_cap_import() local
2723 inode, ci, mds, mseq, in handle_cap_import()
2737 inode, ci, mds, mseq); in handle_cap_import()
2772 int mds = session->s_mds; in ceph_handle_caps() local
2785 dout("handle_caps from mds%d\n", mds); in ceph_handle_caps()
2852 cap = __get_cap_for_mds(ceph_inode(inode), mds); in ceph_handle_caps()
2855 inode, ceph_ino(inode), ceph_snap(inode), mds); in ceph_handle_caps()
2991 int mds, int drop, int unless, int force) in ceph_encode_inode_release() argument
3004 inode, mds, ceph_cap_string(used|dirty), ceph_cap_string(drop), in ceph_encode_inode_release()
3010 cap = __get_cap_for_mds(ci, mds); in ceph_encode_inode_release()
3059 int mds, int drop, int unless) in ceph_encode_dentry_release() argument
3074 if (di->lease_session && di->lease_session->s_mds == mds) in ceph_encode_dentry_release()
3078 ret = ceph_encode_inode_release(p, dir, mds, drop, unless, force); in ceph_encode_dentry_release()
3081 if (ret && di->lease_session && di->lease_session->s_mds == mds) { in ceph_encode_dentry_release()
3083 dentry, mds, (int)di->lease_seq); in ceph_encode_dentry_release()