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