fs/ceph/caps.c

436  * Find ceph_cap for given mds, if any.
440 struct ceph_cap *__get_cap_for_mds(struct ceph_inode_info *ci, int mds)
447 		if (mds < cap->mds)
449 		else if (mds > cap->mds)
457 struct ceph_cap *ceph_get_cap_for_mds(struct ceph_inode_info *ci, int mds)
462 	cap = __get_cap_for_mds(ci, mds);
480 		if (new->mds < cap->mds)
482 		else if (new->mds > cap->mds)
659 	int mds = session->s_mds;
665 	doutc(cl, "%p %llx.%llx mds%d cap %llx %s seq %d\n", inode,
671 	cap = __get_cap_for_mds(ci, mds);
678 		cap->mds = mds;
701 		 * auth mds of the inode changed. we received the cap export
738 	 * If we are issued caps we don't want, or the mds' wanted
740 	 * later and/or update the mds wanted value.
745 		doutc(cl, "issued %s, mds wanted %s, actual %s, queueing\n",
764 	doutc(cl, "inode %p %llx.%llx cap %p %s now %s seq %d mds%d\n",
766 	      ceph_cap_string(issued|cap->issued), seq, mds);
784  * us losing touch with the mds).
875 		doutc(cl, "%p %llx.%llx cap %p mds%d\n", inode,
879 		doutc(cl, "%p %llx.%llx cap %p mds%d NOP, iterating over caps\n",
1341 	/* pool namespace (version 8) (mds always ignores this) */
1400  * Make note of max_size reported/requested from mds, revoked caps
1689 			doutc(cl, "%p %llx.%llx auth cap %p not mds%d, stop\n",
1737 	int mds;
1753 	mds = ci->i_auth_cap->session->s_mds;
1754 	if (session && session->s_mds != mds) {
1762 		session = __ceph_lookup_mds_session(mdsc, mds);
1999 	/* mds will adjust max size according to the reported size */
2013  * versus held caps.  Release, flush, ack revoked caps to mds as
2029 	int mds = -1;   /* keep track of how far we've gone through i_caps list
2091 			 * because then the mds would revoke it anyway to
2140 		if (mds >= cap->mds ||
2153 		doutc(cl, " mds%d cap %p used %s issued %s implemented %s revoking %s\n",
2154 		      cap->mds, cap, ceph_cap_string(cap_used),
2210 		/* want more caps from mds? */
2254 		mds = cap->mds;  /* remember mds, so we don't repeat */
2284  * Try to flush dirty caps back to the auth mds.
2507 	 * only wait on non-file metadata writeback (the mds
2529  * Flush any dirty caps back to the mds.  If we aren't asked to wait,
2599 			pr_err_client(cl, "%p auth cap %p not mds%d ???\n",
2656 	doutc(cl, "mds%d\n", session->s_mds);
2668 			pr_err_client(cl, "%p %llx.%llx auth cap %p not mds%d ???\n",
2710 	doutc(cl, "mds%d\n", session->s_mds);
2722 			pr_err_client(cl, "%p %llx.%llx auth cap %p not mds%d ???\n",
2930 			doutc(cl, "%p %llx.%llx need %s but mds%d readonly\n",
2932 			      ci->i_auth_cap->mds);
3042  * ask the mds) so we don't get hung up indefinitely.
3516 	doutc(cl, "%p %llx.%llx cap %p mds%d seq %d %s\n", inode,
3546 	 * auth mds of the inode changed. we received the cap export message,
3573 			pr_warn_once("inode type changed! (ino %llx.%llx is 0%o, mds says 0%o)\n",
3682 		 * If mds is importing cap, prior cap messages that update
3683 		 * 'wanted' may get dropped by mds (migrate seq mismatch).
3686 		 * want are already issued. If mds revokes caps, cap message
3687 		 * that releases caps also tells mds what we want. But if
3688 		 * caps got revoked by mds forcedly (session stale). We may
3689 		 * haven't told mds what we want.
3849 	doutc(cl, "%p %llx.%llx mds%d seq %d on %s cleaned %s, flushing %s -> %s\n",
3873 				doutc(cl, " mds%d still flushing cap on %p %llx.%llx\n",
3974 	doutc(cl, "%p %llx.%llx ci %p mds%d follows %lld\n", inode,
4021 	int mds = session->s_mds;
4043 	doutc(cl, "%p %llx.%llx mds%d seq %d to %lld truncate seq %d\n",
4044 	      inode, ceph_vinop(inode), mds, seq, truncate_size, truncate_seq);
4051  * Handle EXPORT from MDS.  Cap is being migrated _from_ this mds to a
4071 	int mds = session->s_mds;
4077 		target = le32_to_cpu(ph->mds);
4083 	doutc(cl, "%p %llx.%llx ci %p mds%d mseq %d target %d\n",
4084 	      inode, ceph_vinop(inode), ci, mds, mseq, target);
4088 	cap = __get_cap_for_mds(ci, mds);
4105 					  "%p %llx.%llx mds%d seq %d mseq %d"
4107 					  inode, ceph_vinop(inode), mds,
4118 			doutc(cl, " updating import cap %p mds%d\n", tcap,
4158 		if (mds > target) {
4202 	int mds = session->s_mds;
4215 		peer = le32_to_cpu(ph->mds);
4221 	doutc(cl, "%p %llx.%llx ci %p mds%d mseq %d peer %d\n",
4222 	      inode, ceph_vinop(inode), ci, mds, mseq, peer);
4224 	cap = __get_cap_for_mds(ci, mds);
4248 		doutc(cl, " remove export cap %p mds%d flags %d\n",
4254 					"%p %llx.%llx mds%d seq %d mseq %d"
4255 					" importer mds%d has peer seq %d mseq %d\n",
4257 					ocap->seq, ocap->mseq, mds,
4343 	doutc(cl, "from mds%d\n", session->s_mds);
4449 	doutc(cl, " mds%d seq %lld cap seq %u\n", session->s_mds,
4508 		doutc(cl, " no cap on %p ino %llx.%llx from mds%d\n",
4571 	 * along for the mds (who clearly thinks we still have this
4653  * Flush all dirty caps to the mds
4806  * Helpers for embedding cap and dentry lease releases into mds
4814 			      int mds, int drop, int unless, int force)
4827 	doutc(cl, "%p %llx.%llx mds%d used|dirty %s drop %s unless %s\n",
4828 	      inode, ceph_vinop(inode), mds, ceph_cap_string(used|dirty),
4834 	cap = __get_cap_for_mds(ci, mds);
4897  * @mds: mds that we're speaking to
4906 			       int mds, int drop, int unless)
4920 	 * doesn't have to be perfect; the mds will revoke anything we don't
4924 	if (di->lease_session && di->lease_session->s_mds == mds)
4928 	ret = ceph_encode_inode_release(p, dir, mds, drop, unless, force);
4932 	if (ret && di->lease_session && di->lease_session->s_mds == mds) {
4933 		doutc(cl, "%p mds%d seq %d\n",  dentry, mds,