lfs_vfsops.c revision 1.57 1 /* $NetBSD: lfs_vfsops.c,v 1.57 2000/07/05 22:25:44 perseant Exp $ */
2
3 /*-
4 * Copyright (c) 1999 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) 1989, 1991, 1993, 1994
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_vfsops.c 8.20 (Berkeley) 6/10/95
71 */
72
73 #if defined(_KERNEL) && !defined(_LKM)
74 #include "opt_quota.h"
75 #endif
76
77 #include <sys/param.h>
78 #include <sys/systm.h>
79 #include <sys/namei.h>
80 #include <sys/proc.h>
81 #include <sys/kernel.h>
82 #include <sys/vnode.h>
83 #include <sys/mount.h>
84 #include <sys/buf.h>
85 #include <sys/device.h>
86 #include <sys/mbuf.h>
87 #include <sys/file.h>
88 #include <sys/disklabel.h>
89 #include <sys/ioctl.h>
90 #include <sys/errno.h>
91 #include <sys/malloc.h>
92 #include <sys/pool.h>
93 #include <sys/socket.h>
94 #include <uvm/uvm_extern.h>
95 #include <sys/sysctl.h>
96
97 #include <miscfs/specfs/specdev.h>
98
99 #include <ufs/ufs/quota.h>
100 #include <ufs/ufs/inode.h>
101 #include <ufs/ufs/ufsmount.h>
102 #include <ufs/ufs/ufs_extern.h>
103
104 #include <ufs/lfs/lfs.h>
105 #include <ufs/lfs/lfs_extern.h>
106
107 int lfs_mountfs __P((struct vnode *, struct mount *, struct proc *));
108
109 extern struct vnodeopv_desc lfs_vnodeop_opv_desc;
110 extern struct vnodeopv_desc lfs_specop_opv_desc;
111 extern struct vnodeopv_desc lfs_fifoop_opv_desc;
112
113 struct vnodeopv_desc *lfs_vnodeopv_descs[] = {
114 &lfs_vnodeop_opv_desc,
115 &lfs_specop_opv_desc,
116 &lfs_fifoop_opv_desc,
117 NULL,
118 };
119
120 struct vfsops lfs_vfsops = {
121 MOUNT_LFS,
122 lfs_mount,
123 ufs_start,
124 lfs_unmount,
125 ufs_root,
126 ufs_quotactl,
127 lfs_statfs,
128 lfs_sync,
129 lfs_vget,
130 lfs_fhtovp,
131 lfs_vptofh,
132 lfs_init,
133 lfs_done,
134 lfs_sysctl,
135 lfs_mountroot,
136 ufs_check_export,
137 lfs_vnodeopv_descs,
138 };
139
140 struct pool lfs_inode_pool;
141
142 /*
143 * Initialize the filesystem, most work done by ufs_init.
144 */
145 void
146 lfs_init()
147 {
148 ufs_init();
149
150 /*
151 * XXX Same structure as FFS inodes? Should we share a common pool?
152 */
153 pool_init(&lfs_inode_pool, sizeof(struct inode), 0, 0, 0,
154 "lfsinopl", 0, pool_page_alloc_nointr, pool_page_free_nointr,
155 M_LFSNODE);
156 }
157
158 void
159 lfs_done()
160 {
161 ufs_done();
162 pool_destroy(&lfs_inode_pool);
163 }
164
165 /*
166 * Called by main() when ufs is going to be mounted as root.
167 */
168 int
169 lfs_mountroot()
170 {
171 extern struct vnode *rootvp;
172 struct mount *mp;
173 struct proc *p = curproc; /* XXX */
174 int error;
175
176 if (root_device->dv_class != DV_DISK)
177 return (ENODEV);
178
179 if (rootdev == NODEV)
180 return (ENODEV);
181 /*
182 * Get vnodes for swapdev and rootdev.
183 */
184 if ((error = bdevvp(rootdev, &rootvp))) {
185 printf("lfs_mountroot: can't setup bdevvp's");
186 return (error);
187 }
188 if ((error = vfs_rootmountalloc(MOUNT_LFS, "root_device", &mp))) {
189 vrele(rootvp);
190 return (error);
191 }
192 if ((error = lfs_mountfs(rootvp, mp, p))) {
193 mp->mnt_op->vfs_refcount--;
194 vfs_unbusy(mp);
195 free(mp, M_MOUNT);
196 vrele(rootvp);
197 return (error);
198 }
199 simple_lock(&mountlist_slock);
200 CIRCLEQ_INSERT_TAIL(&mountlist, mp, mnt_list);
201 simple_unlock(&mountlist_slock);
202 (void)lfs_statfs(mp, &mp->mnt_stat, p);
203 vfs_unbusy(mp);
204 return (0);
205 }
206
207 /*
208 * VFS Operations.
209 *
210 * mount system call
211 */
212 int
213 lfs_mount(mp, path, data, ndp, p)
214 struct mount *mp;
215 const char *path;
216 void *data;
217 struct nameidata *ndp;
218 struct proc *p;
219 {
220 struct vnode *devvp;
221 struct ufs_args args;
222 struct ufsmount *ump = NULL;
223 struct lfs *fs = NULL; /* LFS */
224 size_t size;
225 int error;
226 mode_t accessmode;
227
228 error = copyin(data, (caddr_t)&args, sizeof (struct ufs_args));
229 if (error)
230 return (error);
231
232 #if 0
233 /* Until LFS can do NFS right. XXX */
234 if (args.export.ex_flags & MNT_EXPORTED)
235 return (EINVAL);
236 #endif
237
238 /*
239 * If updating, check whether changing from read-only to
240 * read/write; if there is no device name, that's all we do.
241 */
242 if (mp->mnt_flag & MNT_UPDATE) {
243 ump = VFSTOUFS(mp);
244 fs = ump->um_lfs;
245 if (fs->lfs_ronly && (mp->mnt_flag & MNT_WANTRDWR)) {
246 /*
247 * If upgrade to read-write by non-root, then verify
248 * that user has necessary permissions on the device.
249 */
250 if (p->p_ucred->cr_uid != 0) {
251 vn_lock(ump->um_devvp, LK_EXCLUSIVE | LK_RETRY);
252 error = VOP_ACCESS(ump->um_devvp, VREAD|VWRITE,
253 p->p_ucred, p);
254 VOP_UNLOCK(ump->um_devvp, 0);
255 if (error)
256 return (error);
257 }
258 fs->lfs_ronly = 0;
259 }
260 if (args.fspec == 0) {
261 /*
262 * Process export requests.
263 */
264 return (vfs_export(mp, &ump->um_export, &args.export));
265 }
266 }
267 /*
268 * Not an update, or updating the name: look up the name
269 * and verify that it refers to a sensible block device.
270 */
271 NDINIT(ndp, LOOKUP, FOLLOW, UIO_USERSPACE, args.fspec, p);
272 if ((error = namei(ndp)) != 0)
273 return (error);
274 devvp = ndp->ni_vp;
275 if (devvp->v_type != VBLK) {
276 vrele(devvp);
277 return (ENOTBLK);
278 }
279 if (major(devvp->v_rdev) >= nblkdev) {
280 vrele(devvp);
281 return (ENXIO);
282 }
283 /*
284 * If mount by non-root, then verify that user has necessary
285 * permissions on the device.
286 */
287 if (p->p_ucred->cr_uid != 0) {
288 accessmode = VREAD;
289 if ((mp->mnt_flag & MNT_RDONLY) == 0)
290 accessmode |= VWRITE;
291 vn_lock(devvp, LK_EXCLUSIVE | LK_RETRY);
292 error = VOP_ACCESS(devvp, accessmode, p->p_ucred, p);
293 if (error) {
294 vput(devvp);
295 return (error);
296 }
297 VOP_UNLOCK(devvp, 0);
298 }
299 if ((mp->mnt_flag & MNT_UPDATE) == 0)
300 error = lfs_mountfs(devvp, mp, p); /* LFS */
301 else {
302 if (devvp != ump->um_devvp)
303 error = EINVAL; /* needs translation */
304 else
305 vrele(devvp);
306 }
307 if (error) {
308 vrele(devvp);
309 return (error);
310 }
311 ump = VFSTOUFS(mp);
312 fs = ump->um_lfs; /* LFS */
313 (void)copyinstr(path, fs->lfs_fsmnt, sizeof(fs->lfs_fsmnt) - 1, &size);
314 bzero(fs->lfs_fsmnt + size, sizeof(fs->lfs_fsmnt) - size);
315 bcopy(fs->lfs_fsmnt, mp->mnt_stat.f_mntonname, MNAMELEN);
316 (void) copyinstr(args.fspec, mp->mnt_stat.f_mntfromname, MNAMELEN - 1,
317 &size);
318 bzero(mp->mnt_stat.f_mntfromname + size, MNAMELEN - size);
319 return (0);
320 }
321
322 /*
323 * Common code for mount and mountroot
324 * LFS specific
325 */
326 int
327 lfs_mountfs(devvp, mp, p)
328 struct vnode *devvp;
329 struct mount *mp;
330 struct proc *p;
331 {
332 extern struct vnode *rootvp;
333 struct dlfs *dfs, *adfs;
334 struct lfs *fs;
335 struct ufsmount *ump;
336 struct vnode *vp;
337 struct buf *bp, *abp;
338 struct partinfo dpart;
339 dev_t dev;
340 int error, i, ronly, size;
341 struct ucred *cred;
342 SEGUSE *sup;
343
344 cred = p ? p->p_ucred : NOCRED;
345 /*
346 * Disallow multiple mounts of the same device.
347 * Disallow mounting of a device that is currently in use
348 * (except for root, which might share swap device for miniroot).
349 * Flush out any old buffers remaining from a previous use.
350 */
351 if ((error = vfs_mountedon(devvp)) != 0)
352 return (error);
353 if (vcount(devvp) > 1 && devvp != rootvp)
354 return (EBUSY);
355 if ((error = vinvalbuf(devvp, V_SAVE, cred, p, 0, 0)) != 0)
356 return (error);
357
358 ronly = (mp->mnt_flag & MNT_RDONLY) != 0;
359 error = VOP_OPEN(devvp, ronly ? FREAD : FREAD|FWRITE, FSCRED, p);
360 if (error)
361 return (error);
362 if (VOP_IOCTL(devvp, DIOCGPART, (caddr_t)&dpart, FREAD, cred, p) != 0)
363 size = DEV_BSIZE;
364 else
365 size = dpart.disklab->d_secsize;
366
367 /* Don't free random space on error. */
368 bp = NULL;
369 abp = NULL;
370 ump = NULL;
371
372 /* Read in the superblock. */
373 error = bread(devvp, LFS_LABELPAD / size, LFS_SBPAD, cred, &bp);
374 if (error)
375 goto out;
376 dfs = (struct dlfs *)bp->b_data;
377
378 /* Check the basics. */
379 if (dfs->dlfs_magic != LFS_MAGIC || dfs->dlfs_bsize > MAXBSIZE ||
380 dfs->dlfs_version > LFS_VERSION ||
381 dfs->dlfs_bsize < sizeof(struct dlfs)) {
382 error = EINVAL; /* XXX needs translation */
383 goto out;
384 }
385
386 /*
387 * Check the second superblock to see which is newer; then mount
388 * using the older of the two. This is necessary to ensure that
389 * the filesystem is valid if it was not unmounted cleanly.
390 */
391 if (dfs->dlfs_sboffs[1] &&
392 dfs->dlfs_sboffs[1]-(LFS_LABELPAD/size) > LFS_SBPAD/size)
393 {
394 error = bread(devvp, dfs->dlfs_sboffs[1], LFS_SBPAD, cred, &abp);
395 if (error)
396 goto out;
397 adfs = (struct dlfs *)abp->b_data;
398
399 if (adfs->dlfs_tstamp < dfs->dlfs_tstamp) /* XXX 1s? */
400 dfs = adfs;
401 } else {
402 printf("lfs_mountfs: invalid alt superblock daddr=0x%x\n",
403 dfs->dlfs_sboffs[1]);
404 error = EINVAL;
405 goto out;
406 }
407
408 /* Allocate the mount structure, copy the superblock into it. */
409 fs = malloc(sizeof(struct lfs), M_UFSMNT, M_WAITOK);
410 memcpy(&fs->lfs_dlfs, dfs, sizeof(struct dlfs));
411 ump = malloc(sizeof *ump, M_UFSMNT, M_WAITOK);
412 memset((caddr_t)ump, 0, sizeof *ump);
413 ump->um_lfs = fs;
414 if (sizeof(struct lfs) < LFS_SBPAD) /* XXX why? */
415 bp->b_flags |= B_INVAL;
416 brelse(bp);
417 bp = NULL;
418 brelse(abp);
419 abp = NULL;
420
421 /* Set up the I/O information */
422 fs->lfs_iocount = 0;
423 fs->lfs_diropwait = 0;
424 fs->lfs_activesb = 0;
425 fs->lfs_uinodes = 0;
426 #ifdef LFS_CANNOT_ROLLFW
427 fs->lfs_sbactive = 0;
428 #endif
429 #ifdef LFS_TRACK_IOS
430 for (i=0;i<LFS_THROTTLE;i++)
431 fs->lfs_pending[i] = LFS_UNUSED_DADDR;
432 #endif
433 if (fs->lfs_minfreeseg == 0)
434 fs->lfs_minfreeseg = MIN_FREE_SEGS;
435
436 /* Set up the ifile and lock aflags */
437 fs->lfs_doifile = 0;
438 fs->lfs_writer = 0;
439 fs->lfs_dirops = 0;
440 fs->lfs_nadirop = 0;
441 fs->lfs_seglock = 0;
442 lockinit(&fs->lfs_freelock, PINOD, "lfs_freelock", 0, 0);
443
444 /* Set the file system readonly/modify bits. */
445 fs->lfs_ronly = ronly;
446 if (ronly == 0)
447 fs->lfs_fmod = 1;
448
449 /* Initialize the mount structure. */
450 dev = devvp->v_rdev;
451 mp->mnt_data = (qaddr_t)ump;
452 mp->mnt_stat.f_fsid.val[0] = (long)dev;
453 mp->mnt_stat.f_fsid.val[1] = makefstype(MOUNT_LFS);
454 mp->mnt_stat.f_iosize = fs->lfs_bsize;
455 mp->mnt_maxsymlinklen = fs->lfs_maxsymlinklen;
456 mp->mnt_flag |= MNT_LOCAL;
457 ump->um_flags = 0;
458 ump->um_mountp = mp;
459 ump->um_dev = dev;
460 ump->um_devvp = devvp;
461 ump->um_bptrtodb = 0;
462 ump->um_seqinc = 1 << fs->lfs_fsbtodb;
463 ump->um_nindir = fs->lfs_nindir;
464 for (i = 0; i < MAXQUOTAS; i++)
465 ump->um_quotas[i] = NULLVP;
466 devvp->v_specmountpoint = mp;
467
468 /*
469 * We use the ifile vnode for almost every operation. Instead of
470 * retrieving it from the hash table each time we retrieve it here,
471 * artificially increment the reference count and keep a pointer
472 * to it in the incore copy of the superblock.
473 */
474 if ((error = VFS_VGET(mp, LFS_IFILE_INUM, &vp)) != 0)
475 goto out;
476 fs->lfs_ivnode = vp;
477 VREF(vp);
478 vput(vp);
479
480 /*
481 * Mark the current segment as ACTIVE, since we're going to
482 * be writing to it.
483 */
484 LFS_SEGENTRY(sup, fs, datosn(fs, fs->lfs_offset), bp);
485 sup->su_flags |= SEGUSE_DIRTY | SEGUSE_ACTIVE;
486 (void) VOP_BWRITE(bp);
487
488 return (0);
489 out:
490 if (bp)
491 brelse(bp);
492 if (abp)
493 brelse(abp);
494 vn_lock(devvp, LK_EXCLUSIVE | LK_RETRY);
495 (void)VOP_CLOSE(devvp, ronly ? FREAD : FREAD|FWRITE, cred, p);
496 VOP_UNLOCK(devvp, 0);
497 if (ump) {
498 free(ump->um_lfs, M_UFSMNT);
499 free(ump, M_UFSMNT);
500 mp->mnt_data = (qaddr_t)0;
501 }
502 return (error);
503 }
504
505 /*
506 * unmount system call
507 */
508 int
509 lfs_unmount(mp, mntflags, p)
510 struct mount *mp;
511 int mntflags;
512 struct proc *p;
513 {
514 struct ufsmount *ump;
515 struct lfs *fs;
516 int error, flags, ronly;
517 extern int lfs_allclean_wakeup;
518
519 flags = 0;
520 if (mntflags & MNT_FORCE)
521 flags |= FORCECLOSE;
522
523 ump = VFSTOUFS(mp);
524 fs = ump->um_lfs;
525 #ifdef QUOTA
526 if (mp->mnt_flag & MNT_QUOTA) {
527 int i;
528 error = vflush(mp, fs->lfs_ivnode, SKIPSYSTEM|flags);
529 if (error)
530 return (error);
531 for (i = 0; i < MAXQUOTAS; i++) {
532 if (ump->um_quotas[i] == NULLVP)
533 continue;
534 quotaoff(p, mp, i);
535 }
536 /*
537 * Here we fall through to vflush again to ensure
538 * that we have gotten rid of all the system vnodes.
539 */
540 }
541 #endif
542 if ((error = vflush(mp, fs->lfs_ivnode, flags)) != 0)
543 return (error);
544 fs->lfs_clean = 1;
545 if ((error = VFS_SYNC(mp, 1, p->p_ucred, p)) != 0)
546 return (error);
547 if (fs->lfs_ivnode->v_dirtyblkhd.lh_first)
548 panic("lfs_unmount: still dirty blocks on ifile vnode\n");
549 vrele(fs->lfs_ivnode);
550 vgone(fs->lfs_ivnode);
551
552 ronly = !fs->lfs_ronly;
553 if (ump->um_devvp->v_type != VBAD)
554 ump->um_devvp->v_specmountpoint = NULL;
555 vn_lock(ump->um_devvp, LK_EXCLUSIVE | LK_RETRY);
556 error = VOP_CLOSE(ump->um_devvp,
557 ronly ? FREAD : FREAD|FWRITE, NOCRED, p);
558 vput(ump->um_devvp);
559
560 /* XXX KS - wake up the cleaner so it can die */
561 wakeup(&fs->lfs_nextseg);
562 wakeup(&lfs_allclean_wakeup);
563
564 free(fs, M_UFSMNT);
565 free(ump, M_UFSMNT);
566 mp->mnt_data = (qaddr_t)0;
567 mp->mnt_flag &= ~MNT_LOCAL;
568 return (error);
569 }
570
571 /*
572 * Get file system statistics.
573 */
574 int
575 lfs_statfs(mp, sbp, p)
576 struct mount *mp;
577 struct statfs *sbp;
578 struct proc *p;
579 {
580 struct lfs *fs;
581 struct ufsmount *ump;
582
583 ump = VFSTOUFS(mp);
584 fs = ump->um_lfs;
585 if (fs->lfs_magic != LFS_MAGIC)
586 panic("lfs_statfs: magic");
587
588 sbp->f_type = 0;
589 sbp->f_bsize = fs->lfs_fsize;
590 sbp->f_iosize = fs->lfs_bsize;
591 sbp->f_blocks = dbtofrags(fs, LFS_EST_NONMETA(fs));
592 sbp->f_bfree = dbtofrags(fs, LFS_EST_BFREE(fs));
593 sbp->f_bavail = dbtofrags(fs, (long)LFS_EST_BFREE(fs) -
594 (long)LFS_EST_RSVD(fs));
595 sbp->f_files = dbtofsb(fs,fs->lfs_bfree) * INOPB(fs);
596 sbp->f_ffree = sbp->f_files - fs->lfs_nfiles;
597 if (sbp != &mp->mnt_stat) {
598 bcopy(mp->mnt_stat.f_mntonname, sbp->f_mntonname, MNAMELEN);
599 bcopy(mp->mnt_stat.f_mntfromname, sbp->f_mntfromname, MNAMELEN);
600 }
601 strncpy(sbp->f_fstypename, mp->mnt_op->vfs_name, MFSNAMELEN);
602 return (0);
603 }
604
605 /*
606 * Go through the disk queues to initiate sandbagged IO;
607 * go through the inodes to write those that have been modified;
608 * initiate the writing of the super block if it has been modified.
609 *
610 * Note: we are always called with the filesystem marked `MPBUSY'.
611 */
612 int
613 lfs_sync(mp, waitfor, cred, p)
614 struct mount *mp;
615 int waitfor;
616 struct ucred *cred;
617 struct proc *p;
618 {
619 int error;
620 struct lfs *fs;
621
622 fs = ((struct ufsmount *)mp->mnt_data)->ufsmount_u.lfs;
623 if (fs->lfs_ronly)
624 return 0;
625 while(fs->lfs_dirops)
626 error = tsleep(&fs->lfs_dirops, PRIBIO + 1, "lfs_dirops", 0);
627 fs->lfs_writer++;
628
629 /* All syncs must be checkpoints until roll-forward is implemented. */
630 error = lfs_segwrite(mp, SEGM_CKP | (waitfor ? SEGM_SYNC : 0));
631 if(--fs->lfs_writer==0)
632 wakeup(&fs->lfs_dirops);
633 #ifdef QUOTA
634 qsync(mp);
635 #endif
636 return (error);
637 }
638
639 extern struct lock ufs_hashlock;
640
641 /*
642 * Look up an LFS dinode number to find its incore vnode. If not already
643 * in core, read it in from the specified device. Return the inode locked.
644 * Detection and handling of mount points must be done by the calling routine.
645 */
646 int
647 lfs_vget(mp, ino, vpp)
648 struct mount *mp;
649 ino_t ino;
650 struct vnode **vpp;
651 {
652 struct lfs *fs;
653 struct inode *ip;
654 struct buf *bp;
655 struct ifile *ifp;
656 struct vnode *vp;
657 struct ufsmount *ump;
658 ufs_daddr_t daddr;
659 dev_t dev;
660 int error;
661 #ifdef LFS_ATIME_IFILE
662 struct timespec ts;
663 #endif
664
665 ump = VFSTOUFS(mp);
666 dev = ump->um_dev;
667
668 if ((*vpp = ufs_ihashget(dev, ino, LK_EXCLUSIVE)) != NULL)
669 return (0);
670
671 if ((error = getnewvnode(VT_LFS, mp, lfs_vnodeop_p, &vp)) != 0) {
672 *vpp = NULL;
673 return (error);
674 }
675
676 do {
677 if ((*vpp = ufs_ihashget(dev, ino, LK_EXCLUSIVE)) != NULL) {
678 ungetnewvnode(vp);
679 return (0);
680 }
681 } while (lockmgr(&ufs_hashlock, LK_EXCLUSIVE|LK_SLEEPFAIL, 0));
682
683 /* Translate the inode number to a disk address. */
684 fs = ump->um_lfs;
685 if (ino == LFS_IFILE_INUM)
686 daddr = fs->lfs_idaddr;
687 else {
688 LFS_IENTRY(ifp, fs, ino, bp);
689 daddr = ifp->if_daddr;
690 #ifdef LFS_ATIME_IFILE
691 ts = ifp->if_atime; /* structure copy */
692 #endif
693 brelse(bp);
694 if (daddr == LFS_UNUSED_DADDR) {
695 lockmgr(&ufs_hashlock, LK_RELEASE, 0);
696 return (ENOENT);
697 }
698 }
699
700 /* Allocate/init new vnode/inode. */
701 lfs_vcreate(mp, ino, vp);
702
703 /*
704 * Put it onto its hash chain and lock it so that other requests for
705 * this inode will block if they arrive while we are sleeping waiting
706 * for old data structures to be purged or for the contents of the
707 * disk portion of this inode to be read.
708 */
709 ip = VTOI(vp);
710 ufs_ihashins(ip);
711 lockmgr(&ufs_hashlock, LK_RELEASE, 0);
712
713 /*
714 * XXX
715 * This may not need to be here, logically it should go down with
716 * the i_devvp initialization.
717 * Ask Kirk.
718 */
719 ip->i_lfs = ump->um_lfs;
720
721 /* Read in the disk contents for the inode, copy into the inode. */
722 error = bread(ump->um_devvp, daddr, (int)fs->lfs_bsize, NOCRED, &bp);
723 if (error) {
724 /*
725 * The inode does not contain anything useful, so it would
726 * be misleading to leave it on its hash chain. With mode
727 * still zero, it will be unlinked and returned to the free
728 * list by vput().
729 */
730 vput(vp);
731 brelse(bp);
732 *vpp = NULL;
733 return (error);
734 }
735 ip->i_din.ffs_din = *lfs_ifind(fs, ino, bp);
736 ip->i_ffs_effnlink = ip->i_ffs_nlink;
737 ip->i_lfs_effnblks = ip->i_ffs_blocks;
738 #ifdef LFS_ATIME_IFILE
739 ip->i_ffs_atime = ts.tv_sec;
740 ip->i_ffs_atimensec = ts.tv_nsec;
741 #endif
742 brelse(bp);
743
744 /*
745 * Initialize the vnode from the inode, check for aliases. In all
746 * cases re-init ip, the underlying vnode/inode may have changed.
747 */
748 error = ufs_vinit(mp, lfs_specop_p, lfs_fifoop_p, &vp);
749 if (error) {
750 vput(vp);
751 *vpp = NULL;
752 return (error);
753 }
754 if(vp->v_type == VNON) {
755 printf("lfs_vget: ino %d is type VNON! (ifmt %o)\n", ip->i_number, (ip->i_ffs_mode&IFMT)>>12);
756 #ifdef DDB
757 Debugger();
758 #endif
759 }
760 /*
761 * Finish inode initialization now that aliasing has been resolved.
762 */
763 ip->i_devvp = ump->um_devvp;
764 VREF(ip->i_devvp);
765 *vpp = vp;
766
767 return (0);
768 }
769
770 /*
771 * File handle to vnode
772 *
773 * Have to be really careful about stale file handles:
774 * - check that the inode number is valid
775 * - call lfs_vget() to get the locked inode
776 * - check for an unallocated inode (i_mode == 0)
777 *
778 * XXX
779 * use ifile to see if inode is allocated instead of reading off disk
780 * what is the relationship between my generational number and the NFS
781 * generational number.
782 */
783 int
784 lfs_fhtovp(mp, fhp, vpp)
785 struct mount *mp;
786 struct fid *fhp;
787 struct vnode **vpp;
788 {
789 struct ufid *ufhp;
790
791 ufhp = (struct ufid *)fhp;
792 if (ufhp->ufid_ino < ROOTINO)
793 return (ESTALE);
794 return (ufs_fhtovp(mp, ufhp, vpp));
795 }
796
797 /*
798 * Vnode pointer to File handle
799 */
800 /* ARGSUSED */
801 int
802 lfs_vptofh(vp, fhp)
803 struct vnode *vp;
804 struct fid *fhp;
805 {
806 struct inode *ip;
807 struct ufid *ufhp;
808
809 ip = VTOI(vp);
810 ufhp = (struct ufid *)fhp;
811 ufhp->ufid_len = sizeof(struct ufid);
812 ufhp->ufid_ino = ip->i_number;
813 ufhp->ufid_gen = ip->i_ffs_gen;
814 return (0);
815 }
816
817 int
818 lfs_sysctl(name, namelen, oldp, oldlenp, newp, newlen, p)
819 int *name;
820 u_int namelen;
821 void *oldp;
822 size_t *oldlenp;
823 void *newp;
824 size_t newlen;
825 struct proc *p;
826 {
827 extern int lfs_writeindir, lfs_dostats, lfs_clean_vnhead;
828 extern struct lfs_stats lfs_stats;
829 int error;
830
831 /* all sysctl names at this level are terminal */
832 if (namelen != 1)
833 return (ENOTDIR);
834
835 switch (name[0]) {
836 case LFS_WRITEINDIR:
837 return (sysctl_int(oldp, oldlenp, newp, newlen,
838 &lfs_writeindir));
839 case LFS_CLEAN_VNHEAD:
840 return (sysctl_int(oldp, oldlenp, newp, newlen,
841 &lfs_clean_vnhead));
842 case LFS_DOSTATS:
843 if((error = sysctl_int(oldp, oldlenp, newp, newlen,
844 &lfs_dostats)))
845 return error;
846 if(lfs_dostats == 0)
847 memset(&lfs_stats,0,sizeof(lfs_stats));
848 return 0;
849 case LFS_STATS:
850 return (sysctl_rdstruct(oldp, oldlenp, newp,
851 &lfs_stats, sizeof(lfs_stats)));
852 default:
853 return (EOPNOTSUPP);
854 }
855 /* NOTREACHED */
856 }
857