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);
73 004aa293 2005-07-13 devnull usage(void)
75 004aa293 2005-07-13 devnull fprint(2, "usage: vnfs [-LLRVr] [-a addr] [-b blocksize] [-c cachesize] configfile\n");
76 004aa293 2005-07-13 devnull threadexitsall("usage");
80 004aa293 2005-07-13 devnull threadmain(int argc, char **argv)
82 004aa293 2005-07-13 devnull fmtinstall('B', sunrpcfmt);
83 004aa293 2005-07-13 devnull fmtinstall('C', suncallfmt);
84 004aa293 2005-07-13 devnull fmtinstall('F', vtfcallfmt);
85 004aa293 2005-07-13 devnull fmtinstall('H', encodefmt);
86 004aa293 2005-07-13 devnull fmtinstall('I', eipfmt);
87 004aa293 2005-07-13 devnull fmtinstall('V', vtscorefmt);
88 004aa293 2005-07-13 devnull sunfmtinstall(&nfs3prog);
89 004aa293 2005-07-13 devnull sunfmtinstall(&nfsmount3prog);
91 004aa293 2005-07-13 devnull addr = "udp!*!2049";
92 004aa293 2005-07-13 devnull blocksize = 8192;
93 004aa293 2005-07-13 devnull cachesize = 400;
94 004aa293 2005-07-13 devnull srv = sunsrv();
95 004aa293 2005-07-13 devnull srv->ipokay = ipokay;
96 004aa293 2005-07-13 devnull cryptinit();
98 004aa293 2005-07-13 devnull ARGBEGIN{
100 004aa293 2005-07-13 devnull usage();
101 004aa293 2005-07-13 devnull case 'E':
102 004aa293 2005-07-13 devnull encryptedhandles = 0;
104 004aa293 2005-07-13 devnull case 'L':
105 004aa293 2005-07-13 devnull if(srv->localonly == 0)
106 004aa293 2005-07-13 devnull srv->localonly = 1;
108 004aa293 2005-07-13 devnull srv->localparanoia = 1;
110 004aa293 2005-07-13 devnull case 'R':
111 004aa293 2005-07-13 devnull srv->chatty++;
113 004aa293 2005-07-13 devnull case 'T':
114 004aa293 2005-07-13 devnull tracecalls = 1;
116 004aa293 2005-07-13 devnull case 'V':
117 004aa293 2005-07-13 devnull chattyventi = 1;
119 004aa293 2005-07-13 devnull case 'a':
120 004aa293 2005-07-13 devnull addr = EARGF(usage());
122 004aa293 2005-07-13 devnull case 'b':
123 8307dc61 2005-08-12 devnull blocksize = strtoull(EARGF(usage()), 0, 0);
125 004aa293 2005-07-13 devnull case 'c':
126 8307dc61 2005-08-12 devnull cachesize = strtoull(EARGF(usage()), 0, 0);
128 004aa293 2005-07-13 devnull case 'r':
129 004aa293 2005-07-13 devnull srv->alwaysreject++;
133 004aa293 2005-07-13 devnull if(argc != 1)
134 004aa293 2005-07-13 devnull usage();
136 004aa293 2005-07-13 devnull if((z = vtdial(nil)) == nil)
137 004aa293 2005-07-13 devnull sysfatal("vtdial: %r");
138 004aa293 2005-07-13 devnull if(vtconnect(z) < 0)
139 004aa293 2005-07-13 devnull sysfatal("vtconnect: %r");
140 34d0c826 2005-07-13 devnull if((vcache = vtcachealloc(z, blocksize, cachesize)) == nil)
141 004aa293 2005-07-13 devnull sysfatal("vtcache: %r");
143 004aa293 2005-07-13 devnull configfile = argv[0];
144 004aa293 2005-07-13 devnull if(readconfigfile(&config) < 0)
145 004aa293 2005-07-13 devnull sysfatal("readConfig: %r");
146 004aa293 2005-07-13 devnull setrootfid();
148 004aa293 2005-07-13 devnull nfschan = chancreate(sizeof(SunMsg*), 0);
149 004aa293 2005-07-13 devnull mountchan = chancreate(sizeof(SunMsg*), 0);
150 004aa293 2005-07-13 devnull timerchan = chancreate(sizeof(void*), 0);
152 004aa293 2005-07-13 devnull if(sunsrvudp(srv, addr) < 0)
153 004aa293 2005-07-13 devnull sysfatal("starting server: %r");
155 004aa293 2005-07-13 devnull sunsrvthreadcreate(srv, nfs3proc, nfschan);
156 004aa293 2005-07-13 devnull sunsrvthreadcreate(srv, mount3proc, mountchan);
157 004aa293 2005-07-13 devnull sunsrvthreadcreate(srv, timerthread, nil);
158 004aa293 2005-07-13 devnull proccreate(timerproc, nil, 32768);
160 004aa293 2005-07-13 devnull sunsrvprog(srv, &nfs3prog, nfschan);
161 004aa293 2005-07-13 devnull sunsrvprog(srv, &nfsmount3prog, mountchan);
163 004aa293 2005-07-13 devnull threadexits(nil);
167 004aa293 2005-07-13 devnull * Handles.
169 004aa293 2005-07-13 devnull * We store all the state about which file a client is accessing in
170 004aa293 2005-07-13 devnull * the handle, so that we don't have to maintain any per-client state
171 004aa293 2005-07-13 devnull * ourselves. In order to avoid leaking handles or letting clients
172 004aa293 2005-07-13 devnull * create arbitrary handles, we sign and encrypt each handle with
173 004aa293 2005-07-13 devnull * AES using a key selected randomly when the server starts.
174 004aa293 2005-07-13 devnull * Thus, handles cannot be used across sessions.
176 004aa293 2005-07-13 devnull * The decrypted handles begin with the following header:
178 004aa293 2005-07-13 devnull * rand[12] random bytes used to make encryption non-deterministic
179 004aa293 2005-07-13 devnull * len[4] length of handle that follows
180 004aa293 2005-07-13 devnull * sessid[8] random session id chosen at start time
182 004aa293 2005-07-13 devnull * If we're pressed for space in the rest of the handle, we could
183 004aa293 2005-07-13 devnull * probably reduce the amount of randomness.
185 004aa293 2005-07-13 devnull * Security woes aside, the fact that we have to shove everything
186 004aa293 2005-07-13 devnull * into the handles is quite annoying. We have to encode, in 40 bytes:
188 004aa293 2005-07-13 devnull * - position in the synthesized config tree
189 004aa293 2005-07-13 devnull * - enough of the path to do glob matching
190 004aa293 2005-07-13 devnull * - position in an archived file system image
192 004aa293 2005-07-13 devnull * and the handles need to be stable across changes in the config file
193 004aa293 2005-07-13 devnull * (though not across server restarts since encryption screws
194 004aa293 2005-07-13 devnull * that up nicely).
196 004aa293 2005-07-13 devnull * We encode each of the first two as a 10-byte hash that is
197 004aa293 2005-07-13 devnull * the first half of a SHA1 hash.
202 004aa293 2005-07-13 devnull RandSize = 16,
203 004aa293 2005-07-13 devnull SessidSize = 8,
204 004aa293 2005-07-13 devnull HeaderSize = RandSize+SessidSize,
205 004aa293 2005-07-13 devnull MaxHandleSize = Nfs3MaxHandleSize - HeaderSize,
208 004aa293 2005-07-13 devnull AESstate aesstate;
209 004aa293 2005-07-13 devnull uchar sessid[SessidSize];
211 004aa293 2005-07-13 devnull static void
212 004aa293 2005-07-13 devnull hencrypt(Nfs3Handle *h)
214 004aa293 2005-07-13 devnull uchar *p;
215 004aa293 2005-07-13 devnull AESstate aes;
218 004aa293 2005-07-13 devnull * root handle has special encryption - a single 0 byte - so that it
219 004aa293 2005-07-13 devnull * never goes stale.
221 004aa293 2005-07-13 devnull if(h->len == root.len && memcmp(h->h, root.h, root.len) == 0){
222 004aa293 2005-07-13 devnull h->h[0] = 0;
223 004aa293 2005-07-13 devnull h->len = 1;
227 004aa293 2005-07-13 devnull if(!encryptedhandles)
230 004aa293 2005-07-13 devnull if(h->len > MaxHandleSize){
231 004aa293 2005-07-13 devnull /* oops */
232 004aa293 2005-07-13 devnull fprint(2, "handle too long: %.*lH\n", h->len, h->h);
233 004aa293 2005-07-13 devnull memset(h->h, 'X', Nfs3MaxHandleSize);
234 004aa293 2005-07-13 devnull h->len = Nfs3MaxHandleSize;
238 004aa293 2005-07-13 devnull p = h->h;
239 004aa293 2005-07-13 devnull memmove(p+HeaderSize, p, h->len);
240 004aa293 2005-07-13 devnull *(u32int*)p = fastrand();
241 004aa293 2005-07-13 devnull *(u32int*)(p+4) = fastrand();
242 004aa293 2005-07-13 devnull *(u32int*)(p+8) = fastrand();
243 004aa293 2005-07-13 devnull *(u32int*)(p+12) = h->len;
244 004aa293 2005-07-13 devnull memmove(p+16, sessid, SessidSize);
245 004aa293 2005-07-13 devnull h->len += HeaderSize;
247 004aa293 2005-07-13 devnull if(encryptedhandles){
248 004aa293 2005-07-13 devnull while(h->len < MaxHandleSize)
249 004aa293 2005-07-13 devnull h->h[h->len++] = fastrand();
250 004aa293 2005-07-13 devnull aes = aesstate;
251 004aa293 2005-07-13 devnull aesCBCencrypt(h->h, MaxHandleSize, &aes);
255 004aa293 2005-07-13 devnull static Nfs3Status
256 004aa293 2005-07-13 devnull hdecrypt(Nfs3Handle *h)
258 004aa293 2005-07-13 devnull AESstate aes;
260 004aa293 2005-07-13 devnull if(h->len == 1 && h->h[0] == 0){ /* single 0 byte is root */
261 004aa293 2005-07-13 devnull *h = root;
262 004aa293 2005-07-13 devnull return Nfs3Ok;
265 004aa293 2005-07-13 devnull if(!encryptedhandles)
266 004aa293 2005-07-13 devnull return Nfs3Ok;
268 004aa293 2005-07-13 devnull if(h->len <= HeaderSize)
269 004aa293 2005-07-13 devnull return Nfs3ErrBadHandle;
270 004aa293 2005-07-13 devnull if(encryptedhandles){
271 004aa293 2005-07-13 devnull if(h->len != MaxHandleSize)
272 004aa293 2005-07-13 devnull return Nfs3ErrBadHandle;
273 004aa293 2005-07-13 devnull aes = aesstate;
274 004aa293 2005-07-13 devnull aesCBCdecrypt(h->h, h->len, &aes);
276 004aa293 2005-07-13 devnull if(memcmp(h->h+RandSize, sessid, sizeof sessid) != 0)
277 004aa293 2005-07-13 devnull return Nfs3ErrStale; /* give benefit of doubt */
278 004aa293 2005-07-13 devnull h->len = *(u32int*)(h->h+12); /* XXX byte order */
279 004aa293 2005-07-13 devnull memmove(h->h, h->h+HeaderSize, h->len);
280 004aa293 2005-07-13 devnull return Nfs3Ok;
284 004aa293 2005-07-13 devnull cryptinit(void)
286 004aa293 2005-07-13 devnull uchar key[32], ivec[AESbsize];
289 004aa293 2005-07-13 devnull *(u32int*)sessid = truerand();
290 004aa293 2005-07-13 devnull for(i=0; i<nelem(key); i+=4)
291 004aa293 2005-07-13 devnull *(u32int*)&key[i] = truerand();
292 004aa293 2005-07-13 devnull for(i=0; i<nelem(ivec); i++)
293 004aa293 2005-07-13 devnull ivec[i] = fastrand();
294 004aa293 2005-07-13 devnull setupAESstate(&aesstate, key, sizeof key, ivec);
298 004aa293 2005-07-13 devnull * Config file.
300 004aa293 2005-07-13 devnull * The main purpose of the configuration file is to define a tree
301 004aa293 2005-07-13 devnull * in which the archived file system images are mounted.
302 004aa293 2005-07-13 devnull * The tree is stored as Entry structures, defined below.
304 004aa293 2005-07-13 devnull * The configuration file also allows one to define shell-like
305 004aa293 2005-07-13 devnull * glob expressions matching paths that are not to be displayed.
306 004aa293 2005-07-13 devnull * The matched files or directories are shown in directory listings
307 004aa293 2005-07-13 devnull * (could suppress these if we cared) but they cannot be opened,
308 004aa293 2005-07-13 devnull * read, or written, and getattr returns zeroed data.
312 004aa293 2005-07-13 devnull /* sizes used in handles; see nfs server below */
313 004aa293 2005-07-13 devnull CnodeHandleSize = 8,
314 004aa293 2005-07-13 devnull FsysHandleOffset = CnodeHandleSize,
318 004aa293 2005-07-13 devnull * Config file tree.
320 004aa293 2005-07-13 devnull struct Ctree
322 004aa293 2005-07-13 devnull Cnode *root;
323 004aa293 2005-07-13 devnull Cnode *hash[1024];
326 004aa293 2005-07-13 devnull struct Cnode
328 004aa293 2005-07-13 devnull char *name; /* path element */
329 004aa293 2005-07-13 devnull Cnode *parent; /* in tree */
330 004aa293 2005-07-13 devnull Cnode *nextsib; /* in tree */
331 004aa293 2005-07-13 devnull Cnode *kidlist; /* in tree */
332 004aa293 2005-07-13 devnull Cnode *nexthash; /* in hash list */
334 004aa293 2005-07-13 devnull Nfs3Status (*read)(Cnode*, u32int, u64int, uchar**, u32int*, u1int*); /* synthesized read fn */
336 004aa293 2005-07-13 devnull uchar handle[VtScoreSize]; /* sha1(path to here) */
337 004aa293 2005-07-13 devnull ulong mtime; /* mtime for this directory entry */
339 004aa293 2005-07-13 devnull /* fsys overlay on this node */
340 004aa293 2005-07-13 devnull Fsys *fsys; /* cache of memory structure */
341 004aa293 2005-07-13 devnull Nfs3Handle fsyshandle;
342 004aa293 2005-07-13 devnull int isblackhole; /* walking down keeps you here */
345 004aa293 2005-07-13 devnull * mount point info.
346 004aa293 2005-07-13 devnull * if a mount point is inside another file system,
347 004aa293 2005-07-13 devnull * the fsys and fsyshandle above have the old fs info,
348 004aa293 2005-07-13 devnull * the mfsys and mfsyshandle below have the new one.
349 004aa293 2005-07-13 devnull * getattrs must use the old info for consistency.
351 004aa293 2005-07-13 devnull int ismtpt; /* whether there is an fsys mounted here */
352 004aa293 2005-07-13 devnull uchar fsysscore[VtScoreSize]; /* score of fsys image on venti */
353 004aa293 2005-07-13 devnull char *fsysimage; /* raw disk image */
354 004aa293 2005-07-13 devnull Fsys *mfsys; /* mounted file system (nil until walked) */
355 004aa293 2005-07-13 devnull Nfs3Handle mfsyshandle; /* handle to root of mounted fsys */
357 004aa293 2005-07-13 devnull int mark; /* gc */
360 004aa293 2005-07-13 devnull static uint
361 004aa293 2005-07-13 devnull dumbhash(uchar *s)
363 004aa293 2005-07-13 devnull return (s[0]<<2)|(s[1]>>6); /* first 10 bits */
366 004aa293 2005-07-13 devnull static Cnode*
367 004aa293 2005-07-13 devnull mkcnode(Ctree *t, Cnode *parent, char *elem, uint elen, char *path, uint plen)
370 004aa293 2005-07-13 devnull Cnode *n;
372 004aa293 2005-07-13 devnull n = emalloc(sizeof *n + elen+1);
373 004aa293 2005-07-13 devnull n->name = (char*)(n+1);
374 004aa293 2005-07-13 devnull memmove(n->name, elem, elen);
375 004aa293 2005-07-13 devnull n->name[elen] = 0;
376 004aa293 2005-07-13 devnull n->parent = parent;
377 004aa293 2005-07-13 devnull if(parent){
378 004aa293 2005-07-13 devnull n->nextsib = parent->kidlist;
379 004aa293 2005-07-13 devnull parent->kidlist = n;
381 004aa293 2005-07-13 devnull n->kidlist = nil;
382 004aa293 2005-07-13 devnull sha1((uchar*)path, plen, n->handle, nil);
383 004aa293 2005-07-13 devnull h = dumbhash(n->handle);
384 004aa293 2005-07-13 devnull n->nexthash = t->hash[h];
385 004aa293 2005-07-13 devnull t->hash[h] = n;
387 004aa293 2005-07-13 devnull return n;
391 004aa293 2005-07-13 devnull markctree(Ctree *t)
394 004aa293 2005-07-13 devnull Cnode *n;
396 004aa293 2005-07-13 devnull for(i=0; i<nelem(t->hash); i++)
397 004aa293 2005-07-13 devnull for(n=t->hash[i]; n; n=n->nexthash)
398 004aa293 2005-07-13 devnull if(n->name[0] != '+')
399 004aa293 2005-07-13 devnull n->mark = 1;
403 004aa293 2005-07-13 devnull refreshdisk(void)
406 004aa293 2005-07-13 devnull Cnode *n;
407 004aa293 2005-07-13 devnull Ctree *t;
409 004aa293 2005-07-13 devnull t = config.ctree;
410 004aa293 2005-07-13 devnull for(i=0; i<nelem(t->hash); i++)
411 004aa293 2005-07-13 devnull for(n=t->hash[i]; n; n=n->nexthash){
412 004aa293 2005-07-13 devnull if(n->mfsys)
413 004aa293 2005-07-13 devnull disksync(n->mfsys->disk);
414 004aa293 2005-07-13 devnull if(n->fsys)
415 004aa293 2005-07-13 devnull disksync(n->fsys->disk);
417 004aa293 2005-07-13 devnull return 0;
421 004aa293 2005-07-13 devnull sweepctree(Ctree *t)
424 004aa293 2005-07-13 devnull Cnode *n;
426 004aa293 2005-07-13 devnull /* just zero all the garbage and leave it linked into the tree */
427 004aa293 2005-07-13 devnull for(i=0; i<nelem(t->hash); i++){
428 004aa293 2005-07-13 devnull for(n=t->hash[i]; n; n=n->nexthash){
429 004aa293 2005-07-13 devnull if(!n->mark)
430 004aa293 2005-07-13 devnull continue;
431 004aa293 2005-07-13 devnull n->fsys = nil;
432 004aa293 2005-07-13 devnull free(n->fsysimage);
433 004aa293 2005-07-13 devnull n->fsysimage = nil;
434 004aa293 2005-07-13 devnull memset(n->fsysscore, 0, sizeof n->fsysscore);
435 004aa293 2005-07-13 devnull n->mfsys = nil;
436 004aa293 2005-07-13 devnull n->ismtpt = 0;
437 004aa293 2005-07-13 devnull memset(&n->fsyshandle, 0, sizeof n->fsyshandle);
438 004aa293 2005-07-13 devnull memset(&n->mfsyshandle, 0, sizeof n->mfsyshandle);
443 004aa293 2005-07-13 devnull static Cnode*
444 004aa293 2005-07-13 devnull cnodewalk(Cnode *n, char *name, uint len, int markokay)
446 004aa293 2005-07-13 devnull Cnode *nn;
448 004aa293 2005-07-13 devnull for(nn=n->kidlist; nn; nn=nn->nextsib)
449 004aa293 2005-07-13 devnull if(strncmp(nn->name, name, len) == 0 && nn->name[len] == 0)
450 004aa293 2005-07-13 devnull if(!nn->mark || markokay)
451 004aa293 2005-07-13 devnull return nn;
452 004aa293 2005-07-13 devnull return nil;
456 004aa293 2005-07-13 devnull ctreewalkpath(Ctree *t, char *name, ulong createmtime)
458 004aa293 2005-07-13 devnull Cnode *n, *nn;
459 004aa293 2005-07-13 devnull char *p, *nextp;
461 004aa293 2005-07-13 devnull n = t->root;
462 004aa293 2005-07-13 devnull p = name;
463 004aa293 2005-07-13 devnull for(; *p; p=nextp){
464 004aa293 2005-07-13 devnull n->mark = 0;
465 004aa293 2005-07-13 devnull assert(*p == '/');
467 004aa293 2005-07-13 devnull nextp = strchr(p, '/');
468 004aa293 2005-07-13 devnull if(nextp == nil)
469 004aa293 2005-07-13 devnull nextp = p+strlen(p);
470 004aa293 2005-07-13 devnull if((nn = cnodewalk(n, p, nextp-p, 1)) == nil){
471 004aa293 2005-07-13 devnull if(createmtime == 0)
472 004aa293 2005-07-13 devnull return nil;
473 004aa293 2005-07-13 devnull nn = mkcnode(t, n, p, nextp-p, name, nextp-name);
474 004aa293 2005-07-13 devnull nn->mtime = createmtime;
476 004aa293 2005-07-13 devnull if(nn->mark)
477 004aa293 2005-07-13 devnull nn->mark = 0;
480 004aa293 2005-07-13 devnull n->mark = 0;
481 004aa293 2005-07-13 devnull return n;
485 004aa293 2005-07-13 devnull mkctree(void)
487 004aa293 2005-07-13 devnull Ctree *t;
489 004aa293 2005-07-13 devnull t = emalloc(sizeof *t);
490 004aa293 2005-07-13 devnull t->root = mkcnode(t, nil, "", 0, "", 0);
492 004aa293 2005-07-13 devnull ctreewalkpath(t, "/+log", time(0))->read = logread;
493 004aa293 2005-07-13 devnull ctreewalkpath(t, "/+refreshdisk", time(0))->read = refreshdiskread;
494 004aa293 2005-07-13 devnull ctreewalkpath(t, "/+refreshconfig", time(0))->read = refreshconfigread;
496 004aa293 2005-07-13 devnull return t;
500 004aa293 2005-07-13 devnull ctreemountfsys(Ctree *t, char *path, ulong time, uchar *score, char *file)
502 004aa293 2005-07-13 devnull Cnode *n;
504 004aa293 2005-07-13 devnull if(time == 0)
505 004aa293 2005-07-13 devnull time = 1;
506 004aa293 2005-07-13 devnull n = ctreewalkpath(t, path, time);
507 004aa293 2005-07-13 devnull if(score){
508 004aa293 2005-07-13 devnull if(n->ismtpt && (n->fsysimage || memcmp(n->fsysscore, score, VtScoreSize) != 0)){
509 004aa293 2005-07-13 devnull free(n->fsysimage);
510 004aa293 2005-07-13 devnull n->fsysimage = nil;
511 004aa293 2005-07-13 devnull n->fsys = nil; /* leak (might be other refs) */
513 004aa293 2005-07-13 devnull memmove(n->fsysscore, score, VtScoreSize);
515 004aa293 2005-07-13 devnull if(n->ismtpt && (n->fsysimage==nil || strcmp(n->fsysimage, file) != 0)){
516 004aa293 2005-07-13 devnull free(n->fsysimage);
517 004aa293 2005-07-13 devnull n->fsysimage = nil;
518 004aa293 2005-07-13 devnull n->fsys = nil; /* leak (might be other refs) */
520 004aa293 2005-07-13 devnull n->fsysimage = emalloc(strlen(file)+1);
521 004aa293 2005-07-13 devnull strcpy(n->fsysimage, file);
523 004aa293 2005-07-13 devnull n->ismtpt = 1;
524 004aa293 2005-07-13 devnull return n;
528 004aa293 2005-07-13 devnull cnodebyhandle(Ctree *t, uchar *p)
531 004aa293 2005-07-13 devnull Cnode *n;
533 004aa293 2005-07-13 devnull h = dumbhash(p);
534 004aa293 2005-07-13 devnull for(n=t->hash[h]; n; n=n->nexthash)
535 004aa293 2005-07-13 devnull if(memcmp(n->handle, p, CnodeHandleSize) == 0)
536 004aa293 2005-07-13 devnull return n;
537 004aa293 2005-07-13 devnull return nil;
540 004aa293 2005-07-13 devnull static int
541 004aa293 2005-07-13 devnull parseipandmask(char *s, uchar *ip, uchar *mask)
543 004aa293 2005-07-13 devnull char *p, *q;
545 004aa293 2005-07-13 devnull p = strchr(s, '/');
547 004aa293 2005-07-13 devnull *p++ = 0;
548 004aa293 2005-07-13 devnull if(parseip(ip, s) == ~0UL)
549 004aa293 2005-07-13 devnull return -1;
550 004aa293 2005-07-13 devnull if(p == nil)
551 004aa293 2005-07-13 devnull memset(mask, 0xFF, IPaddrlen);
553 2b3a8c4d 2005-10-29 devnull if(isdigit((uchar)*p) && strtol(p, &q, 10)>=0 && *q==0)
554 004aa293 2005-07-13 devnull *--p = '/';
555 004aa293 2005-07-13 devnull if(parseipmask(mask, p) == ~0UL)
556 004aa293 2005-07-13 devnull return -1;
557 004aa293 2005-07-13 devnull if(*p != '/')
558 004aa293 2005-07-13 devnull *--p = '/';
560 004aa293 2005-07-13 devnull //fprint(2, "parseipandmask %s => %I %I\n", s, ip, mask);
561 004aa293 2005-07-13 devnull return 0;
564 004aa293 2005-07-13 devnull static int
565 004aa293 2005-07-13 devnull parsetime(char *s, ulong *time)
567 004aa293 2005-07-13 devnull ulong x;
568 004aa293 2005-07-13 devnull char *p;
572 004aa293 2005-07-13 devnull /* decimal integer is seconds since 1970 */
573 004aa293 2005-07-13 devnull x = strtoul(s, &p, 10);
574 004aa293 2005-07-13 devnull if(x > 0 && *p == 0){
575 004aa293 2005-07-13 devnull *time = x;
576 004aa293 2005-07-13 devnull return 0;
579 004aa293 2005-07-13 devnull /* otherwise expect yyyy/mmdd/hhmm */
580 004aa293 2005-07-13 devnull if(strlen(s) != 14 || s[4] != '/' || s[9] != '/')
581 004aa293 2005-07-13 devnull return -1;
582 004aa293 2005-07-13 devnull for(i=0; i<4; i++)
583 2b3a8c4d 2005-10-29 devnull if(!isdigit((uchar)s[i]) || !isdigit((uchar)s[i+5]) || !isdigit((uchar)s[i+10]))
584 004aa293 2005-07-13 devnull return -1;
585 004aa293 2005-07-13 devnull memset(&tm, 0, sizeof tm);
586 004aa293 2005-07-13 devnull tm.year = atoi(s)-1900;
587 004aa293 2005-07-13 devnull if(tm.year < 0 || tm.year > 200)
588 004aa293 2005-07-13 devnull return -1;
589 004aa293 2005-07-13 devnull tm.mon = (s[5]-'0')*10+s[6]-'0' - 1;
590 004aa293 2005-07-13 devnull if(tm.mon < 0 || tm.mon > 11)
591 004aa293 2005-07-13 devnull return -1;
592 004aa293 2005-07-13 devnull tm.mday = (s[7]-'0')*10+s[8]-'0';
593 004aa293 2005-07-13 devnull if(tm.mday < 0 || tm.mday > 31)
594 004aa293 2005-07-13 devnull return -1;
595 004aa293 2005-07-13 devnull tm.hour = (s[10]-'0')*10+s[11]-'0';
596 004aa293 2005-07-13 devnull if(tm.hour < 0 || tm.hour > 23)
597 004aa293 2005-07-13 devnull return -1;
598 004aa293 2005-07-13 devnull tm.min = (s[12]-'0')*10+s[13]-'0';
599 004aa293 2005-07-13 devnull if(tm.min < 0 || tm.min > 59)
600 004aa293 2005-07-13 devnull return -1;
601 004aa293 2005-07-13 devnull strcpy(tm.zone, "XXX"); /* anything but GMT */
603 004aa293 2005-07-13 devnull print("tm2sec %d/%d/%d/%d/%d\n",
604 004aa293 2005-07-13 devnull tm.year, tm.mon, tm.mday, tm.hour, tm.min);
606 004aa293 2005-07-13 devnull *time = tm2sec(&tm);
607 004aa293 2005-07-13 devnull if(0) print("time %lud\n", *time);
608 004aa293 2005-07-13 devnull return 0;
613 004aa293 2005-07-13 devnull readconfigfile(Config *cp)
615 004aa293 2005-07-13 devnull char *f[10], *image, *p, *pref, *q, *name;
616 004aa293 2005-07-13 devnull int nf, line;
617 004aa293 2005-07-13 devnull uchar scorebuf[VtScoreSize], *score;
618 004aa293 2005-07-13 devnull ulong time;
619 004aa293 2005-07-13 devnull Biobuf *b;
620 004aa293 2005-07-13 devnull Config c;
621 004aa293 2005-07-13 devnull Dir *dir;
623 004aa293 2005-07-13 devnull name = configfile;
624 004aa293 2005-07-13 devnull c = *cp;
625 004aa293 2005-07-13 devnull if((dir = dirstat(name)) == nil)
626 004aa293 2005-07-13 devnull return -1;
627 004aa293 2005-07-13 devnull if(c.mtime == dir->mtime){
628 004aa293 2005-07-13 devnull free(dir);
629 004aa293 2005-07-13 devnull return 0;
631 004aa293 2005-07-13 devnull c.mtime = dir->mtime;
632 004aa293 2005-07-13 devnull free(dir);
633 004aa293 2005-07-13 devnull if((b = Bopen(name, OREAD)) == nil){
634 004aa293 2005-07-13 devnull free(dir);
635 004aa293 2005-07-13 devnull return -1;
639 004aa293 2005-07-13 devnull * Reuse old tree, garbage collecting entries that
640 004aa293 2005-07-13 devnull * are not mentioned in the new config file.
642 004aa293 2005-07-13 devnull if(c.ctree == nil)
643 004aa293 2005-07-13 devnull c.ctree = mkctree();
645 004aa293 2005-07-13 devnull markctree(c.ctree);
646 004aa293 2005-07-13 devnull c.ok = nil;
647 004aa293 2005-07-13 devnull c.nok = 0;
649 004aa293 2005-07-13 devnull line = 0;
650 004aa293 2005-07-13 devnull for(; (p=Brdstr(b, '\n', 1)) != nil; free(p)){
652 004aa293 2005-07-13 devnull if((q = strchr(p, '#')) != nil)
654 004aa293 2005-07-13 devnull nf = tokenize(p, f, nelem(f));
655 004aa293 2005-07-13 devnull if(nf == 0)
656 004aa293 2005-07-13 devnull continue;
657 004aa293 2005-07-13 devnull if(strcmp(f[0], "mount") == 0){
658 004aa293 2005-07-13 devnull if(nf != 4){
659 004aa293 2005-07-13 devnull werrstr("syntax error: mount /path /dev|score mtime");
660 004aa293 2005-07-13 devnull goto badline;
662 004aa293 2005-07-13 devnull if(f[1][0] != '/'){
663 004aa293 2005-07-13 devnull werrstr("unrooted path %s", f[1]);
664 004aa293 2005-07-13 devnull goto badline;
666 004aa293 2005-07-13 devnull score = nil;
667 004aa293 2005-07-13 devnull image = nil;
668 004aa293 2005-07-13 devnull if(f[2][0] == '/'){
669 004aa293 2005-07-13 devnull if(access(f[2], AEXIST) < 0){
670 004aa293 2005-07-13 devnull werrstr("image %s does not exist", f[2]);
671 004aa293 2005-07-13 devnull goto badline;
673 004aa293 2005-07-13 devnull image = f[2];
675 004aa293 2005-07-13 devnull if(vtparsescore(f[2], &pref, scorebuf) < 0){
676 004aa293 2005-07-13 devnull werrstr("bad score %s", f[2]);
677 004aa293 2005-07-13 devnull goto badline;
679 004aa293 2005-07-13 devnull score = scorebuf;
681 004aa293 2005-07-13 devnull if(parsetime(f[3], &time) < 0){
682 004aa293 2005-07-13 devnull fprint(2, "%s:%d: bad time %s\n", name, line, f[3]);
683 004aa293 2005-07-13 devnull time = 1;
685 004aa293 2005-07-13 devnull ctreemountfsys(c.ctree, f[1], time, score, image);
686 004aa293 2005-07-13 devnull continue;
688 004aa293 2005-07-13 devnull if(strcmp(f[0], "allow") == 0 || strcmp(f[0], "deny") == 0){
689 004aa293 2005-07-13 devnull if(nf != 2){
690 004aa293 2005-07-13 devnull werrstr("syntax error: allow|deny ip[/mask]");
691 004aa293 2005-07-13 devnull goto badline;
693 004aa293 2005-07-13 devnull c.ok = erealloc(c.ok, (c.nok+1)*sizeof(c.ok[0]));
694 004aa293 2005-07-13 devnull if(parseipandmask(f[1], c.ok[c.nok].ip, c.ok[c.nok].mask) < 0){
695 004aa293 2005-07-13 devnull werrstr("bad ip[/mask]: %s", f[1]);
696 004aa293 2005-07-13 devnull goto badline;
698 004aa293 2005-07-13 devnull c.ok[c.nok].okay = (strcmp(f[0], "allow") == 0);
699 004aa293 2005-07-13 devnull c.nok++;
700 004aa293 2005-07-13 devnull continue;
702 004aa293 2005-07-13 devnull werrstr("unknown verb '%s'", f[0]);
703 004aa293 2005-07-13 devnull badline:
704 004aa293 2005-07-13 devnull fprint(2, "%s:%d: %r\n", name, line);
706 004aa293 2005-07-13 devnull Bterm(b);
708 004aa293 2005-07-13 devnull sweepctree(c.ctree);
709 004aa293 2005-07-13 devnull free(cp->ok);
710 004aa293 2005-07-13 devnull *cp = c;
711 004aa293 2005-07-13 devnull return 0;
715 004aa293 2005-07-13 devnull ipokay(uchar *ip, ushort port)
718 004aa293 2005-07-13 devnull uchar ipx[IPaddrlen];
719 004aa293 2005-07-13 devnull Ipokay *ok;
721 004aa293 2005-07-13 devnull for(i=0; i<config.nok; i++){
722 004aa293 2005-07-13 devnull ok = &config.ok[i];
723 004aa293 2005-07-13 devnull maskip(ip, ok->mask, ipx);
724 004aa293 2005-07-13 devnull if(0) fprint(2, "%I & %I = %I (== %I?)\n",
725 004aa293 2005-07-13 devnull ip, ok->mask, ipx, ok->ip);
726 004aa293 2005-07-13 devnull if(memcmp(ipx, ok->ip, IPaddrlen) == 0)
727 004aa293 2005-07-13 devnull return ok->okay;
729 004aa293 2005-07-13 devnull if(config.nok == 0) /* all is permitted */
730 004aa293 2005-07-13 devnull return 1;
731 004aa293 2005-07-13 devnull /* otherwise default is none allowed */
732 004aa293 2005-07-13 devnull return 0;
735 004aa293 2005-07-13 devnull Nfs3Status
736 004aa293 2005-07-13 devnull cnodelookup(Ctree *t, Cnode **np, char *name)
738 004aa293 2005-07-13 devnull Cnode *n, *nn;
740 004aa293 2005-07-13 devnull n = *np;
741 004aa293 2005-07-13 devnull if(n->isblackhole)
742 004aa293 2005-07-13 devnull return Nfs3Ok;
743 004aa293 2005-07-13 devnull if((nn = cnodewalk(n, name, strlen(name), 0)) == nil){
744 004aa293 2005-07-13 devnull if(n->ismtpt || n->fsys){
745 004aa293 2005-07-13 devnull if((nn = cnodewalk(n, "", 0, 1)) == nil){
746 004aa293 2005-07-13 devnull nn = mkcnode(t, n, "", 0, (char*)n->handle, SHA1dlen);
747 004aa293 2005-07-13 devnull nn->isblackhole = 1;
749 004aa293 2005-07-13 devnull nn->mark = 0;
752 004aa293 2005-07-13 devnull if(nn == nil)
753 004aa293 2005-07-13 devnull return Nfs3ErrNoEnt;
754 004aa293 2005-07-13 devnull *np = nn;
755 004aa293 2005-07-13 devnull return Nfs3Ok;
758 004aa293 2005-07-13 devnull Nfs3Status
759 004aa293 2005-07-13 devnull cnodegetattr(Cnode *n, Nfs3Attr *attr)
761 004aa293 2005-07-13 devnull memset(attr, 0, sizeof *attr);
762 004aa293 2005-07-13 devnull if(n->read){
763 004aa293 2005-07-13 devnull attr->type = Nfs3FileReg;
764 004aa293 2005-07-13 devnull attr->mode = 0444;
765 004aa293 2005-07-13 devnull attr->size = 512;
766 004aa293 2005-07-13 devnull attr->nlink = 1;
768 004aa293 2005-07-13 devnull attr->type = Nfs3FileDir;
769 004aa293 2005-07-13 devnull attr->mode = 0555;
770 004aa293 2005-07-13 devnull attr->size = 1024;
771 004aa293 2005-07-13 devnull attr->nlink = 10;
773 004aa293 2005-07-13 devnull attr->fileid = *(u64int*)n->handle;
774 004aa293 2005-07-13 devnull attr->atime.sec = n->mtime;
775 004aa293 2005-07-13 devnull attr->mtime.sec = n->mtime;
776 004aa293 2005-07-13 devnull attr->ctime.sec = n->mtime;
777 004aa293 2005-07-13 devnull return Nfs3Ok;
780 004aa293 2005-07-13 devnull Nfs3Status
781 004aa293 2005-07-13 devnull cnodereaddir(Cnode *n, u32int count, u64int cookie, uchar **pdata, u32int *pcount, u1int *peof)
783 004aa293 2005-07-13 devnull uchar *data, *p, *ep, *np;
784 004aa293 2005-07-13 devnull u64int c;
785 004aa293 2005-07-13 devnull Nfs3Entry ne;
787 004aa293 2005-07-13 devnull n = n->kidlist;
788 004aa293 2005-07-13 devnull c = cookie;
789 004aa293 2005-07-13 devnull for(; c && n; c--)
790 004aa293 2005-07-13 devnull n = n->nextsib;
791 004aa293 2005-07-13 devnull if(n == nil){
792 004aa293 2005-07-13 devnull *pdata = 0;
793 004aa293 2005-07-13 devnull *pcount = 0;
794 004aa293 2005-07-13 devnull *peof = 1;
795 004aa293 2005-07-13 devnull return Nfs3Ok;
798 004aa293 2005-07-13 devnull data = emalloc(count);
799 004aa293 2005-07-13 devnull p = data;
800 004aa293 2005-07-13 devnull ep = data+count;
801 004aa293 2005-07-13 devnull while(n && p < ep){
802 004aa293 2005-07-13 devnull if(n->mark || n->name[0] == '+'){
803 004aa293 2005-07-13 devnull n = n->nextsib;
804 004aa293 2005-07-13 devnull ++cookie;
805 004aa293 2005-07-13 devnull continue;
807 004aa293 2005-07-13 devnull ne.name = n->name;
808 004aa293 2005-07-13 devnull ne.cookie = ++cookie;
809 004aa293 2005-07-13 devnull ne.fileid = *(u64int*)n->handle;
810 004aa293 2005-07-13 devnull if(nfs3entrypack(p, ep, &np, &ne) < 0)
813 004aa293 2005-07-13 devnull n = n->nextsib;
815 004aa293 2005-07-13 devnull *pdata = data;
816 004aa293 2005-07-13 devnull *pcount = p - data;
817 004aa293 2005-07-13 devnull *peof = n==nil;
818 004aa293 2005-07-13 devnull return Nfs3Ok;
822 004aa293 2005-07-13 devnull timerproc(void *v)
824 004aa293 2005-07-13 devnull for(;;){
825 004aa293 2005-07-13 devnull sleep(60*1000);
826 004aa293 2005-07-13 devnull sendp(timerchan, 0);
831 004aa293 2005-07-13 devnull timerthread(void *v)
833 004aa293 2005-07-13 devnull for(;;){
834 004aa293 2005-07-13 devnull recvp(timerchan);
835 004aa293 2005-07-13 devnull // refreshconfig();
840 004aa293 2005-07-13 devnull * Actually serve the NFS requests. Called from nfs3srv.c.
841 004aa293 2005-07-13 devnull * Each request runs in its own thread (coroutine).
843 004aa293 2005-07-13 devnull * Decrypted handles have the form:
845 004aa293 2005-07-13 devnull * config[20] - SHA1 hash identifying a config tree node
846 004aa293 2005-07-13 devnull * glob[10] - SHA1 hash prefix identifying a glob state
847 004aa293 2005-07-13 devnull * fsyshandle[<=10] - disk file system handle (usually 4 bytes)
851 004aa293 2005-07-13 devnull * A fid represents a point in the file tree.
852 004aa293 2005-07-13 devnull * There are three components, all derived from the handle:
854 004aa293 2005-07-13 devnull * - config tree position (also used to find fsys)
855 004aa293 2005-07-13 devnull * - glob state for exclusions
856 004aa293 2005-07-13 devnull * - file system position
860 004aa293 2005-07-13 devnull HAccess,
863 004aa293 2005-07-13 devnull HDotdot,
866 004aa293 2005-07-13 devnull typedef struct Fid Fid;
867 004aa293 2005-07-13 devnull struct Fid
869 004aa293 2005-07-13 devnull Cnode *cnode;
870 004aa293 2005-07-13 devnull Fsys *fsys;
871 004aa293 2005-07-13 devnull Nfs3Handle fsyshandle;
875 004aa293 2005-07-13 devnull handlecmp(Nfs3Handle *h, Nfs3Handle *h1)
877 004aa293 2005-07-13 devnull if(h->len != h1->len)
878 004aa293 2005-07-13 devnull return h->len - h1->len;
879 004aa293 2005-07-13 devnull return memcmp(h->h, h1->h, h->len);
882 004aa293 2005-07-13 devnull Nfs3Status
883 004aa293 2005-07-13 devnull handletofid(Nfs3Handle *eh, Fid *fid, int mode)
885 004aa293 2005-07-13 devnull int domount;
886 004aa293 2005-07-13 devnull Cnode *n;
887 004aa293 2005-07-13 devnull Disk *disk, *cdisk;
888 004aa293 2005-07-13 devnull Fsys *fsys;
889 004aa293 2005-07-13 devnull Nfs3Status ok;
890 004aa293 2005-07-13 devnull Nfs3Handle h2, *h, *fh;
892 004aa293 2005-07-13 devnull memset(fid, 0, sizeof *fid);
894 004aa293 2005-07-13 devnull domount = 1;
895 004aa293 2005-07-13 devnull if(mode == HDotdot)
896 004aa293 2005-07-13 devnull domount = 0;
898 004aa293 2005-07-13 devnull * Not necessary, but speeds up ls -l /dump/2005
899 004aa293 2005-07-13 devnull * HAttr and HAccess must be handled the same way
900 004aa293 2005-07-13 devnull * because both can be used to fetch attributes.
901 004aa293 2005-07-13 devnull * Acting differently yields inconsistencies at mount points,
902 004aa293 2005-07-13 devnull * and causes FreeBSD ls -l to fail.
904 004aa293 2005-07-13 devnull if(mode == HAttr || mode == HAccess)
905 004aa293 2005-07-13 devnull domount = 0;
908 004aa293 2005-07-13 devnull * Decrypt handle.
910 004aa293 2005-07-13 devnull h2 = *eh;
911 004aa293 2005-07-13 devnull h = &h2;
912 004aa293 2005-07-13 devnull if((ok = hdecrypt(h)) != Nfs3Ok)
913 004aa293 2005-07-13 devnull return ok;
914 004aa293 2005-07-13 devnull trace("handletofid: decrypted %.*lH\n", h->len, h->h);
915 004aa293 2005-07-13 devnull if(h->len < FsysHandleOffset)
916 004aa293 2005-07-13 devnull return Nfs3ErrBadHandle;
919 004aa293 2005-07-13 devnull * Find place in config tree.
921 004aa293 2005-07-13 devnull if((n = cnodebyhandle(config.ctree, h->h)) == nil)
922 004aa293 2005-07-13 devnull return Nfs3ErrStale;
923 004aa293 2005-07-13 devnull fid->cnode = n;
925 004aa293 2005-07-13 devnull if(n->ismtpt && domount){
927 004aa293 2005-07-13 devnull * Open fsys for mount point if needed.
929 004aa293 2005-07-13 devnull if(n->mfsys == nil){
930 004aa293 2005-07-13 devnull trace("handletofid: mounting %V/%s\n", n->fsysscore, n->fsysimage);
931 004aa293 2005-07-13 devnull if(n->fsysimage){
932 004aa293 2005-07-13 devnull if(strcmp(n->fsysimage, "/dev/null") == 0)
933 004aa293 2005-07-13 devnull return Nfs3ErrAcces;
934 004aa293 2005-07-13 devnull if((disk = diskopenfile(n->fsysimage)) == nil){
935 004aa293 2005-07-13 devnull fprint(2, "cannot open disk %s: %r\n", n->fsysimage);
936 004aa293 2005-07-13 devnull return Nfs3ErrIo;
938 004aa293 2005-07-13 devnull if((cdisk = diskcache(disk, blocksize, 64)) == nil){
939 004aa293 2005-07-13 devnull fprint(2, "cannot cache disk %s: %r\n", n->fsysimage);
940 004aa293 2005-07-13 devnull diskclose(disk);
942 004aa293 2005-07-13 devnull disk = cdisk;
944 004aa293 2005-07-13 devnull if((disk = diskopenventi(vcache, n->fsysscore)) == nil){
945 004aa293 2005-07-13 devnull fprint(2, "cannot open venti disk %V: %r\n", n->fsysscore);
946 004aa293 2005-07-13 devnull return Nfs3ErrIo;
949 004aa293 2005-07-13 devnull if((fsys = fsysopen(disk)) == nil){
950 004aa293 2005-07-13 devnull fprint(2, "cannot open fsys on %V: %r\n", n->fsysscore);
951 004aa293 2005-07-13 devnull diskclose(disk);
952 004aa293 2005-07-13 devnull return Nfs3ErrIo;
954 004aa293 2005-07-13 devnull n->mfsys = fsys;
955 004aa293 2005-07-13 devnull fsysroot(fsys, &n->mfsyshandle);
959 004aa293 2005-07-13 devnull * Use inner handle.
961 004aa293 2005-07-13 devnull fid->fsys = n->mfsys;
962 004aa293 2005-07-13 devnull fid->fsyshandle = n->mfsyshandle;
965 004aa293 2005-07-13 devnull * Use fsys handle from tree or from handle.
966 004aa293 2005-07-13 devnull * This assumes that fsyshandle was set by fidtohandle
967 004aa293 2005-07-13 devnull * earlier, so it's not okay to reuse handles (except the root)
968 004aa293 2005-07-13 devnull * across sessions. The encryption above makes and
969 004aa293 2005-07-13 devnull * enforces the same restriction, so this is okay.
971 004aa293 2005-07-13 devnull fid->fsys = n->fsys;
972 004aa293 2005-07-13 devnull fh = &fid->fsyshandle;
973 004aa293 2005-07-13 devnull if(n->isblackhole){
974 004aa293 2005-07-13 devnull fh->len = h->len-FsysHandleOffset;
975 004aa293 2005-07-13 devnull memmove(fh->h, h->h+FsysHandleOffset, fh->len);
977 004aa293 2005-07-13 devnull *fh = n->fsyshandle;
978 004aa293 2005-07-13 devnull trace("handletofid: fsyshandle %.*lH\n", fh->len, fh->h);
982 004aa293 2005-07-13 devnull * TO DO (maybe): some sort of path restriction here.
984 004aa293 2005-07-13 devnull trace("handletofid: cnode %s fsys %p fsyshandle %.*lH\n",
985 004aa293 2005-07-13 devnull n->name, fid->fsys, fid->fsyshandle.len, fid->fsyshandle.h);
986 004aa293 2005-07-13 devnull return Nfs3Ok;
990 004aa293 2005-07-13 devnull _fidtohandle(Fid *fid, Nfs3Handle *h)
992 004aa293 2005-07-13 devnull Cnode *n;
994 004aa293 2005-07-13 devnull n = fid->cnode;
996 004aa293 2005-07-13 devnull * Record fsys handle in n, don't bother sending it to client
997 004aa293 2005-07-13 devnull * for black holes.
999 004aa293 2005-07-13 devnull n->fsys = fid->fsys;
1000 004aa293 2005-07-13 devnull if(!n->isblackhole){
1001 004aa293 2005-07-13 devnull n->fsyshandle = fid->fsyshandle;
1002 004aa293 2005-07-13 devnull fid->fsyshandle.len = 0;
1004 004aa293 2005-07-13 devnull memmove(h->h, n->handle, CnodeHandleSize);
1005 004aa293 2005-07-13 devnull memmove(h->h+FsysHandleOffset, fid->fsyshandle.h, fid->fsyshandle.len);
1006 004aa293 2005-07-13 devnull h->len = FsysHandleOffset+fid->fsyshandle.len;
1010 004aa293 2005-07-13 devnull fidtohandle(Fid *fid, Nfs3Handle *h)
1012 004aa293 2005-07-13 devnull _fidtohandle(fid, h);
1013 004aa293 2005-07-13 devnull hencrypt(h);
1017 004aa293 2005-07-13 devnull setrootfid(void)
1019 004aa293 2005-07-13 devnull Fid fid;
1021 004aa293 2005-07-13 devnull memset(&fid, 0, sizeof fid);
1022 004aa293 2005-07-13 devnull fid.cnode = config.ctree->root;
1023 004aa293 2005-07-13 devnull _fidtohandle(&fid, &root);
1024 004aa293 2005-07-13 devnull fprint(2, "handle %.*lH\n", root.len, root.h);
1028 004aa293 2005-07-13 devnull fsgetroot(Nfs3Handle *h)
1030 004aa293 2005-07-13 devnull *h = root;
1031 004aa293 2005-07-13 devnull hencrypt(h);
1034 004aa293 2005-07-13 devnull Nfs3Status
1035 004aa293 2005-07-13 devnull fsgetattr(SunAuthUnix *au, Nfs3Handle *h, Nfs3Attr *attr)
1037 004aa293 2005-07-13 devnull Fid fid;
1038 004aa293 2005-07-13 devnull Nfs3Status ok;
1040 004aa293 2005-07-13 devnull trace("getattr %.*lH\n", h->len, h->h);
1041 004aa293 2005-07-13 devnull if((ok = handletofid(h, &fid, HAttr)) != Nfs3Ok)
1042 004aa293 2005-07-13 devnull return ok;
1043 004aa293 2005-07-13 devnull if(fid.fsys)
1044 004aa293 2005-07-13 devnull return fsysgetattr(fid.fsys, au, &fid.fsyshandle, attr);
1046 004aa293 2005-07-13 devnull return cnodegetattr(fid.cnode, attr);
1050 004aa293 2005-07-13 devnull * Lookup is always the hard part.
1052 004aa293 2005-07-13 devnull Nfs3Status
1053 004aa293 2005-07-13 devnull fslookup(SunAuthUnix *au, Nfs3Handle *h, char *name, Nfs3Handle *nh)
1055 004aa293 2005-07-13 devnull Fid fid;
1056 004aa293 2005-07-13 devnull Cnode *n;
1057 004aa293 2005-07-13 devnull Nfs3Status ok;
1058 004aa293 2005-07-13 devnull Nfs3Handle xh;
1059 004aa293 2005-07-13 devnull int mode;
1061 004aa293 2005-07-13 devnull trace("lookup %.*lH %s\n", h->len, h->h, name);
1063 004aa293 2005-07-13 devnull mode = HWalk;
1064 004aa293 2005-07-13 devnull if(strcmp(name, "..") == 0 || strcmp(name, ".") == 0)
1065 004aa293 2005-07-13 devnull mode = HDotdot;
1066 004aa293 2005-07-13 devnull if((ok = handletofid(h, &fid, mode)) != Nfs3Ok){
1067 004aa293 2005-07-13 devnull nfs3errstr(ok);
1068 004aa293 2005-07-13 devnull trace("lookup: handletofid %r\n");
1069 004aa293 2005-07-13 devnull return ok;
1072 004aa293 2005-07-13 devnull if(strcmp(name, ".") == 0){
1073 004aa293 2005-07-13 devnull fidtohandle(&fid, nh);
1074 004aa293 2005-07-13 devnull return Nfs3Ok;
1078 004aa293 2005-07-13 devnull * Walk down file system and cnode simultaneously.
1079 004aa293 2005-07-13 devnull * If dotdot and file system doesn't move, need to walk
1080 004aa293 2005-07-13 devnull * up cnode. Save the corresponding fsys handles in
1081 004aa293 2005-07-13 devnull * the cnode as we walk down so that we'll have them
1082 004aa293 2005-07-13 devnull * for dotdotting back up.
1084 004aa293 2005-07-13 devnull n = fid.cnode;
1085 004aa293 2005-07-13 devnull if(mode == HWalk){
1087 004aa293 2005-07-13 devnull * Walk down config tree and file system simultaneously.
1089 004aa293 2005-07-13 devnull if((ok = cnodelookup(config.ctree, &n, name)) != Nfs3Ok){
1090 004aa293 2005-07-13 devnull nfs3errstr(ok);
1091 004aa293 2005-07-13 devnull trace("lookup: cnodelookup: %r\n");
1092 004aa293 2005-07-13 devnull return ok;
1094 004aa293 2005-07-13 devnull fid.cnode = n;
1095 004aa293 2005-07-13 devnull if(fid.fsys){
1096 004aa293 2005-07-13 devnull if((ok = fsyslookup(fid.fsys, au, &fid.fsyshandle, name, &xh)) != Nfs3Ok){
1097 004aa293 2005-07-13 devnull nfs3errstr(ok);
1098 004aa293 2005-07-13 devnull trace("lookup: fsyslookup: %r\n");
1099 004aa293 2005-07-13 devnull return ok;
1101 004aa293 2005-07-13 devnull fid.fsyshandle = xh;
1105 004aa293 2005-07-13 devnull * Walking dotdot. Ick.
1107 004aa293 2005-07-13 devnull trace("lookup dotdot fsys=%p\n", fid.fsys);
1108 004aa293 2005-07-13 devnull if(fid.fsys){
1110 004aa293 2005-07-13 devnull * Walk up file system, then try up config tree.
1112 004aa293 2005-07-13 devnull if((ok = fsyslookup(fid.fsys, au, &fid.fsyshandle, "..", &xh)) != Nfs3Ok){
1113 004aa293 2005-07-13 devnull nfs3errstr(ok);
1114 004aa293 2005-07-13 devnull trace("lookup fsyslookup: %r\n");
1115 004aa293 2005-07-13 devnull return ok;
1117 004aa293 2005-07-13 devnull fid.fsyshandle = xh;
1120 004aa293 2005-07-13 devnull * Usually just go to n->parent.
1122 004aa293 2005-07-13 devnull * If we're in a subtree of the mounted file system that
1123 004aa293 2005-07-13 devnull * isn't represented explicitly by the config tree (instead
1124 004aa293 2005-07-13 devnull * the black hole node represents the entire file tree),
1125 004aa293 2005-07-13 devnull * then we only go to n->parent when we've dotdotted back
1126 004aa293 2005-07-13 devnull * to the right handle.
1128 004aa293 2005-07-13 devnull if(n->parent == nil)
1129 004aa293 2005-07-13 devnull trace("lookup dotdot: no parent\n");
1131 004aa293 2005-07-13 devnull trace("lookup dotdot: parent %.*lH, have %.*lH\n",
1132 004aa293 2005-07-13 devnull n->parent->fsyshandle.len, n->parent->fsyshandle.h,
1133 004aa293 2005-07-13 devnull xh.len, xh.h);
1136 004aa293 2005-07-13 devnull if(n->isblackhole){
1137 004aa293 2005-07-13 devnull if(handlecmp(&n->parent->mfsyshandle, &xh) == 0)
1138 004aa293 2005-07-13 devnull n = n->parent;
1140 004aa293 2005-07-13 devnull if(n->parent)
1141 004aa293 2005-07-13 devnull n = n->parent;
1145 004aa293 2005-07-13 devnull * No file system, just walk up.
1147 004aa293 2005-07-13 devnull if(n->parent)
1148 004aa293 2005-07-13 devnull n = n->parent;
1150 004aa293 2005-07-13 devnull fid.fsys = n->fsys;
1151 004aa293 2005-07-13 devnull fid.fsyshandle = n->fsyshandle;
1152 004aa293 2005-07-13 devnull fid.cnode = n;
1154 004aa293 2005-07-13 devnull fidtohandle(&fid, nh);
1155 004aa293 2005-07-13 devnull return Nfs3Ok;
1158 004aa293 2005-07-13 devnull Nfs3Status
1159 004aa293 2005-07-13 devnull fsaccess(SunAuthUnix *au, Nfs3Handle *h, u32int want, u32int *got, Nfs3Attr *attr)
1161 004aa293 2005-07-13 devnull Fid fid;
1162 004aa293 2005-07-13 devnull Nfs3Status ok;
1164 004aa293 2005-07-13 devnull trace("access %.*lH 0x%ux\n", h->len, h->h, want);
1165 004aa293 2005-07-13 devnull if((ok = handletofid(h, &fid, HAccess)) != Nfs3Ok)
1166 004aa293 2005-07-13 devnull return ok;
1167 004aa293 2005-07-13 devnull if(fid.fsys)
1168 004aa293 2005-07-13 devnull return fsysaccess(fid.fsys, au, &fid.fsyshandle, want, got, attr);
1169 004aa293 2005-07-13 devnull *got = want & (Nfs3AccessRead|Nfs3AccessLookup|Nfs3AccessExecute);
1170 004aa293 2005-07-13 devnull return cnodegetattr(fid.cnode, attr);
1173 004aa293 2005-07-13 devnull Nfs3Status
1174 004aa293 2005-07-13 devnull fsreadlink(SunAuthUnix *au, Nfs3Handle *h, char **link)
1176 004aa293 2005-07-13 devnull Fid fid;
1177 004aa293 2005-07-13 devnull Nfs3Status ok;
1179 004aa293 2005-07-13 devnull trace("readlink %.*lH\n", h->len, h->h);
1180 004aa293 2005-07-13 devnull if((ok = handletofid(h, &fid, HRead)) != Nfs3Ok)
1181 004aa293 2005-07-13 devnull return ok;
1182 004aa293 2005-07-13 devnull if(fid.fsys)
1183 004aa293 2005-07-13 devnull return fsysreadlink(fid.fsys, au, &fid.fsyshandle, link);
1184 004aa293 2005-07-13 devnull *link = 0;
1185 004aa293 2005-07-13 devnull return Nfs3ErrNotSupp;
1188 004aa293 2005-07-13 devnull Nfs3Status
1189 004aa293 2005-07-13 devnull fsreadfile(SunAuthUnix *au, Nfs3Handle *h, u32int count, u64int offset, uchar **data, u32int *pcount, u1int *peof)
1191 004aa293 2005-07-13 devnull Fid fid;
1192 004aa293 2005-07-13 devnull Nfs3Status ok;
1194 004aa293 2005-07-13 devnull trace("readfile %.*lH\n", h->len, h->h);
1195 004aa293 2005-07-13 devnull if((ok = handletofid(h, &fid, HRead)) != Nfs3Ok)
1196 004aa293 2005-07-13 devnull return ok;
1197 004aa293 2005-07-13 devnull if(fid.cnode->read)
1198 004aa293 2005-07-13 devnull return fid.cnode->read(fid.cnode, count, offset, data, pcount, peof);
1199 004aa293 2005-07-13 devnull if(fid.fsys)
1200 004aa293 2005-07-13 devnull return fsysreadfile(fid.fsys, au, &fid.fsyshandle, count, offset, data, pcount, peof);
1201 004aa293 2005-07-13 devnull return Nfs3ErrNotSupp;
1204 004aa293 2005-07-13 devnull Nfs3Status
1205 004aa293 2005-07-13 devnull fsreaddir(SunAuthUnix *au, Nfs3Handle *h, u32int len, u64int cookie, uchar **pdata, u32int *pcount, u1int *peof)
1207 004aa293 2005-07-13 devnull Fid fid;
1208 004aa293 2005-07-13 devnull Nfs3Status ok;
1210 004aa293 2005-07-13 devnull trace("readdir %.*lH\n", h->len, h->h);
1211 004aa293 2005-07-13 devnull if((ok = handletofid(h, &fid, HRead)) != Nfs3Ok)
1212 004aa293 2005-07-13 devnull return ok;
1213 004aa293 2005-07-13 devnull if(fid.fsys)
1214 004aa293 2005-07-13 devnull return fsysreaddir(fid.fsys, au, &fid.fsyshandle, len, cookie, pdata, pcount, peof);
1215 004aa293 2005-07-13 devnull return cnodereaddir(fid.cnode, len, cookie, pdata, pcount, peof);
1218 004aa293 2005-07-13 devnull Nfs3Status
1219 004aa293 2005-07-13 devnull logread(Cnode *n, u32int count, u64int offset, uchar **data, u32int *pcount, u1int *peof)
1221 004aa293 2005-07-13 devnull *pcount = 0;
1222 004aa293 2005-07-13 devnull *peof = 1;
1223 004aa293 2005-07-13 devnull return Nfs3Ok;
1226 004aa293 2005-07-13 devnull Nfs3Status
1227 004aa293 2005-07-13 devnull refreshdiskread(Cnode *n, u32int count, u64int offset, uchar **data, u32int *pcount, u1int *peof)
1229 004aa293 2005-07-13 devnull char buf[128];
1231 004aa293 2005-07-13 devnull if(offset != 0){
1232 004aa293 2005-07-13 devnull *pcount = 0;
1233 004aa293 2005-07-13 devnull *peof = 1;
1234 004aa293 2005-07-13 devnull return Nfs3Ok;
1236 004aa293 2005-07-13 devnull if(refreshdisk() < 0)
1237 004aa293 2005-07-13 devnull snprint(buf, sizeof buf, "refreshdisk: %r\n");
1239 004aa293 2005-07-13 devnull strcpy(buf, "ok\n");
1240 004aa293 2005-07-13 devnull *data = emalloc(strlen(buf));
1241 004aa293 2005-07-13 devnull strcpy((char*)*data, buf);
1242 004aa293 2005-07-13 devnull *pcount = strlen(buf);
1243 004aa293 2005-07-13 devnull *peof = 1;
1244 004aa293 2005-07-13 devnull return Nfs3Ok;
1247 004aa293 2005-07-13 devnull Nfs3Status
1248 004aa293 2005-07-13 devnull refreshconfigread(Cnode *n, u32int count, u64int offset, uchar **data, u32int *pcount, u1int *peof)
1250 004aa293 2005-07-13 devnull char buf[128];
1252 004aa293 2005-07-13 devnull if(offset != 0){
1253 004aa293 2005-07-13 devnull *pcount = 0;
1254 004aa293 2005-07-13 devnull *peof = 1;
1255 004aa293 2005-07-13 devnull return Nfs3Ok;
1257 004aa293 2005-07-13 devnull if(readconfigfile(&config) < 0)
1258 004aa293 2005-07-13 devnull snprint(buf, sizeof buf, "readconfig: %r\n");
1260 004aa293 2005-07-13 devnull strcpy(buf, "ok\n");
1261 004aa293 2005-07-13 devnull *data = emalloc(strlen(buf));
1262 004aa293 2005-07-13 devnull strcpy((char*)*data, buf);
1263 004aa293 2005-07-13 devnull *pcount = strlen(buf);
1264 004aa293 2005-07-13 devnull *peof = 1;
1265 004aa293 2005-07-13 devnull return Nfs3Ok;
