lfs_vnops.c revision 1.62 1 /* $NetBSD: lfs_vnops.c,v 1.62 2002/04/27 01:00:46 perseant Exp $ */
2
3 /*-
4 * Copyright (c) 1999, 2000 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 * 3. All advertising materials mentioning features or use of this software
19 * must display the following acknowledgement:
20 * This product includes software developed by the NetBSD
21 * Foundation, Inc. and its contributors.
22 * 4. Neither the name of The NetBSD Foundation nor the names of its
23 * contributors may be used to endorse or promote products derived
24 * from this software without specific prior written permission.
25 *
26 * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
27 * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
28 * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
29 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
30 * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
31 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
32 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
33 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
34 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
35 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
36 * POSSIBILITY OF SUCH DAMAGE.
37 */
38 /*
39 * Copyright (c) 1986, 1989, 1991, 1993, 1995
40 * The Regents of the University of California. All rights reserved.
41 *
42 * Redistribution and use in source and binary forms, with or without
43 * modification, are permitted provided that the following conditions
44 * are met:
45 * 1. Redistributions of source code must retain the above copyright
46 * notice, this list of conditions and the following disclaimer.
47 * 2. Redistributions in binary form must reproduce the above copyright
48 * notice, this list of conditions and the following disclaimer in the
49 * documentation and/or other materials provided with the distribution.
50 * 3. All advertising materials mentioning features or use of this software
51 * must display the following acknowledgement:
52 * This product includes software developed by the University of
53 * California, Berkeley and its contributors.
54 * 4. Neither the name of the University nor the names of its contributors
55 * may be used to endorse or promote products derived from this software
56 * without specific prior written permission.
57 *
58 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
59 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
60 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
61 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
62 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
63 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
64 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
65 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
66 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
67 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
68 * SUCH DAMAGE.
69 *
70 * @(#)lfs_vnops.c 8.13 (Berkeley) 6/10/95
71 */
72
73 #include <sys/cdefs.h>
74 __KERNEL_RCSID(0, "$NetBSD: lfs_vnops.c,v 1.62 2002/04/27 01:00:46 perseant Exp $");
75
76 #include <sys/param.h>
77 #include <sys/systm.h>
78 #include <sys/namei.h>
79 #include <sys/resourcevar.h>
80 #include <sys/kernel.h>
81 #include <sys/file.h>
82 #include <sys/stat.h>
83 #include <sys/buf.h>
84 #include <sys/proc.h>
85 #include <sys/conf.h>
86 #include <sys/mount.h>
87 #include <sys/vnode.h>
88 #include <sys/malloc.h>
89 #include <sys/pool.h>
90 #include <sys/signalvar.h>
91
92 #include <miscfs/fifofs/fifo.h>
93 #include <miscfs/genfs/genfs.h>
94 #include <miscfs/specfs/specdev.h>
95
96 #include <ufs/ufs/inode.h>
97 #include <ufs/ufs/dir.h>
98 #include <ufs/ufs/ufsmount.h>
99 #include <ufs/ufs/ufs_extern.h>
100
101 #include <ufs/lfs/lfs.h>
102 #include <ufs/lfs/lfs_extern.h>
103
104 /* Global vfs data structures for lfs. */
105 int (**lfs_vnodeop_p)(void *);
106 const struct vnodeopv_entry_desc lfs_vnodeop_entries[] = {
107 { &vop_default_desc, vn_default_error },
108 { &vop_lookup_desc, ufs_lookup }, /* lookup */
109 { &vop_create_desc, lfs_create }, /* create */
110 { &vop_whiteout_desc, lfs_whiteout }, /* whiteout */
111 { &vop_mknod_desc, lfs_mknod }, /* mknod */
112 { &vop_open_desc, ufs_open }, /* open */
113 { &vop_close_desc, lfs_close }, /* close */
114 { &vop_access_desc, ufs_access }, /* access */
115 { &vop_getattr_desc, lfs_getattr }, /* getattr */
116 { &vop_setattr_desc, lfs_setattr }, /* setattr */
117 { &vop_read_desc, lfs_read }, /* read */
118 { &vop_write_desc, lfs_write }, /* write */
119 { &vop_lease_desc, ufs_lease_check }, /* lease */
120 { &vop_ioctl_desc, ufs_ioctl }, /* ioctl */
121 { &vop_fcntl_desc, ufs_fcntl }, /* fcntl */
122 { &vop_poll_desc, ufs_poll }, /* poll */
123 { &vop_revoke_desc, ufs_revoke }, /* revoke */
124 { &vop_mmap_desc, ufs_mmap }, /* mmap */
125 { &vop_fsync_desc, lfs_fsync }, /* fsync */
126 { &vop_seek_desc, ufs_seek }, /* seek */
127 { &vop_remove_desc, lfs_remove }, /* remove */
128 { &vop_link_desc, lfs_link }, /* link */
129 { &vop_rename_desc, lfs_rename }, /* rename */
130 { &vop_mkdir_desc, lfs_mkdir }, /* mkdir */
131 { &vop_rmdir_desc, lfs_rmdir }, /* rmdir */
132 { &vop_symlink_desc, lfs_symlink }, /* symlink */
133 { &vop_readdir_desc, ufs_readdir }, /* readdir */
134 { &vop_readlink_desc, ufs_readlink }, /* readlink */
135 { &vop_abortop_desc, ufs_abortop }, /* abortop */
136 { &vop_inactive_desc, lfs_inactive }, /* inactive */
137 { &vop_reclaim_desc, lfs_reclaim }, /* reclaim */
138 { &vop_lock_desc, ufs_lock }, /* lock */
139 { &vop_unlock_desc, ufs_unlock }, /* unlock */
140 { &vop_bmap_desc, ufs_bmap }, /* bmap */
141 { &vop_strategy_desc, ufs_strategy }, /* strategy */
142 { &vop_print_desc, ufs_print }, /* print */
143 { &vop_islocked_desc, ufs_islocked }, /* islocked */
144 { &vop_pathconf_desc, ufs_pathconf }, /* pathconf */
145 { &vop_advlock_desc, ufs_advlock }, /* advlock */
146 { &vop_blkatoff_desc, lfs_blkatoff }, /* blkatoff */
147 { &vop_valloc_desc, lfs_valloc }, /* valloc */
148 { &vop_balloc_desc, lfs_balloc }, /* balloc */
149 { &vop_vfree_desc, lfs_vfree }, /* vfree */
150 { &vop_truncate_desc, lfs_truncate }, /* truncate */
151 { &vop_update_desc, lfs_update }, /* update */
152 { &vop_bwrite_desc, lfs_bwrite }, /* bwrite */
153 { &vop_getpages_desc, lfs_getpages }, /* getpages */
154 { &vop_putpages_desc, lfs_putpages }, /* putpages */
155 { NULL, NULL }
156 };
157 const struct vnodeopv_desc lfs_vnodeop_opv_desc =
158 { &lfs_vnodeop_p, lfs_vnodeop_entries };
159
160 int (**lfs_specop_p)(void *);
161 const struct vnodeopv_entry_desc lfs_specop_entries[] = {
162 { &vop_default_desc, vn_default_error },
163 { &vop_lookup_desc, spec_lookup }, /* lookup */
164 { &vop_create_desc, spec_create }, /* create */
165 { &vop_mknod_desc, spec_mknod }, /* mknod */
166 { &vop_open_desc, spec_open }, /* open */
167 { &vop_close_desc, ufsspec_close }, /* close */
168 { &vop_access_desc, ufs_access }, /* access */
169 { &vop_getattr_desc, lfs_getattr }, /* getattr */
170 { &vop_setattr_desc, lfs_setattr }, /* setattr */
171 { &vop_read_desc, ufsspec_read }, /* read */
172 { &vop_write_desc, ufsspec_write }, /* write */
173 { &vop_lease_desc, spec_lease_check }, /* lease */
174 { &vop_ioctl_desc, spec_ioctl }, /* ioctl */
175 { &vop_fcntl_desc, ufs_fcntl }, /* fcntl */
176 { &vop_poll_desc, spec_poll }, /* poll */
177 { &vop_revoke_desc, spec_revoke }, /* revoke */
178 { &vop_mmap_desc, spec_mmap }, /* mmap */
179 { &vop_fsync_desc, spec_fsync }, /* fsync */
180 { &vop_seek_desc, spec_seek }, /* seek */
181 { &vop_remove_desc, spec_remove }, /* remove */
182 { &vop_link_desc, spec_link }, /* link */
183 { &vop_rename_desc, spec_rename }, /* rename */
184 { &vop_mkdir_desc, spec_mkdir }, /* mkdir */
185 { &vop_rmdir_desc, spec_rmdir }, /* rmdir */
186 { &vop_symlink_desc, spec_symlink }, /* symlink */
187 { &vop_readdir_desc, spec_readdir }, /* readdir */
188 { &vop_readlink_desc, spec_readlink }, /* readlink */
189 { &vop_abortop_desc, spec_abortop }, /* abortop */
190 { &vop_inactive_desc, lfs_inactive }, /* inactive */
191 { &vop_reclaim_desc, lfs_reclaim }, /* reclaim */
192 { &vop_lock_desc, ufs_lock }, /* lock */
193 { &vop_unlock_desc, ufs_unlock }, /* unlock */
194 { &vop_bmap_desc, spec_bmap }, /* bmap */
195 { &vop_strategy_desc, spec_strategy }, /* strategy */
196 { &vop_print_desc, ufs_print }, /* print */
197 { &vop_islocked_desc, ufs_islocked }, /* islocked */
198 { &vop_pathconf_desc, spec_pathconf }, /* pathconf */
199 { &vop_advlock_desc, spec_advlock }, /* advlock */
200 { &vop_blkatoff_desc, spec_blkatoff }, /* blkatoff */
201 { &vop_valloc_desc, spec_valloc }, /* valloc */
202 { &vop_vfree_desc, lfs_vfree }, /* vfree */
203 { &vop_truncate_desc, spec_truncate }, /* truncate */
204 { &vop_update_desc, lfs_update }, /* update */
205 { &vop_bwrite_desc, vn_bwrite }, /* bwrite */
206 { &vop_getpages_desc, spec_getpages }, /* getpages */
207 { &vop_putpages_desc, spec_putpages }, /* putpages */
208 { NULL, NULL }
209 };
210 const struct vnodeopv_desc lfs_specop_opv_desc =
211 { &lfs_specop_p, lfs_specop_entries };
212
213 int (**lfs_fifoop_p)(void *);
214 const struct vnodeopv_entry_desc lfs_fifoop_entries[] = {
215 { &vop_default_desc, vn_default_error },
216 { &vop_lookup_desc, fifo_lookup }, /* lookup */
217 { &vop_create_desc, fifo_create }, /* create */
218 { &vop_mknod_desc, fifo_mknod }, /* mknod */
219 { &vop_open_desc, fifo_open }, /* open */
220 { &vop_close_desc, ufsfifo_close }, /* close */
221 { &vop_access_desc, ufs_access }, /* access */
222 { &vop_getattr_desc, lfs_getattr }, /* getattr */
223 { &vop_setattr_desc, lfs_setattr }, /* setattr */
224 { &vop_read_desc, ufsfifo_read }, /* read */
225 { &vop_write_desc, ufsfifo_write }, /* write */
226 { &vop_lease_desc, fifo_lease_check }, /* lease */
227 { &vop_ioctl_desc, fifo_ioctl }, /* ioctl */
228 { &vop_fcntl_desc, ufs_fcntl }, /* fcntl */
229 { &vop_poll_desc, fifo_poll }, /* poll */
230 { &vop_revoke_desc, fifo_revoke }, /* revoke */
231 { &vop_mmap_desc, fifo_mmap }, /* mmap */
232 { &vop_fsync_desc, fifo_fsync }, /* fsync */
233 { &vop_seek_desc, fifo_seek }, /* seek */
234 { &vop_remove_desc, fifo_remove }, /* remove */
235 { &vop_link_desc, fifo_link }, /* link */
236 { &vop_rename_desc, fifo_rename }, /* rename */
237 { &vop_mkdir_desc, fifo_mkdir }, /* mkdir */
238 { &vop_rmdir_desc, fifo_rmdir }, /* rmdir */
239 { &vop_symlink_desc, fifo_symlink }, /* symlink */
240 { &vop_readdir_desc, fifo_readdir }, /* readdir */
241 { &vop_readlink_desc, fifo_readlink }, /* readlink */
242 { &vop_abortop_desc, fifo_abortop }, /* abortop */
243 { &vop_inactive_desc, lfs_inactive }, /* inactive */
244 { &vop_reclaim_desc, lfs_reclaim }, /* reclaim */
245 { &vop_lock_desc, ufs_lock }, /* lock */
246 { &vop_unlock_desc, ufs_unlock }, /* unlock */
247 { &vop_bmap_desc, fifo_bmap }, /* bmap */
248 { &vop_strategy_desc, fifo_strategy }, /* strategy */
249 { &vop_print_desc, ufs_print }, /* print */
250 { &vop_islocked_desc, ufs_islocked }, /* islocked */
251 { &vop_pathconf_desc, fifo_pathconf }, /* pathconf */
252 { &vop_advlock_desc, fifo_advlock }, /* advlock */
253 { &vop_blkatoff_desc, fifo_blkatoff }, /* blkatoff */
254 { &vop_valloc_desc, fifo_valloc }, /* valloc */
255 { &vop_vfree_desc, lfs_vfree }, /* vfree */
256 { &vop_truncate_desc, fifo_truncate }, /* truncate */
257 { &vop_update_desc, lfs_update }, /* update */
258 { &vop_bwrite_desc, lfs_bwrite }, /* bwrite */
259 { &vop_putpages_desc, fifo_putpages }, /* putpages */
260 { NULL, NULL }
261 };
262 const struct vnodeopv_desc lfs_fifoop_opv_desc =
263 { &lfs_fifoop_p, lfs_fifoop_entries };
264
265 /*
266 * A function version of LFS_ITIMES, for the UFS functions which call ITIMES
267 */
268 void
269 lfs_itimes(struct inode *ip, struct timespec *acc, struct timespec *mod, struct timespec *cre)
270 {
271 LFS_ITIMES(ip, acc, mod, cre);
272 }
273
274 #define LFS_READWRITE
275 #include <ufs/ufs/ufs_readwrite.c>
276 #undef LFS_READWRITE
277
278 /*
279 * Synch an open file.
280 */
281 /* ARGSUSED */
282 int
283 lfs_fsync(void *v)
284 {
285 struct vop_fsync_args /* {
286 struct vnode *a_vp;
287 struct ucred *a_cred;
288 int a_flags;
289 off_t offlo;
290 off_t offhi;
291 struct proc *a_p;
292 } */ *ap = v;
293 struct vnode *vp = ap->a_vp;
294 int error;
295
296 /* Ignore the trickle syncer */
297 if (ap->a_flags & FSYNC_LAZY)
298 return 0;
299
300 simple_lock(&vp->v_interlock);
301 error = VOP_PUTPAGES(vp, trunc_page(ap->a_offlo),
302 round_page(ap->a_offhi), PGO_CLEANIT | PGO_SYNCIO);
303 if (error) {
304 return error;
305 }
306 return (VOP_UPDATE(vp, NULL, NULL,
307 (ap->a_flags & FSYNC_WAIT) != 0 ? UPDATE_WAIT : 0));
308 }
309
310 /*
311 * Take IN_ADIROP off, then call ufs_inactive.
312 */
313 int
314 lfs_inactive(void *v)
315 {
316 struct vop_inactive_args /* {
317 struct vnode *a_vp;
318 struct proc *a_p;
319 } */ *ap = v;
320 struct inode *ip = VTOI(ap->a_vp);
321
322 if (ip->i_flag & IN_ADIROP)
323 --ip->i_lfs->lfs_nadirop;
324 ip->i_flag &= ~IN_ADIROP;
325 return ufs_inactive(v);
326 }
327
328 /*
329 * These macros are used to bracket UFS directory ops, so that we can
330 * identify all the pages touched during directory ops which need to
331 * be ordered and flushed atomically, so that they may be recovered.
332 */
333 /*
334 * XXX KS - Because we have to mark nodes VDIROP in order to prevent
335 * the cache from reclaiming them while a dirop is in progress, we must
336 * also manage the number of nodes so marked (otherwise we can run out).
337 * We do this by setting lfs_dirvcount to the number of marked vnodes; it
338 * is decremented during segment write, when VDIROP is taken off.
339 */
340 #define SET_DIROP(vp) lfs_set_dirop(vp)
341 static int lfs_set_dirop(struct vnode *);
342 extern int lfs_dirvcount;
343
344 static int
345 lfs_set_dirop(struct vnode *vp)
346 {
347 struct lfs *fs;
348 int error;
349
350 fs = VTOI(vp)->i_lfs;
351 /*
352 * We might need one directory block plus supporting indirect blocks,
353 * plus an inode block and ifile page for the new vnode.
354 */
355 if ((error = lfs_reserve(fs, vp, btofsb(fs, (NIADDR + 3) << fs->lfs_bshift))) != 0)
356 return (error);
357 if (fs->lfs_dirops == 0)
358 lfs_check(vp, LFS_UNUSED_LBN, 0);
359 while (fs->lfs_writer || lfs_dirvcount > LFS_MAXDIROP) {
360 if (fs->lfs_writer)
361 tsleep(&fs->lfs_dirops, PRIBIO + 1, "lfs_dirop", 0);
362 if (lfs_dirvcount > LFS_MAXDIROP && fs->lfs_dirops == 0) {
363 ++fs->lfs_writer;
364 lfs_flush(fs, 0);
365 if (--fs->lfs_writer == 0)
366 wakeup(&fs->lfs_dirops);
367 }
368
369 if (lfs_dirvcount > LFS_MAXDIROP) {
370 #ifdef DEBUG_LFS
371 printf("lfs_set_dirop: sleeping with dirops=%d, "
372 "dirvcount=%d\n", fs->lfs_dirops,
373 lfs_dirvcount);
374 #endif
375 if ((error = tsleep(&lfs_dirvcount, PCATCH|PUSER,
376 "lfs_maxdirop", 0)) != 0) {
377 lfs_reserve(fs, vp, -btofsb(fs, (NIADDR + 3) << fs->lfs_bshift));
378 return error;
379 }
380 }
381 }
382 ++fs->lfs_dirops;
383 fs->lfs_doifile = 1;
384
385 /* Hold a reference so SET_ENDOP will be happy */
386 lfs_vref(vp);
387
388 return 0;
389 }
390
391 #define SET_ENDOP(fs,vp,str) { \
392 --(fs)->lfs_dirops; \
393 if (!(fs)->lfs_dirops) { \
394 if ((fs)->lfs_nadirop) { \
395 panic("SET_ENDOP: %s: no dirops but nadirop=%d\n", \
396 (str), (fs)->lfs_nadirop); \
397 } \
398 wakeup(&(fs)->lfs_writer); \
399 lfs_check((vp),LFS_UNUSED_LBN,0); \
400 } \
401 lfs_reserve((fs), vp, -btofsb((fs), (NIADDR + 3) << (fs)->lfs_bshift)); /* XXX */ \
402 lfs_vunref(vp); \
403 }
404
405 #define MARK_VNODE(dvp) do { \
406 if (!((dvp)->v_flag & VDIROP)) { \
407 (void)lfs_vref(dvp); \
408 ++lfs_dirvcount; \
409 } \
410 (dvp)->v_flag |= VDIROP; \
411 if (!(VTOI(dvp)->i_flag & IN_ADIROP)) { \
412 ++VTOI(dvp)->i_lfs->lfs_nadirop; \
413 } \
414 VTOI(dvp)->i_flag |= IN_ADIROP; \
415 } while (0)
416
417 #define UNMARK_VNODE(vp) lfs_unmark_vnode(vp)
418
419 void lfs_unmark_vnode(struct vnode *vp)
420 {
421 struct inode *ip;
422
423 ip = VTOI(vp);
424
425 if (ip->i_flag & IN_ADIROP)
426 --ip->i_lfs->lfs_nadirop;
427 ip->i_flag &= ~IN_ADIROP;
428 }
429
430 int
431 lfs_symlink(void *v)
432 {
433 struct vop_symlink_args /* {
434 struct vnode *a_dvp;
435 struct vnode **a_vpp;
436 struct componentname *a_cnp;
437 struct vattr *a_vap;
438 char *a_target;
439 } */ *ap = v;
440 int error;
441
442 if ((error = SET_DIROP(ap->a_dvp)) != 0) {
443 vput(ap->a_dvp);
444 return error;
445 }
446 MARK_VNODE(ap->a_dvp);
447 error = ufs_symlink(ap);
448 UNMARK_VNODE(ap->a_dvp);
449 if (*(ap->a_vpp))
450 UNMARK_VNODE(*(ap->a_vpp));
451 SET_ENDOP(VTOI(ap->a_dvp)->i_lfs,ap->a_dvp,"symlink");
452 return (error);
453 }
454
455 int
456 lfs_mknod(void *v)
457 {
458 struct vop_mknod_args /* {
459 struct vnode *a_dvp;
460 struct vnode **a_vpp;
461 struct componentname *a_cnp;
462 struct vattr *a_vap;
463 } */ *ap = v;
464 struct vattr *vap = ap->a_vap;
465 struct vnode **vpp = ap->a_vpp;
466 struct inode *ip;
467 int error;
468 struct mount *mp;
469 ino_t ino;
470
471 if ((error = SET_DIROP(ap->a_dvp)) != 0) {
472 vput(ap->a_dvp);
473 return error;
474 }
475 MARK_VNODE(ap->a_dvp);
476 error = ufs_makeinode(MAKEIMODE(vap->va_type, vap->va_mode),
477 ap->a_dvp, vpp, ap->a_cnp);
478 UNMARK_VNODE(ap->a_dvp);
479 if (*(ap->a_vpp))
480 UNMARK_VNODE(*(ap->a_vpp));
481
482 /* Either way we're done with the dirop at this point */
483 SET_ENDOP(VTOI(ap->a_dvp)->i_lfs,ap->a_dvp,"mknod");
484
485 if (error)
486 return (error);
487
488 ip = VTOI(*vpp);
489 mp = (*vpp)->v_mount;
490 ino = ip->i_number;
491 ip->i_flag |= IN_ACCESS | IN_CHANGE | IN_UPDATE;
492 if (vap->va_rdev != VNOVAL) {
493 /*
494 * Want to be able to use this to make badblock
495 * inodes, so don't truncate the dev number.
496 */
497 #if 0
498 ip->i_ffs_rdev = ufs_rw32(vap->va_rdev,
499 UFS_MPNEEDSWAP((*vpp)->v_mount));
500 #else
501 ip->i_ffs_rdev = vap->va_rdev;
502 #endif
503 }
504 /*
505 * Call fsync to write the vnode so that we don't have to deal with
506 * flushing it when it's marked VDIROP|VXLOCK.
507 *
508 * XXX KS - If we can't flush we also can't call vgone(), so must
509 * return. But, that leaves this vnode in limbo, also not good.
510 * Can this ever happen (barring hardware failure)?
511 */
512 if ((error = VOP_FSYNC(*vpp, NOCRED, FSYNC_WAIT, 0, 0, curproc)) != 0) {
513 printf("Couldn't fsync in mknod (ino %d)---what do I do?\n",
514 VTOI(*vpp)->i_number);
515 return (error);
516 }
517 /*
518 * Remove vnode so that it will be reloaded by VFS_VGET and
519 * checked to see if it is an alias of an existing entry in
520 * the inode cache.
521 */
522 /* Used to be vput, but that causes us to call VOP_INACTIVE twice. */
523 VOP_UNLOCK(*vpp, 0);
524 lfs_vunref(*vpp);
525 (*vpp)->v_type = VNON;
526 vgone(*vpp);
527 error = VFS_VGET(mp, ino, vpp);
528 if (error != 0) {
529 *vpp = NULL;
530 return (error);
531 }
532 return (0);
533 }
534
535 int
536 lfs_create(void *v)
537 {
538 struct vop_create_args /* {
539 struct vnode *a_dvp;
540 struct vnode **a_vpp;
541 struct componentname *a_cnp;
542 struct vattr *a_vap;
543 } */ *ap = v;
544 int error;
545
546 if ((error = SET_DIROP(ap->a_dvp)) != 0) {
547 vput(ap->a_dvp);
548 return error;
549 }
550 MARK_VNODE(ap->a_dvp);
551 error = ufs_create(ap);
552 UNMARK_VNODE(ap->a_dvp);
553 if (*(ap->a_vpp))
554 UNMARK_VNODE(*(ap->a_vpp));
555 SET_ENDOP(VTOI(ap->a_dvp)->i_lfs,ap->a_dvp,"create");
556 return (error);
557 }
558
559 int
560 lfs_whiteout(void *v)
561 {
562 struct vop_whiteout_args /* {
563 struct vnode *a_dvp;
564 struct componentname *a_cnp;
565 int a_flags;
566 } */ *ap = v;
567 int error;
568
569 if ((error = SET_DIROP(ap->a_dvp)) != 0)
570 /* XXX no unlock here? */
571 return error;
572 MARK_VNODE(ap->a_dvp);
573 error = ufs_whiteout(ap);
574 UNMARK_VNODE(ap->a_dvp);
575 SET_ENDOP(VTOI(ap->a_dvp)->i_lfs,ap->a_dvp,"whiteout");
576 return (error);
577 }
578
579 int
580 lfs_mkdir(void *v)
581 {
582 struct vop_mkdir_args /* {
583 struct vnode *a_dvp;
584 struct vnode **a_vpp;
585 struct componentname *a_cnp;
586 struct vattr *a_vap;
587 } */ *ap = v;
588 int error;
589
590 if ((error = SET_DIROP(ap->a_dvp)) != 0) {
591 vput(ap->a_dvp);
592 return error;
593 }
594 MARK_VNODE(ap->a_dvp);
595 error = ufs_mkdir(ap);
596 UNMARK_VNODE(ap->a_dvp);
597 if (*(ap->a_vpp))
598 UNMARK_VNODE(*(ap->a_vpp));
599 SET_ENDOP(VTOI(ap->a_dvp)->i_lfs,ap->a_dvp,"mkdir");
600 return (error);
601 }
602
603 int
604 lfs_remove(void *v)
605 {
606 struct vop_remove_args /* {
607 struct vnode *a_dvp;
608 struct vnode *a_vp;
609 struct componentname *a_cnp;
610 } */ *ap = v;
611 struct vnode *dvp, *vp;
612 int error;
613
614 dvp = ap->a_dvp;
615 vp = ap->a_vp;
616 if ((error = SET_DIROP(dvp)) != 0) {
617 if (dvp == vp)
618 vrele(vp);
619 else
620 vput(vp);
621 vput(dvp);
622 return error;
623 }
624 MARK_VNODE(dvp);
625 MARK_VNODE(vp);
626 error = ufs_remove(ap);
627 UNMARK_VNODE(dvp);
628 UNMARK_VNODE(vp);
629
630 /*
631 * If ufs_remove failed, vp doesn't need to be VDIROP any more.
632 * If it succeeded, we can go ahead and wipe out vp, since
633 * its loss won't appear on disk until checkpoint, and by then
634 * dvp will have been written, completing the dirop.
635 */
636 --lfs_dirvcount;
637 vp->v_flag &= ~VDIROP;
638 wakeup(&lfs_dirvcount);
639 vrele(vp);
640
641 SET_ENDOP(VTOI(dvp)->i_lfs,dvp,"remove");
642 return (error);
643 }
644
645 int
646 lfs_rmdir(void *v)
647 {
648 struct vop_rmdir_args /* {
649 struct vnodeop_desc *a_desc;
650 struct vnode *a_dvp;
651 struct vnode *a_vp;
652 struct componentname *a_cnp;
653 } */ *ap = v;
654 int error;
655
656 if ((error = SET_DIROP(ap->a_dvp)) != 0) {
657 vrele(ap->a_dvp);
658 if (ap->a_vp->v_mountedhere != NULL)
659 VOP_UNLOCK(ap->a_dvp, 0);
660 vput(ap->a_vp);
661 return error;
662 }
663 MARK_VNODE(ap->a_dvp);
664 MARK_VNODE(ap->a_vp);
665 error = ufs_rmdir(ap);
666 UNMARK_VNODE(ap->a_dvp);
667 UNMARK_VNODE(ap->a_vp);
668
669 /*
670 * If ufs_rmdir failed, vp doesn't need to be VDIROP any more.
671 * If it succeeded, we can go ahead and wipe out vp, since
672 * its loss won't appear on disk until checkpoint, and by then
673 * dvp will have been written, completing the dirop.
674 */
675 --lfs_dirvcount;
676 ap->a_vp->v_flag &= ~VDIROP;
677 wakeup(&lfs_dirvcount);
678 vrele(ap->a_vp);
679
680 SET_ENDOP(VTOI(ap->a_dvp)->i_lfs,ap->a_dvp,"rmdir");
681 return (error);
682 }
683
684 int
685 lfs_link(void *v)
686 {
687 struct vop_link_args /* {
688 struct vnode *a_dvp;
689 struct vnode *a_vp;
690 struct componentname *a_cnp;
691 } */ *ap = v;
692 int error;
693
694 if ((error = SET_DIROP(ap->a_dvp)) != 0) {
695 vput(ap->a_dvp);
696 return error;
697 }
698 MARK_VNODE(ap->a_dvp);
699 error = ufs_link(ap);
700 UNMARK_VNODE(ap->a_dvp);
701 SET_ENDOP(VTOI(ap->a_dvp)->i_lfs,ap->a_dvp,"link");
702 return (error);
703 }
704
705 int
706 lfs_rename(void *v)
707 {
708 struct vop_rename_args /* {
709 struct vnode *a_fdvp;
710 struct vnode *a_fvp;
711 struct componentname *a_fcnp;
712 struct vnode *a_tdvp;
713 struct vnode *a_tvp;
714 struct componentname *a_tcnp;
715 } */ *ap = v;
716 struct vnode *tvp, *fvp, *tdvp, *fdvp;
717 int error;
718 struct lfs *fs;
719
720 fs = VTOI(ap->a_fdvp)->i_lfs;
721 tvp = ap->a_tvp;
722 tdvp = ap->a_tdvp;
723 fvp = ap->a_fvp;
724 fdvp = ap->a_fdvp;
725
726 /*
727 * Check for cross-device rename.
728 * If it is, we don't want to set dirops, just error out.
729 * (In particular note that MARK_VNODE(tdvp) will DTWT on
730 * a cross-device rename.)
731 *
732 * Copied from ufs_rename.
733 */
734 if ((fvp->v_mount != tdvp->v_mount) ||
735 (tvp && (fvp->v_mount != tvp->v_mount))) {
736 error = EXDEV;
737 goto errout;
738 }
739 if ((error = SET_DIROP(fdvp)) != 0)
740 goto errout;
741 MARK_VNODE(fdvp);
742 MARK_VNODE(tdvp);
743 error = ufs_rename(ap);
744 UNMARK_VNODE(fdvp);
745 UNMARK_VNODE(tdvp);
746 SET_ENDOP(fs,fdvp,"rename");
747 return (error);
748
749 errout:
750 VOP_ABORTOP(tdvp, ap->a_tcnp); /* XXX, why not in NFS? */
751 if (tdvp == tvp)
752 vrele(tdvp);
753 else
754 vput(tdvp);
755 if (tvp)
756 vput(tvp);
757 VOP_ABORTOP(fdvp, ap->a_fcnp); /* XXX, why not in NFS? */
758 vrele(fdvp);
759 vrele(fvp);
760 return (error);
761 }
762
763 /* XXX hack to avoid calling ITIMES in getattr */
764 int
765 lfs_getattr(void *v)
766 {
767 struct vop_getattr_args /* {
768 struct vnode *a_vp;
769 struct vattr *a_vap;
770 struct ucred *a_cred;
771 struct proc *a_p;
772 } */ *ap = v;
773 struct vnode *vp = ap->a_vp;
774 struct inode *ip = VTOI(vp);
775 struct vattr *vap = ap->a_vap;
776 struct lfs *fs = ip->i_lfs;
777 /*
778 * Copy from inode table
779 */
780 vap->va_fsid = ip->i_dev;
781 vap->va_fileid = ip->i_number;
782 vap->va_mode = ip->i_ffs_mode & ~IFMT;
783 vap->va_nlink = ip->i_ffs_nlink;
784 vap->va_uid = ip->i_ffs_uid;
785 vap->va_gid = ip->i_ffs_gid;
786 vap->va_rdev = (dev_t)ip->i_ffs_rdev;
787 vap->va_size = vp->v_size;
788 vap->va_atime.tv_sec = ip->i_ffs_atime;
789 vap->va_atime.tv_nsec = ip->i_ffs_atimensec;
790 vap->va_mtime.tv_sec = ip->i_ffs_mtime;
791 vap->va_mtime.tv_nsec = ip->i_ffs_mtimensec;
792 vap->va_ctime.tv_sec = ip->i_ffs_ctime;
793 vap->va_ctime.tv_nsec = ip->i_ffs_ctimensec;
794 vap->va_flags = ip->i_ffs_flags;
795 vap->va_gen = ip->i_ffs_gen;
796 /* this doesn't belong here */
797 if (vp->v_type == VBLK)
798 vap->va_blocksize = BLKDEV_IOSIZE;
799 else if (vp->v_type == VCHR)
800 vap->va_blocksize = MAXBSIZE;
801 else
802 vap->va_blocksize = vp->v_mount->mnt_stat.f_iosize;
803 vap->va_bytes = fsbtob(fs, (u_quad_t)ip->i_ffs_blocks);
804 vap->va_type = vp->v_type;
805 vap->va_filerev = ip->i_modrev;
806 return (0);
807 }
808
809 /*
810 * Check to make sure the inode blocks won't choke the buffer
811 * cache, then call ufs_setattr as usual.
812 */
813 int
814 lfs_setattr(void *v)
815 {
816 struct vop_getattr_args /* {
817 struct vnode *a_vp;
818 struct vattr *a_vap;
819 struct ucred *a_cred;
820 struct proc *a_p;
821 } */ *ap = v;
822 struct vnode *vp = ap->a_vp;
823
824 lfs_check(vp, LFS_UNUSED_LBN, 0);
825 return ufs_setattr(v);
826 }
827
828 /*
829 * Close called
830 *
831 * XXX -- we were using ufs_close, but since it updates the
832 * times on the inode, we might need to bump the uinodes
833 * count.
834 */
835 /* ARGSUSED */
836 int
837 lfs_close(void *v)
838 {
839 struct vop_close_args /* {
840 struct vnode *a_vp;
841 int a_fflag;
842 struct ucred *a_cred;
843 struct proc *a_p;
844 } */ *ap = v;
845 struct vnode *vp = ap->a_vp;
846 struct inode *ip = VTOI(vp);
847 struct timespec ts;
848
849 simple_lock(&vp->v_interlock);
850 if (vp->v_usecount > 1) {
851 TIMEVAL_TO_TIMESPEC(&time, &ts);
852 LFS_ITIMES(ip, &ts, &ts, &ts);
853 }
854 simple_unlock(&vp->v_interlock);
855 return (0);
856 }
857
858 /*
859 * Reclaim an inode so that it can be used for other purposes.
860 */
861 int lfs_no_inactive = 0;
862
863 int
864 lfs_reclaim(void *v)
865 {
866 struct vop_reclaim_args /* {
867 struct vnode *a_vp;
868 struct proc *a_p;
869 } */ *ap = v;
870 struct vnode *vp = ap->a_vp;
871 int error;
872
873 LFS_CLR_UINO(VTOI(vp), IN_ALLMOD);
874 if ((error = ufs_reclaim(vp, ap->a_p)))
875 return (error);
876 pool_put(&lfs_inode_pool, vp->v_data);
877 vp->v_data = NULL;
878 return (0);
879 }
880
881 int
882 lfs_getpages(void *v)
883 {
884 struct vop_getpages_args /* {
885 struct vnode *a_vp;
886 voff_t a_offset;
887 struct vm_page **a_m;
888 int *a_count;
889 int a_centeridx;
890 vm_prot_t a_access_type;
891 int a_advice;
892 int a_flags;
893 } */ *ap = v;
894
895 if ((ap->a_access_type & VM_PROT_WRITE) != 0) {
896 LFS_SET_UINO(VTOI(ap->a_vp), IN_MODIFIED);
897 }
898 return genfs_compat_getpages(v);
899 }
900
901 int
902 lfs_putpages(void *v)
903 {
904 int error;
905
906 error = genfs_putpages(v);
907 return error;
908 }
909