[linux-2.6-block.git] / fs / ceph / export.c

// SPDX-License-Identifier: GPL-2.0
#include <linux/ceph/ceph_debug.h>

#include <linux/exportfs.h>
#include <linux/slab.h>
#include <asm/unaligned.h>

#include "super.h"
#include "mds_client.h"
#include "crypto.h"

/*
 * Basic fh
 */
struct ceph_nfs_fh {
	u64 ino;
} __attribute__ ((packed));

/*
 * Larger fh that includes parent ino.
 */
struct ceph_nfs_confh {
	u64 ino, parent_ino;
} __attribute__ ((packed));

/*
 * fh for snapped inode
 */
struct ceph_nfs_snapfh {
	u64 ino;
	u64 snapid;
	u64 parent_ino;
	u32 hash;
} __attribute__ ((packed));

static int ceph_encode_snapfh(struct inode *inode, u32 *rawfh, int *max_len,
			      struct inode *parent_inode)
{
	struct ceph_client *cl = ceph_inode_to_client(inode);
	static const int snap_handle_length =
		sizeof(struct ceph_nfs_snapfh) >> 2;
	struct ceph_nfs_snapfh *sfh = (void *)rawfh;
	u64 snapid = ceph_snap(inode);
	int ret;
	bool no_parent = true;

	if (*max_len < snap_handle_length) {
		*max_len = snap_handle_length;
		ret = FILEID_INVALID;
		goto out;
	}

	ret =  -EINVAL;
	if (snapid != CEPH_SNAPDIR) {
		struct inode *dir;
		struct dentry *dentry = d_find_alias(inode);
		if (!dentry)
			goto out;

		rcu_read_lock();
		dir = d_inode_rcu(dentry->d_parent);
		if (ceph_snap(dir) != CEPH_SNAPDIR) {
			sfh->parent_ino = ceph_ino(dir);
			sfh->hash = ceph_dentry_hash(dir, dentry);
			no_parent = false;
		}
		rcu_read_unlock();
		dput(dentry);
	}

	if (no_parent) {
		if (!S_ISDIR(inode->i_mode))
			goto out;
		sfh->parent_ino = sfh->ino;
		sfh->hash = 0;
	}
	sfh->ino = ceph_ino(inode);
	sfh->snapid = snapid;

	*max_len = snap_handle_length;
	ret = FILEID_BTRFS_WITH_PARENT;
out:
	doutc(cl, "%p %llx.%llx ret=%d\n", inode, ceph_vinop(inode), ret);
	return ret;
}

static int ceph_encode_fh(struct inode *inode, u32 *rawfh, int *max_len,
			  struct inode *parent_inode)
{
	struct ceph_client *cl = ceph_inode_to_client(inode);
	static const int handle_length =
		sizeof(struct ceph_nfs_fh) >> 2;
	static const int connected_handle_length =
		sizeof(struct ceph_nfs_confh) >> 2;
	int type;

	if (ceph_snap(inode) != CEPH_NOSNAP)
		return ceph_encode_snapfh(inode, rawfh, max_len, parent_inode);

	if (parent_inode && (*max_len < connected_handle_length)) {
		*max_len = connected_handle_length;
		return FILEID_INVALID;
	} else if (*max_len < handle_length) {
		*max_len = handle_length;
		return FILEID_INVALID;
	}

	if (parent_inode) {
		struct ceph_nfs_confh *cfh = (void *)rawfh;
		doutc(cl, "%p %llx.%llx with parent %p %llx.%llx\n", inode,
		      ceph_vinop(inode), parent_inode, ceph_vinop(parent_inode));
		cfh->ino = ceph_ino(inode);
		cfh->parent_ino = ceph_ino(parent_inode);
		*max_len = connected_handle_length;
		type = FILEID_INO32_GEN_PARENT;
	} else {
		struct ceph_nfs_fh *fh = (void *)rawfh;
		doutc(cl, "%p %llx.%llx\n", inode, ceph_vinop(inode));
		fh->ino = ceph_ino(inode);
		*max_len = handle_length;
		type = FILEID_INO32_GEN;
	}
	return type;
}

static struct inode *__lookup_inode(struct super_block *sb, u64 ino)
{
	struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(sb)->mdsc;
	struct inode *inode;
	struct ceph_vino vino;
	int err;

	vino.ino = ino;
	vino.snap = CEPH_NOSNAP;

	if (ceph_vino_is_reserved(vino))
		return ERR_PTR(-ESTALE);

	inode = ceph_find_inode(sb, vino);
	if (!inode) {
		struct ceph_mds_request *req;
		int mask;

		req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_LOOKUPINO,
					       USE_ANY_MDS);
		if (IS_ERR(req))
			return ERR_CAST(req);

		mask = CEPH_STAT_CAP_INODE;
		if (ceph_security_xattr_wanted(d_inode(sb->s_root)))
			mask |= CEPH_CAP_XATTR_SHARED;
		req->r_args.lookupino.mask = cpu_to_le32(mask);

		req->r_ino1 = vino;
		req->r_num_caps = 1;
		err = ceph_mdsc_do_request(mdsc, NULL, req);
		inode = req->r_target_inode;
		if (inode)
			ihold(inode);
		ceph_mdsc_put_request(req);
		if (!inode)
			return err < 0 ? ERR_PTR(err) : ERR_PTR(-ESTALE);
	} else {
		if (ceph_inode_is_shutdown(inode)) {
			iput(inode);
			return ERR_PTR(-ESTALE);
		}
	}
	return inode;
}

struct inode *ceph_lookup_inode(struct super_block *sb, u64 ino)
{
	struct inode *inode = __lookup_inode(sb, ino);
	if (IS_ERR(inode))
		return inode;
	if (inode->i_nlink == 0) {
		iput(inode);
		return ERR_PTR(-ESTALE);
	}
	return inode;
}

static struct dentry *__fh_to_dentry(struct super_block *sb, u64 ino)
{
	struct inode *inode = __lookup_inode(sb, ino);
	struct ceph_inode_info *ci = ceph_inode(inode);
	int err;

	if (IS_ERR(inode))
		return ERR_CAST(inode);
	/* We need LINK caps to reliably check i_nlink */
	err = ceph_do_getattr(inode, CEPH_CAP_LINK_SHARED, false);
	if (err) {
		iput(inode);
		return ERR_PTR(err);
	}
	/* -ESTALE if inode as been unlinked and no file is open */
	if ((inode->i_nlink == 0) && !__ceph_is_file_opened(ci)) {
		iput(inode);
		return ERR_PTR(-ESTALE);
	}
	return d_obtain_alias(inode);
}

static struct dentry *__snapfh_to_dentry(struct super_block *sb,
					  struct ceph_nfs_snapfh *sfh,
					  bool want_parent)
{
	struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(sb)->mdsc;
	struct ceph_client *cl = mdsc->fsc->client;
	struct ceph_mds_request *req;
	struct inode *inode;
	struct ceph_vino vino;
	int mask;
	int err;
	bool unlinked = false;

	if (want_parent) {
		vino.ino = sfh->parent_ino;
		if (sfh->snapid == CEPH_SNAPDIR)
			vino.snap = CEPH_NOSNAP;
		else if (sfh->ino == sfh->parent_ino)
			vino.snap = CEPH_SNAPDIR;
		else
			vino.snap = sfh->snapid;
	} else {
		vino.ino = sfh->ino;
		vino.snap = sfh->snapid;
	}

	if (ceph_vino_is_reserved(vino))
		return ERR_PTR(-ESTALE);

	inode = ceph_find_inode(sb, vino);
	if (inode) {
		if (ceph_inode_is_shutdown(inode)) {
			iput(inode);
			return ERR_PTR(-ESTALE);
		}
		return d_obtain_alias(inode);
	}

	req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_LOOKUPINO,
				       USE_ANY_MDS);
	if (IS_ERR(req))
		return ERR_CAST(req);

	mask = CEPH_STAT_CAP_INODE;
	if (ceph_security_xattr_wanted(d_inode(sb->s_root)))
		mask |= CEPH_CAP_XATTR_SHARED;
	req->r_args.lookupino.mask = cpu_to_le32(mask);
	if (vino.snap < CEPH_NOSNAP) {
		req->r_args.lookupino.snapid = cpu_to_le64(vino.snap);
		if (!want_parent && sfh->ino != sfh->parent_ino) {
			req->r_args.lookupino.parent =
					cpu_to_le64(sfh->parent_ino);
			req->r_args.lookupino.hash =
					cpu_to_le32(sfh->hash);
		}
	}

	req->r_ino1 = vino;
	req->r_num_caps = 1;
	err = ceph_mdsc_do_request(mdsc, NULL, req);
	inode = req->r_target_inode;
	if (inode) {
		if (vino.snap == CEPH_SNAPDIR) {
			if (inode->i_nlink == 0)
				unlinked = true;
			inode = ceph_get_snapdir(inode);
		} else if (ceph_snap(inode) == vino.snap) {
			ihold(inode);
		} else {
			/* mds does not support lookup snapped inode */
			inode = ERR_PTR(-EOPNOTSUPP);
		}
	} else {
		inode = ERR_PTR(-ESTALE);
	}
	ceph_mdsc_put_request(req);

	if (want_parent) {
		doutc(cl, "%llx.%llx\n err=%d\n", vino.ino, vino.snap, err);
	} else {
		doutc(cl, "%llx.%llx parent %llx hash %x err=%d", vino.ino,
		      vino.snap, sfh->parent_ino, sfh->hash, err);
	}
	/* see comments in ceph_get_parent() */
	return unlinked ? d_obtain_root(inode) : d_obtain_alias(inode);
}

/*
 * convert regular fh to dentry
 */
static struct dentry *ceph_fh_to_dentry(struct super_block *sb,
					struct fid *fid,
					int fh_len, int fh_type)
{
	struct ceph_fs_client *fsc = ceph_sb_to_fs_client(sb);
	struct ceph_nfs_fh *fh = (void *)fid->raw;

	if (fh_type == FILEID_BTRFS_WITH_PARENT) {
		struct ceph_nfs_snapfh *sfh = (void *)fid->raw;
		return __snapfh_to_dentry(sb, sfh, false);
	}

	if (fh_type != FILEID_INO32_GEN  &&
	    fh_type != FILEID_INO32_GEN_PARENT)
		return NULL;
	if (fh_len < sizeof(*fh) / 4)
		return NULL;

	doutc(fsc->client, "%llx\n", fh->ino);
	return __fh_to_dentry(sb, fh->ino);
}

static struct dentry *__get_parent(struct super_block *sb,
				   struct dentry *child, u64 ino)
{
	struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(sb)->mdsc;
	struct ceph_mds_request *req;
	struct inode *inode;
	int mask;
	int err;

	req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_LOOKUPPARENT,
				       USE_ANY_MDS);
	if (IS_ERR(req))
		return ERR_CAST(req);

	if (child) {
		req->r_inode = d_inode(child);
		ihold(d_inode(child));
	} else {
		req->r_ino1 = (struct ceph_vino) {
			.ino = ino,
			.snap = CEPH_NOSNAP,
		};
	}

	mask = CEPH_STAT_CAP_INODE;
	if (ceph_security_xattr_wanted(d_inode(sb->s_root)))
		mask |= CEPH_CAP_XATTR_SHARED;
	req->r_args.getattr.mask = cpu_to_le32(mask);

	req->r_num_caps = 1;
	err = ceph_mdsc_do_request(mdsc, NULL, req);
	if (err) {
		ceph_mdsc_put_request(req);
		return ERR_PTR(err);
	}

	inode = req->r_target_inode;
	if (inode)
		ihold(inode);
	ceph_mdsc_put_request(req);
	if (!inode)
		return ERR_PTR(-ENOENT);

	return d_obtain_alias(inode);
}

static struct dentry *ceph_get_parent(struct dentry *child)
{
	struct inode *inode = d_inode(child);
	struct ceph_client *cl = ceph_inode_to_client(inode);
	struct dentry *dn;

	if (ceph_snap(inode) != CEPH_NOSNAP) {
		struct inode* dir;
		bool unlinked = false;
		/* do not support non-directory */
		if (!d_is_dir(child)) {
			dn = ERR_PTR(-EINVAL);
			goto out;
		}
		dir = __lookup_inode(inode->i_sb, ceph_ino(inode));
		if (IS_ERR(dir)) {
			dn = ERR_CAST(dir);
			goto out;
		}
		/* There can be multiple paths to access snapped inode.
		 * For simplicity, treat snapdir of head inode as parent */
		if (ceph_snap(inode) != CEPH_SNAPDIR) {
			struct inode *snapdir = ceph_get_snapdir(dir);
			if (dir->i_nlink == 0)
				unlinked = true;
			iput(dir);
			if (IS_ERR(snapdir)) {
				dn = ERR_CAST(snapdir);
				goto out;
			}
			dir = snapdir;
		}
		/* If directory has already been deleted, futher get_parent
		 * will fail. Do not mark snapdir dentry as disconnected,
		 * this prevent exportfs from doing futher get_parent. */
		if (unlinked)
			dn = d_obtain_root(dir);
		else
			dn = d_obtain_alias(dir);
	} else {
		dn = __get_parent(child->d_sb, child, 0);
	}
out:
	doutc(cl, "child %p %p %llx.%llx err=%ld\n", child, inode,
	      ceph_vinop(inode), (long)PTR_ERR_OR_ZERO(dn));
	return dn;
}

/*
 * convert regular fh to parent
 */
static struct dentry *ceph_fh_to_parent(struct super_block *sb,
					struct fid *fid,
					int fh_len, int fh_type)
{
	struct ceph_fs_client *fsc = ceph_sb_to_fs_client(sb);
	struct ceph_nfs_confh *cfh = (void *)fid->raw;
	struct dentry *dentry;

	if (fh_type == FILEID_BTRFS_WITH_PARENT) {
		struct ceph_nfs_snapfh *sfh = (void *)fid->raw;
		return __snapfh_to_dentry(sb, sfh, true);
	}

	if (fh_type != FILEID_INO32_GEN_PARENT)
		return NULL;
	if (fh_len < sizeof(*cfh) / 4)
		return NULL;

	doutc(fsc->client, "%llx\n", cfh->parent_ino);
	dentry = __get_parent(sb, NULL, cfh->ino);
	if (unlikely(dentry == ERR_PTR(-ENOENT)))
		dentry = __fh_to_dentry(sb, cfh->parent_ino);
	return dentry;
}

static int __get_snap_name(struct dentry *parent, char *name,
			   struct dentry *child)
{
	struct inode *inode = d_inode(child);
	struct inode *dir = d_inode(parent);
	struct ceph_fs_client *fsc = ceph_inode_to_fs_client(inode);
	struct ceph_mds_request *req = NULL;
	char *last_name = NULL;
	unsigned next_offset = 2;
	int err = -EINVAL;

	if (ceph_ino(inode) != ceph_ino(dir))
		goto out;
	if (ceph_snap(inode) == CEPH_SNAPDIR) {
		if (ceph_snap(dir) == CEPH_NOSNAP) {
			strcpy(name, fsc->mount_options->snapdir_name);
			err = 0;
		}
		goto out;
	}
	if (ceph_snap(dir) != CEPH_SNAPDIR)
		goto out;

	while (1) {
		struct ceph_mds_reply_info_parsed *rinfo;
		struct ceph_mds_reply_dir_entry *rde;
		int i;

		req = ceph_mdsc_create_request(fsc->mdsc, CEPH_MDS_OP_LSSNAP,
					       USE_AUTH_MDS);
		if (IS_ERR(req)) {
			err = PTR_ERR(req);
			req = NULL;
			goto out;
		}
		err = ceph_alloc_readdir_reply_buffer(req, inode);
		if (err)
			goto out;

		req->r_direct_mode = USE_AUTH_MDS;
		req->r_readdir_offset = next_offset;
		req->r_args.readdir.flags =
				cpu_to_le16(CEPH_READDIR_REPLY_BITFLAGS);
		if (last_name) {
			req->r_path2 = last_name;
			last_name = NULL;
		}

		req->r_inode = dir;
		ihold(dir);
		req->r_dentry = dget(parent);

		inode_lock(dir);
		err = ceph_mdsc_do_request(fsc->mdsc, NULL, req);
		inode_unlock(dir);

		if (err < 0)
			goto out;

		rinfo = &req->r_reply_info;
		for (i = 0; i < rinfo->dir_nr; i++) {
			rde = rinfo->dir_entries + i;
			BUG_ON(!rde->inode.in);
			if (ceph_snap(inode) ==
			    le64_to_cpu(rde->inode.in->snapid)) {
				memcpy(name, rde->name, rde->name_len);
				name[rde->name_len] = '\0';
				err = 0;
				goto out;
			}
		}

		if (rinfo->dir_end)
			break;

		BUG_ON(rinfo->dir_nr <= 0);
		rde = rinfo->dir_entries + (rinfo->dir_nr - 1);
		next_offset += rinfo->dir_nr;
		last_name = kstrndup(rde->name, rde->name_len, GFP_KERNEL);
		if (!last_name) {
			err = -ENOMEM;
			goto out;
		}

		ceph_mdsc_put_request(req);
		req = NULL;
	}
	err = -ENOENT;
out:
	if (req)
		ceph_mdsc_put_request(req);
	kfree(last_name);
	doutc(fsc->client, "child dentry %p %p %llx.%llx err=%d\n", child,
	      inode, ceph_vinop(inode), err);
	return err;
}

static int ceph_get_name(struct dentry *parent, char *name,
			 struct dentry *child)
{
	struct ceph_mds_client *mdsc;
	struct ceph_mds_request *req;
	struct inode *dir = d_inode(parent);
	struct inode *inode = d_inode(child);
	struct ceph_mds_reply_info_parsed *rinfo;
	int err;

	if (ceph_snap(inode) != CEPH_NOSNAP)
		return __get_snap_name(parent, name, child);

	mdsc = ceph_inode_to_fs_client(inode)->mdsc;
	req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_LOOKUPNAME,
				       USE_ANY_MDS);
	if (IS_ERR(req))
		return PTR_ERR(req);

	inode_lock(dir);
	req->r_inode = inode;
	ihold(inode);
	req->r_ino2 = ceph_vino(d_inode(parent));
	req->r_parent = dir;
	ihold(dir);
	set_bit(CEPH_MDS_R_PARENT_LOCKED, &req->r_req_flags);
	req->r_num_caps = 2;
	err = ceph_mdsc_do_request(mdsc, NULL, req);
	inode_unlock(dir);

	if (err)
		goto out;

	rinfo = &req->r_reply_info;
	if (!IS_ENCRYPTED(dir)) {
		memcpy(name, rinfo->dname, rinfo->dname_len);
		name[rinfo->dname_len] = 0;
	} else {
		struct fscrypt_str oname = FSTR_INIT(NULL, 0);
		struct ceph_fname fname = { .dir	= dir,
					    .name	= rinfo->dname,
					    .ctext	= rinfo->altname,
					    .name_len	= rinfo->dname_len,
					    .ctext_len	= rinfo->altname_len };

		err = ceph_fname_alloc_buffer(dir, &oname);
		if (err < 0)
			goto out;

		err = ceph_fname_to_usr(&fname, NULL, &oname, NULL);
		if (!err) {
			memcpy(name, oname.name, oname.len);
			name[oname.len] = 0;
		}
		ceph_fname_free_buffer(dir, &oname);
	}
out:
	doutc(mdsc->fsc->client, "child dentry %p %p %llx.%llx err %d %s%s\n",
	      child, inode, ceph_vinop(inode), err, err ? "" : "name ",
	      err ? "" : name);
	ceph_mdsc_put_request(req);
	return err;
}

const struct export_operations ceph_export_ops = {
	.encode_fh = ceph_encode_fh,
	.fh_to_dentry = ceph_fh_to_dentry,
	.fh_to_parent = ceph_fh_to_parent,
	.get_parent = ceph_get_parent,
	.get_name = ceph_get_name,
};
Commit	Line	Data
b2441318	1	// SPDX-License-Identifier: GPL-2.0
3d14c5d2	2	#include <linux/ceph/ceph_debug.h>
a8e63b7d SW	3
a8e63b7d SW	4	#include <linux/exportfs.h>
5a0e3ad6	5	#include <linux/slab.h>
a8e63b7d SW	6	#include <asm/unaligned.h>
	7
	8	#include "super.h"
3d14c5d2	9	#include "mds_client.h"
85529096	10	#include "crypto.h"
a8e63b7d	11
a8e63b7d SW	12	/*
	13	* Basic fh
	14	*/
	15	struct ceph_nfs_fh {
	16	u64 ino;
	17	} __attribute__ ((packed));
	18
	19	/*
4f32b42d	20	* Larger fh that includes parent ino.
a8e63b7d SW	21	*/
	22	struct ceph_nfs_confh {
	23	u64 ino, parent_ino;
a8e63b7d SW	24	} __attribute__ ((packed));
a8e63b7d SW	25
570df4e9 YZ	26	/*
	27	* fh for snapped inode
	28	*/
	29	struct ceph_nfs_snapfh {
	30	u64 ino;
	31	u64 snapid;
	32	u64 parent_ino;
	33	u32 hash;
	34	} __attribute__ ((packed));
	35
	36	static int ceph_encode_snapfh(struct inode inode, u32 rawfh, int *max_len,
	37	struct inode *parent_inode)
	38	{
38d46409	39	struct ceph_client *cl = ceph_inode_to_client(inode);
536cc331	40	static const int snap_handle_length =
570df4e9 YZ	41	sizeof(struct ceph_nfs_snapfh) >> 2;
	42	struct ceph_nfs_snapfh sfh = (void )rawfh;
	43	u64 snapid = ceph_snap(inode);
	44	int ret;
	45	bool no_parent = true;
	46
	47	if (*max_len < snap_handle_length) {
	48	*max_len = snap_handle_length;
	49	ret = FILEID_INVALID;
	50	goto out;
	51	}
	52
	53	ret = -EINVAL;
	54	if (snapid != CEPH_SNAPDIR) {
	55	struct inode *dir;
	56	struct dentry *dentry = d_find_alias(inode);
	57	if (!dentry)
	58	goto out;
	59
	60	rcu_read_lock();
	61	dir = d_inode_rcu(dentry->d_parent);
	62	if (ceph_snap(dir) != CEPH_SNAPDIR) {
	63	sfh->parent_ino = ceph_ino(dir);
	64	sfh->hash = ceph_dentry_hash(dir, dentry);
	65	no_parent = false;
	66	}
	67	rcu_read_unlock();
	68	dput(dentry);
	69	}
	70
	71	if (no_parent) {
	72	if (!S_ISDIR(inode->i_mode))
	73	goto out;
	74	sfh->parent_ino = sfh->ino;
	75	sfh->hash = 0;
	76	}
	77	sfh->ino = ceph_ino(inode);
	78	sfh->snapid = snapid;
	79
	80	*max_len = snap_handle_length;
	81	ret = FILEID_BTRFS_WITH_PARENT;
	82	out:
38d46409	83	doutc(cl, "%p %llx.%llx ret=%d\n", inode, ceph_vinop(inode), ret);
570df4e9 YZ	84	return ret;
	85	}
	86
c862868b SW	87	static int ceph_encode_fh(struct inode inode, u32 rawfh, int *max_len,
c862868b SW	88	struct inode *parent_inode)
a8e63b7d	89	{
38d46409	90	struct ceph_client *cl = ceph_inode_to_client(inode);
536cc331	91	static const int handle_length =
570df4e9	92	sizeof(struct ceph_nfs_fh) >> 2;
536cc331	93	static const int connected_handle_length =
570df4e9	94	sizeof(struct ceph_nfs_confh) >> 2;
92923dcb	95	int type;
a8e63b7d	96
a8e63b7d	97	if (ceph_snap(inode) != CEPH_NOSNAP)
570df4e9	98	return ceph_encode_snapfh(inode, rawfh, max_len, parent_inode);
a8e63b7d	99
4f32b42d YZ	100	if (parent_inode && (*max_len < connected_handle_length)) {
	101	*max_len = connected_handle_length;
	102	return FILEID_INVALID;
	103	} else if (*max_len < handle_length) {
	104	*max_len = handle_length;
	105	return FILEID_INVALID;
	106	}
f6af75da	107
4f32b42d	108	if (parent_inode) {
570df4e9	109	struct ceph_nfs_confh cfh = (void )rawfh;
38d46409 XL	110	doutc(cl, "%p %llx.%llx with parent %p %llx.%llx\n", inode,
38d46409 XL	111	ceph_vinop(inode), parent_inode, ceph_vinop(parent_inode));
c862868b	112	cfh->ino = ceph_ino(inode);
4f32b42d	113	cfh->parent_ino = ceph_ino(parent_inode);
92923dcb	114	*max_len = connected_handle_length;
4f32b42d	115	type = FILEID_INO32_GEN_PARENT;
a8e63b7d	116	} else {
570df4e9	117	struct ceph_nfs_fh fh = (void )rawfh;
38d46409	118	doutc(cl, "%p %llx.%llx\n", inode, ceph_vinop(inode));
4f32b42d	119	fh->ino = ceph_ino(inode);
bba0cd0e	120	*max_len = handle_length;
4f32b42d	121	type = FILEID_INO32_GEN;
a8e63b7d SW	122	}
	123	return type;
	124	}
	125
570df4e9	126	static struct inode __lookup_inode(struct super_block sb, u64 ino)
a8e63b7d	127	{
5995d90d	128	struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(sb)->mdsc;
a8e63b7d	129	struct inode *inode;
a8e63b7d SW	130	struct ceph_vino vino;
	131	int err;
	132
4f32b42d	133	vino.ino = ino;
a8e63b7d	134	vino.snap = CEPH_NOSNAP;
d4f6b31d JL	135
	136	if (ceph_vino_is_reserved(vino))
	137	return ERR_PTR(-ESTALE);
	138
a8e63b7d	139	inode = ceph_find_inode(sb, vino);
3c454cf2 SW	140	if (!inode) {
3c454cf2 SW	141	struct ceph_mds_request *req;
315f2408	142	int mask;
3c454cf2 SW	143
	144	req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_LOOKUPINO,
	145	USE_ANY_MDS);
	146	if (IS_ERR(req))
	147	return ERR_CAST(req);
	148
315f2408 YZ	149	mask = CEPH_STAT_CAP_INODE;
	150	if (ceph_security_xattr_wanted(d_inode(sb->s_root)))
	151	mask \|= CEPH_CAP_XATTR_SHARED;
570df4e9	152	req->r_args.lookupino.mask = cpu_to_le32(mask);
315f2408	153
3c454cf2 SW	154	req->r_ino1 = vino;
	155	req->r_num_caps = 1;
	156	err = ceph_mdsc_do_request(mdsc, NULL, req);
45e3d3ee SW	157	inode = req->r_target_inode;
45e3d3ee SW	158	if (inode)
70b666c3	159	ihold(inode);
3c454cf2	160	ceph_mdsc_put_request(req);
3c454cf2	161	if (!inode)
3886274a	162	return err < 0 ? ERR_PTR(err) : ERR_PTR(-ESTALE);
5d6451b1 JL	163	} else {
	164	if (ceph_inode_is_shutdown(inode)) {
	165	iput(inode);
	166	return ERR_PTR(-ESTALE);
	167	}
3c454cf2	168	}
570df4e9 YZ	169	return inode;
570df4e9 YZ	170	}
a8e63b7d	171
570df4e9 YZ	172	struct inode ceph_lookup_inode(struct super_block sb, u64 ino)
	173	{
	174	struct inode *inode = __lookup_inode(sb, ino);
	175	if (IS_ERR(inode))
	176	return inode;
	177	if (inode->i_nlink == 0) {
	178	iput(inode);
	179	return ERR_PTR(-ESTALE);
	180	}
3886274a LH	181	return inode;
	182	}
	183
	184	static struct dentry __fh_to_dentry(struct super_block sb, u64 ino)
	185	{
570df4e9	186	struct inode *inode = __lookup_inode(sb, ino);
bd04b919	187	struct ceph_inode_info *ci = ceph_inode(inode);
878dabb6 LH	188	int err;
878dabb6 LH	189
3886274a LH	190	if (IS_ERR(inode))
3886274a LH	191	return ERR_CAST(inode);
878dabb6 LH	192	/* We need LINK caps to reliably check i_nlink */
878dabb6 LH	193	err = ceph_do_getattr(inode, CEPH_CAP_LINK_SHARED, false);
1775c7dd JL	194	if (err) {
1775c7dd JL	195	iput(inode);
878dabb6	196	return ERR_PTR(err);
1775c7dd	197	}
878dabb6	198	/* -ESTALE if inode as been unlinked and no file is open */
bd04b919	199	if ((inode->i_nlink == 0) && !__ceph_is_file_opened(ci)) {
570df4e9 YZ	200	iput(inode);
	201	return ERR_PTR(-ESTALE);
	202	}
ad5cb123	203	return d_obtain_alias(inode);
a8e63b7d SW	204	}
a8e63b7d SW	205
570df4e9 YZ	206	static struct dentry __snapfh_to_dentry(struct super_block sb,
	207	struct ceph_nfs_snapfh *sfh,
	208	bool want_parent)
	209	{
5995d90d	210	struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(sb)->mdsc;
38d46409	211	struct ceph_client *cl = mdsc->fsc->client;
570df4e9 YZ	212	struct ceph_mds_request *req;
	213	struct inode *inode;
	214	struct ceph_vino vino;
	215	int mask;
	216	int err;
	217	bool unlinked = false;
	218
	219	if (want_parent) {
	220	vino.ino = sfh->parent_ino;
	221	if (sfh->snapid == CEPH_SNAPDIR)
	222	vino.snap = CEPH_NOSNAP;
	223	else if (sfh->ino == sfh->parent_ino)
	224	vino.snap = CEPH_SNAPDIR;
	225	else
	226	vino.snap = sfh->snapid;
	227	} else {
	228	vino.ino = sfh->ino;
	229	vino.snap = sfh->snapid;
	230	}
d4f6b31d JL	231
	232	if (ceph_vino_is_reserved(vino))
	233	return ERR_PTR(-ESTALE);
	234
570df4e9	235	inode = ceph_find_inode(sb, vino);
5d6451b1 JL	236	if (inode) {
	237	if (ceph_inode_is_shutdown(inode)) {
	238	iput(inode);
	239	return ERR_PTR(-ESTALE);
	240	}
570df4e9	241	return d_obtain_alias(inode);
5d6451b1	242	}
570df4e9 YZ	243
	244	req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_LOOKUPINO,
	245	USE_ANY_MDS);
	246	if (IS_ERR(req))
	247	return ERR_CAST(req);
	248
	249	mask = CEPH_STAT_CAP_INODE;
	250	if (ceph_security_xattr_wanted(d_inode(sb->s_root)))
	251	mask \|= CEPH_CAP_XATTR_SHARED;
	252	req->r_args.lookupino.mask = cpu_to_le32(mask);
	253	if (vino.snap < CEPH_NOSNAP) {
	254	req->r_args.lookupino.snapid = cpu_to_le64(vino.snap);
	255	if (!want_parent && sfh->ino != sfh->parent_ino) {
	256	req->r_args.lookupino.parent =
	257	cpu_to_le64(sfh->parent_ino);
	258	req->r_args.lookupino.hash =
	259	cpu_to_le32(sfh->hash);
	260	}
	261	}
	262
	263	req->r_ino1 = vino;
	264	req->r_num_caps = 1;
	265	err = ceph_mdsc_do_request(mdsc, NULL, req);
	266	inode = req->r_target_inode;
	267	if (inode) {
	268	if (vino.snap == CEPH_SNAPDIR) {
	269	if (inode->i_nlink == 0)
	270	unlinked = true;
	271	inode = ceph_get_snapdir(inode);
	272	} else if (ceph_snap(inode) == vino.snap) {
	273	ihold(inode);
	274	} else {
	275	/* mds does not support lookup snapped inode */
3e10a15f	276	inode = ERR_PTR(-EOPNOTSUPP);
570df4e9	277	}
3e10a15f JL	278	} else {
3e10a15f JL	279	inode = ERR_PTR(-ESTALE);
570df4e9 YZ	280	}
	281	ceph_mdsc_put_request(req);
	282
	283	if (want_parent) {
38d46409	284	doutc(cl, "%llx.%llx\n err=%d\n", vino.ino, vino.snap, err);
570df4e9	285	} else {
38d46409 XL	286	doutc(cl, "%llx.%llx parent %llx hash %x err=%d", vino.ino,
38d46409 XL	287	vino.snap, sfh->parent_ino, sfh->hash, err);
570df4e9	288	}
570df4e9 YZ	289	/* see comments in ceph_get_parent() */
	290	return unlinked ? d_obtain_root(inode) : d_obtain_alias(inode);
	291	}
	292
a8e63b7d	293	/*
4f32b42d	294	* convert regular fh to dentry
a8e63b7d	295	*/
4f32b42d YZ	296	static struct dentry ceph_fh_to_dentry(struct super_block sb,
	297	struct fid *fid,
	298	int fh_len, int fh_type)
a8e63b7d	299	{
38d46409	300	struct ceph_fs_client *fsc = ceph_sb_to_fs_client(sb);
4f32b42d	301	struct ceph_nfs_fh fh = (void )fid->raw;
a8e63b7d	302
570df4e9 YZ	303	if (fh_type == FILEID_BTRFS_WITH_PARENT) {
	304	struct ceph_nfs_snapfh sfh = (void )fid->raw;
	305	return __snapfh_to_dentry(sb, sfh, false);
	306	}
	307
4f32b42d YZ	308	if (fh_type != FILEID_INO32_GEN &&
	309	fh_type != FILEID_INO32_GEN_PARENT)
	310	return NULL;
	311	if (fh_len < sizeof(*fh) / 4)
	312	return NULL;
a8e63b7d	313
38d46409	314	doutc(fsc->client, "%llx\n", fh->ino);
4f32b42d	315	return __fh_to_dentry(sb, fh->ino);
a8e63b7d SW	316	}
a8e63b7d SW	317
9017c2ec YZ	318	static struct dentry __get_parent(struct super_block sb,
	319	struct dentry *child, u64 ino)
	320	{
5995d90d	321	struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(sb)->mdsc;
9017c2ec YZ	322	struct ceph_mds_request *req;
9017c2ec YZ	323	struct inode *inode;
315f2408	324	int mask;
9017c2ec YZ	325	int err;
	326
	327	req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_LOOKUPPARENT,
	328	USE_ANY_MDS);
	329	if (IS_ERR(req))
	330	return ERR_CAST(req);
	331
	332	if (child) {
2b0143b5 DH	333	req->r_inode = d_inode(child);
2b0143b5 DH	334	ihold(d_inode(child));
9017c2ec YZ	335	} else {
	336	req->r_ino1 = (struct ceph_vino) {
	337	.ino = ino,
	338	.snap = CEPH_NOSNAP,
	339	};
	340	}
315f2408 YZ	341
	342	mask = CEPH_STAT_CAP_INODE;
	343	if (ceph_security_xattr_wanted(d_inode(sb->s_root)))
	344	mask \|= CEPH_CAP_XATTR_SHARED;
	345	req->r_args.getattr.mask = cpu_to_le32(mask);
	346
9017c2ec YZ	347	req->r_num_caps = 1;
9017c2ec YZ	348	err = ceph_mdsc_do_request(mdsc, NULL, req);
c6d50296 QH	349	if (err) {
	350	ceph_mdsc_put_request(req);
	351	return ERR_PTR(err);
	352	}
	353
9017c2ec YZ	354	inode = req->r_target_inode;
	355	if (inode)
	356	ihold(inode);
	357	ceph_mdsc_put_request(req);
	358	if (!inode)
	359	return ERR_PTR(-ENOENT);
	360
ad5cb123	361	return d_obtain_alias(inode);
9017c2ec YZ	362	}
9017c2ec YZ	363
e84be11c	364	static struct dentry ceph_get_parent(struct dentry child)
9017c2ec	365	{
570df4e9	366	struct inode *inode = d_inode(child);
38d46409	367	struct ceph_client *cl = ceph_inode_to_client(inode);
570df4e9 YZ	368	struct dentry *dn;
	369
	370	if (ceph_snap(inode) != CEPH_NOSNAP) {
	371	struct inode* dir;
	372	bool unlinked = false;
	373	/* do not support non-directory */
	374	if (!d_is_dir(child)) {
	375	dn = ERR_PTR(-EINVAL);
	376	goto out;
	377	}
	378	dir = __lookup_inode(inode->i_sb, ceph_ino(inode));
	379	if (IS_ERR(dir)) {
	380	dn = ERR_CAST(dir);
	381	goto out;
	382	}
	383	/* There can be multiple paths to access snapped inode.
	384	* For simplicity, treat snapdir of head inode as parent */
	385	if (ceph_snap(inode) != CEPH_SNAPDIR) {
	386	struct inode *snapdir = ceph_get_snapdir(dir);
	387	if (dir->i_nlink == 0)
	388	unlinked = true;
	389	iput(dir);
	390	if (IS_ERR(snapdir)) {
	391	dn = ERR_CAST(snapdir);
	392	goto out;
	393	}
	394	dir = snapdir;
	395	}
	396	/* If directory has already been deleted, futher get_parent
	397	* will fail. Do not mark snapdir dentry as disconnected,
	398	* this prevent exportfs from doing futher get_parent. */
	399	if (unlinked)
	400	dn = d_obtain_root(dir);
	401	else
	402	dn = d_obtain_alias(dir);
	403	} else {
	404	dn = __get_parent(child->d_sb, child, 0);
	405	}
	406	out:
38d46409 XL	407	doutc(cl, "child %p %p %llx.%llx err=%ld\n", child, inode,
38d46409 XL	408	ceph_vinop(inode), (long)PTR_ERR_OR_ZERO(dn));
570df4e9	409	return dn;
9017c2ec YZ	410	}
9017c2ec YZ	411
a8e63b7d	412	/*
8996f4f2	413	* convert regular fh to parent
a8e63b7d SW	414	*/
a8e63b7d SW	415	static struct dentry ceph_fh_to_parent(struct super_block sb,
8996f4f2	416	struct fid *fid,
a8e63b7d SW	417	int fh_len, int fh_type)
a8e63b7d SW	418	{
38d46409	419	struct ceph_fs_client *fsc = ceph_sb_to_fs_client(sb);
a8e63b7d	420	struct ceph_nfs_confh cfh = (void )fid->raw;
a8e63b7d	421	struct dentry *dentry;
a8e63b7d	422
570df4e9 YZ	423	if (fh_type == FILEID_BTRFS_WITH_PARENT) {
	424	struct ceph_nfs_snapfh sfh = (void )fid->raw;
	425	return __snapfh_to_dentry(sb, sfh, true);
	426	}
	427
8996f4f2 YZ	428	if (fh_type != FILEID_INO32_GEN_PARENT)
8996f4f2 YZ	429	return NULL;
35c2a7f4	430	if (fh_len < sizeof(*cfh) / 4)
8996f4f2	431	return NULL;
a8e63b7d	432
38d46409	433	doutc(fsc->client, "%llx\n", cfh->parent_ino);
8996f4f2	434	dentry = __get_parent(sb, NULL, cfh->ino);
b42b90d1	435	if (unlikely(dentry == ERR_PTR(-ENOENT)))
8996f4f2	436	dentry = __fh_to_dentry(sb, cfh->parent_ino);
a8e63b7d SW	437	return dentry;
	438	}
	439
570df4e9 YZ	440	static int __get_snap_name(struct dentry parent, char name,
	441	struct dentry *child)
	442	{
	443	struct inode *inode = d_inode(child);
	444	struct inode *dir = d_inode(parent);
5995d90d	445	struct ceph_fs_client *fsc = ceph_inode_to_fs_client(inode);
570df4e9 YZ	446	struct ceph_mds_request *req = NULL;
	447	char *last_name = NULL;
	448	unsigned next_offset = 2;
	449	int err = -EINVAL;
	450
	451	if (ceph_ino(inode) != ceph_ino(dir))
	452	goto out;
	453	if (ceph_snap(inode) == CEPH_SNAPDIR) {
	454	if (ceph_snap(dir) == CEPH_NOSNAP) {
	455	strcpy(name, fsc->mount_options->snapdir_name);
	456	err = 0;
	457	}
	458	goto out;
	459	}
	460	if (ceph_snap(dir) != CEPH_SNAPDIR)
	461	goto out;
	462
	463	while (1) {
	464	struct ceph_mds_reply_info_parsed *rinfo;
	465	struct ceph_mds_reply_dir_entry *rde;
	466	int i;
	467
	468	req = ceph_mdsc_create_request(fsc->mdsc, CEPH_MDS_OP_LSSNAP,
	469	USE_AUTH_MDS);
	470	if (IS_ERR(req)) {
	471	err = PTR_ERR(req);
	472	req = NULL;
	473	goto out;
	474	}
	475	err = ceph_alloc_readdir_reply_buffer(req, inode);
	476	if (err)
	477	goto out;
	478
	479	req->r_direct_mode = USE_AUTH_MDS;
	480	req->r_readdir_offset = next_offset;
	481	req->r_args.readdir.flags =
	482	cpu_to_le16(CEPH_READDIR_REPLY_BITFLAGS);
	483	if (last_name) {
	484	req->r_path2 = last_name;
	485	last_name = NULL;
	486	}
	487
	488	req->r_inode = dir;
	489	ihold(dir);
	490	req->r_dentry = dget(parent);
	491
	492	inode_lock(dir);
	493	err = ceph_mdsc_do_request(fsc->mdsc, NULL, req);
	494	inode_unlock(dir);
	495
	496	if (err < 0)
	497	goto out;
	498
0ed26f36 ID	499	rinfo = &req->r_reply_info;
	500	for (i = 0; i < rinfo->dir_nr; i++) {
	501	rde = rinfo->dir_entries + i;
	502	BUG_ON(!rde->inode.in);
	503	if (ceph_snap(inode) ==
	504	le64_to_cpu(rde->inode.in->snapid)) {
	505	memcpy(name, rde->name, rde->name_len);
	506	name[rde->name_len] = '\0';
	507	err = 0;
	508	goto out;
	509	}
	510	}
	511
	512	if (rinfo->dir_end)
	513	break;
	514
	515	BUG_ON(rinfo->dir_nr <= 0);
	516	rde = rinfo->dir_entries + (rinfo->dir_nr - 1);
	517	next_offset += rinfo->dir_nr;
	518	last_name = kstrndup(rde->name, rde->name_len, GFP_KERNEL);
	519	if (!last_name) {
	520	err = -ENOMEM;
	521	goto out;
	522	}
	523
	524	ceph_mdsc_put_request(req);
	525	req = NULL;
570df4e9 YZ	526	}
	527	err = -ENOENT;
	528	out:
	529	if (req)
	530	ceph_mdsc_put_request(req);
	531	kfree(last_name);
38d46409 XL	532	doutc(fsc->client, "child dentry %p %p %llx.%llx err=%d\n", child,
38d46409 XL	533	inode, ceph_vinop(inode), err);
570df4e9 YZ	534	return err;
	535	}
	536
19913b4e YZ	537	static int ceph_get_name(struct dentry parent, char name,
	538	struct dentry *child)
	539	{
	540	struct ceph_mds_client *mdsc;
	541	struct ceph_mds_request *req;
85529096	542	struct inode *dir = d_inode(parent);
570df4e9	543	struct inode *inode = d_inode(child);
85529096	544	struct ceph_mds_reply_info_parsed *rinfo;
19913b4e YZ	545	int err;
19913b4e YZ	546
570df4e9 YZ	547	if (ceph_snap(inode) != CEPH_NOSNAP)
	548	return __get_snap_name(parent, name, child);
	549
5995d90d	550	mdsc = ceph_inode_to_fs_client(inode)->mdsc;
19913b4e YZ	551	req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_LOOKUPNAME,
	552	USE_ANY_MDS);
	553	if (IS_ERR(req))
	554	return PTR_ERR(req);
	555
85529096	556	inode_lock(dir);
570df4e9 YZ	557	req->r_inode = inode;
570df4e9 YZ	558	ihold(inode);
2b0143b5	559	req->r_ino2 = ceph_vino(d_inode(parent));
85529096 JL	560	req->r_parent = dir;
85529096 JL	561	ihold(dir);
3dd69aab	562	set_bit(CEPH_MDS_R_PARENT_LOCKED, &req->r_req_flags);
19913b4e YZ	563	req->r_num_caps = 2;
19913b4e YZ	564	err = ceph_mdsc_do_request(mdsc, NULL, req);
85529096	565	inode_unlock(dir);
19913b4e	566
85529096 JL	567	if (err)
85529096 JL	568	goto out;
19913b4e	569
85529096 JL	570	rinfo = &req->r_reply_info;
85529096 JL	571	if (!IS_ENCRYPTED(dir)) {
19913b4e YZ	572	memcpy(name, rinfo->dname, rinfo->dname_len);
19913b4e YZ	573	name[rinfo->dname_len] = 0;
19913b4e	574	} else {
85529096 JL	575	struct fscrypt_str oname = FSTR_INIT(NULL, 0);
	576	struct ceph_fname fname = { .dir = dir,
	577	.name = rinfo->dname,
	578	.ctext = rinfo->altname,
	579	.name_len = rinfo->dname_len,
	580	.ctext_len = rinfo->altname_len };
	581
	582	err = ceph_fname_alloc_buffer(dir, &oname);
	583	if (err < 0)
	584	goto out;
19913b4e	585
85529096 JL	586	err = ceph_fname_to_usr(&fname, NULL, &oname, NULL);
	587	if (!err) {
	588	memcpy(name, oname.name, oname.len);
	589	name[oname.len] = 0;
	590	}
	591	ceph_fname_free_buffer(dir, &oname);
	592	}
	593	out:
38d46409 XL	594	doutc(mdsc->fsc->client, "child dentry %p %p %llx.%llx err %d %s%s\n",
	595	child, inode, ceph_vinop(inode), err, err ? "" : "name ",
	596	err ? "" : name);
19913b4e YZ	597	ceph_mdsc_put_request(req);
	598	return err;
	599	}
	600
a8e63b7d SW	601	const struct export_operations ceph_export_ops = {
	602	.encode_fh = ceph_encode_fh,
	603	.fh_to_dentry = ceph_fh_to_dentry,
	604	.fh_to_parent = ceph_fh_to_parent,
9017c2ec	605	.get_parent = ceph_get_parent,
19913b4e	606	.get_name = ceph_get_name,
a8e63b7d	607	};