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 d63790ee 2008-07-20 devnull fprint(2, "usage: vnfs [-LLRVir] [-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 d63790ee 2008-07-20 devnull case 'i':
132 d63790ee 2008-07-20 devnull insecure = 1;
134 004aa293 2005-07-13 devnull case 'r':
135 004aa293 2005-07-13 devnull srv->alwaysreject++;
139 004aa293 2005-07-13 devnull if(argc != 1)
140 004aa293 2005-07-13 devnull usage();
142 004aa293 2005-07-13 devnull if((z = vtdial(nil)) == nil)
143 004aa293 2005-07-13 devnull sysfatal("vtdial: %r");
144 004aa293 2005-07-13 devnull if(vtconnect(z) < 0)
145 004aa293 2005-07-13 devnull sysfatal("vtconnect: %r");
146 e781b7b6 2009-06-16 rsc if((vcache = vtcachealloc(z, blocksize*cachesize)) == nil)
147 004aa293 2005-07-13 devnull sysfatal("vtcache: %r");
149 004aa293 2005-07-13 devnull configfile = argv[0];
150 004aa293 2005-07-13 devnull if(readconfigfile(&config) < 0)
151 004aa293 2005-07-13 devnull sysfatal("readConfig: %r");
152 004aa293 2005-07-13 devnull setrootfid();
154 004aa293 2005-07-13 devnull nfschan = chancreate(sizeof(SunMsg*), 0);
155 004aa293 2005-07-13 devnull mountchan = chancreate(sizeof(SunMsg*), 0);
156 004aa293 2005-07-13 devnull timerchan = chancreate(sizeof(void*), 0);
158 004aa293 2005-07-13 devnull if(sunsrvudp(srv, addr) < 0)
159 004aa293 2005-07-13 devnull sysfatal("starting server: %r");
161 004aa293 2005-07-13 devnull sunsrvthreadcreate(srv, nfs3proc, nfschan);
162 004aa293 2005-07-13 devnull sunsrvthreadcreate(srv, mount3proc, mountchan);
163 004aa293 2005-07-13 devnull sunsrvthreadcreate(srv, timerthread, nil);
164 004aa293 2005-07-13 devnull proccreate(timerproc, nil, 32768);
166 004aa293 2005-07-13 devnull sunsrvprog(srv, &nfs3prog, nfschan);
167 004aa293 2005-07-13 devnull sunsrvprog(srv, &nfsmount3prog, mountchan);
169 004aa293 2005-07-13 devnull threadexits(nil);
172 2214d4b6 2005-12-30 devnull #define TWID64 ((u64int)~(u64int)0)
175 2214d4b6 2005-12-30 devnull unittoull(char *s)
177 2214d4b6 2005-12-30 devnull char *es;
178 2214d4b6 2005-12-30 devnull u64int n;
180 2214d4b6 2005-12-30 devnull if(s == nil)
181 2214d4b6 2005-12-30 devnull return TWID64;
182 2214d4b6 2005-12-30 devnull n = strtoul(s, &es, 0);
183 2214d4b6 2005-12-30 devnull if(*es == 'k' || *es == 'K'){
184 2214d4b6 2005-12-30 devnull n *= 1024;
186 2214d4b6 2005-12-30 devnull }else if(*es == 'm' || *es == 'M'){
187 2214d4b6 2005-12-30 devnull n *= 1024*1024;
189 2214d4b6 2005-12-30 devnull }else if(*es == 'g' || *es == 'G'){
190 2214d4b6 2005-12-30 devnull n *= 1024*1024*1024;
192 2214d4b6 2005-12-30 devnull }else if(*es == 't' || *es == 'T'){
193 2214d4b6 2005-12-30 devnull n *= 1024*1024;
194 2214d4b6 2005-12-30 devnull n *= 1024*1024;
196 2214d4b6 2005-12-30 devnull if(*es != '\0')
197 2214d4b6 2005-12-30 devnull return TWID64;
198 2214d4b6 2005-12-30 devnull return n;
202 004aa293 2005-07-13 devnull * Handles.
204 004aa293 2005-07-13 devnull * We store all the state about which file a client is accessing in
205 004aa293 2005-07-13 devnull * the handle, so that we don't have to maintain any per-client state
206 004aa293 2005-07-13 devnull * ourselves. In order to avoid leaking handles or letting clients
207 004aa293 2005-07-13 devnull * create arbitrary handles, we sign and encrypt each handle with
208 004aa293 2005-07-13 devnull * AES using a key selected randomly when the server starts.
209 004aa293 2005-07-13 devnull * Thus, handles cannot be used across sessions.
211 004aa293 2005-07-13 devnull * The decrypted handles begin with the following header:
213 004aa293 2005-07-13 devnull * sessid[8] random session id chosen at start time
214 6884e49f 2006-06-15 devnull * len[4] length of handle that follows
216 004aa293 2005-07-13 devnull * If we're pressed for space in the rest of the handle, we could
217 6884e49f 2006-06-15 devnull * probably reduce the amount of sessid bytes. Note that the sessid
218 6884e49f 2006-06-15 devnull * bytes must be consistent during a run of vnfs, or else some
219 6884e49f 2006-06-15 devnull * clients (e.g., Linux 2.4) eventually notice that successive TLookups
220 6884e49f 2006-06-15 devnull * return different handles, and they return "Stale NFS file handle"
221 6884e49f 2006-06-15 devnull * errors to system calls in response (even though we never sent
222 6884e49f 2006-06-15 devnull * that error!).
224 004aa293 2005-07-13 devnull * Security woes aside, the fact that we have to shove everything
225 004aa293 2005-07-13 devnull * into the handles is quite annoying. We have to encode, in 40 bytes:
227 004aa293 2005-07-13 devnull * - position in the synthesized config tree
228 004aa293 2005-07-13 devnull * - enough of the path to do glob matching
229 004aa293 2005-07-13 devnull * - position in an archived file system image
231 004aa293 2005-07-13 devnull * and the handles need to be stable across changes in the config file
232 004aa293 2005-07-13 devnull * (though not across server restarts since encryption screws
233 004aa293 2005-07-13 devnull * that up nicely).
235 004aa293 2005-07-13 devnull * We encode each of the first two as a 10-byte hash that is
236 004aa293 2005-07-13 devnull * the first half of a SHA1 hash.
241 004aa293 2005-07-13 devnull SessidSize = 8,
242 6884e49f 2006-06-15 devnull HeaderSize = SessidSize+4,
243 cbeb0b26 2006-04-01 devnull MaxHandleSize = Nfs3MaxHandleSize - HeaderSize
246 004aa293 2005-07-13 devnull AESstate aesstate;
247 004aa293 2005-07-13 devnull uchar sessid[SessidSize];
249 004aa293 2005-07-13 devnull static void
250 004aa293 2005-07-13 devnull hencrypt(Nfs3Handle *h)
252 004aa293 2005-07-13 devnull uchar *p;
253 004aa293 2005-07-13 devnull AESstate aes;
256 004aa293 2005-07-13 devnull * root handle has special encryption - a single 0 byte - so that it
257 004aa293 2005-07-13 devnull * never goes stale.
259 004aa293 2005-07-13 devnull if(h->len == root.len && memcmp(h->h, root.h, root.len) == 0){
260 004aa293 2005-07-13 devnull h->h[0] = 0;
261 004aa293 2005-07-13 devnull h->len = 1;
265 004aa293 2005-07-13 devnull if(!encryptedhandles)
268 004aa293 2005-07-13 devnull if(h->len > MaxHandleSize){
269 004aa293 2005-07-13 devnull /* oops */
270 004aa293 2005-07-13 devnull fprint(2, "handle too long: %.*lH\n", h->len, h->h);
271 004aa293 2005-07-13 devnull memset(h->h, 'X', Nfs3MaxHandleSize);
272 004aa293 2005-07-13 devnull h->len = Nfs3MaxHandleSize;
276 004aa293 2005-07-13 devnull p = h->h;
277 004aa293 2005-07-13 devnull memmove(p+HeaderSize, p, h->len);
278 6884e49f 2006-06-15 devnull memmove(p, sessid, SessidSize);
279 6884e49f 2006-06-15 devnull *(u32int*)(p+SessidSize) = h->len;
280 004aa293 2005-07-13 devnull h->len += HeaderSize;
282 004aa293 2005-07-13 devnull if(encryptedhandles){
283 004aa293 2005-07-13 devnull while(h->len < MaxHandleSize)
284 6884e49f 2006-06-15 devnull h->h[h->len++] = 0;
285 004aa293 2005-07-13 devnull aes = aesstate;
286 004aa293 2005-07-13 devnull aesCBCencrypt(h->h, MaxHandleSize, &aes);
290 004aa293 2005-07-13 devnull static Nfs3Status
291 004aa293 2005-07-13 devnull hdecrypt(Nfs3Handle *h)
293 004aa293 2005-07-13 devnull AESstate aes;
295 004aa293 2005-07-13 devnull if(h->len == 1 && h->h[0] == 0){ /* single 0 byte is root */
296 004aa293 2005-07-13 devnull *h = root;
297 004aa293 2005-07-13 devnull return Nfs3Ok;
300 004aa293 2005-07-13 devnull if(!encryptedhandles)
301 004aa293 2005-07-13 devnull return Nfs3Ok;
303 004aa293 2005-07-13 devnull if(h->len <= HeaderSize)
304 004aa293 2005-07-13 devnull return Nfs3ErrBadHandle;
305 004aa293 2005-07-13 devnull if(encryptedhandles){
306 004aa293 2005-07-13 devnull if(h->len != MaxHandleSize)
307 004aa293 2005-07-13 devnull return Nfs3ErrBadHandle;
308 004aa293 2005-07-13 devnull aes = aesstate;
309 004aa293 2005-07-13 devnull aesCBCdecrypt(h->h, h->len, &aes);
311 6884e49f 2006-06-15 devnull if(memcmp(h->h, sessid, SessidSize) != 0)
312 004aa293 2005-07-13 devnull return Nfs3ErrStale; /* give benefit of doubt */
313 6884e49f 2006-06-15 devnull h->len = *(u32int*)(h->h+SessidSize);
314 6884e49f 2006-06-15 devnull if(h->len >= MaxHandleSize-HeaderSize)
315 6884e49f 2006-06-15 devnull return Nfs3ErrBadHandle;
316 004aa293 2005-07-13 devnull memmove(h->h, h->h+HeaderSize, h->len);
317 004aa293 2005-07-13 devnull return Nfs3Ok;
321 004aa293 2005-07-13 devnull cryptinit(void)
323 004aa293 2005-07-13 devnull uchar key[32], ivec[AESbsize];
326 004aa293 2005-07-13 devnull *(u32int*)sessid = truerand();
327 004aa293 2005-07-13 devnull for(i=0; i<nelem(key); i+=4)
328 004aa293 2005-07-13 devnull *(u32int*)&key[i] = truerand();
329 004aa293 2005-07-13 devnull for(i=0; i<nelem(ivec); i++)
330 004aa293 2005-07-13 devnull ivec[i] = fastrand();
331 004aa293 2005-07-13 devnull setupAESstate(&aesstate, key, sizeof key, ivec);
335 004aa293 2005-07-13 devnull * Config file.
337 004aa293 2005-07-13 devnull * The main purpose of the configuration file is to define a tree
338 004aa293 2005-07-13 devnull * in which the archived file system images are mounted.
339 004aa293 2005-07-13 devnull * The tree is stored as Entry structures, defined below.
341 004aa293 2005-07-13 devnull * The configuration file also allows one to define shell-like
342 004aa293 2005-07-13 devnull * glob expressions matching paths that are not to be displayed.
343 004aa293 2005-07-13 devnull * The matched files or directories are shown in directory listings
344 004aa293 2005-07-13 devnull * (could suppress these if we cared) but they cannot be opened,
345 004aa293 2005-07-13 devnull * read, or written, and getattr returns zeroed data.
349 004aa293 2005-07-13 devnull /* sizes used in handles; see nfs server below */
350 004aa293 2005-07-13 devnull CnodeHandleSize = 8,
351 cbeb0b26 2006-04-01 devnull FsysHandleOffset = CnodeHandleSize
355 004aa293 2005-07-13 devnull * Config file tree.
357 004aa293 2005-07-13 devnull struct Ctree
359 004aa293 2005-07-13 devnull Cnode *root;
360 004aa293 2005-07-13 devnull Cnode *hash[1024];
363 004aa293 2005-07-13 devnull struct Cnode
365 004aa293 2005-07-13 devnull char *name; /* path element */
366 004aa293 2005-07-13 devnull Cnode *parent; /* in tree */
367 004aa293 2005-07-13 devnull Cnode *nextsib; /* in tree */
368 004aa293 2005-07-13 devnull Cnode *kidlist; /* in tree */
369 004aa293 2005-07-13 devnull Cnode *nexthash; /* in hash list */
371 004aa293 2005-07-13 devnull Nfs3Status (*read)(Cnode*, u32int, u64int, uchar**, u32int*, u1int*); /* synthesized read fn */
373 004aa293 2005-07-13 devnull uchar handle[VtScoreSize]; /* sha1(path to here) */
374 004aa293 2005-07-13 devnull ulong mtime; /* mtime for this directory entry */
376 004aa293 2005-07-13 devnull /* fsys overlay on this node */
377 004aa293 2005-07-13 devnull Fsys *fsys; /* cache of memory structure */
378 004aa293 2005-07-13 devnull Nfs3Handle fsyshandle;
379 004aa293 2005-07-13 devnull int isblackhole; /* walking down keeps you here */
382 004aa293 2005-07-13 devnull * mount point info.
383 004aa293 2005-07-13 devnull * if a mount point is inside another file system,
384 004aa293 2005-07-13 devnull * the fsys and fsyshandle above have the old fs info,
385 004aa293 2005-07-13 devnull * the mfsys and mfsyshandle below have the new one.
386 004aa293 2005-07-13 devnull * getattrs must use the old info for consistency.
388 004aa293 2005-07-13 devnull int ismtpt; /* whether there is an fsys mounted here */
389 004aa293 2005-07-13 devnull uchar fsysscore[VtScoreSize]; /* score of fsys image on venti */
390 004aa293 2005-07-13 devnull char *fsysimage; /* raw disk image */
391 004aa293 2005-07-13 devnull Fsys *mfsys; /* mounted file system (nil until walked) */
392 004aa293 2005-07-13 devnull Nfs3Handle mfsyshandle; /* handle to root of mounted fsys */
394 004aa293 2005-07-13 devnull int mark; /* gc */
397 004aa293 2005-07-13 devnull static uint
398 004aa293 2005-07-13 devnull dumbhash(uchar *s)
400 004aa293 2005-07-13 devnull return (s[0]<<2)|(s[1]>>6); /* first 10 bits */
403 004aa293 2005-07-13 devnull static Cnode*
404 004aa293 2005-07-13 devnull mkcnode(Ctree *t, Cnode *parent, char *elem, uint elen, char *path, uint plen)
407 004aa293 2005-07-13 devnull Cnode *n;
409 004aa293 2005-07-13 devnull n = emalloc(sizeof *n + elen+1);
410 004aa293 2005-07-13 devnull n->name = (char*)(n+1);
411 004aa293 2005-07-13 devnull memmove(n->name, elem, elen);
412 004aa293 2005-07-13 devnull n->name[elen] = 0;
413 004aa293 2005-07-13 devnull n->parent = parent;
414 004aa293 2005-07-13 devnull if(parent){
415 004aa293 2005-07-13 devnull n->nextsib = parent->kidlist;
416 004aa293 2005-07-13 devnull parent->kidlist = n;
418 004aa293 2005-07-13 devnull n->kidlist = nil;
419 004aa293 2005-07-13 devnull sha1((uchar*)path, plen, n->handle, nil);
420 004aa293 2005-07-13 devnull h = dumbhash(n->handle);
421 004aa293 2005-07-13 devnull n->nexthash = t->hash[h];
422 004aa293 2005-07-13 devnull t->hash[h] = n;
424 004aa293 2005-07-13 devnull return n;
428 004aa293 2005-07-13 devnull markctree(Ctree *t)
431 004aa293 2005-07-13 devnull Cnode *n;
433 004aa293 2005-07-13 devnull for(i=0; i<nelem(t->hash); i++)
434 004aa293 2005-07-13 devnull for(n=t->hash[i]; n; n=n->nexthash)
435 004aa293 2005-07-13 devnull if(n->name[0] != '+')
436 004aa293 2005-07-13 devnull n->mark = 1;
440 004aa293 2005-07-13 devnull refreshdisk(void)
443 004aa293 2005-07-13 devnull Cnode *n;
444 004aa293 2005-07-13 devnull Ctree *t;
446 004aa293 2005-07-13 devnull t = config.ctree;
447 004aa293 2005-07-13 devnull for(i=0; i<nelem(t->hash); i++)
448 004aa293 2005-07-13 devnull for(n=t->hash[i]; n; n=n->nexthash){
449 004aa293 2005-07-13 devnull if(n->mfsys)
450 004aa293 2005-07-13 devnull disksync(n->mfsys->disk);
451 004aa293 2005-07-13 devnull if(n->fsys)
452 004aa293 2005-07-13 devnull disksync(n->fsys->disk);
454 004aa293 2005-07-13 devnull return 0;
458 004aa293 2005-07-13 devnull sweepctree(Ctree *t)
461 004aa293 2005-07-13 devnull Cnode *n;
463 004aa293 2005-07-13 devnull /* just zero all the garbage and leave it linked into the tree */
464 004aa293 2005-07-13 devnull for(i=0; i<nelem(t->hash); i++){
465 004aa293 2005-07-13 devnull for(n=t->hash[i]; n; n=n->nexthash){
466 004aa293 2005-07-13 devnull if(!n->mark)
467 004aa293 2005-07-13 devnull continue;
468 004aa293 2005-07-13 devnull n->fsys = nil;
469 004aa293 2005-07-13 devnull free(n->fsysimage);
470 004aa293 2005-07-13 devnull n->fsysimage = nil;
471 004aa293 2005-07-13 devnull memset(n->fsysscore, 0, sizeof n->fsysscore);
472 004aa293 2005-07-13 devnull n->mfsys = nil;
473 004aa293 2005-07-13 devnull n->ismtpt = 0;
474 004aa293 2005-07-13 devnull memset(&n->fsyshandle, 0, sizeof n->fsyshandle);
475 004aa293 2005-07-13 devnull memset(&n->mfsyshandle, 0, sizeof n->mfsyshandle);
480 004aa293 2005-07-13 devnull static Cnode*
481 004aa293 2005-07-13 devnull cnodewalk(Cnode *n, char *name, uint len, int markokay)
483 004aa293 2005-07-13 devnull Cnode *nn;
485 004aa293 2005-07-13 devnull for(nn=n->kidlist; nn; nn=nn->nextsib)
486 004aa293 2005-07-13 devnull if(strncmp(nn->name, name, len) == 0 && nn->name[len] == 0)
487 004aa293 2005-07-13 devnull if(!nn->mark || markokay)
488 004aa293 2005-07-13 devnull return nn;
489 004aa293 2005-07-13 devnull return nil;
493 004aa293 2005-07-13 devnull ctreewalkpath(Ctree *t, char *name, ulong createmtime)
495 004aa293 2005-07-13 devnull Cnode *n, *nn;
496 004aa293 2005-07-13 devnull char *p, *nextp;
498 004aa293 2005-07-13 devnull n = t->root;
499 004aa293 2005-07-13 devnull p = name;
500 004aa293 2005-07-13 devnull for(; *p; p=nextp){
501 004aa293 2005-07-13 devnull n->mark = 0;
502 004aa293 2005-07-13 devnull assert(*p == '/');
504 004aa293 2005-07-13 devnull nextp = strchr(p, '/');
505 004aa293 2005-07-13 devnull if(nextp == nil)
506 004aa293 2005-07-13 devnull nextp = p+strlen(p);
507 004aa293 2005-07-13 devnull if((nn = cnodewalk(n, p, nextp-p, 1)) == nil){
508 004aa293 2005-07-13 devnull if(createmtime == 0)
509 004aa293 2005-07-13 devnull return nil;
510 004aa293 2005-07-13 devnull nn = mkcnode(t, n, p, nextp-p, name, nextp-name);
511 004aa293 2005-07-13 devnull nn->mtime = createmtime;
513 004aa293 2005-07-13 devnull if(nn->mark)
514 004aa293 2005-07-13 devnull nn->mark = 0;
517 004aa293 2005-07-13 devnull n->mark = 0;
518 004aa293 2005-07-13 devnull return n;
522 004aa293 2005-07-13 devnull mkctree(void)
524 004aa293 2005-07-13 devnull Ctree *t;
526 004aa293 2005-07-13 devnull t = emalloc(sizeof *t);
527 004aa293 2005-07-13 devnull t->root = mkcnode(t, nil, "", 0, "", 0);
529 004aa293 2005-07-13 devnull ctreewalkpath(t, "/+log", time(0))->read = logread;
530 004aa293 2005-07-13 devnull ctreewalkpath(t, "/+refreshdisk", time(0))->read = refreshdiskread;
531 004aa293 2005-07-13 devnull ctreewalkpath(t, "/+refreshconfig", time(0))->read = refreshconfigread;
533 004aa293 2005-07-13 devnull return t;
537 004aa293 2005-07-13 devnull ctreemountfsys(Ctree *t, char *path, ulong time, uchar *score, char *file)
539 004aa293 2005-07-13 devnull Cnode *n;
541 004aa293 2005-07-13 devnull if(time == 0)
542 004aa293 2005-07-13 devnull time = 1;
543 004aa293 2005-07-13 devnull n = ctreewalkpath(t, path, time);
544 004aa293 2005-07-13 devnull if(score){
545 004aa293 2005-07-13 devnull if(n->ismtpt && (n->fsysimage || memcmp(n->fsysscore, score, VtScoreSize) != 0)){
546 004aa293 2005-07-13 devnull free(n->fsysimage);
547 004aa293 2005-07-13 devnull n->fsysimage = nil;
548 004aa293 2005-07-13 devnull n->fsys = nil; /* leak (might be other refs) */
550 004aa293 2005-07-13 devnull memmove(n->fsysscore, score, VtScoreSize);
552 004aa293 2005-07-13 devnull if(n->ismtpt && (n->fsysimage==nil || strcmp(n->fsysimage, file) != 0)){
553 004aa293 2005-07-13 devnull free(n->fsysimage);
554 004aa293 2005-07-13 devnull n->fsysimage = nil;
555 004aa293 2005-07-13 devnull n->fsys = nil; /* leak (might be other refs) */
557 004aa293 2005-07-13 devnull n->fsysimage = emalloc(strlen(file)+1);
558 004aa293 2005-07-13 devnull strcpy(n->fsysimage, file);
560 004aa293 2005-07-13 devnull n->ismtpt = 1;
561 004aa293 2005-07-13 devnull return n;
565 004aa293 2005-07-13 devnull cnodebyhandle(Ctree *t, uchar *p)
568 004aa293 2005-07-13 devnull Cnode *n;
570 004aa293 2005-07-13 devnull h = dumbhash(p);
571 004aa293 2005-07-13 devnull for(n=t->hash[h]; n; n=n->nexthash)
572 004aa293 2005-07-13 devnull if(memcmp(n->handle, p, CnodeHandleSize) == 0)
573 004aa293 2005-07-13 devnull return n;
574 004aa293 2005-07-13 devnull return nil;
577 004aa293 2005-07-13 devnull static int
578 004aa293 2005-07-13 devnull parseipandmask(char *s, uchar *ip, uchar *mask)
580 004aa293 2005-07-13 devnull char *p, *q;
582 004aa293 2005-07-13 devnull p = strchr(s, '/');
584 004aa293 2005-07-13 devnull *p++ = 0;
585 004aa293 2005-07-13 devnull if(parseip(ip, s) == ~0UL)
586 004aa293 2005-07-13 devnull return -1;
587 004aa293 2005-07-13 devnull if(p == nil)
588 004aa293 2005-07-13 devnull memset(mask, 0xFF, IPaddrlen);
590 2b3a8c4d 2005-10-29 devnull if(isdigit((uchar)*p) && strtol(p, &q, 10)>=0 && *q==0)
591 004aa293 2005-07-13 devnull *--p = '/';
592 004aa293 2005-07-13 devnull if(parseipmask(mask, p) == ~0UL)
593 004aa293 2005-07-13 devnull return -1;
594 004aa293 2005-07-13 devnull if(*p != '/')
595 004aa293 2005-07-13 devnull *--p = '/';
597 cbeb0b26 2006-04-01 devnull /*fprint(2, "parseipandmask %s => %I %I\n", s, ip, mask); */
598 004aa293 2005-07-13 devnull return 0;
601 004aa293 2005-07-13 devnull static int
602 004aa293 2005-07-13 devnull parsetime(char *s, ulong *time)
604 004aa293 2005-07-13 devnull ulong x;
605 004aa293 2005-07-13 devnull char *p;
609 004aa293 2005-07-13 devnull /* decimal integer is seconds since 1970 */
610 004aa293 2005-07-13 devnull x = strtoul(s, &p, 10);
611 004aa293 2005-07-13 devnull if(x > 0 && *p == 0){
612 004aa293 2005-07-13 devnull *time = x;
613 004aa293 2005-07-13 devnull return 0;
616 004aa293 2005-07-13 devnull /* otherwise expect yyyy/mmdd/hhmm */
617 004aa293 2005-07-13 devnull if(strlen(s) != 14 || s[4] != '/' || s[9] != '/')
618 004aa293 2005-07-13 devnull return -1;
619 004aa293 2005-07-13 devnull for(i=0; i<4; i++)
620 2b3a8c4d 2005-10-29 devnull if(!isdigit((uchar)s[i]) || !isdigit((uchar)s[i+5]) || !isdigit((uchar)s[i+10]))
621 004aa293 2005-07-13 devnull return -1;
622 004aa293 2005-07-13 devnull memset(&tm, 0, sizeof tm);
623 004aa293 2005-07-13 devnull tm.year = atoi(s)-1900;
624 004aa293 2005-07-13 devnull if(tm.year < 0 || tm.year > 200)
625 004aa293 2005-07-13 devnull return -1;
626 004aa293 2005-07-13 devnull tm.mon = (s[5]-'0')*10+s[6]-'0' - 1;
627 004aa293 2005-07-13 devnull if(tm.mon < 0 || tm.mon > 11)
628 004aa293 2005-07-13 devnull return -1;
629 004aa293 2005-07-13 devnull tm.mday = (s[7]-'0')*10+s[8]-'0';
630 004aa293 2005-07-13 devnull if(tm.mday < 0 || tm.mday > 31)
631 004aa293 2005-07-13 devnull return -1;
632 004aa293 2005-07-13 devnull tm.hour = (s[10]-'0')*10+s[11]-'0';
633 004aa293 2005-07-13 devnull if(tm.hour < 0 || tm.hour > 23)
634 004aa293 2005-07-13 devnull return -1;
635 004aa293 2005-07-13 devnull tm.min = (s[12]-'0')*10+s[13]-'0';
636 004aa293 2005-07-13 devnull if(tm.min < 0 || tm.min > 59)
637 004aa293 2005-07-13 devnull return -1;
638 004aa293 2005-07-13 devnull strcpy(tm.zone, "XXX"); /* anything but GMT */
640 004aa293 2005-07-13 devnull print("tm2sec %d/%d/%d/%d/%d\n",
641 004aa293 2005-07-13 devnull tm.year, tm.mon, tm.mday, tm.hour, tm.min);
643 004aa293 2005-07-13 devnull *time = tm2sec(&tm);
644 004aa293 2005-07-13 devnull if(0) print("time %lud\n", *time);
645 004aa293 2005-07-13 devnull return 0;
650 004aa293 2005-07-13 devnull readconfigfile(Config *cp)
652 004aa293 2005-07-13 devnull char *f[10], *image, *p, *pref, *q, *name;
653 004aa293 2005-07-13 devnull int nf, line;
654 004aa293 2005-07-13 devnull uchar scorebuf[VtScoreSize], *score;
655 004aa293 2005-07-13 devnull ulong time;
656 004aa293 2005-07-13 devnull Biobuf *b;
657 004aa293 2005-07-13 devnull Config c;
658 004aa293 2005-07-13 devnull Dir *dir;
660 004aa293 2005-07-13 devnull name = configfile;
661 004aa293 2005-07-13 devnull c = *cp;
662 004aa293 2005-07-13 devnull if((dir = dirstat(name)) == nil)
663 004aa293 2005-07-13 devnull return -1;
664 004aa293 2005-07-13 devnull if(c.mtime == dir->mtime){
665 004aa293 2005-07-13 devnull free(dir);
666 004aa293 2005-07-13 devnull return 0;
668 004aa293 2005-07-13 devnull c.mtime = dir->mtime;
669 004aa293 2005-07-13 devnull free(dir);
670 ff3dce55 2007-03-25 devnull if((b = Bopen(name, OREAD)) == nil)
671 004aa293 2005-07-13 devnull return -1;
674 004aa293 2005-07-13 devnull * Reuse old tree, garbage collecting entries that
675 004aa293 2005-07-13 devnull * are not mentioned in the new config file.
677 004aa293 2005-07-13 devnull if(c.ctree == nil)
678 004aa293 2005-07-13 devnull c.ctree = mkctree();
680 004aa293 2005-07-13 devnull markctree(c.ctree);
681 004aa293 2005-07-13 devnull c.ok = nil;
682 004aa293 2005-07-13 devnull c.nok = 0;
684 004aa293 2005-07-13 devnull line = 0;
685 004aa293 2005-07-13 devnull for(; (p=Brdstr(b, '\n', 1)) != nil; free(p)){
687 004aa293 2005-07-13 devnull if((q = strchr(p, '#')) != nil)
689 004aa293 2005-07-13 devnull nf = tokenize(p, f, nelem(f));
690 004aa293 2005-07-13 devnull if(nf == 0)
691 004aa293 2005-07-13 devnull continue;
692 004aa293 2005-07-13 devnull if(strcmp(f[0], "mount") == 0){
693 004aa293 2005-07-13 devnull if(nf != 4){
694 004aa293 2005-07-13 devnull werrstr("syntax error: mount /path /dev|score mtime");
695 004aa293 2005-07-13 devnull goto badline;
697 004aa293 2005-07-13 devnull if(f[1][0] != '/'){
698 004aa293 2005-07-13 devnull werrstr("unrooted path %s", f[1]);
699 004aa293 2005-07-13 devnull goto badline;
701 004aa293 2005-07-13 devnull score = nil;
702 004aa293 2005-07-13 devnull image = nil;
703 004aa293 2005-07-13 devnull if(f[2][0] == '/'){
704 004aa293 2005-07-13 devnull if(access(f[2], AEXIST) < 0){
705 004aa293 2005-07-13 devnull werrstr("image %s does not exist", f[2]);
706 004aa293 2005-07-13 devnull goto badline;
708 004aa293 2005-07-13 devnull image = f[2];
710 004aa293 2005-07-13 devnull if(vtparsescore(f[2], &pref, scorebuf) < 0){
711 004aa293 2005-07-13 devnull werrstr("bad score %s", f[2]);
712 004aa293 2005-07-13 devnull goto badline;
714 004aa293 2005-07-13 devnull score = scorebuf;
716 004aa293 2005-07-13 devnull if(parsetime(f[3], &time) < 0){
717 004aa293 2005-07-13 devnull fprint(2, "%s:%d: bad time %s\n", name, line, f[3]);
718 004aa293 2005-07-13 devnull time = 1;
720 004aa293 2005-07-13 devnull ctreemountfsys(c.ctree, f[1], time, score, image);
721 004aa293 2005-07-13 devnull continue;
723 004aa293 2005-07-13 devnull if(strcmp(f[0], "allow") == 0 || strcmp(f[0], "deny") == 0){
724 004aa293 2005-07-13 devnull if(nf != 2){
725 004aa293 2005-07-13 devnull werrstr("syntax error: allow|deny ip[/mask]");
726 004aa293 2005-07-13 devnull goto badline;
728 004aa293 2005-07-13 devnull c.ok = erealloc(c.ok, (c.nok+1)*sizeof(c.ok[0]));
729 004aa293 2005-07-13 devnull if(parseipandmask(f[1], c.ok[c.nok].ip, c.ok[c.nok].mask) < 0){
730 004aa293 2005-07-13 devnull werrstr("bad ip[/mask]: %s", f[1]);
731 004aa293 2005-07-13 devnull goto badline;
733 004aa293 2005-07-13 devnull c.ok[c.nok].okay = (strcmp(f[0], "allow") == 0);
734 004aa293 2005-07-13 devnull c.nok++;
735 004aa293 2005-07-13 devnull continue;
737 004aa293 2005-07-13 devnull werrstr("unknown verb '%s'", f[0]);
738 004aa293 2005-07-13 devnull badline:
739 004aa293 2005-07-13 devnull fprint(2, "%s:%d: %r\n", name, line);
741 004aa293 2005-07-13 devnull Bterm(b);
743 004aa293 2005-07-13 devnull sweepctree(c.ctree);
744 004aa293 2005-07-13 devnull free(cp->ok);
745 004aa293 2005-07-13 devnull *cp = c;
746 004aa293 2005-07-13 devnull return 0;
750 004aa293 2005-07-13 devnull ipokay(uchar *ip, ushort port)
753 004aa293 2005-07-13 devnull uchar ipx[IPaddrlen];
754 004aa293 2005-07-13 devnull Ipokay *ok;
756 004aa293 2005-07-13 devnull for(i=0; i<config.nok; i++){
757 004aa293 2005-07-13 devnull ok = &config.ok[i];
758 004aa293 2005-07-13 devnull maskip(ip, ok->mask, ipx);
759 004aa293 2005-07-13 devnull if(0) fprint(2, "%I & %I = %I (== %I?)\n",
760 004aa293 2005-07-13 devnull ip, ok->mask, ipx, ok->ip);
761 004aa293 2005-07-13 devnull if(memcmp(ipx, ok->ip, IPaddrlen) == 0)
762 004aa293 2005-07-13 devnull return ok->okay;
764 004aa293 2005-07-13 devnull if(config.nok == 0) /* all is permitted */
765 004aa293 2005-07-13 devnull return 1;
766 004aa293 2005-07-13 devnull /* otherwise default is none allowed */
767 004aa293 2005-07-13 devnull return 0;
770 004aa293 2005-07-13 devnull Nfs3Status
771 004aa293 2005-07-13 devnull cnodelookup(Ctree *t, Cnode **np, char *name)
773 004aa293 2005-07-13 devnull Cnode *n, *nn;
775 004aa293 2005-07-13 devnull n = *np;
776 004aa293 2005-07-13 devnull if(n->isblackhole)
777 004aa293 2005-07-13 devnull return Nfs3Ok;
778 004aa293 2005-07-13 devnull if((nn = cnodewalk(n, name, strlen(name), 0)) == nil){
779 004aa293 2005-07-13 devnull if(n->ismtpt || n->fsys){
780 004aa293 2005-07-13 devnull if((nn = cnodewalk(n, "", 0, 1)) == nil){
781 004aa293 2005-07-13 devnull nn = mkcnode(t, n, "", 0, (char*)n->handle, SHA1dlen);
782 004aa293 2005-07-13 devnull nn->isblackhole = 1;
784 004aa293 2005-07-13 devnull nn->mark = 0;
787 004aa293 2005-07-13 devnull if(nn == nil)
788 004aa293 2005-07-13 devnull return Nfs3ErrNoEnt;
789 004aa293 2005-07-13 devnull *np = nn;
790 004aa293 2005-07-13 devnull return Nfs3Ok;
793 004aa293 2005-07-13 devnull Nfs3Status
794 004aa293 2005-07-13 devnull cnodegetattr(Cnode *n, Nfs3Attr *attr)
796 004aa293 2005-07-13 devnull memset(attr, 0, sizeof *attr);
797 004aa293 2005-07-13 devnull if(n->read){
798 004aa293 2005-07-13 devnull attr->type = Nfs3FileReg;
799 004aa293 2005-07-13 devnull attr->mode = 0444;
800 004aa293 2005-07-13 devnull attr->size = 512;
801 004aa293 2005-07-13 devnull attr->nlink = 1;
803 004aa293 2005-07-13 devnull attr->type = Nfs3FileDir;
804 004aa293 2005-07-13 devnull attr->mode = 0555;
805 004aa293 2005-07-13 devnull attr->size = 1024;
806 004aa293 2005-07-13 devnull attr->nlink = 10;
808 004aa293 2005-07-13 devnull attr->fileid = *(u64int*)n->handle;
809 004aa293 2005-07-13 devnull attr->atime.sec = n->mtime;
810 004aa293 2005-07-13 devnull attr->mtime.sec = n->mtime;
811 004aa293 2005-07-13 devnull attr->ctime.sec = n->mtime;
812 004aa293 2005-07-13 devnull return Nfs3Ok;
815 004aa293 2005-07-13 devnull Nfs3Status
816 004aa293 2005-07-13 devnull cnodereaddir(Cnode *n, u32int count, u64int cookie, uchar **pdata, u32int *pcount, u1int *peof)
818 004aa293 2005-07-13 devnull uchar *data, *p, *ep, *np;
819 004aa293 2005-07-13 devnull u64int c;
820 004aa293 2005-07-13 devnull Nfs3Entry ne;
822 004aa293 2005-07-13 devnull n = n->kidlist;
823 004aa293 2005-07-13 devnull c = cookie;
824 004aa293 2005-07-13 devnull for(; c && n; c--)
825 004aa293 2005-07-13 devnull n = n->nextsib;
826 004aa293 2005-07-13 devnull if(n == nil){
827 004aa293 2005-07-13 devnull *pdata = 0;
828 004aa293 2005-07-13 devnull *pcount = 0;
829 004aa293 2005-07-13 devnull *peof = 1;
830 004aa293 2005-07-13 devnull return Nfs3Ok;
833 004aa293 2005-07-13 devnull data = emalloc(count);
834 004aa293 2005-07-13 devnull p = data;
835 004aa293 2005-07-13 devnull ep = data+count;
836 004aa293 2005-07-13 devnull while(n && p < ep){
837 004aa293 2005-07-13 devnull if(n->mark || n->name[0] == '+'){
838 004aa293 2005-07-13 devnull n = n->nextsib;
839 004aa293 2005-07-13 devnull ++cookie;
840 004aa293 2005-07-13 devnull continue;
842 004aa293 2005-07-13 devnull ne.name = n->name;
843 80b4aedc 2006-05-04 devnull ne.namelen = strlen(n->name);
844 004aa293 2005-07-13 devnull ne.cookie = ++cookie;
845 004aa293 2005-07-13 devnull ne.fileid = *(u64int*)n->handle;
846 004aa293 2005-07-13 devnull if(nfs3entrypack(p, ep, &np, &ne) < 0)
849 004aa293 2005-07-13 devnull n = n->nextsib;
851 004aa293 2005-07-13 devnull *pdata = data;
852 004aa293 2005-07-13 devnull *pcount = p - data;
853 004aa293 2005-07-13 devnull *peof = n==nil;
854 004aa293 2005-07-13 devnull return Nfs3Ok;
858 004aa293 2005-07-13 devnull timerproc(void *v)
860 004aa293 2005-07-13 devnull for(;;){
861 004aa293 2005-07-13 devnull sleep(60*1000);
862 004aa293 2005-07-13 devnull sendp(timerchan, 0);
867 004aa293 2005-07-13 devnull timerthread(void *v)
869 004aa293 2005-07-13 devnull for(;;){
870 004aa293 2005-07-13 devnull recvp(timerchan);
871 cbeb0b26 2006-04-01 devnull /* refreshconfig(); */
876 004aa293 2005-07-13 devnull * Actually serve the NFS requests. Called from nfs3srv.c.
877 004aa293 2005-07-13 devnull * Each request runs in its own thread (coroutine).
879 004aa293 2005-07-13 devnull * Decrypted handles have the form:
881 004aa293 2005-07-13 devnull * config[20] - SHA1 hash identifying a config tree node
882 004aa293 2005-07-13 devnull * glob[10] - SHA1 hash prefix identifying a glob state
883 004aa293 2005-07-13 devnull * fsyshandle[<=10] - disk file system handle (usually 4 bytes)
887 004aa293 2005-07-13 devnull * A fid represents a point in the file tree.
888 004aa293 2005-07-13 devnull * There are three components, all derived from the handle:
890 004aa293 2005-07-13 devnull * - config tree position (also used to find fsys)
891 004aa293 2005-07-13 devnull * - glob state for exclusions
892 004aa293 2005-07-13 devnull * - file system position
896 004aa293 2005-07-13 devnull HAccess,
899 004aa293 2005-07-13 devnull HDotdot,
902 004aa293 2005-07-13 devnull typedef struct Fid Fid;
903 004aa293 2005-07-13 devnull struct Fid
905 004aa293 2005-07-13 devnull Cnode *cnode;
906 004aa293 2005-07-13 devnull Fsys *fsys;
907 004aa293 2005-07-13 devnull Nfs3Handle fsyshandle;
911 004aa293 2005-07-13 devnull handlecmp(Nfs3Handle *h, Nfs3Handle *h1)
913 004aa293 2005-07-13 devnull if(h->len != h1->len)
914 004aa293 2005-07-13 devnull return h->len - h1->len;
915 004aa293 2005-07-13 devnull return memcmp(h->h, h1->h, h->len);
918 004aa293 2005-07-13 devnull Nfs3Status
919 004aa293 2005-07-13 devnull handletofid(Nfs3Handle *eh, Fid *fid, int mode)
921 004aa293 2005-07-13 devnull int domount;
922 004aa293 2005-07-13 devnull Cnode *n;
923 004aa293 2005-07-13 devnull Disk *disk, *cdisk;
924 004aa293 2005-07-13 devnull Fsys *fsys;
925 004aa293 2005-07-13 devnull Nfs3Status ok;
926 004aa293 2005-07-13 devnull Nfs3Handle h2, *h, *fh;
928 004aa293 2005-07-13 devnull memset(fid, 0, sizeof *fid);
930 004aa293 2005-07-13 devnull domount = 1;
931 004aa293 2005-07-13 devnull if(mode == HDotdot)
932 004aa293 2005-07-13 devnull domount = 0;
934 004aa293 2005-07-13 devnull * Not necessary, but speeds up ls -l /dump/2005
935 004aa293 2005-07-13 devnull * HAttr and HAccess must be handled the same way
936 004aa293 2005-07-13 devnull * because both can be used to fetch attributes.
937 004aa293 2005-07-13 devnull * Acting differently yields inconsistencies at mount points,
938 004aa293 2005-07-13 devnull * and causes FreeBSD ls -l to fail.
940 004aa293 2005-07-13 devnull if(mode == HAttr || mode == HAccess)
941 004aa293 2005-07-13 devnull domount = 0;
944 004aa293 2005-07-13 devnull * Decrypt handle.
946 004aa293 2005-07-13 devnull h2 = *eh;
947 004aa293 2005-07-13 devnull h = &h2;
948 004aa293 2005-07-13 devnull if((ok = hdecrypt(h)) != Nfs3Ok)
949 004aa293 2005-07-13 devnull return ok;
950 004aa293 2005-07-13 devnull trace("handletofid: decrypted %.*lH\n", h->len, h->h);
951 004aa293 2005-07-13 devnull if(h->len < FsysHandleOffset)
952 004aa293 2005-07-13 devnull return Nfs3ErrBadHandle;
955 004aa293 2005-07-13 devnull * Find place in config tree.
957 004aa293 2005-07-13 devnull if((n = cnodebyhandle(config.ctree, h->h)) == nil)
958 004aa293 2005-07-13 devnull return Nfs3ErrStale;
959 004aa293 2005-07-13 devnull fid->cnode = n;
961 004aa293 2005-07-13 devnull if(n->ismtpt && domount){
963 004aa293 2005-07-13 devnull * Open fsys for mount point if needed.
965 004aa293 2005-07-13 devnull if(n->mfsys == nil){
966 004aa293 2005-07-13 devnull trace("handletofid: mounting %V/%s\n", n->fsysscore, n->fsysimage);
967 004aa293 2005-07-13 devnull if(n->fsysimage){
968 004aa293 2005-07-13 devnull if(strcmp(n->fsysimage, "/dev/null") == 0)
969 004aa293 2005-07-13 devnull return Nfs3ErrAcces;
970 004aa293 2005-07-13 devnull if((disk = diskopenfile(n->fsysimage)) == nil){
971 004aa293 2005-07-13 devnull fprint(2, "cannot open disk %s: %r\n", n->fsysimage);
972 004aa293 2005-07-13 devnull return Nfs3ErrIo;
974 004aa293 2005-07-13 devnull if((cdisk = diskcache(disk, blocksize, 64)) == nil){
975 004aa293 2005-07-13 devnull fprint(2, "cannot cache disk %s: %r\n", n->fsysimage);
976 004aa293 2005-07-13 devnull diskclose(disk);
978 004aa293 2005-07-13 devnull disk = cdisk;
980 004aa293 2005-07-13 devnull if((disk = diskopenventi(vcache, n->fsysscore)) == nil){
981 004aa293 2005-07-13 devnull fprint(2, "cannot open venti disk %V: %r\n", n->fsysscore);
982 004aa293 2005-07-13 devnull return Nfs3ErrIo;
985 004aa293 2005-07-13 devnull if((fsys = fsysopen(disk)) == nil){
986 004aa293 2005-07-13 devnull fprint(2, "cannot open fsys on %V: %r\n", n->fsysscore);
987 004aa293 2005-07-13 devnull diskclose(disk);
988 004aa293 2005-07-13 devnull return Nfs3ErrIo;
990 004aa293 2005-07-13 devnull n->mfsys = fsys;
991 004aa293 2005-07-13 devnull fsysroot(fsys, &n->mfsyshandle);
995 004aa293 2005-07-13 devnull * Use inner handle.
997 004aa293 2005-07-13 devnull fid->fsys = n->mfsys;
998 004aa293 2005-07-13 devnull fid->fsyshandle = n->mfsyshandle;
1001 004aa293 2005-07-13 devnull * Use fsys handle from tree or from handle.
1002 004aa293 2005-07-13 devnull * This assumes that fsyshandle was set by fidtohandle
1003 004aa293 2005-07-13 devnull * earlier, so it's not okay to reuse handles (except the root)
1004 004aa293 2005-07-13 devnull * across sessions. The encryption above makes and
1005 004aa293 2005-07-13 devnull * enforces the same restriction, so this is okay.
1007 004aa293 2005-07-13 devnull fid->fsys = n->fsys;
1008 004aa293 2005-07-13 devnull fh = &fid->fsyshandle;
1009 004aa293 2005-07-13 devnull if(n->isblackhole){
1010 004aa293 2005-07-13 devnull fh->len = h->len-FsysHandleOffset;
1011 004aa293 2005-07-13 devnull memmove(fh->h, h->h+FsysHandleOffset, fh->len);
1013 004aa293 2005-07-13 devnull *fh = n->fsyshandle;
1014 004aa293 2005-07-13 devnull trace("handletofid: fsyshandle %.*lH\n", fh->len, fh->h);
1018 004aa293 2005-07-13 devnull * TO DO (maybe): some sort of path restriction here.
1020 004aa293 2005-07-13 devnull trace("handletofid: cnode %s fsys %p fsyshandle %.*lH\n",
1021 004aa293 2005-07-13 devnull n->name, fid->fsys, fid->fsyshandle.len, fid->fsyshandle.h);
1022 004aa293 2005-07-13 devnull return Nfs3Ok;
1026 004aa293 2005-07-13 devnull _fidtohandle(Fid *fid, Nfs3Handle *h)
1028 004aa293 2005-07-13 devnull Cnode *n;
1030 004aa293 2005-07-13 devnull n = fid->cnode;
1032 004aa293 2005-07-13 devnull * Record fsys handle in n, don't bother sending it to client
1033 004aa293 2005-07-13 devnull * for black holes.
1035 004aa293 2005-07-13 devnull n->fsys = fid->fsys;
1036 004aa293 2005-07-13 devnull if(!n->isblackhole){
1037 004aa293 2005-07-13 devnull n->fsyshandle = fid->fsyshandle;
1038 004aa293 2005-07-13 devnull fid->fsyshandle.len = 0;
1040 004aa293 2005-07-13 devnull memmove(h->h, n->handle, CnodeHandleSize);
1041 004aa293 2005-07-13 devnull memmove(h->h+FsysHandleOffset, fid->fsyshandle.h, fid->fsyshandle.len);
1042 004aa293 2005-07-13 devnull h->len = FsysHandleOffset+fid->fsyshandle.len;
1046 004aa293 2005-07-13 devnull fidtohandle(Fid *fid, Nfs3Handle *h)
1048 004aa293 2005-07-13 devnull _fidtohandle(fid, h);
1049 004aa293 2005-07-13 devnull hencrypt(h);
1053 004aa293 2005-07-13 devnull setrootfid(void)
1055 004aa293 2005-07-13 devnull Fid fid;
1057 004aa293 2005-07-13 devnull memset(&fid, 0, sizeof fid);
1058 004aa293 2005-07-13 devnull fid.cnode = config.ctree->root;
1059 004aa293 2005-07-13 devnull _fidtohandle(&fid, &root);
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 c59c3b21 2007-06-04 devnull if(!n->isblackhole)
1187 c59c3b21 2007-06-04 devnull fid.fsyshandle = n->fsyshandle;
1188 004aa293 2005-07-13 devnull fid.cnode = n;
1190 004aa293 2005-07-13 devnull fidtohandle(&fid, nh);
1191 004aa293 2005-07-13 devnull return Nfs3Ok;
1194 004aa293 2005-07-13 devnull Nfs3Status
1195 004aa293 2005-07-13 devnull fsaccess(SunAuthUnix *au, Nfs3Handle *h, u32int want, u32int *got, Nfs3Attr *attr)
1197 004aa293 2005-07-13 devnull Fid fid;
1198 004aa293 2005-07-13 devnull Nfs3Status ok;
1200 004aa293 2005-07-13 devnull trace("access %.*lH 0x%ux\n", h->len, h->h, want);
1201 004aa293 2005-07-13 devnull if((ok = handletofid(h, &fid, HAccess)) != Nfs3Ok)
1202 004aa293 2005-07-13 devnull return ok;
1203 004aa293 2005-07-13 devnull if(fid.fsys)
1204 004aa293 2005-07-13 devnull return fsysaccess(fid.fsys, au, &fid.fsyshandle, want, got, attr);
1205 004aa293 2005-07-13 devnull *got = want & (Nfs3AccessRead|Nfs3AccessLookup|Nfs3AccessExecute);
1206 004aa293 2005-07-13 devnull return cnodegetattr(fid.cnode, attr);
1209 004aa293 2005-07-13 devnull Nfs3Status
1210 004aa293 2005-07-13 devnull fsreadlink(SunAuthUnix *au, Nfs3Handle *h, char **link)
1212 004aa293 2005-07-13 devnull Fid fid;
1213 004aa293 2005-07-13 devnull Nfs3Status ok;
1215 004aa293 2005-07-13 devnull trace("readlink %.*lH\n", h->len, h->h);
1216 004aa293 2005-07-13 devnull if((ok = handletofid(h, &fid, HRead)) != Nfs3Ok)
1217 004aa293 2005-07-13 devnull return ok;
1218 004aa293 2005-07-13 devnull if(fid.fsys)
1219 004aa293 2005-07-13 devnull return fsysreadlink(fid.fsys, au, &fid.fsyshandle, link);
1220 004aa293 2005-07-13 devnull *link = 0;
1221 004aa293 2005-07-13 devnull return Nfs3ErrNotSupp;
1224 004aa293 2005-07-13 devnull Nfs3Status
1225 004aa293 2005-07-13 devnull fsreadfile(SunAuthUnix *au, Nfs3Handle *h, u32int count, u64int offset, uchar **data, u32int *pcount, u1int *peof)
1227 004aa293 2005-07-13 devnull Fid fid;
1228 004aa293 2005-07-13 devnull Nfs3Status ok;
1230 004aa293 2005-07-13 devnull trace("readfile %.*lH\n", h->len, h->h);
1231 004aa293 2005-07-13 devnull if((ok = handletofid(h, &fid, HRead)) != Nfs3Ok)
1232 004aa293 2005-07-13 devnull return ok;
1233 004aa293 2005-07-13 devnull if(fid.cnode->read)
1234 004aa293 2005-07-13 devnull return fid.cnode->read(fid.cnode, count, offset, data, pcount, peof);
1235 004aa293 2005-07-13 devnull if(fid.fsys)
1236 004aa293 2005-07-13 devnull return fsysreadfile(fid.fsys, au, &fid.fsyshandle, count, offset, data, pcount, peof);
1237 004aa293 2005-07-13 devnull return Nfs3ErrNotSupp;
1240 004aa293 2005-07-13 devnull Nfs3Status
1241 004aa293 2005-07-13 devnull fsreaddir(SunAuthUnix *au, Nfs3Handle *h, u32int len, u64int cookie, uchar **pdata, u32int *pcount, u1int *peof)
1243 004aa293 2005-07-13 devnull Fid fid;
1244 004aa293 2005-07-13 devnull Nfs3Status ok;
1246 004aa293 2005-07-13 devnull trace("readdir %.*lH\n", h->len, h->h);
1247 004aa293 2005-07-13 devnull if((ok = handletofid(h, &fid, HRead)) != Nfs3Ok)
1248 004aa293 2005-07-13 devnull return ok;
1249 004aa293 2005-07-13 devnull if(fid.fsys)
1250 004aa293 2005-07-13 devnull return fsysreaddir(fid.fsys, au, &fid.fsyshandle, len, cookie, pdata, pcount, peof);
1251 004aa293 2005-07-13 devnull return cnodereaddir(fid.cnode, len, cookie, pdata, pcount, peof);
1254 004aa293 2005-07-13 devnull Nfs3Status
1255 004aa293 2005-07-13 devnull logread(Cnode *n, u32int count, u64int offset, uchar **data, u32int *pcount, u1int *peof)
1257 004aa293 2005-07-13 devnull *pcount = 0;
1258 004aa293 2005-07-13 devnull *peof = 1;
1259 004aa293 2005-07-13 devnull return Nfs3Ok;
1262 004aa293 2005-07-13 devnull Nfs3Status
1263 004aa293 2005-07-13 devnull refreshdiskread(Cnode *n, u32int count, u64int offset, uchar **data, u32int *pcount, u1int *peof)
1265 004aa293 2005-07-13 devnull char buf[128];
1267 004aa293 2005-07-13 devnull if(offset != 0){
1268 004aa293 2005-07-13 devnull *pcount = 0;
1269 004aa293 2005-07-13 devnull *peof = 1;
1270 004aa293 2005-07-13 devnull return Nfs3Ok;
1272 004aa293 2005-07-13 devnull if(refreshdisk() < 0)
1273 004aa293 2005-07-13 devnull snprint(buf, sizeof buf, "refreshdisk: %r\n");
1275 004aa293 2005-07-13 devnull strcpy(buf, "ok\n");
1276 004aa293 2005-07-13 devnull *data = emalloc(strlen(buf));
1277 004aa293 2005-07-13 devnull strcpy((char*)*data, buf);
1278 004aa293 2005-07-13 devnull *pcount = strlen(buf);
1279 004aa293 2005-07-13 devnull *peof = 1;
1280 004aa293 2005-07-13 devnull return Nfs3Ok;
1283 004aa293 2005-07-13 devnull Nfs3Status
1284 004aa293 2005-07-13 devnull refreshconfigread(Cnode *n, u32int count, u64int offset, uchar **data, u32int *pcount, u1int *peof)
1286 004aa293 2005-07-13 devnull char buf[128];
1288 004aa293 2005-07-13 devnull if(offset != 0){
1289 004aa293 2005-07-13 devnull *pcount = 0;
1290 004aa293 2005-07-13 devnull *peof = 1;
1291 004aa293 2005-07-13 devnull return Nfs3Ok;
1293 004aa293 2005-07-13 devnull if(readconfigfile(&config) < 0)
1294 004aa293 2005-07-13 devnull snprint(buf, sizeof buf, "readconfig: %r\n");
1296 004aa293 2005-07-13 devnull strcpy(buf, "ok\n");
1297 004aa293 2005-07-13 devnull *data = emalloc(strlen(buf));
1298 004aa293 2005-07-13 devnull strcpy((char*)*data, buf);
1299 004aa293 2005-07-13 devnull *pcount = strlen(buf);
1300 004aa293 2005-07-13 devnull *peof = 1;
1301 004aa293 2005-07-13 devnull return Nfs3Ok;
