Lines Matching refs:mds
309 * Find ceph_cap for given mds, if any.
313 static struct ceph_cap *__get_cap_for_mds(struct ceph_inode_info *ci, int mds)
320 if (mds < cap->mds)
322 else if (mds > cap->mds)
330 struct ceph_cap *ceph_get_cap_for_mds(struct ceph_inode_info *ci, int mds)
335 cap = __get_cap_for_mds(ci, mds);
346 int mds = -1;
349 /* prefer mds with WR|BUFFER|EXCL caps */
352 mds = cap->mds;
358 return mds;
363 int mds;
365 mds = __ceph_get_cap_mds(ceph_inode(inode));
367 return mds;
383 if (new->mds < cap->mds)
385 else if (new->mds > cap->mds)
522 int mds = session->s_mds;
525 dout("add_cap %p mds%d cap %llx %s seq %d\n", inode,
537 cap = __get_cap_for_mds(ci, mds);
552 cap->mds = mds;
559 if (ci->i_cap_exporting_mds == mds) {
596 * If we are issued caps we don't want, or the mds' wanted
598 * later and/or update the mds wanted value.
603 dout(" issued %s, mds wanted %s, actual %s, queueing\n",
614 dout("add_cap inode %p (%llx.%llx) cap %p %s now %s seq %d mds%d\n",
616 ceph_cap_string(issued|cap->issued), seq, mds);
636 * us losing touch with the mds).
714 dout("__touch_cap %p cap %p mds%d\n", &cap->ci->vfs_inode, cap,
718 dout("__touch_cap %p cap %p mds%d NOP, iterating over caps\n",
1002 dout(" adding %llx release to mds%d msg %p (%d left)\n",
1054 * Make note of max_size reported/requested from mds, revoked caps
1210 int mds;
1242 /* pick mds, take s_mutex */
1254 mds = ci->i_auth_cap->session->s_mds;
1257 if (session && session->s_mds != mds) {
1266 session = __ceph_lookup_mds_session(mdsc, mds);
1276 * get a better @mds value next time.
1453 * versus held caps. Release, flush, ack revoked caps to mds as
1472 int mds = -1; /* keep track of how far we've gone through i_caps list
1510 * because then the mds would revoke it anyway to
1566 if (mds >= cap->mds ||
1574 dout(" mds%d revoking %s\n", cap->mds,
1607 /* want more caps from mds? */
1672 mds = cap->mds; /* remember mds, so we don't repeat */
1704 * Try to flush dirty caps back to the auth mds.
1839 * only wait on non-file metadata writeback (the mds
1854 * Flush any dirty caps back to the mds. If we aren't asked to wait,
1896 dout("kick_flushing_capsnaps mds%d\n", session->s_mds);
1910 pr_err("%p auth cap %p not mds%d ???\n", inode,
1924 dout("kick_flushing_caps mds%d\n", session->s_mds);
1946 pr_err("%p auth cap %p not mds%d ???\n", inode,
2091 * ask the mds) so we don't get hung up indefinitely.
2285 int mds = session->s_mds;
2299 dout("handle_cap_grant inode %p cap %p mds%d seq %u/%u %s\n",
2300 inode, cap, mds, seq, issue_seq, ceph_cap_string(newcaps));
2389 dout("mds wanted %s -> %s\n",
2480 dout("handle_cap_flush_ack inode %p mds%d seq %d on %s cleaned %s,"
2495 dout(" mds%d still flushing cap on %p\n",
2541 dout("handle_cap_flushsnap_ack inode %p ci %p mds%d follows %lld\n",
2583 int mds = session->s_mds;
2595 dout("handle_cap_trunc inode %p mds%d seq %d to %lld seq %d\n",
2596 inode, mds, seq, truncate_size, truncate_seq);
2606 * Handle EXPORT from MDS. Cap is being migrated _from_ this mds to a
2618 int mds = session->s_mds;
2624 dout("handle_cap_export inode %p ci %p mds%d mseq %d\n",
2625 inode, ci, mds, mseq);
2633 dout(" higher mseq on cap from mds%d\n",
2637 if (t->session->s_mds == mds)
2644 ci->i_cap_exporting_mds = mds;
2673 int mds = session->s_mds;
2683 dout("handle_cap_import inode %p ci %p mds%d mseq %d"
2684 " - cleared exporting from mds%d\n",
2685 inode, ci, mds, mseq,
2691 dout("handle_cap_import inode %p ci %p mds%d mseq %d\n",
2692 inode, ci, mds, mseq);
2720 int mds = session->s_mds;
2733 dout("handle_caps from mds%d\n", mds);
2766 dout(" mds%d seq %lld cap seq %u\n", session->s_mds, session->s_seq,
2802 cap = __get_cap_for_mds(ceph_inode(inode), mds);
2804 dout(" no cap on %p ino %llx.%llx from mds%d\n",
2805 inode, ceph_ino(inode), ceph_snap(inode), mds);
2836 * along for the mds (who clearly thinks we still have this
2885 * Flush all dirty caps to the mds
2955 * Helpers for embedding cap and dentry lease releases into mds
2963 int mds, int drop, int unless, int force)
2975 dout("encode_inode_release %p mds%d used|dirty %s drop %s unless %s\n",
2976 inode, mds, ceph_cap_string(used|dirty), ceph_cap_string(drop),
2982 cap = __get_cap_for_mds(ci, mds);
3031 int mds, int drop, int unless)
3042 * doesn't have to be perfect; the mds will revoke anything we don't
3046 if (di->lease_session && di->lease_session->s_mds == mds)
3050 ret = ceph_encode_inode_release(p, dir, mds, drop, unless, force);
3053 if (ret && di->lease_session && di->lease_session->s_mds == mds) {
3054 dout("encode_dentry_release %p mds%d seq %d\n",
3055 dentry, mds, (int)di->lease_seq);