3 004aa293 2005-07-13 devnull * - gc of file systems (not going to do just yet?)
4 004aa293 2005-07-13 devnull * - statistics file
5 004aa293 2005-07-13 devnull * - configure on amsterdam
8 004aa293 2005-07-13 devnull #include <u.h>
9 004aa293 2005-07-13 devnull #include <libc.h>
10 004aa293 2005-07-13 devnull #include <bio.h>
11 004aa293 2005-07-13 devnull #include <ip.h>
12 004aa293 2005-07-13 devnull #include <thread.h>
13 004aa293 2005-07-13 devnull #include <libsec.h>
14 004aa293 2005-07-13 devnull #include <sunrpc.h>
15 004aa293 2005-07-13 devnull #include <nfs3.h>
16 004aa293 2005-07-13 devnull #include <diskfs.h>
17 004aa293 2005-07-13 devnull #include <venti.h>
18 004aa293 2005-07-13 devnull #include "nfs3srv.h"
20 004aa293 2005-07-13 devnull #define trace if(!tracecalls){}else print
22 004aa293 2005-07-13 devnull typedef struct Ipokay Ipokay;
23 004aa293 2005-07-13 devnull typedef struct Config Config;
24 004aa293 2005-07-13 devnull typedef struct Ctree Ctree;
25 004aa293 2005-07-13 devnull typedef struct Cnode Cnode;
27 004aa293 2005-07-13 devnull struct Ipokay
29 004aa293 2005-07-13 devnull int okay;
30 004aa293 2005-07-13 devnull uchar ip[IPaddrlen];
31 004aa293 2005-07-13 devnull uchar mask[IPaddrlen];
34 004aa293 2005-07-13 devnull struct Config
36 004aa293 2005-07-13 devnull Ipokay *ok;
37 004aa293 2005-07-13 devnull uint nok;
38 004aa293 2005-07-13 devnull ulong mtime;
39 004aa293 2005-07-13 devnull Ctree *ctree;
42 004aa293 2005-07-13 devnull char *addr;
43 004aa293 2005-07-13 devnull int blocksize;
44 004aa293 2005-07-13 devnull int cachesize;
45 004aa293 2005-07-13 devnull Config config;
46 004aa293 2005-07-13 devnull char *configfile;
47 004aa293 2005-07-13 devnull int encryptedhandles = 1;
48 004aa293 2005-07-13 devnull Channel *nfschan;
49 004aa293 2005-07-13 devnull Channel *mountchan;
50 004aa293 2005-07-13 devnull Channel *timerchan;
51 004aa293 2005-07-13 devnull Nfs3Handle root;
52 004aa293 2005-07-13 devnull SunSrv *srv;
53 004aa293 2005-07-13 devnull int tracecalls;
54 004aa293 2005-07-13 devnull VtCache *vcache;
55 004aa293 2005-07-13 devnull VtConn *z;
57 004aa293 2005-07-13 devnull void cryptinit(void);
58 004aa293 2005-07-13 devnull void timerthread(void*);
59 004aa293 2005-07-13 devnull void timerproc(void*);
61 004aa293 2005-07-13 devnull extern void handleunparse(Fsys*, Nfs3Handle*, Nfs3Handle*, int);
62 004aa293 2005-07-13 devnull extern Nfs3Status handleparse(Nfs3Handle*, Fsys**, Nfs3Handle*, int);
64 004aa293 2005-07-13 devnull Nfs3Status logread(Cnode*, u32int, u64int, uchar**, u32int*, u1int*);
65 004aa293 2005-07-13 devnull Nfs3Status refreshdiskread(Cnode*, u32int, u64int, uchar**, u32int*, u1int*);
66 004aa293 2005-07-13 devnull Nfs3Status refreshconfigread(Cnode*, u32int, u64int, uchar**, u32int*, u1int*);
68 004aa293 2005-07-13 devnull int readconfigfile(Config *cp);
69 004aa293 2005-07-13 devnull void setrootfid(void);
70 004aa293 2005-07-13 devnull int ipokay(uchar *ip, ushort port);
72 2214d4b6 2005-12-30 devnull u64int unittoull(char*);
75 004aa293 2005-07-13 devnull usage(void)
77 004aa293 2005-07-13 devnull fprint(2, "usage: vnfs [-LLRVr] [-a addr] [-b blocksize] [-c cachesize] configfile\n");
78 004aa293 2005-07-13 devnull threadexitsall("usage");
82 004aa293 2005-07-13 devnull threadmain(int argc, char **argv)
84 004aa293 2005-07-13 devnull fmtinstall('B', sunrpcfmt);
85 004aa293 2005-07-13 devnull fmtinstall('C', suncallfmt);
86 004aa293 2005-07-13 devnull fmtinstall('F', vtfcallfmt);
87 004aa293 2005-07-13 devnull fmtinstall('H', encodefmt);
88 004aa293 2005-07-13 devnull fmtinstall('I', eipfmt);
89 004aa293 2005-07-13 devnull fmtinstall('V', vtscorefmt);
90 004aa293 2005-07-13 devnull sunfmtinstall(&nfs3prog);
91 004aa293 2005-07-13 devnull sunfmtinstall(&nfsmount3prog);
93 004aa293 2005-07-13 devnull addr = "udp!*!2049";
94 004aa293 2005-07-13 devnull blocksize = 8192;
95 004aa293 2005-07-13 devnull cachesize = 400;
96 004aa293 2005-07-13 devnull srv = sunsrv();
97 004aa293 2005-07-13 devnull srv->ipokay = ipokay;
98 004aa293 2005-07-13 devnull cryptinit();
100 004aa293 2005-07-13 devnull ARGBEGIN{
101 004aa293 2005-07-13 devnull default:
102 004aa293 2005-07-13 devnull usage();
103 004aa293 2005-07-13 devnull case 'E':
104 004aa293 2005-07-13 devnull encryptedhandles = 0;
106 004aa293 2005-07-13 devnull case 'L':
107 004aa293 2005-07-13 devnull if(srv->localonly == 0)
108 004aa293 2005-07-13 devnull srv->localonly = 1;
110 004aa293 2005-07-13 devnull srv->localparanoia = 1;
112 004aa293 2005-07-13 devnull case 'R':
113 004aa293 2005-07-13 devnull srv->chatty++;
115 004aa293 2005-07-13 devnull case 'T':
116 004aa293 2005-07-13 devnull tracecalls = 1;
118 004aa293 2005-07-13 devnull case 'V':
119 80b4aedc 2006-05-04 devnull if(chattyventi++)
120 80b4aedc 2006-05-04 devnull vttracelevel++;
122 004aa293 2005-07-13 devnull case 'a':
123 004aa293 2005-07-13 devnull addr = EARGF(usage());
125 004aa293 2005-07-13 devnull case 'b':
126 2214d4b6 2005-12-30 devnull blocksize = unittoull(EARGF(usage()));
128 004aa293 2005-07-13 devnull case 'c':
129 2214d4b6 2005-12-30 devnull cachesize = unittoull(EARGF(usage()));
131 004aa293 2005-07-13 devnull case 'r':
132 004aa293 2005-07-13 devnull srv->alwaysreject++;
136 004aa293 2005-07-13 devnull if(argc != 1)
137 004aa293 2005-07-13 devnull usage();
139 004aa293 2005-07-13 devnull if((z = vtdial(nil)) == nil)
140 004aa293 2005-07-13 devnull sysfatal("vtdial: %r");
141 004aa293 2005-07-13 devnull if(vtconnect(z) < 0)
142 004aa293 2005-07-13 devnull sysfatal("vtconnect: %r");
143 34d0c826 2005-07-13 devnull if((vcache = vtcachealloc(z, blocksize, cachesize)) == nil)
144 004aa293 2005-07-13 devnull sysfatal("vtcache: %r");
146 004aa293 2005-07-13 devnull configfile = argv[0];
147 004aa293 2005-07-13 devnull if(readconfigfile(&config) < 0)
148 004aa293 2005-07-13 devnull sysfatal("readConfig: %r");
149 004aa293 2005-07-13 devnull setrootfid();
151 004aa293 2005-07-13 devnull nfschan = chancreate(sizeof(SunMsg*), 0);
152 004aa293 2005-07-13 devnull mountchan = chancreate(sizeof(SunMsg*), 0);
153 004aa293 2005-07-13 devnull timerchan = chancreate(sizeof(void*), 0);
155 004aa293 2005-07-13 devnull if(sunsrvudp(srv, addr) < 0)
156 004aa293 2005-07-13 devnull sysfatal("starting server: %r");
158 004aa293 2005-07-13 devnull sunsrvthreadcreate(srv, nfs3proc, nfschan);
159 004aa293 2005-07-13 devnull sunsrvthreadcreate(srv, mount3proc, mountchan);
160 004aa293 2005-07-13 devnull sunsrvthreadcreate(srv, timerthread, nil);
161 004aa293 2005-07-13 devnull proccreate(timerproc, nil, 32768);
163 004aa293 2005-07-13 devnull sunsrvprog(srv, &nfs3prog, nfschan);
164 004aa293 2005-07-13 devnull sunsrvprog(srv, &nfsmount3prog, mountchan);
166 004aa293 2005-07-13 devnull threadexits(nil);
169 2214d4b6 2005-12-30 devnull #define TWID64 ((u64int)~(u64int)0)
172 2214d4b6 2005-12-30 devnull unittoull(char *s)
174 2214d4b6 2005-12-30 devnull char *es;
175 2214d4b6 2005-12-30 devnull u64int n;
177 2214d4b6 2005-12-30 devnull if(s == nil)
178 2214d4b6 2005-12-30 devnull return TWID64;
179 2214d4b6 2005-12-30 devnull n = strtoul(s, &es, 0);
180 2214d4b6 2005-12-30 devnull if(*es == 'k' || *es == 'K'){
181 2214d4b6 2005-12-30 devnull n *= 1024;
183 2214d4b6 2005-12-30 devnull }else if(*es == 'm' || *es == 'M'){
184 2214d4b6 2005-12-30 devnull n *= 1024*1024;
186 2214d4b6 2005-12-30 devnull }else if(*es == 'g' || *es == 'G'){
187 2214d4b6 2005-12-30 devnull n *= 1024*1024*1024;
189 2214d4b6 2005-12-30 devnull }else if(*es == 't' || *es == 'T'){
190 2214d4b6 2005-12-30 devnull n *= 1024*1024;
191 2214d4b6 2005-12-30 devnull n *= 1024*1024;
193 2214d4b6 2005-12-30 devnull if(*es != '\0')
194 2214d4b6 2005-12-30 devnull return TWID64;
195 2214d4b6 2005-12-30 devnull return n;
199 004aa293 2005-07-13 devnull * Handles.
201 004aa293 2005-07-13 devnull * We store all the state about which file a client is accessing in
202 004aa293 2005-07-13 devnull * the handle, so that we don't have to maintain any per-client state
203 004aa293 2005-07-13 devnull * ourselves. In order to avoid leaking handles or letting clients
204 004aa293 2005-07-13 devnull * create arbitrary handles, we sign and encrypt each handle with
205 004aa293 2005-07-13 devnull * AES using a key selected randomly when the server starts.
206 004aa293 2005-07-13 devnull * Thus, handles cannot be used across sessions.
208 004aa293 2005-07-13 devnull * The decrypted handles begin with the following header:
210 004aa293 2005-07-13 devnull * sessid[8] random session id chosen at start time
211 6884e49f 2006-06-15 devnull * len[4] length of handle that follows
213 004aa293 2005-07-13 devnull * If we're pressed for space in the rest of the handle, we could
214 6884e49f 2006-06-15 devnull * probably reduce the amount of sessid bytes. Note that the sessid
215 6884e49f 2006-06-15 devnull * bytes must be consistent during a run of vnfs, or else some
216 6884e49f 2006-06-15 devnull * clients (e.g., Linux 2.4) eventually notice that successive TLookups
217 6884e49f 2006-06-15 devnull * return different handles, and they return "Stale NFS file handle"
218 6884e49f 2006-06-15 devnull * errors to system calls in response (even though we never sent
219 6884e49f 2006-06-15 devnull * that error!).
221 004aa293 2005-07-13 devnull * Security woes aside, the fact that we have to shove everything
222 004aa293 2005-07-13 devnull * into the handles is quite annoying. We have to encode, in 40 bytes:
224 004aa293 2005-07-13 devnull * - position in the synthesized config tree
225 004aa293 2005-07-13 devnull * - enough of the path to do glob matching
226 004aa293 2005-07-13 devnull * - position in an archived file system image
228 004aa293 2005-07-13 devnull * and the handles need to be stable across changes in the config file
229 004aa293 2005-07-13 devnull * (though not across server restarts since encryption screws
230 004aa293 2005-07-13 devnull * that up nicely).
232 004aa293 2005-07-13 devnull * We encode each of the first two as a 10-byte hash that is
233 004aa293 2005-07-13 devnull * the first half of a SHA1 hash.
238 004aa293 2005-07-13 devnull SessidSize = 8,
239 6884e49f 2006-06-15 devnull HeaderSize = SessidSize+4,
240 cbeb0b26 2006-04-01 devnull MaxHandleSize = Nfs3MaxHandleSize - HeaderSize
243 004aa293 2005-07-13 devnull AESstate aesstate;
244 004aa293 2005-07-13 devnull uchar sessid[SessidSize];
246 004aa293 2005-07-13 devnull static void
247 004aa293 2005-07-13 devnull hencrypt(Nfs3Handle *h)
249 004aa293 2005-07-13 devnull uchar *p;
250 004aa293 2005-07-13 devnull AESstate aes;
253 004aa293 2005-07-13 devnull * root handle has special encryption - a single 0 byte - so that it
254 004aa293 2005-07-13 devnull * never goes stale.
256 004aa293 2005-07-13 devnull if(h->len == root.len && memcmp(h->h, root.h, root.len) == 0){
257 004aa293 2005-07-13 devnull h->h[0] = 0;
258 004aa293 2005-07-13 devnull h->len = 1;
262 004aa293 2005-07-13 devnull if(!encryptedhandles)
265 004aa293 2005-07-13 devnull if(h->len > MaxHandleSize){
266 004aa293 2005-07-13 devnull /* oops */
267 004aa293 2005-07-13 devnull fprint(2, "handle too long: %.*lH\n", h->len, h->h);
268 004aa293 2005-07-13 devnull memset(h->h, 'X', Nfs3MaxHandleSize);
269 004aa293 2005-07-13 devnull h->len = Nfs3MaxHandleSize;
273 004aa293 2005-07-13 devnull p = h->h;
274 004aa293 2005-07-13 devnull memmove(p+HeaderSize, p, h->len);
275 6884e49f 2006-06-15 devnull memmove(p, sessid, SessidSize);
276 6884e49f 2006-06-15 devnull *(u32int*)(p+SessidSize) = h->len;
277 004aa293 2005-07-13 devnull h->len += HeaderSize;
279 004aa293 2005-07-13 devnull if(encryptedhandles){
280 004aa293 2005-07-13 devnull while(h->len < MaxHandleSize)
281 6884e49f 2006-06-15 devnull h->h[h->len++] = 0;
282 004aa293 2005-07-13 devnull aes = aesstate;
283 004aa293 2005-07-13 devnull aesCBCencrypt(h->h, MaxHandleSize, &aes);
287 004aa293 2005-07-13 devnull static Nfs3Status
288 004aa293 2005-07-13 devnull hdecrypt(Nfs3Handle *h)
290 004aa293 2005-07-13 devnull AESstate aes;
292 004aa293 2005-07-13 devnull if(h->len == 1 && h->h[0] == 0){ /* single 0 byte is root */
293 004aa293 2005-07-13 devnull *h = root;
294 004aa293 2005-07-13 devnull return Nfs3Ok;
297 004aa293 2005-07-13 devnull if(!encryptedhandles)
298 004aa293 2005-07-13 devnull return Nfs3Ok;
300 004aa293 2005-07-13 devnull if(h->len <= HeaderSize)
301 004aa293 2005-07-13 devnull return Nfs3ErrBadHandle;
302 004aa293 2005-07-13 devnull if(encryptedhandles){
303 004aa293 2005-07-13 devnull if(h->len != MaxHandleSize)
304 004aa293 2005-07-13 devnull return Nfs3ErrBadHandle;
305 004aa293 2005-07-13 devnull aes = aesstate;
306 004aa293 2005-07-13 devnull aesCBCdecrypt(h->h, h->len, &aes);
308 6884e49f 2006-06-15 devnull if(memcmp(h->h, sessid, SessidSize) != 0)
309 004aa293 2005-07-13 devnull return Nfs3ErrStale; /* give benefit of doubt */
310 6884e49f 2006-06-15 devnull h->len = *(u32int*)(h->h+SessidSize);
311 6884e49f 2006-06-15 devnull if(h->len >= MaxHandleSize-HeaderSize)
312 6884e49f 2006-06-15 devnull return Nfs3ErrBadHandle;
313 004aa293 2005-07-13 devnull memmove(h->h, h->h+HeaderSize, h->len);
314 004aa293 2005-07-13 devnull return Nfs3Ok;
318 004aa293 2005-07-13 devnull cryptinit(void)
320 004aa293 2005-07-13 devnull uchar key[32], ivec[AESbsize];
323 004aa293 2005-07-13 devnull *(u32int*)sessid = truerand();
324 004aa293 2005-07-13 devnull for(i=0; i<nelem(key); i+=4)
325 004aa293 2005-07-13 devnull *(u32int*)&key[i] = truerand();
326 004aa293 2005-07-13 devnull for(i=0; i<nelem(ivec); i++)
327 004aa293 2005-07-13 devnull ivec[i] = fastrand();
328 004aa293 2005-07-13 devnull setupAESstate(&aesstate, key, sizeof key, ivec);
332 004aa293 2005-07-13 devnull * Config file.
334 004aa293 2005-07-13 devnull * The main purpose of the configuration file is to define a tree
335 004aa293 2005-07-13 devnull * in which the archived file system images are mounted.
336 004aa293 2005-07-13 devnull * The tree is stored as Entry structures, defined below.
338 004aa293 2005-07-13 devnull * The configuration file also allows one to define shell-like
339 004aa293 2005-07-13 devnull * glob expressions matching paths that are not to be displayed.
340 004aa293 2005-07-13 devnull * The matched files or directories are shown in directory listings
341 004aa293 2005-07-13 devnull * (could suppress these if we cared) but they cannot be opened,
342 004aa293 2005-07-13 devnull * read, or written, and getattr returns zeroed data.
346 004aa293 2005-07-13 devnull /* sizes used in handles; see nfs server below */
347 004aa293 2005-07-13 devnull CnodeHandleSize = 8,
348 cbeb0b26 2006-04-01 devnull FsysHandleOffset = CnodeHandleSize
352 004aa293 2005-07-13 devnull * Config file tree.
354 004aa293 2005-07-13 devnull struct Ctree
356 004aa293 2005-07-13 devnull Cnode *root;
357 004aa293 2005-07-13 devnull Cnode *hash[1024];
360 004aa293 2005-07-13 devnull struct Cnode
362 004aa293 2005-07-13 devnull char *name; /* path element */
363 004aa293 2005-07-13 devnull Cnode *parent; /* in tree */
364 004aa293 2005-07-13 devnull Cnode *nextsib; /* in tree */
365 004aa293 2005-07-13 devnull Cnode *kidlist; /* in tree */
366 004aa293 2005-07-13 devnull Cnode *nexthash; /* in hash list */
368 004aa293 2005-07-13 devnull Nfs3Status (*read)(Cnode*, u32int, u64int, uchar**, u32int*, u1int*); /* synthesized read fn */
370 004aa293 2005-07-13 devnull uchar handle[VtScoreSize]; /* sha1(path to here) */
371 004aa293 2005-07-13 devnull ulong mtime; /* mtime for this directory entry */
373 004aa293 2005-07-13 devnull /* fsys overlay on this node */
374 004aa293 2005-07-13 devnull Fsys *fsys; /* cache of memory structure */
375 004aa293 2005-07-13 devnull Nfs3Handle fsyshandle;
376 004aa293 2005-07-13 devnull int isblackhole; /* walking down keeps you here */
379 004aa293 2005-07-13 devnull * mount point info.
380 004aa293 2005-07-13 devnull * if a mount point is inside another file system,
381 004aa293 2005-07-13 devnull * the fsys and fsyshandle above have the old fs info,
382 004aa293 2005-07-13 devnull * the mfsys and mfsyshandle below have the new one.
383 004aa293 2005-07-13 devnull * getattrs must use the old info for consistency.
385 004aa293 2005-07-13 devnull int ismtpt; /* whether there is an fsys mounted here */
386 004aa293 2005-07-13 devnull uchar fsysscore[VtScoreSize]; /* score of fsys image on venti */
387 004aa293 2005-07-13 devnull char *fsysimage; /* raw disk image */
388 004aa293 2005-07-13 devnull Fsys *mfsys; /* mounted file system (nil until walked) */
389 004aa293 2005-07-13 devnull Nfs3Handle mfsyshandle; /* handle to root of mounted fsys */
391 004aa293 2005-07-13 devnull int mark; /* gc */
394 004aa293 2005-07-13 devnull static uint
395 004aa293 2005-07-13 devnull dumbhash(uchar *s)
397 004aa293 2005-07-13 devnull return (s[0]<<2)|(s[1]>>6); /* first 10 bits */
400 004aa293 2005-07-13 devnull static Cnode*
401 004aa293 2005-07-13 devnull mkcnode(Ctree *t, Cnode *parent, char *elem, uint elen, char *path, uint plen)
404 004aa293 2005-07-13 devnull Cnode *n;
406 004aa293 2005-07-13 devnull n = emalloc(sizeof *n + elen+1);
407 004aa293 2005-07-13 devnull n->name = (char*)(n+1);
408 004aa293 2005-07-13 devnull memmove(n->name, elem, elen);
409 004aa293 2005-07-13 devnull n->name[elen] = 0;
410 004aa293 2005-07-13 devnull n->parent = parent;
411 004aa293 2005-07-13 devnull if(parent){
412 004aa293 2005-07-13 devnull n->nextsib = parent->kidlist;
413 004aa293 2005-07-13 devnull parent->kidlist = n;
415 004aa293 2005-07-13 devnull n->kidlist = nil;
416 004aa293 2005-07-13 devnull sha1((uchar*)path, plen, n->handle, nil);
417 004aa293 2005-07-13 devnull h = dumbhash(n->handle);
418 004aa293 2005-07-13 devnull n->nexthash = t->hash[h];
419 004aa293 2005-07-13 devnull t->hash[h] = n;
421 004aa293 2005-07-13 devnull return n;
425 004aa293 2005-07-13 devnull markctree(Ctree *t)
428 004aa293 2005-07-13 devnull Cnode *n;
430 004aa293 2005-07-13 devnull for(i=0; i<nelem(t->hash); i++)
431 004aa293 2005-07-13 devnull for(n=t->hash[i]; n; n=n->nexthash)
432 004aa293 2005-07-13 devnull if(n->name[0] != '+')
433 004aa293 2005-07-13 devnull n->mark = 1;
437 004aa293 2005-07-13 devnull refreshdisk(void)
440 004aa293 2005-07-13 devnull Cnode *n;
441 004aa293 2005-07-13 devnull Ctree *t;
443 004aa293 2005-07-13 devnull t = config.ctree;
444 004aa293 2005-07-13 devnull for(i=0; i<nelem(t->hash); i++)
445 004aa293 2005-07-13 devnull for(n=t->hash[i]; n; n=n->nexthash){
446 004aa293 2005-07-13 devnull if(n->mfsys)
447 004aa293 2005-07-13 devnull disksync(n->mfsys->disk);
448 004aa293 2005-07-13 devnull if(n->fsys)
449 004aa293 2005-07-13 devnull disksync(n->fsys->disk);
451 004aa293 2005-07-13 devnull return 0;
455 004aa293 2005-07-13 devnull sweepctree(Ctree *t)
458 004aa293 2005-07-13 devnull Cnode *n;
460 004aa293 2005-07-13 devnull /* just zero all the garbage and leave it linked into the tree */
461 004aa293 2005-07-13 devnull for(i=0; i<nelem(t->hash); i++){
462 004aa293 2005-07-13 devnull for(n=t->hash[i]; n; n=n->nexthash){
463 004aa293 2005-07-13 devnull if(!n->mark)
464 004aa293 2005-07-13 devnull continue;
465 004aa293 2005-07-13 devnull n->fsys = nil;
466 004aa293 2005-07-13 devnull free(n->fsysimage);
467 004aa293 2005-07-13 devnull n->fsysimage = nil;
468 004aa293 2005-07-13 devnull memset(n->fsysscore, 0, sizeof n->fsysscore);
469 004aa293 2005-07-13 devnull n->mfsys = nil;
470 004aa293 2005-07-13 devnull n->ismtpt = 0;
471 004aa293 2005-07-13 devnull memset(&n->fsyshandle, 0, sizeof n->fsyshandle);
472 004aa293 2005-07-13 devnull memset(&n->mfsyshandle, 0, sizeof n->mfsyshandle);
477 004aa293 2005-07-13 devnull static Cnode*
478 004aa293 2005-07-13 devnull cnodewalk(Cnode *n, char *name, uint len, int markokay)
480 004aa293 2005-07-13 devnull Cnode *nn;
482 004aa293 2005-07-13 devnull for(nn=n->kidlist; nn; nn=nn->nextsib)
483 004aa293 2005-07-13 devnull if(strncmp(nn->name, name, len) == 0 && nn->name[len] == 0)
484 004aa293 2005-07-13 devnull if(!nn->mark || markokay)
485 004aa293 2005-07-13 devnull return nn;
486 004aa293 2005-07-13 devnull return nil;
490 004aa293 2005-07-13 devnull ctreewalkpath(Ctree *t, char *name, ulong createmtime)
492 004aa293 2005-07-13 devnull Cnode *n, *nn;
493 004aa293 2005-07-13 devnull char *p, *nextp;
495 004aa293 2005-07-13 devnull n = t->root;
496 004aa293 2005-07-13 devnull p = name;
497 004aa293 2005-07-13 devnull for(; *p; p=nextp){
498 004aa293 2005-07-13 devnull n->mark = 0;
499 004aa293 2005-07-13 devnull assert(*p == '/');
501 004aa293 2005-07-13 devnull nextp = strchr(p, '/');
502 004aa293 2005-07-13 devnull if(nextp == nil)
503 004aa293 2005-07-13 devnull nextp = p+strlen(p);
504 004aa293 2005-07-13 devnull if((nn = cnodewalk(n, p, nextp-p, 1)) == nil){
505 004aa293 2005-07-13 devnull if(createmtime == 0)
506 004aa293 2005-07-13 devnull return nil;
507 004aa293 2005-07-13 devnull nn = mkcnode(t, n, p, nextp-p, name, nextp-name);
508 004aa293 2005-07-13 devnull nn->mtime = createmtime;
510 004aa293 2005-07-13 devnull if(nn->mark)
511 004aa293 2005-07-13 devnull nn->mark = 0;
514 004aa293 2005-07-13 devnull n->mark = 0;
515 004aa293 2005-07-13 devnull return n;
519 004aa293 2005-07-13 devnull mkctree(void)
521 004aa293 2005-07-13 devnull Ctree *t;
523 004aa293 2005-07-13 devnull t = emalloc(sizeof *t);
524 004aa293 2005-07-13 devnull t->root = mkcnode(t, nil, "", 0, "", 0);
526 004aa293 2005-07-13 devnull ctreewalkpath(t, "/+log", time(0))->read = logread;
527 004aa293 2005-07-13 devnull ctreewalkpath(t, "/+refreshdisk", time(0))->read = refreshdiskread;
528 004aa293 2005-07-13 devnull ctreewalkpath(t, "/+refreshconfig", time(0))->read = refreshconfigread;
530 004aa293 2005-07-13 devnull return t;
534 004aa293 2005-07-13 devnull ctreemountfsys(Ctree *t, char *path, ulong time, uchar *score, char *file)
536 004aa293 2005-07-13 devnull Cnode *n;
538 004aa293 2005-07-13 devnull if(time == 0)
539 004aa293 2005-07-13 devnull time = 1;
540 004aa293 2005-07-13 devnull n = ctreewalkpath(t, path, time);
541 004aa293 2005-07-13 devnull if(score){
542 004aa293 2005-07-13 devnull if(n->ismtpt && (n->fsysimage || memcmp(n->fsysscore, score, VtScoreSize) != 0)){
543 004aa293 2005-07-13 devnull free(n->fsysimage);
544 004aa293 2005-07-13 devnull n->fsysimage = nil;
545 004aa293 2005-07-13 devnull n->fsys = nil; /* leak (might be other refs) */
547 004aa293 2005-07-13 devnull memmove(n->fsysscore, score, VtScoreSize);
549 004aa293 2005-07-13 devnull if(n->ismtpt && (n->fsysimage==nil || strcmp(n->fsysimage, file) != 0)){
550 004aa293 2005-07-13 devnull free(n->fsysimage);
551 004aa293 2005-07-13 devnull n->fsysimage = nil;
552 004aa293 2005-07-13 devnull n->fsys = nil; /* leak (might be other refs) */
554 004aa293 2005-07-13 devnull n->fsysimage = emalloc(strlen(file)+1);
555 004aa293 2005-07-13 devnull strcpy(n->fsysimage, file);
557 004aa293 2005-07-13 devnull n->ismtpt = 1;
558 004aa293 2005-07-13 devnull return n;
562 004aa293 2005-07-13 devnull cnodebyhandle(Ctree *t, uchar *p)
565 004aa293 2005-07-13 devnull Cnode *n;
567 004aa293 2005-07-13 devnull h = dumbhash(p);
568 004aa293 2005-07-13 devnull for(n=t->hash[h]; n; n=n->nexthash)
569 004aa293 2005-07-13 devnull if(memcmp(n->handle, p, CnodeHandleSize) == 0)
570 004aa293 2005-07-13 devnull return n;
571 004aa293 2005-07-13 devnull return nil;
574 004aa293 2005-07-13 devnull static int
575 004aa293 2005-07-13 devnull parseipandmask(char *s, uchar *ip, uchar *mask)
577 004aa293 2005-07-13 devnull char *p, *q;
579 004aa293 2005-07-13 devnull p = strchr(s, '/');
581 004aa293 2005-07-13 devnull *p++ = 0;
582 004aa293 2005-07-13 devnull if(parseip(ip, s) == ~0UL)
583 004aa293 2005-07-13 devnull return -1;
584 004aa293 2005-07-13 devnull if(p == nil)
585 004aa293 2005-07-13 devnull memset(mask, 0xFF, IPaddrlen);
587 2b3a8c4d 2005-10-29 devnull if(isdigit((uchar)*p) && strtol(p, &q, 10)>=0 && *q==0)
588 004aa293 2005-07-13 devnull *--p = '/';
589 004aa293 2005-07-13 devnull if(parseipmask(mask, p) == ~0UL)
590 004aa293 2005-07-13 devnull return -1;
591 004aa293 2005-07-13 devnull if(*p != '/')
592 004aa293 2005-07-13 devnull *--p = '/';
594 cbeb0b26 2006-04-01 devnull /*fprint(2, "parseipandmask %s => %I %I\n", s, ip, mask); */
595 004aa293 2005-07-13 devnull return 0;
598 004aa293 2005-07-13 devnull static int
599 004aa293 2005-07-13 devnull parsetime(char *s, ulong *time)
601 004aa293 2005-07-13 devnull ulong x;
602 004aa293 2005-07-13 devnull char *p;
606 004aa293 2005-07-13 devnull /* decimal integer is seconds since 1970 */
607 004aa293 2005-07-13 devnull x = strtoul(s, &p, 10);
608 004aa293 2005-07-13 devnull if(x > 0 && *p == 0){
609 004aa293 2005-07-13 devnull *time = x;
610 004aa293 2005-07-13 devnull return 0;
613 004aa293 2005-07-13 devnull /* otherwise expect yyyy/mmdd/hhmm */
614 004aa293 2005-07-13 devnull if(strlen(s) != 14 || s[4] != '/' || s[9] != '/')
615 004aa293 2005-07-13 devnull return -1;
616 004aa293 2005-07-13 devnull for(i=0; i<4; i++)
617 2b3a8c4d 2005-10-29 devnull if(!isdigit((uchar)s[i]) || !isdigit((uchar)s[i+5]) || !isdigit((uchar)s[i+10]))
618 004aa293 2005-07-13 devnull return -1;
619 004aa293 2005-07-13 devnull memset(&tm, 0, sizeof tm);
620 004aa293 2005-07-13 devnull tm.year = atoi(s)-1900;
621 004aa293 2005-07-13 devnull if(tm.year < 0 || tm.year > 200)
622 004aa293 2005-07-13 devnull return -1;
623 004aa293 2005-07-13 devnull tm.mon = (s[5]-'0')*10+s[6]-'0' - 1;
624 004aa293 2005-07-13 devnull if(tm.mon < 0 || tm.mon > 11)
625 004aa293 2005-07-13 devnull return -1;
626 004aa293 2005-07-13 devnull tm.mday = (s[7]-'0')*10+s[8]-'0';
627 004aa293 2005-07-13 devnull if(tm.mday < 0 || tm.mday > 31)
628 004aa293 2005-07-13 devnull return -1;
629 004aa293 2005-07-13 devnull tm.hour = (s[10]-'0')*10+s[11]-'0';
630 004aa293 2005-07-13 devnull if(tm.hour < 0 || tm.hour > 23)
631 004aa293 2005-07-13 devnull return -1;
632 004aa293 2005-07-13 devnull tm.min = (s[12]-'0')*10+s[13]-'0';
633 004aa293 2005-07-13 devnull if(tm.min < 0 || tm.min > 59)
634 004aa293 2005-07-13 devnull return -1;
635 004aa293 2005-07-13 devnull strcpy(tm.zone, "XXX"); /* anything but GMT */
637 004aa293 2005-07-13 devnull print("tm2sec %d/%d/%d/%d/%d\n",
638 004aa293 2005-07-13 devnull tm.year, tm.mon, tm.mday, tm.hour, tm.min);
640 004aa293 2005-07-13 devnull *time = tm2sec(&tm);
641 004aa293 2005-07-13 devnull if(0) print("time %lud\n", *time);
642 004aa293 2005-07-13 devnull return 0;
647 004aa293 2005-07-13 devnull readconfigfile(Config *cp)
649 004aa293 2005-07-13 devnull char *f[10], *image, *p, *pref, *q, *name;
650 004aa293 2005-07-13 devnull int nf, line;
651 004aa293 2005-07-13 devnull uchar scorebuf[VtScoreSize], *score;
652 004aa293 2005-07-13 devnull ulong time;
653 004aa293 2005-07-13 devnull Biobuf *b;
654 004aa293 2005-07-13 devnull Config c;
655 004aa293 2005-07-13 devnull Dir *dir;
657 004aa293 2005-07-13 devnull name = configfile;
658 004aa293 2005-07-13 devnull c = *cp;
659 004aa293 2005-07-13 devnull if((dir = dirstat(name)) == nil)
660 004aa293 2005-07-13 devnull return -1;
661 004aa293 2005-07-13 devnull if(c.mtime == dir->mtime){
662 004aa293 2005-07-13 devnull free(dir);
663 004aa293 2005-07-13 devnull return 0;
665 004aa293 2005-07-13 devnull c.mtime = dir->mtime;
666 004aa293 2005-07-13 devnull free(dir);
667 004aa293 2005-07-13 devnull if((b = Bopen(name, OREAD)) == nil){
668 004aa293 2005-07-13 devnull free(dir);
669 004aa293 2005-07-13 devnull return -1;
673 004aa293 2005-07-13 devnull * Reuse old tree, garbage collecting entries that
674 004aa293 2005-07-13 devnull * are not mentioned in the new config file.
676 004aa293 2005-07-13 devnull if(c.ctree == nil)
677 004aa293 2005-07-13 devnull c.ctree = mkctree();
679 004aa293 2005-07-13 devnull markctree(c.ctree);
680 004aa293 2005-07-13 devnull c.ok = nil;
681 004aa293 2005-07-13 devnull c.nok = 0;
683 004aa293 2005-07-13 devnull line = 0;
684 004aa293 2005-07-13 devnull for(; (p=Brdstr(b, '\n', 1)) != nil; free(p)){
686 004aa293 2005-07-13 devnull if((q = strchr(p, '#')) != nil)
688 004aa293 2005-07-13 devnull nf = tokenize(p, f, nelem(f));
689 004aa293 2005-07-13 devnull if(nf == 0)
690 004aa293 2005-07-13 devnull continue;
691 004aa293 2005-07-13 devnull if(strcmp(f[0], "mount") == 0){
692 004aa293 2005-07-13 devnull if(nf != 4){
693 004aa293 2005-07-13 devnull werrstr("syntax error: mount /path /dev|score mtime");
694 004aa293 2005-07-13 devnull goto badline;
696 004aa293 2005-07-13 devnull if(f[1][0] != '/'){
697 004aa293 2005-07-13 devnull werrstr("unrooted path %s", f[1]);
698 004aa293 2005-07-13 devnull goto badline;
700 004aa293 2005-07-13 devnull score = nil;
701 004aa293 2005-07-13 devnull image = nil;
702 004aa293 2005-07-13 devnull if(f[2][0] == '/'){
703 004aa293 2005-07-13 devnull if(access(f[2], AEXIST) < 0){
704 004aa293 2005-07-13 devnull werrstr("image %s does not exist", f[2]);
705 004aa293 2005-07-13 devnull goto badline;
707 004aa293 2005-07-13 devnull image = f[2];
709 004aa293 2005-07-13 devnull if(vtparsescore(f[2], &pref, scorebuf) < 0){
710 004aa293 2005-07-13 devnull werrstr("bad score %s", f[2]);
711 004aa293 2005-07-13 devnull goto badline;
713 004aa293 2005-07-13 devnull score = scorebuf;
715 004aa293 2005-07-13 devnull if(parsetime(f[3], &time) < 0){
716 004aa293 2005-07-13 devnull fprint(2, "%s:%d: bad time %s\n", name, line, f[3]);
717 004aa293 2005-07-13 devnull time = 1;
719 004aa293 2005-07-13 devnull ctreemountfsys(c.ctree, f[1], time, score, image);
720 004aa293 2005-07-13 devnull continue;
722 004aa293 2005-07-13 devnull if(strcmp(f[0], "allow") == 0 || strcmp(f[0], "deny") == 0){
723 004aa293 2005-07-13 devnull if(nf != 2){
724 004aa293 2005-07-13 devnull werrstr("syntax error: allow|deny ip[/mask]");
725 004aa293 2005-07-13 devnull goto badline;
727 004aa293 2005-07-13 devnull c.ok = erealloc(c.ok, (c.nok+1)*sizeof(c.ok[0]));
728 004aa293 2005-07-13 devnull if(parseipandmask(f[1], c.ok[c.nok].ip, c.ok[c.nok].mask) < 0){
729 004aa293 2005-07-13 devnull werrstr("bad ip[/mask]: %s", f[1]);
730 004aa293 2005-07-13 devnull goto badline;
732 004aa293 2005-07-13 devnull c.ok[c.nok].okay = (strcmp(f[0], "allow") == 0);
733 004aa293 2005-07-13 devnull c.nok++;
734 004aa293 2005-07-13 devnull continue;
736 004aa293 2005-07-13 devnull werrstr("unknown verb '%s'", f[0]);
737 004aa293 2005-07-13 devnull badline:
738 004aa293 2005-07-13 devnull fprint(2, "%s:%d: %r\n", name, line);
740 004aa293 2005-07-13 devnull Bterm(b);
742 004aa293 2005-07-13 devnull sweepctree(c.ctree);
743 004aa293 2005-07-13 devnull free(cp->ok);
744 004aa293 2005-07-13 devnull *cp = c;
745 004aa293 2005-07-13 devnull return 0;
749 004aa293 2005-07-13 devnull ipokay(uchar *ip, ushort port)
752 004aa293 2005-07-13 devnull uchar ipx[IPaddrlen];
753 004aa293 2005-07-13 devnull Ipokay *ok;
755 004aa293 2005-07-13 devnull for(i=0; i<config.nok; i++){
756 004aa293 2005-07-13 devnull ok = &config.ok[i];
757 004aa293 2005-07-13 devnull maskip(ip, ok->mask, ipx);
758 004aa293 2005-07-13 devnull if(0) fprint(2, "%I & %I = %I (== %I?)\n",
759 004aa293 2005-07-13 devnull ip, ok->mask, ipx, ok->ip);
760 004aa293 2005-07-13 devnull if(memcmp(ipx, ok->ip, IPaddrlen) == 0)
761 004aa293 2005-07-13 devnull return ok->okay;
763 004aa293 2005-07-13 devnull if(config.nok == 0) /* all is permitted */
764 004aa293 2005-07-13 devnull return 1;
765 004aa293 2005-07-13 devnull /* otherwise default is none allowed */
766 004aa293 2005-07-13 devnull return 0;
769 004aa293 2005-07-13 devnull Nfs3Status
770 004aa293 2005-07-13 devnull cnodelookup(Ctree *t, Cnode **np, char *name)
772 004aa293 2005-07-13 devnull Cnode *n, *nn;
774 004aa293 2005-07-13 devnull n = *np;
775 004aa293 2005-07-13 devnull if(n->isblackhole)
776 004aa293 2005-07-13 devnull return Nfs3Ok;
777 004aa293 2005-07-13 devnull if((nn = cnodewalk(n, name, strlen(name), 0)) == nil){
778 004aa293 2005-07-13 devnull if(n->ismtpt || n->fsys){
779 004aa293 2005-07-13 devnull if((nn = cnodewalk(n, "", 0, 1)) == nil){
780 004aa293 2005-07-13 devnull nn = mkcnode(t, n, "", 0, (char*)n->handle, SHA1dlen);
781 004aa293 2005-07-13 devnull nn->isblackhole = 1;
783 004aa293 2005-07-13 devnull nn->mark = 0;
786 004aa293 2005-07-13 devnull if(nn == nil)
787 004aa293 2005-07-13 devnull return Nfs3ErrNoEnt;
788 004aa293 2005-07-13 devnull *np = nn;
789 004aa293 2005-07-13 devnull return Nfs3Ok;
792 004aa293 2005-07-13 devnull Nfs3Status
793 004aa293 2005-07-13 devnull cnodegetattr(Cnode *n, Nfs3Attr *attr)
795 004aa293 2005-07-13 devnull memset(attr, 0, sizeof *attr);
796 004aa293 2005-07-13 devnull if(n->read){
797 004aa293 2005-07-13 devnull attr->type = Nfs3FileReg;
798 004aa293 2005-07-13 devnull attr->mode = 0444;
799 004aa293 2005-07-13 devnull attr->size = 512;
800 004aa293 2005-07-13 devnull attr->nlink = 1;
802 004aa293 2005-07-13 devnull attr->type = Nfs3FileDir;
803 004aa293 2005-07-13 devnull attr->mode = 0555;
804 004aa293 2005-07-13 devnull attr->size = 1024;
805 004aa293 2005-07-13 devnull attr->nlink = 10;
807 004aa293 2005-07-13 devnull attr->fileid = *(u64int*)n->handle;
808 004aa293 2005-07-13 devnull attr->atime.sec = n->mtime;
809 004aa293 2005-07-13 devnull attr->mtime.sec = n->mtime;
810 004aa293 2005-07-13 devnull attr->ctime.sec = n->mtime;
811 004aa293 2005-07-13 devnull return Nfs3Ok;
814 004aa293 2005-07-13 devnull Nfs3Status
815 004aa293 2005-07-13 devnull cnodereaddir(Cnode *n, u32int count, u64int cookie, uchar **pdata, u32int *pcount, u1int *peof)
817 004aa293 2005-07-13 devnull uchar *data, *p, *ep, *np;
818 004aa293 2005-07-13 devnull u64int c;
819 004aa293 2005-07-13 devnull Nfs3Entry ne;
821 004aa293 2005-07-13 devnull n = n->kidlist;
822 004aa293 2005-07-13 devnull c = cookie;
823 004aa293 2005-07-13 devnull for(; c && n; c--)
824 004aa293 2005-07-13 devnull n = n->nextsib;
825 004aa293 2005-07-13 devnull if(n == nil){
826 004aa293 2005-07-13 devnull *pdata = 0;
827 004aa293 2005-07-13 devnull *pcount = 0;
828 004aa293 2005-07-13 devnull *peof = 1;
829 004aa293 2005-07-13 devnull return Nfs3Ok;
832 004aa293 2005-07-13 devnull data = emalloc(count);
833 004aa293 2005-07-13 devnull p = data;
834 004aa293 2005-07-13 devnull ep = data+count;
835 004aa293 2005-07-13 devnull while(n && p < ep){
836 004aa293 2005-07-13 devnull if(n->mark || n->name[0] == '+'){
837 004aa293 2005-07-13 devnull n = n->nextsib;
838 004aa293 2005-07-13 devnull ++cookie;
839 004aa293 2005-07-13 devnull continue;
841 004aa293 2005-07-13 devnull ne.name = n->name;
842 80b4aedc 2006-05-04 devnull ne.namelen = strlen(n->name);
843 004aa293 2005-07-13 devnull ne.cookie = ++cookie;
844 004aa293 2005-07-13 devnull ne.fileid = *(u64int*)n->handle;
845 004aa293 2005-07-13 devnull if(nfs3entrypack(p, ep, &np, &ne) < 0)
848 004aa293 2005-07-13 devnull n = n->nextsib;
850 004aa293 2005-07-13 devnull *pdata = data;
851 004aa293 2005-07-13 devnull *pcount = p - data;
852 004aa293 2005-07-13 devnull *peof = n==nil;
853 004aa293 2005-07-13 devnull return Nfs3Ok;
857 004aa293 2005-07-13 devnull timerproc(void *v)
859 004aa293 2005-07-13 devnull for(;;){
860 004aa293 2005-07-13 devnull sleep(60*1000);
861 004aa293 2005-07-13 devnull sendp(timerchan, 0);
866 004aa293 2005-07-13 devnull timerthread(void *v)
868 004aa293 2005-07-13 devnull for(;;){
869 004aa293 2005-07-13 devnull recvp(timerchan);
870 cbeb0b26 2006-04-01 devnull /* refreshconfig(); */
875 004aa293 2005-07-13 devnull * Actually serve the NFS requests. Called from nfs3srv.c.
876 004aa293 2005-07-13 devnull * Each request runs in its own thread (coroutine).
878 004aa293 2005-07-13 devnull * Decrypted handles have the form:
880 004aa293 2005-07-13 devnull * config[20] - SHA1 hash identifying a config tree node
881 004aa293 2005-07-13 devnull * glob[10] - SHA1 hash prefix identifying a glob state
882 004aa293 2005-07-13 devnull * fsyshandle[<=10] - disk file system handle (usually 4 bytes)
886 004aa293 2005-07-13 devnull * A fid represents a point in the file tree.
887 004aa293 2005-07-13 devnull * There are three components, all derived from the handle:
889 004aa293 2005-07-13 devnull * - config tree position (also used to find fsys)
890 004aa293 2005-07-13 devnull * - glob state for exclusions
891 004aa293 2005-07-13 devnull * - file system position
895 004aa293 2005-07-13 devnull HAccess,
898 004aa293 2005-07-13 devnull HDotdot,
901 004aa293 2005-07-13 devnull typedef struct Fid Fid;
902 004aa293 2005-07-13 devnull struct Fid
904 004aa293 2005-07-13 devnull Cnode *cnode;
905 004aa293 2005-07-13 devnull Fsys *fsys;
906 004aa293 2005-07-13 devnull Nfs3Handle fsyshandle;
910 004aa293 2005-07-13 devnull handlecmp(Nfs3Handle *h, Nfs3Handle *h1)
912 004aa293 2005-07-13 devnull if(h->len != h1->len)
913 004aa293 2005-07-13 devnull return h->len - h1->len;
914 004aa293 2005-07-13 devnull return memcmp(h->h, h1->h, h->len);
917 004aa293 2005-07-13 devnull Nfs3Status
918 004aa293 2005-07-13 devnull handletofid(Nfs3Handle *eh, Fid *fid, int mode)
920 004aa293 2005-07-13 devnull int domount;
921 004aa293 2005-07-13 devnull Cnode *n;
922 004aa293 2005-07-13 devnull Disk *disk, *cdisk;
923 004aa293 2005-07-13 devnull Fsys *fsys;
924 004aa293 2005-07-13 devnull Nfs3Status ok;
925 004aa293 2005-07-13 devnull Nfs3Handle h2, *h, *fh;
927 004aa293 2005-07-13 devnull memset(fid, 0, sizeof *fid);
929 004aa293 2005-07-13 devnull domount = 1;
930 004aa293 2005-07-13 devnull if(mode == HDotdot)
931 004aa293 2005-07-13 devnull domount = 0;
933 004aa293 2005-07-13 devnull * Not necessary, but speeds up ls -l /dump/2005
934 004aa293 2005-07-13 devnull * HAttr and HAccess must be handled the same way
935 004aa293 2005-07-13 devnull * because both can be used to fetch attributes.
936 004aa293 2005-07-13 devnull * Acting differently yields inconsistencies at mount points,
937 004aa293 2005-07-13 devnull * and causes FreeBSD ls -l to fail.
939 004aa293 2005-07-13 devnull if(mode == HAttr || mode == HAccess)
940 004aa293 2005-07-13 devnull domount = 0;
943 004aa293 2005-07-13 devnull * Decrypt handle.
945 004aa293 2005-07-13 devnull h2 = *eh;
946 004aa293 2005-07-13 devnull h = &h2;
947 004aa293 2005-07-13 devnull if((ok = hdecrypt(h)) != Nfs3Ok)
948 004aa293 2005-07-13 devnull return ok;
949 004aa293 2005-07-13 devnull trace("handletofid: decrypted %.*lH\n", h->len, h->h);
950 004aa293 2005-07-13 devnull if(h->len < FsysHandleOffset)
951 004aa293 2005-07-13 devnull return Nfs3ErrBadHandle;
954 004aa293 2005-07-13 devnull * Find place in config tree.
956 004aa293 2005-07-13 devnull if((n = cnodebyhandle(config.ctree, h->h)) == nil)
957 004aa293 2005-07-13 devnull return Nfs3ErrStale;
958 004aa293 2005-07-13 devnull fid->cnode = n;
960 004aa293 2005-07-13 devnull if(n->ismtpt && domount){
962 004aa293 2005-07-13 devnull * Open fsys for mount point if needed.
964 004aa293 2005-07-13 devnull if(n->mfsys == nil){
965 004aa293 2005-07-13 devnull trace("handletofid: mounting %V/%s\n", n->fsysscore, n->fsysimage);
966 004aa293 2005-07-13 devnull if(n->fsysimage){
967 004aa293 2005-07-13 devnull if(strcmp(n->fsysimage, "/dev/null") == 0)
968 004aa293 2005-07-13 devnull return Nfs3ErrAcces;
969 004aa293 2005-07-13 devnull if((disk = diskopenfile(n->fsysimage)) == nil){
970 004aa293 2005-07-13 devnull fprint(2, "cannot open disk %s: %r\n", n->fsysimage);
971 004aa293 2005-07-13 devnull return Nfs3ErrIo;
973 004aa293 2005-07-13 devnull if((cdisk = diskcache(disk, blocksize, 64)) == nil){
974 004aa293 2005-07-13 devnull fprint(2, "cannot cache disk %s: %r\n", n->fsysimage);
975 004aa293 2005-07-13 devnull diskclose(disk);
977 004aa293 2005-07-13 devnull disk = cdisk;
979 004aa293 2005-07-13 devnull if((disk = diskopenventi(vcache, n->fsysscore)) == nil){
980 004aa293 2005-07-13 devnull fprint(2, "cannot open venti disk %V: %r\n", n->fsysscore);
981 004aa293 2005-07-13 devnull return Nfs3ErrIo;
984 004aa293 2005-07-13 devnull if((fsys = fsysopen(disk)) == nil){
985 004aa293 2005-07-13 devnull fprint(2, "cannot open fsys on %V: %r\n", n->fsysscore);
986 004aa293 2005-07-13 devnull diskclose(disk);
987 004aa293 2005-07-13 devnull return Nfs3ErrIo;
989 004aa293 2005-07-13 devnull n->mfsys = fsys;
990 004aa293 2005-07-13 devnull fsysroot(fsys, &n->mfsyshandle);
994 004aa293 2005-07-13 devnull * Use inner handle.
996 004aa293 2005-07-13 devnull fid->fsys = n->mfsys;
997 004aa293 2005-07-13 devnull fid->fsyshandle = n->mfsyshandle;
1000 004aa293 2005-07-13 devnull * Use fsys handle from tree or from handle.
1001 004aa293 2005-07-13 devnull * This assumes that fsyshandle was set by fidtohandle
1002 004aa293 2005-07-13 devnull * earlier, so it's not okay to reuse handles (except the root)
1003 004aa293 2005-07-13 devnull * across sessions. The encryption above makes and
1004 004aa293 2005-07-13 devnull * enforces the same restriction, so this is okay.
1006 004aa293 2005-07-13 devnull fid->fsys = n->fsys;
1007 004aa293 2005-07-13 devnull fh = &fid->fsyshandle;
1008 004aa293 2005-07-13 devnull if(n->isblackhole){
1009 004aa293 2005-07-13 devnull fh->len = h->len-FsysHandleOffset;
1010 004aa293 2005-07-13 devnull memmove(fh->h, h->h+FsysHandleOffset, fh->len);
1012 004aa293 2005-07-13 devnull *fh = n->fsyshandle;
1013 004aa293 2005-07-13 devnull trace("handletofid: fsyshandle %.*lH\n", fh->len, fh->h);
1017 004aa293 2005-07-13 devnull * TO DO (maybe): some sort of path restriction here.
1019 004aa293 2005-07-13 devnull trace("handletofid: cnode %s fsys %p fsyshandle %.*lH\n",
1020 004aa293 2005-07-13 devnull n->name, fid->fsys, fid->fsyshandle.len, fid->fsyshandle.h);
1021 004aa293 2005-07-13 devnull return Nfs3Ok;
1025 004aa293 2005-07-13 devnull _fidtohandle(Fid *fid, Nfs3Handle *h)
1027 004aa293 2005-07-13 devnull Cnode *n;
1029 004aa293 2005-07-13 devnull n = fid->cnode;
1031 004aa293 2005-07-13 devnull * Record fsys handle in n, don't bother sending it to client
1032 004aa293 2005-07-13 devnull * for black holes.
1034 004aa293 2005-07-13 devnull n->fsys = fid->fsys;
1035 004aa293 2005-07-13 devnull if(!n->isblackhole){
1036 004aa293 2005-07-13 devnull n->fsyshandle = fid->fsyshandle;
1037 004aa293 2005-07-13 devnull fid->fsyshandle.len = 0;
1039 004aa293 2005-07-13 devnull memmove(h->h, n->handle, CnodeHandleSize);
1040 004aa293 2005-07-13 devnull memmove(h->h+FsysHandleOffset, fid->fsyshandle.h, fid->fsyshandle.len);
1041 004aa293 2005-07-13 devnull h->len = FsysHandleOffset+fid->fsyshandle.len;
1045 004aa293 2005-07-13 devnull fidtohandle(Fid *fid, Nfs3Handle *h)
1047 004aa293 2005-07-13 devnull _fidtohandle(fid, h);
1048 004aa293 2005-07-13 devnull hencrypt(h);
1052 004aa293 2005-07-13 devnull setrootfid(void)
1054 004aa293 2005-07-13 devnull Fid fid;
1056 004aa293 2005-07-13 devnull memset(&fid, 0, sizeof fid);
1057 004aa293 2005-07-13 devnull fid.cnode = config.ctree->root;
1058 004aa293 2005-07-13 devnull _fidtohandle(&fid, &root);
1059 004aa293 2005-07-13 devnull fprint(2, "handle %.*lH\n", root.len, root.h);
1063 004aa293 2005-07-13 devnull fsgetroot(Nfs3Handle *h)
1065 004aa293 2005-07-13 devnull *h = root;
1066 004aa293 2005-07-13 devnull hencrypt(h);
1069 004aa293 2005-07-13 devnull Nfs3Status
1070 004aa293 2005-07-13 devnull fsgetattr(SunAuthUnix *au, Nfs3Handle *h, Nfs3Attr *attr)
1072 004aa293 2005-07-13 devnull Fid fid;
1073 004aa293 2005-07-13 devnull Nfs3Status ok;
1075 004aa293 2005-07-13 devnull trace("getattr %.*lH\n", h->len, h->h);
1076 004aa293 2005-07-13 devnull if((ok = handletofid(h, &fid, HAttr)) != Nfs3Ok)
1077 004aa293 2005-07-13 devnull return ok;
1078 004aa293 2005-07-13 devnull if(fid.fsys)
1079 004aa293 2005-07-13 devnull return fsysgetattr(fid.fsys, au, &fid.fsyshandle, attr);
1081 004aa293 2005-07-13 devnull return cnodegetattr(fid.cnode, attr);
1085 004aa293 2005-07-13 devnull * Lookup is always the hard part.
1087 004aa293 2005-07-13 devnull Nfs3Status
1088 004aa293 2005-07-13 devnull fslookup(SunAuthUnix *au, Nfs3Handle *h, char *name, Nfs3Handle *nh)
1090 004aa293 2005-07-13 devnull Fid fid;
1091 004aa293 2005-07-13 devnull Cnode *n;
1092 004aa293 2005-07-13 devnull Nfs3Status ok;
1093 004aa293 2005-07-13 devnull Nfs3Handle xh;
1094 004aa293 2005-07-13 devnull int mode;
1096 004aa293 2005-07-13 devnull trace("lookup %.*lH %s\n", h->len, h->h, name);
1098 004aa293 2005-07-13 devnull mode = HWalk;
1099 004aa293 2005-07-13 devnull if(strcmp(name, "..") == 0 || strcmp(name, ".") == 0)
1100 004aa293 2005-07-13 devnull mode = HDotdot;
1101 004aa293 2005-07-13 devnull if((ok = handletofid(h, &fid, mode)) != Nfs3Ok){
1102 004aa293 2005-07-13 devnull nfs3errstr(ok);
1103 004aa293 2005-07-13 devnull trace("lookup: handletofid %r\n");
1104 004aa293 2005-07-13 devnull return ok;
1107 004aa293 2005-07-13 devnull if(strcmp(name, ".") == 0){
1108 004aa293 2005-07-13 devnull fidtohandle(&fid, nh);
1109 004aa293 2005-07-13 devnull return Nfs3Ok;
1113 004aa293 2005-07-13 devnull * Walk down file system and cnode simultaneously.
1114 004aa293 2005-07-13 devnull * If dotdot and file system doesn't move, need to walk
1115 004aa293 2005-07-13 devnull * up cnode. Save the corresponding fsys handles in
1116 004aa293 2005-07-13 devnull * the cnode as we walk down so that we'll have them
1117 004aa293 2005-07-13 devnull * for dotdotting back up.
1119 004aa293 2005-07-13 devnull n = fid.cnode;
1120 004aa293 2005-07-13 devnull if(mode == HWalk){
1122 004aa293 2005-07-13 devnull * Walk down config tree and file system simultaneously.
1124 004aa293 2005-07-13 devnull if((ok = cnodelookup(config.ctree, &n, name)) != Nfs3Ok){
1125 004aa293 2005-07-13 devnull nfs3errstr(ok);
1126 004aa293 2005-07-13 devnull trace("lookup: cnodelookup: %r\n");
1127 004aa293 2005-07-13 devnull return ok;
1129 004aa293 2005-07-13 devnull fid.cnode = n;
1130 004aa293 2005-07-13 devnull if(fid.fsys){
1131 004aa293 2005-07-13 devnull if((ok = fsyslookup(fid.fsys, au, &fid.fsyshandle, name, &xh)) != Nfs3Ok){
1132 004aa293 2005-07-13 devnull nfs3errstr(ok);
1133 004aa293 2005-07-13 devnull trace("lookup: fsyslookup: %r\n");
1134 004aa293 2005-07-13 devnull return ok;
1136 004aa293 2005-07-13 devnull fid.fsyshandle = xh;
1140 004aa293 2005-07-13 devnull * Walking dotdot. Ick.
1142 004aa293 2005-07-13 devnull trace("lookup dotdot fsys=%p\n", fid.fsys);
1143 004aa293 2005-07-13 devnull if(fid.fsys){
1145 004aa293 2005-07-13 devnull * Walk up file system, then try up config tree.
1147 004aa293 2005-07-13 devnull if((ok = fsyslookup(fid.fsys, au, &fid.fsyshandle, "..", &xh)) != Nfs3Ok){
1148 004aa293 2005-07-13 devnull nfs3errstr(ok);
1149 004aa293 2005-07-13 devnull trace("lookup fsyslookup: %r\n");
1150 004aa293 2005-07-13 devnull return ok;
1152 004aa293 2005-07-13 devnull fid.fsyshandle = xh;
1155 004aa293 2005-07-13 devnull * Usually just go to n->parent.
1157 004aa293 2005-07-13 devnull * If we're in a subtree of the mounted file system that
1158 004aa293 2005-07-13 devnull * isn't represented explicitly by the config tree (instead
1159 004aa293 2005-07-13 devnull * the black hole node represents the entire file tree),
1160 004aa293 2005-07-13 devnull * then we only go to n->parent when we've dotdotted back
1161 004aa293 2005-07-13 devnull * to the right handle.
1163 004aa293 2005-07-13 devnull if(n->parent == nil)
1164 004aa293 2005-07-13 devnull trace("lookup dotdot: no parent\n");
1166 004aa293 2005-07-13 devnull trace("lookup dotdot: parent %.*lH, have %.*lH\n",
1167 004aa293 2005-07-13 devnull n->parent->fsyshandle.len, n->parent->fsyshandle.h,
1168 004aa293 2005-07-13 devnull xh.len, xh.h);
1171 004aa293 2005-07-13 devnull if(n->isblackhole){
1172 004aa293 2005-07-13 devnull if(handlecmp(&n->parent->mfsyshandle, &xh) == 0)
1173 004aa293 2005-07-13 devnull n = n->parent;
1175 004aa293 2005-07-13 devnull if(n->parent)
1176 004aa293 2005-07-13 devnull n = n->parent;
1180 004aa293 2005-07-13 devnull * No file system, just walk up.
1182 004aa293 2005-07-13 devnull if(n->parent)
1183 004aa293 2005-07-13 devnull n = n->parent;
1185 004aa293 2005-07-13 devnull fid.fsys = n->fsys;
1186 004aa293 2005-07-13 devnull fid.fsyshandle = n->fsyshandle;
1187 004aa293 2005-07-13 devnull fid.cnode = n;
1189 004aa293 2005-07-13 devnull fidtohandle(&fid, nh);
1190 004aa293 2005-07-13 devnull return Nfs3Ok;
1193 004aa293 2005-07-13 devnull Nfs3Status
1194 004aa293 2005-07-13 devnull fsaccess(SunAuthUnix *au, Nfs3Handle *h, u32int want, u32int *got, Nfs3Attr *attr)
1196 004aa293 2005-07-13 devnull Fid fid;
1197 004aa293 2005-07-13 devnull Nfs3Status ok;
1199 004aa293 2005-07-13 devnull trace("access %.*lH 0x%ux\n", h->len, h->h, want);
1200 004aa293 2005-07-13 devnull if((ok = handletofid(h, &fid, HAccess)) != Nfs3Ok)
1201 004aa293 2005-07-13 devnull return ok;
1202 004aa293 2005-07-13 devnull if(fid.fsys)
1203 004aa293 2005-07-13 devnull return fsysaccess(fid.fsys, au, &fid.fsyshandle, want, got, attr);
1204 004aa293 2005-07-13 devnull *got = want & (Nfs3AccessRead|Nfs3AccessLookup|Nfs3AccessExecute);
1205 004aa293 2005-07-13 devnull return cnodegetattr(fid.cnode, attr);
1208 004aa293 2005-07-13 devnull Nfs3Status
1209 004aa293 2005-07-13 devnull fsreadlink(SunAuthUnix *au, Nfs3Handle *h, char **link)
1211 004aa293 2005-07-13 devnull Fid fid;
1212 004aa293 2005-07-13 devnull Nfs3Status ok;
1214 004aa293 2005-07-13 devnull trace("readlink %.*lH\n", h->len, h->h);
1215 004aa293 2005-07-13 devnull if((ok = handletofid(h, &fid, HRead)) != Nfs3Ok)
1216 004aa293 2005-07-13 devnull return ok;
1217 004aa293 2005-07-13 devnull if(fid.fsys)
1218 004aa293 2005-07-13 devnull return fsysreadlink(fid.fsys, au, &fid.fsyshandle, link);
1219 004aa293 2005-07-13 devnull *link = 0;
1220 004aa293 2005-07-13 devnull return Nfs3ErrNotSupp;
1223 004aa293 2005-07-13 devnull Nfs3Status
1224 004aa293 2005-07-13 devnull fsreadfile(SunAuthUnix *au, Nfs3Handle *h, u32int count, u64int offset, uchar **data, u32int *pcount, u1int *peof)
1226 004aa293 2005-07-13 devnull Fid fid;
1227 004aa293 2005-07-13 devnull Nfs3Status ok;
1229 004aa293 2005-07-13 devnull trace("readfile %.*lH\n", h->len, h->h);
1230 004aa293 2005-07-13 devnull if((ok = handletofid(h, &fid, HRead)) != Nfs3Ok)
1231 004aa293 2005-07-13 devnull return ok;
1232 004aa293 2005-07-13 devnull if(fid.cnode->read)
1233 004aa293 2005-07-13 devnull return fid.cnode->read(fid.cnode, count, offset, data, pcount, peof);
1234 004aa293 2005-07-13 devnull if(fid.fsys)
1235 004aa293 2005-07-13 devnull return fsysreadfile(fid.fsys, au, &fid.fsyshandle, count, offset, data, pcount, peof);
1236 004aa293 2005-07-13 devnull return Nfs3ErrNotSupp;
1239 004aa293 2005-07-13 devnull Nfs3Status
1240 004aa293 2005-07-13 devnull fsreaddir(SunAuthUnix *au, Nfs3Handle *h, u32int len, u64int cookie, uchar **pdata, u32int *pcount, u1int *peof)
1242 004aa293 2005-07-13 devnull Fid fid;
1243 004aa293 2005-07-13 devnull Nfs3Status ok;
1245 004aa293 2005-07-13 devnull trace("readdir %.*lH\n", h->len, h->h);
1246 004aa293 2005-07-13 devnull if((ok = handletofid(h, &fid, HRead)) != Nfs3Ok)
1247 004aa293 2005-07-13 devnull return ok;
1248 004aa293 2005-07-13 devnull if(fid.fsys)
1249 004aa293 2005-07-13 devnull return fsysreaddir(fid.fsys, au, &fid.fsyshandle, len, cookie, pdata, pcount, peof);
1250 004aa293 2005-07-13 devnull return cnodereaddir(fid.cnode, len, cookie, pdata, pcount, peof);
1253 004aa293 2005-07-13 devnull Nfs3Status
1254 004aa293 2005-07-13 devnull logread(Cnode *n, u32int count, u64int offset, uchar **data, u32int *pcount, u1int *peof)
1256 004aa293 2005-07-13 devnull *pcount = 0;
1257 004aa293 2005-07-13 devnull *peof = 1;
1258 004aa293 2005-07-13 devnull return Nfs3Ok;
1261 004aa293 2005-07-13 devnull Nfs3Status
1262 004aa293 2005-07-13 devnull refreshdiskread(Cnode *n, u32int count, u64int offset, uchar **data, u32int *pcount, u1int *peof)
1264 004aa293 2005-07-13 devnull char buf[128];
1266 004aa293 2005-07-13 devnull if(offset != 0){
1267 004aa293 2005-07-13 devnull *pcount = 0;
1268 004aa293 2005-07-13 devnull *peof = 1;
1269 004aa293 2005-07-13 devnull return Nfs3Ok;
1271 004aa293 2005-07-13 devnull if(refreshdisk() < 0)
1272 004aa293 2005-07-13 devnull snprint(buf, sizeof buf, "refreshdisk: %r\n");
1274 004aa293 2005-07-13 devnull strcpy(buf, "ok\n");
1275 004aa293 2005-07-13 devnull *data = emalloc(strlen(buf));
1276 004aa293 2005-07-13 devnull strcpy((char*)*data, buf);
1277 004aa293 2005-07-13 devnull *pcount = strlen(buf);
1278 004aa293 2005-07-13 devnull *peof = 1;
1279 004aa293 2005-07-13 devnull return Nfs3Ok;
1282 004aa293 2005-07-13 devnull Nfs3Status
1283 004aa293 2005-07-13 devnull refreshconfigread(Cnode *n, u32int count, u64int offset, uchar **data, u32int *pcount, u1int *peof)
1285 004aa293 2005-07-13 devnull char buf[128];
1287 004aa293 2005-07-13 devnull if(offset != 0){
1288 004aa293 2005-07-13 devnull *pcount = 0;
1289 004aa293 2005-07-13 devnull *peof = 1;
1290 004aa293 2005-07-13 devnull return Nfs3Ok;
1292 004aa293 2005-07-13 devnull if(readconfigfile(&config) < 0)
1293 004aa293 2005-07-13 devnull snprint(buf, sizeof buf, "readconfig: %r\n");
1295 004aa293 2005-07-13 devnull strcpy(buf, "ok\n");
1296 004aa293 2005-07-13 devnull *data = emalloc(strlen(buf));
1297 004aa293 2005-07-13 devnull strcpy((char*)*data, buf);
1298 004aa293 2005-07-13 devnull *pcount = strlen(buf);
1299 004aa293 2005-07-13 devnull *peof = 1;
1300 004aa293 2005-07-13 devnull return Nfs3Ok;
