vfs_vnops.c revision 1.169.2.4 1 1.169.2.4 uebayasi /* $NetBSD: vfs_vnops.c,v 1.169.2.4 2010/11/06 08:08:44 uebayasi Exp $ */
2 1.164 ad
3 1.164 ad /*-
4 1.164 ad * Copyright (c) 2009 The NetBSD Foundation, Inc.
5 1.164 ad * All rights reserved.
6 1.164 ad *
7 1.164 ad * This code is derived from software contributed to The NetBSD Foundation
8 1.164 ad * by Andrew Doran.
9 1.164 ad *
10 1.164 ad * Redistribution and use in source and binary forms, with or without
11 1.164 ad * modification, are permitted provided that the following conditions
12 1.164 ad * are met:
13 1.164 ad * 1. Redistributions of source code must retain the above copyright
14 1.164 ad * notice, this list of conditions and the following disclaimer.
15 1.164 ad * 2. Redistributions in binary form must reproduce the above copyright
16 1.164 ad * notice, this list of conditions and the following disclaimer in the
17 1.164 ad * documentation and/or other materials provided with the distribution.
18 1.164 ad *
19 1.164 ad * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
20 1.164 ad * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
21 1.164 ad * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
22 1.164 ad * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
23 1.164 ad * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
24 1.164 ad * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
25 1.164 ad * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
26 1.164 ad * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
27 1.164 ad * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
28 1.164 ad * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
29 1.164 ad * POSSIBILITY OF SUCH DAMAGE.
30 1.164 ad */
31 1.12 cgd
32 1.10 cgd /*
33 1.11 mycroft * Copyright (c) 1982, 1986, 1989, 1993
34 1.11 mycroft * The Regents of the University of California. All rights reserved.
35 1.10 cgd * (c) UNIX System Laboratories, Inc.
36 1.10 cgd * All or some portions of this file are derived from material licensed
37 1.10 cgd * to the University of California by American Telephone and Telegraph
38 1.10 cgd * Co. or Unix System Laboratories, Inc. and are reproduced herein with
39 1.10 cgd * the permission of UNIX System Laboratories, Inc.
40 1.10 cgd *
41 1.10 cgd * Redistribution and use in source and binary forms, with or without
42 1.10 cgd * modification, are permitted provided that the following conditions
43 1.10 cgd * are met:
44 1.10 cgd * 1. Redistributions of source code must retain the above copyright
45 1.10 cgd * notice, this list of conditions and the following disclaimer.
46 1.10 cgd * 2. Redistributions in binary form must reproduce the above copyright
47 1.10 cgd * notice, this list of conditions and the following disclaimer in the
48 1.10 cgd * documentation and/or other materials provided with the distribution.
49 1.73 agc * 3. Neither the name of the University nor the names of its contributors
50 1.10 cgd * may be used to endorse or promote products derived from this software
51 1.10 cgd * without specific prior written permission.
52 1.10 cgd *
53 1.10 cgd * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
54 1.10 cgd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
55 1.10 cgd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
56 1.10 cgd * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
57 1.10 cgd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
58 1.10 cgd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
59 1.10 cgd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
60 1.10 cgd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
61 1.10 cgd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
62 1.10 cgd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
63 1.10 cgd * SUCH DAMAGE.
64 1.10 cgd *
65 1.28 fvdl * @(#)vfs_vnops.c 8.14 (Berkeley) 6/15/95
66 1.10 cgd */
67 1.52 lukem
68 1.52 lukem #include <sys/cdefs.h>
69 1.169.2.4 uebayasi __KERNEL_RCSID(0, "$NetBSD: vfs_vnops.c,v 1.169.2.4 2010/11/06 08:08:44 uebayasi Exp $");
70 1.26 mrg
71 1.122 dogcow #include "veriexec.h"
72 1.10 cgd
73 1.10 cgd #include <sys/param.h>
74 1.10 cgd #include <sys/systm.h>
75 1.10 cgd #include <sys/kernel.h>
76 1.10 cgd #include <sys/file.h>
77 1.10 cgd #include <sys/stat.h>
78 1.10 cgd #include <sys/buf.h>
79 1.10 cgd #include <sys/proc.h>
80 1.10 cgd #include <sys/mount.h>
81 1.10 cgd #include <sys/namei.h>
82 1.10 cgd #include <sys/vnode.h>
83 1.10 cgd #include <sys/ioctl.h>
84 1.10 cgd #include <sys/tty.h>
85 1.21 mycroft #include <sys/poll.h>
86 1.111 elad #include <sys/kauth.h>
87 1.128 elad #include <sys/syslog.h>
88 1.141 hannken #include <sys/fstrans.h>
89 1.145 ad #include <sys/atomic.h>
90 1.151 pooka #include <sys/filedesc.h>
91 1.159 simonb #include <sys/wapbl.h>
92 1.11 mycroft
93 1.77 hannken #include <miscfs/specfs/specdev.h>
94 1.169.2.1 uebayasi #include <miscfs/fifofs/fifo.h>
95 1.77 hannken
96 1.25 mrg #include <uvm/uvm_extern.h>
97 1.100 yamt #include <uvm/uvm_readahead.h>
98 1.25 mrg
99 1.28 fvdl #ifdef UNION
100 1.65 jdolecek #include <fs/union/union.h>
101 1.28 fvdl #endif
102 1.64 jdolecek
103 1.101 christos int (*vn_union_readdir_hook) (struct vnode **, struct file *, struct lwp *);
104 1.66 jdolecek
105 1.58 blymn #include <sys/verified_exec.h>
106 1.28 fvdl
107 1.155 ad static int vn_read(file_t *fp, off_t *offset, struct uio *uio,
108 1.111 elad kauth_cred_t cred, int flags);
109 1.155 ad static int vn_write(file_t *fp, off_t *offset, struct uio *uio,
110 1.111 elad kauth_cred_t cred, int flags);
111 1.155 ad static int vn_closefile(file_t *fp);
112 1.155 ad static int vn_poll(file_t *fp, int events);
113 1.155 ad static int vn_fcntl(file_t *fp, u_int com, void *data);
114 1.155 ad static int vn_statfile(file_t *fp, struct stat *sb);
115 1.155 ad static int vn_ioctl(file_t *fp, u_long com, void *data);
116 1.48 jdolecek
117 1.83 christos const struct fileops vnops = {
118 1.164 ad .fo_read = vn_read,
119 1.164 ad .fo_write = vn_write,
120 1.164 ad .fo_ioctl = vn_ioctl,
121 1.164 ad .fo_fcntl = vn_fcntl,
122 1.164 ad .fo_poll = vn_poll,
123 1.164 ad .fo_stat = vn_statfile,
124 1.164 ad .fo_close = vn_closefile,
125 1.164 ad .fo_kqfilter = vn_kqfilter,
126 1.168 dsl .fo_restart = fnullop_restart,
127 1.48 jdolecek };
128 1.10 cgd
129 1.10 cgd /*
130 1.10 cgd * Common code for vnode open operations.
131 1.10 cgd * Check permissions, and call the VOP_OPEN or VOP_CREATE routine.
132 1.10 cgd */
133 1.20 christos int
134 1.89 thorpej vn_open(struct nameidata *ndp, int fmode, int cmode)
135 1.10 cgd {
136 1.94 erh struct vnode *vp;
137 1.148 pooka struct lwp *l = curlwp;
138 1.117 ad kauth_cred_t cred = l->l_cred;
139 1.19 mycroft struct vattr va;
140 1.10 cgd int error;
141 1.139 christos char *path;
142 1.75 hannken
143 1.169.2.3 uebayasi if ((fmode & (O_CREAT | O_DIRECTORY)) == (O_CREAT | O_DIRECTORY))
144 1.169.2.3 uebayasi return EINVAL;
145 1.169.2.3 uebayasi
146 1.163 enami ndp->ni_cnd.cn_flags &= TRYEMULROOT | NOCHROOT;
147 1.138 dsl
148 1.10 cgd if (fmode & O_CREAT) {
149 1.11 mycroft ndp->ni_cnd.cn_nameiop = CREATE;
150 1.138 dsl ndp->ni_cnd.cn_flags |= LOCKPARENT | LOCKLEAF;
151 1.38 bouyer if ((fmode & O_EXCL) == 0 &&
152 1.59 christos ((fmode & O_NOFOLLOW) == 0))
153 1.11 mycroft ndp->ni_cnd.cn_flags |= FOLLOW;
154 1.130 elad } else {
155 1.130 elad ndp->ni_cnd.cn_nameiop = LOOKUP;
156 1.138 dsl ndp->ni_cnd.cn_flags |= LOCKLEAF;
157 1.130 elad if ((fmode & O_NOFOLLOW) == 0)
158 1.130 elad ndp->ni_cnd.cn_flags |= FOLLOW;
159 1.130 elad }
160 1.139 christos
161 1.139 christos VERIEXEC_PATH_GET(ndp->ni_dirp, ndp->ni_segflg, ndp->ni_dirp, path);
162 1.139 christos
163 1.130 elad error = namei(ndp);
164 1.130 elad if (error)
165 1.139 christos goto out;
166 1.91 elad
167 1.130 elad vp = ndp->ni_vp;
168 1.91 elad
169 1.130 elad #if NVERIEXEC > 0
170 1.130 elad error = veriexec_openchk(l, ndp->ni_vp, ndp->ni_dirp, fmode);
171 1.130 elad if (error)
172 1.130 elad goto bad;
173 1.115 elad #endif /* NVERIEXEC > 0 */
174 1.91 elad
175 1.130 elad if (fmode & O_CREAT) {
176 1.130 elad if (ndp->ni_vp == NULL) {
177 1.169 pooka vattr_null(&va);
178 1.19 mycroft va.va_type = VREG;
179 1.19 mycroft va.va_mode = cmode;
180 1.28 fvdl if (fmode & O_EXCL)
181 1.28 fvdl va.va_vaflags |= VA_EXCLUSIVE;
182 1.20 christos error = VOP_CREATE(ndp->ni_dvp, &ndp->ni_vp,
183 1.20 christos &ndp->ni_cnd, &va);
184 1.20 christos if (error)
185 1.139 christos goto out;
186 1.10 cgd fmode &= ~O_TRUNC;
187 1.10 cgd vp = ndp->ni_vp;
188 1.10 cgd } else {
189 1.11 mycroft VOP_ABORTOP(ndp->ni_dvp, &ndp->ni_cnd);
190 1.10 cgd if (ndp->ni_dvp == ndp->ni_vp)
191 1.10 cgd vrele(ndp->ni_dvp);
192 1.10 cgd else
193 1.10 cgd vput(ndp->ni_dvp);
194 1.10 cgd ndp->ni_dvp = NULL;
195 1.10 cgd vp = ndp->ni_vp;
196 1.10 cgd if (fmode & O_EXCL) {
197 1.10 cgd error = EEXIST;
198 1.38 bouyer goto bad;
199 1.38 bouyer }
200 1.10 cgd fmode &= ~O_CREAT;
201 1.10 cgd }
202 1.10 cgd } else {
203 1.10 cgd vp = ndp->ni_vp;
204 1.10 cgd }
205 1.10 cgd if (vp->v_type == VSOCK) {
206 1.10 cgd error = EOPNOTSUPP;
207 1.74 cb goto bad;
208 1.74 cb }
209 1.74 cb if (ndp->ni_vp->v_type == VLNK) {
210 1.74 cb error = EFTYPE;
211 1.10 cgd goto bad;
212 1.10 cgd }
213 1.58 blymn
214 1.10 cgd if ((fmode & O_CREAT) == 0) {
215 1.146 yamt error = vn_openchk(vp, cred, fmode);
216 1.146 yamt if (error != 0)
217 1.146 yamt goto bad;
218 1.10 cgd }
219 1.87 blymn
220 1.10 cgd if (fmode & O_TRUNC) {
221 1.169 pooka vattr_null(&va);
222 1.19 mycroft va.va_size = 0;
223 1.144 pooka error = VOP_SETATTR(vp, &va, cred);
224 1.75 hannken if (error != 0)
225 1.10 cgd goto bad;
226 1.10 cgd }
227 1.144 pooka if ((error = VOP_OPEN(vp, fmode, cred)) != 0)
228 1.10 cgd goto bad;
229 1.143 ad if (fmode & FWRITE) {
230 1.149 ad mutex_enter(&vp->v_interlock);
231 1.10 cgd vp->v_writecount++;
232 1.149 ad mutex_exit(&vp->v_interlock);
233 1.143 ad }
234 1.45 chs
235 1.10 cgd bad:
236 1.127 elad if (error)
237 1.127 elad vput(vp);
238 1.139 christos out:
239 1.139 christos VERIEXEC_PATH_PUT(path);
240 1.10 cgd return (error);
241 1.10 cgd }
242 1.10 cgd
243 1.10 cgd /*
244 1.10 cgd * Check for write permissions on the specified vnode.
245 1.28 fvdl * Prototype text segments cannot be written.
246 1.10 cgd */
247 1.20 christos int
248 1.89 thorpej vn_writechk(struct vnode *vp)
249 1.10 cgd {
250 1.10 cgd
251 1.10 cgd /*
252 1.45 chs * If the vnode is in use as a process's text,
253 1.45 chs * we can't allow writing.
254 1.10 cgd */
255 1.143 ad if (vp->v_iflag & VI_TEXT)
256 1.25 mrg return (ETXTBSY);
257 1.10 cgd return (0);
258 1.42 chs }
259 1.42 chs
260 1.146 yamt int
261 1.146 yamt vn_openchk(struct vnode *vp, kauth_cred_t cred, int fflags)
262 1.146 yamt {
263 1.146 yamt int permbits = 0;
264 1.146 yamt int error;
265 1.146 yamt
266 1.169.2.3 uebayasi if ((fflags & O_DIRECTORY) != 0 && vp->v_type != VDIR)
267 1.169.2.3 uebayasi return ENOTDIR;
268 1.169.2.3 uebayasi
269 1.146 yamt if ((fflags & FREAD) != 0) {
270 1.146 yamt permbits = VREAD;
271 1.146 yamt }
272 1.146 yamt if ((fflags & (FWRITE | O_TRUNC)) != 0) {
273 1.146 yamt permbits |= VWRITE;
274 1.146 yamt if (vp->v_type == VDIR) {
275 1.146 yamt error = EISDIR;
276 1.146 yamt goto bad;
277 1.146 yamt }
278 1.146 yamt error = vn_writechk(vp);
279 1.146 yamt if (error != 0)
280 1.146 yamt goto bad;
281 1.146 yamt }
282 1.146 yamt error = VOP_ACCESS(vp, permbits, cred);
283 1.146 yamt bad:
284 1.146 yamt return error;
285 1.146 yamt }
286 1.146 yamt
287 1.42 chs /*
288 1.51 thorpej * Mark a vnode as having executable mappings.
289 1.42 chs */
290 1.42 chs void
291 1.89 thorpej vn_markexec(struct vnode *vp)
292 1.42 chs {
293 1.143 ad
294 1.158 ad if ((vp->v_iflag & VI_EXECMAP) != 0) {
295 1.158 ad /* Safe unlocked, as long as caller holds a reference. */
296 1.158 ad return;
297 1.158 ad }
298 1.143 ad
299 1.158 ad mutex_enter(&vp->v_interlock);
300 1.143 ad if ((vp->v_iflag & VI_EXECMAP) == 0) {
301 1.145 ad atomic_add_int(&uvmexp.filepages, -vp->v_uobj.uo_npages);
302 1.145 ad atomic_add_int(&uvmexp.execpages, vp->v_uobj.uo_npages);
303 1.158 ad vp->v_iflag |= VI_EXECMAP;
304 1.46 chs }
305 1.158 ad mutex_exit(&vp->v_interlock);
306 1.55 chs }
307 1.55 chs
308 1.55 chs /*
309 1.55 chs * Mark a vnode as being the text of a process.
310 1.55 chs * Fail if the vnode is currently writable.
311 1.55 chs */
312 1.55 chs int
313 1.89 thorpej vn_marktext(struct vnode *vp)
314 1.55 chs {
315 1.55 chs
316 1.157 ad if ((vp->v_iflag & (VI_TEXT|VI_EXECMAP)) == (VI_TEXT|VI_EXECMAP)) {
317 1.157 ad /* Safe unlocked, as long as caller holds a reference. */
318 1.158 ad return (0);
319 1.157 ad }
320 1.157 ad
321 1.149 ad mutex_enter(&vp->v_interlock);
322 1.55 chs if (vp->v_writecount != 0) {
323 1.143 ad KASSERT((vp->v_iflag & VI_TEXT) == 0);
324 1.149 ad mutex_exit(&vp->v_interlock);
325 1.55 chs return (ETXTBSY);
326 1.55 chs }
327 1.158 ad if ((vp->v_iflag & VI_EXECMAP) == 0) {
328 1.158 ad atomic_add_int(&uvmexp.filepages, -vp->v_uobj.uo_npages);
329 1.158 ad atomic_add_int(&uvmexp.execpages, vp->v_uobj.uo_npages);
330 1.158 ad }
331 1.158 ad vp->v_iflag |= (VI_TEXT | VI_EXECMAP);
332 1.149 ad mutex_exit(&vp->v_interlock);
333 1.55 chs return (0);
334 1.10 cgd }
335 1.10 cgd
336 1.10 cgd /*
337 1.10 cgd * Vnode close call
338 1.32 wrstuden *
339 1.32 wrstuden * Note: takes an unlocked vnode, while VOP_CLOSE takes a locked node.
340 1.10 cgd */
341 1.20 christos int
342 1.155 ad vn_close(struct vnode *vp, int flags, kauth_cred_t cred)
343 1.10 cgd {
344 1.10 cgd int error;
345 1.10 cgd
346 1.158 ad if (flags & FWRITE) {
347 1.158 ad mutex_enter(&vp->v_interlock);
348 1.10 cgd vp->v_writecount--;
349 1.158 ad mutex_exit(&vp->v_interlock);
350 1.158 ad }
351 1.158 ad vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
352 1.144 pooka error = VOP_CLOSE(vp, flags, cred);
353 1.32 wrstuden vput(vp);
354 1.10 cgd return (error);
355 1.10 cgd }
356 1.10 cgd
357 1.169.2.1 uebayasi static int
358 1.169.2.1 uebayasi enforce_rlimit_fsize(struct vnode *vp, struct uio *uio, int ioflag)
359 1.169.2.1 uebayasi {
360 1.169.2.1 uebayasi struct lwp *l = curlwp;
361 1.169.2.1 uebayasi off_t testoff;
362 1.169.2.1 uebayasi
363 1.169.2.1 uebayasi if (uio->uio_rw != UIO_WRITE || vp->v_type != VREG)
364 1.169.2.1 uebayasi return 0;
365 1.169.2.1 uebayasi
366 1.169.2.1 uebayasi KASSERT(VOP_ISLOCKED(vp) == LK_EXCLUSIVE);
367 1.169.2.1 uebayasi if (ioflag & IO_APPEND)
368 1.169.2.1 uebayasi testoff = vp->v_size;
369 1.169.2.1 uebayasi else
370 1.169.2.1 uebayasi testoff = uio->uio_offset;
371 1.169.2.1 uebayasi
372 1.169.2.1 uebayasi if (testoff + uio->uio_resid >
373 1.169.2.1 uebayasi l->l_proc->p_rlimit[RLIMIT_FSIZE].rlim_cur) {
374 1.169.2.1 uebayasi mutex_enter(proc_lock);
375 1.169.2.1 uebayasi psignal(l->l_proc, SIGXFSZ);
376 1.169.2.1 uebayasi mutex_exit(proc_lock);
377 1.169.2.1 uebayasi return EFBIG;
378 1.169.2.1 uebayasi }
379 1.169.2.1 uebayasi
380 1.169.2.1 uebayasi return 0;
381 1.169.2.1 uebayasi }
382 1.169.2.1 uebayasi
383 1.10 cgd /*
384 1.10 cgd * Package up an I/O request on a vnode into a uio and do it.
385 1.10 cgd */
386 1.20 christos int
387 1.134 christos vn_rdwr(enum uio_rw rw, struct vnode *vp, void *base, int len, off_t offset,
388 1.111 elad enum uio_seg segflg, int ioflg, kauth_cred_t cred, size_t *aresid,
389 1.101 christos struct lwp *l)
390 1.10 cgd {
391 1.10 cgd struct uio auio;
392 1.10 cgd struct iovec aiov;
393 1.10 cgd int error;
394 1.10 cgd
395 1.50 chs if ((ioflg & IO_NODELOCKED) == 0) {
396 1.50 chs if (rw == UIO_READ) {
397 1.50 chs vn_lock(vp, LK_SHARED | LK_RETRY);
398 1.75 hannken } else /* UIO_WRITE */ {
399 1.50 chs vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
400 1.50 chs }
401 1.50 chs }
402 1.10 cgd auio.uio_iov = &aiov;
403 1.10 cgd auio.uio_iovcnt = 1;
404 1.10 cgd aiov.iov_base = base;
405 1.10 cgd aiov.iov_len = len;
406 1.10 cgd auio.uio_resid = len;
407 1.10 cgd auio.uio_offset = offset;
408 1.10 cgd auio.uio_rw = rw;
409 1.106 yamt if (segflg == UIO_SYSSPACE) {
410 1.106 yamt UIO_SETUP_SYSSPACE(&auio);
411 1.106 yamt } else {
412 1.106 yamt auio.uio_vmspace = l->l_proc->p_vmspace;
413 1.106 yamt }
414 1.169.2.1 uebayasi
415 1.169.2.1 uebayasi if ((error = enforce_rlimit_fsize(vp, &auio, ioflg)) != 0)
416 1.169.2.1 uebayasi goto out;
417 1.169.2.1 uebayasi
418 1.11 mycroft if (rw == UIO_READ) {
419 1.10 cgd error = VOP_READ(vp, &auio, ioflg, cred);
420 1.11 mycroft } else {
421 1.10 cgd error = VOP_WRITE(vp, &auio, ioflg, cred);
422 1.11 mycroft }
423 1.169.2.1 uebayasi
424 1.10 cgd if (aresid)
425 1.10 cgd *aresid = auio.uio_resid;
426 1.10 cgd else
427 1.10 cgd if (auio.uio_resid && error == 0)
428 1.10 cgd error = EIO;
429 1.169.2.1 uebayasi
430 1.169.2.1 uebayasi out:
431 1.75 hannken if ((ioflg & IO_NODELOCKED) == 0) {
432 1.169.2.2 uebayasi VOP_UNLOCK(vp);
433 1.75 hannken }
434 1.10 cgd return (error);
435 1.23 fvdl }
436 1.23 fvdl
437 1.23 fvdl int
438 1.155 ad vn_readdir(file_t *fp, char *bf, int segflg, u_int count, int *done,
439 1.101 christos struct lwp *l, off_t **cookies, int *ncookies)
440 1.23 fvdl {
441 1.23 fvdl struct vnode *vp = (struct vnode *)fp->f_data;
442 1.23 fvdl struct iovec aiov;
443 1.23 fvdl struct uio auio;
444 1.23 fvdl int error, eofflag;
445 1.23 fvdl
446 1.112 simonb /* Limit the size on any kernel buffers used by VOP_READDIR */
447 1.112 simonb count = min(MAXBSIZE, count);
448 1.112 simonb
449 1.23 fvdl unionread:
450 1.23 fvdl if (vp->v_type != VDIR)
451 1.23 fvdl return (EINVAL);
452 1.88 christos aiov.iov_base = bf;
453 1.23 fvdl aiov.iov_len = count;
454 1.23 fvdl auio.uio_iov = &aiov;
455 1.23 fvdl auio.uio_iovcnt = 1;
456 1.23 fvdl auio.uio_rw = UIO_READ;
457 1.106 yamt if (segflg == UIO_SYSSPACE) {
458 1.106 yamt UIO_SETUP_SYSSPACE(&auio);
459 1.106 yamt } else {
460 1.106 yamt KASSERT(l == curlwp);
461 1.106 yamt auio.uio_vmspace = l->l_proc->p_vmspace;
462 1.106 yamt }
463 1.23 fvdl auio.uio_resid = count;
464 1.50 chs vn_lock(vp, LK_SHARED | LK_RETRY);
465 1.23 fvdl auio.uio_offset = fp->f_offset;
466 1.28 fvdl error = VOP_READDIR(vp, &auio, fp->f_cred, &eofflag, cookies,
467 1.23 fvdl ncookies);
468 1.166 yamt mutex_enter(&fp->f_lock);
469 1.23 fvdl fp->f_offset = auio.uio_offset;
470 1.166 yamt mutex_exit(&fp->f_lock);
471 1.169.2.2 uebayasi VOP_UNLOCK(vp);
472 1.23 fvdl if (error)
473 1.23 fvdl return (error);
474 1.23 fvdl
475 1.66 jdolecek if (count == auio.uio_resid && vn_union_readdir_hook) {
476 1.66 jdolecek struct vnode *ovp = vp;
477 1.23 fvdl
478 1.101 christos error = (*vn_union_readdir_hook)(&vp, fp, l);
479 1.66 jdolecek if (error)
480 1.66 jdolecek return (error);
481 1.66 jdolecek if (vp != ovp)
482 1.23 fvdl goto unionread;
483 1.23 fvdl }
484 1.23 fvdl
485 1.143 ad if (count == auio.uio_resid && (vp->v_vflag & VV_ROOT) &&
486 1.23 fvdl (vp->v_mount->mnt_flag & MNT_UNION)) {
487 1.23 fvdl struct vnode *tvp = vp;
488 1.23 fvdl vp = vp->v_mount->mnt_vnodecovered;
489 1.169 pooka vref(vp);
490 1.166 yamt mutex_enter(&fp->f_lock);
491 1.68 dsl fp->f_data = vp;
492 1.23 fvdl fp->f_offset = 0;
493 1.166 yamt mutex_exit(&fp->f_lock);
494 1.23 fvdl vrele(tvp);
495 1.23 fvdl goto unionread;
496 1.23 fvdl }
497 1.23 fvdl *done = count - auio.uio_resid;
498 1.23 fvdl return error;
499 1.10 cgd }
500 1.10 cgd
501 1.10 cgd /*
502 1.10 cgd * File table vnode read routine.
503 1.10 cgd */
504 1.56 gmcgarry static int
505 1.155 ad vn_read(file_t *fp, off_t *offset, struct uio *uio, kauth_cred_t cred,
506 1.89 thorpej int flags)
507 1.10 cgd {
508 1.28 fvdl struct vnode *vp = (struct vnode *)fp->f_data;
509 1.155 ad int count, error, ioflag, fflag;
510 1.10 cgd
511 1.100 yamt ioflag = IO_ADV_ENCODE(fp->f_advice);
512 1.155 ad fflag = fp->f_flag;
513 1.155 ad if (fflag & FNONBLOCK)
514 1.31 kleink ioflag |= IO_NDELAY;
515 1.155 ad if ((fflag & (FFSYNC | FRSYNC)) == (FFSYNC | FRSYNC))
516 1.31 kleink ioflag |= IO_SYNC;
517 1.155 ad if (fflag & FALTIO)
518 1.37 wrstuden ioflag |= IO_ALTSEMANTICS;
519 1.155 ad if (fflag & FDIRECT)
520 1.125 chs ioflag |= IO_DIRECT;
521 1.50 chs vn_lock(vp, LK_SHARED | LK_RETRY);
522 1.29 thorpej uio->uio_offset = *offset;
523 1.10 cgd count = uio->uio_resid;
524 1.31 kleink error = VOP_READ(vp, uio, ioflag, cred);
525 1.29 thorpej if (flags & FOF_UPDATE_OFFSET)
526 1.29 thorpej *offset += count - uio->uio_resid;
527 1.169.2.2 uebayasi VOP_UNLOCK(vp);
528 1.10 cgd return (error);
529 1.10 cgd }
530 1.10 cgd
531 1.10 cgd /*
532 1.10 cgd * File table vnode write routine.
533 1.10 cgd */
534 1.56 gmcgarry static int
535 1.155 ad vn_write(file_t *fp, off_t *offset, struct uio *uio, kauth_cred_t cred,
536 1.89 thorpej int flags)
537 1.10 cgd {
538 1.28 fvdl struct vnode *vp = (struct vnode *)fp->f_data;
539 1.155 ad int count, error, ioflag, fflag;
540 1.10 cgd
541 1.151 pooka ioflag = IO_ADV_ENCODE(fp->f_advice) | IO_UNIT;
542 1.155 ad fflag = fp->f_flag;
543 1.155 ad if (vp->v_type == VREG && (fflag & O_APPEND))
544 1.10 cgd ioflag |= IO_APPEND;
545 1.155 ad if (fflag & FNONBLOCK)
546 1.10 cgd ioflag |= IO_NDELAY;
547 1.155 ad if (fflag & FFSYNC ||
548 1.24 thorpej (vp->v_mount && (vp->v_mount->mnt_flag & MNT_SYNCHRONOUS)))
549 1.24 thorpej ioflag |= IO_SYNC;
550 1.155 ad else if (fflag & FDSYNC)
551 1.31 kleink ioflag |= IO_DSYNC;
552 1.155 ad if (fflag & FALTIO)
553 1.37 wrstuden ioflag |= IO_ALTSEMANTICS;
554 1.155 ad if (fflag & FDIRECT)
555 1.125 chs ioflag |= IO_DIRECT;
556 1.28 fvdl vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
557 1.29 thorpej uio->uio_offset = *offset;
558 1.10 cgd count = uio->uio_resid;
559 1.169.2.1 uebayasi
560 1.169.2.1 uebayasi if ((error = enforce_rlimit_fsize(vp, uio, ioflag)) != 0)
561 1.169.2.1 uebayasi goto out;
562 1.169.2.1 uebayasi
563 1.10 cgd error = VOP_WRITE(vp, uio, ioflag, cred);
564 1.169.2.1 uebayasi
565 1.29 thorpej if (flags & FOF_UPDATE_OFFSET) {
566 1.160 christos if (ioflag & IO_APPEND) {
567 1.160 christos /*
568 1.160 christos * SUSv3 describes behaviour for count = 0 as following:
569 1.160 christos * "Before any action ... is taken, and if nbyte is zero
570 1.160 christos * and the file is a regular file, the write() function
571 1.160 christos * ... in the absence of errors ... shall return zero
572 1.160 christos * and have no other results."
573 1.160 christos */
574 1.160 christos if (count)
575 1.160 christos *offset = uio->uio_offset;
576 1.160 christos } else
577 1.29 thorpej *offset += count - uio->uio_resid;
578 1.29 thorpej }
579 1.169.2.1 uebayasi
580 1.169.2.1 uebayasi out:
581 1.169.2.2 uebayasi VOP_UNLOCK(vp);
582 1.10 cgd return (error);
583 1.10 cgd }
584 1.10 cgd
585 1.10 cgd /*
586 1.10 cgd * File table vnode stat routine.
587 1.10 cgd */
588 1.48 jdolecek static int
589 1.155 ad vn_statfile(file_t *fp, struct stat *sb)
590 1.48 jdolecek {
591 1.165 christos struct vnode *vp = fp->f_data;
592 1.165 christos int error;
593 1.48 jdolecek
594 1.165 christos vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
595 1.165 christos error = vn_stat(vp, sb);
596 1.169.2.2 uebayasi VOP_UNLOCK(vp);
597 1.165 christos return error;
598 1.48 jdolecek }
599 1.48 jdolecek
600 1.20 christos int
601 1.155 ad vn_stat(struct vnode *vp, struct stat *sb)
602 1.10 cgd {
603 1.19 mycroft struct vattr va;
604 1.10 cgd int error;
605 1.35 wrstuden mode_t mode;
606 1.10 cgd
607 1.169.2.2 uebayasi memset(&va, 0, sizeof(va));
608 1.155 ad error = VOP_GETATTR(vp, &va, kauth_cred_get());
609 1.10 cgd if (error)
610 1.10 cgd return (error);
611 1.10 cgd /*
612 1.10 cgd * Copy from vattr table
613 1.10 cgd */
614 1.169.2.4 uebayasi memset(sb, 0, sizeof(*sb));
615 1.19 mycroft sb->st_dev = va.va_fsid;
616 1.19 mycroft sb->st_ino = va.va_fileid;
617 1.19 mycroft mode = va.va_mode;
618 1.10 cgd switch (vp->v_type) {
619 1.10 cgd case VREG:
620 1.10 cgd mode |= S_IFREG;
621 1.10 cgd break;
622 1.10 cgd case VDIR:
623 1.10 cgd mode |= S_IFDIR;
624 1.10 cgd break;
625 1.10 cgd case VBLK:
626 1.10 cgd mode |= S_IFBLK;
627 1.10 cgd break;
628 1.10 cgd case VCHR:
629 1.10 cgd mode |= S_IFCHR;
630 1.10 cgd break;
631 1.10 cgd case VLNK:
632 1.10 cgd mode |= S_IFLNK;
633 1.10 cgd break;
634 1.10 cgd case VSOCK:
635 1.10 cgd mode |= S_IFSOCK;
636 1.10 cgd break;
637 1.10 cgd case VFIFO:
638 1.10 cgd mode |= S_IFIFO;
639 1.10 cgd break;
640 1.10 cgd default:
641 1.10 cgd return (EBADF);
642 1.10 cgd };
643 1.10 cgd sb->st_mode = mode;
644 1.19 mycroft sb->st_nlink = va.va_nlink;
645 1.19 mycroft sb->st_uid = va.va_uid;
646 1.19 mycroft sb->st_gid = va.va_gid;
647 1.19 mycroft sb->st_rdev = va.va_rdev;
648 1.19 mycroft sb->st_size = va.va_size;
649 1.19 mycroft sb->st_atimespec = va.va_atime;
650 1.19 mycroft sb->st_mtimespec = va.va_mtime;
651 1.19 mycroft sb->st_ctimespec = va.va_ctime;
652 1.69 fvdl sb->st_birthtimespec = va.va_birthtime;
653 1.19 mycroft sb->st_blksize = va.va_blocksize;
654 1.19 mycroft sb->st_flags = va.va_flags;
655 1.22 mycroft sb->st_gen = 0;
656 1.19 mycroft sb->st_blocks = va.va_bytes / S_BLKSIZE;
657 1.10 cgd return (0);
658 1.37 wrstuden }
659 1.37 wrstuden
660 1.37 wrstuden /*
661 1.37 wrstuden * File table vnode fcntl routine.
662 1.37 wrstuden */
663 1.56 gmcgarry static int
664 1.155 ad vn_fcntl(file_t *fp, u_int com, void *data)
665 1.37 wrstuden {
666 1.155 ad struct vnode *vp = fp->f_data;
667 1.37 wrstuden int error;
668 1.37 wrstuden
669 1.155 ad error = VOP_FCNTL(vp, com, data, fp->f_flag, kauth_cred_get());
670 1.37 wrstuden return (error);
671 1.10 cgd }
672 1.10 cgd
673 1.10 cgd /*
674 1.10 cgd * File table vnode ioctl routine.
675 1.10 cgd */
676 1.56 gmcgarry static int
677 1.155 ad vn_ioctl(file_t *fp, u_long com, void *data)
678 1.10 cgd {
679 1.155 ad struct vnode *vp = fp->f_data, *ovp;
680 1.10 cgd struct vattr vattr;
681 1.10 cgd int error;
682 1.10 cgd
683 1.10 cgd switch (vp->v_type) {
684 1.10 cgd
685 1.10 cgd case VREG:
686 1.10 cgd case VDIR:
687 1.10 cgd if (com == FIONREAD) {
688 1.155 ad error = VOP_GETATTR(vp, &vattr,
689 1.155 ad kauth_cred_get());
690 1.20 christos if (error)
691 1.10 cgd return (error);
692 1.10 cgd *(int *)data = vattr.va_size - fp->f_offset;
693 1.10 cgd return (0);
694 1.60 atatat }
695 1.82 christos if ((com == FIONWRITE) || (com == FIONSPACE)) {
696 1.81 wrstuden /*
697 1.81 wrstuden * Files don't have send queues, so there never
698 1.81 wrstuden * are any bytes in them, nor is there any
699 1.81 wrstuden * open space in them.
700 1.81 wrstuden */
701 1.81 wrstuden *(int *)data = 0;
702 1.81 wrstuden return (0);
703 1.81 wrstuden }
704 1.60 atatat if (com == FIOGETBMAP) {
705 1.60 atatat daddr_t *block;
706 1.60 atatat
707 1.62 atatat if (*(daddr_t *)data < 0)
708 1.62 atatat return (EINVAL);
709 1.60 atatat block = (daddr_t *)data;
710 1.60 atatat return (VOP_BMAP(vp, *block, NULL, block, NULL));
711 1.61 fvdl }
712 1.61 fvdl if (com == OFIOGETBMAP) {
713 1.61 fvdl daddr_t ibn, obn;
714 1.61 fvdl
715 1.62 atatat if (*(int32_t *)data < 0)
716 1.62 atatat return (EINVAL);
717 1.61 fvdl ibn = (daddr_t)*(int32_t *)data;
718 1.61 fvdl error = VOP_BMAP(vp, ibn, NULL, &obn, NULL);
719 1.61 fvdl *(int32_t *)data = (int32_t)obn;
720 1.61 fvdl return error;
721 1.10 cgd }
722 1.10 cgd if (com == FIONBIO || com == FIOASYNC) /* XXX */
723 1.10 cgd return (0); /* XXX */
724 1.10 cgd /* fall into ... */
725 1.10 cgd case VFIFO:
726 1.10 cgd case VCHR:
727 1.10 cgd case VBLK:
728 1.155 ad error = VOP_IOCTL(vp, com, data, fp->f_flag,
729 1.155 ad kauth_cred_get());
730 1.10 cgd if (error == 0 && com == TIOCSCTTY) {
731 1.169 pooka vref(vp);
732 1.156 ad mutex_enter(proc_lock);
733 1.155 ad ovp = curproc->p_session->s_ttyvp;
734 1.155 ad curproc->p_session->s_ttyvp = vp;
735 1.156 ad mutex_exit(proc_lock);
736 1.132 ad if (ovp != NULL)
737 1.132 ad vrele(ovp);
738 1.10 cgd }
739 1.10 cgd return (error);
740 1.63 perseant
741 1.63 perseant default:
742 1.63 perseant return (EPASSTHROUGH);
743 1.10 cgd }
744 1.10 cgd }
745 1.10 cgd
746 1.10 cgd /*
747 1.21 mycroft * File table vnode poll routine.
748 1.10 cgd */
749 1.56 gmcgarry static int
750 1.155 ad vn_poll(file_t *fp, int events)
751 1.10 cgd {
752 1.10 cgd
753 1.155 ad return (VOP_POLL(fp->f_data, events));
754 1.57 jdolecek }
755 1.57 jdolecek
756 1.57 jdolecek /*
757 1.57 jdolecek * File table vnode kqfilter routine.
758 1.57 jdolecek */
759 1.57 jdolecek int
760 1.155 ad vn_kqfilter(file_t *fp, struct knote *kn)
761 1.57 jdolecek {
762 1.57 jdolecek
763 1.155 ad return (VOP_KQFILTER(fp->f_data, kn));
764 1.28 fvdl }
765 1.28 fvdl
766 1.28 fvdl /*
767 1.28 fvdl * Check that the vnode is still valid, and if so
768 1.28 fvdl * acquire requested lock.
769 1.28 fvdl */
770 1.28 fvdl int
771 1.89 thorpej vn_lock(struct vnode *vp, int flags)
772 1.28 fvdl {
773 1.28 fvdl int error;
774 1.34 sommerfe
775 1.84 yamt #if 0
776 1.169.2.2 uebayasi KASSERT(vp->v_usecount > 0 || (vp->v_iflag & VI_ONWORKLST) != 0);
777 1.84 yamt #endif
778 1.169.2.2 uebayasi KASSERT((flags & ~(LK_SHARED|LK_EXCLUSIVE|LK_NOWAIT|LK_RETRY)) == 0);
779 1.169.2.2 uebayasi KASSERT(!mutex_owned(&vp->v_interlock));
780 1.80 yamt
781 1.159 simonb #ifdef DIAGNOSTIC
782 1.159 simonb if (wapbl_vphaswapbl(vp))
783 1.159 simonb WAPBL_JUNLOCK_ASSERT(wapbl_vptomp(vp));
784 1.159 simonb #endif
785 1.159 simonb
786 1.28 fvdl do {
787 1.157 ad /*
788 1.157 ad * XXX PR 37706 forced unmount of file systems is unsafe.
789 1.157 ad * Race between vclean() and this the remaining problem.
790 1.157 ad */
791 1.169.2.2 uebayasi mutex_enter(&vp->v_interlock);
792 1.143 ad if (vp->v_iflag & VI_XLOCK) {
793 1.49 chs if (flags & LK_NOWAIT) {
794 1.149 ad mutex_exit(&vp->v_interlock);
795 1.49 chs return EBUSY;
796 1.49 chs }
797 1.149 ad vwait(vp, VI_XLOCK);
798 1.149 ad mutex_exit(&vp->v_interlock);
799 1.28 fvdl error = ENOENT;
800 1.28 fvdl } else {
801 1.169.2.2 uebayasi mutex_exit(&vp->v_interlock);
802 1.157 ad error = VOP_LOCK(vp, (flags & ~LK_RETRY));
803 1.49 chs if (error == 0 || error == EDEADLK || error == EBUSY)
804 1.28 fvdl return (error);
805 1.28 fvdl }
806 1.28 fvdl } while (flags & LK_RETRY);
807 1.28 fvdl return (error);
808 1.10 cgd }
809 1.10 cgd
810 1.10 cgd /*
811 1.10 cgd * File table vnode close routine.
812 1.10 cgd */
813 1.56 gmcgarry static int
814 1.155 ad vn_closefile(file_t *fp)
815 1.10 cgd {
816 1.10 cgd
817 1.155 ad return vn_close(fp->f_data, fp->f_flag, fp->f_cred);
818 1.39 fvdl }
819 1.39 fvdl
820 1.39 fvdl /*
821 1.85 thorpej * Simplified in-kernel wrapper calls for extended attribute access.
822 1.85 thorpej * Both calls pass in a NULL credential, authorizing a "kernel" access.
823 1.85 thorpej * Set IO_NODELOCKED in ioflg if the vnode is already locked.
824 1.85 thorpej */
825 1.85 thorpej int
826 1.85 thorpej vn_extattr_get(struct vnode *vp, int ioflg, int attrnamespace,
827 1.101 christos const char *attrname, size_t *buflen, void *bf, struct lwp *l)
828 1.85 thorpej {
829 1.85 thorpej struct uio auio;
830 1.85 thorpej struct iovec aiov;
831 1.85 thorpej int error;
832 1.85 thorpej
833 1.85 thorpej aiov.iov_len = *buflen;
834 1.88 christos aiov.iov_base = bf;
835 1.85 thorpej
836 1.85 thorpej auio.uio_iov = &aiov;
837 1.85 thorpej auio.uio_iovcnt = 1;
838 1.85 thorpej auio.uio_rw = UIO_READ;
839 1.85 thorpej auio.uio_offset = 0;
840 1.85 thorpej auio.uio_resid = *buflen;
841 1.106 yamt UIO_SETUP_SYSSPACE(&auio);
842 1.85 thorpej
843 1.85 thorpej if ((ioflg & IO_NODELOCKED) == 0)
844 1.85 thorpej vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
845 1.86 perry
846 1.144 pooka error = VOP_GETEXTATTR(vp, attrnamespace, attrname, &auio, NULL, NULL);
847 1.86 perry
848 1.85 thorpej if ((ioflg & IO_NODELOCKED) == 0)
849 1.169.2.2 uebayasi VOP_UNLOCK(vp);
850 1.86 perry
851 1.85 thorpej if (error == 0)
852 1.85 thorpej *buflen = *buflen - auio.uio_resid;
853 1.86 perry
854 1.85 thorpej return (error);
855 1.85 thorpej }
856 1.85 thorpej
857 1.85 thorpej /*
858 1.85 thorpej * XXX Failure mode if partially written?
859 1.85 thorpej */
860 1.85 thorpej int
861 1.85 thorpej vn_extattr_set(struct vnode *vp, int ioflg, int attrnamespace,
862 1.101 christos const char *attrname, size_t buflen, const void *bf, struct lwp *l)
863 1.85 thorpej {
864 1.85 thorpej struct uio auio;
865 1.85 thorpej struct iovec aiov;
866 1.85 thorpej int error;
867 1.85 thorpej
868 1.85 thorpej aiov.iov_len = buflen;
869 1.88 christos aiov.iov_base = __UNCONST(bf); /* XXXUNCONST kills const */
870 1.85 thorpej
871 1.85 thorpej auio.uio_iov = &aiov;
872 1.85 thorpej auio.uio_iovcnt = 1;
873 1.85 thorpej auio.uio_rw = UIO_WRITE;
874 1.85 thorpej auio.uio_offset = 0;
875 1.85 thorpej auio.uio_resid = buflen;
876 1.106 yamt UIO_SETUP_SYSSPACE(&auio);
877 1.85 thorpej
878 1.85 thorpej if ((ioflg & IO_NODELOCKED) == 0) {
879 1.85 thorpej vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
880 1.85 thorpej }
881 1.85 thorpej
882 1.144 pooka error = VOP_SETEXTATTR(vp, attrnamespace, attrname, &auio, NULL);
883 1.85 thorpej
884 1.85 thorpej if ((ioflg & IO_NODELOCKED) == 0) {
885 1.169.2.2 uebayasi VOP_UNLOCK(vp);
886 1.85 thorpej }
887 1.85 thorpej
888 1.85 thorpej return (error);
889 1.85 thorpej }
890 1.85 thorpej
891 1.85 thorpej int
892 1.85 thorpej vn_extattr_rm(struct vnode *vp, int ioflg, int attrnamespace,
893 1.101 christos const char *attrname, struct lwp *l)
894 1.85 thorpej {
895 1.85 thorpej int error;
896 1.85 thorpej
897 1.85 thorpej if ((ioflg & IO_NODELOCKED) == 0) {
898 1.85 thorpej vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
899 1.85 thorpej }
900 1.85 thorpej
901 1.144 pooka error = VOP_DELETEEXTATTR(vp, attrnamespace, attrname, NULL);
902 1.85 thorpej if (error == EOPNOTSUPP)
903 1.144 pooka error = VOP_SETEXTATTR(vp, attrnamespace, attrname, NULL, NULL);
904 1.86 perry
905 1.85 thorpej if ((ioflg & IO_NODELOCKED) == 0) {
906 1.169.2.2 uebayasi VOP_UNLOCK(vp);
907 1.85 thorpej }
908 1.85 thorpej
909 1.85 thorpej return (error);
910 1.85 thorpej }
911 1.95 yamt
912 1.100 yamt void
913 1.100 yamt vn_ra_allocctx(struct vnode *vp)
914 1.100 yamt {
915 1.100 yamt struct uvm_ractx *ra = NULL;
916 1.100 yamt
917 1.149 ad KASSERT(mutex_owned(&vp->v_interlock));
918 1.149 ad
919 1.100 yamt if (vp->v_type != VREG) {
920 1.100 yamt return;
921 1.100 yamt }
922 1.100 yamt if (vp->v_ractx != NULL) {
923 1.100 yamt return;
924 1.100 yamt }
925 1.100 yamt if (vp->v_ractx == NULL) {
926 1.149 ad mutex_exit(&vp->v_interlock);
927 1.100 yamt ra = uvm_ra_allocctx();
928 1.149 ad mutex_enter(&vp->v_interlock);
929 1.100 yamt if (ra != NULL && vp->v_ractx == NULL) {
930 1.100 yamt vp->v_ractx = ra;
931 1.100 yamt ra = NULL;
932 1.100 yamt }
933 1.100 yamt }
934 1.100 yamt if (ra != NULL) {
935 1.100 yamt uvm_ra_freectx(ra);
936 1.100 yamt }
937 1.100 yamt }
938 1.169.2.1 uebayasi
939 1.169.2.1 uebayasi int
940 1.169.2.1 uebayasi vn_fifo_bypass(void *v)
941 1.169.2.1 uebayasi {
942 1.169.2.1 uebayasi struct vop_generic_args *ap = v;
943 1.169.2.1 uebayasi
944 1.169.2.1 uebayasi return VOCALL(fifo_vnodeop_p, ap->a_desc->vdesc_offset, v);
945 1.169.2.1 uebayasi }
946