2 5551e51d 2006-07-23 devnull * 9P to FUSE translator. Acts as FUSE server, 9P client.
3 5551e51d 2006-07-23 devnull * Mounts 9P servers via FUSE kernel module.
5 5551e51d 2006-07-23 devnull * There are four procs in this threaded program
6 5551e51d 2006-07-23 devnull * (ignoring the one that runs main and then exits).
7 5551e51d 2006-07-23 devnull * The first proc reads FUSE requests from /dev/fuse.
8 5551e51d 2006-07-23 devnull * It sends the requests over a channel to a second proc,
9 5551e51d 2006-07-23 devnull * which serves the requests. Each request runs in a
10 5551e51d 2006-07-23 devnull * thread in that second proc. Those threads do write
11 5551e51d 2006-07-23 devnull * FUSE replies, which in theory might block, but in practice don't.
12 5551e51d 2006-07-23 devnull * The 9P interactions are handled by lib9pclient, which
13 5551e51d 2006-07-23 devnull * allocates two more procs, one for reading and one for
14 5551e51d 2006-07-23 devnull * writing the 9P connection. Thus the many threads in the
15 5551e51d 2006-07-23 devnull * request proc can do 9P interactions without blocking.
18 05f50fe6 2006-07-23 devnull #define _GNU_SOURCE 1 /* for O_DIRECTORY on Linux */
19 5551e51d 2006-07-23 devnull #include "a.h"
21 05f50fe6 2006-07-23 devnull /* GNUisms */
22 05f50fe6 2006-07-23 devnull #ifndef O_DIRECTORY
23 05f50fe6 2006-07-23 devnull #define O_DIRECTORY 0
26 05f50fe6 2006-07-23 devnull #ifndef O_LARGEFILE
27 7dc6d244 2008-06-19 rsc # define O_LARGEFILE 0
31 7dc6d244 2008-06-19 rsc * Work around glibc's broken <bits/fcntl.h> which defines
32 7dc6d244 2008-06-19 rsc * O_LARGEFILE to 0 on 64 bit architectures. But, on those same
33 7dc6d244 2008-06-19 rsc * architectures, linux _forces_ O_LARGEFILE (which is always
34 7dc6d244 2008-06-19 rsc * 0100000 in the kernel) at each file open. FUSE is all too
35 7dc6d244 2008-06-19 rsc * happy to pass the flag onto us, where we'd have no idea what
36 7dc6d244 2008-06-19 rsc * to do with it if we trusted glibc.
38 9bcee1f0 2014-12-02 rsc * On ARM however, the O_LARGEFILE is set correctly.
41 9bcee1f0 2014-12-02 rsc #if defined(__linux__) && !defined(__arm__)
42 7dc6d244 2008-06-19 rsc # undef O_LARGEFILE
43 7dc6d244 2008-06-19 rsc # define O_LARGEFILE 0100000
46 83ab7d88 2007-11-27 rsc #ifndef O_CLOEXEC
47 83ab7d88 2007-11-27 rsc # if defined(__linux__)
48 83ab7d88 2007-11-27 rsc # define O_CLOEXEC 02000000 /* Sigh */
50 83ab7d88 2007-11-27 rsc # define O_CLOEXEC 0
54 93f9789c 2020-01-13 rsc #ifndef FMODE_EXEC
55 93f9789c 2020-01-13 rsc # if defined(__linux__)
56 93f9789c 2020-01-13 rsc # define FMODE_EXEC 040
58 93f9789c 2020-01-13 rsc # define FMODE_EXEC 0
62 5551e51d 2006-07-23 devnull int debug;
63 5551e51d 2006-07-23 devnull char *argv0;
64 9ec386fe 2007-06-21 devnull char *aname = "";
65 5551e51d 2006-07-23 devnull void fusedispatch(void*);
66 5551e51d 2006-07-23 devnull Channel *fusechan;
70 5551e51d 2006-07-23 devnull STACK = 8192
74 5551e51d 2006-07-23 devnull * The number of seconds that the kernel can cache
75 5551e51d 2006-07-23 devnull * returned file attributes. FUSE's default is 1.0.
76 5551e51d 2006-07-23 devnull * I haven't experimented with using 0.
78 5551e51d 2006-07-23 devnull double attrtimeout = 1.0;
81 5551e51d 2006-07-23 devnull * The number of seconds that the kernel can cache
82 5551e51d 2006-07-23 devnull * the returned entry nodeids returned by lookup.
83 5551e51d 2006-07-23 devnull * I haven't experimented with other values.
85 5551e51d 2006-07-23 devnull double entrytimeout = 1.0;
87 5551e51d 2006-07-23 devnull CFsys *fsys;
88 5551e51d 2006-07-23 devnull CFid *fsysroot;
89 9ec386fe 2007-06-21 devnull void init9p(char*, char*);
92 5551e51d 2006-07-23 devnull usage(void)
94 9ec386fe 2007-06-21 devnull fprint(2, "usage: 9pfuse [-D] [-A attrtimeout] [-a aname] address mtpt\n");
98 5551e51d 2006-07-23 devnull void fusereader(void*);
99 e63025d0 2008-04-17 rsc void watchfd(void*);
102 5551e51d 2006-07-23 devnull threadmain(int argc, char **argv)
104 5551e51d 2006-07-23 devnull ARGBEGIN{
105 5551e51d 2006-07-23 devnull case 'D':
106 5551e51d 2006-07-23 devnull chatty9pclient++;
107 5551e51d 2006-07-23 devnull debug++;
109 9ec386fe 2007-06-21 devnull case 'A':
110 5551e51d 2006-07-23 devnull attrtimeout = atof(EARGF(usage()));
112 9ec386fe 2007-06-21 devnull case 'a':
113 9ec386fe 2007-06-21 devnull aname = EARGF(usage());
115 5551e51d 2006-07-23 devnull default:
116 5551e51d 2006-07-23 devnull usage();
119 5551e51d 2006-07-23 devnull if(argc != 2)
120 5551e51d 2006-07-23 devnull usage();
122 5551e51d 2006-07-23 devnull quotefmtinstall();
123 5551e51d 2006-07-23 devnull fmtinstall('F', fcallfmt);
124 5551e51d 2006-07-23 devnull fmtinstall('M', dirmodefmt);
125 5551e51d 2006-07-23 devnull fmtinstall('G', fusefmt);
127 a695bc7d 2006-07-23 devnull setsid(); /* won't be able to use console, but can't be interrupted */
129 9ec386fe 2007-06-21 devnull init9p(argv[0], aname);
130 5551e51d 2006-07-23 devnull initfuse(argv[1]);
132 5551e51d 2006-07-23 devnull fusechan = chancreate(sizeof(void*), 0);
133 5551e51d 2006-07-23 devnull proccreate(fusedispatch, nil, STACK);
134 5551e51d 2006-07-23 devnull sendp(fusechan, nil); /* sync */
136 5551e51d 2006-07-23 devnull proccreate(fusereader, nil, STACK);
138 a83ccf38 2006-07-27 devnull * Now that we're serving FUSE, we can wait
139 a83ccf38 2006-07-27 devnull * for the mount to finish and exit back to the user.
141 a83ccf38 2006-07-27 devnull waitfuse();
142 5551e51d 2006-07-23 devnull threadexits(0);
146 5551e51d 2006-07-23 devnull fusereader(void *v)
148 5551e51d 2006-07-23 devnull FuseMsg *m;
150 5551e51d 2006-07-23 devnull while((m = readfusemsg()) != nil)
151 5551e51d 2006-07-23 devnull sendp(fusechan, m);
153 5551e51d 2006-07-23 devnull fusemtpt = nil; /* no need to unmount */
154 5551e51d 2006-07-23 devnull threadexitsall(0);
158 9ec386fe 2007-06-21 devnull init9p(char *addr, char *spec)
162 e63025d0 2008-04-17 rsc if(strcmp(addr, "-") == 0)
165 e63025d0 2008-04-17 rsc if((fd = dial(netmkaddr(addr, "tcp", "564"), nil, nil, nil)) < 0)
166 e63025d0 2008-04-17 rsc sysfatal("dial %s: %r", addr);
167 e63025d0 2008-04-17 rsc proccreate(watchfd, (void*)(uintptr)fd, STACK);
168 9ec386fe 2007-06-21 devnull if((fsys = fsmount(fd, spec)) == nil)
169 5551e51d 2006-07-23 devnull sysfatal("fsmount: %r");
170 5551e51d 2006-07-23 devnull fsysroot = fsroot(fsys);
174 5551e51d 2006-07-23 devnull * FUSE uses nodeids to refer to active "struct inodes"
175 5551e51d 2006-07-23 devnull * (9P's unopened fids). FUSE uses fhs to refer to active
176 fa325e9b 2020-01-10 cross * "struct fuse_files" (9P's opened fids). The choice of
177 5551e51d 2006-07-23 devnull * numbers is up to us except that nodeid 1 is the root directory.
178 fa325e9b 2020-01-10 cross * We use the same number space for both and call the
179 5551e51d 2006-07-23 devnull * bookkeeping structure a FuseFid.
181 fa325e9b 2020-01-10 cross * FUSE requires nodeids to have associated generation
182 fa325e9b 2020-01-10 cross * numbers. If we reuse a nodeid, we have to bump the
183 5551e51d 2006-07-23 devnull * generation number to guarantee that the nodeid,gen
184 5551e51d 2006-07-23 devnull * combination is never reused.
186 5551e51d 2006-07-23 devnull * There are also inode numbers returned in directory reads
187 5551e51d 2006-07-23 devnull * and file attributes, but these do NOT need to match the nodeids.
188 5551e51d 2006-07-23 devnull * We use a combination of qid.path and qid.type as the inode
189 5551e51d 2006-07-23 devnull * number.
192 5551e51d 2006-07-23 devnull * TO DO: reference count the fids.
194 5551e51d 2006-07-23 devnull typedef struct Fusefid Fusefid;
195 5551e51d 2006-07-23 devnull struct Fusefid
197 5551e51d 2006-07-23 devnull Fusefid *next;
198 5551e51d 2006-07-23 devnull CFid *fid;
199 5551e51d 2006-07-23 devnull int ref;
201 5551e51d 2006-07-23 devnull int gen;
202 5551e51d 2006-07-23 devnull int isnodeid;
204 5551e51d 2006-07-23 devnull /* directory read state */
205 5551e51d 2006-07-23 devnull Dir *d0;
208 5551e51d 2006-07-23 devnull int off;
211 5551e51d 2006-07-23 devnull Fusefid **fusefid;
212 5551e51d 2006-07-23 devnull int nfusefid;
213 5551e51d 2006-07-23 devnull Fusefid *freefusefidlist;
215 5551e51d 2006-07-23 devnull Fusefid*
216 5551e51d 2006-07-23 devnull allocfusefid(void)
218 5551e51d 2006-07-23 devnull Fusefid *f;
220 5551e51d 2006-07-23 devnull if((f = freefusefidlist) == nil){
221 5551e51d 2006-07-23 devnull f = emalloc(sizeof *f);
222 5551e51d 2006-07-23 devnull fusefid = erealloc(fusefid, (nfusefid+1)*sizeof *fusefid);
223 5551e51d 2006-07-23 devnull f->id = nfusefid;
224 5551e51d 2006-07-23 devnull fusefid[f->id] = f;
225 5551e51d 2006-07-23 devnull nfusefid++;
227 5551e51d 2006-07-23 devnull freefusefidlist = f->next;
228 5551e51d 2006-07-23 devnull f->next = nil;
229 5551e51d 2006-07-23 devnull f->ref = 1;
230 5551e51d 2006-07-23 devnull f->isnodeid = -1;
231 5551e51d 2006-07-23 devnull return f;
235 5551e51d 2006-07-23 devnull freefusefid(Fusefid *f)
237 5551e51d 2006-07-23 devnull if(--f->ref > 0)
239 5551e51d 2006-07-23 devnull assert(f->ref == 0);
240 5551e51d 2006-07-23 devnull if(f->fid)
241 5551e51d 2006-07-23 devnull fsclose(f->fid);
242 5551e51d 2006-07-23 devnull if(f->d0)
243 5551e51d 2006-07-23 devnull free(f->d0);
244 5551e51d 2006-07-23 devnull f->off = 0;
245 5551e51d 2006-07-23 devnull f->d0 = nil;
246 5551e51d 2006-07-23 devnull f->fid = nil;
247 5551e51d 2006-07-23 devnull f->d = nil;
248 5551e51d 2006-07-23 devnull f->nd = 0;
249 5551e51d 2006-07-23 devnull f->next = freefusefidlist;
250 5551e51d 2006-07-23 devnull f->isnodeid = -1;
251 5551e51d 2006-07-23 devnull freefusefidlist = f;
255 5551e51d 2006-07-23 devnull _alloc(CFid *fid, int isnodeid)
257 5551e51d 2006-07-23 devnull Fusefid *ff;
259 5551e51d 2006-07-23 devnull ff = allocfusefid();
260 5551e51d 2006-07-23 devnull ff->fid = fid;
261 5551e51d 2006-07-23 devnull ff->isnodeid = isnodeid;
262 5551e51d 2006-07-23 devnull ff->gen++;
263 5551e51d 2006-07-23 devnull return ff->id+2; /* skip 0 and 1 */
267 5551e51d 2006-07-23 devnull allocfh(CFid *fid)
269 5551e51d 2006-07-23 devnull return _alloc(fid, 0);
273 5551e51d 2006-07-23 devnull allocnodeid(CFid *fid)
275 5551e51d 2006-07-23 devnull return _alloc(fid, 1);
278 5551e51d 2006-07-23 devnull Fusefid*
279 5551e51d 2006-07-23 devnull lookupfusefid(uvlong id, int isnodeid)
281 5551e51d 2006-07-23 devnull Fusefid *ff;
282 5551e51d 2006-07-23 devnull if(id < 2 || id >= nfusefid+2)
283 5551e51d 2006-07-23 devnull return nil;
284 5551e51d 2006-07-23 devnull ff = fusefid[(int)id-2];
285 5551e51d 2006-07-23 devnull if(ff->isnodeid != isnodeid)
286 5551e51d 2006-07-23 devnull return nil;
287 5551e51d 2006-07-23 devnull return ff;
291 5551e51d 2006-07-23 devnull _lookupcfid(uvlong id, int isnodeid)
293 5551e51d 2006-07-23 devnull Fusefid *ff;
295 5551e51d 2006-07-23 devnull if((ff = lookupfusefid(id, isnodeid)) == nil)
296 5551e51d 2006-07-23 devnull return nil;
297 5551e51d 2006-07-23 devnull return ff->fid;
301 5551e51d 2006-07-23 devnull fh2fid(uvlong fh)
303 5551e51d 2006-07-23 devnull return _lookupcfid(fh, 0);
307 5551e51d 2006-07-23 devnull nodeid2fid(uvlong nodeid)
309 5551e51d 2006-07-23 devnull if(nodeid == 1)
310 5551e51d 2006-07-23 devnull return fsysroot;
311 5551e51d 2006-07-23 devnull return _lookupcfid(nodeid, 1);
315 5551e51d 2006-07-23 devnull qid2inode(Qid q)
317 5551e51d 2006-07-23 devnull return q.path | ((uvlong)q.type<<56);
321 5551e51d 2006-07-23 devnull dir2attr(Dir *d, struct fuse_attr *attr)
323 5551e51d 2006-07-23 devnull attr->ino = qid2inode(d->qid);
324 5551e51d 2006-07-23 devnull attr->size = d->length;
325 5551e51d 2006-07-23 devnull attr->blocks = (d->length+8191)/8192;
326 5551e51d 2006-07-23 devnull attr->atime = d->atime;
327 5551e51d 2006-07-23 devnull attr->mtime = d->mtime;
328 5551e51d 2006-07-23 devnull attr->ctime = d->mtime; /* not right */
329 5551e51d 2006-07-23 devnull attr->atimensec = 0;
330 5551e51d 2006-07-23 devnull attr->mtimensec = 0;
331 5551e51d 2006-07-23 devnull attr->ctimensec = 0;
332 5551e51d 2006-07-23 devnull attr->mode = d->mode&0777;
333 5551e51d 2006-07-23 devnull if(d->mode&DMDIR)
334 5551e51d 2006-07-23 devnull attr->mode |= S_IFDIR;
335 d07db89b 2008-07-04 rsc else if(d->mode&DMSYMLINK)
336 d07db89b 2008-07-04 rsc attr->mode |= S_IFLNK;
338 5551e51d 2006-07-23 devnull attr->mode |= S_IFREG;
339 5551e51d 2006-07-23 devnull attr->nlink = 1; /* works for directories! - see FUSE FAQ */
340 5551e51d 2006-07-23 devnull attr->uid = getuid();
341 5551e51d 2006-07-23 devnull attr->gid = getgid();
342 5551e51d 2006-07-23 devnull attr->rdev = 0;
346 5551e51d 2006-07-23 devnull f2timeout(double f, __u64 *s, __u32 *ns)
349 5551e51d 2006-07-23 devnull *ns = (f - (int)f)*1e9;
353 5551e51d 2006-07-23 devnull dir2attrout(Dir *d, struct fuse_attr_out *out)
355 5551e51d 2006-07-23 devnull f2timeout(attrtimeout, &out->attr_valid, &out->attr_valid_nsec);
356 5551e51d 2006-07-23 devnull dir2attr(d, &out->attr);
360 5551e51d 2006-07-23 devnull * Lookup. Walk to the name given as the argument.
361 5551e51d 2006-07-23 devnull * The response is a fuse_entry_out giving full stat info.
364 5551e51d 2006-07-23 devnull fuselookup(FuseMsg *m)
366 5551e51d 2006-07-23 devnull char *name;
367 5551e51d 2006-07-23 devnull Fusefid *ff;
368 5551e51d 2006-07-23 devnull CFid *fid, *newfid;
370 5551e51d 2006-07-23 devnull struct fuse_entry_out out;
372 5551e51d 2006-07-23 devnull name = m->tx;
373 5551e51d 2006-07-23 devnull if((fid = nodeid2fid(m->hdr->nodeid)) == nil){
374 5551e51d 2006-07-23 devnull replyfuseerrno(m, ESTALE);
377 5551e51d 2006-07-23 devnull if(strchr(name, '/')){
378 5551e51d 2006-07-23 devnull replyfuseerrno(m, ENOENT);
381 5551e51d 2006-07-23 devnull if((newfid = fswalk(fid, name)) == nil){
382 5551e51d 2006-07-23 devnull replyfuseerrstr(m);
385 5551e51d 2006-07-23 devnull if((d = fsdirfstat(newfid)) == nil){
386 5551e51d 2006-07-23 devnull fsclose(newfid);
387 5551e51d 2006-07-23 devnull replyfuseerrstr(m);
390 5551e51d 2006-07-23 devnull out.nodeid = allocnodeid(newfid);
391 5551e51d 2006-07-23 devnull ff = lookupfusefid(out.nodeid, 1);
392 5551e51d 2006-07-23 devnull out.generation = ff->gen;
393 5551e51d 2006-07-23 devnull f2timeout(attrtimeout, &out.attr_valid, &out.attr_valid_nsec);
394 5551e51d 2006-07-23 devnull f2timeout(entrytimeout, &out.entry_valid, &out.entry_valid_nsec);
395 5551e51d 2006-07-23 devnull dir2attr(d, &out.attr);
396 5551e51d 2006-07-23 devnull free(d);
397 5551e51d 2006-07-23 devnull replyfuse(m, &out, sizeof out);
401 5551e51d 2006-07-23 devnull * Forget. Reference-counted clunk for nodeids.
402 5551e51d 2006-07-23 devnull * Does not send a reply.
403 fa325e9b 2020-01-10 cross * Each lookup response gives the kernel an additional reference
404 5551e51d 2006-07-23 devnull * to the returned nodeid. Forget says "drop this many references
405 5551e51d 2006-07-23 devnull * to this nodeid". Our fuselookup, when presented with the same query,
406 5551e51d 2006-07-23 devnull * does not return the same results (it allocates a new nodeid for each
407 5551e51d 2006-07-23 devnull * call), but if that ever changes, fuseforget already handles the ref
408 5551e51d 2006-07-23 devnull * counts properly.
411 5551e51d 2006-07-23 devnull fuseforget(FuseMsg *m)
413 5551e51d 2006-07-23 devnull struct fuse_forget_in *in;
414 5551e51d 2006-07-23 devnull Fusefid *ff;
416 5551e51d 2006-07-23 devnull in = m->tx;
417 5551e51d 2006-07-23 devnull if((ff = lookupfusefid(m->hdr->nodeid, 1)) == nil)
419 5551e51d 2006-07-23 devnull if(ff->ref > in->nlookup){
420 5551e51d 2006-07-23 devnull ff->ref -= in->nlookup;
423 5551e51d 2006-07-23 devnull if(ff->ref < in->nlookup)
424 5551e51d 2006-07-23 devnull fprint(2, "bad count in forget\n");
425 5551e51d 2006-07-23 devnull ff->ref = 1;
426 5551e51d 2006-07-23 devnull freefusefid(ff);
427 d4ccb0a9 2012-09-11 rsc freefusemsg(m);
431 5551e51d 2006-07-23 devnull * Getattr.
432 5551e51d 2006-07-23 devnull * Replies with a fuse_attr_out structure giving the
433 5551e51d 2006-07-23 devnull * attr for the requested nodeid in out.attr.
434 fa325e9b 2020-01-10 cross * Out.attr_valid and out.attr_valid_nsec give
435 5551e51d 2006-07-23 devnull * the amount of time that the attributes can
436 5551e51d 2006-07-23 devnull * be cached.
438 5551e51d 2006-07-23 devnull * Empirically, though, if I run ls -ld on the root
439 5551e51d 2006-07-23 devnull * twice back to back, I still get two getattrs,
440 5551e51d 2006-07-23 devnull * even with a one second attribute timeout!
443 5551e51d 2006-07-23 devnull fusegetattr(FuseMsg *m)
445 5551e51d 2006-07-23 devnull CFid *fid;
446 5551e51d 2006-07-23 devnull struct fuse_attr_out out;
449 5551e51d 2006-07-23 devnull if((fid = nodeid2fid(m->hdr->nodeid)) == nil){
450 5551e51d 2006-07-23 devnull replyfuseerrno(m, ESTALE);
453 5551e51d 2006-07-23 devnull if((d = fsdirfstat(fid)) == nil){
454 5551e51d 2006-07-23 devnull replyfuseerrstr(m);
457 5551e51d 2006-07-23 devnull memset(&out, 0, sizeof out);
458 5551e51d 2006-07-23 devnull dir2attrout(d, &out);
459 5551e51d 2006-07-23 devnull free(d);
460 5551e51d 2006-07-23 devnull replyfuse(m, &out, sizeof out);
464 5551e51d 2006-07-23 devnull * Setattr.
465 5551e51d 2006-07-23 devnull * FUSE treats the many Unix attribute setting routines
466 5551e51d 2006-07-23 devnull * more or less like 9P does, with a single message.
469 5551e51d 2006-07-23 devnull fusesetattr(FuseMsg *m)
471 5551e51d 2006-07-23 devnull CFid *fid, *nfid;
472 5551e51d 2006-07-23 devnull Dir d, *dd;
473 5551e51d 2006-07-23 devnull struct fuse_setattr_in *in;
474 5551e51d 2006-07-23 devnull struct fuse_attr_out out;
476 5551e51d 2006-07-23 devnull in = m->tx;
477 5551e51d 2006-07-23 devnull if(in->valid&FATTR_FH){
478 5551e51d 2006-07-23 devnull if((fid = fh2fid(in->fh)) == nil){
479 5551e51d 2006-07-23 devnull replyfuseerrno(m, ESTALE);
483 5551e51d 2006-07-23 devnull if((fid = nodeid2fid(m->hdr->nodeid)) == nil){
484 5551e51d 2006-07-23 devnull replyfuseerrno(m, ESTALE);
488 5551e51d 2006-07-23 devnull * Special case: Linux issues a size change to
489 5551e51d 2006-07-23 devnull * truncate a file before opening it OTRUNC.
490 fa325e9b 2020-01-10 cross * Synthetic file servers (e.g., plumber) honor
491 5551e51d 2006-07-23 devnull * open(OTRUNC) but not wstat.
493 5551e51d 2006-07-23 devnull if(in->valid == FATTR_SIZE && in->size == 0){
494 5551e51d 2006-07-23 devnull if((nfid = fswalk(fid, nil)) == nil){
495 5551e51d 2006-07-23 devnull replyfuseerrstr(m);
498 5551e51d 2006-07-23 devnull if(fsfopen(nfid, OWRITE|OTRUNC) < 0){
499 5551e51d 2006-07-23 devnull replyfuseerrstr(m);
500 5551e51d 2006-07-23 devnull fsclose(nfid);
503 5551e51d 2006-07-23 devnull fsclose(nfid);
504 5551e51d 2006-07-23 devnull goto stat;
508 5551e51d 2006-07-23 devnull nulldir(&d);
509 5551e51d 2006-07-23 devnull if(in->valid&FATTR_SIZE)
510 5551e51d 2006-07-23 devnull d.length = in->size;
511 5551e51d 2006-07-23 devnull if(in->valid&FATTR_ATIME)
512 5551e51d 2006-07-23 devnull d.atime = in->atime;
513 5551e51d 2006-07-23 devnull if(in->valid&FATTR_MTIME)
514 5551e51d 2006-07-23 devnull d.mtime = in->mtime;
515 5551e51d 2006-07-23 devnull if(in->valid&FATTR_MODE)
516 4798a8a5 2018-02-05 0intro d.mode = in->mode & 0777;
517 4798a8a5 2018-02-05 0intro if((in->mode&S_IFMT) == S_IFDIR)
518 4798a8a5 2018-02-05 0intro d.mode |= DMDIR;
519 5551e51d 2006-07-23 devnull if((in->valid&FATTR_UID) || (in->valid&FATTR_GID)){
521 5551e51d 2006-07-23 devnull * I can't be bothered with these yet.
523 5551e51d 2006-07-23 devnull replyfuseerrno(m, EPERM);
526 5551e51d 2006-07-23 devnull if(fsdirfwstat(fid, &d) < 0){
527 5551e51d 2006-07-23 devnull replyfuseerrstr(m);
531 5551e51d 2006-07-23 devnull if((dd = fsdirfstat(fid)) == nil){
532 5551e51d 2006-07-23 devnull replyfuseerrstr(m);
535 5551e51d 2006-07-23 devnull memset(&out, 0, sizeof out);
536 5551e51d 2006-07-23 devnull dir2attrout(dd, &out);
537 5551e51d 2006-07-23 devnull free(dd);
538 5551e51d 2006-07-23 devnull replyfuse(m, &out, sizeof out);
542 5551e51d 2006-07-23 devnull _fuseopenfid(uvlong nodeid, int isdir, int openmode, int *err)
544 5551e51d 2006-07-23 devnull CFid *fid, *newfid;
546 5551e51d 2006-07-23 devnull if((fid = nodeid2fid(nodeid)) == nil){
547 5551e51d 2006-07-23 devnull *err = ESTALE;
548 5551e51d 2006-07-23 devnull return nil;
550 5551e51d 2006-07-23 devnull if(isdir && !(fsqid(fid).type&QTDIR)){
551 5551e51d 2006-07-23 devnull *err = ENOTDIR;
552 5551e51d 2006-07-23 devnull return nil;
554 5551e51d 2006-07-23 devnull if(openmode != OREAD && fsqid(fid).type&QTDIR){
555 5551e51d 2006-07-23 devnull *err = EISDIR;
556 5551e51d 2006-07-23 devnull return nil;
559 5551e51d 2006-07-23 devnull /* Clone fid to get one we can open. */
560 5551e51d 2006-07-23 devnull newfid = fswalk(fid, nil);
561 5551e51d 2006-07-23 devnull if(newfid == nil){
562 5551e51d 2006-07-23 devnull *err = errstr2errno();
563 5551e51d 2006-07-23 devnull return nil;
566 5551e51d 2006-07-23 devnull if(fsfopen(newfid, openmode) < 0){
567 5551e51d 2006-07-23 devnull *err = errstr2errno();
568 5551e51d 2006-07-23 devnull fsclose(newfid);
569 5551e51d 2006-07-23 devnull return nil;
572 5551e51d 2006-07-23 devnull return newfid;
576 5551e51d 2006-07-23 devnull * Open & Opendir.
577 5551e51d 2006-07-23 devnull * Argument is a struct fuse_open_in.
578 5551e51d 2006-07-23 devnull * The mode field is ignored (presumably permission bits)
579 5551e51d 2006-07-23 devnull * and flags is the open mode.
580 5551e51d 2006-07-23 devnull * Replies with a struct fuse_open_out.
583 5551e51d 2006-07-23 devnull _fuseopen(FuseMsg *m, int isdir)
585 5551e51d 2006-07-23 devnull struct fuse_open_in *in;
586 5551e51d 2006-07-23 devnull struct fuse_open_out out;
587 5551e51d 2006-07-23 devnull CFid *fid;
588 5551e51d 2006-07-23 devnull int openmode, flags, err;
590 5551e51d 2006-07-23 devnull in = m->tx;
591 5551e51d 2006-07-23 devnull flags = in->flags;
592 5551e51d 2006-07-23 devnull openmode = flags&3;
593 5551e51d 2006-07-23 devnull flags &= ~3;
594 93f9789c 2020-01-13 rsc flags &= ~(O_DIRECTORY|O_NONBLOCK|O_LARGEFILE|O_CLOEXEC|FMODE_EXEC);
595 281ca361 2011-10-05 rsc #ifdef O_NOFOLLOW
596 f9c8cdb5 2011-10-07 rsc flags &= ~O_NOFOLLOW;
598 281ca361 2011-10-05 rsc #ifdef O_LARGEFILE
599 f9c8cdb5 2011-10-07 rsc flags &= ~O_LARGEFILE;
603 e465991e 2008-12-30 rsc * Discarding O_APPEND here is not completely wrong,
604 e465991e 2008-12-30 rsc * because the host kernel will rewrite the offsets
605 e465991e 2008-12-30 rsc * of write system calls for us. That's the best we
606 e465991e 2008-12-30 rsc * can do on Unix anyway.
608 e465991e 2008-12-30 rsc flags &= ~O_APPEND;
609 0d7fd011 2006-07-23 devnull if(flags & O_TRUNC){
610 0d7fd011 2006-07-23 devnull openmode |= OTRUNC;
611 0d7fd011 2006-07-23 devnull flags &= ~O_TRUNC;
615 0d7fd011 2006-07-23 devnull * Could translate but not standard 9P:
616 0d7fd011 2006-07-23 devnull * O_DIRECT -> ODIRECT
617 0d7fd011 2006-07-23 devnull * O_NONBLOCK -> ONONBLOCK
619 5551e51d 2006-07-23 devnull if(flags){
620 93f9789c 2020-01-13 rsc fprint(2, "unexpected open flags requested=%#uo unhandled=%#uo\n", (uint)in->flags, (uint)flags);
621 5551e51d 2006-07-23 devnull replyfuseerrno(m, EACCES);
624 5551e51d 2006-07-23 devnull if((fid = _fuseopenfid(m->hdr->nodeid, isdir, openmode, &err)) == nil){
625 5551e51d 2006-07-23 devnull replyfuseerrno(m, err);
628 5551e51d 2006-07-23 devnull out.fh = allocfh(fid);
629 fa325e9b 2020-01-10 cross out.open_flags = FOPEN_DIRECT_IO; /* no page cache */
630 5551e51d 2006-07-23 devnull replyfuse(m, &out, sizeof out);
634 5551e51d 2006-07-23 devnull fuseopen(FuseMsg *m)
636 5551e51d 2006-07-23 devnull _fuseopen(m, 0);
640 5551e51d 2006-07-23 devnull fuseopendir(FuseMsg *m)
642 5551e51d 2006-07-23 devnull _fuseopen(m, 1);
646 5551e51d 2006-07-23 devnull * Create & Mkdir.
649 5551e51d 2006-07-23 devnull _fusecreate(uvlong nodeid, char *name, int perm, int ismkdir, int omode, struct fuse_entry_out *out, int *err)
651 5551e51d 2006-07-23 devnull CFid *fid, *newfid, *newfid2;
653 5551e51d 2006-07-23 devnull Fusefid *ff;
655 5551e51d 2006-07-23 devnull if((fid = nodeid2fid(nodeid)) == nil){
656 5551e51d 2006-07-23 devnull *err = ESTALE;
657 5551e51d 2006-07-23 devnull return nil;
659 5551e51d 2006-07-23 devnull perm &= 0777;
660 5551e51d 2006-07-23 devnull if(ismkdir)
661 5551e51d 2006-07-23 devnull perm |= DMDIR;
662 5551e51d 2006-07-23 devnull if(ismkdir && omode != OREAD){
663 5551e51d 2006-07-23 devnull *err = EPERM;
664 5551e51d 2006-07-23 devnull return nil;
666 5551e51d 2006-07-23 devnull if((newfid = fswalk(fid, nil)) == nil){
667 5551e51d 2006-07-23 devnull *err = errstr2errno();
668 5551e51d 2006-07-23 devnull return nil;
670 e54f9a4a 2007-05-09 devnull if(fsfcreate(newfid, name, omode, perm) < 0){
671 5551e51d 2006-07-23 devnull *err = errstr2errno();
672 5551e51d 2006-07-23 devnull fsclose(newfid);
673 5551e51d 2006-07-23 devnull return nil;
675 5551e51d 2006-07-23 devnull if((d = fsdirfstat(newfid)) == nil){
676 5551e51d 2006-07-23 devnull *err = errstr2errno();
677 5551e51d 2006-07-23 devnull fsfremove(newfid);
678 5551e51d 2006-07-23 devnull return nil;
681 5551e51d 2006-07-23 devnull * This fid is no good, because it's open.
682 5551e51d 2006-07-23 devnull * We need an unopened fid. Sigh.
684 5551e51d 2006-07-23 devnull if((newfid2 = fswalk(fid, name)) == nil){
685 5551e51d 2006-07-23 devnull *err = errstr2errno();
686 5551e51d 2006-07-23 devnull free(d);
687 5551e51d 2006-07-23 devnull fsfremove(newfid);
688 5551e51d 2006-07-23 devnull return nil;
690 5551e51d 2006-07-23 devnull out->nodeid = allocnodeid(newfid2);
691 5551e51d 2006-07-23 devnull ff = lookupfusefid(out->nodeid, 1);
692 5551e51d 2006-07-23 devnull out->generation = ff->gen;
693 5551e51d 2006-07-23 devnull f2timeout(attrtimeout, &out->attr_valid, &out->attr_valid_nsec);
694 5551e51d 2006-07-23 devnull f2timeout(entrytimeout, &out->entry_valid, &out->entry_valid_nsec);
695 5551e51d 2006-07-23 devnull dir2attr(d, &out->attr);
696 5551e51d 2006-07-23 devnull free(d);
697 5551e51d 2006-07-23 devnull return newfid;
701 5551e51d 2006-07-23 devnull fusemkdir(FuseMsg *m)
703 5551e51d 2006-07-23 devnull struct fuse_mkdir_in *in;
704 5551e51d 2006-07-23 devnull struct fuse_entry_out out;
705 5551e51d 2006-07-23 devnull CFid *fid;
706 5551e51d 2006-07-23 devnull int err;
707 5551e51d 2006-07-23 devnull char *name;
709 5551e51d 2006-07-23 devnull in = m->tx;
710 5551e51d 2006-07-23 devnull name = (char*)(in+1);
711 5551e51d 2006-07-23 devnull if((fid = _fusecreate(m->hdr->nodeid, name, in->mode, 1, OREAD, &out, &err)) == nil){
712 5551e51d 2006-07-23 devnull replyfuseerrno(m, err);
715 5551e51d 2006-07-23 devnull /* Toss the open fid. */
716 5551e51d 2006-07-23 devnull fsclose(fid);
717 5551e51d 2006-07-23 devnull replyfuse(m, &out, sizeof out);
721 5551e51d 2006-07-23 devnull fusecreate(FuseMsg *m)
723 5551e51d 2006-07-23 devnull struct fuse_open_in *in;
724 5551e51d 2006-07-23 devnull struct fuse_create_out out;
725 5551e51d 2006-07-23 devnull CFid *fid;
726 5551e51d 2006-07-23 devnull int err, openmode, flags;
727 5551e51d 2006-07-23 devnull char *name;
729 5551e51d 2006-07-23 devnull in = m->tx;
730 5551e51d 2006-07-23 devnull flags = in->flags;
731 5551e51d 2006-07-23 devnull openmode = in->flags&3;
732 d7158243 2007-05-09 devnull flags &= ~3;
733 e10a8342 2009-04-30 rsc flags &= ~(O_DIRECTORY|O_NONBLOCK|O_LARGEFILE|O_EXCL);
734 e465991e 2008-12-30 rsc flags &= ~O_APPEND; /* see comment in _fuseopen */
735 d7158243 2007-05-09 devnull flags &= ~(O_CREAT|O_TRUNC); /* huh? */
736 5551e51d 2006-07-23 devnull if(flags){
737 5551e51d 2006-07-23 devnull fprint(2, "bad mode %#uo\n", in->flags);
738 5551e51d 2006-07-23 devnull replyfuseerrno(m, EACCES);
741 5551e51d 2006-07-23 devnull name = (char*)(in+1);
742 5551e51d 2006-07-23 devnull if((fid = _fusecreate(m->hdr->nodeid, name, in->mode, 0, openmode, &out.e, &err)) == nil){
743 5551e51d 2006-07-23 devnull replyfuseerrno(m, err);
746 5551e51d 2006-07-23 devnull out.o.fh = allocfh(fid);
747 5551e51d 2006-07-23 devnull out.o.open_flags = FOPEN_DIRECT_IO; /* no page cache */
748 5551e51d 2006-07-23 devnull replyfuse(m, &out, sizeof out);
753 5551e51d 2006-07-23 devnull * Lib9pclient implements this just as Plan 9 does,
754 5551e51d 2006-07-23 devnull * by opening the file (or not) and then closing it.
757 5551e51d 2006-07-23 devnull fuseaccess(FuseMsg *m)
759 5551e51d 2006-07-23 devnull struct fuse_access_in *in;
760 5551e51d 2006-07-23 devnull CFid *fid;
761 143cdf57 2006-07-26 devnull int err, omode;
762 5551e51d 2006-07-23 devnull static int a2o[] = {
773 5551e51d 2006-07-23 devnull in = m->tx;
774 5551e51d 2006-07-23 devnull if(in->mask >= nelem(a2o)){
775 5551e51d 2006-07-23 devnull replyfuseerrno(m, EINVAL);
778 143cdf57 2006-07-26 devnull omode = a2o[in->mask];
779 143cdf57 2006-07-26 devnull if((fid = nodeid2fid(m->hdr->nodeid)) == nil){
780 143cdf57 2006-07-26 devnull replyfuseerrno(m, ESTALE);
783 143cdf57 2006-07-26 devnull if(fsqid(fid).type&QTDIR)
784 143cdf57 2006-07-26 devnull omode = OREAD;
785 143cdf57 2006-07-26 devnull if((fid = _fuseopenfid(m->hdr->nodeid, 0, omode, &err)) == nil){
786 5551e51d 2006-07-23 devnull replyfuseerrno(m, err);
789 5551e51d 2006-07-23 devnull fsclose(fid);
790 5551e51d 2006-07-23 devnull replyfuse(m, nil, 0);
794 5551e51d 2006-07-23 devnull * Release.
795 5551e51d 2006-07-23 devnull * Equivalent of clunk for file handles.
796 5551e51d 2006-07-23 devnull * in->flags is the open mode used in Open or Opendir.
799 5551e51d 2006-07-23 devnull fuserelease(FuseMsg *m)
801 5551e51d 2006-07-23 devnull struct fuse_release_in *in;
802 5551e51d 2006-07-23 devnull Fusefid *ff;
804 5551e51d 2006-07-23 devnull in = m->tx;
805 5551e51d 2006-07-23 devnull if((ff = lookupfusefid(in->fh, 0)) != nil)
806 5551e51d 2006-07-23 devnull freefusefid(ff);
808 5551e51d 2006-07-23 devnull fprint(2, "fuserelease: fh not found\n");
809 5551e51d 2006-07-23 devnull replyfuse(m, nil, 0);
813 5551e51d 2006-07-23 devnull fusereleasedir(FuseMsg *m)
815 5551e51d 2006-07-23 devnull fuserelease(m);
820 5551e51d 2006-07-23 devnull * Read from file handle in->fh at offset in->offset for size in->size.
821 5551e51d 2006-07-23 devnull * We truncate size to maxwrite just to keep the buffer reasonable.
824 5551e51d 2006-07-23 devnull fuseread(FuseMsg *m)
827 5551e51d 2006-07-23 devnull uchar *buf;
828 5551e51d 2006-07-23 devnull CFid *fid;
829 5551e51d 2006-07-23 devnull struct fuse_read_in *in;
831 5551e51d 2006-07-23 devnull in = m->tx;
832 5551e51d 2006-07-23 devnull if((fid = fh2fid(in->fh)) == nil){
833 5551e51d 2006-07-23 devnull replyfuseerrno(m, ESTALE);
836 5551e51d 2006-07-23 devnull n = in->size;
837 5551e51d 2006-07-23 devnull if(n > fusemaxwrite)
838 5551e51d 2006-07-23 devnull n = fusemaxwrite;
839 5551e51d 2006-07-23 devnull buf = emalloc(n);
840 cd2bb6ce 2007-05-04 devnull n = fspread(fid, buf, n, in->offset);
841 5551e51d 2006-07-23 devnull if(n < 0){
842 5551e51d 2006-07-23 devnull free(buf);
843 5551e51d 2006-07-23 devnull replyfuseerrstr(m);
846 5551e51d 2006-07-23 devnull replyfuse(m, buf, n);
847 5551e51d 2006-07-23 devnull free(buf);
854 d07db89b 2008-07-04 rsc fusereadlink(FuseMsg *m)
859 d07db89b 2008-07-04 rsc if((fid = nodeid2fid(m->hdr->nodeid)) == nil){
860 d07db89b 2008-07-04 rsc replyfuseerrno(m, ESTALE);
863 d07db89b 2008-07-04 rsc if((d = fsdirfstat(fid)) == nil){
864 d07db89b 2008-07-04 rsc replyfuseerrstr(m);
867 d07db89b 2008-07-04 rsc if(!(d->mode&DMSYMLINK)){
868 d07db89b 2008-07-04 rsc replyfuseerrno(m, EINVAL);
871 d07db89b 2008-07-04 rsc replyfuse(m, d->ext, strlen(d->ext));
877 5551e51d 2006-07-23 devnull * Readdir.
878 5551e51d 2006-07-23 devnull * Read from file handle in->fh at offset in->offset for size in->size.
879 5551e51d 2006-07-23 devnull * We truncate size to maxwrite just to keep the buffer reasonable.
880 5551e51d 2006-07-23 devnull * We assume 9P directory read semantics: a read at offset 0 rewinds
881 5551e51d 2006-07-23 devnull * and a read at any other offset starts where we left off.
882 5551e51d 2006-07-23 devnull * If it became necessary, we could implement a crude seek
883 5551e51d 2006-07-23 devnull * or cache the entire list of directory entries.
884 5551e51d 2006-07-23 devnull * Directory entries read from 9P but not yet handed to FUSE
885 5551e51d 2006-07-23 devnull * are stored in m->d,nd,d0.
887 5551e51d 2006-07-23 devnull int canpack(Dir*, uvlong, uchar**, uchar*);
888 fa588406 2020-01-13 rsc Dir *dotdir(CFid*);
890 5551e51d 2006-07-23 devnull fusereaddir(FuseMsg *m)
892 5551e51d 2006-07-23 devnull struct fuse_read_in *in;
893 5551e51d 2006-07-23 devnull uchar *buf, *p, *ep;
895 5551e51d 2006-07-23 devnull Fusefid *ff;
897 5551e51d 2006-07-23 devnull in = m->tx;
898 5551e51d 2006-07-23 devnull if((ff = lookupfusefid(in->fh, 0)) == nil){
899 5551e51d 2006-07-23 devnull replyfuseerrno(m, ESTALE);
902 5551e51d 2006-07-23 devnull if(in->offset == 0){
903 5551e51d 2006-07-23 devnull fsseek(ff->fid, 0, 0);
904 5551e51d 2006-07-23 devnull free(ff->d0);
905 fa588406 2020-01-13 rsc ff->d0 = ff->d = dotdir(ff->fid);
908 5551e51d 2006-07-23 devnull n = in->size;
909 5551e51d 2006-07-23 devnull if(n > fusemaxwrite)
910 5551e51d 2006-07-23 devnull n = fusemaxwrite;
911 5551e51d 2006-07-23 devnull buf = emalloc(n);
912 5551e51d 2006-07-23 devnull p = buf;
913 5551e51d 2006-07-23 devnull ep = buf + n;
914 5551e51d 2006-07-23 devnull for(;;){
915 ca6a2d95 2006-08-01 devnull while(ff->nd > 0){
916 ca6a2d95 2006-08-01 devnull if(!canpack(ff->d, ff->off, &p, ep))
917 ca6a2d95 2006-08-01 devnull goto out;
918 5551e51d 2006-07-23 devnull ff->off++;
919 5551e51d 2006-07-23 devnull ff->d++;
920 5551e51d 2006-07-23 devnull ff->nd--;
922 ca6a2d95 2006-08-01 devnull free(ff->d0);
923 ca6a2d95 2006-08-01 devnull ff->d0 = nil;
924 ca6a2d95 2006-08-01 devnull ff->d = nil;
925 ca6a2d95 2006-08-01 devnull if((ff->nd = fsdirread(ff->fid, &ff->d0)) < 0){
926 ca6a2d95 2006-08-01 devnull replyfuseerrstr(m);
927 ca6a2d95 2006-08-01 devnull free(buf);
930 ca6a2d95 2006-08-01 devnull if(ff->nd == 0)
932 ca6a2d95 2006-08-01 devnull ff->d = ff->d0;
935 5551e51d 2006-07-23 devnull replyfuse(m, buf, p - buf);
936 5551e51d 2006-07-23 devnull free(buf);
940 9ec57f8b 2008-07-04 rsc * Fuse assumes that it can always read two directory entries.
941 9ec57f8b 2008-07-04 rsc * If it gets just one, it will double it in the dirread results.
942 9ec57f8b 2008-07-04 rsc * Thus if a directory contains just "a", you see "a" twice.
943 9ec57f8b 2008-07-04 rsc * Adding . as the first directory entry works around this.
944 9ec57f8b 2008-07-04 rsc * We could add .. too, but it isn't necessary.
947 fa588406 2020-01-13 rsc dotdir(CFid *f)
951 fa588406 2020-01-13 rsc d = emalloc(1*sizeof *d);
952 9ec57f8b 2008-07-04 rsc d[0].name = ".";
953 9ec57f8b 2008-07-04 rsc d[0].qid = fsqid(f);
958 5551e51d 2006-07-23 devnull canpack(Dir *d, uvlong off, uchar **pp, uchar *ep)
960 5551e51d 2006-07-23 devnull uchar *p;
961 5551e51d 2006-07-23 devnull struct fuse_dirent *de;
962 5551e51d 2006-07-23 devnull int pad, size;
964 5551e51d 2006-07-23 devnull p = *pp;
965 5551e51d 2006-07-23 devnull size = FUSE_NAME_OFFSET + strlen(d->name);
966 5551e51d 2006-07-23 devnull pad = 0;
967 5551e51d 2006-07-23 devnull if(size%8)
968 5551e51d 2006-07-23 devnull pad = 8 - size%8;
969 5551e51d 2006-07-23 devnull if(size+pad > ep - p)
970 5551e51d 2006-07-23 devnull return 0;
971 5551e51d 2006-07-23 devnull de = (struct fuse_dirent*)p;
972 5551e51d 2006-07-23 devnull de->ino = qid2inode(d->qid);
973 5551e51d 2006-07-23 devnull de->off = off;
974 5551e51d 2006-07-23 devnull de->namelen = strlen(d->name);
975 5551e51d 2006-07-23 devnull memmove(de->name, d->name, de->namelen);
976 5551e51d 2006-07-23 devnull if(pad > 0)
977 5551e51d 2006-07-23 devnull memset(de->name+de->namelen, 0, pad);
978 5551e51d 2006-07-23 devnull *pp = p+size+pad;
979 5551e51d 2006-07-23 devnull return 1;
983 5551e51d 2006-07-23 devnull * Write.
984 5551e51d 2006-07-23 devnull * Write from file handle in->fh at offset in->offset for size in->size.
985 5551e51d 2006-07-23 devnull * Don't know what in->write_flags means.
987 5551e51d 2006-07-23 devnull * Apparently implementations are allowed to buffer these writes
988 5551e51d 2006-07-23 devnull * and wait until Flush is sent, but FUSE docs say flush may be
989 5551e51d 2006-07-23 devnull * called zero, one, or even more times per close. So better do the
990 5551e51d 2006-07-23 devnull * actual writing here. Also, errors that happen during Flush just
991 5551e51d 2006-07-23 devnull * show up in the close() return status, which no one checks anyway.
994 5551e51d 2006-07-23 devnull fusewrite(FuseMsg *m)
996 5551e51d 2006-07-23 devnull struct fuse_write_in *in;
997 5551e51d 2006-07-23 devnull struct fuse_write_out out;
998 5551e51d 2006-07-23 devnull void *a;
999 5551e51d 2006-07-23 devnull CFid *fid;
1002 5551e51d 2006-07-23 devnull in = m->tx;
1003 5551e51d 2006-07-23 devnull a = in+1;
1004 5551e51d 2006-07-23 devnull if((fid = fh2fid(in->fh)) == nil){
1005 5551e51d 2006-07-23 devnull replyfuseerrno(m, ESTALE);
1006 5551e51d 2006-07-23 devnull return;
1008 5551e51d 2006-07-23 devnull if(in->size > fusemaxwrite){
1009 5551e51d 2006-07-23 devnull replyfuseerrno(m, EINVAL);
1010 5551e51d 2006-07-23 devnull return;
1012 cd2bb6ce 2007-05-04 devnull n = fspwrite(fid, a, in->size, in->offset);
1013 5551e51d 2006-07-23 devnull if(n < 0){
1014 5551e51d 2006-07-23 devnull replyfuseerrstr(m);
1015 5551e51d 2006-07-23 devnull return;
1017 5551e51d 2006-07-23 devnull out.size = n;
1018 5551e51d 2006-07-23 devnull replyfuse(m, &out, sizeof out);
1022 5551e51d 2006-07-23 devnull * Flush. Supposed to flush any buffered writes. Don't use this.
1024 5551e51d 2006-07-23 devnull * Flush is a total crock. It gets called on close() of a file descriptor
1025 5551e51d 2006-07-23 devnull * associated with this open file. Some open files have multiple file
1026 5551e51d 2006-07-23 devnull * descriptors and thus multiple closes of those file descriptors.
1027 5551e51d 2006-07-23 devnull * In those cases, Flush is called multiple times. Some open files
1028 5551e51d 2006-07-23 devnull * have file descriptors that are closed on process exit instead of
1029 5551e51d 2006-07-23 devnull * closed explicitly. For those files, Flush is never called.
1030 5551e51d 2006-07-23 devnull * Even more amusing, Flush gets called before close() of read-only
1031 5551e51d 2006-07-23 devnull * file descriptors too!
1033 5551e51d 2006-07-23 devnull * This is just a bad idea.
1036 5551e51d 2006-07-23 devnull fuseflush(FuseMsg *m)
1038 5551e51d 2006-07-23 devnull replyfuse(m, nil, 0);
1042 5551e51d 2006-07-23 devnull * Unlink & Rmdir.
1045 5551e51d 2006-07-23 devnull _fuseremove(FuseMsg *m, int isdir)
1047 5551e51d 2006-07-23 devnull char *name;
1048 5551e51d 2006-07-23 devnull CFid *fid, *newfid;
1050 5551e51d 2006-07-23 devnull name = m->tx;
1051 5551e51d 2006-07-23 devnull if((fid = nodeid2fid(m->hdr->nodeid)) == nil){
1052 5551e51d 2006-07-23 devnull replyfuseerrno(m, ESTALE);
1053 5551e51d 2006-07-23 devnull return;
1055 5551e51d 2006-07-23 devnull if(strchr(name, '/')){
1056 5551e51d 2006-07-23 devnull replyfuseerrno(m, ENOENT);
1057 5551e51d 2006-07-23 devnull return;
1059 5551e51d 2006-07-23 devnull if((newfid = fswalk(fid, name)) == nil){
1060 5551e51d 2006-07-23 devnull replyfuseerrstr(m);
1061 5551e51d 2006-07-23 devnull return;
1063 5551e51d 2006-07-23 devnull if(isdir && !(fsqid(newfid).type&QTDIR)){
1064 5551e51d 2006-07-23 devnull replyfuseerrno(m, ENOTDIR);
1065 5551e51d 2006-07-23 devnull fsclose(newfid);
1066 5551e51d 2006-07-23 devnull return;
1068 5551e51d 2006-07-23 devnull if(!isdir && (fsqid(newfid).type&QTDIR)){
1069 5551e51d 2006-07-23 devnull replyfuseerrno(m, EISDIR);
1070 5551e51d 2006-07-23 devnull fsclose(newfid);
1071 5551e51d 2006-07-23 devnull return;
1073 5551e51d 2006-07-23 devnull if(fsfremove(newfid) < 0){
1074 5551e51d 2006-07-23 devnull replyfuseerrstr(m);
1075 5551e51d 2006-07-23 devnull return;
1077 5551e51d 2006-07-23 devnull replyfuse(m, nil, 0);
1081 5551e51d 2006-07-23 devnull fuseunlink(FuseMsg *m)
1083 5551e51d 2006-07-23 devnull _fuseremove(m, 0);
1087 5551e51d 2006-07-23 devnull fusermdir(FuseMsg *m)
1089 5551e51d 2006-07-23 devnull _fuseremove(m, 1);
1093 5551e51d 2006-07-23 devnull * Rename.
1095 5551e51d 2006-07-23 devnull * FUSE sends the nodeid for the source and destination
1096 5551e51d 2006-07-23 devnull * directory and then the before and after names as strings.
1097 5551e51d 2006-07-23 devnull * 9P can only do the rename if the source and destination
1098 5551e51d 2006-07-23 devnull * are the same. If the same nodeid is used for source and
1099 5551e51d 2006-07-23 devnull * destination, we're fine, but if FUSE gives us different nodeids
1100 5551e51d 2006-07-23 devnull * that happen to correspond to the same directory, we have
1101 5551e51d 2006-07-23 devnull * no way of figuring that out. Let's hope it doesn't happen too often.
1104 5551e51d 2006-07-23 devnull fuserename(FuseMsg *m)
1106 5551e51d 2006-07-23 devnull struct fuse_rename_in *in;
1107 5551e51d 2006-07-23 devnull char *before, *after;
1108 5551e51d 2006-07-23 devnull CFid *fid, *newfid;
1111 5551e51d 2006-07-23 devnull in = m->tx;
1112 5551e51d 2006-07-23 devnull if(in->newdir != m->hdr->nodeid){
1113 5551e51d 2006-07-23 devnull replyfuseerrno(m, EXDEV);
1114 5551e51d 2006-07-23 devnull return;
1116 5551e51d 2006-07-23 devnull before = (char*)(in+1);
1117 5551e51d 2006-07-23 devnull after = before + strlen(before) + 1;
1118 5551e51d 2006-07-23 devnull if((fid = nodeid2fid(m->hdr->nodeid)) == nil){
1119 5551e51d 2006-07-23 devnull replyfuseerrno(m, ESTALE);
1120 5551e51d 2006-07-23 devnull return;
1122 5551e51d 2006-07-23 devnull if(strchr(before, '/') || strchr(after, '/')){
1123 5551e51d 2006-07-23 devnull replyfuseerrno(m, ENOENT);
1124 5551e51d 2006-07-23 devnull return;
1126 5551e51d 2006-07-23 devnull if((newfid = fswalk(fid, before)) == nil){
1127 5551e51d 2006-07-23 devnull replyfuseerrstr(m);
1128 5551e51d 2006-07-23 devnull return;
1130 5551e51d 2006-07-23 devnull nulldir(&d);
1131 5551e51d 2006-07-23 devnull d.name = after;
1132 5551e51d 2006-07-23 devnull if(fsdirfwstat(newfid, &d) < 0){
1133 5551e51d 2006-07-23 devnull replyfuseerrstr(m);
1134 5551e51d 2006-07-23 devnull fsclose(newfid);
1135 5551e51d 2006-07-23 devnull return;
1137 5551e51d 2006-07-23 devnull fsclose(newfid);
1138 5551e51d 2006-07-23 devnull replyfuse(m, nil, 0);
1142 5551e51d 2006-07-23 devnull * Fsync. Commit file info to stable storage.
1143 5551e51d 2006-07-23 devnull * Not sure what in->fsync_flags are.
1146 5551e51d 2006-07-23 devnull fusefsync(FuseMsg *m)
1148 5551e51d 2006-07-23 devnull struct fuse_fsync_in *in;
1149 5551e51d 2006-07-23 devnull CFid *fid;
1152 5551e51d 2006-07-23 devnull in = m->tx;
1153 5551e51d 2006-07-23 devnull if((fid = fh2fid(in->fh)) == nil){
1154 5551e51d 2006-07-23 devnull replyfuseerrno(m, ESTALE);
1155 5551e51d 2006-07-23 devnull return;
1157 5551e51d 2006-07-23 devnull nulldir(&d);
1158 5551e51d 2006-07-23 devnull if(fsdirfwstat(fid, &d) < 0){
1159 5551e51d 2006-07-23 devnull replyfuseerrstr(m);
1160 5551e51d 2006-07-23 devnull return;
1162 5551e51d 2006-07-23 devnull replyfuse(m, nil, 0);
1166 5551e51d 2006-07-23 devnull * Fsyncdir. Commit dir info to stable storage?
1169 5551e51d 2006-07-23 devnull fusefsyncdir(FuseMsg *m)
1171 5551e51d 2006-07-23 devnull fusefsync(m);
1175 5551e51d 2006-07-23 devnull * Statfs. Send back information about file system.
1176 5551e51d 2006-07-23 devnull * Not really worth implementing, except that if we
1177 5551e51d 2006-07-23 devnull * reply with ENOSYS, programs like df print messages like
1178 5551e51d 2006-07-23 devnull * df: `/tmp/z': Function not implemented
1179 5551e51d 2006-07-23 devnull * and that gets annoying. Returning all zeros excludes
1180 5551e51d 2006-07-23 devnull * us from df without appearing to cause any problems.
1183 5551e51d 2006-07-23 devnull fusestatfs(FuseMsg *m)
1185 5551e51d 2006-07-23 devnull struct fuse_statfs_out out;
1187 5551e51d 2006-07-23 devnull memset(&out, 0, sizeof out);
1188 5551e51d 2006-07-23 devnull replyfuse(m, &out, sizeof out);
1191 5551e51d 2006-07-23 devnull void (*fusehandlers[100])(FuseMsg*);
1193 5551e51d 2006-07-23 devnull struct {
1194 5551e51d 2006-07-23 devnull int op;
1195 5551e51d 2006-07-23 devnull void (*fn)(FuseMsg*);
1196 5551e51d 2006-07-23 devnull } fuselist[] = {
1197 5551e51d 2006-07-23 devnull { FUSE_LOOKUP, fuselookup },
1198 5551e51d 2006-07-23 devnull { FUSE_FORGET, fuseforget },
1199 5551e51d 2006-07-23 devnull { FUSE_GETATTR, fusegetattr },
1200 5551e51d 2006-07-23 devnull { FUSE_SETATTR, fusesetattr },
1202 d07db89b 2008-07-04 rsc * FUSE_SYMLINK, FUSE_MKNOD are unimplemented.
1204 d07db89b 2008-07-04 rsc { FUSE_READLINK, fusereadlink },
1205 5551e51d 2006-07-23 devnull { FUSE_MKDIR, fusemkdir },
1206 5551e51d 2006-07-23 devnull { FUSE_UNLINK, fuseunlink },
1207 5551e51d 2006-07-23 devnull { FUSE_RMDIR, fusermdir },
1208 5551e51d 2006-07-23 devnull { FUSE_RENAME, fuserename },
1210 5551e51d 2006-07-23 devnull * FUSE_LINK is unimplemented.
1212 5551e51d 2006-07-23 devnull { FUSE_OPEN, fuseopen },
1213 5551e51d 2006-07-23 devnull { FUSE_READ, fuseread },
1214 5551e51d 2006-07-23 devnull { FUSE_WRITE, fusewrite },
1215 5551e51d 2006-07-23 devnull { FUSE_STATFS, fusestatfs },
1216 5551e51d 2006-07-23 devnull { FUSE_RELEASE, fuserelease },
1217 5551e51d 2006-07-23 devnull { FUSE_FSYNC, fusefsync },
1219 5551e51d 2006-07-23 devnull * FUSE_SETXATTR, FUSE_GETXATTR, FUSE_LISTXATTR, and
1220 fa325e9b 2020-01-10 cross * FUSE_REMOVEXATTR are unimplemented.
1221 5551e51d 2006-07-23 devnull * FUSE will stop sending these requests after getting
1222 5551e51d 2006-07-23 devnull * an -ENOSYS reply (see dispatch below).
1224 5551e51d 2006-07-23 devnull { FUSE_FLUSH, fuseflush },
1226 5551e51d 2006-07-23 devnull * FUSE_INIT is handled in initfuse and should not be seen again.
1228 5551e51d 2006-07-23 devnull { FUSE_OPENDIR, fuseopendir },
1229 5551e51d 2006-07-23 devnull { FUSE_READDIR, fusereaddir },
1230 5551e51d 2006-07-23 devnull { FUSE_RELEASEDIR, fusereleasedir },
1231 5551e51d 2006-07-23 devnull { FUSE_FSYNCDIR, fusefsyncdir },
1232 5551e51d 2006-07-23 devnull { FUSE_ACCESS, fuseaccess },
1233 5551e51d 2006-07-23 devnull { FUSE_CREATE, fusecreate },
1237 5551e51d 2006-07-23 devnull fusethread(void *v)
1239 5551e51d 2006-07-23 devnull FuseMsg *m;
1242 fa325e9b 2020-01-10 cross if((uint)m->hdr->opcode >= nelem(fusehandlers)
1243 5551e51d 2006-07-23 devnull || !fusehandlers[m->hdr->opcode]){
1244 5551e51d 2006-07-23 devnull replyfuseerrno(m, ENOSYS);
1245 5551e51d 2006-07-23 devnull return;
1247 5551e51d 2006-07-23 devnull fusehandlers[m->hdr->opcode](m);
1251 5551e51d 2006-07-23 devnull fusedispatch(void *v)
1254 5551e51d 2006-07-23 devnull FuseMsg *m;
1256 5551e51d 2006-07-23 devnull eofkill9pclient = 1; /* threadexitsall on 9P eof */
1257 5551e51d 2006-07-23 devnull atexit(unmountatexit);
1259 5551e51d 2006-07-23 devnull recvp(fusechan); /* sync */
1261 5551e51d 2006-07-23 devnull for(i=0; i<nelem(fuselist); i++){
1262 5551e51d 2006-07-23 devnull if(fuselist[i].op >= nelem(fusehandlers))
1263 5551e51d 2006-07-23 devnull sysfatal("make fusehandlers bigger op=%d", fuselist[i].op);
1264 5551e51d 2006-07-23 devnull fusehandlers[fuselist[i].op] = fuselist[i].fn;
1267 d4ccb0a9 2012-09-11 rsc while((m = recvp(fusechan)) != nil) {
1268 d4ccb0a9 2012-09-11 rsc switch(m->hdr->opcode) {
1269 d4ccb0a9 2012-09-11 rsc case FUSE_FORGET:
1270 d4ccb0a9 2012-09-11 rsc fusehandlers[m->hdr->opcode](m);
1273 d4ccb0a9 2012-09-11 rsc threadcreate(fusethread, m, STACK);
1279 5551e51d 2006-07-23 devnull emalloc(uint n)
1281 5551e51d 2006-07-23 devnull void *p;
1283 5551e51d 2006-07-23 devnull p = malloc(n);
1284 5551e51d 2006-07-23 devnull if(p == nil)
1285 5551e51d 2006-07-23 devnull sysfatal("malloc(%d): %r", n);
1286 5551e51d 2006-07-23 devnull memset(p, 0, n);
1287 5551e51d 2006-07-23 devnull return p;
1291 5551e51d 2006-07-23 devnull erealloc(void *p, uint n)
1293 5551e51d 2006-07-23 devnull p = realloc(p, n);
1294 5551e51d 2006-07-23 devnull if(p == nil)
1295 5551e51d 2006-07-23 devnull sysfatal("realloc(..., %d): %r", n);
1296 5551e51d 2006-07-23 devnull return p;
1300 5551e51d 2006-07-23 devnull estrdup(char *p)
1302 5551e51d 2006-07-23 devnull char *pp;
1303 5551e51d 2006-07-23 devnull pp = strdup(p);
1304 5551e51d 2006-07-23 devnull if(pp == nil)
1305 5551e51d 2006-07-23 devnull sysfatal("strdup(%.20s): %r", p);
1306 5551e51d 2006-07-23 devnull return pp;
1310 e63025d0 2008-04-17 rsc watchfd(void *v)
1312 e63025d0 2008-04-17 rsc int fd = (int)(uintptr)v;
1314 e63025d0 2008-04-17 rsc /* wait for exception (file closed) */
1315 e63025d0 2008-04-17 rsc fd_set set;
1316 e63025d0 2008-04-17 rsc FD_ZERO(&set);
1317 e63025d0 2008-04-17 rsc FD_SET(fd, &set);
1318 e63025d0 2008-04-17 rsc if(select(fd+1, NULL, NULL, &set, NULL) >= 0)
1319 e63025d0 2008-04-17 rsc threadexitsall(nil);
