Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 57e62324 authored by Bryan Schumaker's avatar Bryan Schumaker Committed by Trond Myklebust
Browse files

NFS: Store the legacy idmapper result in the keyring



This patch removes the old hashmap-based caching and instead uses a
"request key actor" to place an upcall to the legacy idmapper rather
than going through /sbin/request-key.  This will only be used as a
fallback if /etc/request-key.conf isn't configured to use nfsidmap.

Signed-off-by: default avatarBryan Schumaker <bjschuma@netapp.com>
Signed-off-by: default avatarTrond Myklebust <Trond.Myklebust@netapp.com>
parent 59e6b9c1
Loading
Loading
Loading
Loading
+166 −388
Original line number Original line Diff line number Diff line
@@ -34,42 +34,28 @@
 *  SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 *  SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 */
 */
#include <linux/types.h>
#include <linux/types.h>
#include <linux/string.h>
#include <linux/parser.h>
#include <linux/kernel.h>
#include <linux/fs.h>
#include <linux/slab.h>
#include <linux/nfs_idmap.h>
#include <linux/nfs_idmap.h>
#include <net/net_namespace.h>
#include <linux/sunrpc/rpc_pipe_fs.h>
#include <linux/nfs_fs.h>
#include <linux/nfs_fs.h>
#include <linux/cred.h>
#include <linux/sunrpc/sched.h>
#include <linux/nfs4.h>
#include <linux/nfs_fs_sb.h>
#include <linux/nfs_fs_sb.h>
#include <linux/key.h>
#include <linux/keyctl.h>
#include <linux/keyctl.h>
#include <linux/key-type.h>
#include <linux/key-type.h>
#include <linux/rcupdate.h>
#include <linux/err.h>
#include <keys/user-type.h>
#include <keys/user-type.h>

/* include files needed by legacy idmapper */
#include <linux/module.h>
#include <linux/module.h>
#include <linux/mutex.h>

#include <linux/init.h>
#include <linux/socket.h>
#include <linux/in.h>
#include <linux/sched.h>
#include <linux/sunrpc/clnt.h>
#include <linux/workqueue.h>
#include <linux/sunrpc/rpc_pipe_fs.h>
#include <linux/nfs_fs.h>
#include "nfs4_fs.h"
#include "internal.h"
#include "internal.h"
#include "netns.h"
#include "netns.h"


#define NFS_UINT_MAXLEN 11
#define NFS_UINT_MAXLEN 11
#define IDMAP_HASH_SZ          128


/* Default cache timeout is 10 minutes */
/* Default cache timeout is 10 minutes */
unsigned int nfs_idmap_cache_timeout = 600 * HZ;
unsigned int nfs_idmap_cache_timeout = 600;
const struct cred *id_resolver_cache;
const struct cred *id_resolver_cache;
struct key_type key_type_id_resolver_legacy;




/**
/**
@@ -261,8 +247,10 @@ static ssize_t nfs_idmap_get_desc(const char *name, size_t namelen,
	return desclen;
	return desclen;
}
}


static ssize_t nfs_idmap_request_key(const char *name, size_t namelen,
static ssize_t nfs_idmap_request_key(struct key_type *key_type,
		const char *type, void *data, size_t data_size)
				     const char *name, size_t namelen,
				     const char *type, void *data,
				     size_t data_size, struct idmap *idmap)
{
{
	const struct cred *saved_cred;
	const struct cred *saved_cred;
	struct key *rkey;
	struct key *rkey;
@@ -275,8 +263,12 @@ static ssize_t nfs_idmap_request_key(const char *name, size_t namelen,
		goto out;
		goto out;


	saved_cred = override_creds(id_resolver_cache);
	saved_cred = override_creds(id_resolver_cache);
	if (idmap)
		rkey = request_key_with_auxdata(key_type, desc, "", 0, idmap);
	else
		rkey = request_key(&key_type_id_resolver, desc, "");
		rkey = request_key(&key_type_id_resolver, desc, "");
	revert_creds(saved_cred);
	revert_creds(saved_cred);

	kfree(desc);
	kfree(desc);
	if (IS_ERR(rkey)) {
	if (IS_ERR(rkey)) {
		ret = PTR_ERR(rkey);
		ret = PTR_ERR(rkey);
@@ -309,31 +301,46 @@ static ssize_t nfs_idmap_request_key(const char *name, size_t namelen,
	return ret;
	return ret;
}
}


static ssize_t nfs_idmap_get_key(const char *name, size_t namelen,
				 const char *type, void *data,
				 size_t data_size, struct idmap *idmap)
{
	ssize_t ret = nfs_idmap_request_key(&key_type_id_resolver,
					    name, namelen, type, data,
					    data_size, NULL);
	if (ret < 0) {
		ret = nfs_idmap_request_key(&key_type_id_resolver_legacy,
					    name, namelen, type, data,
					    data_size, idmap);
	}
	return ret;
}


/* ID -> Name */
/* ID -> Name */
static ssize_t nfs_idmap_lookup_name(__u32 id, const char *type, char *buf, size_t buflen)
static ssize_t nfs_idmap_lookup_name(__u32 id, const char *type, char *buf,
				     size_t buflen, struct idmap *idmap)
{
{
	char id_str[NFS_UINT_MAXLEN];
	char id_str[NFS_UINT_MAXLEN];
	int id_len;
	int id_len;
	ssize_t ret;
	ssize_t ret;


	id_len = snprintf(id_str, sizeof(id_str), "%u", id);
	id_len = snprintf(id_str, sizeof(id_str), "%u", id);
	ret = nfs_idmap_request_key(id_str, id_len, type, buf, buflen);
	ret = nfs_idmap_get_key(id_str, id_len, type, buf, buflen, idmap);
	if (ret < 0)
	if (ret < 0)
		return -EINVAL;
		return -EINVAL;
	return ret;
	return ret;
}
}


/* Name -> ID */
/* Name -> ID */
static int nfs_idmap_lookup_id(const char *name, size_t namelen,
static int nfs_idmap_lookup_id(const char *name, size_t namelen, const char *type,
				const char *type, __u32 *id)
			       __u32 *id, struct idmap *idmap)
{
{
	char id_str[NFS_UINT_MAXLEN];
	char id_str[NFS_UINT_MAXLEN];
	long id_long;
	long id_long;
	ssize_t data_size;
	ssize_t data_size;
	int ret = 0;
	int ret = 0;


	data_size = nfs_idmap_request_key(name, namelen, type, id_str, NFS_UINT_MAXLEN);
	data_size = nfs_idmap_get_key(name, namelen, type, id_str, NFS_UINT_MAXLEN, idmap);
	if (data_size <= 0) {
	if (data_size <= 0) {
		ret = -EINVAL;
		ret = -EINVAL;
	} else {
	} else {
@@ -344,54 +351,47 @@ static int nfs_idmap_lookup_id(const char *name, size_t namelen,
}
}


/* idmap classic begins here */
/* idmap classic begins here */
static int param_set_idmap_timeout(const char *val, struct kernel_param *kp)
module_param(nfs_idmap_cache_timeout, int, 0644);
{
	char *endp;
	int num = simple_strtol(val, &endp, 0);
	int jif = num * HZ;
	if (endp == val || *endp || num < 0 || jif < num)
		return -EINVAL;
	*((int *)kp->arg) = jif;
	return 0;
}

module_param_call(idmap_cache_timeout, param_set_idmap_timeout, param_get_int,
		 &nfs_idmap_cache_timeout, 0644);


struct idmap_hashent {
struct idmap {
	unsigned long		ih_expires;
	struct rpc_pipe		*idmap_pipe;
	__u32			ih_id;
	struct key_construction	*idmap_key_cons;
	size_t			ih_namelen;
	const char		*ih_name;
};
};


struct idmap_hashtable {
enum {
	__u8			h_type;
	Opt_find_uid, Opt_find_gid, Opt_find_user, Opt_find_group, Opt_find_err
	struct idmap_hashent	*h_entries;
};
};


struct idmap {
static const match_table_t nfs_idmap_tokens = {
	struct rpc_pipe		*idmap_pipe;
	{ Opt_find_uid, "uid:%s" },
	wait_queue_head_t	idmap_wq;
	{ Opt_find_gid, "gid:%s" },
	struct idmap_msg	idmap_im;
	{ Opt_find_user, "user:%s" },
	struct mutex		idmap_lock;	/* Serializes upcalls */
	{ Opt_find_group, "group:%s" },
	struct mutex		idmap_im_lock;	/* Protects the hashtable */
	{ Opt_find_err, NULL }
	struct idmap_hashtable	idmap_user_hash;
	struct idmap_hashtable	idmap_group_hash;
};
};


static int nfs_idmap_legacy_upcall(struct key_construction *, const char *, void *);
static ssize_t idmap_pipe_downcall(struct file *, const char __user *,
static ssize_t idmap_pipe_downcall(struct file *, const char __user *,
				   size_t);
				   size_t);
static void idmap_pipe_destroy_msg(struct rpc_pipe_msg *);
static void idmap_pipe_destroy_msg(struct rpc_pipe_msg *);


static unsigned int fnvhash32(const void *, size_t);

static const struct rpc_pipe_ops idmap_upcall_ops = {
static const struct rpc_pipe_ops idmap_upcall_ops = {
	.upcall		= rpc_pipe_generic_upcall,
	.upcall		= rpc_pipe_generic_upcall,
	.downcall	= idmap_pipe_downcall,
	.downcall	= idmap_pipe_downcall,
	.destroy_msg	= idmap_pipe_destroy_msg,
	.destroy_msg	= idmap_pipe_destroy_msg,
};
};


struct key_type key_type_id_resolver_legacy = {
	.name		= "id_resolver",
	.instantiate	= user_instantiate,
	.match		= user_match,
	.revoke		= user_revoke,
	.destroy	= user_destroy,
	.describe	= user_describe,
	.read		= user_read,
	.request_key	= nfs_idmap_legacy_upcall,
};

static void __nfs_idmap_unregister(struct rpc_pipe *pipe)
static void __nfs_idmap_unregister(struct rpc_pipe *pipe)
{
{
	if (pipe->dentry)
	if (pipe->dentry)
@@ -468,38 +468,11 @@ nfs_idmap_new(struct nfs_client *clp)
		return error;
		return error;
	}
	}
	idmap->idmap_pipe = pipe;
	idmap->idmap_pipe = pipe;
	mutex_init(&idmap->idmap_lock);
	mutex_init(&idmap->idmap_im_lock);
	init_waitqueue_head(&idmap->idmap_wq);
	idmap->idmap_user_hash.h_type = IDMAP_TYPE_USER;
	idmap->idmap_group_hash.h_type = IDMAP_TYPE_GROUP;


	clp->cl_idmap = idmap;
	clp->cl_idmap = idmap;
	return 0;
	return 0;
}
}


static void
idmap_alloc_hashtable(struct idmap_hashtable *h)
{
	if (h->h_entries != NULL)
		return;
	h->h_entries = kcalloc(IDMAP_HASH_SZ,
			sizeof(*h->h_entries),
			GFP_KERNEL);
}

static void
idmap_free_hashtable(struct idmap_hashtable *h)
{
	int i;

	if (h->h_entries == NULL)
		return;
	for (i = 0; i < IDMAP_HASH_SZ; i++)
		kfree(h->h_entries[i].ih_name);
	kfree(h->h_entries);
}

void
void
nfs_idmap_delete(struct nfs_client *clp)
nfs_idmap_delete(struct nfs_client *clp)
{
{
@@ -510,8 +483,6 @@ nfs_idmap_delete(struct nfs_client *clp)
	nfs_idmap_unregister(clp, idmap->idmap_pipe);
	nfs_idmap_unregister(clp, idmap->idmap_pipe);
	rpc_destroy_pipe_data(idmap->idmap_pipe);
	rpc_destroy_pipe_data(idmap->idmap_pipe);
	clp->cl_idmap = NULL;
	clp->cl_idmap = NULL;
	idmap_free_hashtable(&idmap->idmap_user_hash);
	idmap_free_hashtable(&idmap->idmap_group_hash);
	kfree(idmap);
	kfree(idmap);
}
}


@@ -617,222 +588,107 @@ void nfs_idmap_quit(void)
	nfs_idmap_quit_keyring();
	nfs_idmap_quit_keyring();
}
}


/*
static int nfs_idmap_prepare_message(char *desc, struct idmap_msg *im,
 * Helper routines for manipulating the hashtable
				     struct rpc_pipe_msg *msg)
 */
static inline struct idmap_hashent *
idmap_name_hash(struct idmap_hashtable* h, const char *name, size_t len)
{
{
	if (h->h_entries == NULL)
	substring_t substr;
		return NULL;
	int token, ret;
	return &h->h_entries[fnvhash32(name, len) % IDMAP_HASH_SZ];
}


static struct idmap_hashent *
	memset(im,  0, sizeof(*im));
idmap_lookup_name(struct idmap_hashtable *h, const char *name, size_t len)
	memset(msg, 0, sizeof(*msg));
{
	struct idmap_hashent *he = idmap_name_hash(h, name, len);


	if (he == NULL)
	im->im_type = IDMAP_TYPE_GROUP;
		return NULL;
	token = match_token(desc, nfs_idmap_tokens, &substr);
	if (he->ih_namelen != len || memcmp(he->ih_name, name, len) != 0)
		return NULL;
	if (time_after(jiffies, he->ih_expires))
		return NULL;
	return he;
}


static inline struct idmap_hashent *
	switch (token) {
idmap_id_hash(struct idmap_hashtable* h, __u32 id)
	case Opt_find_uid:
{
		im->im_type = IDMAP_TYPE_USER;
	if (h->h_entries == NULL)
	case Opt_find_gid:
		return NULL;
		im->im_conv = IDMAP_CONV_NAMETOID;
	return &h->h_entries[fnvhash32(&id, sizeof(id)) % IDMAP_HASH_SZ];
		ret = match_strlcpy(im->im_name, &substr, IDMAP_NAMESZ);
}
		break;

static struct idmap_hashent *
idmap_lookup_id(struct idmap_hashtable *h, __u32 id)
{
	struct idmap_hashent *he = idmap_id_hash(h, id);


	if (he == NULL)
	case Opt_find_user:
		return NULL;
		im->im_type = IDMAP_TYPE_USER;
	if (he->ih_id != id || he->ih_namelen == 0)
	case Opt_find_group:
		return NULL;
		im->im_conv = IDMAP_CONV_IDTONAME;
	if (time_after(jiffies, he->ih_expires))
		ret = match_int(&substr, &im->im_id);
		return NULL;
		break;
	return he;
}


/*
	default:
 * Routines for allocating new entries in the hashtable.
		ret = -EINVAL;
 * For now, we just have 1 entry per bucket, so it's all
		goto out;
 * pretty trivial.
 */
static inline struct idmap_hashent *
idmap_alloc_name(struct idmap_hashtable *h, char *name, size_t len)
{
	idmap_alloc_hashtable(h);
	return idmap_name_hash(h, name, len);
	}
	}


static inline struct idmap_hashent *
	msg->data = im;
idmap_alloc_id(struct idmap_hashtable *h, __u32 id)
	msg->len  = sizeof(struct idmap_msg);
{
	idmap_alloc_hashtable(h);
	return idmap_id_hash(h, id);
}


static void
out:
idmap_update_entry(struct idmap_hashent *he, const char *name,
	return ret;
		size_t namelen, __u32 id)
{
	char *str = kmalloc(namelen + 1, GFP_KERNEL);
	if (str == NULL)
		return;
	kfree(he->ih_name);
	he->ih_id = id;
	memcpy(str, name, namelen);
	str[namelen] = '\0';
	he->ih_name = str;
	he->ih_namelen = namelen;
	he->ih_expires = jiffies + nfs_idmap_cache_timeout;
}
}


/*
static int nfs_idmap_legacy_upcall(struct key_construction *cons,
 * Name -> ID
				   const char *op,
 */
				   void *aux)
static int
nfs_idmap_id(struct idmap *idmap, struct idmap_hashtable *h,
		const char *name, size_t namelen, __u32 *id)
{
{
	struct rpc_pipe_msg msg;
	struct rpc_pipe_msg *msg;
	struct idmap_msg *im;
	struct idmap_msg *im;
	struct idmap_hashent *he;
	struct idmap *idmap = (struct idmap *)aux;
	DECLARE_WAITQUEUE(wq, current);
	struct key *key = cons->key;
	int ret = -EIO;
	int ret;

	im = &idmap->idmap_im;


	/*
	/* msg and im are freed in idmap_pipe_destroy_msg */
	 * String sanity checks
	msg = kmalloc(sizeof(*msg), GFP_KERNEL);
	 * Note that the userland daemon expects NUL terminated strings
	if (IS_ERR(msg)) {
	 */
		ret = PTR_ERR(msg);
	for (;;) {
		goto out0;
		if (namelen == 0)
			return -EINVAL;
		if (name[namelen-1] != '\0')
			break;
		namelen--;
	}
	}
	if (namelen >= IDMAP_NAMESZ)
		return -EINVAL;


	mutex_lock(&idmap->idmap_lock);
	im = kmalloc(sizeof(*im), GFP_KERNEL);
	mutex_lock(&idmap->idmap_im_lock);
	if (IS_ERR(im)) {

		ret = PTR_ERR(im);
	he = idmap_lookup_name(h, name, namelen);
		goto out1;
	if (he != NULL) {
		*id = he->ih_id;
		ret = 0;
		goto out;
	}
	}


	memset(im, 0, sizeof(*im));
	ret = nfs_idmap_prepare_message(key->description, im, msg);
	memcpy(im->im_name, name, namelen);
	if (ret < 0)

		goto out2;
	im->im_type = h->h_type;
	im->im_conv = IDMAP_CONV_NAMETOID;

	memset(&msg, 0, sizeof(msg));
	msg.data = im;
	msg.len = sizeof(*im);

	add_wait_queue(&idmap->idmap_wq, &wq);
	if (rpc_queue_upcall(idmap->idmap_pipe, &msg) < 0) {
		remove_wait_queue(&idmap->idmap_wq, &wq);
		goto out;
	}


	set_current_state(TASK_UNINTERRUPTIBLE);
	idmap->idmap_key_cons = cons;
	mutex_unlock(&idmap->idmap_im_lock);
	schedule();
	__set_current_state(TASK_RUNNING);
	remove_wait_queue(&idmap->idmap_wq, &wq);
	mutex_lock(&idmap->idmap_im_lock);


	if (im->im_status & IDMAP_STATUS_SUCCESS) {
	return rpc_queue_upcall(idmap->idmap_pipe, msg);
		*id = im->im_id;
		ret = 0;
	}


 out:
out2:
	memset(im, 0, sizeof(*im));
	kfree(im);
	mutex_unlock(&idmap->idmap_im_lock);
out1:
	mutex_unlock(&idmap->idmap_lock);
	kfree(msg);
out0:
	complete_request_key(cons, ret);
	return ret;
	return ret;
}
}


/*
static int nfs_idmap_instantiate(struct key *key, struct key *authkey, char *data)
 * ID -> Name
 */
static int
nfs_idmap_name(struct idmap *idmap, struct idmap_hashtable *h,
		__u32 id, char *name)
{
{
	struct rpc_pipe_msg msg;
	return key_instantiate_and_link(key, data, strlen(data) + 1,
	struct idmap_msg *im;
					id_resolver_cache->thread_keyring,
	struct idmap_hashent *he;
					authkey);
	DECLARE_WAITQUEUE(wq, current);
	int ret = -EIO;
	unsigned int len;

	im = &idmap->idmap_im;

	mutex_lock(&idmap->idmap_lock);
	mutex_lock(&idmap->idmap_im_lock);

	he = idmap_lookup_id(h, id);
	if (he) {
		memcpy(name, he->ih_name, he->ih_namelen);
		ret = he->ih_namelen;
		goto out;
	}

	memset(im, 0, sizeof(*im));
	im->im_type = h->h_type;
	im->im_conv = IDMAP_CONV_IDTONAME;
	im->im_id = id;

	memset(&msg, 0, sizeof(msg));
	msg.data = im;
	msg.len = sizeof(*im);

	add_wait_queue(&idmap->idmap_wq, &wq);

	if (rpc_queue_upcall(idmap->idmap_pipe, &msg) < 0) {
		remove_wait_queue(&idmap->idmap_wq, &wq);
		goto out;
}
}


	set_current_state(TASK_UNINTERRUPTIBLE);
static int nfs_idmap_read_message(struct idmap_msg *im, struct key *key, struct key *authkey)
	mutex_unlock(&idmap->idmap_im_lock);
{
	schedule();
	char id_str[NFS_UINT_MAXLEN];
	__set_current_state(TASK_RUNNING);
	int ret = -EINVAL;
	remove_wait_queue(&idmap->idmap_wq, &wq);
	mutex_lock(&idmap->idmap_im_lock);


	if (im->im_status & IDMAP_STATUS_SUCCESS) {
	switch (im->im_conv) {
		if ((len = strnlen(im->im_name, IDMAP_NAMESZ)) == 0)
	case IDMAP_CONV_NAMETOID:
			goto out;
		sprintf(id_str, "%d", im->im_id);
		memcpy(name, im->im_name, len);
		ret = nfs_idmap_instantiate(key, authkey, id_str);
		ret = len;
		break;
	case IDMAP_CONV_IDTONAME:
		ret = nfs_idmap_instantiate(key, authkey, im->im_name);
		break;
	}
	}


 out:
	memset(im, 0, sizeof(*im));
	mutex_unlock(&idmap->idmap_im_lock);
	mutex_unlock(&idmap->idmap_lock);
	return ret;
	return ret;
}
}


@@ -841,141 +697,69 @@ idmap_pipe_downcall(struct file *filp, const char __user *src, size_t mlen)
{
{
	struct rpc_inode *rpci = RPC_I(filp->f_path.dentry->d_inode);
	struct rpc_inode *rpci = RPC_I(filp->f_path.dentry->d_inode);
	struct idmap *idmap = (struct idmap *)rpci->private;
	struct idmap *idmap = (struct idmap *)rpci->private;
	struct idmap_msg im_in, *im = &idmap->idmap_im;
	struct key_construction *cons = idmap->idmap_key_cons;
	struct idmap_hashtable *h;
	struct idmap_msg im;
	struct idmap_hashent *he = NULL;
	size_t namelen_in;
	size_t namelen_in;
	int ret;
	int ret;


	if (mlen != sizeof(im_in))
	if (mlen != sizeof(im)) {
		return -ENOSPC;
		ret = -ENOSPC;

	if (copy_from_user(&im_in, src, mlen) != 0)
		return -EFAULT;

	mutex_lock(&idmap->idmap_im_lock);

	ret = mlen;
	im->im_status = im_in.im_status;
	/* If we got an error, terminate now, and wake up pending upcalls */
	if (!(im_in.im_status & IDMAP_STATUS_SUCCESS)) {
		wake_up(&idmap->idmap_wq);
		goto out;
		goto out;
	}
	}


	/* Sanity checking of strings */
	if (copy_from_user(&im, src, mlen) != 0) {
	ret = -EINVAL;
		ret = -EFAULT;
	namelen_in = strnlen(im_in.im_name, IDMAP_NAMESZ);
	if (namelen_in == 0 || namelen_in == IDMAP_NAMESZ)
		goto out;
		goto out;
	}


	switch (im_in.im_type) {
	if (!(im.im_status & IDMAP_STATUS_SUCCESS)) {
		case IDMAP_TYPE_USER:
		ret = mlen;
			h = &idmap->idmap_user_hash;
		complete_request_key(idmap->idmap_key_cons, -ENOKEY);
			break;
		goto out_incomplete;
		case IDMAP_TYPE_GROUP:
			h = &idmap->idmap_group_hash;
			break;
		default:
			goto out;
	}
	}


	switch (im_in.im_conv) {
	namelen_in = strnlen(im.im_name, IDMAP_NAMESZ);
	case IDMAP_CONV_IDTONAME:
	if (namelen_in == 0 || namelen_in == IDMAP_NAMESZ) {
		/* Did we match the current upcall? */
		ret = -EINVAL;
		if (im->im_conv == IDMAP_CONV_IDTONAME
				&& im->im_type == im_in.im_type
				&& im->im_id == im_in.im_id) {
			/* Yes: copy string, including the terminating '\0'  */
			memcpy(im->im_name, im_in.im_name, namelen_in);
			im->im_name[namelen_in] = '\0';
			wake_up(&idmap->idmap_wq);
		}
		he = idmap_alloc_id(h, im_in.im_id);
		break;
	case IDMAP_CONV_NAMETOID:
		/* Did we match the current upcall? */
		if (im->im_conv == IDMAP_CONV_NAMETOID
				&& im->im_type == im_in.im_type
				&& strnlen(im->im_name, IDMAP_NAMESZ) == namelen_in
				&& memcmp(im->im_name, im_in.im_name, namelen_in) == 0) {
			im->im_id = im_in.im_id;
			wake_up(&idmap->idmap_wq);
		}
		he = idmap_alloc_name(h, im_in.im_name, namelen_in);
		break;
	default:
		goto out;
		goto out;
	}
	}


	/* If the entry is valid, also copy it to the cache */
	ret = nfs_idmap_read_message(&im, cons->key, cons->authkey);
	if (he != NULL)
	if (ret >= 0) {
		idmap_update_entry(he, im_in.im_name, namelen_in, im_in.im_id);
		key_set_timeout(cons->key, nfs_idmap_cache_timeout);
		ret = mlen;
		ret = mlen;
	}

out:
out:
	mutex_unlock(&idmap->idmap_im_lock);
	complete_request_key(idmap->idmap_key_cons, ret);
out_incomplete:
	return ret;
	return ret;
}
}


static void
static void
idmap_pipe_destroy_msg(struct rpc_pipe_msg *msg)
idmap_pipe_destroy_msg(struct rpc_pipe_msg *msg)
{
{
	struct idmap_msg *im = msg->data;
	/* Free memory allocated in nfs_idmap_legacy_upcall() */
	struct idmap *idmap = container_of(im, struct idmap, idmap_im); 
	kfree(msg->data);

	kfree(msg);
	if (msg->errno >= 0)
		return;
	mutex_lock(&idmap->idmap_im_lock);
	im->im_status = IDMAP_STATUS_LOOKUPFAIL;
	wake_up(&idmap->idmap_wq);
	mutex_unlock(&idmap->idmap_im_lock);
}

/* 
 * Fowler/Noll/Vo hash
 *    http://www.isthe.com/chongo/tech/comp/fnv/
 */

#define FNV_P_32 ((unsigned int)0x01000193) /* 16777619 */
#define FNV_1_32 ((unsigned int)0x811c9dc5) /* 2166136261 */

static unsigned int fnvhash32(const void *buf, size_t buflen)
{
	const unsigned char *p, *end = (const unsigned char *)buf + buflen;
	unsigned int hash = FNV_1_32;

	for (p = buf; p < end; p++) {
		hash *= FNV_P_32;
		hash ^= (unsigned int)*p;
	}

	return hash;
}
}


int nfs_map_name_to_uid(const struct nfs_server *server, const char *name, size_t namelen, __u32 *uid)
int nfs_map_name_to_uid(const struct nfs_server *server, const char *name, size_t namelen, __u32 *uid)
{
{
	struct idmap *idmap = server->nfs_client->cl_idmap;
	struct idmap *idmap = server->nfs_client->cl_idmap;
	int ret = -EINVAL;


	if (nfs_map_string_to_numeric(name, namelen, uid))
	if (nfs_map_string_to_numeric(name, namelen, uid))
		return 0;
		return 0;
	ret = nfs_idmap_lookup_id(name, namelen, "uid", uid);
	return nfs_idmap_lookup_id(name, namelen, "uid", uid, idmap);
	if (ret < 0)
		ret = nfs_idmap_id(idmap, &idmap->idmap_user_hash, name, namelen, uid);
	return ret;
}
}


int nfs_map_group_to_gid(const struct nfs_server *server, const char *name, size_t namelen, __u32 *gid)
int nfs_map_group_to_gid(const struct nfs_server *server, const char *name, size_t namelen, __u32 *gid)
{
{
	struct idmap *idmap = server->nfs_client->cl_idmap;
	struct idmap *idmap = server->nfs_client->cl_idmap;
	int ret = -EINVAL;


	if (nfs_map_string_to_numeric(name, namelen, gid))
	if (nfs_map_string_to_numeric(name, namelen, gid))
		return 0;
		return 0;
	ret = nfs_idmap_lookup_id(name, namelen, "gid", gid);
	return nfs_idmap_lookup_id(name, namelen, "gid", gid, idmap);
	if (ret < 0)
		ret = nfs_idmap_id(idmap, &idmap->idmap_group_hash, name, namelen, gid);
	return ret;
}
}


int nfs_map_uid_to_name(const struct nfs_server *server, __u32 uid, char *buf, size_t buflen)
int nfs_map_uid_to_name(const struct nfs_server *server, __u32 uid, char *buf, size_t buflen)
@@ -983,11 +767,8 @@ int nfs_map_uid_to_name(const struct nfs_server *server, __u32 uid, char *buf, s
	struct idmap *idmap = server->nfs_client->cl_idmap;
	struct idmap *idmap = server->nfs_client->cl_idmap;
	int ret = -EINVAL;
	int ret = -EINVAL;


	if (!(server->caps & NFS_CAP_UIDGID_NOMAP)) {
	if (!(server->caps & NFS_CAP_UIDGID_NOMAP))
		ret = nfs_idmap_lookup_name(uid, "user", buf, buflen);
		ret = nfs_idmap_lookup_name(uid, "user", buf, buflen, idmap);
		if (ret < 0)
			ret = nfs_idmap_name(idmap, &idmap->idmap_user_hash, uid, buf);
	}
	if (ret < 0)
	if (ret < 0)
		ret = nfs_map_numeric_to_string(uid, buf, buflen);
		ret = nfs_map_numeric_to_string(uid, buf, buflen);
	return ret;
	return ret;
@@ -997,11 +778,8 @@ int nfs_map_gid_to_group(const struct nfs_server *server, __u32 gid, char *buf,
	struct idmap *idmap = server->nfs_client->cl_idmap;
	struct idmap *idmap = server->nfs_client->cl_idmap;
	int ret = -EINVAL;
	int ret = -EINVAL;


	if (!(server->caps & NFS_CAP_UIDGID_NOMAP)) {
	if (!(server->caps & NFS_CAP_UIDGID_NOMAP))
		ret = nfs_idmap_lookup_name(gid, "group", buf, buflen);
		ret = nfs_idmap_lookup_name(gid, "group", buf, buflen, idmap);
		if (ret < 0)
			ret = nfs_idmap_name(idmap, &idmap->idmap_group_hash, gid, buf);
	}
	if (ret < 0)
	if (ret < 0)
		ret = nfs_map_numeric_to_string(gid, buf, buflen);
		ret = nfs_map_numeric_to_string(gid, buf, buflen);
	return ret;
	return ret;
+0 −11
Original line number Original line Diff line number Diff line
@@ -69,19 +69,8 @@ struct nfs_server;
struct nfs_fattr;
struct nfs_fattr;
struct nfs4_string;
struct nfs4_string;


#ifdef CONFIG_NFS_V4
int nfs_idmap_init(void);
int nfs_idmap_init(void);
void nfs_idmap_quit(void);
void nfs_idmap_quit(void);
#else
static inline int nfs_idmap_init(void)
{
	return 0;
}

static inline void nfs_idmap_quit(void)
{}
#endif

int nfs_idmap_new(struct nfs_client *);
int nfs_idmap_new(struct nfs_client *);
void nfs_idmap_delete(struct nfs_client *);
void nfs_idmap_delete(struct nfs_client *);