lfs_vnops.c revision 1.321.4.1 1 /* $NetBSD: lfs_vnops.c,v 1.321.4.1 2019/06/10 22:09:58 christos Exp $ */
2
3 /*-
4 * Copyright (c) 1999, 2000, 2001, 2002, 2003 The NetBSD Foundation, Inc.
5 * All rights reserved.
6 *
7 * This code is derived from software contributed to The NetBSD Foundation
8 * by Konrad E. Schroder <perseant (at) hhhh.org>.
9 *
10 * Redistribution and use in source and binary forms, with or without
11 * modification, are permitted provided that the following conditions
12 * are met:
13 * 1. Redistributions of source code must retain the above copyright
14 * notice, this list of conditions and the following disclaimer.
15 * 2. Redistributions in binary form must reproduce the above copyright
16 * notice, this list of conditions and the following disclaimer in the
17 * documentation and/or other materials provided with the distribution.
18 *
19 * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
20 * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
21 * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
22 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
23 * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
24 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
25 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
26 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
27 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
28 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
29 * POSSIBILITY OF SUCH DAMAGE.
30 */
31 /*
32 * Copyright (c) 1986, 1989, 1991, 1993, 1995
33 * The Regents of the University of California. All rights reserved.
34 *
35 * Redistribution and use in source and binary forms, with or without
36 * modification, are permitted provided that the following conditions
37 * are met:
38 * 1. Redistributions of source code must retain the above copyright
39 * notice, this list of conditions and the following disclaimer.
40 * 2. Redistributions in binary form must reproduce the above copyright
41 * notice, this list of conditions and the following disclaimer in the
42 * documentation and/or other materials provided with the distribution.
43 * 3. Neither the name of the University nor the names of its contributors
44 * may be used to endorse or promote products derived from this software
45 * without specific prior written permission.
46 *
47 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
48 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
49 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
50 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
51 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
52 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
53 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
54 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
55 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
56 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
57 * SUCH DAMAGE.
58 *
59 * @(#)lfs_vnops.c 8.13 (Berkeley) 6/10/95
60 */
61
62 /* from NetBSD: ufs_vnops.c,v 1.232 2016/05/19 18:32:03 riastradh Exp */
63 /*-
64 * Copyright (c) 2008 The NetBSD Foundation, Inc.
65 * All rights reserved.
66 *
67 * This code is derived from software contributed to The NetBSD Foundation
68 * by Wasabi Systems, Inc.
69 *
70 * Redistribution and use in source and binary forms, with or without
71 * modification, are permitted provided that the following conditions
72 * are met:
73 * 1. Redistributions of source code must retain the above copyright
74 * notice, this list of conditions and the following disclaimer.
75 * 2. Redistributions in binary form must reproduce the above copyright
76 * notice, this list of conditions and the following disclaimer in the
77 * documentation and/or other materials provided with the distribution.
78 *
79 * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
80 * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
81 * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
82 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
83 * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
84 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
85 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
86 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
87 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
88 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
89 * POSSIBILITY OF SUCH DAMAGE.
90 */
91 /*
92 * Copyright (c) 1982, 1986, 1989, 1993, 1995
93 * The Regents of the University of California. All rights reserved.
94 * (c) UNIX System Laboratories, Inc.
95 * All or some portions of this file are derived from material licensed
96 * to the University of California by American Telephone and Telegraph
97 * Co. or Unix System Laboratories, Inc. and are reproduced herein with
98 * the permission of UNIX System Laboratories, Inc.
99 *
100 * Redistribution and use in source and binary forms, with or without
101 * modification, are permitted provided that the following conditions
102 * are met:
103 * 1. Redistributions of source code must retain the above copyright
104 * notice, this list of conditions and the following disclaimer.
105 * 2. Redistributions in binary form must reproduce the above copyright
106 * notice, this list of conditions and the following disclaimer in the
107 * documentation and/or other materials provided with the distribution.
108 * 3. Neither the name of the University nor the names of its contributors
109 * may be used to endorse or promote products derived from this software
110 * without specific prior written permission.
111 *
112 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
113 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
114 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
115 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
116 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
117 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
118 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
119 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
120 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
121 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
122 * SUCH DAMAGE.
123 *
124 * @(#)ufs_vnops.c 8.28 (Berkeley) 7/31/95
125 */
126
127 #include <sys/cdefs.h>
128 __KERNEL_RCSID(0, "$NetBSD: lfs_vnops.c,v 1.321.4.1 2019/06/10 22:09:58 christos Exp $");
129
130 #ifdef _KERNEL_OPT
131 #include "opt_compat_netbsd.h"
132 #include "opt_uvm_page_trkown.h"
133 #endif
134
135 #include <sys/param.h>
136 #include <sys/systm.h>
137 #include <sys/namei.h>
138 #include <sys/resourcevar.h>
139 #include <sys/kernel.h>
140 #include <sys/file.h>
141 #include <sys/stat.h>
142 #include <sys/buf.h>
143 #include <sys/proc.h>
144 #include <sys/mount.h>
145 #include <sys/vnode.h>
146 #include <sys/pool.h>
147 #include <sys/signalvar.h>
148 #include <sys/kauth.h>
149 #include <sys/syslog.h>
150
151 #include <miscfs/fifofs/fifo.h>
152 #include <miscfs/genfs/genfs.h>
153 #include <miscfs/specfs/specdev.h>
154
155 #include <ufs/lfs/ulfs_inode.h>
156 #include <ufs/lfs/ulfsmount.h>
157 #include <ufs/lfs/ulfs_bswap.h>
158 #include <ufs/lfs/ulfs_extern.h>
159
160 #include <uvm/uvm.h>
161 #include <uvm/uvm_pmap.h>
162 #include <uvm/uvm_stat.h>
163 #include <uvm/uvm_pager.h>
164
165 #include <ufs/lfs/lfs.h>
166 #include <ufs/lfs/lfs_accessors.h>
167 #include <ufs/lfs/lfs_kernel.h>
168 #include <ufs/lfs/lfs_extern.h>
169
170 extern kcondvar_t lfs_writerd_cv;
171 int lfs_ignore_lazy_sync = 1;
172
173 static int lfs_openextattr(void *v);
174 static int lfs_closeextattr(void *v);
175 static int lfs_getextattr(void *v);
176 static int lfs_setextattr(void *v);
177 static int lfs_listextattr(void *v);
178 static int lfs_deleteextattr(void *v);
179
180 static int lfs_makeinode(struct vattr *vap, struct vnode *,
181 const struct ulfs_lookup_results *,
182 struct vnode **, struct componentname *);
183
184 /* Global vfs data structures for lfs. */
185 int (**lfs_vnodeop_p)(void *);
186 const struct vnodeopv_entry_desc lfs_vnodeop_entries[] = {
187 { &vop_default_desc, vn_default_error },
188 { &vop_lookup_desc, ulfs_lookup }, /* lookup */
189 { &vop_create_desc, lfs_create }, /* create */
190 { &vop_whiteout_desc, ulfs_whiteout }, /* whiteout */
191 { &vop_mknod_desc, lfs_mknod }, /* mknod */
192 { &vop_open_desc, ulfs_open }, /* open */
193 { &vop_close_desc, lfs_close }, /* close */
194 { &vop_access_desc, ulfs_access }, /* access */
195 { &vop_getattr_desc, lfs_getattr }, /* getattr */
196 { &vop_setattr_desc, lfs_setattr }, /* setattr */
197 { &vop_read_desc, lfs_read }, /* read */
198 { &vop_write_desc, lfs_write }, /* write */
199 { &vop_fallocate_desc, genfs_eopnotsupp }, /* fallocate */
200 { &vop_fdiscard_desc, genfs_eopnotsupp }, /* fdiscard */
201 { &vop_ioctl_desc, ulfs_ioctl }, /* ioctl */
202 { &vop_fcntl_desc, lfs_fcntl }, /* fcntl */
203 { &vop_poll_desc, ulfs_poll }, /* poll */
204 { &vop_kqfilter_desc, genfs_kqfilter }, /* kqfilter */
205 { &vop_revoke_desc, ulfs_revoke }, /* revoke */
206 { &vop_mmap_desc, lfs_mmap }, /* mmap */
207 { &vop_fsync_desc, lfs_fsync }, /* fsync */
208 { &vop_seek_desc, ulfs_seek }, /* seek */
209 { &vop_remove_desc, lfs_remove }, /* remove */
210 { &vop_link_desc, lfs_link }, /* link */
211 { &vop_rename_desc, lfs_rename }, /* rename */
212 { &vop_mkdir_desc, lfs_mkdir }, /* mkdir */
213 { &vop_rmdir_desc, lfs_rmdir }, /* rmdir */
214 { &vop_symlink_desc, lfs_symlink }, /* symlink */
215 { &vop_readdir_desc, ulfs_readdir }, /* readdir */
216 { &vop_readlink_desc, ulfs_readlink }, /* readlink */
217 { &vop_abortop_desc, ulfs_abortop }, /* abortop */
218 { &vop_inactive_desc, lfs_inactive }, /* inactive */
219 { &vop_reclaim_desc, lfs_reclaim }, /* reclaim */
220 { &vop_lock_desc, ulfs_lock }, /* lock */
221 { &vop_unlock_desc, ulfs_unlock }, /* unlock */
222 { &vop_bmap_desc, ulfs_bmap }, /* bmap */
223 { &vop_strategy_desc, lfs_strategy }, /* strategy */
224 { &vop_print_desc, ulfs_print }, /* print */
225 { &vop_islocked_desc, ulfs_islocked }, /* islocked */
226 { &vop_pathconf_desc, ulfs_pathconf }, /* pathconf */
227 { &vop_advlock_desc, ulfs_advlock }, /* advlock */
228 { &vop_bwrite_desc, lfs_bwrite }, /* bwrite */
229 { &vop_getpages_desc, lfs_getpages }, /* getpages */
230 { &vop_putpages_desc, lfs_putpages }, /* putpages */
231 { &vop_openextattr_desc, lfs_openextattr }, /* openextattr */
232 { &vop_closeextattr_desc, lfs_closeextattr }, /* closeextattr */
233 { &vop_getextattr_desc, lfs_getextattr }, /* getextattr */
234 { &vop_setextattr_desc, lfs_setextattr }, /* setextattr */
235 { &vop_listextattr_desc, lfs_listextattr }, /* listextattr */
236 { &vop_deleteextattr_desc, lfs_deleteextattr }, /* deleteextattr */
237 { NULL, NULL }
238 };
239 const struct vnodeopv_desc lfs_vnodeop_opv_desc =
240 { &lfs_vnodeop_p, lfs_vnodeop_entries };
241
242 int (**lfs_specop_p)(void *);
243 const struct vnodeopv_entry_desc lfs_specop_entries[] = {
244 { &vop_default_desc, vn_default_error },
245 { &vop_lookup_desc, spec_lookup }, /* lookup */
246 { &vop_create_desc, spec_create }, /* create */
247 { &vop_mknod_desc, spec_mknod }, /* mknod */
248 { &vop_open_desc, spec_open }, /* open */
249 { &vop_close_desc, lfsspec_close }, /* close */
250 { &vop_access_desc, ulfs_access }, /* access */
251 { &vop_getattr_desc, lfs_getattr }, /* getattr */
252 { &vop_setattr_desc, lfs_setattr }, /* setattr */
253 { &vop_read_desc, ulfsspec_read }, /* read */
254 { &vop_write_desc, ulfsspec_write }, /* write */
255 { &vop_fallocate_desc, spec_fallocate }, /* fallocate */
256 { &vop_fdiscard_desc, spec_fdiscard }, /* fdiscard */
257 { &vop_ioctl_desc, spec_ioctl }, /* ioctl */
258 { &vop_fcntl_desc, ulfs_fcntl }, /* fcntl */
259 { &vop_poll_desc, spec_poll }, /* poll */
260 { &vop_kqfilter_desc, spec_kqfilter }, /* kqfilter */
261 { &vop_revoke_desc, spec_revoke }, /* revoke */
262 { &vop_mmap_desc, spec_mmap }, /* mmap */
263 { &vop_fsync_desc, spec_fsync }, /* fsync */
264 { &vop_seek_desc, spec_seek }, /* seek */
265 { &vop_remove_desc, spec_remove }, /* remove */
266 { &vop_link_desc, spec_link }, /* link */
267 { &vop_rename_desc, spec_rename }, /* rename */
268 { &vop_mkdir_desc, spec_mkdir }, /* mkdir */
269 { &vop_rmdir_desc, spec_rmdir }, /* rmdir */
270 { &vop_symlink_desc, spec_symlink }, /* symlink */
271 { &vop_readdir_desc, spec_readdir }, /* readdir */
272 { &vop_readlink_desc, spec_readlink }, /* readlink */
273 { &vop_abortop_desc, spec_abortop }, /* abortop */
274 { &vop_inactive_desc, lfs_inactive }, /* inactive */
275 { &vop_reclaim_desc, lfs_reclaim }, /* reclaim */
276 { &vop_lock_desc, ulfs_lock }, /* lock */
277 { &vop_unlock_desc, ulfs_unlock }, /* unlock */
278 { &vop_bmap_desc, spec_bmap }, /* bmap */
279 { &vop_strategy_desc, spec_strategy }, /* strategy */
280 { &vop_print_desc, ulfs_print }, /* print */
281 { &vop_islocked_desc, ulfs_islocked }, /* islocked */
282 { &vop_pathconf_desc, spec_pathconf }, /* pathconf */
283 { &vop_advlock_desc, spec_advlock }, /* advlock */
284 { &vop_bwrite_desc, vn_bwrite }, /* bwrite */
285 { &vop_getpages_desc, spec_getpages }, /* getpages */
286 { &vop_putpages_desc, spec_putpages }, /* putpages */
287 { &vop_openextattr_desc, lfs_openextattr }, /* openextattr */
288 { &vop_closeextattr_desc, lfs_closeextattr }, /* closeextattr */
289 { &vop_getextattr_desc, lfs_getextattr }, /* getextattr */
290 { &vop_setextattr_desc, lfs_setextattr }, /* setextattr */
291 { &vop_listextattr_desc, lfs_listextattr }, /* listextattr */
292 { &vop_deleteextattr_desc, lfs_deleteextattr }, /* deleteextattr */
293 { NULL, NULL }
294 };
295 const struct vnodeopv_desc lfs_specop_opv_desc =
296 { &lfs_specop_p, lfs_specop_entries };
297
298 int (**lfs_fifoop_p)(void *);
299 const struct vnodeopv_entry_desc lfs_fifoop_entries[] = {
300 { &vop_default_desc, vn_default_error },
301 { &vop_lookup_desc, vn_fifo_bypass }, /* lookup */
302 { &vop_create_desc, vn_fifo_bypass }, /* create */
303 { &vop_mknod_desc, vn_fifo_bypass }, /* mknod */
304 { &vop_open_desc, vn_fifo_bypass }, /* open */
305 { &vop_close_desc, lfsfifo_close }, /* close */
306 { &vop_access_desc, ulfs_access }, /* access */
307 { &vop_getattr_desc, lfs_getattr }, /* getattr */
308 { &vop_setattr_desc, lfs_setattr }, /* setattr */
309 { &vop_read_desc, ulfsfifo_read }, /* read */
310 { &vop_write_desc, ulfsfifo_write }, /* write */
311 { &vop_fallocate_desc, vn_fifo_bypass }, /* fallocate */
312 { &vop_fdiscard_desc, vn_fifo_bypass }, /* fdiscard */
313 { &vop_ioctl_desc, vn_fifo_bypass }, /* ioctl */
314 { &vop_fcntl_desc, ulfs_fcntl }, /* fcntl */
315 { &vop_poll_desc, vn_fifo_bypass }, /* poll */
316 { &vop_kqfilter_desc, vn_fifo_bypass }, /* kqfilter */
317 { &vop_revoke_desc, vn_fifo_bypass }, /* revoke */
318 { &vop_mmap_desc, vn_fifo_bypass }, /* mmap */
319 { &vop_fsync_desc, vn_fifo_bypass }, /* fsync */
320 { &vop_seek_desc, vn_fifo_bypass }, /* seek */
321 { &vop_remove_desc, vn_fifo_bypass }, /* remove */
322 { &vop_link_desc, vn_fifo_bypass }, /* link */
323 { &vop_rename_desc, vn_fifo_bypass }, /* rename */
324 { &vop_mkdir_desc, vn_fifo_bypass }, /* mkdir */
325 { &vop_rmdir_desc, vn_fifo_bypass }, /* rmdir */
326 { &vop_symlink_desc, vn_fifo_bypass }, /* symlink */
327 { &vop_readdir_desc, vn_fifo_bypass }, /* readdir */
328 { &vop_readlink_desc, vn_fifo_bypass }, /* readlink */
329 { &vop_abortop_desc, vn_fifo_bypass }, /* abortop */
330 { &vop_inactive_desc, lfs_inactive }, /* inactive */
331 { &vop_reclaim_desc, lfs_reclaim }, /* reclaim */
332 { &vop_lock_desc, ulfs_lock }, /* lock */
333 { &vop_unlock_desc, ulfs_unlock }, /* unlock */
334 { &vop_bmap_desc, vn_fifo_bypass }, /* bmap */
335 { &vop_strategy_desc, vn_fifo_bypass }, /* strategy */
336 { &vop_print_desc, ulfs_print }, /* print */
337 { &vop_islocked_desc, ulfs_islocked }, /* islocked */
338 { &vop_pathconf_desc, vn_fifo_bypass }, /* pathconf */
339 { &vop_advlock_desc, vn_fifo_bypass }, /* advlock */
340 { &vop_bwrite_desc, lfs_bwrite }, /* bwrite */
341 { &vop_putpages_desc, vn_fifo_bypass }, /* putpages */
342 { &vop_openextattr_desc, lfs_openextattr }, /* openextattr */
343 { &vop_closeextattr_desc, lfs_closeextattr }, /* closeextattr */
344 { &vop_getextattr_desc, lfs_getextattr }, /* getextattr */
345 { &vop_setextattr_desc, lfs_setextattr }, /* setextattr */
346 { &vop_listextattr_desc, lfs_listextattr }, /* listextattr */
347 { &vop_deleteextattr_desc, lfs_deleteextattr }, /* deleteextattr */
348 { NULL, NULL }
349 };
350 const struct vnodeopv_desc lfs_fifoop_opv_desc =
351 { &lfs_fifoop_p, lfs_fifoop_entries };
352
353 #define LFS_READWRITE
354 #include <ufs/lfs/ulfs_readwrite.c>
355 #undef LFS_READWRITE
356
357 /*
358 * Allocate a new inode.
359 */
360 static int
361 lfs_makeinode(struct vattr *vap, struct vnode *dvp,
362 const struct ulfs_lookup_results *ulr,
363 struct vnode **vpp, struct componentname *cnp)
364 {
365 struct inode *ip;
366 struct vnode *tvp;
367 int error;
368
369 error = vcache_new(dvp->v_mount, dvp, vap, cnp->cn_cred, NULL, &tvp);
370 if (error)
371 return error;
372 error = vn_lock(tvp, LK_EXCLUSIVE);
373 if (error) {
374 vrele(tvp);
375 return error;
376 }
377 MARK_VNODE(tvp);
378 *vpp = tvp;
379 ip = VTOI(tvp);
380 ip->i_state |= IN_ACCESS | IN_CHANGE | IN_UPDATE;
381 ip->i_nlink = 1;
382 DIP_ASSIGN(ip, nlink, 1);
383
384 /* Authorize setting SGID if needed. */
385 if (ip->i_mode & ISGID) {
386 error = kauth_authorize_vnode(cnp->cn_cred, KAUTH_VNODE_WRITE_SECURITY,
387 tvp, NULL, genfs_can_chmod(tvp->v_type, cnp->cn_cred, ip->i_uid,
388 ip->i_gid, MAKEIMODE(vap->va_type, vap->va_mode)));
389 if (error) {
390 ip->i_mode &= ~ISGID;
391 DIP_ASSIGN(ip, mode, ip->i_mode);
392 }
393 }
394
395 if (cnp->cn_flags & ISWHITEOUT) {
396 ip->i_flags |= UF_OPAQUE;
397 DIP_ASSIGN(ip, flags, ip->i_flags);
398 }
399
400 /*
401 * Make sure inode goes to disk before directory entry.
402 */
403 if ((error = lfs_update(tvp, NULL, NULL, UPDATE_DIROP)) != 0)
404 goto bad;
405 error = ulfs_direnter(dvp, ulr, tvp,
406 cnp, ip->i_number, LFS_IFTODT(ip->i_mode), NULL);
407 if (error)
408 goto bad;
409 *vpp = tvp;
410 KASSERT(VOP_ISLOCKED(*vpp) == LK_EXCLUSIVE);
411 return (0);
412
413 bad:
414 /*
415 * Write error occurred trying to update the inode
416 * or the directory so must deallocate the inode.
417 */
418 ip->i_nlink = 0;
419 DIP_ASSIGN(ip, nlink, 0);
420 ip->i_state |= IN_CHANGE;
421 /* If IN_ADIROP, account for it */
422 UNMARK_VNODE(tvp);
423 vput(tvp);
424 return (error);
425 }
426
427 /*
428 * Synch an open file.
429 */
430 /* ARGSUSED */
431 int
432 lfs_fsync(void *v)
433 {
434 struct vop_fsync_args /* {
435 struct vnode *a_vp;
436 kauth_cred_t a_cred;
437 int a_flags;
438 off_t offlo;
439 off_t offhi;
440 } */ *ap = v;
441 struct vnode *vp = ap->a_vp;
442 int wait;
443 struct inode *ip = VTOI(vp);
444 struct lfs *fs = ip->i_lfs;
445 int error = 0;
446
447 KASSERT(VOP_ISLOCKED(vp) == LK_EXCLUSIVE);
448
449 /* If we're mounted read-only, don't try to sync. */
450 if (fs->lfs_ronly)
451 goto out;
452
453 /* If a removed vnode is being cleaned, no need to sync here. */
454 if ((ap->a_flags & FSYNC_RECLAIM) != 0 && ip->i_mode == 0)
455 goto out;
456
457 /*
458 * Trickle sync simply adds this vnode to the pager list, as if
459 * the pagedaemon had requested a pageout.
460 */
461 if (ap->a_flags & FSYNC_LAZY) {
462 if (lfs_ignore_lazy_sync == 0) {
463 mutex_enter(&lfs_lock);
464 if (!(ip->i_state & IN_PAGING)) {
465 ip->i_state |= IN_PAGING;
466 TAILQ_INSERT_TAIL(&fs->lfs_pchainhd, ip,
467 i_lfs_pchain);
468 }
469 cv_broadcast(&lfs_writerd_cv);
470 mutex_exit(&lfs_lock);
471 }
472 goto out;
473 }
474
475 /*
476 * If a vnode is being cleaned, flush it out before we try to
477 * reuse it. This prevents the cleaner from writing files twice
478 * in the same partial segment, causing an accounting underflow.
479 */
480 if (ap->a_flags & FSYNC_RECLAIM && ip->i_state & IN_CLEANING) {
481 lfs_vflush(vp);
482 }
483
484 wait = (ap->a_flags & FSYNC_WAIT);
485 do {
486 mutex_enter(vp->v_interlock);
487 error = VOP_PUTPAGES(vp, trunc_page(ap->a_offlo),
488 round_page(ap->a_offhi),
489 PGO_CLEANIT | (wait ? PGO_SYNCIO : 0));
490 if (error == EAGAIN) {
491 mutex_enter(&lfs_lock);
492 mtsleep(&fs->lfs_availsleep, PCATCH | PUSER,
493 "lfs_fsync", hz / 100 + 1, &lfs_lock);
494 mutex_exit(&lfs_lock);
495 }
496 } while (error == EAGAIN);
497 if (error)
498 goto out;
499
500 if ((ap->a_flags & FSYNC_DATAONLY) == 0)
501 error = lfs_update(vp, NULL, NULL, wait ? UPDATE_WAIT : 0);
502
503 if (error == 0 && ap->a_flags & FSYNC_CACHE) {
504 int l = 0;
505 error = VOP_IOCTL(ip->i_devvp, DIOCCACHESYNC, &l, FWRITE,
506 curlwp->l_cred);
507 }
508 if (wait && !VPISEMPTY(vp))
509 LFS_SET_UINO(ip, IN_MODIFIED);
510
511 out:
512 KASSERT(VOP_ISLOCKED(vp) == LK_EXCLUSIVE);
513 return error;
514 }
515
516 /*
517 * Take IN_ADIROP off, then call ulfs_inactive.
518 */
519 int
520 lfs_inactive(void *v)
521 {
522 struct vop_inactive_v2_args /* {
523 struct vnode *a_vp;
524 bool *a_recycle;
525 } */ *ap = v;
526
527 KASSERT(VOP_ISLOCKED(ap->a_vp) == LK_EXCLUSIVE);
528
529 UNMARK_VNODE(ap->a_vp);
530
531 /*
532 * The Ifile is only ever inactivated on unmount.
533 * Streamline this process by not giving it more dirty blocks.
534 */
535 if (VTOI(ap->a_vp)->i_number == LFS_IFILE_INUM) {
536 mutex_enter(&lfs_lock);
537 LFS_CLR_UINO(VTOI(ap->a_vp), IN_ALLMOD);
538 mutex_exit(&lfs_lock);
539 return 0;
540 }
541
542 #ifdef DEBUG
543 /*
544 * This might happen on unmount.
545 * XXX If it happens at any other time, it should be a panic.
546 */
547 if (ap->a_vp->v_uflag & VU_DIROP) {
548 struct inode *ip = VTOI(ap->a_vp);
549 printf("lfs_inactive: inactivating VU_DIROP? ino = %llu\n",
550 (unsigned long long) ip->i_number);
551 }
552 #endif /* DIAGNOSTIC */
553
554 return ulfs_inactive(v);
555 }
556
557 int
558 lfs_set_dirop(struct vnode *dvp, struct vnode *vp)
559 {
560 struct lfs *fs;
561 int error;
562
563 KASSERT(VOP_ISLOCKED(dvp) == LK_EXCLUSIVE);
564 KASSERT(vp == NULL || VOP_ISLOCKED(vp) == LK_EXCLUSIVE);
565
566 fs = VTOI(dvp)->i_lfs;
567
568 ASSERT_NO_SEGLOCK(fs);
569 /*
570 * LFS_NRESERVE calculates direct and indirect blocks as well
571 * as an inode block; an overestimate in most cases.
572 */
573 if ((error = lfs_reserve(fs, dvp, vp, LFS_NRESERVE(fs))) != 0)
574 return (error);
575
576 restart:
577 mutex_enter(&lfs_lock);
578 if (fs->lfs_dirops == 0) {
579 mutex_exit(&lfs_lock);
580 lfs_check(dvp, LFS_UNUSED_LBN, 0);
581 mutex_enter(&lfs_lock);
582 }
583 while (fs->lfs_writer) {
584 error = cv_wait_sig(&fs->lfs_diropscv, &lfs_lock);
585 if (error == EINTR) {
586 mutex_exit(&lfs_lock);
587 goto unreserve;
588 }
589 }
590 if (lfs_dirvcount > LFS_MAX_DIROP && fs->lfs_dirops == 0) {
591 cv_broadcast(&lfs_writerd_cv);
592 mutex_exit(&lfs_lock);
593 preempt();
594 goto restart;
595 }
596
597 if (lfs_dirvcount > LFS_MAX_DIROP) {
598 DLOG((DLOG_DIROP, "lfs_set_dirop: sleeping with dirops=%d, "
599 "dirvcount=%d\n", fs->lfs_dirops, lfs_dirvcount));
600 if ((error = mtsleep(&lfs_dirvcount,
601 PCATCH | PUSER | PNORELOCK, "lfs_maxdirop", 0,
602 &lfs_lock)) != 0) {
603 mutex_exit(&lfs_lock);
604 goto unreserve;
605 }
606 mutex_exit(&lfs_lock);
607 goto restart;
608 }
609
610 ++fs->lfs_dirops;
611 /* fs->lfs_doifile = 1; */ /* XXX why? --ks */
612 mutex_exit(&lfs_lock);
613
614 /* Hold a reference so SET_ENDOP will be happy */
615 vref(dvp);
616 if (vp) {
617 vref(vp);
618 MARK_VNODE(vp);
619 }
620
621 MARK_VNODE(dvp);
622 return 0;
623
624 unreserve:
625 lfs_reserve(fs, dvp, vp, -LFS_NRESERVE(fs));
626 return error;
627 }
628
629 /*
630 * Opposite of lfs_set_dirop... mostly. For now at least must call
631 * UNMARK_VNODE(dvp) explicitly first. (XXX: clean that up)
632 */
633 void
634 lfs_unset_dirop(struct lfs *fs, struct vnode *dvp, const char *str)
635 {
636 mutex_enter(&lfs_lock);
637 --fs->lfs_dirops;
638 if (!fs->lfs_dirops) {
639 if (fs->lfs_nadirop) {
640 panic("lfs_unset_dirop: %s: no dirops but "
641 " nadirop=%d", str,
642 fs->lfs_nadirop);
643 }
644 wakeup(&fs->lfs_writer);
645 mutex_exit(&lfs_lock);
646 lfs_check(dvp, LFS_UNUSED_LBN, 0);
647 } else {
648 mutex_exit(&lfs_lock);
649 }
650 lfs_reserve(fs, dvp, NULL, -LFS_NRESERVE(fs));
651 }
652
653 void
654 lfs_mark_vnode(struct vnode *vp)
655 {
656 struct inode *ip = VTOI(vp);
657 struct lfs *fs = ip->i_lfs;
658
659 mutex_enter(&lfs_lock);
660 if (!(ip->i_state & IN_ADIROP)) {
661 if (!(vp->v_uflag & VU_DIROP)) {
662 mutex_exit(&lfs_lock);
663 vref(vp);
664 mutex_enter(&lfs_lock);
665 ++lfs_dirvcount;
666 ++fs->lfs_dirvcount;
667 TAILQ_INSERT_TAIL(&fs->lfs_dchainhd, ip, i_lfs_dchain);
668 vp->v_uflag |= VU_DIROP;
669 }
670 ++fs->lfs_nadirop;
671 ip->i_state &= ~IN_CDIROP;
672 ip->i_state |= IN_ADIROP;
673 } else
674 KASSERT(vp->v_uflag & VU_DIROP);
675 mutex_exit(&lfs_lock);
676 }
677
678 void
679 lfs_unmark_vnode(struct vnode *vp)
680 {
681 struct inode *ip = VTOI(vp);
682
683 mutex_enter(&lfs_lock);
684 if (ip && (ip->i_state & IN_ADIROP)) {
685 KASSERT(vp->v_uflag & VU_DIROP);
686 --ip->i_lfs->lfs_nadirop;
687 ip->i_state &= ~IN_ADIROP;
688 }
689 mutex_exit(&lfs_lock);
690 }
691
692 int
693 lfs_symlink(void *v)
694 {
695 struct vop_symlink_v3_args /* {
696 struct vnode *a_dvp;
697 struct vnode **a_vpp;
698 struct componentname *a_cnp;
699 struct vattr *a_vap;
700 char *a_target;
701 } */ *ap = v;
702 struct lfs *fs;
703 struct vnode *dvp, **vpp;
704 struct inode *ip;
705 struct ulfs_lookup_results *ulr;
706 ssize_t len; /* XXX should be size_t */
707 int error;
708
709 dvp = ap->a_dvp;
710 vpp = ap->a_vpp;
711
712 KASSERT(VOP_ISLOCKED(dvp) == LK_EXCLUSIVE);
713 KASSERT(vpp != NULL);
714 KASSERT(*vpp == NULL);
715 KASSERT(ap->a_vap->va_type == VLNK);
716
717 /* XXX should handle this material another way */
718 ulr = &VTOI(ap->a_dvp)->i_crap;
719 ULFS_CHECK_CRAPCOUNTER(VTOI(ap->a_dvp));
720
721 fs = VFSTOULFS(dvp->v_mount)->um_lfs;
722 ASSERT_NO_SEGLOCK(fs);
723 if (fs->lfs_ronly) {
724 return EROFS;
725 }
726
727 error = lfs_set_dirop(dvp, NULL);
728 if (error)
729 return error;
730
731 error = lfs_makeinode(ap->a_vap, dvp, ulr, vpp, ap->a_cnp);
732 if (error) {
733 goto out;
734 }
735 KASSERT(VOP_ISLOCKED(*vpp) == LK_EXCLUSIVE);
736
737 VN_KNOTE(ap->a_dvp, NOTE_WRITE);
738 ip = VTOI(*vpp);
739
740 /*
741 * This test is off by one. um_maxsymlinklen contains the
742 * number of bytes available, and we aren't storing a \0, so
743 * the test should properly be <=. However, it cannot be
744 * changed as this would break compatibility with existing fs
745 * images -- see the way ulfs_readlink() works.
746 */
747 len = strlen(ap->a_target);
748 if (len < ip->i_lfs->um_maxsymlinklen) {
749 memcpy((char *)SHORTLINK(ip), ap->a_target, len);
750 ip->i_size = len;
751 DIP_ASSIGN(ip, size, len);
752 uvm_vnp_setsize(*vpp, ip->i_size);
753 ip->i_state |= IN_CHANGE | IN_UPDATE;
754 if ((*vpp)->v_mount->mnt_flag & MNT_RELATIME)
755 ip->i_state |= IN_ACCESS;
756 } else {
757 error = ulfs_bufio(UIO_WRITE, *vpp, ap->a_target, len, (off_t)0,
758 IO_NODELOCKED | IO_JOURNALLOCKED, ap->a_cnp->cn_cred, NULL,
759 NULL);
760 }
761
762 VOP_UNLOCK(*vpp);
763 if (error)
764 vrele(*vpp);
765
766 out:
767 UNMARK_VNODE(dvp);
768 /* XXX: is it even possible for the symlink to get MARK'd? */
769 UNMARK_VNODE(*vpp);
770 if (error) {
771 *vpp = NULL;
772 }
773 lfs_unset_dirop(fs, dvp, "symlink");
774
775 vrele(dvp);
776 return (error);
777 }
778
779 int
780 lfs_mknod(void *v)
781 {
782 struct vop_mknod_v3_args /* {
783 struct vnode *a_dvp;
784 struct vnode **a_vpp;
785 struct componentname *a_cnp;
786 struct vattr *a_vap;
787 } */ *ap = v;
788 struct lfs *fs;
789 struct vnode *dvp, **vpp;
790 struct vattr *vap;
791 struct inode *ip;
792 int error;
793 ino_t ino;
794 struct ulfs_lookup_results *ulr;
795
796 dvp = ap->a_dvp;
797 vpp = ap->a_vpp;
798 vap = ap->a_vap;
799
800 KASSERT(VOP_ISLOCKED(dvp) == LK_EXCLUSIVE);
801 KASSERT(vpp != NULL);
802 KASSERT(*vpp == NULL);
803
804 /* XXX should handle this material another way */
805 ulr = &VTOI(dvp)->i_crap;
806 ULFS_CHECK_CRAPCOUNTER(VTOI(dvp));
807
808 fs = VFSTOULFS(dvp->v_mount)->um_lfs;
809 ASSERT_NO_SEGLOCK(fs);
810 if (fs->lfs_ronly) {
811 return EROFS;
812 }
813
814 error = lfs_set_dirop(dvp, NULL);
815 if (error)
816 return error;
817
818 error = lfs_makeinode(vap, dvp, ulr, vpp, ap->a_cnp);
819
820 /* Either way we're done with the dirop at this point */
821 UNMARK_VNODE(dvp);
822 UNMARK_VNODE(*vpp);
823 lfs_unset_dirop(fs, dvp, "mknod");
824
825 if (error) {
826 vrele(dvp);
827 *vpp = NULL;
828 return (error);
829 }
830 KASSERT(VOP_ISLOCKED(*vpp) == LK_EXCLUSIVE);
831
832 VN_KNOTE(dvp, NOTE_WRITE);
833 ip = VTOI(*vpp);
834 ino = ip->i_number;
835 ip->i_state |= IN_ACCESS | IN_CHANGE | IN_UPDATE;
836
837 /*
838 * Call fsync to write the vnode so that we don't have to deal with
839 * flushing it when it's marked VU_DIROP or reclaiming.
840 *
841 * XXX KS - If we can't flush we also can't call vgone(), so must
842 * return. But, that leaves this vnode in limbo, also not good.
843 * Can this ever happen (barring hardware failure)?
844 */
845 if ((error = VOP_FSYNC(*vpp, NOCRED, FSYNC_WAIT, 0, 0)) != 0) {
846 panic("lfs_mknod: couldn't fsync (ino %llu)",
847 (unsigned long long) ino);
848 /* return (error); */
849 }
850
851 vrele(dvp);
852 KASSERT(error == 0);
853 VOP_UNLOCK(*vpp);
854 return (0);
855 }
856
857 /*
858 * Create a regular file
859 */
860 int
861 lfs_create(void *v)
862 {
863 struct vop_create_v3_args /* {
864 struct vnode *a_dvp;
865 struct vnode **a_vpp;
866 struct componentname *a_cnp;
867 struct vattr *a_vap;
868 } */ *ap = v;
869 struct lfs *fs;
870 struct vnode *dvp, **vpp;
871 struct vattr *vap;
872 struct ulfs_lookup_results *ulr;
873 int error;
874
875 dvp = ap->a_dvp;
876 vpp = ap->a_vpp;
877 vap = ap->a_vap;
878
879 KASSERT(VOP_ISLOCKED(dvp) == LK_EXCLUSIVE);
880 KASSERT(vpp != NULL);
881 KASSERT(*vpp == NULL);
882
883 /* XXX should handle this material another way */
884 ulr = &VTOI(dvp)->i_crap;
885 ULFS_CHECK_CRAPCOUNTER(VTOI(dvp));
886
887 fs = VFSTOULFS(dvp->v_mount)->um_lfs;
888 ASSERT_NO_SEGLOCK(fs);
889 if (fs->lfs_ronly) {
890 return EROFS;
891 }
892
893 error = lfs_set_dirop(dvp, NULL);
894 if (error)
895 return error;
896
897 error = lfs_makeinode(vap, dvp, ulr, vpp, ap->a_cnp);
898 if (error) {
899 goto out;
900 }
901 KASSERT(VOP_ISLOCKED(*vpp) == LK_EXCLUSIVE);
902 VN_KNOTE(dvp, NOTE_WRITE);
903 VOP_UNLOCK(*vpp);
904
905 out:
906
907 UNMARK_VNODE(dvp);
908 UNMARK_VNODE(*vpp);
909 if (error) {
910 *vpp = NULL;
911 }
912 lfs_unset_dirop(fs, dvp, "create");
913
914 vrele(dvp);
915 return (error);
916 }
917
918 int
919 lfs_mkdir(void *v)
920 {
921 struct vop_mkdir_v3_args /* {
922 struct vnode *a_dvp;
923 struct vnode **a_vpp;
924 struct componentname *a_cnp;
925 struct vattr *a_vap;
926 } */ *ap = v;
927 struct lfs *fs;
928 struct vnode *dvp, *tvp, **vpp;
929 struct inode *dp, *ip;
930 struct componentname *cnp;
931 struct vattr *vap;
932 struct ulfs_lookup_results *ulr;
933 struct buf *bp;
934 LFS_DIRHEADER *dirp;
935 int dirblksiz;
936 int error;
937
938 dvp = ap->a_dvp;
939 tvp = NULL;
940 vpp = ap->a_vpp;
941 cnp = ap->a_cnp;
942 vap = ap->a_vap;
943
944 KASSERT(VOP_ISLOCKED(dvp) == LK_EXCLUSIVE);
945
946 dp = VTOI(dvp);
947 ip = NULL;
948
949 KASSERT(vap->va_type == VDIR);
950 KASSERT(vpp != NULL);
951 KASSERT(*vpp == NULL);
952
953 /* XXX should handle this material another way */
954 ulr = &dp->i_crap;
955 ULFS_CHECK_CRAPCOUNTER(dp);
956
957 fs = VFSTOULFS(dvp->v_mount)->um_lfs;
958 ASSERT_NO_SEGLOCK(fs);
959 if (fs->lfs_ronly) {
960 return EROFS;
961 }
962
963 if ((nlink_t)dp->i_nlink >= LINK_MAX) {
964 return EMLINK;
965 }
966
967 dirblksiz = fs->um_dirblksiz;
968 /* XXX dholland 20150911 I believe this to be true, but... */
969 //KASSERT(dirblksiz == LFS_DIRBLKSIZ);
970
971 error = lfs_set_dirop(dvp, NULL);
972 if (error)
973 return error;
974
975 /*
976 * Must simulate part of lfs_makeinode here to acquire the inode,
977 * but not have it entered in the parent directory. The entry is
978 * made later after writing "." and ".." entries.
979 */
980 error = vcache_new(dvp->v_mount, dvp, vap, cnp->cn_cred, NULL,
981 ap->a_vpp);
982 if (error)
983 goto out;
984
985 error = vn_lock(*ap->a_vpp, LK_EXCLUSIVE);
986 if (error) {
987 vrele(*ap->a_vpp);
988 *ap->a_vpp = NULL;
989 goto out;
990 }
991
992 tvp = *ap->a_vpp;
993 MARK_VNODE(tvp);
994 ip = VTOI(tvp);
995 ip->i_state |= IN_ACCESS | IN_CHANGE | IN_UPDATE;
996 ip->i_nlink = 2;
997 DIP_ASSIGN(ip, nlink, 2);
998 if (cnp->cn_flags & ISWHITEOUT) {
999 ip->i_flags |= UF_OPAQUE;
1000 DIP_ASSIGN(ip, flags, ip->i_flags);
1001 }
1002
1003 /*
1004 * Bump link count in parent directory to reflect work done below.
1005 */
1006 dp->i_nlink++;
1007 DIP_ASSIGN(dp, nlink, dp->i_nlink);
1008 dp->i_state |= IN_CHANGE;
1009 if ((error = lfs_update(dvp, NULL, NULL, UPDATE_DIROP)) != 0)
1010 goto bad;
1011
1012 /*
1013 * Initialize directory with "." and "..". This used to use a
1014 * static template but that adds moving parts for very little
1015 * benefit.
1016 */
1017 if ((error = lfs_balloc(tvp, (off_t)0, dirblksiz, cnp->cn_cred,
1018 B_CLRBUF, &bp)) != 0)
1019 goto bad;
1020 ip->i_size = dirblksiz;
1021 DIP_ASSIGN(ip, size, dirblksiz);
1022 ip->i_state |= IN_ACCESS | IN_CHANGE | IN_UPDATE;
1023 uvm_vnp_setsize(tvp, ip->i_size);
1024 dirp = bp->b_data;
1025
1026 /* . */
1027 lfs_dir_setino(fs, dirp, ip->i_number);
1028 lfs_dir_setreclen(fs, dirp, LFS_DIRECTSIZ(fs, 1));
1029 lfs_dir_settype(fs, dirp, LFS_DT_DIR);
1030 lfs_dir_setnamlen(fs, dirp, 1);
1031 lfs_copydirname(fs, lfs_dir_nameptr(fs, dirp), ".", 1,
1032 LFS_DIRECTSIZ(fs, 1));
1033 dirp = LFS_NEXTDIR(fs, dirp);
1034 /* .. */
1035 lfs_dir_setino(fs, dirp, dp->i_number);
1036 lfs_dir_setreclen(fs, dirp, dirblksiz - LFS_DIRECTSIZ(fs, 1));
1037 lfs_dir_settype(fs, dirp, LFS_DT_DIR);
1038 lfs_dir_setnamlen(fs, dirp, 2);
1039 lfs_copydirname(fs, lfs_dir_nameptr(fs, dirp), "..", 2,
1040 dirblksiz - LFS_DIRECTSIZ(fs, 1));
1041
1042 /*
1043 * Directory set up; now install its entry in the parent directory.
1044 */
1045 if ((error = VOP_BWRITE(bp->b_vp, bp)) != 0)
1046 goto bad;
1047 if ((error = lfs_update(tvp, NULL, NULL, UPDATE_DIROP)) != 0) {
1048 goto bad;
1049 }
1050 error = ulfs_direnter(dvp, ulr, tvp,
1051 cnp, ip->i_number, LFS_IFTODT(ip->i_mode), bp);
1052 bad:
1053 if (error == 0) {
1054 VN_KNOTE(dvp, NOTE_WRITE | NOTE_LINK);
1055 VOP_UNLOCK(tvp);
1056 } else {
1057 dp->i_nlink--;
1058 DIP_ASSIGN(dp, nlink, dp->i_nlink);
1059 dp->i_state |= IN_CHANGE;
1060 /*
1061 * No need to do an explicit lfs_truncate here, vrele will
1062 * do this for us because we set the link count to 0.
1063 */
1064 ip->i_nlink = 0;
1065 DIP_ASSIGN(ip, nlink, 0);
1066 ip->i_state |= IN_CHANGE;
1067 /* If IN_ADIROP, account for it */
1068 UNMARK_VNODE(tvp);
1069 vput(tvp);
1070 }
1071
1072 out:
1073 UNMARK_VNODE(dvp);
1074 UNMARK_VNODE(*vpp);
1075 if (error) {
1076 *vpp = NULL;
1077 }
1078 lfs_unset_dirop(fs, dvp, "mkdir");
1079
1080 vrele(dvp);
1081 return (error);
1082 }
1083
1084 int
1085 lfs_remove(void *v)
1086 {
1087 struct vop_remove_v2_args /* {
1088 struct vnode *a_dvp;
1089 struct vnode *a_vp;
1090 struct componentname *a_cnp;
1091 } */ *ap = v;
1092 struct vnode *dvp, *vp;
1093 struct inode *ip;
1094 int error;
1095
1096 dvp = ap->a_dvp;
1097 vp = ap->a_vp;
1098
1099 KASSERT(VOP_ISLOCKED(dvp) == LK_EXCLUSIVE);
1100 KASSERT(VOP_ISLOCKED(vp) == LK_EXCLUSIVE);
1101
1102 ip = VTOI(vp);
1103 if ((error = lfs_set_dirop(dvp, vp)) != 0) {
1104 if (dvp == vp)
1105 vrele(vp);
1106 else
1107 vput(vp);
1108 return error;
1109 }
1110 error = ulfs_remove(ap);
1111 if (ip->i_nlink == 0)
1112 lfs_orphan(ip->i_lfs, ip->i_number);
1113
1114 UNMARK_VNODE(dvp);
1115 if (ap->a_vp) {
1116 UNMARK_VNODE(ap->a_vp);
1117 }
1118 lfs_unset_dirop(ip->i_lfs, dvp, "remove");
1119 vrele(dvp);
1120 if (ap->a_vp) {
1121 vrele(ap->a_vp);
1122 }
1123
1124 return (error);
1125 }
1126
1127 int
1128 lfs_rmdir(void *v)
1129 {
1130 struct vop_rmdir_v2_args /* {
1131 struct vnodeop_desc *a_desc;
1132 struct vnode *a_dvp;
1133 struct vnode *a_vp;
1134 struct componentname *a_cnp;
1135 } */ *ap = v;
1136 struct vnode *vp;
1137 struct inode *ip;
1138 int error;
1139
1140 vp = ap->a_vp;
1141
1142 KASSERT(VOP_ISLOCKED(ap->a_dvp) == LK_EXCLUSIVE);
1143 KASSERT(VOP_ISLOCKED(vp) == LK_EXCLUSIVE);
1144
1145 ip = VTOI(vp);
1146 if ((error = lfs_set_dirop(ap->a_dvp, ap->a_vp)) != 0) {
1147 if (ap->a_dvp == vp)
1148 vrele(vp);
1149 else
1150 vput(vp);
1151 return error;
1152 }
1153 error = ulfs_rmdir(ap);
1154 if (ip->i_nlink == 0)
1155 lfs_orphan(ip->i_lfs, ip->i_number);
1156
1157 UNMARK_VNODE(ap->a_dvp);
1158 if (ap->a_vp) {
1159 UNMARK_VNODE(ap->a_vp);
1160 }
1161 lfs_unset_dirop(ip->i_lfs, ap->a_dvp, "rmdir");
1162 vrele(ap->a_dvp);
1163 if (ap->a_vp) {
1164 vrele(ap->a_vp);
1165 }
1166
1167 return (error);
1168 }
1169
1170 int
1171 lfs_link(void *v)
1172 {
1173 struct vop_link_v2_args /* {
1174 struct vnode *a_dvp;
1175 struct vnode *a_vp;
1176 struct componentname *a_cnp;
1177 } */ *ap = v;
1178 struct lfs *fs;
1179 struct vnode *dvp;
1180 int error;
1181
1182 dvp = ap->a_dvp;
1183
1184 KASSERT(VOP_ISLOCKED(dvp) == LK_EXCLUSIVE);
1185
1186 fs = VFSTOULFS(dvp->v_mount)->um_lfs;
1187 ASSERT_NO_SEGLOCK(fs);
1188 if (fs->lfs_ronly) {
1189 return EROFS;
1190 }
1191
1192 error = lfs_set_dirop(dvp, NULL);
1193 if (error) {
1194 return error;
1195 }
1196
1197 error = ulfs_link(ap);
1198
1199 UNMARK_VNODE(dvp);
1200 lfs_unset_dirop(fs, dvp, "link");
1201 vrele(dvp);
1202
1203 return (error);
1204 }
1205
1206 /* XXX hack to avoid calling ITIMES in getattr */
1207 int
1208 lfs_getattr(void *v)
1209 {
1210 struct vop_getattr_args /* {
1211 struct vnode *a_vp;
1212 struct vattr *a_vap;
1213 kauth_cred_t a_cred;
1214 } */ *ap = v;
1215 struct vnode *vp = ap->a_vp;
1216 struct inode *ip;
1217 struct vattr *vap = ap->a_vap;
1218 struct lfs *fs;
1219
1220 KASSERT(VOP_ISLOCKED(vp));
1221
1222 ip = VTOI(vp);
1223 fs = ip->i_lfs;
1224
1225 /*
1226 * Copy from inode table
1227 */
1228 vap->va_fsid = ip->i_dev;
1229 vap->va_fileid = ip->i_number;
1230 vap->va_mode = ip->i_mode & ~LFS_IFMT;
1231 vap->va_nlink = ip->i_nlink;
1232 vap->va_uid = ip->i_uid;
1233 vap->va_gid = ip->i_gid;
1234 switch (vp->v_type) {
1235 case VBLK:
1236 case VCHR:
1237 vap->va_rdev = (dev_t)lfs_dino_getrdev(fs, ip->i_din);
1238 break;
1239 default:
1240 vap->va_rdev = NODEV;
1241 break;
1242 }
1243 vap->va_size = vp->v_size;
1244 vap->va_atime.tv_sec = lfs_dino_getatime(fs, ip->i_din);
1245 vap->va_atime.tv_nsec = lfs_dino_getatimensec(fs, ip->i_din);
1246 vap->va_mtime.tv_sec = lfs_dino_getmtime(fs, ip->i_din);
1247 vap->va_mtime.tv_nsec = lfs_dino_getmtimensec(fs, ip->i_din);
1248 vap->va_ctime.tv_sec = lfs_dino_getctime(fs, ip->i_din);
1249 vap->va_ctime.tv_nsec = lfs_dino_getctimensec(fs, ip->i_din);
1250 vap->va_flags = ip->i_flags;
1251 vap->va_gen = ip->i_gen;
1252 /* this doesn't belong here */
1253 if (vp->v_type == VBLK)
1254 vap->va_blocksize = BLKDEV_IOSIZE;
1255 else if (vp->v_type == VCHR)
1256 vap->va_blocksize = MAXBSIZE;
1257 else
1258 vap->va_blocksize = vp->v_mount->mnt_stat.f_iosize;
1259 vap->va_bytes = lfs_fsbtob(fs, ip->i_lfs_effnblks);
1260 vap->va_type = vp->v_type;
1261 vap->va_filerev = ip->i_modrev;
1262 return (0);
1263 }
1264
1265 /*
1266 * Check to make sure the inode blocks won't choke the buffer
1267 * cache, then call ulfs_setattr as usual.
1268 */
1269 int
1270 lfs_setattr(void *v)
1271 {
1272 struct vop_setattr_args /* {
1273 struct vnode *a_vp;
1274 struct vattr *a_vap;
1275 kauth_cred_t a_cred;
1276 } */ *ap = v;
1277 struct vnode *vp = ap->a_vp;
1278
1279 KASSERT(VOP_ISLOCKED(vp) == LK_EXCLUSIVE);
1280 lfs_check(vp, LFS_UNUSED_LBN, 0);
1281 return ulfs_setattr(v);
1282 }
1283
1284 /*
1285 * Release the block we hold on lfs_newseg wrapping. Called on file close,
1286 * or explicitly from LFCNWRAPGO. Called with the interlock held.
1287 */
1288 static int
1289 lfs_wrapgo(struct lfs *fs, struct inode *ip, int waitfor)
1290 {
1291 if (fs->lfs_stoplwp != curlwp)
1292 return EBUSY;
1293
1294 fs->lfs_stoplwp = NULL;
1295 cv_signal(&fs->lfs_stopcv);
1296
1297 KASSERT(fs->lfs_nowrap > 0);
1298 if (fs->lfs_nowrap <= 0) {
1299 return 0;
1300 }
1301
1302 if (--fs->lfs_nowrap == 0) {
1303 log(LOG_NOTICE, "%s: re-enabled log wrap\n",
1304 lfs_sb_getfsmnt(fs));
1305 wakeup(&fs->lfs_wrappass);
1306 lfs_wakeup_cleaner(fs);
1307 }
1308 if (waitfor) {
1309 cv_wait_sig(&fs->lfs_nextsegsleep, &lfs_lock);
1310 }
1311
1312 return 0;
1313 }
1314
1315 /*
1316 * Close called.
1317 *
1318 * Update the times on the inode.
1319 */
1320 /* ARGSUSED */
1321 int
1322 lfs_close(void *v)
1323 {
1324 struct vop_close_args /* {
1325 struct vnode *a_vp;
1326 int a_fflag;
1327 kauth_cred_t a_cred;
1328 } */ *ap = v;
1329 struct vnode *vp = ap->a_vp;
1330 struct inode *ip;
1331 struct lfs *fs;
1332
1333 KASSERT(VOP_ISLOCKED(vp) == LK_EXCLUSIVE);
1334
1335 ip = VTOI(vp);
1336 fs = ip->i_lfs;
1337
1338 if ((ip->i_number == ULFS_ROOTINO || ip->i_number == LFS_IFILE_INUM) &&
1339 fs->lfs_stoplwp == curlwp) {
1340 mutex_enter(&lfs_lock);
1341 log(LOG_NOTICE, "lfs_close: releasing log wrap control\n");
1342 lfs_wrapgo(fs, ip, 0);
1343 mutex_exit(&lfs_lock);
1344 }
1345
1346 if (vp == ip->i_lfs->lfs_ivnode &&
1347 vp->v_mount->mnt_iflag & IMNT_UNMOUNT)
1348 return 0;
1349
1350 if (vp->v_usecount > 1 && vp != ip->i_lfs->lfs_ivnode) {
1351 LFS_ITIMES(ip, NULL, NULL, NULL);
1352 }
1353 return (0);
1354 }
1355
1356 /*
1357 * Close wrapper for special devices.
1358 *
1359 * Update the times on the inode then do device close.
1360 */
1361 int
1362 lfsspec_close(void *v)
1363 {
1364 struct vop_close_args /* {
1365 struct vnode *a_vp;
1366 int a_fflag;
1367 kauth_cred_t a_cred;
1368 } */ *ap = v;
1369 struct vnode *vp;
1370 struct inode *ip;
1371
1372 vp = ap->a_vp;
1373
1374 KASSERT(VOP_ISLOCKED(vp) == LK_EXCLUSIVE);
1375
1376 ip = VTOI(vp);
1377 if (vp->v_usecount > 1) {
1378 LFS_ITIMES(ip, NULL, NULL, NULL);
1379 }
1380 return (VOCALL (spec_vnodeop_p, VOFFSET(vop_close), ap));
1381 }
1382
1383 /*
1384 * Close wrapper for fifo's.
1385 *
1386 * Update the times on the inode then do device close.
1387 */
1388 int
1389 lfsfifo_close(void *v)
1390 {
1391 struct vop_close_args /* {
1392 struct vnode *a_vp;
1393 int a_fflag;
1394 kauth_cred_ a_cred;
1395 } */ *ap = v;
1396 struct vnode *vp;
1397 struct inode *ip;
1398
1399 vp = ap->a_vp;
1400
1401 KASSERT(VOP_ISLOCKED(vp) == LK_EXCLUSIVE);
1402
1403 ip = VTOI(vp);
1404 if (ap->a_vp->v_usecount > 1) {
1405 LFS_ITIMES(ip, NULL, NULL, NULL);
1406 }
1407 return (VOCALL (fifo_vnodeop_p, VOFFSET(vop_close), ap));
1408 }
1409
1410 /*
1411 * Reclaim an inode so that it can be used for other purposes.
1412 */
1413
1414 int
1415 lfs_reclaim(void *v)
1416 {
1417 struct vop_reclaim_v2_args /* {
1418 struct vnode *a_vp;
1419 } */ *ap = v;
1420 struct vnode *vp = ap->a_vp;
1421 struct inode *ip;
1422 struct lfs *fs;
1423 int error;
1424
1425 VOP_UNLOCK(vp);
1426
1427 ip = VTOI(vp);
1428 fs = ip->i_lfs;
1429
1430 /*
1431 * The inode must be freed and updated before being removed
1432 * from its hash chain. Other threads trying to gain a hold
1433 * or lock on the inode will be stalled.
1434 */
1435 if (ip->i_nlink <= 0 && (vp->v_mount->mnt_flag & MNT_RDONLY) == 0)
1436 lfs_vfree(vp, ip->i_number, ip->i_omode);
1437
1438 mutex_enter(&lfs_lock);
1439 LFS_CLR_UINO(ip, IN_ALLMOD);
1440 mutex_exit(&lfs_lock);
1441 if ((error = ulfs_reclaim(vp)))
1442 return (error);
1443
1444 /*
1445 * Take us off the paging and/or dirop queues if we were on them.
1446 * We shouldn't be on them.
1447 */
1448 mutex_enter(&lfs_lock);
1449 if (ip->i_state & IN_PAGING) {
1450 log(LOG_WARNING, "%s: reclaimed vnode is IN_PAGING\n",
1451 lfs_sb_getfsmnt(fs));
1452 ip->i_state &= ~IN_PAGING;
1453 TAILQ_REMOVE(&fs->lfs_pchainhd, ip, i_lfs_pchain);
1454 }
1455 if (vp->v_uflag & VU_DIROP)
1456 panic("reclaimed vnode is VU_DIROP");
1457 mutex_exit(&lfs_lock);
1458
1459 pool_put(&lfs_dinode_pool, ip->i_din);
1460 lfs_deregister_all(vp);
1461 pool_put(&lfs_inoext_pool, ip->inode_ext.lfs);
1462 ip->inode_ext.lfs = NULL;
1463 genfs_node_destroy(vp);
1464 pool_put(&lfs_inode_pool, vp->v_data);
1465 vp->v_data = NULL;
1466 return (0);
1467 }
1468
1469 /*
1470 * Read a block from a storage device.
1471 *
1472 * Calculate the logical to physical mapping if not done already,
1473 * then call the device strategy routine.
1474 *
1475 * In order to avoid reading blocks that are in the process of being
1476 * written by the cleaner---and hence are not mutexed by the normal
1477 * buffer cache / page cache mechanisms---check for collisions before
1478 * reading.
1479 *
1480 * We inline ulfs_strategy to make sure that the VOP_BMAP occurs *before*
1481 * the active cleaner test.
1482 *
1483 * XXX This code assumes that lfs_markv makes synchronous checkpoints.
1484 */
1485 int
1486 lfs_strategy(void *v)
1487 {
1488 struct vop_strategy_args /* {
1489 struct vnode *a_vp;
1490 struct buf *a_bp;
1491 } */ *ap = v;
1492 struct buf *bp;
1493 struct lfs *fs;
1494 struct vnode *vp;
1495 struct inode *ip;
1496 daddr_t tbn;
1497 #define MAXLOOP 25
1498 int i, sn, error, slept, loopcount;
1499
1500 bp = ap->a_bp;
1501 vp = ap->a_vp;
1502 ip = VTOI(vp);
1503 fs = ip->i_lfs;
1504
1505 /* lfs uses its strategy routine only for read */
1506 KASSERT(bp->b_flags & B_READ);
1507
1508 if (vp->v_type == VBLK || vp->v_type == VCHR)
1509 panic("lfs_strategy: spec");
1510 KASSERT(bp->b_bcount != 0);
1511 if (bp->b_blkno == bp->b_lblkno) {
1512 error = VOP_BMAP(vp, bp->b_lblkno, NULL, &bp->b_blkno,
1513 NULL);
1514 if (error) {
1515 bp->b_error = error;
1516 bp->b_resid = bp->b_bcount;
1517 biodone(bp);
1518 return (error);
1519 }
1520 if ((long)bp->b_blkno == -1) /* no valid data */
1521 clrbuf(bp);
1522 }
1523 if ((long)bp->b_blkno < 0) { /* block is not on disk */
1524 bp->b_resid = bp->b_bcount;
1525 biodone(bp);
1526 return (0);
1527 }
1528
1529 slept = 1;
1530 loopcount = 0;
1531 mutex_enter(&lfs_lock);
1532 while (slept && fs->lfs_seglock) {
1533 mutex_exit(&lfs_lock);
1534 /*
1535 * Look through list of intervals.
1536 * There will only be intervals to look through
1537 * if the cleaner holds the seglock.
1538 * Since the cleaner is synchronous, we can trust
1539 * the list of intervals to be current.
1540 */
1541 tbn = LFS_DBTOFSB(fs, bp->b_blkno);
1542 sn = lfs_dtosn(fs, tbn);
1543 slept = 0;
1544 for (i = 0; i < fs->lfs_cleanind; i++) {
1545 if (sn == lfs_dtosn(fs, fs->lfs_cleanint[i]) &&
1546 tbn >= fs->lfs_cleanint[i]) {
1547 DLOG((DLOG_CLEAN,
1548 "lfs_strategy: ino %llu lbn %" PRId64
1549 " ind %d sn %d fsb %" PRIx64
1550 " given sn %d fsb %" PRIx64 "\n",
1551 (unsigned long long) ip->i_number,
1552 bp->b_lblkno, i,
1553 lfs_dtosn(fs, fs->lfs_cleanint[i]),
1554 fs->lfs_cleanint[i], sn, tbn));
1555 DLOG((DLOG_CLEAN,
1556 "lfs_strategy: sleeping on ino %llu lbn %"
1557 PRId64 "\n",
1558 (unsigned long long) ip->i_number,
1559 bp->b_lblkno));
1560 mutex_enter(&lfs_lock);
1561 if (LFS_SEGLOCK_HELD(fs) && fs->lfs_iocount) {
1562 /*
1563 * Cleaner can't wait for itself.
1564 * Instead, wait for the blocks
1565 * to be written to disk.
1566 * XXX we need pribio in the test
1567 * XXX here.
1568 */
1569 mtsleep(&fs->lfs_iocount,
1570 (PRIBIO + 1) | PNORELOCK,
1571 "clean2", hz/10 + 1,
1572 &lfs_lock);
1573 slept = 1;
1574 ++loopcount;
1575 break;
1576 } else if (fs->lfs_seglock) {
1577 mtsleep(&fs->lfs_seglock,
1578 (PRIBIO + 1) | PNORELOCK,
1579 "clean1", 0,
1580 &lfs_lock);
1581 slept = 1;
1582 break;
1583 }
1584 mutex_exit(&lfs_lock);
1585 }
1586 }
1587 mutex_enter(&lfs_lock);
1588 if (loopcount > MAXLOOP) {
1589 printf("lfs_strategy: breaking out of clean2 loop\n");
1590 break;
1591 }
1592 }
1593 mutex_exit(&lfs_lock);
1594
1595 vp = ip->i_devvp;
1596 return VOP_STRATEGY(vp, bp);
1597 }
1598
1599 /*
1600 * Inline lfs_segwrite/lfs_writevnodes, but just for dirops.
1601 * Technically this is a checkpoint (the on-disk state is valid)
1602 * even though we are leaving out all the file data.
1603 */
1604 int
1605 lfs_flush_dirops(struct lfs *fs)
1606 {
1607 struct inode *ip, *nip;
1608 struct vnode *vp;
1609 extern int lfs_dostats; /* XXX this does not belong here */
1610 struct segment *sp;
1611 SEGSUM *ssp;
1612 int flags = 0;
1613 int error = 0;
1614
1615 ASSERT_MAYBE_SEGLOCK(fs);
1616 KASSERT(fs->lfs_nadirop == 0);
1617
1618 if (fs->lfs_ronly)
1619 return EROFS;
1620
1621 mutex_enter(&lfs_lock);
1622 if (TAILQ_FIRST(&fs->lfs_dchainhd) == NULL) {
1623 mutex_exit(&lfs_lock);
1624 return 0;
1625 } else
1626 mutex_exit(&lfs_lock);
1627
1628 if (lfs_dostats)
1629 ++lfs_stats.flush_invoked;
1630
1631 lfs_imtime(fs);
1632 lfs_seglock(fs, flags);
1633 sp = fs->lfs_sp;
1634
1635 /*
1636 * lfs_writevnodes, optimized to get dirops out of the way.
1637 * Only write dirops, and don't flush files' pages, only
1638 * blocks from the directories.
1639 *
1640 * We don't need to vref these files because they are
1641 * dirops and so hold an extra reference until the
1642 * segunlock clears them of that status.
1643 *
1644 * We don't need to check for IN_ADIROP because we know that
1645 * no dirops are active.
1646 *
1647 */
1648 mutex_enter(&lfs_lock);
1649 for (ip = TAILQ_FIRST(&fs->lfs_dchainhd); ip != NULL; ip = nip) {
1650 nip = TAILQ_NEXT(ip, i_lfs_dchain);
1651 mutex_exit(&lfs_lock);
1652 vp = ITOV(ip);
1653 mutex_enter(vp->v_interlock);
1654
1655 KASSERT((ip->i_state & IN_ADIROP) == 0);
1656 KASSERT(vp->v_uflag & VU_DIROP);
1657 KASSERT(vdead_check(vp, VDEAD_NOWAIT) == 0);
1658
1659 /*
1660 * All writes to directories come from dirops; all
1661 * writes to files' direct blocks go through the page
1662 * cache, which we're not touching. Reads to files
1663 * and/or directories will not be affected by writing
1664 * directory blocks inodes and file inodes. So we don't
1665 * really need to lock.
1666 */
1667 if (vdead_check(vp, VDEAD_NOWAIT) != 0) {
1668 mutex_exit(vp->v_interlock);
1669 mutex_enter(&lfs_lock);
1670 continue;
1671 }
1672 mutex_exit(vp->v_interlock);
1673 /* XXX see below
1674 * waslocked = VOP_ISLOCKED(vp);
1675 */
1676 if (vp->v_type != VREG &&
1677 ((ip->i_state & IN_ALLMOD) || !VPISEMPTY(vp))) {
1678 error = lfs_writefile(fs, sp, vp);
1679 if (!VPISEMPTY(vp) && !WRITEINPROG(vp) &&
1680 !(ip->i_state & IN_ALLMOD)) {
1681 mutex_enter(&lfs_lock);
1682 LFS_SET_UINO(ip, IN_MODIFIED);
1683 mutex_exit(&lfs_lock);
1684 }
1685 if (error && (sp->seg_flags & SEGM_SINGLE)) {
1686 mutex_enter(&lfs_lock);
1687 error = EAGAIN;
1688 break;
1689 }
1690 }
1691 KDASSERT(ip->i_number != LFS_IFILE_INUM);
1692 error = lfs_writeinode(fs, sp, ip);
1693 mutex_enter(&lfs_lock);
1694 if (error && (sp->seg_flags & SEGM_SINGLE)) {
1695 error = EAGAIN;
1696 break;
1697 }
1698
1699 /*
1700 * We might need to update these inodes again,
1701 * for example, if they have data blocks to write.
1702 * Make sure that after this flush, they are still
1703 * marked IN_MODIFIED so that we don't forget to
1704 * write them.
1705 */
1706 /* XXX only for non-directories? --KS */
1707 LFS_SET_UINO(ip, IN_MODIFIED);
1708 }
1709 mutex_exit(&lfs_lock);
1710 /* We've written all the dirops there are */
1711 ssp = (SEGSUM *)sp->segsum;
1712 lfs_ss_setflags(fs, ssp, lfs_ss_getflags(fs, ssp) & ~(SS_CONT));
1713 lfs_finalize_fs_seguse(fs);
1714 (void) lfs_writeseg(fs, sp);
1715 lfs_segunlock(fs);
1716
1717 return error;
1718 }
1719
1720 /*
1721 * Flush all vnodes for which the pagedaemon has requested pageouts.
1722 * Skip over any files that are marked VU_DIROP (since lfs_flush_dirop()
1723 * has just run, this would be an error). If we have to skip a vnode
1724 * for any reason, just skip it; if we have to wait for the cleaner,
1725 * abort. The writer daemon will call us again later.
1726 */
1727 int
1728 lfs_flush_pchain(struct lfs *fs)
1729 {
1730 struct inode *ip, *nip;
1731 struct vnode *vp;
1732 extern int lfs_dostats;
1733 struct segment *sp;
1734 int error, error2;
1735
1736 ASSERT_NO_SEGLOCK(fs);
1737
1738 if (fs->lfs_ronly)
1739 return EROFS;
1740
1741 mutex_enter(&lfs_lock);
1742 if (TAILQ_FIRST(&fs->lfs_pchainhd) == NULL) {
1743 mutex_exit(&lfs_lock);
1744 return 0;
1745 } else
1746 mutex_exit(&lfs_lock);
1747
1748 /* Get dirops out of the way */
1749 if ((error = lfs_flush_dirops(fs)) != 0)
1750 return error;
1751
1752 if (lfs_dostats)
1753 ++lfs_stats.flush_invoked;
1754
1755 /*
1756 * Inline lfs_segwrite/lfs_writevnodes, but just for pageouts.
1757 */
1758 lfs_imtime(fs);
1759 lfs_seglock(fs, 0);
1760 sp = fs->lfs_sp;
1761
1762 /*
1763 * lfs_writevnodes, optimized to clear pageout requests.
1764 * Only write non-dirop files that are in the pageout queue.
1765 * We're very conservative about what we write; we want to be
1766 * fast and async.
1767 */
1768 mutex_enter(&lfs_lock);
1769 top:
1770 for (ip = TAILQ_FIRST(&fs->lfs_pchainhd); ip != NULL; ip = nip) {
1771 struct mount *mp = ITOV(ip)->v_mount;
1772 ino_t ino = ip->i_number;
1773
1774 nip = TAILQ_NEXT(ip, i_lfs_pchain);
1775
1776 if (!(ip->i_state & IN_PAGING))
1777 goto top;
1778
1779 mutex_exit(&lfs_lock);
1780 if (vcache_get(mp, &ino, sizeof(ino), &vp) != 0) {
1781 mutex_enter(&lfs_lock);
1782 continue;
1783 };
1784 if (vn_lock(vp, LK_EXCLUSIVE | LK_NOWAIT) != 0) {
1785 vrele(vp);
1786 mutex_enter(&lfs_lock);
1787 continue;
1788 }
1789 ip = VTOI(vp);
1790 mutex_enter(&lfs_lock);
1791 if ((vp->v_uflag & VU_DIROP) != 0 || vp->v_type != VREG ||
1792 !(ip->i_state & IN_PAGING)) {
1793 mutex_exit(&lfs_lock);
1794 vput(vp);
1795 mutex_enter(&lfs_lock);
1796 goto top;
1797 }
1798 mutex_exit(&lfs_lock);
1799
1800 error = lfs_writefile(fs, sp, vp);
1801 if (!VPISEMPTY(vp) && !WRITEINPROG(vp) &&
1802 !(ip->i_state & IN_ALLMOD)) {
1803 mutex_enter(&lfs_lock);
1804 LFS_SET_UINO(ip, IN_MODIFIED);
1805 mutex_exit(&lfs_lock);
1806 }
1807 KDASSERT(ip->i_number != LFS_IFILE_INUM);
1808 error2 = lfs_writeinode(fs, sp, ip);
1809
1810 VOP_UNLOCK(vp);
1811 vrele(vp);
1812
1813 if (error == EAGAIN || error2 == EAGAIN) {
1814 lfs_writeseg(fs, sp);
1815 mutex_enter(&lfs_lock);
1816 break;
1817 }
1818 mutex_enter(&lfs_lock);
1819 }
1820 mutex_exit(&lfs_lock);
1821 (void) lfs_writeseg(fs, sp);
1822 lfs_segunlock(fs);
1823
1824 return 0;
1825 }
1826
1827 /*
1828 * Conversion for compat.
1829 */
1830 static void
1831 block_info_from_70(BLOCK_INFO *bi, const BLOCK_INFO_70 *bi70)
1832 {
1833 bi->bi_inode = bi70->bi_inode;
1834 bi->bi_lbn = bi70->bi_lbn;
1835 bi->bi_daddr = bi70->bi_daddr;
1836 bi->bi_segcreate = bi70->bi_segcreate;
1837 bi->bi_version = bi70->bi_version;
1838 bi->bi_bp = bi70->bi_bp;
1839 bi->bi_size = bi70->bi_size;
1840 }
1841
1842 static void
1843 block_info_to_70(BLOCK_INFO_70 *bi70, const BLOCK_INFO *bi)
1844 {
1845 bi70->bi_inode = bi->bi_inode;
1846 bi70->bi_lbn = bi->bi_lbn;
1847 bi70->bi_daddr = bi->bi_daddr;
1848 bi70->bi_segcreate = bi->bi_segcreate;
1849 bi70->bi_version = bi->bi_version;
1850 bi70->bi_bp = bi->bi_bp;
1851 bi70->bi_size = bi->bi_size;
1852 }
1853
1854 /*
1855 * Provide a fcntl interface to sys_lfs_{segwait,bmapv,markv}.
1856 */
1857 int
1858 lfs_fcntl(void *v)
1859 {
1860 struct vop_fcntl_args /* {
1861 struct vnode *a_vp;
1862 u_int a_command;
1863 void * a_data;
1864 int a_fflag;
1865 kauth_cred_t a_cred;
1866 } */ *ap = v;
1867 struct timeval tv;
1868 struct timeval *tvp;
1869 BLOCK_INFO *blkiov;
1870 BLOCK_INFO_70 *blkiov70;
1871 CLEANERINFO *cip;
1872 SEGUSE *sup;
1873 int blkcnt, i, error;
1874 size_t fh_size;
1875 struct lfs_fcntl_markv blkvp;
1876 struct lfs_fcntl_markv_70 blkvp70;
1877 struct lwp *l;
1878 fsid_t *fsidp;
1879 struct lfs *fs;
1880 struct buf *bp;
1881 fhandle_t *fhp;
1882 daddr_t off;
1883 int oclean;
1884
1885 /* Only respect LFS fcntls on fs root or Ifile */
1886 if (VTOI(ap->a_vp)->i_number != ULFS_ROOTINO &&
1887 VTOI(ap->a_vp)->i_number != LFS_IFILE_INUM) {
1888 return ulfs_fcntl(v);
1889 }
1890
1891 /* Avoid locking a draining lock */
1892 if (ap->a_vp->v_mount->mnt_iflag & IMNT_UNMOUNT) {
1893 return ESHUTDOWN;
1894 }
1895
1896 /* LFS control and monitoring fcntls are available only to root */
1897 l = curlwp;
1898 if (((ap->a_command & 0xff00) >> 8) == 'L' &&
1899 (error = kauth_authorize_system(l->l_cred, KAUTH_SYSTEM_LFS,
1900 KAUTH_REQ_SYSTEM_LFS_FCNTL, NULL, NULL, NULL)) != 0)
1901 return (error);
1902
1903 fs = VTOI(ap->a_vp)->i_lfs;
1904 fsidp = &ap->a_vp->v_mount->mnt_stat.f_fsidx;
1905
1906 error = 0;
1907 switch ((int)ap->a_command) {
1908 case LFCNSEGWAITALL_COMPAT_50:
1909 case LFCNSEGWAITALL_COMPAT:
1910 fsidp = NULL;
1911 /* FALLTHROUGH */
1912 case LFCNSEGWAIT_COMPAT_50:
1913 case LFCNSEGWAIT_COMPAT:
1914 {
1915 struct timeval50 *tvp50
1916 = (struct timeval50 *)ap->a_data;
1917 timeval50_to_timeval(tvp50, &tv);
1918 tvp = &tv;
1919 }
1920 goto segwait_common;
1921 case LFCNSEGWAITALL:
1922 fsidp = NULL;
1923 /* FALLTHROUGH */
1924 case LFCNSEGWAIT:
1925 tvp = (struct timeval *)ap->a_data;
1926 segwait_common:
1927 mutex_enter(&lfs_lock);
1928 ++fs->lfs_sleepers;
1929 mutex_exit(&lfs_lock);
1930
1931 error = lfs_segwait(fsidp, tvp);
1932
1933 mutex_enter(&lfs_lock);
1934 if (--fs->lfs_sleepers == 0)
1935 cv_broadcast(&fs->lfs_sleeperscv);
1936 mutex_exit(&lfs_lock);
1937 return error;
1938
1939 case LFCNBMAPV_COMPAT_70:
1940 case LFCNMARKV_COMPAT_70:
1941 blkvp70 = *(struct lfs_fcntl_markv_70 *)ap->a_data;
1942
1943 blkcnt = blkvp70.blkcnt;
1944 if ((u_int) blkcnt > LFS_MARKV_MAXBLKCNT)
1945 return (EINVAL);
1946 blkiov = lfs_malloc(fs, blkcnt * sizeof(BLOCK_INFO), LFS_NB_BLKIOV);
1947 blkiov70 = lfs_malloc(fs, sizeof(BLOCK_INFO_70), LFS_NB_BLKIOV);
1948 for (i = 0; i < blkcnt; i++) {
1949 error = copyin(&blkvp70.blkiov[i], blkiov70,
1950 sizeof(*blkiov70));
1951 if (error) {
1952 lfs_free(fs, blkiov70, LFS_NB_BLKIOV);
1953 lfs_free(fs, blkiov, LFS_NB_BLKIOV);
1954 return error;
1955 }
1956 block_info_from_70(&blkiov[i], blkiov70);
1957 }
1958
1959 mutex_enter(&lfs_lock);
1960 ++fs->lfs_sleepers;
1961 mutex_exit(&lfs_lock);
1962 if (ap->a_command == LFCNBMAPV)
1963 error = lfs_bmapv(l, fsidp, blkiov, blkcnt);
1964 else /* LFCNMARKV */
1965 error = lfs_markv(l, fsidp, blkiov, blkcnt);
1966 if (error == 0) {
1967 for (i = 0; i < blkcnt; i++) {
1968 block_info_to_70(blkiov70, &blkiov[i]);
1969 error = copyout(blkiov70, &blkvp70.blkiov[i],
1970 sizeof(*blkiov70));
1971 if (error) {
1972 break;
1973 }
1974 }
1975 }
1976 mutex_enter(&lfs_lock);
1977 if (--fs->lfs_sleepers == 0)
1978 cv_broadcast(&fs->lfs_sleeperscv);
1979 mutex_exit(&lfs_lock);
1980 lfs_free(fs, blkiov, LFS_NB_BLKIOV);
1981 return error;
1982
1983 case LFCNBMAPV:
1984 case LFCNMARKV:
1985 blkvp = *(struct lfs_fcntl_markv *)ap->a_data;
1986
1987 blkcnt = blkvp.blkcnt;
1988 if ((u_int) blkcnt > LFS_MARKV_MAXBLKCNT)
1989 return (EINVAL);
1990 blkiov = lfs_malloc(fs, blkcnt * sizeof(BLOCK_INFO), LFS_NB_BLKIOV);
1991 if ((error = copyin(blkvp.blkiov, blkiov,
1992 blkcnt * sizeof(BLOCK_INFO))) != 0) {
1993 lfs_free(fs, blkiov, LFS_NB_BLKIOV);
1994 return error;
1995 }
1996
1997 mutex_enter(&lfs_lock);
1998 ++fs->lfs_sleepers;
1999 mutex_exit(&lfs_lock);
2000 if (ap->a_command == LFCNBMAPV)
2001 error = lfs_bmapv(l, fsidp, blkiov, blkcnt);
2002 else /* LFCNMARKV */
2003 error = lfs_markv(l, fsidp, blkiov, blkcnt);
2004 if (error == 0)
2005 error = copyout(blkiov, blkvp.blkiov,
2006 blkcnt * sizeof(BLOCK_INFO));
2007 mutex_enter(&lfs_lock);
2008 if (--fs->lfs_sleepers == 0)
2009 cv_broadcast(&fs->lfs_sleeperscv);
2010 mutex_exit(&lfs_lock);
2011 lfs_free(fs, blkiov, LFS_NB_BLKIOV);
2012 return error;
2013
2014 case LFCNRECLAIM:
2015 /*
2016 * Flush dirops and write Ifile, allowing empty segments
2017 * to be immediately reclaimed.
2018 */
2019 lfs_writer_enter(fs, "pndirop");
2020 off = lfs_sb_getoffset(fs);
2021 lfs_seglock(fs, SEGM_FORCE_CKP | SEGM_CKP);
2022 lfs_flush_dirops(fs);
2023 LFS_CLEANERINFO(cip, fs, bp);
2024 oclean = lfs_ci_getclean(fs, cip);
2025 LFS_SYNC_CLEANERINFO(cip, fs, bp, 1);
2026 lfs_segwrite(ap->a_vp->v_mount, SEGM_FORCE_CKP);
2027 fs->lfs_sp->seg_flags |= SEGM_PROT;
2028 lfs_segunlock(fs);
2029 lfs_writer_leave(fs);
2030
2031 #ifdef DEBUG
2032 LFS_CLEANERINFO(cip, fs, bp);
2033 DLOG((DLOG_CLEAN, "lfs_fcntl: reclaim wrote %" PRId64
2034 " blocks, cleaned %" PRId32 " segments (activesb %d)\n",
2035 lfs_sb_getoffset(fs) - off,
2036 lfs_ci_getclean(fs, cip) - oclean,
2037 fs->lfs_activesb));
2038 LFS_SYNC_CLEANERINFO(cip, fs, bp, 0);
2039 #else
2040 __USE(oclean);
2041 __USE(off);
2042 #endif
2043
2044 return 0;
2045
2046 case LFCNIFILEFH_COMPAT:
2047 /* Return the filehandle of the Ifile */
2048 if ((error = kauth_authorize_system(l->l_cred,
2049 KAUTH_SYSTEM_FILEHANDLE, 0, NULL, NULL, NULL)) != 0)
2050 return (error);
2051 fhp = (struct fhandle *)ap->a_data;
2052 fhp->fh_fsid = *fsidp;
2053 fh_size = 16; /* former VFS_MAXFIDSIZ */
2054 return lfs_vptofh(fs->lfs_ivnode, &(fhp->fh_fid), &fh_size);
2055
2056 case LFCNIFILEFH_COMPAT2:
2057 case LFCNIFILEFH:
2058 /* Return the filehandle of the Ifile */
2059 fhp = (struct fhandle *)ap->a_data;
2060 fhp->fh_fsid = *fsidp;
2061 fh_size = sizeof(struct lfs_fhandle) -
2062 offsetof(fhandle_t, fh_fid);
2063 return lfs_vptofh(fs->lfs_ivnode, &(fhp->fh_fid), &fh_size);
2064
2065 case LFCNREWIND:
2066 /* Move lfs_offset to the lowest-numbered segment */
2067 return lfs_rewind(fs, *(int *)ap->a_data);
2068
2069 case LFCNINVAL:
2070 /* Mark a segment SEGUSE_INVAL */
2071 LFS_SEGENTRY(sup, fs, *(int *)ap->a_data, bp);
2072 if (sup->su_nbytes > 0) {
2073 brelse(bp, 0);
2074 lfs_unset_inval_all(fs);
2075 return EBUSY;
2076 }
2077 sup->su_flags |= SEGUSE_INVAL;
2078 VOP_BWRITE(bp->b_vp, bp);
2079 return 0;
2080
2081 case LFCNRESIZE:
2082 /* Resize the filesystem */
2083 return lfs_resize_fs(fs, *(int *)ap->a_data);
2084
2085 case LFCNWRAPSTOP:
2086 case LFCNWRAPSTOP_COMPAT:
2087 /*
2088 * Hold lfs_newseg at segment 0; if requested, sleep until
2089 * the filesystem wraps around. To support external agents
2090 * (dump, fsck-based regression test) that need to look at
2091 * a snapshot of the filesystem, without necessarily
2092 * requiring that all fs activity stops.
2093 */
2094 if (fs->lfs_stoplwp == curlwp)
2095 return EALREADY;
2096
2097 mutex_enter(&lfs_lock);
2098 while (fs->lfs_stoplwp != NULL)
2099 cv_wait(&fs->lfs_stopcv, &lfs_lock);
2100 fs->lfs_stoplwp = curlwp;
2101 if (fs->lfs_nowrap == 0)
2102 log(LOG_NOTICE, "%s: disabled log wrap\n",
2103 lfs_sb_getfsmnt(fs));
2104 ++fs->lfs_nowrap;
2105 if (*(int *)ap->a_data == 1
2106 || ap->a_command == LFCNWRAPSTOP_COMPAT) {
2107 log(LOG_NOTICE, "LFCNSTOPWRAP waiting for log wrap\n");
2108 error = mtsleep(&fs->lfs_nowrap, PCATCH | PUSER,
2109 "segwrap", 0, &lfs_lock);
2110 log(LOG_NOTICE, "LFCNSTOPWRAP done waiting\n");
2111 if (error) {
2112 lfs_wrapgo(fs, VTOI(ap->a_vp), 0);
2113 }
2114 }
2115 mutex_exit(&lfs_lock);
2116 return 0;
2117
2118 case LFCNWRAPGO:
2119 case LFCNWRAPGO_COMPAT:
2120 /*
2121 * Having done its work, the agent wakes up the writer.
2122 * If the argument is 1, it sleeps until a new segment
2123 * is selected.
2124 */
2125 mutex_enter(&lfs_lock);
2126 error = lfs_wrapgo(fs, VTOI(ap->a_vp),
2127 ap->a_command == LFCNWRAPGO_COMPAT ? 1 :
2128 *((int *)ap->a_data));
2129 mutex_exit(&lfs_lock);
2130 return error;
2131
2132 case LFCNWRAPPASS:
2133 if ((VTOI(ap->a_vp)->i_lfs_iflags & LFSI_WRAPWAIT))
2134 return EALREADY;
2135 mutex_enter(&lfs_lock);
2136 if (fs->lfs_stoplwp != curlwp) {
2137 mutex_exit(&lfs_lock);
2138 return EALREADY;
2139 }
2140 if (fs->lfs_nowrap == 0) {
2141 mutex_exit(&lfs_lock);
2142 return EBUSY;
2143 }
2144 fs->lfs_wrappass = 1;
2145 wakeup(&fs->lfs_wrappass);
2146 /* Wait for the log to wrap, if asked */
2147 if (*(int *)ap->a_data) {
2148 vref(ap->a_vp);
2149 VTOI(ap->a_vp)->i_lfs_iflags |= LFSI_WRAPWAIT;
2150 log(LOG_NOTICE, "LFCNPASS waiting for log wrap\n");
2151 error = mtsleep(&fs->lfs_nowrap, PCATCH | PUSER,
2152 "segwrap", 0, &lfs_lock);
2153 log(LOG_NOTICE, "LFCNPASS done waiting\n");
2154 VTOI(ap->a_vp)->i_lfs_iflags &= ~LFSI_WRAPWAIT;
2155 vrele(ap->a_vp);
2156 }
2157 mutex_exit(&lfs_lock);
2158 return error;
2159
2160 case LFCNWRAPSTATUS:
2161 mutex_enter(&lfs_lock);
2162 *(int *)ap->a_data = fs->lfs_wrapstatus;
2163 mutex_exit(&lfs_lock);
2164 return 0;
2165
2166 default:
2167 return ulfs_fcntl(v);
2168 }
2169 return 0;
2170 }
2171
2172 /*
2173 * Return the last logical file offset that should be written for this file
2174 * if we're doing a write that ends at "size". If writing, we need to know
2175 * about sizes on disk, i.e. fragments if there are any; if reading, we need
2176 * to know about entire blocks.
2177 */
2178 void
2179 lfs_gop_size(struct vnode *vp, off_t size, off_t *eobp, int flags)
2180 {
2181 struct inode *ip = VTOI(vp);
2182 struct lfs *fs = ip->i_lfs;
2183 daddr_t olbn, nlbn;
2184
2185 olbn = lfs_lblkno(fs, ip->i_size);
2186 nlbn = lfs_lblkno(fs, size);
2187 if (!(flags & GOP_SIZE_MEM) && nlbn < ULFS_NDADDR && olbn <= nlbn) {
2188 *eobp = lfs_fragroundup(fs, size);
2189 } else {
2190 *eobp = lfs_blkroundup(fs, size);
2191 }
2192 }
2193
2194 #ifdef DEBUG
2195 void lfs_dump_vop(void *);
2196
2197 void
2198 lfs_dump_vop(void *v)
2199 {
2200 struct vop_putpages_args /* {
2201 struct vnode *a_vp;
2202 voff_t a_offlo;
2203 voff_t a_offhi;
2204 int a_flags;
2205 } */ *ap = v;
2206
2207 struct inode *ip = VTOI(ap->a_vp);
2208 struct lfs *fs = ip->i_lfs;
2209
2210 #ifdef DDB
2211 vfs_vnode_print(ap->a_vp, 0, printf);
2212 #endif
2213 lfs_dump_dinode(fs, ip->i_din);
2214 }
2215 #endif
2216
2217 int
2218 lfs_mmap(void *v)
2219 {
2220 struct vop_mmap_args /* {
2221 const struct vnodeop_desc *a_desc;
2222 struct vnode *a_vp;
2223 vm_prot_t a_prot;
2224 kauth_cred_t a_cred;
2225 } */ *ap = v;
2226
2227 if (VTOI(ap->a_vp)->i_number == LFS_IFILE_INUM)
2228 return EOPNOTSUPP;
2229 return ulfs_mmap(v);
2230 }
2231
2232 static int
2233 lfs_openextattr(void *v)
2234 {
2235 struct vop_openextattr_args /* {
2236 struct vnode *a_vp;
2237 kauth_cred_t a_cred;
2238 struct proc *a_p;
2239 } */ *ap = v;
2240 struct vnode *vp = ap->a_vp;
2241 struct inode *ip;
2242 struct ulfsmount *ump;
2243
2244 KASSERT(VOP_ISLOCKED(vp) == LK_EXCLUSIVE);
2245
2246 ip = VTOI(vp);
2247 ump = ip->i_ump;
2248
2249 /* Not supported for ULFS1 file systems. */
2250 if (ump->um_fstype == ULFS1)
2251 return (EOPNOTSUPP);
2252
2253 /* XXX Not implemented for ULFS2 file systems. */
2254 return (EOPNOTSUPP);
2255 }
2256
2257 static int
2258 lfs_closeextattr(void *v)
2259 {
2260 struct vop_closeextattr_args /* {
2261 struct vnode *a_vp;
2262 int a_commit;
2263 kauth_cred_t a_cred;
2264 struct proc *a_p;
2265 } */ *ap = v;
2266 struct vnode *vp = ap->a_vp;
2267 struct inode *ip;
2268 struct ulfsmount *ump;
2269
2270 KASSERT(VOP_ISLOCKED(vp) == LK_EXCLUSIVE);
2271
2272 ip = VTOI(vp);
2273 ump = ip->i_ump;
2274
2275 /* Not supported for ULFS1 file systems. */
2276 if (ump->um_fstype == ULFS1)
2277 return (EOPNOTSUPP);
2278
2279 /* XXX Not implemented for ULFS2 file systems. */
2280 return (EOPNOTSUPP);
2281 }
2282
2283 static int
2284 lfs_getextattr(void *v)
2285 {
2286 struct vop_getextattr_args /* {
2287 struct vnode *a_vp;
2288 int a_attrnamespace;
2289 const char *a_name;
2290 struct uio *a_uio;
2291 size_t *a_size;
2292 kauth_cred_t a_cred;
2293 struct proc *a_p;
2294 } */ *ap = v;
2295 struct vnode *vp = ap->a_vp;
2296 struct inode *ip;
2297 struct ulfsmount *ump;
2298 int error;
2299
2300 KASSERT(VOP_ISLOCKED(vp));
2301
2302 ip = VTOI(vp);
2303 ump = ip->i_ump;
2304
2305 if (ump->um_fstype == ULFS1) {
2306 #ifdef LFS_EXTATTR
2307 error = ulfs_getextattr(ap);
2308 #else
2309 error = EOPNOTSUPP;
2310 #endif
2311 return error;
2312 }
2313
2314 /* XXX Not implemented for ULFS2 file systems. */
2315 return (EOPNOTSUPP);
2316 }
2317
2318 static int
2319 lfs_setextattr(void *v)
2320 {
2321 struct vop_setextattr_args /* {
2322 struct vnode *a_vp;
2323 int a_attrnamespace;
2324 const char *a_name;
2325 struct uio *a_uio;
2326 kauth_cred_t a_cred;
2327 struct proc *a_p;
2328 } */ *ap = v;
2329 struct vnode *vp = ap->a_vp;
2330 struct inode *ip;
2331 struct ulfsmount *ump;
2332 int error;
2333
2334 KASSERT(VOP_ISLOCKED(vp) == LK_EXCLUSIVE);
2335
2336 ip = VTOI(vp);
2337 ump = ip->i_ump;
2338
2339 if (ump->um_fstype == ULFS1) {
2340 #ifdef LFS_EXTATTR
2341 error = ulfs_setextattr(ap);
2342 #else
2343 error = EOPNOTSUPP;
2344 #endif
2345 return error;
2346 }
2347
2348 /* XXX Not implemented for ULFS2 file systems. */
2349 return (EOPNOTSUPP);
2350 }
2351
2352 static int
2353 lfs_listextattr(void *v)
2354 {
2355 struct vop_listextattr_args /* {
2356 struct vnode *a_vp;
2357 int a_attrnamespace;
2358 struct uio *a_uio;
2359 size_t *a_size;
2360 kauth_cred_t a_cred;
2361 struct proc *a_p;
2362 } */ *ap = v;
2363 struct vnode *vp = ap->a_vp;
2364 struct inode *ip;
2365 struct ulfsmount *ump;
2366 int error;
2367
2368 KASSERT(VOP_ISLOCKED(vp));
2369
2370 ip = VTOI(vp);
2371 ump = ip->i_ump;
2372
2373 if (ump->um_fstype == ULFS1) {
2374 #ifdef LFS_EXTATTR
2375 error = ulfs_listextattr(ap);
2376 #else
2377 error = EOPNOTSUPP;
2378 #endif
2379 return error;
2380 }
2381
2382 /* XXX Not implemented for ULFS2 file systems. */
2383 return (EOPNOTSUPP);
2384 }
2385
2386 static int
2387 lfs_deleteextattr(void *v)
2388 {
2389 struct vop_deleteextattr_args /* {
2390 struct vnode *a_vp;
2391 int a_attrnamespace;
2392 kauth_cred_t a_cred;
2393 struct proc *a_p;
2394 } */ *ap = v;
2395 struct vnode *vp = ap->a_vp;
2396 struct inode *ip;
2397 struct ulfsmount *ump;
2398 int error;
2399
2400 KASSERT(VOP_ISLOCKED(vp) == LK_EXCLUSIVE);
2401
2402 ip = VTOI(vp);
2403 ump = ip->i_ump;
2404
2405 if (ump->um_fstype == ULFS1) {
2406 #ifdef LFS_EXTATTR
2407 error = ulfs_deleteextattr(ap);
2408 #else
2409 error = EOPNOTSUPP;
2410 #endif
2411 return error;
2412 }
2413
2414 /* XXX Not implemented for ULFS2 file systems. */
2415 return (EOPNOTSUPP);
2416 }
2417
2418