123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965 |
- /*
- * 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);
- }
|