net/9p/client.c - fp2-dev/kernel/msm - Gitiles

 /*
  * net/9p/clnt.c
  *
  * 9P Client
  *
  *  Copyright (C) 2007 by Latchesar Ionkov <lucho@ionkov.net>
  *
  *  This program is free software; you can redistribute it and/or modify
  *  it under the terms of the GNU General Public License version 2
  *  as published by the Free Software Foundation.
  *
  *  This program is distributed in the hope that it will be useful,
  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  *  GNU General Public License for more details.
  *
  *  You should have received a copy of the GNU General Public License
  *  along with this program; if not, write to:
  *  Free Software Foundation
  *  51 Franklin Street, Fifth Floor
  *  Boston, MA  02111-1301  USA
  *
  */

 #include <linux/module.h>
 #include <linux/errno.h>
 #include <linux/fs.h>
 #include <linux/idr.h>
 #include <linux/mutex.h>
 #include <linux/sched.h>
 #include <linux/uaccess.h>
 #include <net/9p/9p.h>
 #include <net/9p/transport.h>
 #include <net/9p/conn.h>
 #include <net/9p/client.h>

 static struct p9_fid *p9_fid_create(struct p9_client *clnt);
 static void p9_fid_destroy(struct p9_fid *fid);
 static struct p9_stat *p9_clone_stat(struct p9_stat *st, int dotu);

 struct p9_client *p9_client_create(struct p9_transport *trans, int msize,
 								   int dotu)
 {
 	int err, n;
 	struct p9_client *clnt;
 	struct p9_fcall *tc, *rc;
 	struct p9_str *version;

 	err = 0;
 	tc = NULL;
 	rc = NULL;
 	clnt = kmalloc(sizeof(struct p9_client), GFP_KERNEL);
 	if (!clnt)
 		return ERR_PTR(-ENOMEM);

 	P9_DPRINTK(P9_DEBUG_9P, "clnt %p trans %p msize %d dotu %d\n",
 		clnt, trans, msize, dotu);
 	spin_lock_init(&clnt->lock);
 	clnt->trans = trans;
 	clnt->msize = msize;
 	clnt->dotu = dotu;
 	INIT_LIST_HEAD(&clnt->fidlist);
 	clnt->fidpool = p9_idpool_create();
 	if (!clnt->fidpool) {
 		err = PTR_ERR(clnt->fidpool);
 		clnt->fidpool = NULL;
 		goto error;
 	}

 	clnt->conn = p9_conn_create(clnt->trans, clnt->msize, &clnt->dotu);
 	if (IS_ERR(clnt->conn)) {
 		err = PTR_ERR(clnt->conn);
 		clnt->conn = NULL;
 		goto error;
 	}

 	tc = p9_create_tversion(clnt->msize, clnt->dotu?"9P2000.u":"9P2000");
 	if (IS_ERR(tc)) {
 		err = PTR_ERR(tc);
 		tc = NULL;
 		goto error;
 	}

 	err = p9_conn_rpc(clnt->conn, tc, &rc);
 	if (err)
 		goto error;

 	version = &rc->params.rversion.version;
 	if (version->len == 8 && !memcmp(version->str, "9P2000.u", 8))
 		clnt->dotu = 1;
 	else if (version->len == 6 && !memcmp(version->str, "9P2000", 6))
 		clnt->dotu = 0;
 	else {
 		err = -EREMOTEIO;
 		goto error;
 	}

 	n = rc->params.rversion.msize;
 	if (n < clnt->msize)
 		clnt->msize = n;

 	kfree(tc);
 	kfree(rc);
 	return clnt;

 error:
 	kfree(tc);
 	kfree(rc);
 	p9_client_destroy(clnt);
 	return ERR_PTR(err);
 }
 EXPORT_SYMBOL(p9_client_create);

 void p9_client_destroy(struct p9_client *clnt)
 {
 	struct p9_fid *fid, *fidptr;

 	P9_DPRINTK(P9_DEBUG_9P, "clnt %p\n", clnt);
 	if (clnt->conn) {
 		p9_conn_destroy(clnt->conn);
 		clnt->conn = NULL;
 	}

 	if (clnt->trans) {
 		clnt->trans->close(clnt->trans);
 		kfree(clnt->trans);
 		clnt->trans = NULL;
 	}

 	list_for_each_entry_safe(fid, fidptr, &clnt->fidlist, flist)
 		p9_fid_destroy(fid);

 	if (clnt->fidpool)
 		p9_idpool_destroy(clnt->fidpool);

 	kfree(clnt);
 }
 EXPORT_SYMBOL(p9_client_destroy);

 void p9_client_disconnect(struct p9_client *clnt)
 {
 	P9_DPRINTK(P9_DEBUG_9P, "clnt %p\n", clnt);
 	clnt->trans->status = Disconnected;
 	p9_conn_cancel(clnt->conn, -EIO);
 }
 EXPORT_SYMBOL(p9_client_disconnect);

 struct p9_fid *p9_client_attach(struct p9_client *clnt, struct p9_fid *afid,
 	char *uname, char *aname)
 {
 	int err;
 	struct p9_fcall *tc, *rc;
 	struct p9_fid *fid;

 	P9_DPRINTK(P9_DEBUG_9P, "clnt %p afid %d uname %s aname %s\n",
 		clnt, afid?afid->fid:-1, uname, aname);
 	err = 0;
 	tc = NULL;
 	rc = NULL;

 	fid = p9_fid_create(clnt);
 	if (IS_ERR(fid)) {
 		err = PTR_ERR(fid);
 		fid = NULL;
 		goto error;
 	}

 	tc = p9_create_tattach(fid->fid, afid?afid->fid:P9_NOFID, uname, aname);
 	if (IS_ERR(tc)) {
 		err = PTR_ERR(tc);
 		tc = NULL;
 		goto error;
 	}

 	err = p9_conn_rpc(clnt->conn, tc, &rc);
 	if (err)
 		goto error;

 	memmove(&fid->qid, &rc->params.rattach.qid, sizeof(struct p9_qid));
 	kfree(tc);
 	kfree(rc);
 	return fid;

 error:
 	kfree(tc);
 	kfree(rc);
 	if (fid)
 		p9_fid_destroy(fid);
 	return ERR_PTR(err);
 }
 EXPORT_SYMBOL(p9_client_attach);

 struct p9_fid *p9_client_auth(struct p9_client *clnt, char *uname, char *aname)
 {
 	int err;
 	struct p9_fcall *tc, *rc;
 	struct p9_fid *fid;

 	P9_DPRINTK(P9_DEBUG_9P, "clnt %p uname %s aname %s\n", clnt, uname,
 									aname);
 	err = 0;
 	tc = NULL;
 	rc = NULL;

 	fid = p9_fid_create(clnt);
 	if (IS_ERR(fid)) {
 		err = PTR_ERR(fid);
 		fid = NULL;
 		goto error;
 	}

 	tc = p9_create_tauth(fid->fid, uname, aname);
 	if (IS_ERR(tc)) {
 		err = PTR_ERR(tc);
 		tc = NULL;
 		goto error;
 	}

 	err = p9_conn_rpc(clnt->conn, tc, &rc);
 	if (err)
 		goto error;

 	memmove(&fid->qid, &rc->params.rauth.qid, sizeof(struct p9_qid));
 	kfree(tc);
 	kfree(rc);
 	return fid;

 error:
 	kfree(tc);
 	kfree(rc);
 	if (fid)
 		p9_fid_destroy(fid);
 	return ERR_PTR(err);
 }
 EXPORT_SYMBOL(p9_client_auth);

 struct p9_fid *p9_client_walk(struct p9_fid *oldfid, int nwname, char **wnames,
 	int clone)
 {
 	int err;
 	struct p9_fcall *tc, *rc;
 	struct p9_client *clnt;
 	struct p9_fid *fid;

 	P9_DPRINTK(P9_DEBUG_9P, "fid %d nwname %d wname[0] %s\n",
 		oldfid->fid, nwname, wnames?wnames[0]:NULL);
 	err = 0;
 	tc = NULL;
 	rc = NULL;
 	clnt = oldfid->clnt;
 	if (clone) {
 		fid = p9_fid_create(clnt);
 		if (IS_ERR(fid)) {
 			err = PTR_ERR(fid);
 			fid = NULL;
 			goto error;
 		}

 		fid->uid = oldfid->uid;
 	} else
 		fid = oldfid;

 	tc = p9_create_twalk(oldfid->fid, fid->fid, nwname, wnames);
 	if (IS_ERR(tc)) {
 		err = PTR_ERR(tc);
 		tc = NULL;
 		goto error;
 	}

 	err = p9_conn_rpc(clnt->conn, tc, &rc);
 	if (err) {
 		if (rc && rc->id == P9_RWALK)
 			goto clunk_fid;
 		else
 			goto error;
 	}

 	if (rc->params.rwalk.nwqid != nwname) {
 		err = -ENOENT;
 		goto clunk_fid;
 	}

 	if (nwname)
 		memmove(&fid->qid,
 			&rc->params.rwalk.wqids[rc->params.rwalk.nwqid - 1],
 			sizeof(struct p9_qid));
 	else
 		fid->qid = oldfid->qid;

 	kfree(tc);
 	kfree(rc);
 	return fid;

 clunk_fid:
 	kfree(tc);
 	kfree(rc);
 	rc = NULL;
 	tc = p9_create_tclunk(fid->fid);
 	if (IS_ERR(tc)) {
 		err = PTR_ERR(tc);
 		tc = NULL;
 		goto error;
 	}

 	p9_conn_rpc(clnt->conn, tc, &rc);

 error:
 	kfree(tc);
 	kfree(rc);
 	if (fid && (fid != oldfid))
 		p9_fid_destroy(fid);

 	return ERR_PTR(err);
 }
 EXPORT_SYMBOL(p9_client_walk);

 int p9_client_open(struct p9_fid *fid, int mode)
 {
 	int err;
 	struct p9_fcall *tc, *rc;
 	struct p9_client *clnt;

 	P9_DPRINTK(P9_DEBUG_9P, "fid %d mode %d\n", fid->fid, mode);
 	err = 0;
 	tc = NULL;
 	rc = NULL;
 	clnt = fid->clnt;

 	if (fid->mode != -1)
 		return -EINVAL;

 	tc = p9_create_topen(fid->fid, mode);
 	if (IS_ERR(tc)) {
 		err = PTR_ERR(tc);
 		tc = NULL;
 		goto done;
 	}

 	err = p9_conn_rpc(clnt->conn, tc, &rc);
 	if (err)
 		goto done;

 	fid->mode = mode;
 	fid->iounit = rc->params.ropen.iounit;

 done:
 	kfree(tc);
 	kfree(rc);
 	return err;
 }
 EXPORT_SYMBOL(p9_client_open);

 int p9_client_fcreate(struct p9_fid *fid, char *name, u32 perm, int mode,
 		     char *extension)
 {
 	int err;
 	struct p9_fcall *tc, *rc;
 	struct p9_client *clnt;

 	P9_DPRINTK(P9_DEBUG_9P, "fid %d name %s perm %d mode %d\n", fid->fid,
 		name, perm, mode);
 	err = 0;
 	tc = NULL;
 	rc = NULL;
 	clnt = fid->clnt;

 	if (fid->mode != -1)
 		return -EINVAL;

 	tc = p9_create_tcreate(fid->fid, name, perm, mode, extension,
 							       clnt->dotu);
 	if (IS_ERR(tc)) {
 		err = PTR_ERR(tc);
 		tc = NULL;
 		goto done;
 	}

 	err = p9_conn_rpc(clnt->conn, tc, &rc);
 	if (err)
 		goto done;

 	fid->mode = mode;
 	fid->iounit = rc->params.ropen.iounit;

 done:
 	kfree(tc);
 	kfree(rc);
 	return err;
 }
 EXPORT_SYMBOL(p9_client_fcreate);

 int p9_client_clunk(struct p9_fid *fid)
 {
 	int err;
 	struct p9_fcall *tc, *rc;
 	struct p9_client *clnt;

 	P9_DPRINTK(P9_DEBUG_9P, "fid %d\n", fid->fid);
 	err = 0;
 	tc = NULL;
 	rc = NULL;
 	clnt = fid->clnt;

 	tc = p9_create_tclunk(fid->fid);
 	if (IS_ERR(tc)) {
 		err = PTR_ERR(tc);
 		tc = NULL;
 		goto done;
 	}

 	err = p9_conn_rpc(clnt->conn, tc, &rc);
 	if (err)
 		goto done;

 	p9_fid_destroy(fid);

 done:
 	kfree(tc);
 	kfree(rc);
 	return err;
 }
 EXPORT_SYMBOL(p9_client_clunk);

 int p9_client_remove(struct p9_fid *fid)
 {
 	int err;
 	struct p9_fcall *tc, *rc;
 	struct p9_client *clnt;

 	P9_DPRINTK(P9_DEBUG_9P, "fid %d\n", fid->fid);
 	err = 0;
 	tc = NULL;
 	rc = NULL;
 	clnt = fid->clnt;

 	tc = p9_create_tremove(fid->fid);
 	if (IS_ERR(tc)) {
 		err = PTR_ERR(tc);
 		tc = NULL;
 		goto done;
 	}

 	err = p9_conn_rpc(clnt->conn, tc, &rc);
 	if (err)
 		goto done;

 	p9_fid_destroy(fid);

 done:
 	kfree(tc);
 	kfree(rc);
 	return err;
 }
 EXPORT_SYMBOL(p9_client_remove);

 int p9_client_read(struct p9_fid *fid, char *data, u64 offset, u32 count)
 {
 	int err, n, rsize, total;
 	struct p9_fcall *tc, *rc;
 	struct p9_client *clnt;

 	P9_DPRINTK(P9_DEBUG_9P, "fid %d offset %llu %d\n", fid->fid,
 					(long long unsigned) offset, count);
 	err = 0;
 	tc = NULL;
 	rc = NULL;
 	clnt = fid->clnt;
 	total = 0;

 	rsize = fid->iounit;
 	if (!rsize || rsize > clnt->msize-P9_IOHDRSZ)
 		rsize = clnt->msize - P9_IOHDRSZ;

 	do {
 		if (count < rsize)
 			rsize = count;

 		tc = p9_create_tread(fid->fid, offset, rsize);
 		if (IS_ERR(tc)) {
 			err = PTR_ERR(tc);
 			tc = NULL;
 			goto error;
 		}

 		err = p9_conn_rpc(clnt->conn, tc, &rc);
 		if (err)
 			goto error;

 		n = rc->params.rread.count;
 		if (n > count)
 			n = count;

 		memmove(data, rc->params.rread.data, n);
 		count -= n;
 		data += n;
 		offset += n;
 		total += n;
 		kfree(tc);
 		tc = NULL;
 		kfree(rc);
 		rc = NULL;
 	} while (count > 0 && n == rsize);

 	return total;

 error:
 	kfree(tc);
 	kfree(rc);
 	return err;
 }
 EXPORT_SYMBOL(p9_client_read);

 int p9_client_write(struct p9_fid *fid, char *data, u64 offset, u32 count)
 {
 	int err, n, rsize, total;
 	struct p9_fcall *tc, *rc;
 	struct p9_client *clnt;

 	P9_DPRINTK(P9_DEBUG_9P, "fid %d offset %llu count %d\n", fid->fid,
 					(long long unsigned) offset, count);
 	err = 0;
 	tc = NULL;
 	rc = NULL;
 	clnt = fid->clnt;
 	total = 0;

 	rsize = fid->iounit;
 	if (!rsize || rsize > clnt->msize-P9_IOHDRSZ)
 		rsize = clnt->msize - P9_IOHDRSZ;

 	do {
 		if (count < rsize)
 			rsize = count;

 		tc = p9_create_twrite(fid->fid, offset, rsize, data);
 		if (IS_ERR(tc)) {
 			err = PTR_ERR(tc);
 			tc = NULL;
 			goto error;
 		}

 		err = p9_conn_rpc(clnt->conn, tc, &rc);
 		if (err)
 			goto error;

 		n = rc->params.rread.count;
 		count -= n;
 		data += n;
 		offset += n;
 		total += n;
 		kfree(tc);
 		tc = NULL;
 		kfree(rc);
 		rc = NULL;
 	} while (count > 0);

 	return total;

 error:
 	kfree(tc);
 	kfree(rc);
 	return err;
 }
 EXPORT_SYMBOL(p9_client_write);

 int
 p9_client_uread(struct p9_fid *fid, char __user *data, u64 offset, u32 count)
 {
 	int err, n, rsize, total;
 	struct p9_fcall *tc, *rc;
 	struct p9_client *clnt;

 	P9_DPRINTK(P9_DEBUG_9P, "fid %d offset %llu count %d\n", fid->fid,
 					(long long unsigned) offset, count);
 	err = 0;
 	tc = NULL;
 	rc = NULL;
 	clnt = fid->clnt;
 	total = 0;

 	rsize = fid->iounit;
 	if (!rsize || rsize > clnt->msize-P9_IOHDRSZ)
 		rsize = clnt->msize - P9_IOHDRSZ;

 	do {
 		if (count < rsize)
 			rsize = count;

 		tc = p9_create_tread(fid->fid, offset, rsize);
 		if (IS_ERR(tc)) {
 			err = PTR_ERR(tc);
 			tc = NULL;
 			goto error;
 		}

 		err = p9_conn_rpc(clnt->conn, tc, &rc);
 		if (err)
 			goto error;

 		n = rc->params.rread.count;
 		if (n > count)
 			n = count;

 		err = copy_to_user(data, rc->params.rread.data, n);
 		if (err) {
 			err = -EFAULT;
 			goto error;
 		}

 		count -= n;
 		data += n;
 		offset += n;
 		total += n;
 		kfree(tc);
 		tc = NULL;
 		kfree(rc);
 		rc = NULL;
 	} while (count > 0 && n == rsize);

 	return total;

 error:
 	kfree(tc);
 	kfree(rc);
 	return err;
 }
 EXPORT_SYMBOL(p9_client_uread);

 int
 p9_client_uwrite(struct p9_fid *fid, const char __user *data, u64 offset,
 								   u32 count)
 {
 	int err, n, rsize, total;
 	struct p9_fcall *tc, *rc;
 	struct p9_client *clnt;

 	P9_DPRINTK(P9_DEBUG_9P, "fid %d offset %llu count %d\n", fid->fid,
 					(long long unsigned) offset, count);
 	err = 0;
 	tc = NULL;
 	rc = NULL;
 	clnt = fid->clnt;
 	total = 0;

 	rsize = fid->iounit;
 	if (!rsize || rsize > clnt->msize-P9_IOHDRSZ)
 		rsize = clnt->msize - P9_IOHDRSZ;

 	do {
 		if (count < rsize)
 			rsize = count;

 		tc = p9_create_twrite_u(fid->fid, offset, rsize, data);
 		if (IS_ERR(tc)) {
 			err = PTR_ERR(tc);
 			tc = NULL;
 			goto error;
 		}

 		err = p9_conn_rpc(clnt->conn, tc, &rc);
 		if (err)
 			goto error;

 		n = rc->params.rread.count;
 		count -= n;
 		data += n;
 		offset += n;
 		total += n;
 		kfree(tc);
 		tc = NULL;
 		kfree(rc);
 		rc = NULL;
 	} while (count > 0);

 	return total;

 error:
 	kfree(tc);
 	kfree(rc);
 	return err;
 }
 EXPORT_SYMBOL(p9_client_uwrite);

 int p9_client_readn(struct p9_fid *fid, char *data, u64 offset, u32 count)
 {
 	int n, total;

 	P9_DPRINTK(P9_DEBUG_9P, "fid %d offset %llu count %d\n", fid->fid,
 					(long long unsigned) offset, count);
 	n = 0;
 	total = 0;
 	while (count) {
 		n = p9_client_read(fid, data, offset, count);
 		if (n <= 0)
 			break;

 		data += n;
 		offset += n;
 		count -= n;
 		total += n;
 	}

 	if (n < 0)
 		total = n;

 	return total;
 }
 EXPORT_SYMBOL(p9_client_readn);

 struct p9_stat *p9_client_stat(struct p9_fid *fid)
 {
 	int err;
 	struct p9_fcall *tc, *rc;
 	struct p9_client *clnt;
 	struct p9_stat *ret;

 	P9_DPRINTK(P9_DEBUG_9P, "fid %d\n", fid->fid);
 	err = 0;
 	tc = NULL;
 	rc = NULL;
 	ret = NULL;
 	clnt = fid->clnt;

 	tc = p9_create_tstat(fid->fid);
 	if (IS_ERR(tc)) {
 		err = PTR_ERR(tc);
 		tc = NULL;
 		goto error;
 	}

 	err = p9_conn_rpc(clnt->conn, tc, &rc);
 	if (err)
 		goto error;

 	ret = p9_clone_stat(&rc->params.rstat.stat, clnt->dotu);
 	if (IS_ERR(ret)) {
 		err = PTR_ERR(ret);
 		ret = NULL;
 		goto error;
 	}

 	kfree(tc);
 	kfree(rc);
 	return ret;

 error:
 	kfree(tc);
 	kfree(rc);
 	kfree(ret);
 	return ERR_PTR(err);
 }
 EXPORT_SYMBOL(p9_client_stat);

 int p9_client_wstat(struct p9_fid *fid, struct p9_wstat *wst)
 {
 	int err;
 	struct p9_fcall *tc, *rc;
 	struct p9_client *clnt;

 	P9_DPRINTK(P9_DEBUG_9P, "fid %d\n", fid->fid);
 	err = 0;
 	tc = NULL;
 	rc = NULL;
 	clnt = fid->clnt;

 	tc = p9_create_twstat(fid->fid, wst, clnt->dotu);
 	if (IS_ERR(tc)) {
 		err = PTR_ERR(tc);
 		tc = NULL;
 		goto done;
 	}

 	err = p9_conn_rpc(clnt->conn, tc, &rc);

 done:
 	kfree(tc);
 	kfree(rc);
 	return err;
 }
 EXPORT_SYMBOL(p9_client_wstat);

 struct p9_stat *p9_client_dirread(struct p9_fid *fid, u64 offset)
 {
 	int err, n, m;
 	struct p9_fcall *tc, *rc;
 	struct p9_client *clnt;
 	struct p9_stat st, *ret;

 	P9_DPRINTK(P9_DEBUG_9P, "fid %d offset %llu\n", fid->fid,
 						(long long unsigned) offset);
 	err = 0;
 	tc = NULL;
 	rc = NULL;
 	ret = NULL;
 	clnt = fid->clnt;

 	/* if the offset is below or above the current response, free it */
 	if (offset < fid->rdir_fpos || (fid->rdir_fcall &&
 		offset >= fid->rdir_fpos+fid->rdir_fcall->params.rread.count)) {
 		fid->rdir_pos = 0;
 		if (fid->rdir_fcall)
 			fid->rdir_fpos += fid->rdir_fcall->params.rread.count;

 		kfree(fid->rdir_fcall);
 		fid->rdir_fcall = NULL;
 		if (offset < fid->rdir_fpos)
 			fid->rdir_fpos = 0;
 	}

 	if (!fid->rdir_fcall) {
 		n = fid->iounit;
 		if (!n || n > clnt->msize-P9_IOHDRSZ)
 			n = clnt->msize - P9_IOHDRSZ;

 		while (1) {
 			if (fid->rdir_fcall) {
 				fid->rdir_fpos +=
 					fid->rdir_fcall->params.rread.count;
 				kfree(fid->rdir_fcall);
 				fid->rdir_fcall = NULL;
 			}

 			tc = p9_create_tread(fid->fid, fid->rdir_fpos, n);
 			if (IS_ERR(tc)) {
 				err = PTR_ERR(tc);
 				tc = NULL;
 				goto error;
 			}

 			err = p9_conn_rpc(clnt->conn, tc, &rc);
 			if (err)
 				goto error;

 			n = rc->params.rread.count;
 			if (n == 0)
 				goto done;

 			fid->rdir_fcall = rc;
 			rc = NULL;
 			if (offset >= fid->rdir_fpos &&
 						offset < fid->rdir_fpos+n)
 				break;
 		}

 		fid->rdir_pos = 0;
 	}

 	m = offset - fid->rdir_fpos;
 	if (m < 0)
 		goto done;

 	n = p9_deserialize_stat(fid->rdir_fcall->params.rread.data + m,
 		fid->rdir_fcall->params.rread.count - m, &st, clnt->dotu);

 	if (!n) {
 		err = -EIO;
 		goto error;
 	}

 	fid->rdir_pos += n;
 	st.size = n;
 	ret = p9_clone_stat(&st, clnt->dotu);
 	if (IS_ERR(ret)) {
 		err = PTR_ERR(ret);
 		ret = NULL;
 		goto error;
 	}

 done:
 	kfree(tc);
 	kfree(rc);
 	return ret;

 error:
 	kfree(tc);
 	kfree(rc);
 	kfree(ret);
 	return ERR_PTR(err);
 }
 EXPORT_SYMBOL(p9_client_dirread);

 static struct p9_stat *p9_clone_stat(struct p9_stat *st, int dotu)
 {
 	int n;
 	char *p;
 	struct p9_stat *ret;

 	n = sizeof(struct p9_stat) + st->name.len + st->uid.len + st->gid.len +
 		st->muid.len;

 	if (dotu)
 		n += st->extension.len;

 	ret = kmalloc(n, GFP_KERNEL);
 	if (!ret)
 		return ERR_PTR(-ENOMEM);

 	memmove(ret, st, sizeof(struct p9_stat));
 	p = ((char *) ret) + sizeof(struct p9_stat);
 	memmove(p, st->name.str, st->name.len);
 	p += st->name.len;
 	memmove(p, st->uid.str, st->uid.len);
 	p += st->uid.len;
 	memmove(p, st->gid.str, st->gid.len);
 	p += st->gid.len;
 	memmove(p, st->muid.str, st->muid.len);
 	p += st->muid.len;

 	if (dotu) {
 		memmove(p, st->extension.str, st->extension.len);
 		p += st->extension.len;
 	}

 	return ret;
 }

 static struct p9_fid *p9_fid_create(struct p9_client *clnt)
 {
 	int err;
 	struct p9_fid *fid;

 	P9_DPRINTK(P9_DEBUG_9P, "clnt %p\n", clnt);
 	fid = kmalloc(sizeof(struct p9_fid), GFP_KERNEL);
 	if (!fid)
 		return ERR_PTR(-ENOMEM);

 	fid->fid = p9_idpool_get(clnt->fidpool);
 	if (fid->fid < 0) {
 		err = -ENOSPC;
 		goto error;
 	}

 	memset(&fid->qid, 0, sizeof(struct p9_qid));
 	fid->mode = -1;
 	fid->rdir_fpos = 0;
 	fid->rdir_pos = 0;
 	fid->rdir_fcall = NULL;
 	fid->uid = current->fsuid;
 	fid->clnt = clnt;
 	fid->aux = NULL;

 	spin_lock(&clnt->lock);
 	list_add(&fid->flist, &clnt->fidlist);
 	spin_unlock(&clnt->lock);

 	return fid;

 error:
 	kfree(fid);
 	return ERR_PTR(err);
 }

 static void p9_fid_destroy(struct p9_fid *fid)
 {
 	struct p9_client *clnt;

 	P9_DPRINTK(P9_DEBUG_9P, "fid %d\n", fid->fid);
 	clnt = fid->clnt;
 	p9_idpool_put(fid->fid, clnt->fidpool);
 	spin_lock(&clnt->lock);
 	list_del(&fid->flist);
 	spin_unlock(&clnt->lock);
 	kfree(fid->rdir_fcall);
 	kfree(fid);
 }
	/*
	* net/9p/clnt.c
	*
	* 9P Client
	*
	* Copyright (C) 2007 by Latchesar Ionkov <lucho@ionkov.net>
	*
	* This program is free software; you can redistribute it and/or modify
	* it under the terms of the GNU General Public License version 2
	* as published by the Free Software Foundation.
	*
	* This program is distributed in the hope that it will be useful,
	* but WITHOUT ANY WARRANTY; without even the implied warranty of
	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
	* GNU General Public License for more details.
	*
	* You should have received a copy of the GNU General Public License
	* along with this program; if not, write to:
	* Free Software Foundation
	* 51 Franklin Street, Fifth Floor
	* Boston, MA 02111-1301 USA
	*
	*/

	#include <linux/module.h>
	#include <linux/errno.h>
	#include <linux/fs.h>
	#include <linux/idr.h>
	#include <linux/mutex.h>
	#include <linux/sched.h>
	#include <linux/uaccess.h>
	#include <net/9p/9p.h>
	#include <net/9p/transport.h>
	#include <net/9p/conn.h>
	#include <net/9p/client.h>

	static struct p9_fid p9_fid_create(struct p9_client clnt);
	static void p9_fid_destroy(struct p9_fid *fid);
	static struct p9_stat p9_clone_stat(struct p9_stat st, int dotu);

	struct p9_client p9_client_create(struct p9_transport trans, int msize,
	int dotu)
	{
	int err, n;
	struct p9_client *clnt;
	struct p9_fcall tc, rc;
	struct p9_str *version;

	err = 0;
	tc = NULL;
	rc = NULL;
	clnt = kmalloc(sizeof(struct p9_client), GFP_KERNEL);
	if (!clnt)
	return ERR_PTR(-ENOMEM);

	P9_DPRINTK(P9_DEBUG_9P, "clnt %p trans %p msize %d dotu %d\n",
	clnt, trans, msize, dotu);
	spin_lock_init(&clnt->lock);
	clnt->trans = trans;
	clnt->msize = msize;
	clnt->dotu = dotu;
	INIT_LIST_HEAD(&clnt->fidlist);
	clnt->fidpool = p9_idpool_create();
	if (!clnt->fidpool) {
	err = PTR_ERR(clnt->fidpool);
	clnt->fidpool = NULL;
	goto error;
	}

	clnt->conn = p9_conn_create(clnt->trans, clnt->msize, &clnt->dotu);
	if (IS_ERR(clnt->conn)) {
	err = PTR_ERR(clnt->conn);
	clnt->conn = NULL;
	goto error;
	}

	tc = p9_create_tversion(clnt->msize, clnt->dotu?"9P2000.u":"9P2000");
	if (IS_ERR(tc)) {
	err = PTR_ERR(tc);
	tc = NULL;
	goto error;
	}

	err = p9_conn_rpc(clnt->conn, tc, &rc);
	if (err)
	goto error;

	version = &rc->params.rversion.version;
	if (version->len == 8 && !memcmp(version->str, "9P2000.u", 8))
	clnt->dotu = 1;
	else if (version->len == 6 && !memcmp(version->str, "9P2000", 6))
	clnt->dotu = 0;
	else {
	err = -EREMOTEIO;
	goto error;
	}

	n = rc->params.rversion.msize;
	if (n < clnt->msize)
	clnt->msize = n;

	kfree(tc);
	kfree(rc);
	return clnt;

	error:
	kfree(tc);
	kfree(rc);
	p9_client_destroy(clnt);
	return ERR_PTR(err);
	}
	EXPORT_SYMBOL(p9_client_create);

	void p9_client_destroy(struct p9_client *clnt)
	{
	struct p9_fid fid, fidptr;

	P9_DPRINTK(P9_DEBUG_9P, "clnt %p\n", clnt);
	if (clnt->conn) {
	p9_conn_destroy(clnt->conn);
	clnt->conn = NULL;
	}

	if (clnt->trans) {
	clnt->trans->close(clnt->trans);
	kfree(clnt->trans);
	clnt->trans = NULL;
	}

	list_for_each_entry_safe(fid, fidptr, &clnt->fidlist, flist)
	p9_fid_destroy(fid);

	if (clnt->fidpool)
	p9_idpool_destroy(clnt->fidpool);

	kfree(clnt);
	}
	EXPORT_SYMBOL(p9_client_destroy);

	void p9_client_disconnect(struct p9_client *clnt)
	{
	P9_DPRINTK(P9_DEBUG_9P, "clnt %p\n", clnt);
	clnt->trans->status = Disconnected;
	p9_conn_cancel(clnt->conn, -EIO);
	}
	EXPORT_SYMBOL(p9_client_disconnect);

	struct p9_fid p9_client_attach(struct p9_client clnt, struct p9_fid *afid,
	char uname, char aname)
	{
	int err;
	struct p9_fcall tc, rc;
	struct p9_fid *fid;

	P9_DPRINTK(P9_DEBUG_9P, "clnt %p afid %d uname %s aname %s\n",
	clnt, afid?afid->fid:-1, uname, aname);
	err = 0;
	tc = NULL;
	rc = NULL;

	fid = p9_fid_create(clnt);
	if (IS_ERR(fid)) {
	err = PTR_ERR(fid);
	fid = NULL;
	goto error;
	}

	tc = p9_create_tattach(fid->fid, afid?afid->fid:P9_NOFID, uname, aname);
	if (IS_ERR(tc)) {
	err = PTR_ERR(tc);
	tc = NULL;
	goto error;
	}

	err = p9_conn_rpc(clnt->conn, tc, &rc);
	if (err)
	goto error;

	memmove(&fid->qid, &rc->params.rattach.qid, sizeof(struct p9_qid));
	kfree(tc);
	kfree(rc);
	return fid;

	error:
	kfree(tc);
	kfree(rc);
	if (fid)
	p9_fid_destroy(fid);
	return ERR_PTR(err);
	}
	EXPORT_SYMBOL(p9_client_attach);

	struct p9_fid p9_client_auth(struct p9_client clnt, char uname, char aname)
	{
	int err;
	struct p9_fcall tc, rc;
	struct p9_fid *fid;

	P9_DPRINTK(P9_DEBUG_9P, "clnt %p uname %s aname %s\n", clnt, uname,
	aname);
	err = 0;
	tc = NULL;
	rc = NULL;

	fid = p9_fid_create(clnt);
	if (IS_ERR(fid)) {
	err = PTR_ERR(fid);
	fid = NULL;
	goto error;
	}

	tc = p9_create_tauth(fid->fid, uname, aname);
	if (IS_ERR(tc)) {
	err = PTR_ERR(tc);
	tc = NULL;
	goto error;
	}

	err = p9_conn_rpc(clnt->conn, tc, &rc);
	if (err)
	goto error;

	memmove(&fid->qid, &rc->params.rauth.qid, sizeof(struct p9_qid));
	kfree(tc);
	kfree(rc);
	return fid;

	error:
	kfree(tc);
	kfree(rc);
	if (fid)
	p9_fid_destroy(fid);
	return ERR_PTR(err);
	}
	EXPORT_SYMBOL(p9_client_auth);

	struct p9_fid p9_client_walk(struct p9_fid oldfid, int nwname, char **wnames,
	int clone)
	{
	int err;
	struct p9_fcall tc, rc;
	struct p9_client *clnt;
	struct p9_fid *fid;

	P9_DPRINTK(P9_DEBUG_9P, "fid %d nwname %d wname[0] %s\n",
	oldfid->fid, nwname, wnames?wnames[0]:NULL);
	err = 0;
	tc = NULL;
	rc = NULL;
	clnt = oldfid->clnt;
	if (clone) {
	fid = p9_fid_create(clnt);
	if (IS_ERR(fid)) {
	err = PTR_ERR(fid);
	fid = NULL;
	goto error;
	}

	fid->uid = oldfid->uid;
	} else
	fid = oldfid;

	tc = p9_create_twalk(oldfid->fid, fid->fid, nwname, wnames);
	if (IS_ERR(tc)) {
	err = PTR_ERR(tc);
	tc = NULL;
	goto error;
	}

	err = p9_conn_rpc(clnt->conn, tc, &rc);
	if (err) {
	if (rc && rc->id == P9_RWALK)
	goto clunk_fid;
	else
	goto error;
	}

	if (rc->params.rwalk.nwqid != nwname) {
	err = -ENOENT;
	goto clunk_fid;
	}

	if (nwname)
	memmove(&fid->qid,
	&rc->params.rwalk.wqids[rc->params.rwalk.nwqid - 1],
	sizeof(struct p9_qid));
	else
	fid->qid = oldfid->qid;

	kfree(tc);
	kfree(rc);
	return fid;

	clunk_fid:
	kfree(tc);
	kfree(rc);
	rc = NULL;
	tc = p9_create_tclunk(fid->fid);
	if (IS_ERR(tc)) {
	err = PTR_ERR(tc);
	tc = NULL;
	goto error;
	}

	p9_conn_rpc(clnt->conn, tc, &rc);

	error:
	kfree(tc);
	kfree(rc);
	if (fid && (fid != oldfid))
	p9_fid_destroy(fid);

	return ERR_PTR(err);
	}
	EXPORT_SYMBOL(p9_client_walk);

	int p9_client_open(struct p9_fid *fid, int mode)
	{
	int err;
	struct p9_fcall tc, rc;
	struct p9_client *clnt;

	P9_DPRINTK(P9_DEBUG_9P, "fid %d mode %d\n", fid->fid, mode);
	err = 0;
	tc = NULL;
	rc = NULL;
	clnt = fid->clnt;

	if (fid->mode != -1)
	return -EINVAL;

	tc = p9_create_topen(fid->fid, mode);
	if (IS_ERR(tc)) {
	err = PTR_ERR(tc);
	tc = NULL;
	goto done;
	}

	err = p9_conn_rpc(clnt->conn, tc, &rc);
	if (err)
	goto done;

	fid->mode = mode;
	fid->iounit = rc->params.ropen.iounit;

	done:
	kfree(tc);
	kfree(rc);
	return err;
	}
	EXPORT_SYMBOL(p9_client_open);

	int p9_client_fcreate(struct p9_fid fid, char name, u32 perm, int mode,
	char *extension)
	{
	int err;
	struct p9_fcall tc, rc;
	struct p9_client *clnt;

	P9_DPRINTK(P9_DEBUG_9P, "fid %d name %s perm %d mode %d\n", fid->fid,
	name, perm, mode);
	err = 0;
	tc = NULL;
	rc = NULL;
	clnt = fid->clnt;

	if (fid->mode != -1)
	return -EINVAL;

	tc = p9_create_tcreate(fid->fid, name, perm, mode, extension,
	clnt->dotu);
	if (IS_ERR(tc)) {
	err = PTR_ERR(tc);
	tc = NULL;
	goto done;
	}

	err = p9_conn_rpc(clnt->conn, tc, &rc);
	if (err)
	goto done;

	fid->mode = mode;
	fid->iounit = rc->params.ropen.iounit;

	done:
	kfree(tc);
	kfree(rc);
	return err;
	}
	EXPORT_SYMBOL(p9_client_fcreate);

	int p9_client_clunk(struct p9_fid *fid)
	{
	int err;
	struct p9_fcall tc, rc;
	struct p9_client *clnt;

	P9_DPRINTK(P9_DEBUG_9P, "fid %d\n", fid->fid);
	err = 0;
	tc = NULL;
	rc = NULL;
	clnt = fid->clnt;

	tc = p9_create_tclunk(fid->fid);
	if (IS_ERR(tc)) {
	err = PTR_ERR(tc);
	tc = NULL;
	goto done;
	}

	err = p9_conn_rpc(clnt->conn, tc, &rc);
	if (err)
	goto done;

	p9_fid_destroy(fid);

	done:
	kfree(tc);
	kfree(rc);
	return err;
	}
	EXPORT_SYMBOL(p9_client_clunk);

	int p9_client_remove(struct p9_fid *fid)
	{
	int err;
	struct p9_fcall tc, rc;
	struct p9_client *clnt;

	P9_DPRINTK(P9_DEBUG_9P, "fid %d\n", fid->fid);
	err = 0;
	tc = NULL;
	rc = NULL;
	clnt = fid->clnt;

	tc = p9_create_tremove(fid->fid);
	if (IS_ERR(tc)) {
	err = PTR_ERR(tc);
	tc = NULL;
	goto done;
	}

	err = p9_conn_rpc(clnt->conn, tc, &rc);
	if (err)
	goto done;

	p9_fid_destroy(fid);

	done:
	kfree(tc);
	kfree(rc);
	return err;
	}
	EXPORT_SYMBOL(p9_client_remove);

	int p9_client_read(struct p9_fid fid, char data, u64 offset, u32 count)
	{
	int err, n, rsize, total;
	struct p9_fcall tc, rc;
	struct p9_client *clnt;

	P9_DPRINTK(P9_DEBUG_9P, "fid %d offset %llu %d\n", fid->fid,
	(long long unsigned) offset, count);
	err = 0;
	tc = NULL;
	rc = NULL;
	clnt = fid->clnt;
	total = 0;

	rsize = fid->iounit;
	if (!rsize \|\| rsize > clnt->msize-P9_IOHDRSZ)
	rsize = clnt->msize - P9_IOHDRSZ;

	do {
	if (count < rsize)
	rsize = count;

	tc = p9_create_tread(fid->fid, offset, rsize);
	if (IS_ERR(tc)) {
	err = PTR_ERR(tc);
	tc = NULL;
	goto error;
	}

	err = p9_conn_rpc(clnt->conn, tc, &rc);
	if (err)
	goto error;

	n = rc->params.rread.count;
	if (n > count)
	n = count;

	memmove(data, rc->params.rread.data, n);
	count -= n;
	data += n;
	offset += n;
	total += n;
	kfree(tc);
	tc = NULL;
	kfree(rc);
	rc = NULL;
	} while (count > 0 && n == rsize);

	return total;

	error:
	kfree(tc);
	kfree(rc);
	return err;
	}
	EXPORT_SYMBOL(p9_client_read);

	int p9_client_write(struct p9_fid fid, char data, u64 offset, u32 count)
	{
	int err, n, rsize, total;
	struct p9_fcall tc, rc;
	struct p9_client *clnt;

	P9_DPRINTK(P9_DEBUG_9P, "fid %d offset %llu count %d\n", fid->fid,
	(long long unsigned) offset, count);
	err = 0;
	tc = NULL;
	rc = NULL;
	clnt = fid->clnt;
	total = 0;

	rsize = fid->iounit;
	if (!rsize \|\| rsize > clnt->msize-P9_IOHDRSZ)
	rsize = clnt->msize - P9_IOHDRSZ;

	do {
	if (count < rsize)
	rsize = count;

	tc = p9_create_twrite(fid->fid, offset, rsize, data);
	if (IS_ERR(tc)) {
	err = PTR_ERR(tc);
	tc = NULL;
	goto error;
	}

	err = p9_conn_rpc(clnt->conn, tc, &rc);
	if (err)
	goto error;

	n = rc->params.rread.count;
	count -= n;
	data += n;
	offset += n;
	total += n;
	kfree(tc);
	tc = NULL;
	kfree(rc);
	rc = NULL;
	} while (count > 0);

	return total;

	error:
	kfree(tc);
	kfree(rc);
	return err;
	}
	EXPORT_SYMBOL(p9_client_write);

	int
	p9_client_uread(struct p9_fid fid, char __user data, u64 offset, u32 count)
	{
	int err, n, rsize, total;
	struct p9_fcall tc, rc;
	struct p9_client *clnt;

	P9_DPRINTK(P9_DEBUG_9P, "fid %d offset %llu count %d\n", fid->fid,
	(long long unsigned) offset, count);
	err = 0;
	tc = NULL;
	rc = NULL;
	clnt = fid->clnt;
	total = 0;

	rsize = fid->iounit;
	if (!rsize \|\| rsize > clnt->msize-P9_IOHDRSZ)
	rsize = clnt->msize - P9_IOHDRSZ;

	do {
	if (count < rsize)
	rsize = count;

	tc = p9_create_tread(fid->fid, offset, rsize);
	if (IS_ERR(tc)) {
	err = PTR_ERR(tc);
	tc = NULL;
	goto error;
	}

	err = p9_conn_rpc(clnt->conn, tc, &rc);
	if (err)
	goto error;

	n = rc->params.rread.count;
	if (n > count)
	n = count;

	err = copy_to_user(data, rc->params.rread.data, n);
	if (err) {
	err = -EFAULT;
	goto error;
	}

	count -= n;
	data += n;
	offset += n;
	total += n;
	kfree(tc);
	tc = NULL;
	kfree(rc);
	rc = NULL;
	} while (count > 0 && n == rsize);

	return total;

	error:
	kfree(tc);
	kfree(rc);
	return err;
	}
	EXPORT_SYMBOL(p9_client_uread);

	int
	p9_client_uwrite(struct p9_fid fid, const char __user data, u64 offset,
	u32 count)
	{
	int err, n, rsize, total;
	struct p9_fcall tc, rc;
	struct p9_client *clnt;

	P9_DPRINTK(P9_DEBUG_9P, "fid %d offset %llu count %d\n", fid->fid,
	(long long unsigned) offset, count);
	err = 0;
	tc = NULL;
	rc = NULL;
	clnt = fid->clnt;
	total = 0;

	rsize = fid->iounit;
	if (!rsize \|\| rsize > clnt->msize-P9_IOHDRSZ)
	rsize = clnt->msize - P9_IOHDRSZ;

	do {
	if (count < rsize)
	rsize = count;

	tc = p9_create_twrite_u(fid->fid, offset, rsize, data);
	if (IS_ERR(tc)) {
	err = PTR_ERR(tc);
	tc = NULL;
	goto error;
	}

	err = p9_conn_rpc(clnt->conn, tc, &rc);
	if (err)
	goto error;

	n = rc->params.rread.count;
	count -= n;
	data += n;
	offset += n;
	total += n;
	kfree(tc);
	tc = NULL;
	kfree(rc);
	rc = NULL;
	} while (count > 0);

	return total;

	error:
	kfree(tc);
	kfree(rc);
	return err;
	}
	EXPORT_SYMBOL(p9_client_uwrite);

	int p9_client_readn(struct p9_fid fid, char data, u64 offset, u32 count)
	{
	int n, total;

	P9_DPRINTK(P9_DEBUG_9P, "fid %d offset %llu count %d\n", fid->fid,
	(long long unsigned) offset, count);
	n = 0;
	total = 0;
	while (count) {
	n = p9_client_read(fid, data, offset, count);
	if (n <= 0)
	break;

	data += n;
	offset += n;
	count -= n;
	total += n;
	}

	if (n < 0)
	total = n;

	return total;
	}
	EXPORT_SYMBOL(p9_client_readn);

	struct p9_stat p9_client_stat(struct p9_fid fid)
	{
	int err;
	struct p9_fcall tc, rc;
	struct p9_client *clnt;
	struct p9_stat *ret;

	P9_DPRINTK(P9_DEBUG_9P, "fid %d\n", fid->fid);
	err = 0;
	tc = NULL;
	rc = NULL;
	ret = NULL;
	clnt = fid->clnt;

	tc = p9_create_tstat(fid->fid);
	if (IS_ERR(tc)) {
	err = PTR_ERR(tc);
	tc = NULL;
	goto error;
	}

	err = p9_conn_rpc(clnt->conn, tc, &rc);
	if (err)
	goto error;

	ret = p9_clone_stat(&rc->params.rstat.stat, clnt->dotu);
	if (IS_ERR(ret)) {
	err = PTR_ERR(ret);
	ret = NULL;
	goto error;
	}

	kfree(tc);
	kfree(rc);
	return ret;

	error:
	kfree(tc);
	kfree(rc);
	kfree(ret);
	return ERR_PTR(err);
	}
	EXPORT_SYMBOL(p9_client_stat);

	int p9_client_wstat(struct p9_fid fid, struct p9_wstat wst)
	{
	int err;
	struct p9_fcall tc, rc;
	struct p9_client *clnt;

	P9_DPRINTK(P9_DEBUG_9P, "fid %d\n", fid->fid);
	err = 0;
	tc = NULL;
	rc = NULL;
	clnt = fid->clnt;

	tc = p9_create_twstat(fid->fid, wst, clnt->dotu);
	if (IS_ERR(tc)) {
	err = PTR_ERR(tc);
	tc = NULL;
	goto done;
	}

	err = p9_conn_rpc(clnt->conn, tc, &rc);

	done:
	kfree(tc);
	kfree(rc);
	return err;
	}
	EXPORT_SYMBOL(p9_client_wstat);

	struct p9_stat p9_client_dirread(struct p9_fid fid, u64 offset)
	{
	int err, n, m;
	struct p9_fcall tc, rc;
	struct p9_client *clnt;
	struct p9_stat st, *ret;

	P9_DPRINTK(P9_DEBUG_9P, "fid %d offset %llu\n", fid->fid,
	(long long unsigned) offset);
	err = 0;
	tc = NULL;
	rc = NULL;
	ret = NULL;
	clnt = fid->clnt;

	/* if the offset is below or above the current response, free it */
	if (offset < fid->rdir_fpos \|\| (fid->rdir_fcall &&
	offset >= fid->rdir_fpos+fid->rdir_fcall->params.rread.count)) {
	fid->rdir_pos = 0;
	if (fid->rdir_fcall)
	fid->rdir_fpos += fid->rdir_fcall->params.rread.count;

	kfree(fid->rdir_fcall);
	fid->rdir_fcall = NULL;
	if (offset < fid->rdir_fpos)
	fid->rdir_fpos = 0;
	}

	if (!fid->rdir_fcall) {
	n = fid->iounit;
	if (!n \|\| n > clnt->msize-P9_IOHDRSZ)
	n = clnt->msize - P9_IOHDRSZ;

	while (1) {
	if (fid->rdir_fcall) {
	fid->rdir_fpos +=
	fid->rdir_fcall->params.rread.count;
	kfree(fid->rdir_fcall);
	fid->rdir_fcall = NULL;
	}

	tc = p9_create_tread(fid->fid, fid->rdir_fpos, n);
	if (IS_ERR(tc)) {
	err = PTR_ERR(tc);
	tc = NULL;
	goto error;
	}

	err = p9_conn_rpc(clnt->conn, tc, &rc);
	if (err)
	goto error;

	n = rc->params.rread.count;
	if (n == 0)
	goto done;

	fid->rdir_fcall = rc;
	rc = NULL;
	if (offset >= fid->rdir_fpos &&
	offset < fid->rdir_fpos+n)
	break;
	}

	fid->rdir_pos = 0;
	}

	m = offset - fid->rdir_fpos;
	if (m < 0)
	goto done;

	n = p9_deserialize_stat(fid->rdir_fcall->params.rread.data + m,
	fid->rdir_fcall->params.rread.count - m, &st, clnt->dotu);

	if (!n) {
	err = -EIO;
	goto error;
	}

	fid->rdir_pos += n;
	st.size = n;
	ret = p9_clone_stat(&st, clnt->dotu);
	if (IS_ERR(ret)) {
	err = PTR_ERR(ret);
	ret = NULL;
	goto error;
	}

	done:
	kfree(tc);
	kfree(rc);
	return ret;

	error:
	kfree(tc);
	kfree(rc);
	kfree(ret);
	return ERR_PTR(err);
	}
	EXPORT_SYMBOL(p9_client_dirread);

	static struct p9_stat p9_clone_stat(struct p9_stat st, int dotu)
	{
	int n;
	char *p;
	struct p9_stat *ret;

	n = sizeof(struct p9_stat) + st->name.len + st->uid.len + st->gid.len +
	st->muid.len;

	if (dotu)
	n += st->extension.len;

	ret = kmalloc(n, GFP_KERNEL);
	if (!ret)
	return ERR_PTR(-ENOMEM);

	memmove(ret, st, sizeof(struct p9_stat));
	p = ((char *) ret) + sizeof(struct p9_stat);
	memmove(p, st->name.str, st->name.len);
	p += st->name.len;
	memmove(p, st->uid.str, st->uid.len);
	p += st->uid.len;
	memmove(p, st->gid.str, st->gid.len);
	p += st->gid.len;
	memmove(p, st->muid.str, st->muid.len);
	p += st->muid.len;

	if (dotu) {
	memmove(p, st->extension.str, st->extension.len);
	p += st->extension.len;
	}

	return ret;
	}

	static struct p9_fid p9_fid_create(struct p9_client clnt)
	{
	int err;
	struct p9_fid *fid;

	P9_DPRINTK(P9_DEBUG_9P, "clnt %p\n", clnt);
	fid = kmalloc(sizeof(struct p9_fid), GFP_KERNEL);
	if (!fid)
	return ERR_PTR(-ENOMEM);

	fid->fid = p9_idpool_get(clnt->fidpool);
	if (fid->fid < 0) {
	err = -ENOSPC;
	goto error;
	}

	memset(&fid->qid, 0, sizeof(struct p9_qid));
	fid->mode = -1;
	fid->rdir_fpos = 0;
	fid->rdir_pos = 0;
	fid->rdir_fcall = NULL;
	fid->uid = current->fsuid;
	fid->clnt = clnt;
	fid->aux = NULL;

	spin_lock(&clnt->lock);
	list_add(&fid->flist, &clnt->fidlist);
	spin_unlock(&clnt->lock);

	return fid;

	error:
	kfree(fid);
	return ERR_PTR(err);
	}

	static void p9_fid_destroy(struct p9_fid *fid)
	{
	struct p9_client *clnt;

	P9_DPRINTK(P9_DEBUG_9P, "fid %d\n", fid->fid);
	clnt = fid->clnt;
	p9_idpool_put(fid->fid, clnt->fidpool);
	spin_lock(&clnt->lock);
	list_del(&fid->flist);
	spin_unlock(&clnt->lock);
	kfree(fid->rdir_fcall);
	kfree(fid);
	}