1*85291faaSozaki-r /* $NetBSD: node.c,v 1.31 2022/03/02 07:48:20 ozaki-r Exp $ */
2e73a712fSpooka
3e73a712fSpooka /*
4e73a712fSpooka * Copyright (c) 2007 Antti Kantee. All Rights Reserved.
5e73a712fSpooka *
6e73a712fSpooka * Redistribution and use in source and binary forms, with or without
7e73a712fSpooka * modification, are permitted provided that the following conditions
8e73a712fSpooka * are met:
9e73a712fSpooka * 1. Redistributions of source code must retain the above copyright
10e73a712fSpooka * notice, this list of conditions and the following disclaimer.
11e73a712fSpooka * 2. Redistributions in binary form must reproduce the above copyright
12e73a712fSpooka * notice, this list of conditions and the following disclaimer in the
13e73a712fSpooka * documentation and/or other materials provided with the distribution.
14e73a712fSpooka *
15e73a712fSpooka * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS
16e73a712fSpooka * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
17e73a712fSpooka * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
18e73a712fSpooka * DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
19e73a712fSpooka * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
20e73a712fSpooka * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
21e73a712fSpooka * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
22e73a712fSpooka * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
23e73a712fSpooka * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
24e73a712fSpooka * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
25e73a712fSpooka * SUCH DAMAGE.
26e73a712fSpooka */
27e73a712fSpooka
28e73a712fSpooka #include <sys/cdefs.h>
29e73a712fSpooka #ifndef lint
30*85291faaSozaki-r __RCSID("$NetBSD: node.c,v 1.31 2022/03/02 07:48:20 ozaki-r Exp $");
31e73a712fSpooka #endif /* !lint */
32e73a712fSpooka
33e73a712fSpooka #include <assert.h>
34e73a712fSpooka #include <errno.h>
35e73a712fSpooka #include <puffs.h>
36e73a712fSpooka #include <stdio.h>
375252a3b0Spooka #include <stdlib.h>
38e73a712fSpooka
39e73a712fSpooka #include "ninepuffs.h"
40e73a712fSpooka #include "nineproto.h"
41e73a712fSpooka
42e73a712fSpooka static void *
nodecmp(struct puffs_usermount * pu,struct puffs_node * pn,void * arg)43e73a712fSpooka nodecmp(struct puffs_usermount *pu, struct puffs_node *pn, void *arg)
44e73a712fSpooka {
45e73a712fSpooka struct vattr *vap = &pn->pn_va;
46e73a712fSpooka struct qid9p *qid = arg;
47e73a712fSpooka
4830c29b1bSpooka if (vap->va_fileid == qid->qidpath && vap->va_gen == qid->qidvers)
49e73a712fSpooka return pn;
50e73a712fSpooka
51e73a712fSpooka return NULL;
52e73a712fSpooka }
53e73a712fSpooka
546360ca31Spooka static int
do_getattr(struct puffs_usermount * pu,struct puffs_node * pn,struct vattr * vap)5521913eabSpooka do_getattr(struct puffs_usermount *pu, struct puffs_node *pn, struct vattr *vap)
566360ca31Spooka {
5721913eabSpooka AUTOVAR(pu);
586360ca31Spooka struct p9pnode *p9n = pn->pn_data;
596360ca31Spooka
606a530be8Suwe tag = NEXTTAG(p9p);
616360ca31Spooka p9pbuf_put_1(pb, P9PROTO_T_STAT);
626360ca31Spooka p9pbuf_put_2(pb, tag);
636360ca31Spooka p9pbuf_put_4(pb, p9n->fid_base);
646360ca31Spooka GETRESPONSE(pb);
656360ca31Spooka
6648ecd244Sozaki-r if (p9pbuf_get_type(pb) != P9PROTO_R_STAT) {
6748ecd244Sozaki-r rv = proto_handle_rerror(pu, pb);
6848ecd244Sozaki-r goto out;
6948ecd244Sozaki-r }
7026721651Sozaki-r rv = proto_expect_stat(pu, pb, vap);
716360ca31Spooka
726360ca31Spooka out:
736360ca31Spooka RETURN(rv);
746360ca31Spooka }
756360ca31Spooka
766360ca31Spooka int
puffs9p_node_getattr(struct puffs_usermount * pu,void * opc,struct vattr * vap,const struct puffs_cred * pcr)7721913eabSpooka puffs9p_node_getattr(struct puffs_usermount *pu, void *opc, struct vattr *vap,
786a3d9a18Spooka const struct puffs_cred *pcr)
796360ca31Spooka {
806360ca31Spooka struct puffs_node *pn = opc;
816360ca31Spooka int rv;
826360ca31Spooka
8321913eabSpooka rv = do_getattr(pu, pn, &pn->pn_va);
846360ca31Spooka if (rv == 0)
856360ca31Spooka memcpy(vap, &pn->pn_va, sizeof(struct vattr));
866360ca31Spooka return rv;
876360ca31Spooka }
886360ca31Spooka
89e73a712fSpooka int
puffs9p_node_lookup(struct puffs_usermount * pu,void * opc,struct puffs_newinfo * pni,const struct puffs_cn * pcn)9021913eabSpooka puffs9p_node_lookup(struct puffs_usermount *pu, void *opc, struct puffs_newinfo *pni,
91e73a712fSpooka const struct puffs_cn *pcn)
92e73a712fSpooka {
9321913eabSpooka AUTOVAR(pu);
9430c29b1bSpooka struct vattr va;
95e73a712fSpooka struct puffs_node *pn, *pn_dir = opc;
96e73a712fSpooka struct p9pnode *p9n_dir = pn_dir->pn_data;
97dfbab0ecSuwe p9pfid_t tfid = NEXTFID(p9p);
98e73a712fSpooka struct qid9p newqid;
99e73a712fSpooka uint16_t nqid;
100e73a712fSpooka
1016a530be8Suwe tag = NEXTTAG(p9p);
102e73a712fSpooka p9pbuf_put_1(pb, P9PROTO_T_WALK);
103e73a712fSpooka p9pbuf_put_2(pb, tag);
104e73a712fSpooka p9pbuf_put_4(pb, p9n_dir->fid_base);
105e73a712fSpooka p9pbuf_put_4(pb, tfid);
106e73a712fSpooka p9pbuf_put_2(pb, 1);
107e73a712fSpooka p9pbuf_put_str(pb, pcn->pcn_name);
1085069b5dfSpooka GETRESPONSE(pb);
109e73a712fSpooka
11048ecd244Sozaki-r rv = proto_expect_walk_nqids(pu, pb, &nqid);
111e73a712fSpooka if (rv) {
112e73a712fSpooka rv = ENOENT;
113e73a712fSpooka goto out;
114e73a712fSpooka }
1150e7bdfc1Spooka if (nqid != 1) {
116e73a712fSpooka rv = EPROTO;
117e73a712fSpooka goto out;
118e73a712fSpooka }
1190e7bdfc1Spooka if ((rv = proto_getqid(pb, &newqid)))
1200e7bdfc1Spooka goto out;
121e73a712fSpooka
12230c29b1bSpooka /* we get the parent vers in walk(?) compensate */
12330c29b1bSpooka p9pbuf_recycleout(pb);
12430c29b1bSpooka tag = NEXTTAG(p9p);
12530c29b1bSpooka p9pbuf_put_1(pb, P9PROTO_T_STAT);
12630c29b1bSpooka p9pbuf_put_2(pb, tag);
12730c29b1bSpooka p9pbuf_put_4(pb, tfid);
12830c29b1bSpooka GETRESPONSE(pb);
12926721651Sozaki-r if ((rv = proto_expect_stat(pu, pb, &va)) != 0) {
13030c29b1bSpooka proto_cc_clunkfid(pu, tfid, 0);
13130c29b1bSpooka rv = ENOENT;
13230c29b1bSpooka goto out;
13330c29b1bSpooka }
13430c29b1bSpooka if (newqid.qidpath != va.va_fileid) {
13530c29b1bSpooka proto_cc_clunkfid(pu, tfid, 0);
13630c29b1bSpooka rv = EPROTO;
13730c29b1bSpooka goto out;
13830c29b1bSpooka }
13930c29b1bSpooka newqid.qidvers = va.va_gen;
14030c29b1bSpooka
141e73a712fSpooka pn = puffs_pn_nodewalk(pu, nodecmp, &newqid);
142e73a712fSpooka if (pn == NULL)
143e73a712fSpooka pn = newp9pnode_qid(pu, &newqid, tfid);
144e73a712fSpooka else
14521913eabSpooka proto_cc_clunkfid(pu, tfid, 0);
14630c29b1bSpooka /* assert pn */
14730c29b1bSpooka memcpy(&pn->pn_va, &va, sizeof(va));
1486360ca31Spooka
1496596e0c9Spooka puffs_newinfo_setcookie(pni, pn);
1506596e0c9Spooka puffs_newinfo_setvtype(pni, pn->pn_va.va_type);
1516596e0c9Spooka puffs_newinfo_setsize(pni, pn->pn_va.va_size);
1526596e0c9Spooka puffs_newinfo_setrdev(pni, pn->pn_va.va_rdev);
153e73a712fSpooka
154e73a712fSpooka out:
155e73a712fSpooka RETURN(rv);
156e73a712fSpooka }
157e73a712fSpooka
158e73a712fSpooka /*
159e73a712fSpooka * Problem is that 9P doesn't allow seeking into a directory. So we
160e73a712fSpooka * maintain a list of active fids for any given directory. They
161e73a712fSpooka * start living at the first read and exist either until the directory
162e73a712fSpooka * is closed or until they reach the end.
163e73a712fSpooka */
164e73a712fSpooka int
puffs9p_node_readdir(struct puffs_usermount * pu,void * opc,struct dirent * dent,off_t * readoff,size_t * reslen,const struct puffs_cred * pcr,int * eofflag,off_t * cookies,size_t * ncookies)16521913eabSpooka puffs9p_node_readdir(struct puffs_usermount *pu, void *opc, struct dirent *dent,
166e73a712fSpooka off_t *readoff, size_t *reslen, const struct puffs_cred *pcr,
167e73a712fSpooka int *eofflag, off_t *cookies, size_t *ncookies)
168e73a712fSpooka {
16921913eabSpooka AUTOVAR(pu);
170e73a712fSpooka struct puffs_node *pn = opc;
171e73a712fSpooka struct p9pnode *p9n = pn->pn_data;
172e73a712fSpooka struct vattr va;
173e73a712fSpooka struct dirfid *dfp;
174e73a712fSpooka char *name;
175e73a712fSpooka uint32_t count;
176e73a712fSpooka uint16_t statsize;
177e73a712fSpooka
17821913eabSpooka rv = getdfwithoffset(pu, p9n, *readoff, &dfp);
179e73a712fSpooka if (rv)
180e73a712fSpooka goto out;
181e73a712fSpooka
182e73a712fSpooka tag = NEXTTAG(p9p);
183e73a712fSpooka p9pbuf_put_1(pb, P9PROTO_T_READ);
184e73a712fSpooka p9pbuf_put_2(pb, tag);
185e73a712fSpooka p9pbuf_put_4(pb, dfp->fid);
186e73a712fSpooka p9pbuf_put_8(pb, *readoff);
187e73a712fSpooka p9pbuf_put_4(pb, *reslen); /* XXX */
1885069b5dfSpooka GETRESPONSE(pb);
189e73a712fSpooka
190*85291faaSozaki-r if (p9pbuf_get_type(pb) != P9PROTO_R_READ) {
191*85291faaSozaki-r rv = proto_handle_rerror(pu, pb);
192*85291faaSozaki-r goto out;
193*85291faaSozaki-r }
194*85291faaSozaki-r
195e73a712fSpooka p9pbuf_get_4(pb, &count);
196e73a712fSpooka
197e73a712fSpooka /*
198e73a712fSpooka * if count is 0, assume we at end-of-dir. dfp is no longer
199e73a712fSpooka * useful, so nuke it
200e73a712fSpooka */
201e73a712fSpooka if (count == 0) {
202e73a712fSpooka *eofflag = 1;
20321913eabSpooka releasedf(pu, dfp);
204e73a712fSpooka goto out;
205e73a712fSpooka }
206e73a712fSpooka
207e73a712fSpooka while (count > 0) {
20826721651Sozaki-r if ((rv = proto_getstat(pu, pb, &va, &name, &statsize))) {
2099fec8114Spooka /*
2109fec8114Spooka * If there was an error, it's unlikely we'll be
2119fec8114Spooka * coming back, so just nuke the dfp. If we do
2129fec8114Spooka * come back for some strange reason, we'll just
2139fec8114Spooka * regen it.
2149fec8114Spooka */
21521913eabSpooka releasedf(pu, dfp);
216e73a712fSpooka goto out;
2179fec8114Spooka }
218e73a712fSpooka
219e73a712fSpooka puffs_nextdent(&dent, name, va.va_fileid,
220e73a712fSpooka puffs_vtype2dt(va.va_type), reslen);
221e73a712fSpooka
222e73a712fSpooka count -= statsize;
223e73a712fSpooka *readoff += statsize;
224e73a712fSpooka dfp->seekoff += statsize;
2255252a3b0Spooka free(name);
226e73a712fSpooka }
227e73a712fSpooka
228e73a712fSpooka storedf(p9n, dfp);
229e73a712fSpooka
230e73a712fSpooka out:
231e73a712fSpooka RETURN(rv);
232e73a712fSpooka }
233e73a712fSpooka
234e73a712fSpooka int
puffs9p_node_setattr(struct puffs_usermount * pu,void * opc,const struct vattr * va,const struct puffs_cred * pcr)23521913eabSpooka puffs9p_node_setattr(struct puffs_usermount *pu, void *opc,
2366a3d9a18Spooka const struct vattr *va, const struct puffs_cred *pcr)
237e73a712fSpooka {
23821913eabSpooka AUTOVAR(pu);
239e73a712fSpooka struct puffs_node *pn = opc;
240e73a712fSpooka struct p9pnode *p9n = pn->pn_data;
241e73a712fSpooka
2426a530be8Suwe tag = NEXTTAG(p9p);
243e73a712fSpooka p9pbuf_put_1(pb, P9PROTO_T_WSTAT);
244e73a712fSpooka p9pbuf_put_2(pb, tag);
245e73a712fSpooka p9pbuf_put_4(pb, p9n->fid_base);
24626721651Sozaki-r proto_make_stat(pu, pb, va, NULL, pn->pn_va.va_type);
2475069b5dfSpooka GETRESPONSE(pb);
248e73a712fSpooka
24948ecd244Sozaki-r if (p9pbuf_get_type(pb) != P9PROTO_R_WSTAT) {
25048ecd244Sozaki-r rv = proto_handle_rerror(pu, pb);
25148ecd244Sozaki-r }
252e73a712fSpooka
2530b0e609bSpooka out:
254e73a712fSpooka RETURN(rv);
255e73a712fSpooka }
256e73a712fSpooka
257e73a712fSpooka /*
258e73a712fSpooka * Ok, time to get clever. There are two possible cases: we are
259e73a712fSpooka * opening a file or we are opening a directory.
260e73a712fSpooka *
261e73a712fSpooka * If it's a directory, don't bother opening it here, but rather
262e73a712fSpooka * wait until readdir, since it's probable we need to be able to
263e73a712fSpooka * open a directory there in any case.
264e73a712fSpooka *
265436cfd0dSpooka * If it's a regular file, open it here with whatever credentials
266436cfd0dSpooka * we happen to have. Let the upper layers of the kernel worry
267436cfd0dSpooka * about permission control.
268e73a712fSpooka */
269e73a712fSpooka int
puffs9p_node_open(struct puffs_usermount * pu,void * opc,int mode,const struct puffs_cred * pcr)27021913eabSpooka puffs9p_node_open(struct puffs_usermount *pu, void *opc, int mode,
2716a3d9a18Spooka const struct puffs_cred *pcr)
272e73a712fSpooka {
27321913eabSpooka struct puffs_cc *pcc = puffs_cc_getcc(pu);
27421913eabSpooka struct puffs9p *p9p = puffs_getspecific(pu);
275e73a712fSpooka struct puffs_node *pn = opc;
276e73a712fSpooka struct p9pnode *p9n = pn->pn_data;
277e73a712fSpooka p9pfid_t nfid;
278e73a712fSpooka int error = 0;
279e73a712fSpooka
280dca252d8Spooka puffs_setback(pcc, PUFFS_SETBACK_INACT_N1);
281436cfd0dSpooka if (pn->pn_va.va_type != VDIR) {
282dc439268Sozaki-r /* Always require read access for page cache */
283dc439268Sozaki-r mode |= FREAD;
284436cfd0dSpooka if (mode & FREAD && p9n->fid_read == P9P_INVALFID) {
285e73a712fSpooka nfid = NEXTFID(p9p);
28621913eabSpooka error = proto_cc_open(pu, p9n->fid_base, nfid,
287436cfd0dSpooka P9PROTO_OMODE_READ);
288e73a712fSpooka if (error)
289e73a712fSpooka return error;
290436cfd0dSpooka p9n->fid_read = nfid;
291436cfd0dSpooka }
292436cfd0dSpooka if (mode & FWRITE && p9n->fid_write == P9P_INVALFID) {
293436cfd0dSpooka nfid = NEXTFID(p9p);
29421913eabSpooka error = proto_cc_open(pu, p9n->fid_base, nfid,
295436cfd0dSpooka P9PROTO_OMODE_WRITE);
296436cfd0dSpooka if (error)
297436cfd0dSpooka return error;
298436cfd0dSpooka p9n->fid_write = nfid;
299436cfd0dSpooka }
300e73a712fSpooka }
301e73a712fSpooka
302e73a712fSpooka return 0;
303e73a712fSpooka }
304e73a712fSpooka
305e73a712fSpooka int
puffs9p_node_inactive(struct puffs_usermount * pu,void * opc)30621913eabSpooka puffs9p_node_inactive(struct puffs_usermount *pu, void *opc)
307e73a712fSpooka {
308e73a712fSpooka struct puffs_node *pn = opc;
309e73a712fSpooka struct p9pnode *p9n = pn->pn_data;
310e73a712fSpooka
311436cfd0dSpooka if (pn->pn_va.va_type == VDIR) {
31221913eabSpooka nukealldf(pu, p9n);
313436cfd0dSpooka } else {
314436cfd0dSpooka if (p9n->fid_read != P9P_INVALFID) {
31521913eabSpooka proto_cc_clunkfid(pu, p9n->fid_read, 0);
316436cfd0dSpooka p9n->fid_read = P9P_INVALFID;
317436cfd0dSpooka }
318436cfd0dSpooka if (p9n->fid_write != P9P_INVALFID) {
31921913eabSpooka proto_cc_clunkfid(pu, p9n->fid_write, 0);
320436cfd0dSpooka p9n->fid_write = P9P_INVALFID;
321436cfd0dSpooka }
322436cfd0dSpooka }
323e73a712fSpooka
324e73a712fSpooka return 0;
325e73a712fSpooka }
326e73a712fSpooka
327e73a712fSpooka int
puffs9p_node_read(struct puffs_usermount * pu,void * opc,uint8_t * buf,off_t offset,size_t * resid,const struct puffs_cred * pcr,int ioflag)32821913eabSpooka puffs9p_node_read(struct puffs_usermount *pu, void *opc, uint8_t *buf,
329e73a712fSpooka off_t offset, size_t *resid, const struct puffs_cred *pcr,
330e73a712fSpooka int ioflag)
331e73a712fSpooka {
33221913eabSpooka AUTOVAR(pu);
333e73a712fSpooka struct puffs_node *pn = opc;
334e73a712fSpooka struct p9pnode *p9n = pn->pn_data;
335e73a712fSpooka uint32_t count;
336e73a712fSpooka size_t nread;
337e73a712fSpooka
338e73a712fSpooka nread = 0;
3393cafe960Slukem while (*resid > 0 && (uint64_t)(offset+nread) < pn->pn_va.va_size) {
3406a530be8Suwe tag = NEXTTAG(p9p);
341e73a712fSpooka p9pbuf_put_1(pb, P9PROTO_T_READ);
342e73a712fSpooka p9pbuf_put_2(pb, tag);
343436cfd0dSpooka p9pbuf_put_4(pb, p9n->fid_read);
344e73a712fSpooka p9pbuf_put_8(pb, offset+nread);
345e73a712fSpooka p9pbuf_put_4(pb, MIN((uint32_t)*resid,p9p->maxreq-24));
3465069b5dfSpooka GETRESPONSE(pb);
347e73a712fSpooka
3480e7bdfc1Spooka if (p9pbuf_get_type(pb) != P9PROTO_R_READ) {
34948ecd244Sozaki-r rv = proto_handle_rerror(pu, pb);
350e73a712fSpooka break;
351e73a712fSpooka }
352e73a712fSpooka
353e73a712fSpooka p9pbuf_get_4(pb, &count);
3540e7bdfc1Spooka if ((rv = p9pbuf_read_data(pb, buf + nread, count)))
355e73a712fSpooka break;
356e73a712fSpooka
35730c29b1bSpooka if (count == 0)
35830c29b1bSpooka break;
35930c29b1bSpooka
360e73a712fSpooka *resid -= count;
361e73a712fSpooka nread += count;
362e73a712fSpooka
3630e7bdfc1Spooka p9pbuf_recycleout(pb);
364e73a712fSpooka }
365e73a712fSpooka
3660b0e609bSpooka out:
367e73a712fSpooka RETURN(rv);
368e73a712fSpooka }
369e73a712fSpooka
370e73a712fSpooka int
puffs9p_node_write(struct puffs_usermount * pu,void * opc,uint8_t * buf,off_t offset,size_t * resid,const struct puffs_cred * cred,int ioflag)37121913eabSpooka puffs9p_node_write(struct puffs_usermount *pu, void *opc, uint8_t *buf,
372e73a712fSpooka off_t offset, size_t *resid, const struct puffs_cred *cred,
373e73a712fSpooka int ioflag)
374e73a712fSpooka {
37521913eabSpooka AUTOVAR(pu);
376e73a712fSpooka struct puffs_node *pn = opc;
377e73a712fSpooka struct p9pnode *p9n = pn->pn_data;
378e73a712fSpooka uint32_t chunk, count;
379e73a712fSpooka size_t nwrite;
380e73a712fSpooka
381e73a712fSpooka if (ioflag & PUFFS_IO_APPEND)
382e73a712fSpooka offset = pn->pn_va.va_size;
383e73a712fSpooka
384e73a712fSpooka nwrite = 0;
385e73a712fSpooka while (*resid > 0) {
386e73a712fSpooka chunk = MIN(*resid, p9p->maxreq-32);
387e73a712fSpooka
3886a530be8Suwe tag = NEXTTAG(p9p);
389e73a712fSpooka p9pbuf_put_1(pb, P9PROTO_T_WRITE);
390e73a712fSpooka p9pbuf_put_2(pb, tag);
391436cfd0dSpooka p9pbuf_put_4(pb, p9n->fid_write);
392e73a712fSpooka p9pbuf_put_8(pb, offset+nwrite);
393e73a712fSpooka p9pbuf_put_4(pb, chunk);
394e73a712fSpooka p9pbuf_write_data(pb, buf+nwrite, chunk);
3955069b5dfSpooka GETRESPONSE(pb);
396e73a712fSpooka
3970e7bdfc1Spooka if (p9pbuf_get_type(pb) != P9PROTO_R_WRITE) {
39848ecd244Sozaki-r rv = proto_handle_rerror(pu, pb);
399e73a712fSpooka break;
400e73a712fSpooka }
401e73a712fSpooka
402e73a712fSpooka p9pbuf_get_4(pb, &count);
403e73a712fSpooka *resid -= count;
404e73a712fSpooka nwrite += count;
405e73a712fSpooka
406e73a712fSpooka if (count != chunk) {
407e73a712fSpooka rv = EPROTO;
408e73a712fSpooka break;
409e73a712fSpooka }
410e73a712fSpooka
4110e7bdfc1Spooka p9pbuf_recycleout(pb);
412e73a712fSpooka }
413e73a712fSpooka
4140b0e609bSpooka out:
415e73a712fSpooka RETURN(rv);
416e73a712fSpooka }
417e73a712fSpooka
418e73a712fSpooka static int
nodecreate(struct puffs_usermount * pu,struct puffs_node * pn,struct puffs_newinfo * pni,const char * name,const struct vattr * vap,uint32_t dirbit)41921913eabSpooka nodecreate(struct puffs_usermount *pu, struct puffs_node *pn,
4206596e0c9Spooka struct puffs_newinfo *pni, const char *name,
4216596e0c9Spooka const struct vattr *vap, uint32_t dirbit)
422e73a712fSpooka {
42321913eabSpooka AUTOVAR(pu);
424e73a712fSpooka struct puffs_node *pn_new;
425e73a712fSpooka struct p9pnode *p9n = pn->pn_data;
426e73a712fSpooka p9pfid_t nfid = NEXTFID(p9p);
427e73a712fSpooka struct qid9p nqid;
428e73a712fSpooka int tries = 0;
429e73a712fSpooka
430e73a712fSpooka again:
431e73a712fSpooka if (++tries > 5) {
432e73a712fSpooka rv = EPROTO;
433e73a712fSpooka goto out;
434e73a712fSpooka }
435e73a712fSpooka
43621913eabSpooka rv = proto_cc_dupfid(pu, p9n->fid_base, nfid);
437e73a712fSpooka if (rv)
438e73a712fSpooka goto out;
439e73a712fSpooka
4406a530be8Suwe tag = NEXTTAG(p9p);
441e73a712fSpooka p9pbuf_put_1(pb, P9PROTO_T_CREATE);
442e73a712fSpooka p9pbuf_put_2(pb, tag);
443e73a712fSpooka p9pbuf_put_4(pb, nfid);
444e73a712fSpooka p9pbuf_put_str(pb, name);
445e73a712fSpooka p9pbuf_put_4(pb, dirbit | (vap->va_mode & 0777));
446e73a712fSpooka p9pbuf_put_1(pb, 0);
44726721651Sozaki-r if (p9p->protover == P9PROTO_VERSION_U)
44826721651Sozaki-r p9pbuf_put_str(pb, ""); /* extension[s] */
4495069b5dfSpooka GETRESPONSE(pb);
450e73a712fSpooka
45148ecd244Sozaki-r rv = proto_expect_qid(pu, pb, P9PROTO_R_CREATE, &nqid);
452e73a712fSpooka if (rv)
453e73a712fSpooka goto out;
454e73a712fSpooka
455e73a712fSpooka /*
456e73a712fSpooka * Now, little problem here: create returns an *open* fid.
457e73a712fSpooka * So, clunk it and walk the parent directory to get a fid
458e73a712fSpooka * which is not open for I/O yet.
459e73a712fSpooka */
46021913eabSpooka proto_cc_clunkfid(pu, nfid, 0);
461e73a712fSpooka nfid = NEXTFID(p9p);
462e73a712fSpooka
4630e7bdfc1Spooka p9pbuf_recycleout(pb);
4646a530be8Suwe tag = NEXTTAG(p9p);
465e73a712fSpooka p9pbuf_put_1(pb, P9PROTO_T_WALK);
466e73a712fSpooka p9pbuf_put_2(pb, tag);
467e73a712fSpooka p9pbuf_put_4(pb, p9n->fid_base);
468e73a712fSpooka p9pbuf_put_4(pb, nfid);
469e73a712fSpooka p9pbuf_put_2(pb, 1);
470e73a712fSpooka p9pbuf_put_str(pb, name);
4715069b5dfSpooka GETRESPONSE(pb);
472e73a712fSpooka
473e73a712fSpooka /*
474e73a712fSpooka * someone removed it already? try again
475e73a712fSpooka * note: this is kind of lose/lose
476e73a712fSpooka */
4770e7bdfc1Spooka if (p9pbuf_get_type(pb) != P9PROTO_R_WALK)
478e73a712fSpooka goto again;
479e73a712fSpooka
480e73a712fSpooka pn_new = newp9pnode_va(pu, vap, nfid);
481e73a712fSpooka qid2vattr(&pn_new->pn_va, &nqid);
4826596e0c9Spooka puffs_newinfo_setcookie(pni, pn_new);
483e73a712fSpooka
484e73a712fSpooka out:
485e73a712fSpooka RETURN(rv);
486e73a712fSpooka }
487e73a712fSpooka
488e73a712fSpooka int
puffs9p_node_create(struct puffs_usermount * pu,void * opc,struct puffs_newinfo * pni,const struct puffs_cn * pcn,const struct vattr * va)48921913eabSpooka puffs9p_node_create(struct puffs_usermount *pu, void *opc, struct puffs_newinfo *pni,
490e73a712fSpooka const struct puffs_cn *pcn, const struct vattr *va)
491e73a712fSpooka {
492e73a712fSpooka
49321913eabSpooka return nodecreate(pu, opc, pni, pcn->pcn_name, va, 0);
494e73a712fSpooka }
495e73a712fSpooka
496e73a712fSpooka int
puffs9p_node_mkdir(struct puffs_usermount * pu,void * opc,struct puffs_newinfo * pni,const struct puffs_cn * pcn,const struct vattr * va)49721913eabSpooka puffs9p_node_mkdir(struct puffs_usermount *pu, void *opc, struct puffs_newinfo *pni,
498e73a712fSpooka const struct puffs_cn *pcn, const struct vattr *va)
499e73a712fSpooka {
500e73a712fSpooka
50121913eabSpooka return nodecreate(pu, opc, pni, pcn->pcn_name,
502e73a712fSpooka va, P9PROTO_CPERM_DIR);
503e73a712fSpooka }
504e73a712fSpooka
505e73a712fSpooka /*
506e73a712fSpooka * Need to be a bit clever again: the fid is clunked no matter if
507e73a712fSpooka * the remove succeeds or not. Re-getting a fid would be way too
508e73a712fSpooka * difficult in case the remove failed for a valid reason (directory
509e73a712fSpooka * not empty etcetc.). So walk ourselves another fid to prod the
510e73a712fSpooka * ice with.
511e73a712fSpooka */
512e73a712fSpooka static int
noderemove(struct puffs_usermount * pu,struct puffs_node * pn)51321913eabSpooka noderemove(struct puffs_usermount *pu, struct puffs_node *pn)
514e73a712fSpooka {
51521913eabSpooka AUTOVAR(pu);
51691629617Spooka struct p9pnode *p9n = pn->pn_data;
517e73a712fSpooka p9pfid_t testfid = NEXTFID(p9p);
518e73a712fSpooka
51921913eabSpooka rv = proto_cc_dupfid(pu, p9n->fid_base, testfid);
5200b0e609bSpooka if (rv)
5210b0e609bSpooka goto out;
522e73a712fSpooka
5236a530be8Suwe tag = NEXTTAG(p9p);
524e73a712fSpooka p9pbuf_put_1(pb, P9PROTO_T_REMOVE);
525e73a712fSpooka p9pbuf_put_2(pb, tag);
526e73a712fSpooka p9pbuf_put_4(pb, testfid);
5270b0e609bSpooka
5280b0e609bSpooka /*
5290b0e609bSpooka * XXX: error handling isn't very robust, but doom is impending
5300b0e609bSpooka * anyway, so just accept we're going belly up and play dead
5310b0e609bSpooka */
5325069b5dfSpooka GETRESPONSE(pb);
533e73a712fSpooka
5340e7bdfc1Spooka if (p9pbuf_get_type(pb) != P9PROTO_R_REMOVE) {
53548ecd244Sozaki-r rv = proto_handle_rerror(pu, pb);
536e73a712fSpooka } else {
53721913eabSpooka proto_cc_clunkfid(pu, p9n->fid_base, 0);
538e73a712fSpooka p9n->fid_base = P9P_INVALFID;
53991629617Spooka puffs_pn_remove(pn);
540e73a712fSpooka }
541e73a712fSpooka
5420b0e609bSpooka out:
543e73a712fSpooka RETURN(rv);
544e73a712fSpooka }
545e73a712fSpooka
546e73a712fSpooka int
puffs9p_node_remove(struct puffs_usermount * pu,void * opc,void * targ,const struct puffs_cn * pcn)54721913eabSpooka puffs9p_node_remove(struct puffs_usermount *pu, void *opc, void *targ,
548e73a712fSpooka const struct puffs_cn *pcn)
549e73a712fSpooka {
5501c216692Suwe struct puffs_cc *pcc = puffs_cc_getcc(pu);
551e73a712fSpooka struct puffs_node *pn = targ;
5521c216692Suwe int rv;
553e73a712fSpooka
554e73a712fSpooka if (pn->pn_va.va_type == VDIR)
555e73a712fSpooka return EISDIR;
556e73a712fSpooka
5571c216692Suwe rv = noderemove(pu, pn);
5581c216692Suwe if (rv == 0)
5591c216692Suwe puffs_setback(pcc, PUFFS_SETBACK_NOREF_N2);
5601c216692Suwe
5611c216692Suwe return rv;
562e73a712fSpooka }
563e73a712fSpooka
564e73a712fSpooka int
puffs9p_node_rmdir(struct puffs_usermount * pu,void * opc,void * targ,const struct puffs_cn * pcn)56521913eabSpooka puffs9p_node_rmdir(struct puffs_usermount *pu, void *opc, void *targ,
566e73a712fSpooka const struct puffs_cn *pcn)
567e73a712fSpooka {
5681c216692Suwe struct puffs_cc *pcc = puffs_cc_getcc(pu);
569e73a712fSpooka struct puffs_node *pn = targ;
5701c216692Suwe int rv;
571e73a712fSpooka
572e73a712fSpooka if (pn->pn_va.va_type != VDIR)
573e73a712fSpooka return ENOTDIR;
574e73a712fSpooka
5751c216692Suwe rv = noderemove(pu, pn);
5761c216692Suwe if (rv == 0)
5771c216692Suwe puffs_setback(pcc, PUFFS_SETBACK_NOREF_N2);
5781c216692Suwe
5791c216692Suwe return rv;
580e73a712fSpooka }
581e73a712fSpooka
582e73a712fSpooka int
puffs9p_node_rename(struct puffs_usermount * pu,void * src_dir,void * src,const struct puffs_cn * pcn_src,void * targ_dir,void * targ,const struct puffs_cn * pcn_targ)583a78ee365Suwe puffs9p_node_rename(struct puffs_usermount *pu,
584a78ee365Suwe void *src_dir, void *src, const struct puffs_cn *pcn_src,
585a78ee365Suwe void *targ_dir, void *targ, const struct puffs_cn *pcn_targ)
586e73a712fSpooka {
58721913eabSpooka AUTOVAR(pu);
588e73a712fSpooka struct puffs_node *pn_src = src;
589e73a712fSpooka struct p9pnode *p9n_src = pn_src->pn_data;
590e73a712fSpooka
591a78ee365Suwe /*
592a78ee365Suwe * 9P rename can only change the last pathname component.
593a78ee365Suwe * Return EXDEV for attempts to move a file to a different
594a78ee365Suwe * directory to make mv(1) fall back to copying.
595a78ee365Suwe */
596a78ee365Suwe if (src_dir != targ_dir) {
597a78ee365Suwe rv = EXDEV;
598e73a712fSpooka goto out;
599e73a712fSpooka }
600e73a712fSpooka
601e73a712fSpooka /* 9P doesn't allow to overwrite in rename */
602e73a712fSpooka if (targ) {
603e73a712fSpooka struct puffs_node *pn_targ = targ;
604e73a712fSpooka
605b9f4ef93Suwe rv = noderemove(pu, pn_targ);
606e73a712fSpooka if (rv)
607ff4087e2Spooka goto out;
608e73a712fSpooka }
609e73a712fSpooka
6106a530be8Suwe tag = NEXTTAG(p9p);
611e73a712fSpooka p9pbuf_put_1(pb, P9PROTO_T_WSTAT);
612e73a712fSpooka p9pbuf_put_2(pb, tag);
613e73a712fSpooka p9pbuf_put_4(pb, p9n_src->fid_base);
61426721651Sozaki-r proto_make_stat(pu, pb, NULL, pcn_targ->pcn_name, pn_src->pn_va.va_type);
6155069b5dfSpooka GETRESPONSE(pb);
616e73a712fSpooka
6170e7bdfc1Spooka if (p9pbuf_get_type(pb) != P9PROTO_R_WSTAT)
61848ecd244Sozaki-r rv = proto_handle_rerror(pu, pb);
619e73a712fSpooka
620e73a712fSpooka out:
621e73a712fSpooka RETURN(rv);
622e73a712fSpooka }
623e73a712fSpooka
624e73a712fSpooka /*
625e73a712fSpooka * - "here's one"
626e73a712fSpooka * - "9P"
627e73a712fSpooka * ~ "i'm not dead"
628e73a712fSpooka * - "you're not fooling anyone you know, you'll be stone dead in a minute
629e73a712fSpooka * - "he says he's not quite dead"
630e73a712fSpooka * - "isn't there anything you could do?"
631e73a712fSpooka * - *clunk*!
632e73a712fSpooka * - "thanks"
633e73a712fSpooka */
634e73a712fSpooka int
puffs9p_node_reclaim(struct puffs_usermount * pu,void * opc)63521913eabSpooka puffs9p_node_reclaim(struct puffs_usermount *pu, void *opc)
636e73a712fSpooka {
637b283afddSpooka struct puffs_node *pn = opc;
638b283afddSpooka struct p9pnode *p9n = pn->pn_data;
639b283afddSpooka
640b283afddSpooka assert(LIST_EMPTY(&p9n->dir_openlist));
641b283afddSpooka assert(p9n->fid_read == P9P_INVALFID && p9n->fid_write == P9P_INVALFID);
642b283afddSpooka
64321913eabSpooka proto_cc_clunkfid(pu, p9n->fid_base, 0);
644b283afddSpooka free(p9n);
645b283afddSpooka puffs_pn_put(pn);
646e73a712fSpooka
647e73a712fSpooka return 0;
648e73a712fSpooka }
649