vfs_vnops.c revision 1.192 1 1.192 chs /* $NetBSD: vfs_vnops.c,v 1.192 2014/12/14 23:48:58 chs 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.192 chs __KERNEL_RCSID(0, "$NetBSD: vfs_vnops.c,v 1.192 2014/12/14 23:48:58 chs 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.192 chs #include <sys/mman.h>
93 1.11 mycroft
94 1.77 hannken #include <miscfs/specfs/specdev.h>
95 1.170 pooka #include <miscfs/fifofs/fifo.h>
96 1.77 hannken
97 1.25 mrg #include <uvm/uvm_extern.h>
98 1.100 yamt #include <uvm/uvm_readahead.h>
99 1.192 chs #include <uvm/uvm_device.h>
100 1.25 mrg
101 1.28 fvdl #ifdef UNION
102 1.65 jdolecek #include <fs/union/union.h>
103 1.28 fvdl #endif
104 1.64 jdolecek
105 1.192 chs #ifndef COMPAT_ZERODEV
106 1.192 chs #define COMPAT_ZERODEV(dev) (0)
107 1.192 chs #endif
108 1.192 chs
109 1.101 christos int (*vn_union_readdir_hook) (struct vnode **, struct file *, struct lwp *);
110 1.66 jdolecek
111 1.58 blymn #include <sys/verified_exec.h>
112 1.28 fvdl
113 1.155 ad static int vn_read(file_t *fp, off_t *offset, struct uio *uio,
114 1.111 elad kauth_cred_t cred, int flags);
115 1.155 ad static int vn_write(file_t *fp, off_t *offset, struct uio *uio,
116 1.111 elad kauth_cred_t cred, int flags);
117 1.155 ad static int vn_closefile(file_t *fp);
118 1.155 ad static int vn_poll(file_t *fp, int events);
119 1.155 ad static int vn_fcntl(file_t *fp, u_int com, void *data);
120 1.155 ad static int vn_statfile(file_t *fp, struct stat *sb);
121 1.155 ad static int vn_ioctl(file_t *fp, u_long com, void *data);
122 1.192 chs static int vn_mmap(struct file *, off_t *, size_t, int, int *, int *,
123 1.192 chs struct uvm_object **, int *);
124 1.48 jdolecek
125 1.83 christos const struct fileops vnops = {
126 1.164 ad .fo_read = vn_read,
127 1.164 ad .fo_write = vn_write,
128 1.164 ad .fo_ioctl = vn_ioctl,
129 1.164 ad .fo_fcntl = vn_fcntl,
130 1.164 ad .fo_poll = vn_poll,
131 1.164 ad .fo_stat = vn_statfile,
132 1.164 ad .fo_close = vn_closefile,
133 1.164 ad .fo_kqfilter = vn_kqfilter,
134 1.168 dsl .fo_restart = fnullop_restart,
135 1.192 chs .fo_mmap = vn_mmap,
136 1.48 jdolecek };
137 1.10 cgd
138 1.10 cgd /*
139 1.10 cgd * Common code for vnode open operations.
140 1.10 cgd * Check permissions, and call the VOP_OPEN or VOP_CREATE routine.
141 1.10 cgd */
142 1.20 christos int
143 1.89 thorpej vn_open(struct nameidata *ndp, int fmode, int cmode)
144 1.10 cgd {
145 1.94 erh struct vnode *vp;
146 1.148 pooka struct lwp *l = curlwp;
147 1.117 ad kauth_cred_t cred = l->l_cred;
148 1.19 mycroft struct vattr va;
149 1.10 cgd int error;
150 1.180 dholland const char *pathstring;
151 1.75 hannken
152 1.178 chs if ((fmode & (O_CREAT | O_DIRECTORY)) == (O_CREAT | O_DIRECTORY))
153 1.178 chs return EINVAL;
154 1.178 chs
155 1.163 enami ndp->ni_cnd.cn_flags &= TRYEMULROOT | NOCHROOT;
156 1.138 dsl
157 1.10 cgd if (fmode & O_CREAT) {
158 1.11 mycroft ndp->ni_cnd.cn_nameiop = CREATE;
159 1.138 dsl ndp->ni_cnd.cn_flags |= LOCKPARENT | LOCKLEAF;
160 1.38 bouyer if ((fmode & O_EXCL) == 0 &&
161 1.59 christos ((fmode & O_NOFOLLOW) == 0))
162 1.11 mycroft ndp->ni_cnd.cn_flags |= FOLLOW;
163 1.130 elad } else {
164 1.130 elad ndp->ni_cnd.cn_nameiop = LOOKUP;
165 1.138 dsl ndp->ni_cnd.cn_flags |= LOCKLEAF;
166 1.130 elad if ((fmode & O_NOFOLLOW) == 0)
167 1.130 elad ndp->ni_cnd.cn_flags |= FOLLOW;
168 1.130 elad }
169 1.139 christos
170 1.180 dholland pathstring = pathbuf_stringcopy_get(ndp->ni_pathbuf);
171 1.180 dholland if (pathstring == NULL) {
172 1.180 dholland return ENOMEM;
173 1.180 dholland }
174 1.139 christos
175 1.130 elad error = namei(ndp);
176 1.130 elad if (error)
177 1.139 christos goto out;
178 1.91 elad
179 1.130 elad vp = ndp->ni_vp;
180 1.91 elad
181 1.130 elad #if NVERIEXEC > 0
182 1.180 dholland error = veriexec_openchk(l, ndp->ni_vp, pathstring, fmode);
183 1.190 maxv if (error) {
184 1.190 maxv /* We have to release the locks ourselves */
185 1.190 maxv if (fmode & O_CREAT) {
186 1.190 maxv if (vp == NULL) {
187 1.190 maxv vput(ndp->ni_dvp);
188 1.190 maxv } else {
189 1.190 maxv VOP_ABORTOP(ndp->ni_dvp, &ndp->ni_cnd);
190 1.190 maxv if (ndp->ni_dvp == ndp->ni_vp)
191 1.190 maxv vrele(ndp->ni_dvp);
192 1.190 maxv else
193 1.190 maxv vput(ndp->ni_dvp);
194 1.190 maxv ndp->ni_dvp = NULL;
195 1.190 maxv vput(vp);
196 1.190 maxv }
197 1.190 maxv } else {
198 1.190 maxv vput(vp);
199 1.190 maxv }
200 1.190 maxv goto out;
201 1.190 maxv }
202 1.115 elad #endif /* NVERIEXEC > 0 */
203 1.91 elad
204 1.130 elad if (fmode & O_CREAT) {
205 1.130 elad if (ndp->ni_vp == NULL) {
206 1.169 pooka vattr_null(&va);
207 1.19 mycroft va.va_type = VREG;
208 1.19 mycroft va.va_mode = cmode;
209 1.28 fvdl if (fmode & O_EXCL)
210 1.28 fvdl va.va_vaflags |= VA_EXCLUSIVE;
211 1.20 christos error = VOP_CREATE(ndp->ni_dvp, &ndp->ni_vp,
212 1.20 christos &ndp->ni_cnd, &va);
213 1.187 hannken vput(ndp->ni_dvp);
214 1.20 christos if (error)
215 1.139 christos goto out;
216 1.10 cgd fmode &= ~O_TRUNC;
217 1.10 cgd vp = ndp->ni_vp;
218 1.188 hannken vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
219 1.10 cgd } else {
220 1.11 mycroft VOP_ABORTOP(ndp->ni_dvp, &ndp->ni_cnd);
221 1.10 cgd if (ndp->ni_dvp == ndp->ni_vp)
222 1.10 cgd vrele(ndp->ni_dvp);
223 1.10 cgd else
224 1.10 cgd vput(ndp->ni_dvp);
225 1.10 cgd ndp->ni_dvp = NULL;
226 1.10 cgd vp = ndp->ni_vp;
227 1.10 cgd if (fmode & O_EXCL) {
228 1.10 cgd error = EEXIST;
229 1.38 bouyer goto bad;
230 1.38 bouyer }
231 1.10 cgd fmode &= ~O_CREAT;
232 1.10 cgd }
233 1.10 cgd } else {
234 1.10 cgd vp = ndp->ni_vp;
235 1.10 cgd }
236 1.10 cgd if (vp->v_type == VSOCK) {
237 1.10 cgd error = EOPNOTSUPP;
238 1.74 cb goto bad;
239 1.74 cb }
240 1.74 cb if (ndp->ni_vp->v_type == VLNK) {
241 1.74 cb error = EFTYPE;
242 1.10 cgd goto bad;
243 1.10 cgd }
244 1.58 blymn
245 1.10 cgd if ((fmode & O_CREAT) == 0) {
246 1.146 yamt error = vn_openchk(vp, cred, fmode);
247 1.146 yamt if (error != 0)
248 1.146 yamt goto bad;
249 1.10 cgd }
250 1.87 blymn
251 1.10 cgd if (fmode & O_TRUNC) {
252 1.169 pooka vattr_null(&va);
253 1.19 mycroft va.va_size = 0;
254 1.144 pooka error = VOP_SETATTR(vp, &va, cred);
255 1.75 hannken if (error != 0)
256 1.10 cgd goto bad;
257 1.10 cgd }
258 1.144 pooka if ((error = VOP_OPEN(vp, fmode, cred)) != 0)
259 1.10 cgd goto bad;
260 1.143 ad if (fmode & FWRITE) {
261 1.181 rmind mutex_enter(vp->v_interlock);
262 1.10 cgd vp->v_writecount++;
263 1.181 rmind mutex_exit(vp->v_interlock);
264 1.143 ad }
265 1.45 chs
266 1.10 cgd bad:
267 1.127 elad if (error)
268 1.127 elad vput(vp);
269 1.139 christos out:
270 1.180 dholland pathbuf_stringcopy_put(ndp->ni_pathbuf, pathstring);
271 1.10 cgd return (error);
272 1.10 cgd }
273 1.10 cgd
274 1.10 cgd /*
275 1.10 cgd * Check for write permissions on the specified vnode.
276 1.28 fvdl * Prototype text segments cannot be written.
277 1.10 cgd */
278 1.20 christos int
279 1.89 thorpej vn_writechk(struct vnode *vp)
280 1.10 cgd {
281 1.10 cgd
282 1.10 cgd /*
283 1.45 chs * If the vnode is in use as a process's text,
284 1.45 chs * we can't allow writing.
285 1.10 cgd */
286 1.143 ad if (vp->v_iflag & VI_TEXT)
287 1.25 mrg return (ETXTBSY);
288 1.10 cgd return (0);
289 1.42 chs }
290 1.42 chs
291 1.146 yamt int
292 1.146 yamt vn_openchk(struct vnode *vp, kauth_cred_t cred, int fflags)
293 1.146 yamt {
294 1.146 yamt int permbits = 0;
295 1.146 yamt int error;
296 1.146 yamt
297 1.178 chs if ((fflags & O_DIRECTORY) != 0 && vp->v_type != VDIR)
298 1.178 chs return ENOTDIR;
299 1.178 chs
300 1.146 yamt if ((fflags & FREAD) != 0) {
301 1.146 yamt permbits = VREAD;
302 1.146 yamt }
303 1.146 yamt if ((fflags & (FWRITE | O_TRUNC)) != 0) {
304 1.146 yamt permbits |= VWRITE;
305 1.146 yamt if (vp->v_type == VDIR) {
306 1.146 yamt error = EISDIR;
307 1.146 yamt goto bad;
308 1.146 yamt }
309 1.146 yamt error = vn_writechk(vp);
310 1.146 yamt if (error != 0)
311 1.146 yamt goto bad;
312 1.146 yamt }
313 1.146 yamt error = VOP_ACCESS(vp, permbits, cred);
314 1.146 yamt bad:
315 1.146 yamt return error;
316 1.146 yamt }
317 1.146 yamt
318 1.42 chs /*
319 1.51 thorpej * Mark a vnode as having executable mappings.
320 1.42 chs */
321 1.42 chs void
322 1.89 thorpej vn_markexec(struct vnode *vp)
323 1.42 chs {
324 1.143 ad
325 1.158 ad if ((vp->v_iflag & VI_EXECMAP) != 0) {
326 1.158 ad /* Safe unlocked, as long as caller holds a reference. */
327 1.158 ad return;
328 1.158 ad }
329 1.143 ad
330 1.181 rmind mutex_enter(vp->v_interlock);
331 1.143 ad if ((vp->v_iflag & VI_EXECMAP) == 0) {
332 1.145 ad atomic_add_int(&uvmexp.filepages, -vp->v_uobj.uo_npages);
333 1.145 ad atomic_add_int(&uvmexp.execpages, vp->v_uobj.uo_npages);
334 1.158 ad vp->v_iflag |= VI_EXECMAP;
335 1.46 chs }
336 1.181 rmind mutex_exit(vp->v_interlock);
337 1.55 chs }
338 1.55 chs
339 1.55 chs /*
340 1.55 chs * Mark a vnode as being the text of a process.
341 1.55 chs * Fail if the vnode is currently writable.
342 1.55 chs */
343 1.55 chs int
344 1.89 thorpej vn_marktext(struct vnode *vp)
345 1.55 chs {
346 1.55 chs
347 1.157 ad if ((vp->v_iflag & (VI_TEXT|VI_EXECMAP)) == (VI_TEXT|VI_EXECMAP)) {
348 1.157 ad /* Safe unlocked, as long as caller holds a reference. */
349 1.158 ad return (0);
350 1.157 ad }
351 1.157 ad
352 1.181 rmind mutex_enter(vp->v_interlock);
353 1.55 chs if (vp->v_writecount != 0) {
354 1.143 ad KASSERT((vp->v_iflag & VI_TEXT) == 0);
355 1.181 rmind mutex_exit(vp->v_interlock);
356 1.55 chs return (ETXTBSY);
357 1.55 chs }
358 1.158 ad if ((vp->v_iflag & VI_EXECMAP) == 0) {
359 1.158 ad atomic_add_int(&uvmexp.filepages, -vp->v_uobj.uo_npages);
360 1.158 ad atomic_add_int(&uvmexp.execpages, vp->v_uobj.uo_npages);
361 1.158 ad }
362 1.158 ad vp->v_iflag |= (VI_TEXT | VI_EXECMAP);
363 1.181 rmind mutex_exit(vp->v_interlock);
364 1.55 chs return (0);
365 1.10 cgd }
366 1.10 cgd
367 1.10 cgd /*
368 1.10 cgd * Vnode close call
369 1.32 wrstuden *
370 1.32 wrstuden * Note: takes an unlocked vnode, while VOP_CLOSE takes a locked node.
371 1.10 cgd */
372 1.20 christos int
373 1.155 ad vn_close(struct vnode *vp, int flags, kauth_cred_t cred)
374 1.10 cgd {
375 1.10 cgd int error;
376 1.10 cgd
377 1.158 ad if (flags & FWRITE) {
378 1.181 rmind mutex_enter(vp->v_interlock);
379 1.182 yamt KASSERT(vp->v_writecount > 0);
380 1.10 cgd vp->v_writecount--;
381 1.181 rmind mutex_exit(vp->v_interlock);
382 1.158 ad }
383 1.158 ad vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
384 1.144 pooka error = VOP_CLOSE(vp, flags, cred);
385 1.32 wrstuden vput(vp);
386 1.10 cgd return (error);
387 1.10 cgd }
388 1.10 cgd
389 1.171 pooka static int
390 1.171 pooka enforce_rlimit_fsize(struct vnode *vp, struct uio *uio, int ioflag)
391 1.171 pooka {
392 1.171 pooka struct lwp *l = curlwp;
393 1.171 pooka off_t testoff;
394 1.171 pooka
395 1.171 pooka if (uio->uio_rw != UIO_WRITE || vp->v_type != VREG)
396 1.171 pooka return 0;
397 1.171 pooka
398 1.171 pooka KASSERT(VOP_ISLOCKED(vp) == LK_EXCLUSIVE);
399 1.171 pooka if (ioflag & IO_APPEND)
400 1.171 pooka testoff = vp->v_size;
401 1.171 pooka else
402 1.171 pooka testoff = uio->uio_offset;
403 1.171 pooka
404 1.171 pooka if (testoff + uio->uio_resid >
405 1.171 pooka l->l_proc->p_rlimit[RLIMIT_FSIZE].rlim_cur) {
406 1.171 pooka mutex_enter(proc_lock);
407 1.171 pooka psignal(l->l_proc, SIGXFSZ);
408 1.171 pooka mutex_exit(proc_lock);
409 1.171 pooka return EFBIG;
410 1.171 pooka }
411 1.171 pooka
412 1.171 pooka return 0;
413 1.171 pooka }
414 1.171 pooka
415 1.10 cgd /*
416 1.10 cgd * Package up an I/O request on a vnode into a uio and do it.
417 1.10 cgd */
418 1.20 christos int
419 1.134 christos vn_rdwr(enum uio_rw rw, struct vnode *vp, void *base, int len, off_t offset,
420 1.111 elad enum uio_seg segflg, int ioflg, kauth_cred_t cred, size_t *aresid,
421 1.101 christos struct lwp *l)
422 1.10 cgd {
423 1.10 cgd struct uio auio;
424 1.10 cgd struct iovec aiov;
425 1.10 cgd int error;
426 1.10 cgd
427 1.50 chs if ((ioflg & IO_NODELOCKED) == 0) {
428 1.50 chs if (rw == UIO_READ) {
429 1.50 chs vn_lock(vp, LK_SHARED | LK_RETRY);
430 1.75 hannken } else /* UIO_WRITE */ {
431 1.50 chs vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
432 1.50 chs }
433 1.50 chs }
434 1.10 cgd auio.uio_iov = &aiov;
435 1.10 cgd auio.uio_iovcnt = 1;
436 1.10 cgd aiov.iov_base = base;
437 1.10 cgd aiov.iov_len = len;
438 1.10 cgd auio.uio_resid = len;
439 1.10 cgd auio.uio_offset = offset;
440 1.10 cgd auio.uio_rw = rw;
441 1.106 yamt if (segflg == UIO_SYSSPACE) {
442 1.106 yamt UIO_SETUP_SYSSPACE(&auio);
443 1.106 yamt } else {
444 1.106 yamt auio.uio_vmspace = l->l_proc->p_vmspace;
445 1.106 yamt }
446 1.171 pooka
447 1.171 pooka if ((error = enforce_rlimit_fsize(vp, &auio, ioflg)) != 0)
448 1.171 pooka goto out;
449 1.171 pooka
450 1.11 mycroft if (rw == UIO_READ) {
451 1.10 cgd error = VOP_READ(vp, &auio, ioflg, cred);
452 1.11 mycroft } else {
453 1.10 cgd error = VOP_WRITE(vp, &auio, ioflg, cred);
454 1.11 mycroft }
455 1.171 pooka
456 1.10 cgd if (aresid)
457 1.10 cgd *aresid = auio.uio_resid;
458 1.10 cgd else
459 1.10 cgd if (auio.uio_resid && error == 0)
460 1.10 cgd error = EIO;
461 1.171 pooka
462 1.171 pooka out:
463 1.75 hannken if ((ioflg & IO_NODELOCKED) == 0) {
464 1.174 hannken VOP_UNLOCK(vp);
465 1.75 hannken }
466 1.10 cgd return (error);
467 1.23 fvdl }
468 1.23 fvdl
469 1.23 fvdl int
470 1.155 ad vn_readdir(file_t *fp, char *bf, int segflg, u_int count, int *done,
471 1.101 christos struct lwp *l, off_t **cookies, int *ncookies)
472 1.23 fvdl {
473 1.191 matt struct vnode *vp = fp->f_vnode;
474 1.23 fvdl struct iovec aiov;
475 1.23 fvdl struct uio auio;
476 1.23 fvdl int error, eofflag;
477 1.23 fvdl
478 1.112 simonb /* Limit the size on any kernel buffers used by VOP_READDIR */
479 1.112 simonb count = min(MAXBSIZE, count);
480 1.112 simonb
481 1.23 fvdl unionread:
482 1.23 fvdl if (vp->v_type != VDIR)
483 1.23 fvdl return (EINVAL);
484 1.88 christos aiov.iov_base = bf;
485 1.23 fvdl aiov.iov_len = count;
486 1.23 fvdl auio.uio_iov = &aiov;
487 1.23 fvdl auio.uio_iovcnt = 1;
488 1.23 fvdl auio.uio_rw = UIO_READ;
489 1.106 yamt if (segflg == UIO_SYSSPACE) {
490 1.106 yamt UIO_SETUP_SYSSPACE(&auio);
491 1.106 yamt } else {
492 1.106 yamt KASSERT(l == curlwp);
493 1.106 yamt auio.uio_vmspace = l->l_proc->p_vmspace;
494 1.106 yamt }
495 1.23 fvdl auio.uio_resid = count;
496 1.50 chs vn_lock(vp, LK_SHARED | LK_RETRY);
497 1.23 fvdl auio.uio_offset = fp->f_offset;
498 1.28 fvdl error = VOP_READDIR(vp, &auio, fp->f_cred, &eofflag, cookies,
499 1.23 fvdl ncookies);
500 1.166 yamt mutex_enter(&fp->f_lock);
501 1.23 fvdl fp->f_offset = auio.uio_offset;
502 1.166 yamt mutex_exit(&fp->f_lock);
503 1.174 hannken VOP_UNLOCK(vp);
504 1.23 fvdl if (error)
505 1.23 fvdl return (error);
506 1.23 fvdl
507 1.66 jdolecek if (count == auio.uio_resid && vn_union_readdir_hook) {
508 1.66 jdolecek struct vnode *ovp = vp;
509 1.23 fvdl
510 1.101 christos error = (*vn_union_readdir_hook)(&vp, fp, l);
511 1.66 jdolecek if (error)
512 1.66 jdolecek return (error);
513 1.66 jdolecek if (vp != ovp)
514 1.23 fvdl goto unionread;
515 1.23 fvdl }
516 1.23 fvdl
517 1.143 ad if (count == auio.uio_resid && (vp->v_vflag & VV_ROOT) &&
518 1.23 fvdl (vp->v_mount->mnt_flag & MNT_UNION)) {
519 1.23 fvdl struct vnode *tvp = vp;
520 1.23 fvdl vp = vp->v_mount->mnt_vnodecovered;
521 1.169 pooka vref(vp);
522 1.166 yamt mutex_enter(&fp->f_lock);
523 1.191 matt fp->f_vnode = vp;
524 1.23 fvdl fp->f_offset = 0;
525 1.166 yamt mutex_exit(&fp->f_lock);
526 1.23 fvdl vrele(tvp);
527 1.23 fvdl goto unionread;
528 1.23 fvdl }
529 1.23 fvdl *done = count - auio.uio_resid;
530 1.23 fvdl return error;
531 1.10 cgd }
532 1.10 cgd
533 1.10 cgd /*
534 1.10 cgd * File table vnode read routine.
535 1.10 cgd */
536 1.56 gmcgarry static int
537 1.155 ad vn_read(file_t *fp, off_t *offset, struct uio *uio, kauth_cred_t cred,
538 1.89 thorpej int flags)
539 1.10 cgd {
540 1.191 matt struct vnode *vp = fp->f_vnode;
541 1.185 dholland int error, ioflag, fflag;
542 1.185 dholland size_t count;
543 1.10 cgd
544 1.100 yamt ioflag = IO_ADV_ENCODE(fp->f_advice);
545 1.155 ad fflag = fp->f_flag;
546 1.155 ad if (fflag & FNONBLOCK)
547 1.31 kleink ioflag |= IO_NDELAY;
548 1.155 ad if ((fflag & (FFSYNC | FRSYNC)) == (FFSYNC | FRSYNC))
549 1.31 kleink ioflag |= IO_SYNC;
550 1.155 ad if (fflag & FALTIO)
551 1.37 wrstuden ioflag |= IO_ALTSEMANTICS;
552 1.155 ad if (fflag & FDIRECT)
553 1.125 chs ioflag |= IO_DIRECT;
554 1.50 chs vn_lock(vp, LK_SHARED | LK_RETRY);
555 1.29 thorpej uio->uio_offset = *offset;
556 1.10 cgd count = uio->uio_resid;
557 1.31 kleink error = VOP_READ(vp, uio, ioflag, cred);
558 1.29 thorpej if (flags & FOF_UPDATE_OFFSET)
559 1.29 thorpej *offset += count - uio->uio_resid;
560 1.174 hannken VOP_UNLOCK(vp);
561 1.10 cgd return (error);
562 1.10 cgd }
563 1.10 cgd
564 1.10 cgd /*
565 1.10 cgd * File table vnode write routine.
566 1.10 cgd */
567 1.56 gmcgarry static int
568 1.155 ad vn_write(file_t *fp, off_t *offset, struct uio *uio, kauth_cred_t cred,
569 1.89 thorpej int flags)
570 1.10 cgd {
571 1.191 matt struct vnode *vp = fp->f_vnode;
572 1.185 dholland int error, ioflag, fflag;
573 1.185 dholland size_t count;
574 1.10 cgd
575 1.151 pooka ioflag = IO_ADV_ENCODE(fp->f_advice) | IO_UNIT;
576 1.155 ad fflag = fp->f_flag;
577 1.155 ad if (vp->v_type == VREG && (fflag & O_APPEND))
578 1.10 cgd ioflag |= IO_APPEND;
579 1.155 ad if (fflag & FNONBLOCK)
580 1.10 cgd ioflag |= IO_NDELAY;
581 1.155 ad if (fflag & FFSYNC ||
582 1.24 thorpej (vp->v_mount && (vp->v_mount->mnt_flag & MNT_SYNCHRONOUS)))
583 1.24 thorpej ioflag |= IO_SYNC;
584 1.155 ad else if (fflag & FDSYNC)
585 1.31 kleink ioflag |= IO_DSYNC;
586 1.155 ad if (fflag & FALTIO)
587 1.37 wrstuden ioflag |= IO_ALTSEMANTICS;
588 1.155 ad if (fflag & FDIRECT)
589 1.125 chs ioflag |= IO_DIRECT;
590 1.28 fvdl vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
591 1.29 thorpej uio->uio_offset = *offset;
592 1.10 cgd count = uio->uio_resid;
593 1.171 pooka
594 1.171 pooka if ((error = enforce_rlimit_fsize(vp, uio, ioflag)) != 0)
595 1.171 pooka goto out;
596 1.171 pooka
597 1.10 cgd error = VOP_WRITE(vp, uio, ioflag, cred);
598 1.171 pooka
599 1.29 thorpej if (flags & FOF_UPDATE_OFFSET) {
600 1.160 christos if (ioflag & IO_APPEND) {
601 1.160 christos /*
602 1.160 christos * SUSv3 describes behaviour for count = 0 as following:
603 1.160 christos * "Before any action ... is taken, and if nbyte is zero
604 1.160 christos * and the file is a regular file, the write() function
605 1.160 christos * ... in the absence of errors ... shall return zero
606 1.160 christos * and have no other results."
607 1.160 christos */
608 1.160 christos if (count)
609 1.160 christos *offset = uio->uio_offset;
610 1.160 christos } else
611 1.29 thorpej *offset += count - uio->uio_resid;
612 1.29 thorpej }
613 1.171 pooka
614 1.171 pooka out:
615 1.174 hannken VOP_UNLOCK(vp);
616 1.10 cgd return (error);
617 1.10 cgd }
618 1.10 cgd
619 1.10 cgd /*
620 1.10 cgd * File table vnode stat routine.
621 1.10 cgd */
622 1.48 jdolecek static int
623 1.155 ad vn_statfile(file_t *fp, struct stat *sb)
624 1.48 jdolecek {
625 1.191 matt struct vnode *vp = fp->f_vnode;
626 1.165 christos int error;
627 1.48 jdolecek
628 1.165 christos vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
629 1.165 christos error = vn_stat(vp, sb);
630 1.174 hannken VOP_UNLOCK(vp);
631 1.165 christos return error;
632 1.48 jdolecek }
633 1.48 jdolecek
634 1.20 christos int
635 1.155 ad vn_stat(struct vnode *vp, struct stat *sb)
636 1.10 cgd {
637 1.19 mycroft struct vattr va;
638 1.10 cgd int error;
639 1.35 wrstuden mode_t mode;
640 1.10 cgd
641 1.175 pooka memset(&va, 0, sizeof(va));
642 1.155 ad error = VOP_GETATTR(vp, &va, kauth_cred_get());
643 1.10 cgd if (error)
644 1.10 cgd return (error);
645 1.10 cgd /*
646 1.10 cgd * Copy from vattr table
647 1.10 cgd */
648 1.179 pooka memset(sb, 0, sizeof(*sb));
649 1.19 mycroft sb->st_dev = va.va_fsid;
650 1.19 mycroft sb->st_ino = va.va_fileid;
651 1.19 mycroft mode = va.va_mode;
652 1.10 cgd switch (vp->v_type) {
653 1.10 cgd case VREG:
654 1.10 cgd mode |= S_IFREG;
655 1.10 cgd break;
656 1.10 cgd case VDIR:
657 1.10 cgd mode |= S_IFDIR;
658 1.10 cgd break;
659 1.10 cgd case VBLK:
660 1.10 cgd mode |= S_IFBLK;
661 1.10 cgd break;
662 1.10 cgd case VCHR:
663 1.10 cgd mode |= S_IFCHR;
664 1.10 cgd break;
665 1.10 cgd case VLNK:
666 1.10 cgd mode |= S_IFLNK;
667 1.10 cgd break;
668 1.10 cgd case VSOCK:
669 1.10 cgd mode |= S_IFSOCK;
670 1.10 cgd break;
671 1.10 cgd case VFIFO:
672 1.10 cgd mode |= S_IFIFO;
673 1.10 cgd break;
674 1.10 cgd default:
675 1.10 cgd return (EBADF);
676 1.10 cgd };
677 1.10 cgd sb->st_mode = mode;
678 1.19 mycroft sb->st_nlink = va.va_nlink;
679 1.19 mycroft sb->st_uid = va.va_uid;
680 1.19 mycroft sb->st_gid = va.va_gid;
681 1.19 mycroft sb->st_rdev = va.va_rdev;
682 1.19 mycroft sb->st_size = va.va_size;
683 1.19 mycroft sb->st_atimespec = va.va_atime;
684 1.19 mycroft sb->st_mtimespec = va.va_mtime;
685 1.19 mycroft sb->st_ctimespec = va.va_ctime;
686 1.69 fvdl sb->st_birthtimespec = va.va_birthtime;
687 1.19 mycroft sb->st_blksize = va.va_blocksize;
688 1.19 mycroft sb->st_flags = va.va_flags;
689 1.22 mycroft sb->st_gen = 0;
690 1.19 mycroft sb->st_blocks = va.va_bytes / S_BLKSIZE;
691 1.10 cgd return (0);
692 1.37 wrstuden }
693 1.37 wrstuden
694 1.37 wrstuden /*
695 1.37 wrstuden * File table vnode fcntl routine.
696 1.37 wrstuden */
697 1.56 gmcgarry static int
698 1.155 ad vn_fcntl(file_t *fp, u_int com, void *data)
699 1.37 wrstuden {
700 1.191 matt struct vnode *vp = fp->f_vnode;
701 1.37 wrstuden int error;
702 1.37 wrstuden
703 1.155 ad error = VOP_FCNTL(vp, com, data, fp->f_flag, kauth_cred_get());
704 1.37 wrstuden return (error);
705 1.10 cgd }
706 1.10 cgd
707 1.10 cgd /*
708 1.10 cgd * File table vnode ioctl routine.
709 1.10 cgd */
710 1.56 gmcgarry static int
711 1.155 ad vn_ioctl(file_t *fp, u_long com, void *data)
712 1.10 cgd {
713 1.191 matt struct vnode *vp = fp->f_vnode, *ovp;
714 1.10 cgd struct vattr vattr;
715 1.10 cgd int error;
716 1.10 cgd
717 1.10 cgd switch (vp->v_type) {
718 1.10 cgd
719 1.10 cgd case VREG:
720 1.10 cgd case VDIR:
721 1.10 cgd if (com == FIONREAD) {
722 1.183 hannken vn_lock(vp, LK_SHARED | LK_RETRY);
723 1.183 hannken error = VOP_GETATTR(vp, &vattr, kauth_cred_get());
724 1.183 hannken VOP_UNLOCK(vp);
725 1.20 christos if (error)
726 1.10 cgd return (error);
727 1.10 cgd *(int *)data = vattr.va_size - fp->f_offset;
728 1.10 cgd return (0);
729 1.60 atatat }
730 1.82 christos if ((com == FIONWRITE) || (com == FIONSPACE)) {
731 1.81 wrstuden /*
732 1.81 wrstuden * Files don't have send queues, so there never
733 1.81 wrstuden * are any bytes in them, nor is there any
734 1.81 wrstuden * open space in them.
735 1.81 wrstuden */
736 1.81 wrstuden *(int *)data = 0;
737 1.81 wrstuden return (0);
738 1.81 wrstuden }
739 1.60 atatat if (com == FIOGETBMAP) {
740 1.60 atatat daddr_t *block;
741 1.60 atatat
742 1.62 atatat if (*(daddr_t *)data < 0)
743 1.62 atatat return (EINVAL);
744 1.60 atatat block = (daddr_t *)data;
745 1.60 atatat return (VOP_BMAP(vp, *block, NULL, block, NULL));
746 1.61 fvdl }
747 1.61 fvdl if (com == OFIOGETBMAP) {
748 1.61 fvdl daddr_t ibn, obn;
749 1.61 fvdl
750 1.62 atatat if (*(int32_t *)data < 0)
751 1.62 atatat return (EINVAL);
752 1.61 fvdl ibn = (daddr_t)*(int32_t *)data;
753 1.61 fvdl error = VOP_BMAP(vp, ibn, NULL, &obn, NULL);
754 1.61 fvdl *(int32_t *)data = (int32_t)obn;
755 1.61 fvdl return error;
756 1.10 cgd }
757 1.10 cgd if (com == FIONBIO || com == FIOASYNC) /* XXX */
758 1.10 cgd return (0); /* XXX */
759 1.10 cgd /* fall into ... */
760 1.10 cgd case VFIFO:
761 1.10 cgd case VCHR:
762 1.10 cgd case VBLK:
763 1.155 ad error = VOP_IOCTL(vp, com, data, fp->f_flag,
764 1.155 ad kauth_cred_get());
765 1.10 cgd if (error == 0 && com == TIOCSCTTY) {
766 1.169 pooka vref(vp);
767 1.156 ad mutex_enter(proc_lock);
768 1.155 ad ovp = curproc->p_session->s_ttyvp;
769 1.155 ad curproc->p_session->s_ttyvp = vp;
770 1.156 ad mutex_exit(proc_lock);
771 1.132 ad if (ovp != NULL)
772 1.132 ad vrele(ovp);
773 1.10 cgd }
774 1.10 cgd return (error);
775 1.63 perseant
776 1.63 perseant default:
777 1.63 perseant return (EPASSTHROUGH);
778 1.10 cgd }
779 1.10 cgd }
780 1.10 cgd
781 1.10 cgd /*
782 1.21 mycroft * File table vnode poll routine.
783 1.10 cgd */
784 1.56 gmcgarry static int
785 1.155 ad vn_poll(file_t *fp, int events)
786 1.10 cgd {
787 1.10 cgd
788 1.191 matt return (VOP_POLL(fp->f_vnode, events));
789 1.57 jdolecek }
790 1.57 jdolecek
791 1.57 jdolecek /*
792 1.57 jdolecek * File table vnode kqfilter routine.
793 1.57 jdolecek */
794 1.57 jdolecek int
795 1.155 ad vn_kqfilter(file_t *fp, struct knote *kn)
796 1.57 jdolecek {
797 1.57 jdolecek
798 1.191 matt return (VOP_KQFILTER(fp->f_vnode, kn));
799 1.28 fvdl }
800 1.28 fvdl
801 1.192 chs static int
802 1.192 chs vn_mmap(struct file *fp, off_t *offp, size_t size, int prot, int *flagsp,
803 1.192 chs int *advicep, struct uvm_object **uobjp, int *maxprotp)
804 1.192 chs {
805 1.192 chs struct uvm_object *uobj;
806 1.192 chs struct vnode *vp;
807 1.192 chs struct vattr va;
808 1.192 chs struct lwp *l;
809 1.192 chs vm_prot_t maxprot;
810 1.192 chs off_t off;
811 1.192 chs int error, flags;
812 1.192 chs bool needwritemap;
813 1.192 chs
814 1.192 chs l = curlwp;
815 1.192 chs
816 1.192 chs off = *offp;
817 1.192 chs flags = *flagsp;
818 1.192 chs maxprot = VM_PROT_EXECUTE;
819 1.192 chs
820 1.192 chs vp = fp->f_vnode;
821 1.192 chs if (vp->v_type != VREG && vp->v_type != VCHR &&
822 1.192 chs vp->v_type != VBLK) {
823 1.192 chs /* only REG/CHR/BLK support mmap */
824 1.192 chs return ENODEV;
825 1.192 chs }
826 1.192 chs if (vp->v_type != VCHR && off < 0) {
827 1.192 chs return EINVAL;
828 1.192 chs }
829 1.192 chs if (vp->v_type != VCHR && (off_t)(off + size) < off) {
830 1.192 chs /* no offset wrapping */
831 1.192 chs return EOVERFLOW;
832 1.192 chs }
833 1.192 chs
834 1.192 chs /* special case: catch SunOS style /dev/zero */
835 1.192 chs if (vp->v_type == VCHR &&
836 1.192 chs (vp->v_rdev == zerodev || COMPAT_ZERODEV(vp->v_rdev))) {
837 1.192 chs *uobjp = NULL;
838 1.192 chs *maxprotp = VM_PROT_ALL;
839 1.192 chs return 0;
840 1.192 chs }
841 1.192 chs
842 1.192 chs /*
843 1.192 chs * Old programs may not select a specific sharing type, so
844 1.192 chs * default to an appropriate one.
845 1.192 chs *
846 1.192 chs * XXX: how does MAP_ANON fit in the picture?
847 1.192 chs */
848 1.192 chs if ((flags & (MAP_SHARED|MAP_PRIVATE)) == 0) {
849 1.192 chs #if defined(DEBUG)
850 1.192 chs struct proc *p = l->l_proc;
851 1.192 chs printf("WARNING: defaulted mmap() share type to "
852 1.192 chs "%s (pid %d command %s)\n", vp->v_type == VCHR ?
853 1.192 chs "MAP_SHARED" : "MAP_PRIVATE", p->p_pid,
854 1.192 chs p->p_comm);
855 1.192 chs #endif
856 1.192 chs if (vp->v_type == VCHR)
857 1.192 chs flags |= MAP_SHARED; /* for a device */
858 1.192 chs else
859 1.192 chs flags |= MAP_PRIVATE; /* for a file */
860 1.192 chs }
861 1.192 chs
862 1.192 chs /*
863 1.192 chs * MAP_PRIVATE device mappings don't make sense (and aren't
864 1.192 chs * supported anyway). However, some programs rely on this,
865 1.192 chs * so just change it to MAP_SHARED.
866 1.192 chs */
867 1.192 chs if (vp->v_type == VCHR && (flags & MAP_PRIVATE) != 0) {
868 1.192 chs flags = (flags & ~MAP_PRIVATE) | MAP_SHARED;
869 1.192 chs }
870 1.192 chs
871 1.192 chs /*
872 1.192 chs * now check protection
873 1.192 chs */
874 1.192 chs
875 1.192 chs /* check read access */
876 1.192 chs if (fp->f_flag & FREAD)
877 1.192 chs maxprot |= VM_PROT_READ;
878 1.192 chs else if (prot & PROT_READ) {
879 1.192 chs return EACCES;
880 1.192 chs }
881 1.192 chs
882 1.192 chs /* check write access, shared case first */
883 1.192 chs if (flags & MAP_SHARED) {
884 1.192 chs /*
885 1.192 chs * if the file is writable, only add PROT_WRITE to
886 1.192 chs * maxprot if the file is not immutable, append-only.
887 1.192 chs * otherwise, if we have asked for PROT_WRITE, return
888 1.192 chs * EPERM.
889 1.192 chs */
890 1.192 chs if (fp->f_flag & FWRITE) {
891 1.192 chs vn_lock(vp, LK_SHARED | LK_RETRY);
892 1.192 chs error = VOP_GETATTR(vp, &va, l->l_cred);
893 1.192 chs VOP_UNLOCK(vp);
894 1.192 chs if (error) {
895 1.192 chs return error;
896 1.192 chs }
897 1.192 chs if ((va.va_flags &
898 1.192 chs (SF_SNAPSHOT|IMMUTABLE|APPEND)) == 0)
899 1.192 chs maxprot |= VM_PROT_WRITE;
900 1.192 chs else if (prot & PROT_WRITE) {
901 1.192 chs return EPERM;
902 1.192 chs }
903 1.192 chs } else if (prot & PROT_WRITE) {
904 1.192 chs return EACCES;
905 1.192 chs }
906 1.192 chs } else {
907 1.192 chs /* MAP_PRIVATE mappings can always write to */
908 1.192 chs maxprot |= VM_PROT_WRITE;
909 1.192 chs }
910 1.192 chs
911 1.192 chs /*
912 1.192 chs * Don't allow mmap for EXEC if the file system
913 1.192 chs * is mounted NOEXEC.
914 1.192 chs */
915 1.192 chs if ((prot & PROT_EXEC) != 0 &&
916 1.192 chs (vp->v_mount->mnt_flag & MNT_NOEXEC) != 0) {
917 1.192 chs return EACCES;
918 1.192 chs }
919 1.192 chs
920 1.192 chs if (vp->v_type != VCHR) {
921 1.192 chs error = VOP_MMAP(vp, prot, curlwp->l_cred);
922 1.192 chs if (error) {
923 1.192 chs return error;
924 1.192 chs }
925 1.192 chs vref(vp);
926 1.192 chs uobj = &vp->v_uobj;
927 1.192 chs
928 1.192 chs /*
929 1.192 chs * If the vnode is being mapped with PROT_EXEC,
930 1.192 chs * then mark it as text.
931 1.192 chs */
932 1.192 chs if (prot & PROT_EXEC) {
933 1.192 chs vn_markexec(vp);
934 1.192 chs }
935 1.192 chs } else {
936 1.192 chs int i = maxprot;
937 1.192 chs
938 1.192 chs /*
939 1.192 chs * XXX Some devices don't like to be mapped with
940 1.192 chs * XXX PROT_EXEC or PROT_WRITE, but we don't really
941 1.192 chs * XXX have a better way of handling this, right now
942 1.192 chs */
943 1.192 chs do {
944 1.192 chs uobj = udv_attach(vp->v_rdev,
945 1.192 chs (flags & MAP_SHARED) ? i :
946 1.192 chs (i & ~VM_PROT_WRITE), off, size);
947 1.192 chs i--;
948 1.192 chs } while ((uobj == NULL) && (i > 0));
949 1.192 chs if (uobj == NULL) {
950 1.192 chs return EINVAL;
951 1.192 chs }
952 1.192 chs *advicep = UVM_ADV_RANDOM;
953 1.192 chs }
954 1.192 chs
955 1.192 chs /*
956 1.192 chs * Set vnode flags to indicate the new kinds of mapping.
957 1.192 chs * We take the vnode lock in exclusive mode here to serialize
958 1.192 chs * with direct I/O.
959 1.192 chs *
960 1.192 chs * Safe to check for these flag values without a lock, as
961 1.192 chs * long as a reference to the vnode is held.
962 1.192 chs */
963 1.192 chs needwritemap = (vp->v_iflag & VI_WRMAP) == 0 &&
964 1.192 chs (flags & MAP_SHARED) != 0 &&
965 1.192 chs (maxprot & VM_PROT_WRITE) != 0;
966 1.192 chs if ((vp->v_vflag & VV_MAPPED) == 0 || needwritemap) {
967 1.192 chs vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
968 1.192 chs vp->v_vflag |= VV_MAPPED;
969 1.192 chs if (needwritemap) {
970 1.192 chs mutex_enter(vp->v_interlock);
971 1.192 chs vp->v_iflag |= VI_WRMAP;
972 1.192 chs mutex_exit(vp->v_interlock);
973 1.192 chs }
974 1.192 chs VOP_UNLOCK(vp);
975 1.192 chs }
976 1.192 chs
977 1.192 chs #if NVERIEXEC > 0
978 1.192 chs
979 1.192 chs /*
980 1.192 chs * Check if the file can be executed indirectly.
981 1.192 chs *
982 1.192 chs * XXX: This gives false warnings about "Incorrect access type"
983 1.192 chs * XXX: if the mapping is not executable. Harmless, but will be
984 1.192 chs * XXX: fixed as part of other changes.
985 1.192 chs */
986 1.192 chs if (veriexec_verify(l, vp, "(mmap)", VERIEXEC_INDIRECT,
987 1.192 chs NULL)) {
988 1.192 chs
989 1.192 chs /*
990 1.192 chs * Don't allow executable mappings if we can't
991 1.192 chs * indirectly execute the file.
992 1.192 chs */
993 1.192 chs if (prot & VM_PROT_EXECUTE) {
994 1.192 chs return EPERM;
995 1.192 chs }
996 1.192 chs
997 1.192 chs /*
998 1.192 chs * Strip the executable bit from 'maxprot' to make sure
999 1.192 chs * it can't be made executable later.
1000 1.192 chs */
1001 1.192 chs maxprot &= ~VM_PROT_EXECUTE;
1002 1.192 chs }
1003 1.192 chs #endif /* NVERIEXEC > 0 */
1004 1.192 chs
1005 1.192 chs *uobjp = uobj;
1006 1.192 chs *maxprotp = maxprot;
1007 1.192 chs *flagsp = flags;
1008 1.192 chs
1009 1.192 chs return 0;
1010 1.192 chs }
1011 1.192 chs
1012 1.192 chs
1013 1.192 chs
1014 1.28 fvdl /*
1015 1.28 fvdl * Check that the vnode is still valid, and if so
1016 1.28 fvdl * acquire requested lock.
1017 1.28 fvdl */
1018 1.28 fvdl int
1019 1.89 thorpej vn_lock(struct vnode *vp, int flags)
1020 1.28 fvdl {
1021 1.28 fvdl int error;
1022 1.34 sommerfe
1023 1.84 yamt #if 0
1024 1.176 hannken KASSERT(vp->v_usecount > 0 || (vp->v_iflag & VI_ONWORKLST) != 0);
1025 1.84 yamt #endif
1026 1.176 hannken KASSERT((flags & ~(LK_SHARED|LK_EXCLUSIVE|LK_NOWAIT|LK_RETRY)) == 0);
1027 1.181 rmind KASSERT(!mutex_owned(vp->v_interlock));
1028 1.80 yamt
1029 1.159 simonb #ifdef DIAGNOSTIC
1030 1.159 simonb if (wapbl_vphaswapbl(vp))
1031 1.159 simonb WAPBL_JUNLOCK_ASSERT(wapbl_vptomp(vp));
1032 1.159 simonb #endif
1033 1.159 simonb
1034 1.189 hannken error = VOP_LOCK(vp, flags);
1035 1.189 hannken if ((flags & LK_RETRY) != 0 && error == ENOENT)
1036 1.189 hannken error = VOP_LOCK(vp, flags);
1037 1.189 hannken
1038 1.189 hannken KASSERT((flags & LK_RETRY) == 0 || (flags & LK_NOWAIT) != 0 ||
1039 1.189 hannken error == 0);
1040 1.189 hannken
1041 1.189 hannken return error;
1042 1.10 cgd }
1043 1.10 cgd
1044 1.10 cgd /*
1045 1.10 cgd * File table vnode close routine.
1046 1.10 cgd */
1047 1.56 gmcgarry static int
1048 1.155 ad vn_closefile(file_t *fp)
1049 1.10 cgd {
1050 1.10 cgd
1051 1.191 matt return vn_close(fp->f_vnode, fp->f_flag, fp->f_cred);
1052 1.39 fvdl }
1053 1.39 fvdl
1054 1.39 fvdl /*
1055 1.85 thorpej * Simplified in-kernel wrapper calls for extended attribute access.
1056 1.85 thorpej * Both calls pass in a NULL credential, authorizing a "kernel" access.
1057 1.85 thorpej * Set IO_NODELOCKED in ioflg if the vnode is already locked.
1058 1.85 thorpej */
1059 1.85 thorpej int
1060 1.85 thorpej vn_extattr_get(struct vnode *vp, int ioflg, int attrnamespace,
1061 1.101 christos const char *attrname, size_t *buflen, void *bf, struct lwp *l)
1062 1.85 thorpej {
1063 1.85 thorpej struct uio auio;
1064 1.85 thorpej struct iovec aiov;
1065 1.85 thorpej int error;
1066 1.85 thorpej
1067 1.85 thorpej aiov.iov_len = *buflen;
1068 1.88 christos aiov.iov_base = bf;
1069 1.85 thorpej
1070 1.85 thorpej auio.uio_iov = &aiov;
1071 1.85 thorpej auio.uio_iovcnt = 1;
1072 1.85 thorpej auio.uio_rw = UIO_READ;
1073 1.85 thorpej auio.uio_offset = 0;
1074 1.85 thorpej auio.uio_resid = *buflen;
1075 1.106 yamt UIO_SETUP_SYSSPACE(&auio);
1076 1.85 thorpej
1077 1.85 thorpej if ((ioflg & IO_NODELOCKED) == 0)
1078 1.85 thorpej vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
1079 1.86 perry
1080 1.144 pooka error = VOP_GETEXTATTR(vp, attrnamespace, attrname, &auio, NULL, NULL);
1081 1.86 perry
1082 1.85 thorpej if ((ioflg & IO_NODELOCKED) == 0)
1083 1.174 hannken VOP_UNLOCK(vp);
1084 1.86 perry
1085 1.85 thorpej if (error == 0)
1086 1.85 thorpej *buflen = *buflen - auio.uio_resid;
1087 1.86 perry
1088 1.85 thorpej return (error);
1089 1.85 thorpej }
1090 1.85 thorpej
1091 1.85 thorpej /*
1092 1.85 thorpej * XXX Failure mode if partially written?
1093 1.85 thorpej */
1094 1.85 thorpej int
1095 1.85 thorpej vn_extattr_set(struct vnode *vp, int ioflg, int attrnamespace,
1096 1.101 christos const char *attrname, size_t buflen, const void *bf, struct lwp *l)
1097 1.85 thorpej {
1098 1.85 thorpej struct uio auio;
1099 1.85 thorpej struct iovec aiov;
1100 1.85 thorpej int error;
1101 1.85 thorpej
1102 1.85 thorpej aiov.iov_len = buflen;
1103 1.88 christos aiov.iov_base = __UNCONST(bf); /* XXXUNCONST kills const */
1104 1.85 thorpej
1105 1.85 thorpej auio.uio_iov = &aiov;
1106 1.85 thorpej auio.uio_iovcnt = 1;
1107 1.85 thorpej auio.uio_rw = UIO_WRITE;
1108 1.85 thorpej auio.uio_offset = 0;
1109 1.85 thorpej auio.uio_resid = buflen;
1110 1.106 yamt UIO_SETUP_SYSSPACE(&auio);
1111 1.85 thorpej
1112 1.85 thorpej if ((ioflg & IO_NODELOCKED) == 0) {
1113 1.85 thorpej vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
1114 1.85 thorpej }
1115 1.85 thorpej
1116 1.144 pooka error = VOP_SETEXTATTR(vp, attrnamespace, attrname, &auio, NULL);
1117 1.85 thorpej
1118 1.85 thorpej if ((ioflg & IO_NODELOCKED) == 0) {
1119 1.174 hannken VOP_UNLOCK(vp);
1120 1.85 thorpej }
1121 1.85 thorpej
1122 1.85 thorpej return (error);
1123 1.85 thorpej }
1124 1.85 thorpej
1125 1.85 thorpej int
1126 1.85 thorpej vn_extattr_rm(struct vnode *vp, int ioflg, int attrnamespace,
1127 1.101 christos const char *attrname, struct lwp *l)
1128 1.85 thorpej {
1129 1.85 thorpej int error;
1130 1.85 thorpej
1131 1.85 thorpej if ((ioflg & IO_NODELOCKED) == 0) {
1132 1.85 thorpej vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
1133 1.85 thorpej }
1134 1.85 thorpej
1135 1.144 pooka error = VOP_DELETEEXTATTR(vp, attrnamespace, attrname, NULL);
1136 1.85 thorpej if (error == EOPNOTSUPP)
1137 1.144 pooka error = VOP_SETEXTATTR(vp, attrnamespace, attrname, NULL, NULL);
1138 1.86 perry
1139 1.85 thorpej if ((ioflg & IO_NODELOCKED) == 0) {
1140 1.174 hannken VOP_UNLOCK(vp);
1141 1.85 thorpej }
1142 1.85 thorpej
1143 1.85 thorpej return (error);
1144 1.85 thorpej }
1145 1.95 yamt
1146 1.100 yamt void
1147 1.100 yamt vn_ra_allocctx(struct vnode *vp)
1148 1.100 yamt {
1149 1.100 yamt struct uvm_ractx *ra = NULL;
1150 1.100 yamt
1151 1.181 rmind KASSERT(mutex_owned(vp->v_interlock));
1152 1.149 ad
1153 1.100 yamt if (vp->v_type != VREG) {
1154 1.100 yamt return;
1155 1.100 yamt }
1156 1.100 yamt if (vp->v_ractx != NULL) {
1157 1.100 yamt return;
1158 1.100 yamt }
1159 1.100 yamt if (vp->v_ractx == NULL) {
1160 1.181 rmind mutex_exit(vp->v_interlock);
1161 1.100 yamt ra = uvm_ra_allocctx();
1162 1.181 rmind mutex_enter(vp->v_interlock);
1163 1.100 yamt if (ra != NULL && vp->v_ractx == NULL) {
1164 1.100 yamt vp->v_ractx = ra;
1165 1.100 yamt ra = NULL;
1166 1.100 yamt }
1167 1.100 yamt }
1168 1.100 yamt if (ra != NULL) {
1169 1.100 yamt uvm_ra_freectx(ra);
1170 1.100 yamt }
1171 1.100 yamt }
1172 1.170 pooka
1173 1.170 pooka int
1174 1.170 pooka vn_fifo_bypass(void *v)
1175 1.170 pooka {
1176 1.170 pooka struct vop_generic_args *ap = v;
1177 1.170 pooka
1178 1.170 pooka return VOCALL(fifo_vnodeop_p, ap->a_desc->vdesc_offset, v);
1179 1.170 pooka }
1180