p2k.c revision 1.38 1 1.38 pooka /* $NetBSD: p2k.c,v 1.38 2010/05/21 10:52:17 pooka Exp $ */
2 1.1 pooka
3 1.1 pooka /*
4 1.19 pooka * Copyright (c) 2007, 2008, 2009 Antti Kantee. All Rights Reserved.
5 1.1 pooka *
6 1.19 pooka * Development of this software was supported by the
7 1.19 pooka * Finnish Cultural Foundation.
8 1.1 pooka *
9 1.1 pooka * Redistribution and use in source and binary forms, with or without
10 1.1 pooka * modification, are permitted provided that the following conditions
11 1.1 pooka * are met:
12 1.1 pooka * 1. Redistributions of source code must retain the above copyright
13 1.1 pooka * notice, this list of conditions and the following disclaimer.
14 1.1 pooka * 2. Redistributions in binary form must reproduce the above copyright
15 1.1 pooka * notice, this list of conditions and the following disclaimer in the
16 1.1 pooka * documentation and/or other materials provided with the distribution.
17 1.1 pooka *
18 1.1 pooka * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS
19 1.1 pooka * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
20 1.1 pooka * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
21 1.1 pooka * DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
22 1.1 pooka * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
23 1.1 pooka * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
24 1.1 pooka * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
25 1.1 pooka * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
26 1.1 pooka * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
27 1.1 pooka * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
28 1.1 pooka * SUCH DAMAGE.
29 1.1 pooka */
30 1.1 pooka
31 1.1 pooka /*
32 1.1 pooka * puffs 2k, i.e. puffs 2 kernel. Converts the puffs protocol to
33 1.1 pooka * the kernel vfs protocol and vice versa.
34 1.1 pooka *
35 1.1 pooka * A word about reference counting: puffs in the kernel is the king of
36 1.1 pooka * reference counting. We must maintain a vnode alive and kicking
37 1.1 pooka * until the kernel tells us to reclaim it. Therefore we make sure
38 1.1 pooka * we never accidentally lose a vnode. Before calling operations which
39 1.1 pooka * decrease the refcount we always bump the refcount up to compensate.
40 1.1 pooka * Come inactive, if the file system thinks that the vnode should be
41 1.1 pooka * put out of its misery, it will set the recycle flag. We use this
42 1.1 pooka * to tell the kernel to reclaim the vnode. Only in reclaim do we
43 1.1 pooka * really nuke the last reference.
44 1.1 pooka */
45 1.1 pooka
46 1.4 pooka #include <sys/cdefs.h>
47 1.1 pooka #include <sys/mount.h>
48 1.1 pooka #include <sys/param.h>
49 1.1 pooka #include <sys/vnode.h>
50 1.1 pooka #include <sys/lock.h>
51 1.1 pooka #include <sys/namei.h>
52 1.1 pooka #include <sys/dirent.h>
53 1.17 pooka #include <sys/hash.h>
54 1.1 pooka
55 1.1 pooka #include <assert.h>
56 1.1 pooka #include <errno.h>
57 1.1 pooka #include <puffs.h>
58 1.1 pooka #include <stdlib.h>
59 1.10 pooka #include <stdio.h>
60 1.1 pooka
61 1.1 pooka #include <rump/rump.h>
62 1.1 pooka #include <rump/p2k.h>
63 1.1 pooka #include <rump/ukfs.h>
64 1.1 pooka
65 1.35 pooka /* NetBSD-5 compat */
66 1.35 pooka #ifndef MOUNT_RUMPFS
67 1.35 pooka #define MOUNT_RUMPFS "rumpfs"
68 1.35 pooka #endif
69 1.35 pooka
70 1.1 pooka PUFFSOP_PROTOS(p2k)
71 1.1 pooka
72 1.17 pooka LIST_HEAD(p2k_vp_hash, p2k_node);
73 1.17 pooka #define NHASHBUCK (1<<16)
74 1.17 pooka struct p2k_mount {
75 1.17 pooka struct vnode *p2m_rvp;
76 1.21 pooka struct puffs_usermount *p2m_pu;
77 1.21 pooka struct ukfs *p2m_ukfs;
78 1.17 pooka struct p2k_vp_hash p2m_vphash[NHASHBUCK];
79 1.35 pooka struct mount *p2m_mp;
80 1.17 pooka int p2m_nvnodes;
81 1.31 pooka int p2m_imtmpfsman;
82 1.36 pooka bool p2m_hasdebug;
83 1.17 pooka };
84 1.17 pooka
85 1.17 pooka struct p2k_node {
86 1.17 pooka struct vnode *p2n_vp;
87 1.17 pooka struct componentname *p2n_cn;
88 1.17 pooka
89 1.17 pooka /*
90 1.17 pooka * Ok, then, uhm, we need .. *drumroll*.. two componentname
91 1.17 pooka * storages for rename. This is because the source dir is
92 1.17 pooka * unlocked after the first lookup, and someone else might
93 1.17 pooka * race in here. However, we know it's not another rename
94 1.17 pooka * because of the kernel rename lock. And we need two since
95 1.17 pooka * srcdir and targdir might be the same. It's a wonderful world.
96 1.17 pooka */
97 1.17 pooka struct componentname *p2n_cn_ren_src, *p2n_cn_ren_targ;
98 1.17 pooka
99 1.17 pooka LIST_ENTRY(p2k_node) p2n_entries;
100 1.17 pooka };
101 1.17 pooka
102 1.17 pooka #define OPC2VP(opc) (((struct p2k_node *)opc)->p2n_vp)
103 1.17 pooka
104 1.28 pooka static int haswizard;
105 1.28 pooka static uid_t wizarduid;
106 1.28 pooka
107 1.34 pooka static struct kauth_cred *
108 1.1 pooka cred_create(const struct puffs_cred *pcr)
109 1.1 pooka {
110 1.1 pooka gid_t groups[NGROUPS];
111 1.1 pooka uid_t uid;
112 1.1 pooka gid_t gid;
113 1.29 pooka short ngroups = __arraycount(groups);
114 1.1 pooka
115 1.28 pooka if (haswizard) {
116 1.28 pooka uid = wizarduid;
117 1.28 pooka } else {
118 1.28 pooka if (puffs_cred_getuid(pcr, &uid) == -1)
119 1.28 pooka uid = 0;
120 1.28 pooka }
121 1.1 pooka if (puffs_cred_getgid(pcr, &gid) == -1)
122 1.1 pooka gid = 0;
123 1.1 pooka puffs_cred_getgroups(pcr, groups, &ngroups);
124 1.1 pooka
125 1.1 pooka /* LINTED: ngroups is ok */
126 1.23 pooka return rump_pub_cred_create(uid, gid, ngroups, groups);
127 1.1 pooka }
128 1.1 pooka
129 1.1 pooka static __inline void
130 1.34 pooka cred_destroy(struct kauth_cred *cred)
131 1.1 pooka {
132 1.1 pooka
133 1.23 pooka rump_pub_cred_put(cred);
134 1.1 pooka }
135 1.1 pooka
136 1.1 pooka static struct componentname *
137 1.17 pooka makecn(const struct puffs_cn *pcn, int myflags)
138 1.1 pooka {
139 1.34 pooka struct kauth_cred *cred;
140 1.1 pooka
141 1.1 pooka cred = cred_create(pcn->pcn_cred);
142 1.1 pooka /* LINTED: prehistoric types in first two args */
143 1.23 pooka return rump_pub_makecn(pcn->pcn_nameiop, pcn->pcn_flags | myflags,
144 1.24 pooka pcn->pcn_name, pcn->pcn_namelen, cred, rump_pub_lwp_curlwp());
145 1.1 pooka }
146 1.1 pooka
147 1.1 pooka static __inline void
148 1.1 pooka freecn(struct componentname *cnp, int flags)
149 1.1 pooka {
150 1.1 pooka
151 1.23 pooka rump_pub_freecn(cnp, flags | RUMPCN_FREECRED);
152 1.1 pooka }
153 1.1 pooka
154 1.1 pooka static void
155 1.1 pooka makelwp(struct puffs_usermount *pu)
156 1.1 pooka {
157 1.1 pooka pid_t pid;
158 1.1 pooka lwpid_t lid;
159 1.1 pooka
160 1.1 pooka puffs_cc_getcaller(puffs_cc_getcc(pu), &pid, &lid);
161 1.24 pooka rump_pub_lwp_alloc_and_switch(pid, lid);
162 1.1 pooka }
163 1.1 pooka
164 1.1 pooka /*ARGSUSED*/
165 1.1 pooka static void
166 1.1 pooka clearlwp(struct puffs_usermount *pu)
167 1.1 pooka {
168 1.1 pooka
169 1.24 pooka rump_pub_lwp_release(rump_pub_lwp_curlwp());
170 1.17 pooka }
171 1.17 pooka
172 1.17 pooka static __inline struct p2k_vp_hash *
173 1.17 pooka gethash(struct p2k_mount *p2m, struct vnode *vp)
174 1.17 pooka {
175 1.17 pooka uint32_t hash;
176 1.17 pooka
177 1.17 pooka hash = hash32_buf(&vp, sizeof(vp), HASH32_BUF_INIT);
178 1.17 pooka return &p2m->p2m_vphash[hash % NHASHBUCK];
179 1.17 pooka }
180 1.17 pooka
181 1.17 pooka /*
182 1.17 pooka * Find node based on hash of vnode pointer. If vnode is found,
183 1.17 pooka * releases one reference to vnode based on the fact that we just
184 1.17 pooka * performed a lookup for it.
185 1.17 pooka *
186 1.17 pooka * If the optinal p2n_storage parameter is passed, it is used instead
187 1.17 pooka * of allocating more memory. This allows for easier error recovery.
188 1.17 pooka */
189 1.17 pooka static struct p2k_node *
190 1.17 pooka getp2n(struct p2k_mount *p2m, struct vnode *vp, bool initial,
191 1.17 pooka struct p2k_node *p2n_storage)
192 1.17 pooka {
193 1.17 pooka struct p2k_vp_hash *hl;
194 1.17 pooka struct p2k_node *p2n = NULL;
195 1.17 pooka
196 1.17 pooka /* p2n_storage => initial */
197 1.17 pooka assert(!p2n_storage || initial);
198 1.17 pooka
199 1.17 pooka hl = gethash(p2m, vp);
200 1.17 pooka if (!initial)
201 1.17 pooka LIST_FOREACH(p2n, hl, p2n_entries)
202 1.17 pooka if (p2n->p2n_vp == vp)
203 1.17 pooka break;
204 1.17 pooka
205 1.17 pooka hl = gethash(p2m, vp);
206 1.17 pooka if (p2n) {
207 1.23 pooka rump_pub_vp_rele(vp);
208 1.17 pooka } else {
209 1.17 pooka if (p2n_storage)
210 1.17 pooka p2n = p2n_storage;
211 1.17 pooka else
212 1.17 pooka p2n = malloc(sizeof(*p2n));
213 1.17 pooka if (!p2n) {
214 1.23 pooka rump_pub_vp_rele(vp);
215 1.17 pooka return NULL;
216 1.17 pooka }
217 1.17 pooka memset(p2n, 0, sizeof(*p2n));
218 1.17 pooka LIST_INSERT_HEAD(hl, p2n, p2n_entries);
219 1.17 pooka p2n->p2n_vp = vp;
220 1.17 pooka }
221 1.17 pooka return p2n;
222 1.17 pooka }
223 1.17 pooka
224 1.17 pooka static void
225 1.17 pooka freep2n(struct p2k_node *p2n)
226 1.17 pooka {
227 1.17 pooka
228 1.17 pooka assert(p2n->p2n_vp == NULL);
229 1.17 pooka assert(p2n->p2n_cn == NULL);
230 1.17 pooka LIST_REMOVE(p2n, p2n_entries);
231 1.17 pooka free(p2n);
232 1.1 pooka }
233 1.1 pooka
234 1.11 pooka /*ARGSUSED*/
235 1.10 pooka static void
236 1.10 pooka p2k_errcatcher(struct puffs_usermount *pu, uint8_t type, int error,
237 1.10 pooka const char *str, puffs_cookie_t cook)
238 1.10 pooka {
239 1.10 pooka
240 1.10 pooka fprintf(stderr, "type %d, error %d, cookie %p (%s)\n",
241 1.10 pooka type, error, cook, str);
242 1.10 pooka
243 1.10 pooka /*
244 1.10 pooka * Trap all EINVAL responses to lookup. It most likely means
245 1.10 pooka * that we supplied VNON/VBAD as the type. The real kernel
246 1.10 pooka * doesn't panic from this either, but just handles it.
247 1.10 pooka */
248 1.10 pooka if (type != PUFFS_VN_LOOKUP && error == EINVAL)
249 1.10 pooka abort();
250 1.10 pooka }
251 1.10 pooka
252 1.17 pooka /* just to avoid annoying loop when singlestepping */
253 1.26 pooka static struct p2k_mount *
254 1.26 pooka allocp2m(void)
255 1.17 pooka {
256 1.17 pooka struct p2k_mount *p2m;
257 1.17 pooka int i;
258 1.17 pooka
259 1.17 pooka p2m = malloc(sizeof(*p2m));
260 1.26 pooka if (p2m == NULL)
261 1.26 pooka return NULL;
262 1.21 pooka memset(p2m, 0, sizeof(*p2m));
263 1.21 pooka
264 1.17 pooka for (i = 0; i < NHASHBUCK; i++)
265 1.17 pooka LIST_INIT(&p2m->p2m_vphash[i]);
266 1.26 pooka
267 1.26 pooka return p2m;
268 1.17 pooka }
269 1.17 pooka
270 1.26 pooka struct p2k_mount *
271 1.26 pooka p2k_init(uint32_t puffs_flags)
272 1.1 pooka {
273 1.1 pooka struct puffs_ops *pops;
274 1.26 pooka struct p2k_mount *p2m;
275 1.28 pooka char *envbuf;
276 1.6 pooka bool dodaemon;
277 1.36 pooka bool hasdebug;
278 1.1 pooka
279 1.1 pooka PUFFSOP_INIT(pops);
280 1.1 pooka
281 1.1 pooka PUFFSOP_SET(pops, p2k, fs, statvfs);
282 1.1 pooka PUFFSOP_SET(pops, p2k, fs, unmount);
283 1.1 pooka PUFFSOP_SET(pops, p2k, fs, sync);
284 1.1 pooka PUFFSOP_SET(pops, p2k, fs, fhtonode);
285 1.1 pooka PUFFSOP_SET(pops, p2k, fs, nodetofh);
286 1.38 pooka PUFFSOP_SET(pops, p2k, fs, extattrctl);
287 1.1 pooka
288 1.1 pooka PUFFSOP_SET(pops, p2k, node, lookup);
289 1.1 pooka PUFFSOP_SET(pops, p2k, node, create);
290 1.1 pooka PUFFSOP_SET(pops, p2k, node, mknod);
291 1.1 pooka PUFFSOP_SET(pops, p2k, node, open);
292 1.1 pooka PUFFSOP_SET(pops, p2k, node, close);
293 1.1 pooka PUFFSOP_SET(pops, p2k, node, access);
294 1.1 pooka PUFFSOP_SET(pops, p2k, node, getattr);
295 1.1 pooka PUFFSOP_SET(pops, p2k, node, setattr);
296 1.1 pooka #if 0
297 1.1 pooka PUFFSOP_SET(pops, p2k, node, poll);
298 1.1 pooka #endif
299 1.1 pooka PUFFSOP_SET(pops, p2k, node, mmap);
300 1.1 pooka PUFFSOP_SET(pops, p2k, node, fsync);
301 1.1 pooka PUFFSOP_SET(pops, p2k, node, seek);
302 1.1 pooka PUFFSOP_SET(pops, p2k, node, remove);
303 1.1 pooka PUFFSOP_SET(pops, p2k, node, link);
304 1.1 pooka PUFFSOP_SET(pops, p2k, node, rename);
305 1.1 pooka PUFFSOP_SET(pops, p2k, node, mkdir);
306 1.1 pooka PUFFSOP_SET(pops, p2k, node, rmdir);
307 1.1 pooka PUFFSOP_SET(pops, p2k, node, symlink);
308 1.1 pooka PUFFSOP_SET(pops, p2k, node, readdir);
309 1.1 pooka PUFFSOP_SET(pops, p2k, node, readlink);
310 1.1 pooka PUFFSOP_SET(pops, p2k, node, read);
311 1.1 pooka PUFFSOP_SET(pops, p2k, node, write);
312 1.1 pooka
313 1.1 pooka PUFFSOP_SET(pops, p2k, node, inactive);
314 1.1 pooka PUFFSOP_SET(pops, p2k, node, reclaim);
315 1.25 pooka PUFFSOP_SET(pops, p2k, node, abortop);
316 1.1 pooka
317 1.38 pooka PUFFSOP_SET(pops, p2k, node, getextattr);
318 1.38 pooka PUFFSOP_SET(pops, p2k, node, setextattr);
319 1.38 pooka PUFFSOP_SET(pops, p2k, node, listextattr);
320 1.38 pooka PUFFSOP_SET(pops, p2k, node, deleteextattr);
321 1.38 pooka
322 1.6 pooka dodaemon = true;
323 1.37 pooka hasdebug = false;
324 1.37 pooka
325 1.6 pooka if (getenv("P2K_DEBUG") != NULL) {
326 1.6 pooka puffs_flags |= PUFFS_FLAG_OPDUMP;
327 1.6 pooka dodaemon = false;
328 1.36 pooka hasdebug = true;
329 1.6 pooka }
330 1.8 pooka if (getenv("P2K_NODETACH") != NULL) {
331 1.8 pooka dodaemon = false;
332 1.8 pooka }
333 1.13 pooka if (getenv("P2K_NOCACHE_PAGE") != NULL) {
334 1.13 pooka puffs_flags |= PUFFS_KFLAG_NOCACHE_PAGE;
335 1.13 pooka }
336 1.13 pooka if (getenv("P2K_NOCACHE_NAME") != NULL) {
337 1.13 pooka puffs_flags |= PUFFS_KFLAG_NOCACHE_NAME;
338 1.13 pooka }
339 1.13 pooka if (getenv("P2K_NOCACHE") != NULL) {
340 1.13 pooka puffs_flags |= PUFFS_KFLAG_NOCACHE;
341 1.13 pooka }
342 1.28 pooka if ((envbuf = getenv("P2K_WIZARDUID")) != NULL) {
343 1.28 pooka /* default to 0 in error cases */
344 1.28 pooka wizarduid = atoi(envbuf);
345 1.28 pooka haswizard = 1;
346 1.28 pooka printf("P2K WIZARD MODE: using uid %d\n", wizarduid);
347 1.28 pooka }
348 1.6 pooka
349 1.26 pooka p2m = allocp2m();
350 1.26 pooka if (p2m == NULL)
351 1.26 pooka return NULL;
352 1.26 pooka p2m->p2m_pu = puffs_init(pops, PUFFS_DEFER, PUFFS_DEFER,
353 1.26 pooka PUFFS_DEFER, puffs_flags);
354 1.26 pooka if (p2m->p2m_pu == NULL) {
355 1.26 pooka int sverrno = errno;
356 1.26 pooka free(p2m);
357 1.26 pooka errno = sverrno;
358 1.26 pooka return NULL;
359 1.26 pooka }
360 1.36 pooka p2m->p2m_hasdebug = hasdebug;
361 1.26 pooka
362 1.26 pooka if (dodaemon) {
363 1.26 pooka if (puffs_daemon(p2m->p2m_pu, 1, 1) == -1) {
364 1.26 pooka int sverrno = errno;
365 1.26 pooka p2k_cancel(p2m, sverrno);
366 1.26 pooka errno = sverrno;
367 1.26 pooka p2m = NULL;
368 1.26 pooka }
369 1.26 pooka }
370 1.26 pooka if (p2m)
371 1.26 pooka rump_init();
372 1.26 pooka
373 1.26 pooka return p2m;
374 1.26 pooka }
375 1.26 pooka
376 1.26 pooka void
377 1.26 pooka p2k_cancel(struct p2k_mount *p2m, int error)
378 1.26 pooka {
379 1.26 pooka
380 1.26 pooka puffs_cancel(p2m->p2m_pu, error);
381 1.26 pooka free(p2m);
382 1.26 pooka }
383 1.26 pooka
384 1.26 pooka static int
385 1.26 pooka setupfs(struct p2k_mount *p2m, const char *vfsname, const char *devpath,
386 1.30 pooka struct ukfs_part *part, const char *mountpath, int mntflags,
387 1.26 pooka void *arg, size_t alen)
388 1.26 pooka {
389 1.30 pooka char partpath[UKFS_DEVICE_MAXPATHLEN];
390 1.30 pooka char partbuf[UKFS_DEVICE_MAXSTR];
391 1.26 pooka char typebuf[PUFFS_TYPELEN];
392 1.26 pooka struct puffs_usermount *pu = p2m->p2m_pu;
393 1.26 pooka struct p2k_node *p2n_root;
394 1.26 pooka struct ukfs *ukfs = NULL;
395 1.26 pooka extern int puffs_fakecc;
396 1.26 pooka int rv = -1, sverrno;
397 1.26 pooka
398 1.1 pooka strcpy(typebuf, "p2k|");
399 1.1 pooka if (strcmp(vfsname, "puffs") == 0) { /* XXX */
400 1.1 pooka struct puffs_kargs *args = arg;
401 1.1 pooka strlcat(typebuf, args->pa_typename, sizeof(typebuf));
402 1.1 pooka } else {
403 1.1 pooka strlcat(typebuf, vfsname, sizeof(typebuf));
404 1.1 pooka }
405 1.1 pooka
406 1.30 pooka strlcpy(partpath, devpath, sizeof(partpath));
407 1.30 pooka if (ukfs_part_tostring(part, partbuf, sizeof(partbuf))) {
408 1.19 pooka strlcat(partpath, partbuf, sizeof(partpath));
409 1.19 pooka }
410 1.26 pooka puffs_setmntinfo(pu, partpath, typebuf);
411 1.7 pooka
412 1.7 pooka if (ukfs_init() == -1)
413 1.21 pooka goto out;
414 1.35 pooka
415 1.35 pooka /*
416 1.35 pooka * If we're mounting rumpfs, actually do no mount and redirect
417 1.35 pooka * requests to rump fs namespace root. Strictly speaking, this
418 1.35 pooka * is not correct, but considering rumpfs doesn't currently
419 1.35 pooka * support VFS_MOUNT(), I don't think anyone will notice.
420 1.35 pooka */
421 1.35 pooka if (strcmp(vfsname, MOUNT_RUMPFS) == 0) {
422 1.35 pooka if ((rv = rump_pub_vfs_getmp("/", &p2m->p2m_mp)) != 0) {
423 1.35 pooka errno = rv;
424 1.35 pooka rv = -1;
425 1.35 pooka goto out;
426 1.35 pooka }
427 1.35 pooka if ((rv = rump_pub_vfs_root(p2m->p2m_mp,
428 1.35 pooka &p2m->p2m_rvp, 0)) != 0) {
429 1.35 pooka errno = rv;
430 1.35 pooka rv = -1;
431 1.35 pooka goto out;
432 1.35 pooka }
433 1.35 pooka } else {
434 1.35 pooka if (part != ukfs_part_na)
435 1.35 pooka ukfs = ukfs_mount_disk(vfsname, devpath, part,
436 1.35 pooka mountpath, mntflags, arg, alen);
437 1.35 pooka else
438 1.35 pooka ukfs = ukfs_mount(vfsname, devpath, mountpath, mntflags,
439 1.35 pooka arg, alen);
440 1.35 pooka if (ukfs == NULL)
441 1.35 pooka goto out;
442 1.35 pooka ukfs_setspecific(ukfs, p2m);
443 1.35 pooka p2m->p2m_ukfs = ukfs;
444 1.35 pooka p2m->p2m_mp = ukfs_getmp(ukfs);
445 1.35 pooka p2m->p2m_rvp = ukfs_getrvp(ukfs);
446 1.35 pooka }
447 1.35 pooka
448 1.21 pooka p2m->p2m_pu = pu;
449 1.7 pooka
450 1.31 pooka /*
451 1.31 pooka * Detect tmpfs. XXX: this is a kludge. See inactive().
452 1.31 pooka *
453 1.31 pooka * In reality we'd want "does file system use anon objects
454 1.31 pooka * for storage?". But since tmpfs hides the anon object from
455 1.31 pooka * the public interface, we can't actually detect it sanely.
456 1.31 pooka * Therefore, use this kludge.
457 1.31 pooka */
458 1.31 pooka p2m->p2m_imtmpfsman = strcmp(vfsname, MOUNT_TMPFS) == 0;
459 1.31 pooka
460 1.17 pooka p2n_root = getp2n(p2m, p2m->p2m_rvp, true, NULL);
461 1.1 pooka puffs_setfhsize(pu, 0, PUFFS_FHFLAG_PASSTHROUGH);
462 1.1 pooka puffs_setstacksize(pu, PUFFS_STACKSIZE_MIN);
463 1.1 pooka puffs_fakecc = 1;
464 1.1 pooka puffs_set_prepost(pu, makelwp, clearlwp);
465 1.10 pooka puffs_set_errnotify(pu, p2k_errcatcher);
466 1.1 pooka
467 1.35 pooka puffs_setspecific(pu, p2m);
468 1.26 pooka rv = puffs_mount(pu, mountpath, mntflags, p2n_root);
469 1.1 pooka
470 1.1 pooka out:
471 1.26 pooka if (rv == -1) {
472 1.26 pooka sverrno = errno;
473 1.26 pooka puffs_cancel(pu, sverrno);
474 1.21 pooka if (ukfs)
475 1.21 pooka ukfs_release(p2m->p2m_ukfs, UKFS_RELFLAG_FORCE);
476 1.26 pooka free(p2m);
477 1.1 pooka errno = sverrno;
478 1.1 pooka }
479 1.1 pooka
480 1.26 pooka return rv;
481 1.21 pooka }
482 1.21 pooka
483 1.21 pooka int
484 1.21 pooka p2k_mainloop(struct p2k_mount *p2m)
485 1.21 pooka {
486 1.21 pooka int rv, sverrno;
487 1.21 pooka
488 1.21 pooka rv = puffs_mainloop(p2m->p2m_pu);
489 1.21 pooka sverrno = errno;
490 1.21 pooka puffs_exit(p2m->p2m_pu, 1);
491 1.21 pooka if (p2m->p2m_ukfs)
492 1.21 pooka ukfs_release(p2m->p2m_ukfs, UKFS_RELFLAG_FORCE);
493 1.21 pooka free(p2m);
494 1.21 pooka
495 1.21 pooka if (rv == -1)
496 1.21 pooka errno = sverrno;
497 1.1 pooka return rv;
498 1.1 pooka }
499 1.1 pooka
500 1.19 pooka int
501 1.19 pooka p2k_run_fs(const char *vfsname, const char *devpath, const char *mountpath,
502 1.19 pooka int mntflags, void *arg, size_t alen, uint32_t puffs_flags)
503 1.19 pooka {
504 1.21 pooka struct p2k_mount *p2m;
505 1.26 pooka int rv;
506 1.19 pooka
507 1.26 pooka p2m = p2k_init(puffs_flags);
508 1.21 pooka if (p2m == NULL)
509 1.21 pooka return -1;
510 1.30 pooka rv = setupfs(p2m, vfsname, devpath, ukfs_part_na, mountpath,
511 1.26 pooka mntflags, arg, alen);
512 1.26 pooka if (rv == -1)
513 1.26 pooka return rv;
514 1.21 pooka return p2k_mainloop(p2m);
515 1.19 pooka }
516 1.19 pooka
517 1.19 pooka int
518 1.30 pooka p2k_run_diskfs(const char *vfsname, const char *devpath, struct ukfs_part *part,
519 1.19 pooka const char *mountpath, int mntflags, void *arg, size_t alen,
520 1.19 pooka uint32_t puffs_flags)
521 1.19 pooka {
522 1.21 pooka struct p2k_mount *p2m;
523 1.26 pooka int rv;
524 1.21 pooka
525 1.26 pooka p2m = p2k_init(puffs_flags);
526 1.21 pooka if (p2m == NULL)
527 1.21 pooka return -1;
528 1.30 pooka rv = setupfs(p2m, vfsname, devpath, part, mountpath, mntflags,
529 1.26 pooka arg, alen);
530 1.26 pooka if (rv == -1)
531 1.26 pooka return rv;
532 1.21 pooka return p2k_mainloop(p2m);
533 1.21 pooka }
534 1.21 pooka
535 1.26 pooka int
536 1.26 pooka p2k_setup_fs(struct p2k_mount *p2m, const char *vfsname, const char *devpath,
537 1.26 pooka const char *mountpath, int mntflags, void *arg, size_t alen)
538 1.21 pooka {
539 1.19 pooka
540 1.30 pooka return setupfs(p2m, vfsname, devpath, ukfs_part_na, mountpath,
541 1.26 pooka mntflags, arg, alen);
542 1.21 pooka }
543 1.21 pooka
544 1.26 pooka int
545 1.26 pooka p2k_setup_diskfs(struct p2k_mount *p2m, const char *vfsname,
546 1.30 pooka const char *devpath, struct ukfs_part *part, const char *mountpath,
547 1.26 pooka int mntflags, void *arg, size_t alen)
548 1.21 pooka {
549 1.21 pooka
550 1.30 pooka return setupfs(p2m, vfsname, devpath, part, mountpath, mntflags,
551 1.26 pooka arg, alen);
552 1.19 pooka }
553 1.19 pooka
554 1.1 pooka int
555 1.1 pooka p2k_fs_statvfs(struct puffs_usermount *pu, struct statvfs *sbp)
556 1.1 pooka {
557 1.35 pooka struct p2k_mount *p2m = puffs_getspecific(pu);
558 1.35 pooka struct mount *mp = p2m->p2m_mp;
559 1.1 pooka
560 1.23 pooka return rump_pub_vfs_statvfs(mp, sbp);
561 1.1 pooka }
562 1.1 pooka
563 1.15 pooka /*ARGSUSED*/
564 1.1 pooka int
565 1.1 pooka p2k_fs_unmount(struct puffs_usermount *pu, int flags)
566 1.1 pooka {
567 1.35 pooka struct p2k_mount *p2m = puffs_getspecific(pu);
568 1.35 pooka struct ukfs *fs = p2m->p2m_ukfs;
569 1.17 pooka int error = 0;
570 1.1 pooka
571 1.24 pooka rump_pub_lwp_release(rump_pub_lwp_curlwp()); /* ukfs & curlwp tricks */
572 1.17 pooka
573 1.23 pooka rump_pub_vp_rele(p2m->p2m_rvp);
574 1.35 pooka if (fs) {
575 1.35 pooka if (ukfs_release(fs, 0) != 0) {
576 1.35 pooka ukfs_release(fs, UKFS_RELFLAG_FORCE);
577 1.35 pooka error = 0;
578 1.35 pooka }
579 1.17 pooka }
580 1.21 pooka p2m->p2m_ukfs = NULL;
581 1.1 pooka
582 1.36 pooka if (p2m->p2m_hasdebug) {
583 1.36 pooka printf("-- rump kernel event counters --\n");
584 1.36 pooka rump_printevcnts();
585 1.36 pooka printf("-- end of event counters --\n");
586 1.36 pooka }
587 1.36 pooka
588 1.24 pooka rump_pub_lwp_alloc_and_switch(0, 0);
589 1.17 pooka return error;
590 1.1 pooka }
591 1.1 pooka
592 1.1 pooka int
593 1.1 pooka p2k_fs_sync(struct puffs_usermount *pu, int waitfor,
594 1.1 pooka const struct puffs_cred *pcr)
595 1.1 pooka {
596 1.35 pooka struct p2k_mount *p2m = puffs_getspecific(pu);
597 1.35 pooka struct mount *mp = p2m->p2m_mp;
598 1.34 pooka struct kauth_cred *cred;
599 1.1 pooka int rv;
600 1.1 pooka
601 1.1 pooka cred = cred_create(pcr);
602 1.34 pooka rv = rump_pub_vfs_sync(mp, waitfor, cred);
603 1.1 pooka cred_destroy(cred);
604 1.1 pooka
605 1.1 pooka return rv;
606 1.1 pooka }
607 1.1 pooka
608 1.1 pooka /*ARGSUSED*/
609 1.1 pooka int
610 1.1 pooka p2k_fs_fhtonode(struct puffs_usermount *pu, void *fid, size_t fidsize,
611 1.1 pooka struct puffs_newinfo *pni)
612 1.1 pooka {
613 1.35 pooka struct p2k_mount *p2m = puffs_getspecific(pu);
614 1.35 pooka struct mount *mp = p2m->p2m_mp;
615 1.17 pooka struct p2k_node *p2n;
616 1.1 pooka struct vnode *vp;
617 1.1 pooka enum vtype vtype;
618 1.1 pooka voff_t vsize;
619 1.17 pooka uint64_t rdev; /* XXX: allows running this on NetBSD 5.0 */
620 1.1 pooka int rv;
621 1.1 pooka
622 1.23 pooka rv = rump_pub_vfs_fhtovp(mp, fid, &vp);
623 1.1 pooka if (rv)
624 1.1 pooka return rv;
625 1.17 pooka RUMP_VOP_UNLOCK(vp, 0);
626 1.1 pooka
627 1.17 pooka p2n = getp2n(p2m, vp, false, NULL);
628 1.17 pooka if (p2n == NULL)
629 1.17 pooka return ENOMEM;
630 1.17 pooka
631 1.17 pooka puffs_newinfo_setcookie(pni, p2n);
632 1.23 pooka rump_pub_getvninfo(vp, &vtype, &vsize, (void *)&rdev);
633 1.1 pooka puffs_newinfo_setvtype(pni, vtype);
634 1.1 pooka puffs_newinfo_setsize(pni, vsize);
635 1.17 pooka /* LINTED: yea, it'll lose accuracy, but that's life */
636 1.1 pooka puffs_newinfo_setrdev(pni, rdev);
637 1.1 pooka
638 1.1 pooka return 0;
639 1.1 pooka }
640 1.1 pooka
641 1.1 pooka /*ARGSUSED*/
642 1.1 pooka int
643 1.3 pooka p2k_fs_nodetofh(struct puffs_usermount *pu, puffs_cookie_t cookie, void *fid,
644 1.1 pooka size_t *fidsize)
645 1.1 pooka {
646 1.1 pooka struct vnode *vp = cookie;
647 1.1 pooka
648 1.23 pooka return rump_pub_vfs_vptofh(vp, fid, fidsize);
649 1.1 pooka }
650 1.1 pooka
651 1.38 pooka int
652 1.38 pooka p2k_fs_extattrctl(struct puffs_usermount *pu, int cmd,
653 1.38 pooka puffs_cookie_t cookie, int flags,
654 1.38 pooka int attrnamespace, const char *attrname)
655 1.38 pooka {
656 1.38 pooka struct p2k_mount *p2m = puffs_getspecific(pu);
657 1.38 pooka struct mount *mp = p2m->p2m_mp;
658 1.38 pooka struct vnode *vp;
659 1.38 pooka
660 1.38 pooka if (flags & PUFFS_EXTATTRCTL_HASNODE) {
661 1.38 pooka vp = OPC2VP(cookie);
662 1.38 pooka RUMP_VOP_LOCK(vp, LK_EXCLUSIVE | LK_RETRY);
663 1.38 pooka } else {
664 1.38 pooka vp = NULL;
665 1.38 pooka }
666 1.38 pooka
667 1.38 pooka /* vfsop unlocks (but doesn't release) vnode, so we're done here */
668 1.38 pooka return rump_pub_vfs_extattrctl(mp, cmd, vp, attrnamespace, attrname);
669 1.38 pooka }
670 1.38 pooka
671 1.1 pooka /*ARGSUSED*/
672 1.1 pooka int
673 1.3 pooka p2k_node_lookup(struct puffs_usermount *pu, puffs_cookie_t opc,
674 1.1 pooka struct puffs_newinfo *pni, const struct puffs_cn *pcn)
675 1.1 pooka {
676 1.35 pooka struct p2k_mount *p2m = puffs_getspecific(pu);
677 1.17 pooka struct p2k_node *p2n_dir = opc, *p2n;
678 1.1 pooka struct componentname *cn;
679 1.17 pooka struct vnode *dvp = p2n_dir->p2n_vp, *vp;
680 1.1 pooka enum vtype vtype;
681 1.1 pooka voff_t vsize;
682 1.14 pooka uint64_t rdev; /* XXX: uint64_t because of stack overwrite in compat */
683 1.1 pooka int rv;
684 1.1 pooka
685 1.17 pooka cn = makecn(pcn, 0);
686 1.17 pooka RUMP_VOP_LOCK(dvp, LK_EXCLUSIVE);
687 1.17 pooka rv = RUMP_VOP_LOOKUP(dvp, &vp, cn);
688 1.17 pooka RUMP_VOP_UNLOCK(dvp, 0);
689 1.23 pooka if (rump_pub_checksavecn(cn)) {
690 1.17 pooka /*
691 1.32 pooka * XXX the rename lookup protocol is currently horribly
692 1.32 pooka * broken. We get 1) DELETE with SAVESTART 2) DELETE
693 1.32 pooka * without SAVESTART 3) RENAME. Hold on to this like
694 1.32 pooka * it were the absolute truth for now. However, do
695 1.32 pooka * not sprinkle asserts based on this due to abovementioned
696 1.32 pooka * brokenness -- some file system drivers might not
697 1.32 pooka * even issue ABORT properly, so just free resources
698 1.32 pooka * on the fly and hope for the best. PR kern/42348
699 1.17 pooka */
700 1.33 pooka if (pcn->pcn_flags & RUMP_NAMEI_INRENAME) {
701 1.33 pooka if (pcn->pcn_nameiop == RUMP_NAMEI_DELETE) {
702 1.32 pooka /* save path from the first lookup */
703 1.33 pooka if (pcn->pcn_flags & RUMP_NAMEI_SAVESTART) {
704 1.32 pooka if (p2n_dir->p2n_cn_ren_src)
705 1.32 pooka freecn(p2n_dir->p2n_cn_ren_src,
706 1.32 pooka RUMPCN_FORCEFREE);
707 1.32 pooka p2n_dir->p2n_cn_ren_src = cn;
708 1.32 pooka } else {
709 1.32 pooka freecn(cn, RUMPCN_FORCEFREE);
710 1.32 pooka cn = NULL;
711 1.32 pooka }
712 1.17 pooka } else {
713 1.33 pooka assert(pcn->pcn_nameiop == RUMP_NAMEI_RENAME);
714 1.32 pooka if (p2n_dir->p2n_cn_ren_targ)
715 1.32 pooka freecn(p2n_dir->p2n_cn_ren_targ,
716 1.32 pooka RUMPCN_FORCEFREE);
717 1.17 pooka p2n_dir->p2n_cn_ren_targ = cn;
718 1.17 pooka }
719 1.17 pooka } else {
720 1.32 pooka assert(p2n_dir->p2n_cn == NULL);
721 1.32 pooka p2n_dir->p2n_cn = cn;
722 1.17 pooka }
723 1.17 pooka } else {
724 1.17 pooka freecn(cn, 0);
725 1.17 pooka cn = NULL;
726 1.17 pooka }
727 1.1 pooka if (rv) {
728 1.17 pooka if (rv == EJUSTRETURN) {
729 1.1 pooka rv = ENOENT;
730 1.17 pooka }
731 1.1 pooka return rv;
732 1.1 pooka }
733 1.17 pooka RUMP_VOP_UNLOCK(vp, 0);
734 1.1 pooka
735 1.17 pooka p2n = getp2n(p2m, vp, false, NULL);
736 1.17 pooka if (p2n == NULL) {
737 1.33 pooka if (pcn->pcn_flags & RUMP_NAMEI_INRENAME) {
738 1.33 pooka if (pcn->pcn_nameiop == RUMP_NAMEI_DELETE) {
739 1.17 pooka p2n_dir->p2n_cn_ren_src = NULL;
740 1.17 pooka } else {
741 1.17 pooka p2n_dir->p2n_cn_ren_targ = NULL;
742 1.17 pooka }
743 1.17 pooka } else {
744 1.17 pooka p2n_dir->p2n_cn = NULL;
745 1.17 pooka }
746 1.17 pooka /* XXX: what in the world should happen with SAVESTART? */
747 1.17 pooka RUMP_VOP_ABORTOP(dvp, cn);
748 1.17 pooka return ENOMEM;
749 1.17 pooka }
750 1.17 pooka
751 1.17 pooka puffs_newinfo_setcookie(pni, p2n);
752 1.23 pooka rump_pub_getvninfo(vp, &vtype, &vsize, (void *)&rdev);
753 1.1 pooka puffs_newinfo_setvtype(pni, vtype);
754 1.1 pooka puffs_newinfo_setsize(pni, vsize);
755 1.17 pooka /* LINTED: yea, it'll lose accuracy, but that's life */
756 1.1 pooka puffs_newinfo_setrdev(pni, rdev);
757 1.1 pooka
758 1.1 pooka return 0;
759 1.1 pooka }
760 1.1 pooka
761 1.14 pooka #define VERS_TIMECHANGE 599000700
762 1.14 pooka static int
763 1.14 pooka needcompat(void)
764 1.14 pooka {
765 1.14 pooka
766 1.15 pooka /*LINTED*/
767 1.14 pooka return __NetBSD_Version__ < VERS_TIMECHANGE
768 1.23 pooka && rump_pub_getversion() >= VERS_TIMECHANGE;
769 1.14 pooka }
770 1.14 pooka
771 1.14 pooka #define DOCOMPAT(va, va_compat) \
772 1.14 pooka do { \
773 1.14 pooka if (needcompat()) { \
774 1.23 pooka va_compat = rump_pub_vattr_init(); \
775 1.23 pooka rump_pub_vattr50_to_vattr(va, va_compat); \
776 1.14 pooka } else { \
777 1.14 pooka va_compat = __UNCONST(va); \
778 1.14 pooka } \
779 1.14 pooka } while (/*CONSTCOND*/0)
780 1.14 pooka
781 1.14 pooka #define UNDOCOMPAT(va_compat) \
782 1.14 pooka do { \
783 1.14 pooka if (needcompat()) \
784 1.23 pooka rump_pub_vattr_free(va_compat); \
785 1.14 pooka } while (/*CONSTCOND*/0)
786 1.14 pooka
787 1.17 pooka static int
788 1.17 pooka do_makenode(struct puffs_usermount *pu, struct p2k_node *p2n_dir,
789 1.1 pooka struct puffs_newinfo *pni, const struct puffs_cn *pcn,
790 1.17 pooka const struct vattr *vap, char *link_target,
791 1.17 pooka int (*makefn)(struct vnode *, struct vnode **, struct componentname *,
792 1.17 pooka struct vattr *),
793 1.17 pooka int (*symfn)(struct vnode *, struct vnode **, struct componentname *,
794 1.17 pooka struct vattr *, char *))
795 1.17 pooka {
796 1.35 pooka struct p2k_mount *p2m = puffs_getspecific(pu);
797 1.17 pooka struct vnode *dvp = p2n_dir->p2n_vp;
798 1.17 pooka struct p2k_node *p2n;
799 1.1 pooka struct componentname *cn;
800 1.14 pooka struct vattr *va_x;
801 1.1 pooka struct vnode *vp;
802 1.1 pooka int rv;
803 1.1 pooka
804 1.17 pooka p2n = malloc(sizeof(*p2n));
805 1.17 pooka if (p2n == NULL)
806 1.17 pooka return ENOMEM;
807 1.14 pooka DOCOMPAT(vap, va_x);
808 1.14 pooka
809 1.17 pooka if (p2n_dir->p2n_cn) {
810 1.17 pooka cn = p2n_dir->p2n_cn;
811 1.17 pooka p2n_dir->p2n_cn = NULL;
812 1.17 pooka } else {
813 1.17 pooka cn = makecn(pcn, RUMP_NAMEI_HASBUF);
814 1.17 pooka }
815 1.17 pooka
816 1.17 pooka RUMP_VOP_LOCK(dvp, LK_EXCLUSIVE);
817 1.23 pooka rump_pub_vp_incref(dvp);
818 1.17 pooka if (makefn) {
819 1.17 pooka rv = makefn(dvp, &vp, cn, va_x);
820 1.17 pooka } else {
821 1.17 pooka rv = symfn(dvp, &vp, cn, va_x, link_target);
822 1.17 pooka }
823 1.17 pooka assert(RUMP_VOP_ISLOCKED(dvp) == 0);
824 1.1 pooka freecn(cn, 0);
825 1.17 pooka
826 1.1 pooka if (rv == 0) {
827 1.17 pooka RUMP_VOP_UNLOCK(vp, 0);
828 1.17 pooka p2n = getp2n(p2m, vp, true, p2n);
829 1.17 pooka puffs_newinfo_setcookie(pni, p2n);
830 1.17 pooka } else {
831 1.17 pooka free(p2n);
832 1.1 pooka }
833 1.1 pooka
834 1.14 pooka UNDOCOMPAT(va_x);
835 1.14 pooka
836 1.1 pooka return rv;
837 1.17 pooka
838 1.1 pooka }
839 1.1 pooka
840 1.1 pooka /*ARGSUSED*/
841 1.1 pooka int
842 1.17 pooka p2k_node_create(struct puffs_usermount *pu, puffs_cookie_t opc,
843 1.3 pooka struct puffs_newinfo *pni, const struct puffs_cn *pcn,
844 1.3 pooka const struct vattr *vap)
845 1.1 pooka {
846 1.1 pooka
847 1.17 pooka return do_makenode(pu, opc, pni, pcn, vap, NULL, RUMP_VOP_CREATE, NULL);
848 1.17 pooka }
849 1.14 pooka
850 1.17 pooka /*ARGSUSED*/
851 1.17 pooka int
852 1.17 pooka p2k_node_mknod(struct puffs_usermount *pu, puffs_cookie_t opc,
853 1.17 pooka struct puffs_newinfo *pni, const struct puffs_cn *pcn,
854 1.17 pooka const struct vattr *vap)
855 1.17 pooka {
856 1.14 pooka
857 1.17 pooka return do_makenode(pu, opc, pni, pcn, vap, NULL, RUMP_VOP_MKNOD, NULL);
858 1.1 pooka }
859 1.1 pooka
860 1.1 pooka /*ARGSUSED*/
861 1.1 pooka int
862 1.3 pooka p2k_node_open(struct puffs_usermount *pu, puffs_cookie_t opc, int mode,
863 1.1 pooka const struct puffs_cred *pcr)
864 1.1 pooka {
865 1.17 pooka struct vnode *vp = OPC2VP(opc);
866 1.34 pooka struct kauth_cred *cred;
867 1.1 pooka int rv;
868 1.1 pooka
869 1.1 pooka cred = cred_create(pcr);
870 1.17 pooka RUMP_VOP_LOCK(vp, LK_EXCLUSIVE);
871 1.17 pooka rv = RUMP_VOP_OPEN(vp, mode, cred);
872 1.17 pooka RUMP_VOP_UNLOCK(vp, 0);
873 1.1 pooka cred_destroy(cred);
874 1.1 pooka
875 1.1 pooka return rv;
876 1.1 pooka }
877 1.1 pooka
878 1.1 pooka /*ARGSUSED*/
879 1.1 pooka int
880 1.3 pooka p2k_node_close(struct puffs_usermount *pu, puffs_cookie_t opc, int flags,
881 1.1 pooka const struct puffs_cred *pcr)
882 1.1 pooka {
883 1.17 pooka struct vnode *vp = OPC2VP(opc);
884 1.34 pooka struct kauth_cred *cred;
885 1.1 pooka
886 1.1 pooka cred = cred_create(pcr);
887 1.17 pooka RUMP_VOP_LOCK(vp, LK_EXCLUSIVE);
888 1.17 pooka RUMP_VOP_CLOSE(vp, flags, cred);
889 1.17 pooka RUMP_VOP_UNLOCK(vp, 0);
890 1.1 pooka cred_destroy(cred);
891 1.1 pooka
892 1.1 pooka return 0;
893 1.1 pooka }
894 1.1 pooka
895 1.1 pooka /*ARGSUSED*/
896 1.1 pooka int
897 1.3 pooka p2k_node_access(struct puffs_usermount *pu, puffs_cookie_t opc, int mode,
898 1.1 pooka const struct puffs_cred *pcr)
899 1.1 pooka {
900 1.17 pooka struct vnode *vp = OPC2VP(opc);
901 1.34 pooka struct kauth_cred *cred;
902 1.1 pooka int rv;
903 1.1 pooka
904 1.1 pooka cred = cred_create(pcr);
905 1.17 pooka RUMP_VOP_LOCK(vp, LK_EXCLUSIVE);
906 1.17 pooka rv = RUMP_VOP_ACCESS(vp, mode, cred);
907 1.17 pooka RUMP_VOP_UNLOCK(vp, 0);
908 1.1 pooka cred_destroy(cred);
909 1.1 pooka
910 1.1 pooka return rv;
911 1.1 pooka }
912 1.1 pooka
913 1.1 pooka /*ARGSUSED*/
914 1.1 pooka int
915 1.3 pooka p2k_node_getattr(struct puffs_usermount *pu, puffs_cookie_t opc,
916 1.3 pooka struct vattr *vap, const struct puffs_cred *pcr)
917 1.1 pooka {
918 1.17 pooka struct vnode *vp = OPC2VP(opc);
919 1.34 pooka struct kauth_cred *cred;
920 1.14 pooka struct vattr *va_x;
921 1.1 pooka int rv;
922 1.1 pooka
923 1.20 pooka /* "deadfs" */
924 1.20 pooka if (!vp)
925 1.20 pooka return 0;
926 1.20 pooka
927 1.14 pooka if (needcompat()) {
928 1.23 pooka va_x = rump_pub_vattr_init();
929 1.14 pooka } else {
930 1.14 pooka va_x = vap;
931 1.14 pooka }
932 1.14 pooka
933 1.1 pooka cred = cred_create(pcr);
934 1.17 pooka RUMP_VOP_LOCK(vp, LK_EXCLUSIVE);
935 1.17 pooka rv = RUMP_VOP_GETATTR(vp, va_x, cred);
936 1.17 pooka RUMP_VOP_UNLOCK(vp, 0);
937 1.1 pooka cred_destroy(cred);
938 1.1 pooka
939 1.14 pooka if (needcompat()) {
940 1.23 pooka rump_pub_vattr_to_vattr50(va_x, vap);
941 1.23 pooka rump_pub_vattr_free(va_x);
942 1.14 pooka }
943 1.14 pooka
944 1.1 pooka return rv;
945 1.1 pooka }
946 1.1 pooka
947 1.1 pooka /*ARGSUSED*/
948 1.1 pooka int
949 1.3 pooka p2k_node_setattr(struct puffs_usermount *pu, puffs_cookie_t opc,
950 1.3 pooka const struct vattr *vap, const struct puffs_cred *pcr)
951 1.1 pooka {
952 1.17 pooka struct vnode *vp = OPC2VP(opc);
953 1.34 pooka struct kauth_cred *cred;
954 1.14 pooka struct vattr *va_x;
955 1.1 pooka int rv;
956 1.1 pooka
957 1.17 pooka /* "deadfs" */
958 1.17 pooka if (!vp)
959 1.17 pooka return 0;
960 1.17 pooka
961 1.14 pooka DOCOMPAT(vap, va_x);
962 1.14 pooka
963 1.1 pooka cred = cred_create(pcr);
964 1.17 pooka RUMP_VOP_LOCK(vp, LK_EXCLUSIVE);
965 1.17 pooka rv = RUMP_VOP_SETATTR(vp, va_x, cred);
966 1.17 pooka RUMP_VOP_UNLOCK(vp, 0);
967 1.1 pooka cred_destroy(cred);
968 1.1 pooka
969 1.14 pooka UNDOCOMPAT(va_x);
970 1.14 pooka
971 1.1 pooka return rv;
972 1.1 pooka }
973 1.1 pooka
974 1.1 pooka /*ARGSUSED*/
975 1.1 pooka int
976 1.3 pooka p2k_node_fsync(struct puffs_usermount *pu, puffs_cookie_t opc,
977 1.1 pooka const struct puffs_cred *pcr, int flags, off_t offlo, off_t offhi)
978 1.1 pooka {
979 1.17 pooka struct vnode *vp = OPC2VP(opc);
980 1.34 pooka struct kauth_cred *cred;
981 1.1 pooka int rv;
982 1.1 pooka
983 1.17 pooka /* "deadfs" */
984 1.17 pooka if (!vp)
985 1.17 pooka return 0;
986 1.17 pooka
987 1.1 pooka cred = cred_create(pcr);
988 1.17 pooka RUMP_VOP_LOCK(vp, LK_EXCLUSIVE);
989 1.17 pooka rv = RUMP_VOP_FSYNC(vp, cred, flags, offlo, offhi);
990 1.17 pooka RUMP_VOP_UNLOCK(vp, 0);
991 1.1 pooka cred_destroy(cred);
992 1.1 pooka
993 1.1 pooka return rv;
994 1.1 pooka }
995 1.1 pooka
996 1.1 pooka /*ARGSUSED*/
997 1.1 pooka int
998 1.3 pooka p2k_node_mmap(struct puffs_usermount *pu, puffs_cookie_t opc, vm_prot_t flags,
999 1.1 pooka const struct puffs_cred *pcr)
1000 1.1 pooka {
1001 1.34 pooka struct kauth_cred *cred;
1002 1.1 pooka int rv;
1003 1.1 pooka
1004 1.1 pooka cred = cred_create(pcr);
1005 1.17 pooka rv = RUMP_VOP_MMAP(OPC2VP(opc), flags, cred);
1006 1.1 pooka cred_destroy(cred);
1007 1.1 pooka
1008 1.1 pooka return rv;
1009 1.1 pooka }
1010 1.1 pooka
1011 1.1 pooka /*ARGSUSED*/
1012 1.1 pooka int
1013 1.3 pooka p2k_node_seek(struct puffs_usermount *pu, puffs_cookie_t opc,
1014 1.3 pooka off_t oldoff, off_t newoff, const struct puffs_cred *pcr)
1015 1.1 pooka {
1016 1.17 pooka struct vnode *vp = OPC2VP(opc);
1017 1.34 pooka struct kauth_cred *cred;
1018 1.1 pooka int rv;
1019 1.1 pooka
1020 1.1 pooka cred = cred_create(pcr);
1021 1.17 pooka RUMP_VOP_LOCK(vp, LK_EXCLUSIVE);
1022 1.17 pooka rv = RUMP_VOP_SEEK(vp, oldoff, newoff, cred);
1023 1.17 pooka RUMP_VOP_UNLOCK(vp, 0);
1024 1.1 pooka cred_destroy(cred);
1025 1.1 pooka
1026 1.1 pooka return rv;
1027 1.1 pooka }
1028 1.1 pooka
1029 1.26 pooka /*ARGSUSED*/
1030 1.25 pooka int
1031 1.25 pooka p2k_node_abortop(struct puffs_usermount *pu, puffs_cookie_t opc,
1032 1.25 pooka const struct puffs_cn *pcn)
1033 1.25 pooka {
1034 1.25 pooka struct p2k_node *p2n_dir = opc;
1035 1.25 pooka struct componentname *cnp;
1036 1.25 pooka
1037 1.25 pooka if ((cnp = p2n_dir->p2n_cn) != NULL) {
1038 1.25 pooka freecn(cnp, 0);
1039 1.25 pooka p2n_dir->p2n_cn = NULL;
1040 1.25 pooka }
1041 1.25 pooka if ((cnp = p2n_dir->p2n_cn_ren_src) != NULL) {
1042 1.25 pooka freecn(cnp, RUMPCN_FORCEFREE);
1043 1.25 pooka p2n_dir->p2n_cn_ren_src = NULL;
1044 1.25 pooka }
1045 1.25 pooka if ((cnp = p2n_dir->p2n_cn_ren_targ) != NULL) {
1046 1.25 pooka freecn(cnp, RUMPCN_FORCEFREE);
1047 1.25 pooka p2n_dir->p2n_cn_ren_targ = NULL;
1048 1.25 pooka }
1049 1.25 pooka
1050 1.25 pooka return 0;
1051 1.25 pooka }
1052 1.25 pooka
1053 1.17 pooka static int
1054 1.17 pooka do_nukenode(struct p2k_node *p2n_dir, struct p2k_node *p2n,
1055 1.17 pooka const struct puffs_cn *pcn,
1056 1.17 pooka int (*nukefn)(struct vnode *, struct vnode *, struct componentname *))
1057 1.1 pooka {
1058 1.17 pooka struct vnode *dvp = p2n_dir->p2n_vp, *vp = p2n->p2n_vp;
1059 1.1 pooka struct componentname *cn;
1060 1.1 pooka int rv;
1061 1.1 pooka
1062 1.17 pooka if (p2n_dir->p2n_cn) {
1063 1.17 pooka cn = p2n_dir->p2n_cn;
1064 1.17 pooka p2n_dir->p2n_cn = NULL;
1065 1.17 pooka } else {
1066 1.17 pooka cn = makecn(pcn, RUMP_NAMEI_HASBUF);
1067 1.17 pooka }
1068 1.17 pooka
1069 1.17 pooka RUMP_VOP_LOCK(dvp, LK_EXCLUSIVE);
1070 1.23 pooka rump_pub_vp_incref(dvp);
1071 1.17 pooka RUMP_VOP_LOCK(vp, LK_EXCLUSIVE);
1072 1.23 pooka rump_pub_vp_incref(vp);
1073 1.17 pooka rv = nukefn(dvp, vp, cn);
1074 1.17 pooka assert(RUMP_VOP_ISLOCKED(dvp) == 0);
1075 1.17 pooka assert(RUMP_VOP_ISLOCKED(vp) == 0);
1076 1.1 pooka freecn(cn, 0);
1077 1.1 pooka
1078 1.1 pooka return rv;
1079 1.17 pooka
1080 1.17 pooka }
1081 1.17 pooka
1082 1.17 pooka /*ARGSUSED*/
1083 1.17 pooka int
1084 1.17 pooka p2k_node_remove(struct puffs_usermount *pu, puffs_cookie_t opc,
1085 1.17 pooka puffs_cookie_t targ, const struct puffs_cn *pcn)
1086 1.17 pooka {
1087 1.17 pooka
1088 1.17 pooka return do_nukenode(opc, targ, pcn, RUMP_VOP_REMOVE);
1089 1.1 pooka }
1090 1.1 pooka
1091 1.1 pooka /*ARGSUSED*/
1092 1.1 pooka int
1093 1.3 pooka p2k_node_link(struct puffs_usermount *pu, puffs_cookie_t opc,
1094 1.3 pooka puffs_cookie_t targ, const struct puffs_cn *pcn)
1095 1.1 pooka {
1096 1.17 pooka struct vnode *dvp = OPC2VP(opc);
1097 1.17 pooka struct p2k_node *p2n_dir = opc;
1098 1.1 pooka struct componentname *cn;
1099 1.1 pooka int rv;
1100 1.1 pooka
1101 1.17 pooka if (p2n_dir->p2n_cn) {
1102 1.17 pooka cn = p2n_dir->p2n_cn;
1103 1.17 pooka p2n_dir->p2n_cn = NULL;
1104 1.17 pooka } else {
1105 1.17 pooka cn = makecn(pcn, RUMP_NAMEI_HASBUF);
1106 1.17 pooka }
1107 1.17 pooka
1108 1.17 pooka RUMP_VOP_LOCK(dvp, LK_EXCLUSIVE);
1109 1.23 pooka rump_pub_vp_incref(dvp);
1110 1.17 pooka rv = RUMP_VOP_LINK(dvp, OPC2VP(targ), cn);
1111 1.1 pooka freecn(cn, 0);
1112 1.1 pooka
1113 1.1 pooka return rv;
1114 1.1 pooka }
1115 1.1 pooka
1116 1.1 pooka /*ARGSUSED*/
1117 1.1 pooka int
1118 1.3 pooka p2k_node_rename(struct puffs_usermount *pu,
1119 1.3 pooka puffs_cookie_t src_dir, puffs_cookie_t src,
1120 1.3 pooka const struct puffs_cn *pcn_src,
1121 1.3 pooka puffs_cookie_t targ_dir, puffs_cookie_t targ,
1122 1.1 pooka const struct puffs_cn *pcn_targ)
1123 1.1 pooka {
1124 1.17 pooka struct p2k_node *p2n_srcdir = src_dir, *p2n_targdir = targ_dir;
1125 1.17 pooka struct vnode *dvp, *vp, *tdvp, *tvp = NULL;
1126 1.1 pooka struct componentname *cn_src, *cn_targ;
1127 1.1 pooka int rv;
1128 1.1 pooka
1129 1.17 pooka if (p2n_srcdir->p2n_cn_ren_src) {
1130 1.17 pooka cn_src = p2n_srcdir->p2n_cn_ren_src;
1131 1.17 pooka p2n_srcdir->p2n_cn_ren_src = NULL;
1132 1.17 pooka } else {
1133 1.17 pooka cn_src = makecn(pcn_src, RUMP_NAMEI_HASBUF);
1134 1.17 pooka }
1135 1.17 pooka
1136 1.17 pooka if (p2n_targdir->p2n_cn_ren_targ) {
1137 1.17 pooka cn_targ = p2n_targdir->p2n_cn_ren_targ;
1138 1.17 pooka p2n_targdir->p2n_cn_ren_targ = NULL;
1139 1.17 pooka } else {
1140 1.17 pooka cn_targ = makecn(pcn_targ, RUMP_NAMEI_HASBUF);
1141 1.17 pooka }
1142 1.17 pooka
1143 1.17 pooka dvp = OPC2VP(src_dir);
1144 1.17 pooka vp = OPC2VP(src);
1145 1.17 pooka tdvp = OPC2VP(targ_dir);
1146 1.1 pooka if (targ) {
1147 1.17 pooka tvp = OPC2VP(targ);
1148 1.1 pooka }
1149 1.17 pooka
1150 1.23 pooka rump_pub_vp_incref(dvp);
1151 1.23 pooka rump_pub_vp_incref(vp);
1152 1.17 pooka RUMP_VOP_LOCK(tdvp, LK_EXCLUSIVE);
1153 1.23 pooka rump_pub_vp_incref(tdvp);
1154 1.17 pooka if (tvp) {
1155 1.17 pooka RUMP_VOP_LOCK(tvp, LK_EXCLUSIVE);
1156 1.23 pooka rump_pub_vp_incref(tvp);
1157 1.17 pooka }
1158 1.17 pooka rv = RUMP_VOP_RENAME(dvp, vp, cn_src, tdvp, tvp, cn_targ);
1159 1.17 pooka assert(RUMP_VOP_ISLOCKED(tdvp) == 0);
1160 1.17 pooka if (tvp) {
1161 1.17 pooka assert(RUMP_VOP_ISLOCKED(tvp) == 0);
1162 1.17 pooka }
1163 1.17 pooka freecn(cn_src, RUMPCN_FORCEFREE);
1164 1.17 pooka freecn(cn_targ, RUMPCN_FORCEFREE);
1165 1.1 pooka
1166 1.1 pooka return rv;
1167 1.1 pooka }
1168 1.1 pooka
1169 1.1 pooka /*ARGSUSED*/
1170 1.1 pooka int
1171 1.3 pooka p2k_node_mkdir(struct puffs_usermount *pu, puffs_cookie_t opc,
1172 1.3 pooka struct puffs_newinfo *pni, const struct puffs_cn *pcn,
1173 1.3 pooka const struct vattr *vap)
1174 1.1 pooka {
1175 1.1 pooka
1176 1.17 pooka return do_makenode(pu, opc, pni, pcn, vap, NULL, RUMP_VOP_MKDIR, NULL);
1177 1.1 pooka }
1178 1.1 pooka
1179 1.1 pooka /*ARGSUSED*/
1180 1.1 pooka int
1181 1.3 pooka p2k_node_rmdir(struct puffs_usermount *pu, puffs_cookie_t opc,
1182 1.3 pooka puffs_cookie_t targ, const struct puffs_cn *pcn)
1183 1.1 pooka {
1184 1.1 pooka
1185 1.17 pooka return do_nukenode(opc, targ, pcn, RUMP_VOP_RMDIR);
1186 1.1 pooka }
1187 1.1 pooka
1188 1.1 pooka /*ARGSUSED*/
1189 1.1 pooka int
1190 1.3 pooka p2k_node_symlink(struct puffs_usermount *pu, puffs_cookie_t opc,
1191 1.17 pooka struct puffs_newinfo *pni, const struct puffs_cn *pcn,
1192 1.1 pooka const struct vattr *vap, const char *link_target)
1193 1.1 pooka {
1194 1.1 pooka
1195 1.17 pooka return do_makenode(pu, opc, pni, pcn, vap,
1196 1.17 pooka __UNCONST(link_target), NULL, RUMP_VOP_SYMLINK);
1197 1.1 pooka }
1198 1.1 pooka
1199 1.1 pooka /*ARGSUSED*/
1200 1.1 pooka int
1201 1.3 pooka p2k_node_readdir(struct puffs_usermount *pu, puffs_cookie_t opc,
1202 1.3 pooka struct dirent *dent, off_t *readoff, size_t *reslen,
1203 1.3 pooka const struct puffs_cred *pcr, int *eofflag,
1204 1.3 pooka off_t *cookies, size_t *ncookies)
1205 1.1 pooka {
1206 1.17 pooka struct vnode *vp = OPC2VP(opc);
1207 1.34 pooka struct kauth_cred *cred;
1208 1.1 pooka struct uio *uio;
1209 1.1 pooka off_t *vop_cookies;
1210 1.1 pooka int vop_ncookies;
1211 1.1 pooka int rv;
1212 1.1 pooka
1213 1.1 pooka cred = cred_create(pcr);
1214 1.23 pooka uio = rump_pub_uio_setup(dent, *reslen, *readoff, RUMPUIO_READ);
1215 1.17 pooka RUMP_VOP_LOCK(vp, LK_SHARED);
1216 1.1 pooka if (cookies) {
1217 1.17 pooka rv = RUMP_VOP_READDIR(vp, uio, cred, eofflag,
1218 1.1 pooka &vop_cookies, &vop_ncookies);
1219 1.1 pooka memcpy(cookies, vop_cookies, vop_ncookies * sizeof(*cookies));
1220 1.1 pooka *ncookies = vop_ncookies;
1221 1.1 pooka free(vop_cookies);
1222 1.1 pooka } else {
1223 1.17 pooka rv = RUMP_VOP_READDIR(vp, uio, cred, eofflag, NULL, NULL);
1224 1.1 pooka }
1225 1.17 pooka RUMP_VOP_UNLOCK(vp, 0);
1226 1.1 pooka if (rv == 0) {
1227 1.23 pooka *reslen = rump_pub_uio_getresid(uio);
1228 1.23 pooka *readoff = rump_pub_uio_getoff(uio);
1229 1.1 pooka }
1230 1.23 pooka rump_pub_uio_free(uio);
1231 1.1 pooka cred_destroy(cred);
1232 1.1 pooka
1233 1.1 pooka return rv;
1234 1.1 pooka }
1235 1.1 pooka
1236 1.1 pooka /*ARGSUSED*/
1237 1.1 pooka int
1238 1.3 pooka p2k_node_readlink(struct puffs_usermount *pu, puffs_cookie_t opc,
1239 1.1 pooka const struct puffs_cred *pcr, char *linkname, size_t *linklen)
1240 1.1 pooka {
1241 1.17 pooka struct vnode *vp = OPC2VP(opc);
1242 1.34 pooka struct kauth_cred *cred;
1243 1.1 pooka struct uio *uio;
1244 1.1 pooka int rv;
1245 1.1 pooka
1246 1.1 pooka cred = cred_create(pcr);
1247 1.23 pooka uio = rump_pub_uio_setup(linkname, *linklen, 0, RUMPUIO_READ);
1248 1.17 pooka RUMP_VOP_LOCK(vp, LK_EXCLUSIVE);
1249 1.17 pooka rv = RUMP_VOP_READLINK(vp, uio, cred);
1250 1.17 pooka RUMP_VOP_UNLOCK(vp, 0);
1251 1.23 pooka *linklen -= rump_pub_uio_free(uio);
1252 1.1 pooka cred_destroy(cred);
1253 1.1 pooka
1254 1.1 pooka return rv;
1255 1.1 pooka }
1256 1.1 pooka
1257 1.1 pooka /*ARGSUSED*/
1258 1.1 pooka int
1259 1.3 pooka p2k_node_read(struct puffs_usermount *pu, puffs_cookie_t opc,
1260 1.1 pooka uint8_t *buf, off_t offset, size_t *resid,
1261 1.1 pooka const struct puffs_cred *pcr, int ioflag)
1262 1.1 pooka {
1263 1.17 pooka struct vnode *vp = OPC2VP(opc);
1264 1.34 pooka struct kauth_cred *cred;
1265 1.1 pooka struct uio *uio;
1266 1.1 pooka int rv;
1267 1.1 pooka
1268 1.1 pooka cred = cred_create(pcr);
1269 1.23 pooka uio = rump_pub_uio_setup(buf, *resid, offset, RUMPUIO_READ);
1270 1.17 pooka RUMP_VOP_LOCK(vp, LK_SHARED);
1271 1.17 pooka rv = RUMP_VOP_READ(vp, uio, ioflag, cred);
1272 1.17 pooka RUMP_VOP_UNLOCK(vp, 0);
1273 1.23 pooka *resid = rump_pub_uio_free(uio);
1274 1.1 pooka cred_destroy(cred);
1275 1.1 pooka
1276 1.1 pooka return rv;
1277 1.1 pooka }
1278 1.1 pooka
1279 1.1 pooka /*ARGSUSED*/
1280 1.1 pooka int
1281 1.3 pooka p2k_node_write(struct puffs_usermount *pu, puffs_cookie_t opc,
1282 1.1 pooka uint8_t *buf, off_t offset, size_t *resid,
1283 1.1 pooka const struct puffs_cred *pcr, int ioflag)
1284 1.1 pooka {
1285 1.17 pooka struct vnode *vp = OPC2VP(opc);
1286 1.34 pooka struct kauth_cred *cred;
1287 1.1 pooka struct uio *uio;
1288 1.1 pooka int rv;
1289 1.1 pooka
1290 1.17 pooka /* "deadfs" */
1291 1.17 pooka if (!vp)
1292 1.17 pooka return 0;
1293 1.17 pooka
1294 1.1 pooka cred = cred_create(pcr);
1295 1.23 pooka uio = rump_pub_uio_setup(buf, *resid, offset, RUMPUIO_WRITE);
1296 1.17 pooka RUMP_VOP_LOCK(vp, LK_EXCLUSIVE);
1297 1.17 pooka rv = RUMP_VOP_WRITE(vp, uio, ioflag, cred);
1298 1.17 pooka RUMP_VOP_UNLOCK(vp, 0);
1299 1.23 pooka *resid = rump_pub_uio_free(uio);
1300 1.1 pooka cred_destroy(cred);
1301 1.1 pooka
1302 1.1 pooka return rv;
1303 1.1 pooka }
1304 1.1 pooka
1305 1.38 pooka /*ARGSUSED*/
1306 1.38 pooka int
1307 1.38 pooka p2k_node_getextattr(struct puffs_usermount *pu, puffs_cookie_t opc,
1308 1.38 pooka int attrnamespace, const char *attrname, size_t *attrsize,
1309 1.38 pooka uint8_t *attr, size_t *resid, const struct puffs_cred *pcr)
1310 1.38 pooka {
1311 1.38 pooka struct vnode *vp = OPC2VP(opc);
1312 1.38 pooka struct kauth_cred *cred;
1313 1.38 pooka struct uio *uio;
1314 1.38 pooka int rv;
1315 1.38 pooka
1316 1.38 pooka if (attr)
1317 1.38 pooka uio = rump_pub_uio_setup(attr, *resid, 0, RUMPUIO_READ);
1318 1.38 pooka else
1319 1.38 pooka uio = NULL;
1320 1.38 pooka
1321 1.38 pooka cred = cred_create(pcr);
1322 1.38 pooka RUMP_VOP_LOCK(vp, LK_EXCLUSIVE);
1323 1.38 pooka rv = RUMP_VOP_GETEXTATTR(vp, attrnamespace, attrname, uio,
1324 1.38 pooka attrsize, cred);
1325 1.38 pooka RUMP_VOP_UNLOCK(vp, 0);
1326 1.38 pooka cred_destroy(cred);
1327 1.38 pooka
1328 1.38 pooka if (uio)
1329 1.38 pooka *resid = rump_pub_uio_free(uio);
1330 1.38 pooka
1331 1.38 pooka return rv;
1332 1.38 pooka }
1333 1.38 pooka
1334 1.38 pooka /*ARGSUSED*/
1335 1.38 pooka int
1336 1.38 pooka p2k_node_setextattr(struct puffs_usermount *pu, puffs_cookie_t opc,
1337 1.38 pooka int attrnamespace, const char *attrname,
1338 1.38 pooka uint8_t *attr, size_t *resid, const struct puffs_cred *pcr)
1339 1.38 pooka {
1340 1.38 pooka struct vnode *vp = OPC2VP(opc);
1341 1.38 pooka struct kauth_cred *cred;
1342 1.38 pooka struct uio *uio;
1343 1.38 pooka int rv;
1344 1.38 pooka
1345 1.38 pooka if (attr)
1346 1.38 pooka uio = rump_pub_uio_setup(attr, *resid, 0, RUMPUIO_READ);
1347 1.38 pooka else
1348 1.38 pooka uio = NULL;
1349 1.38 pooka
1350 1.38 pooka cred = cred_create(pcr);
1351 1.38 pooka RUMP_VOP_LOCK(vp, LK_EXCLUSIVE);
1352 1.38 pooka rv = RUMP_VOP_SETEXTATTR(vp, attrnamespace, attrname, uio, cred);
1353 1.38 pooka RUMP_VOP_UNLOCK(vp, 0);
1354 1.38 pooka cred_destroy(cred);
1355 1.38 pooka
1356 1.38 pooka if (uio)
1357 1.38 pooka *resid = rump_pub_uio_free(uio);
1358 1.38 pooka
1359 1.38 pooka return rv;
1360 1.38 pooka }
1361 1.38 pooka
1362 1.38 pooka /*ARGSUSED*/
1363 1.38 pooka int
1364 1.38 pooka p2k_node_listextattr(struct puffs_usermount *pu, puffs_cookie_t opc,
1365 1.38 pooka int attrnamespace, size_t *attrsize,
1366 1.38 pooka uint8_t *attrs, size_t *resid, const struct puffs_cred *pcr)
1367 1.38 pooka {
1368 1.38 pooka struct vnode *vp = OPC2VP(opc);
1369 1.38 pooka struct kauth_cred *cred;
1370 1.38 pooka struct uio *uio;
1371 1.38 pooka int rv;
1372 1.38 pooka
1373 1.38 pooka if (attrs)
1374 1.38 pooka uio = rump_pub_uio_setup(attrs, *resid, 0, RUMPUIO_READ);
1375 1.38 pooka else
1376 1.38 pooka uio = NULL;
1377 1.38 pooka
1378 1.38 pooka cred = cred_create(pcr);
1379 1.38 pooka RUMP_VOP_LOCK(vp, LK_EXCLUSIVE);
1380 1.38 pooka rv = RUMP_VOP_LISTEXTATTR(vp, attrnamespace, uio, attrsize, cred);
1381 1.38 pooka RUMP_VOP_UNLOCK(vp, 0);
1382 1.38 pooka cred_destroy(cred);
1383 1.38 pooka
1384 1.38 pooka if (uio)
1385 1.38 pooka *resid = rump_pub_uio_free(uio);
1386 1.38 pooka
1387 1.38 pooka return rv;
1388 1.38 pooka }
1389 1.38 pooka
1390 1.38 pooka /*ARGSUSED*/
1391 1.38 pooka int
1392 1.38 pooka p2k_node_deleteextattr(struct puffs_usermount *pu, puffs_cookie_t opc,
1393 1.38 pooka int attrnamespace, const char *attrname, const struct puffs_cred *pcr)
1394 1.38 pooka {
1395 1.38 pooka struct vnode *vp = OPC2VP(opc);
1396 1.38 pooka struct kauth_cred *cred;
1397 1.38 pooka int rv;
1398 1.38 pooka
1399 1.38 pooka cred = cred_create(pcr);
1400 1.38 pooka RUMP_VOP_LOCK(vp, LK_EXCLUSIVE);
1401 1.38 pooka rv = RUMP_VOP_DELETEEXTATTR(vp, attrnamespace, attrname, cred);
1402 1.38 pooka RUMP_VOP_UNLOCK(vp, 0);
1403 1.38 pooka cred_destroy(cred);
1404 1.38 pooka
1405 1.38 pooka return rv;
1406 1.38 pooka }
1407 1.38 pooka
1408 1.17 pooka /* the kernel releases its last reference here */
1409 1.1 pooka int
1410 1.3 pooka p2k_node_inactive(struct puffs_usermount *pu, puffs_cookie_t opc)
1411 1.1 pooka {
1412 1.35 pooka struct p2k_mount *p2m = puffs_getspecific(pu);
1413 1.17 pooka struct p2k_node *p2n = opc;
1414 1.17 pooka struct vnode *vp = OPC2VP(opc);
1415 1.27 pooka bool recycle = false;
1416 1.1 pooka int rv;
1417 1.1 pooka
1418 1.17 pooka /* deadfs */
1419 1.17 pooka if (!vp)
1420 1.17 pooka return 0;
1421 1.17 pooka
1422 1.17 pooka /*
1423 1.17 pooka * Flush all cached vnode pages from the rump kernel -- they
1424 1.31 pooka * are kept in puffs for all things that matter. However,
1425 1.31 pooka * don't do this for tmpfs (vnodes are backed by an aobj), since that
1426 1.31 pooka * would cause us to clear the backing storage leaving us without
1427 1.31 pooka * a way to regain the data from "stable storage".
1428 1.17 pooka */
1429 1.31 pooka if (!p2m->p2m_imtmpfsman) {
1430 1.31 pooka rump_pub_vp_interlock(vp);
1431 1.31 pooka RUMP_VOP_PUTPAGES(vp, 0, 0,
1432 1.31 pooka PGO_ALLPAGES|PGO_CLEANIT|PGO_FREE);
1433 1.31 pooka }
1434 1.17 pooka
1435 1.17 pooka /*
1436 1.17 pooka * Ok, this is where we get nasty. We pretend the vnode is
1437 1.17 pooka * inactive and already tell the file system that. However,
1438 1.17 pooka * we are allowed to pretend it also grows a reference immediately
1439 1.17 pooka * after per vget(), so this does not do harm. Cheap trick, but ...
1440 1.17 pooka *
1441 1.17 pooka * If the file system thinks the inode is done for, we release
1442 1.17 pooka * our reference and clear all knowledge of the vnode. If,
1443 1.17 pooka * however, the inode is still active, we retain our reference
1444 1.17 pooka * until reclaim, since puffs might be flushing out some data
1445 1.17 pooka * later.
1446 1.17 pooka */
1447 1.17 pooka RUMP_VOP_LOCK(vp, LK_EXCLUSIVE);
1448 1.1 pooka rv = RUMP_VOP_INACTIVE(vp, &recycle);
1449 1.17 pooka if (recycle) {
1450 1.1 pooka puffs_setback(puffs_cc_getcc(pu), PUFFS_SETBACK_NOREF_N1);
1451 1.23 pooka rump_pub_vp_rele(p2n->p2n_vp);
1452 1.17 pooka p2n->p2n_vp = NULL;
1453 1.17 pooka }
1454 1.1 pooka
1455 1.1 pooka return rv;
1456 1.1 pooka }
1457 1.1 pooka
1458 1.1 pooka /*ARGSUSED*/
1459 1.1 pooka int
1460 1.3 pooka p2k_node_reclaim(struct puffs_usermount *pu, puffs_croissant_t opc)
1461 1.1 pooka {
1462 1.17 pooka struct p2k_node *p2n = opc;
1463 1.17 pooka
1464 1.17 pooka if (p2n->p2n_vp) {
1465 1.23 pooka rump_pub_vp_rele(p2n->p2n_vp);
1466 1.17 pooka p2n->p2n_vp = NULL;
1467 1.17 pooka }
1468 1.1 pooka
1469 1.17 pooka freep2n(p2n);
1470 1.1 pooka return 0;
1471 1.1 pooka }
1472