ref: e8cf7530517534ccd9f5b0469191aa7c41581120
dir: /sys/src/cmd/9nfs/nfs.c/
#include "all.h" extern uchar buf[]; Xfid * rpc2xfid(Rpccall *cmd, Dir *dp) { char *argptr = cmd->args; Xfile *xp; Xfid *xf; Session *s; char *service; Authunix au; Qid qid; char client[256], *user; Unixidmap *m; int i; uvlong x1, x2; chat("rpc2xfid %.8lux %.8lux %p %p\n", *((ulong*)argptr), *((ulong*)argptr+1), buf, argptr); if(argptr[0] == 0 && argptr[1] == 0){ /* root */ chat("root..."); xp = xfroot(&argptr[2], 0); s = xp ? xp->s : 0; }else{ ulong ul; chat("noroot %.8lux...", *((ulong*)argptr)); if((ul=GLONG()) != starttime){ chat("bad tag %lux %lux...", ul, starttime); return 0; } s = (Session *)GLONG(); x1 = GLONG(); x2 = GLONG(); qid.path = x1 | (x2<<32); qid.vers = 0; qid.type = GBYTE(); xp = xfile(&qid, s, 0); } if(xp == 0){ chat("no xfile..."); return 0; } if(auth2unix(&cmd->cred, &au) != 0){ chat("auth flavor=%ld, count=%ld\n", cmd->cred.flavor, cmd->cred.count); for(i=0; i<cmd->cred.count; i++) chat(" %.2ux", ((uchar *)cmd->cred.data)[i]); chat("..."); return 0; }else{ /* chat("auth: %d %.*s u=%d g=%d", * au.stamp, utfnlen(au.mach.s, au.mach.n), au.mach.s, au.uid, au.gid); * for(i=0; i<au.gidlen; i++) * chat(", %d", au.gids[i]); * chat("..."); */ char *p = memchr(au.mach.s, '.', au.mach.n); chat("%ld@%.*s...", au.uid, utfnlen(au.mach.s, (p ? p-au.mach.s : au.mach.n)), au.mach.s); } if(au.mach.n >= sizeof client){ chat("client name too long..."); return 0; } memcpy(client, au.mach.s, au.mach.n); client[au.mach.n] = 0; service = xp->parent->s->service; cmd->up = m = pair2idmap(service, cmd->host); if(m == 0){ chat("no map for pair (%s,%s)...", service, client); /*chat("getdom %d.%d.%d.%d", cmd->host&0xFF, (cmd->host>>8)&0xFF, (cmd->host>>16)&0xFF, (cmd->host>>24)&0xFF);/**/ /*if(getdom(cmd->host, client, sizeof(client))<0) return 0;/**/ return 0; } /*chat("map=(%s,%s)...", m->server, m->client);/**/ cmd->user = user = id2name(&m->u.ids, au.uid); if(user == 0){ chat("no user for id %ld...", au.uid); return 0; } chat("user=%s...", user);/**/ xf = 0; if(s == xp->parent->s){ if(!s->noauth) xf = setuser(xp, user); if(xf == 0) xf = setuser(xp, "none"); if(xf == 0) chat("can't set user none..."); }else xf = xp->users; if(xf) chat("uid=%s...", xf->uid); if(xf && dp && xfstat(xf, dp) < 0){ chat("can't stat %s...", xp->name); return 0; } return xf; } Xfid * setuser(Xfile *xp, char *user) { Xfid *xf, *xpf; Session *s; xf = xfid(user, xp, 1); if(xf->urfid) return xf; if(xp->parent==xp || !(xpf = setuser(xp->parent, user))) /* assign = */ return xfid(user, xp, -1); s = xp->s; xf->urfid = newfid(s); xf->urfid->owner = &xf->urfid; setfid(s, xpf->urfid); s->f.newfid = xf->urfid - s->fids; s->f.nwname = 1; s->f.wname[0] = xp->name; if(xmesg(s, Twalk) || s->f.nwqid != 1) return xfid(user, xp, -1); return xf; } int xfstat(Xfid *xf, Dir *dp) { Xfile *xp; Session *s; char buf[128]; xp = xf->xp; s = xp->s; if(s != xp->parent->s){ seprint(buf, buf+sizeof buf, "#%s", xf->uid); dp->name = strstore(buf); dp->uid = xf->uid; dp->gid = xf->uid; dp->muid = xf->uid; dp->qid.path = (uvlong)xf->uid; dp->qid.type = QTFILE; dp->qid.vers = 0; dp->mode = 0666; dp->atime = time(0); dp->mtime = dp->atime; dp->length = NETCHLEN; dp->type = 0; dp->type = 0; return 0; } setfid(s, xf->urfid); if(xmesg(s, Tstat) == 0){ convM2D(s->f.stat, s->f.nstat, dp, (char*)s->statbuf); if(xp->qid.path == dp->qid.path){ xp->name = strstore(dp->name); return 0; } /* not reached ? */ chat("xp->qid.path=0x%.16llux, dp->qid.path=0x%.16llux name=%s...", xp->qid.path, dp->qid.path, dp->name); } if(xp != xp->parent) xpclear(xp); else clog("can't stat root: %s", s->f.type == Rerror ? s->f.ename : "??"); return -1; } int xfwstat(Xfid *xf, Dir *dp) { Xfile *xp; Session *s; xp = xf->xp; s = xp->s; /* * xf->urfid can be zero because some DOS NFS clients * try to do wstat on the #user authentication files on close. */ if(s == 0 || xf->urfid == 0) return -1; setfid(s, xf->urfid); s->f.stat = s->statbuf; convD2M(dp, s->f.stat, Maxstatdata); if(xmesg(s, Twstat)) return -1; xp->name = strstore(dp->name); return 0; } int xfopen(Xfid *xf, int flag) { static int modes[] = { [Oread] OREAD, [Owrite] OWRITE, [Oread|Owrite] ORDWR, }; Xfile *xp; Session *s; Fid *opfid; int omode; if(xf->opfid && (xf->mode & flag & Open) == flag) return 0; omode = modes[(xf->mode|flag) & Open]; if(flag & Trunc) omode |= OTRUNC; xp = xf->xp; chat("open(\"%s\", %d)...", xp->name, omode); s = xp->s; opfid = newfid(s); setfid(s, xf->urfid); s->f.newfid = opfid - s->fids; s->f.nwname = 0; if(xmesg(s, Twalk)){ putfid(s, opfid); return -1; } setfid(s, opfid); s->f.mode = omode; if(xmesg(s, Topen)){ clunkfid(s, opfid); return -1; } if(xf->opfid) clunkfid(s, xf->opfid); xf->mode |= flag & Open; xf->opfid = opfid; opfid->owner = &xf->opfid; xf->offset = 0; return 0; } void xfclose(Xfid *xf) { Xfile *xp; if(xf->mode & Open){ xp = xf->xp; chat("close(\"%s\")...", xp->name); if(xf->opfid) clunkfid(xp->s, xf->opfid); xf->mode &= ~Open; xf->opfid = 0; } } void xfclear(Xfid *xf) { Xfile *xp = xf->xp; if(xf->opfid){ clunkfid(xp->s, xf->opfid); xf->opfid = 0; } if(xf->urfid){ clunkfid(xp->s, xf->urfid); xf->urfid = 0; } xfid(xf->uid, xp, -1); } Xfid * xfwalkcr(int type, Xfid *xf, String *elem, long perm) { Session *s; Xfile *xp, *newxp; Xfid *newxf; Fid *nfid; chat("xf%s(\"%s\")...", type==Tcreate ? "create" : "walk", elem->s); xp = xf->xp; s = xp->s; nfid = newfid(s); setfid(s, xf->urfid); s->f.newfid = nfid - s->fids; if(type == Tcreate){ s->f.nwname = 0; if(xmesg(s, Twalk)){ putfid(s, nfid); return 0; } s->f.fid = nfid - s->fids; } if(type == Tcreate){ s->f.name = elem->s; s->f.perm = perm; s->f.mode = (perm&DMDIR) ? OREAD : ORDWR; if(xmesg(s, type)){ clunkfid(s, nfid); return 0; } }else{ /* Twalk */ s->f.nwname = 1; s->f.wname[0] = elem->s; if(xmesg(s, type) || s->f.nwqid!=1){ putfid(s, nfid); return 0; } s->f.qid = s->f.wqid[0]; /* only one element */ } chat("fid=%d,qid=0x%llux,%ld,%.2ux...", s->f.fid, s->f.qid.path, s->f.qid.vers, s->f.qid.type); newxp = xfile(&s->f.qid, s, 1); if(newxp->parent == 0){ chat("new xfile..."); newxp->parent = xp; newxp->sib = xp->child; xp->child = newxp; } newxf = xfid(xf->uid, newxp, 1); if(type == Tcreate){ newxf->mode = (perm&DMDIR) ? Oread : (Oread|Owrite); newxf->opfid = nfid; nfid->owner = &newxf->opfid; nfid = newfid(s); setfid(s, xf->urfid); s->f.newfid = nfid - s->fids; s->f.nwname = 1; s->f.wname[0] = elem->s; if(xmesg(s, Twalk) || s->f.nwqid!=1){ putfid(s, nfid); xpclear(newxp); return 0; } newxf->urfid = nfid; nfid->owner = &newxf->urfid; }else if(newxf->urfid){ chat("old xfid %zd...", newxf->urfid-s->fids); clunkfid(s, nfid); }else{ newxf->urfid = nfid; nfid->owner = &newxf->urfid; } newxp->name = strstore(elem->s); return newxf; } void xpclear(Xfile *xp) { Session *s; Xfid *xf; Xfile *xnp; s = xp->s; while(xf = xp->users) /* assign = */ xfclear(xf); while(xnp = xp->child){ /* assign = */ xp->child = xnp->sib; xnp->parent = 0; xpclear(xnp); xfile(&xnp->qid, s, -1); } if(xnp = xp->parent){ /* assign = */ if(xnp->child == xp) xnp->child = xp->sib; else{ xnp = xnp->child; while(xnp->sib != xp) xnp = xnp->sib; xnp->sib = xp->sib; } xfile(&xp->qid, s, -1); } } int xp2fhandle(Xfile *xp, Fhandle fh) { uchar *dataptr = fh; ulong x; int n; memset(fh, 0, FHSIZE); if(xp == xp->parent){ /* root */ dataptr[0] = 0; dataptr[1] = 0; n = strlen(xp->s->service); if(n > FHSIZE-3) n = FHSIZE-3; memmove(&dataptr[2], xp->s->service, n); dataptr[2+n] = 0; }else{ PLONG(starttime); PLONG((u32int)(uintptr)xp->s); x = xp->qid.path; PLONG(x); x = xp->qid.path>>32; PLONG(x); PBYTE(xp->qid.type); USED(dataptr); } return FHSIZE; } int dir2fattr(Unixidmap *up, Dir *dp, void *mp) { uchar *dataptr = mp; long length; int r; r = dp->mode & 0777; if (dp->mode & DMDIR) length = 1024; else length = dp->length; if((dp->mode & DMDIR) && dp->type == '/' && dp->dev == 0) r |= 0555; if(dp->mode & DMDIR){ PLONG(NFDIR); /* type */ r |= S_IFDIR; PLONG(r); /* mode */ PLONG(3); /* nlink */ }else{ PLONG(NFREG); /* type */ r |= S_IFREG; PLONG(r); /* mode */ PLONG(1); /* nlink */ } r = name2id(&up->u.ids, dp->uid); if(r < 0){ r = name2id(&up->u.ids, "daemon"); if(r < 0) r = 1; } PLONG(r); /* uid */ r = name2id(&up->g.ids, dp->gid); if(r < 0){ r = name2id(&up->g.ids, "user"); if(r < 0) r = 1; } PLONG(r); /* gid */ PLONG(length); /* size */ PLONG(2048); /* blocksize */ PLONG(0); /* rdev */ r = (length+2047)/2048; PLONG(r); /* blocks */ r = (dp->type<<16) | dp->dev; PLONG(r); /* fsid */ PLONG(dp->qid.path); /* fileid */ PLONG(dp->atime); /* atime */ PLONG(0); PLONG(dp->mtime); /* mtime */ PLONG(0); PLONG(dp->mtime); /* ctime */ PLONG(0); return dataptr - (uchar *)mp; } int convM2sattr(void *mp, Sattr *sp) { uchar *argptr = mp; sp->mode = GLONG(); sp->uid = GLONG(); sp->gid = GLONG(); sp->size = GLONG(); sp->atime = GLONG(); sp->ausec = GLONG(); sp->mtime = GLONG(); sp->musec = GLONG(); return argptr - (uchar *)mp; }