lfs_vfsops.c revision 1.62 1 1.62 perseant /* $NetBSD: lfs_vfsops.c,v 1.62 2000/12/03 07:34:49 perseant Exp $ */
2 1.2 cgd
3 1.26 perseant /*-
4 1.58 perseant * Copyright (c) 1999, 2000 The NetBSD Foundation, Inc.
5 1.26 perseant * All rights reserved.
6 1.26 perseant *
7 1.26 perseant * This code is derived from software contributed to The NetBSD Foundation
8 1.26 perseant * by Konrad E. Schroder <perseant (at) hhhh.org>.
9 1.26 perseant *
10 1.26 perseant * Redistribution and use in source and binary forms, with or without
11 1.26 perseant * modification, are permitted provided that the following conditions
12 1.26 perseant * are met:
13 1.26 perseant * 1. Redistributions of source code must retain the above copyright
14 1.26 perseant * notice, this list of conditions and the following disclaimer.
15 1.26 perseant * 2. Redistributions in binary form must reproduce the above copyright
16 1.26 perseant * notice, this list of conditions and the following disclaimer in the
17 1.26 perseant * documentation and/or other materials provided with the distribution.
18 1.26 perseant * 3. All advertising materials mentioning features or use of this software
19 1.26 perseant * must display the following acknowledgement:
20 1.26 perseant * This product includes software developed by the NetBSD
21 1.26 perseant * Foundation, Inc. and its contributors.
22 1.26 perseant * 4. Neither the name of The NetBSD Foundation nor the names of its
23 1.26 perseant * contributors may be used to endorse or promote products derived
24 1.26 perseant * from this software without specific prior written permission.
25 1.26 perseant *
26 1.26 perseant * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
27 1.26 perseant * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
28 1.26 perseant * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
29 1.26 perseant * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
30 1.26 perseant * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
31 1.26 perseant * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
32 1.26 perseant * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
33 1.26 perseant * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
34 1.26 perseant * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
35 1.26 perseant * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
36 1.26 perseant * POSSIBILITY OF SUCH DAMAGE.
37 1.26 perseant */
38 1.26 perseant /*-
39 1.1 mycroft * Copyright (c) 1989, 1991, 1993, 1994
40 1.1 mycroft * The Regents of the University of California. All rights reserved.
41 1.1 mycroft *
42 1.1 mycroft * Redistribution and use in source and binary forms, with or without
43 1.1 mycroft * modification, are permitted provided that the following conditions
44 1.1 mycroft * are met:
45 1.1 mycroft * 1. Redistributions of source code must retain the above copyright
46 1.1 mycroft * notice, this list of conditions and the following disclaimer.
47 1.1 mycroft * 2. Redistributions in binary form must reproduce the above copyright
48 1.1 mycroft * notice, this list of conditions and the following disclaimer in the
49 1.1 mycroft * documentation and/or other materials provided with the distribution.
50 1.1 mycroft * 3. All advertising materials mentioning features or use of this software
51 1.1 mycroft * must display the following acknowledgement:
52 1.1 mycroft * This product includes software developed by the University of
53 1.1 mycroft * California, Berkeley and its contributors.
54 1.1 mycroft * 4. Neither the name of the University nor the names of its contributors
55 1.1 mycroft * may be used to endorse or promote products derived from this software
56 1.1 mycroft * without specific prior written permission.
57 1.1 mycroft *
58 1.1 mycroft * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
59 1.1 mycroft * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
60 1.1 mycroft * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
61 1.1 mycroft * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
62 1.1 mycroft * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
63 1.1 mycroft * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
64 1.1 mycroft * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
65 1.1 mycroft * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
66 1.1 mycroft * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
67 1.1 mycroft * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
68 1.1 mycroft * SUCH DAMAGE.
69 1.1 mycroft *
70 1.16 fvdl * @(#)lfs_vfsops.c 8.20 (Berkeley) 6/10/95
71 1.1 mycroft */
72 1.19 scottr
73 1.20 scottr #if defined(_KERNEL) && !defined(_LKM)
74 1.19 scottr #include "opt_quota.h"
75 1.20 scottr #endif
76 1.1 mycroft
77 1.1 mycroft #include <sys/param.h>
78 1.1 mycroft #include <sys/systm.h>
79 1.1 mycroft #include <sys/namei.h>
80 1.1 mycroft #include <sys/proc.h>
81 1.1 mycroft #include <sys/kernel.h>
82 1.1 mycroft #include <sys/vnode.h>
83 1.1 mycroft #include <sys/mount.h>
84 1.1 mycroft #include <sys/buf.h>
85 1.38 augustss #include <sys/device.h>
86 1.1 mycroft #include <sys/mbuf.h>
87 1.1 mycroft #include <sys/file.h>
88 1.1 mycroft #include <sys/disklabel.h>
89 1.1 mycroft #include <sys/ioctl.h>
90 1.1 mycroft #include <sys/errno.h>
91 1.1 mycroft #include <sys/malloc.h>
92 1.23 thorpej #include <sys/pool.h>
93 1.1 mycroft #include <sys/socket.h>
94 1.54 mrg #include <uvm/uvm_extern.h>
95 1.26 perseant #include <sys/sysctl.h>
96 1.1 mycroft
97 1.1 mycroft #include <miscfs/specfs/specdev.h>
98 1.1 mycroft
99 1.1 mycroft #include <ufs/ufs/quota.h>
100 1.1 mycroft #include <ufs/ufs/inode.h>
101 1.1 mycroft #include <ufs/ufs/ufsmount.h>
102 1.1 mycroft #include <ufs/ufs/ufs_extern.h>
103 1.1 mycroft
104 1.1 mycroft #include <ufs/lfs/lfs.h>
105 1.1 mycroft #include <ufs/lfs/lfs_extern.h>
106 1.1 mycroft
107 1.1 mycroft int lfs_mountfs __P((struct vnode *, struct mount *, struct proc *));
108 1.1 mycroft
109 1.15 thorpej extern struct vnodeopv_desc lfs_vnodeop_opv_desc;
110 1.15 thorpej extern struct vnodeopv_desc lfs_specop_opv_desc;
111 1.15 thorpej extern struct vnodeopv_desc lfs_fifoop_opv_desc;
112 1.15 thorpej
113 1.15 thorpej struct vnodeopv_desc *lfs_vnodeopv_descs[] = {
114 1.15 thorpej &lfs_vnodeop_opv_desc,
115 1.15 thorpej &lfs_specop_opv_desc,
116 1.15 thorpej &lfs_fifoop_opv_desc,
117 1.15 thorpej NULL,
118 1.15 thorpej };
119 1.15 thorpej
120 1.1 mycroft struct vfsops lfs_vfsops = {
121 1.1 mycroft MOUNT_LFS,
122 1.1 mycroft lfs_mount,
123 1.1 mycroft ufs_start,
124 1.1 mycroft lfs_unmount,
125 1.1 mycroft ufs_root,
126 1.1 mycroft ufs_quotactl,
127 1.1 mycroft lfs_statfs,
128 1.1 mycroft lfs_sync,
129 1.1 mycroft lfs_vget,
130 1.1 mycroft lfs_fhtovp,
131 1.1 mycroft lfs_vptofh,
132 1.1 mycroft lfs_init,
133 1.47 jdolecek lfs_done,
134 1.16 fvdl lfs_sysctl,
135 1.36 perseant lfs_mountroot,
136 1.25 wrstuden ufs_check_export,
137 1.15 thorpej lfs_vnodeopv_descs,
138 1.1 mycroft };
139 1.1 mycroft
140 1.23 thorpej struct pool lfs_inode_pool;
141 1.23 thorpej
142 1.60 perseant extern int locked_queue_count;
143 1.60 perseant extern long locked_queue_bytes;
144 1.60 perseant
145 1.16 fvdl /*
146 1.16 fvdl * Initialize the filesystem, most work done by ufs_init.
147 1.16 fvdl */
148 1.16 fvdl void
149 1.16 fvdl lfs_init()
150 1.16 fvdl {
151 1.16 fvdl ufs_init();
152 1.56 perseant
153 1.23 thorpej /*
154 1.23 thorpej * XXX Same structure as FFS inodes? Should we share a common pool?
155 1.23 thorpej */
156 1.23 thorpej pool_init(&lfs_inode_pool, sizeof(struct inode), 0, 0, 0,
157 1.26 perseant "lfsinopl", 0, pool_page_alloc_nointr, pool_page_free_nointr,
158 1.26 perseant M_LFSNODE);
159 1.47 jdolecek }
160 1.47 jdolecek
161 1.47 jdolecek void
162 1.47 jdolecek lfs_done()
163 1.47 jdolecek {
164 1.47 jdolecek ufs_done();
165 1.47 jdolecek pool_destroy(&lfs_inode_pool);
166 1.16 fvdl }
167 1.16 fvdl
168 1.16 fvdl /*
169 1.16 fvdl * Called by main() when ufs is going to be mounted as root.
170 1.16 fvdl */
171 1.1 mycroft int
172 1.1 mycroft lfs_mountroot()
173 1.1 mycroft {
174 1.16 fvdl extern struct vnode *rootvp;
175 1.16 fvdl struct mount *mp;
176 1.16 fvdl struct proc *p = curproc; /* XXX */
177 1.16 fvdl int error;
178 1.16 fvdl
179 1.37 sommerfe if (root_device->dv_class != DV_DISK)
180 1.37 sommerfe return (ENODEV);
181 1.37 sommerfe
182 1.37 sommerfe if (rootdev == NODEV)
183 1.37 sommerfe return (ENODEV);
184 1.16 fvdl /*
185 1.16 fvdl * Get vnodes for swapdev and rootdev.
186 1.16 fvdl */
187 1.16 fvdl if ((error = bdevvp(rootdev, &rootvp))) {
188 1.16 fvdl printf("lfs_mountroot: can't setup bdevvp's");
189 1.16 fvdl return (error);
190 1.16 fvdl }
191 1.35 wrstuden if ((error = vfs_rootmountalloc(MOUNT_LFS, "root_device", &mp))) {
192 1.35 wrstuden vrele(rootvp);
193 1.16 fvdl return (error);
194 1.35 wrstuden }
195 1.16 fvdl if ((error = lfs_mountfs(rootvp, mp, p))) {
196 1.16 fvdl mp->mnt_op->vfs_refcount--;
197 1.16 fvdl vfs_unbusy(mp);
198 1.16 fvdl free(mp, M_MOUNT);
199 1.35 wrstuden vrele(rootvp);
200 1.16 fvdl return (error);
201 1.16 fvdl }
202 1.16 fvdl simple_lock(&mountlist_slock);
203 1.16 fvdl CIRCLEQ_INSERT_TAIL(&mountlist, mp, mnt_list);
204 1.16 fvdl simple_unlock(&mountlist_slock);
205 1.16 fvdl (void)lfs_statfs(mp, &mp->mnt_stat, p);
206 1.16 fvdl vfs_unbusy(mp);
207 1.16 fvdl return (0);
208 1.1 mycroft }
209 1.1 mycroft
210 1.1 mycroft /*
211 1.1 mycroft * VFS Operations.
212 1.1 mycroft *
213 1.1 mycroft * mount system call
214 1.1 mycroft */
215 1.10 christos int
216 1.1 mycroft lfs_mount(mp, path, data, ndp, p)
217 1.48 augustss struct mount *mp;
218 1.12 cgd const char *path;
219 1.12 cgd void *data;
220 1.1 mycroft struct nameidata *ndp;
221 1.1 mycroft struct proc *p;
222 1.1 mycroft {
223 1.1 mycroft struct vnode *devvp;
224 1.1 mycroft struct ufs_args args;
225 1.10 christos struct ufsmount *ump = NULL;
226 1.48 augustss struct lfs *fs = NULL; /* LFS */
227 1.8 mycroft size_t size;
228 1.1 mycroft int error;
229 1.3 mycroft mode_t accessmode;
230 1.1 mycroft
231 1.10 christos error = copyin(data, (caddr_t)&args, sizeof (struct ufs_args));
232 1.10 christos if (error)
233 1.1 mycroft return (error);
234 1.1 mycroft
235 1.29 mycroft #if 0
236 1.1 mycroft /* Until LFS can do NFS right. XXX */
237 1.1 mycroft if (args.export.ex_flags & MNT_EXPORTED)
238 1.1 mycroft return (EINVAL);
239 1.29 mycroft #endif
240 1.1 mycroft
241 1.1 mycroft /*
242 1.1 mycroft * If updating, check whether changing from read-only to
243 1.1 mycroft * read/write; if there is no device name, that's all we do.
244 1.1 mycroft */
245 1.1 mycroft if (mp->mnt_flag & MNT_UPDATE) {
246 1.1 mycroft ump = VFSTOUFS(mp);
247 1.29 mycroft fs = ump->um_lfs;
248 1.3 mycroft if (fs->lfs_ronly && (mp->mnt_flag & MNT_WANTRDWR)) {
249 1.3 mycroft /*
250 1.3 mycroft * If upgrade to read-write by non-root, then verify
251 1.3 mycroft * that user has necessary permissions on the device.
252 1.3 mycroft */
253 1.3 mycroft if (p->p_ucred->cr_uid != 0) {
254 1.16 fvdl vn_lock(ump->um_devvp, LK_EXCLUSIVE | LK_RETRY);
255 1.10 christos error = VOP_ACCESS(ump->um_devvp, VREAD|VWRITE,
256 1.10 christos p->p_ucred, p);
257 1.16 fvdl VOP_UNLOCK(ump->um_devvp, 0);
258 1.16 fvdl if (error)
259 1.3 mycroft return (error);
260 1.3 mycroft }
261 1.1 mycroft fs->lfs_ronly = 0;
262 1.3 mycroft }
263 1.1 mycroft if (args.fspec == 0) {
264 1.1 mycroft /*
265 1.1 mycroft * Process export requests.
266 1.1 mycroft */
267 1.1 mycroft return (vfs_export(mp, &ump->um_export, &args.export));
268 1.1 mycroft }
269 1.1 mycroft }
270 1.1 mycroft /*
271 1.1 mycroft * Not an update, or updating the name: look up the name
272 1.1 mycroft * and verify that it refers to a sensible block device.
273 1.1 mycroft */
274 1.1 mycroft NDINIT(ndp, LOOKUP, FOLLOW, UIO_USERSPACE, args.fspec, p);
275 1.10 christos if ((error = namei(ndp)) != 0)
276 1.1 mycroft return (error);
277 1.1 mycroft devvp = ndp->ni_vp;
278 1.1 mycroft if (devvp->v_type != VBLK) {
279 1.1 mycroft vrele(devvp);
280 1.1 mycroft return (ENOTBLK);
281 1.1 mycroft }
282 1.1 mycroft if (major(devvp->v_rdev) >= nblkdev) {
283 1.1 mycroft vrele(devvp);
284 1.1 mycroft return (ENXIO);
285 1.1 mycroft }
286 1.3 mycroft /*
287 1.3 mycroft * If mount by non-root, then verify that user has necessary
288 1.3 mycroft * permissions on the device.
289 1.3 mycroft */
290 1.3 mycroft if (p->p_ucred->cr_uid != 0) {
291 1.3 mycroft accessmode = VREAD;
292 1.3 mycroft if ((mp->mnt_flag & MNT_RDONLY) == 0)
293 1.3 mycroft accessmode |= VWRITE;
294 1.16 fvdl vn_lock(devvp, LK_EXCLUSIVE | LK_RETRY);
295 1.10 christos error = VOP_ACCESS(devvp, accessmode, p->p_ucred, p);
296 1.10 christos if (error) {
297 1.3 mycroft vput(devvp);
298 1.3 mycroft return (error);
299 1.3 mycroft }
300 1.16 fvdl VOP_UNLOCK(devvp, 0);
301 1.3 mycroft }
302 1.1 mycroft if ((mp->mnt_flag & MNT_UPDATE) == 0)
303 1.1 mycroft error = lfs_mountfs(devvp, mp, p); /* LFS */
304 1.1 mycroft else {
305 1.1 mycroft if (devvp != ump->um_devvp)
306 1.1 mycroft error = EINVAL; /* needs translation */
307 1.1 mycroft else
308 1.1 mycroft vrele(devvp);
309 1.1 mycroft }
310 1.1 mycroft if (error) {
311 1.1 mycroft vrele(devvp);
312 1.1 mycroft return (error);
313 1.1 mycroft }
314 1.1 mycroft ump = VFSTOUFS(mp);
315 1.1 mycroft fs = ump->um_lfs; /* LFS */
316 1.1 mycroft (void)copyinstr(path, fs->lfs_fsmnt, sizeof(fs->lfs_fsmnt) - 1, &size);
317 1.1 mycroft bzero(fs->lfs_fsmnt + size, sizeof(fs->lfs_fsmnt) - size);
318 1.6 mycroft bcopy(fs->lfs_fsmnt, mp->mnt_stat.f_mntonname, MNAMELEN);
319 1.1 mycroft (void) copyinstr(args.fspec, mp->mnt_stat.f_mntfromname, MNAMELEN - 1,
320 1.26 perseant &size);
321 1.1 mycroft bzero(mp->mnt_stat.f_mntfromname + size, MNAMELEN - size);
322 1.1 mycroft return (0);
323 1.1 mycroft }
324 1.1 mycroft
325 1.60 perseant #ifdef LFS_DO_ROLLFORWARD
326 1.60 perseant /*
327 1.60 perseant * Roll-forward code.
328 1.60 perseant */
329 1.60 perseant
330 1.60 perseant /*
331 1.60 perseant * Load the appropriate indirect block, and change the appropriate pointer.
332 1.60 perseant * Mark the block dirty. Do segment and avail accounting.
333 1.60 perseant */
334 1.60 perseant static int
335 1.60 perseant update_meta(struct lfs *fs, ino_t ino, int version, ufs_daddr_t lbn,
336 1.60 perseant daddr_t ndaddr, size_t size, struct proc *p)
337 1.60 perseant {
338 1.60 perseant int error;
339 1.60 perseant struct vnode *vp;
340 1.60 perseant struct inode *ip;
341 1.60 perseant daddr_t odaddr, ooff;
342 1.60 perseant struct indir a[NIADDR], *ap;
343 1.60 perseant struct buf *bp;
344 1.60 perseant SEGUSE *sup;
345 1.60 perseant int num;
346 1.60 perseant
347 1.60 perseant if ((error = lfs_rf_valloc(fs, ino, version, p, &vp)) != 0) {
348 1.60 perseant printf("update_meta: ino %d: lfs_rf_valloc returned %d\n", ino,
349 1.60 perseant error);
350 1.60 perseant return error;
351 1.60 perseant }
352 1.60 perseant
353 1.60 perseant if ((error = VOP_BALLOC(vp, (lbn << fs->lfs_bshift), size,
354 1.60 perseant NOCRED, 0, &bp)) != 0) {
355 1.60 perseant vput(vp);
356 1.60 perseant return (error);
357 1.60 perseant }
358 1.60 perseant /* No need to write, the block is already on disk */
359 1.60 perseant if (bp->b_flags & B_DELWRI) {
360 1.60 perseant LFS_UNLOCK_BUF(bp);
361 1.60 perseant fs->lfs_avail += btodb(bp->b_bcount);
362 1.60 perseant }
363 1.60 perseant bp->b_flags |= B_INVAL;
364 1.60 perseant brelse(bp);
365 1.60 perseant
366 1.60 perseant /*
367 1.60 perseant * Extend the file, if it is not large enough already.
368 1.60 perseant * XXX this is not exactly right, we don't know how much of the
369 1.60 perseant * XXX last block is actually used. We hope that an inode will
370 1.60 perseant * XXX appear later to give the correct size.
371 1.60 perseant */
372 1.60 perseant ip = VTOI(vp);
373 1.60 perseant if (ip->i_ffs_size <= (lbn << fs->lfs_bshift)) {
374 1.60 perseant if (lbn < NDADDR)
375 1.60 perseant ip->i_ffs_size = (lbn << fs->lfs_bshift) +
376 1.60 perseant (size - fs->lfs_fsize) + 1;
377 1.60 perseant else
378 1.60 perseant ip->i_ffs_size = (lbn << fs->lfs_bshift) + 1;
379 1.60 perseant }
380 1.60 perseant
381 1.60 perseant error = ufs_bmaparray(vp, lbn, &odaddr, &a[0], &num, NULL);
382 1.60 perseant if (error) {
383 1.60 perseant printf("update_meta: ufs_bmaparray returned %d\n", error);
384 1.60 perseant vput(vp);
385 1.60 perseant return error;
386 1.60 perseant }
387 1.60 perseant switch (num) {
388 1.60 perseant case 0:
389 1.60 perseant ooff = ip->i_ffs_db[lbn];
390 1.60 perseant if (ooff == UNWRITTEN)
391 1.60 perseant ip->i_ffs_blocks += btodb(size);
392 1.60 perseant ip->i_ffs_db[lbn] = ndaddr;
393 1.60 perseant break;
394 1.60 perseant case 1:
395 1.60 perseant ooff = ip->i_ffs_ib[a[0].in_off];
396 1.60 perseant if (ooff == UNWRITTEN)
397 1.60 perseant ip->i_ffs_blocks += btodb(size);
398 1.60 perseant ip->i_ffs_ib[a[0].in_off] = ndaddr;
399 1.60 perseant break;
400 1.60 perseant default:
401 1.60 perseant ap = &a[num - 1];
402 1.60 perseant if (bread(vp, ap->in_lbn, fs->lfs_bsize, NOCRED, &bp))
403 1.60 perseant panic("update_meta: bread bno %d", ap->in_lbn);
404 1.60 perseant
405 1.60 perseant ooff = ((ufs_daddr_t *)bp->b_data)[ap->in_off];
406 1.60 perseant if (ooff == UNWRITTEN)
407 1.60 perseant ip->i_ffs_blocks += btodb(size);
408 1.60 perseant ((ufs_daddr_t *)bp->b_data)[ap->in_off] = ndaddr;
409 1.60 perseant (void) VOP_BWRITE(bp);
410 1.60 perseant }
411 1.60 perseant LFS_SET_UINO(ip, IN_CHANGE | IN_MODIFIED | IN_UPDATE);
412 1.60 perseant
413 1.60 perseant /* Update segment usage information. */
414 1.60 perseant if (odaddr > 0) {
415 1.60 perseant LFS_SEGENTRY(sup, fs, datosn(fs, odaddr), bp);
416 1.60 perseant #ifdef DIAGNOSTIC
417 1.60 perseant if (sup->su_nbytes < size) {
418 1.60 perseant panic("update_meta: negative bytes "
419 1.60 perseant "(segment %d short by %ld)\n",
420 1.60 perseant datosn(fs, odaddr), (long)size - sup->su_nbytes);
421 1.60 perseant sup->su_nbytes = size;
422 1.60 perseant }
423 1.60 perseant #endif
424 1.60 perseant sup->su_nbytes -= size;
425 1.60 perseant VOP_BWRITE(bp);
426 1.60 perseant }
427 1.60 perseant LFS_SEGENTRY(sup, fs, datosn(fs, ndaddr), bp);
428 1.60 perseant sup->su_nbytes += size;
429 1.60 perseant VOP_BWRITE(bp);
430 1.60 perseant
431 1.60 perseant /* Fix this so it can be released */
432 1.60 perseant /* ip->i_lfs_effnblks = ip->i_ffs_blocks; */
433 1.60 perseant
434 1.60 perseant /* Now look again to make sure it worked */
435 1.60 perseant ufs_bmaparray(vp, lbn, &odaddr, &a[0], &num, NULL );
436 1.60 perseant if (odaddr != ndaddr)
437 1.60 perseant printf("update_meta: failed setting ino %d lbn %d to %x\n",
438 1.60 perseant ino, lbn, ndaddr);
439 1.60 perseant
440 1.60 perseant vput(vp);
441 1.60 perseant return 0;
442 1.60 perseant }
443 1.60 perseant
444 1.60 perseant static int
445 1.60 perseant update_inoblk(struct lfs *fs, daddr_t offset, struct ucred *cred,
446 1.60 perseant struct proc *p)
447 1.60 perseant {
448 1.60 perseant struct vnode *devvp, *vp;
449 1.60 perseant struct inode *ip;
450 1.60 perseant struct dinode *dip;
451 1.60 perseant struct buf *dbp, *ibp;
452 1.60 perseant int error;
453 1.60 perseant daddr_t daddr;
454 1.60 perseant IFILE *ifp;
455 1.60 perseant SEGUSE *sup;
456 1.60 perseant
457 1.60 perseant devvp = VTOI(fs->lfs_ivnode)->i_devvp;
458 1.60 perseant
459 1.60 perseant /*
460 1.60 perseant * Get the inode, update times and perms.
461 1.60 perseant * DO NOT update disk blocks, we do that separately.
462 1.60 perseant */
463 1.60 perseant error = bread(devvp, offset, fs->lfs_bsize, cred, &dbp);
464 1.60 perseant if (error) {
465 1.60 perseant printf("update_inoblk: bread returned %d\n", error);
466 1.60 perseant return error;
467 1.60 perseant }
468 1.60 perseant dip = ((struct dinode *)(dbp->b_data)) + INOPB(fs);
469 1.60 perseant while(--dip >= (struct dinode *)dbp->b_data) {
470 1.60 perseant if(dip->di_inumber > LFS_IFILE_INUM) {
471 1.60 perseant /* printf("ino %d version %d\n", dip->di_inumber,
472 1.60 perseant dip->di_gen); */
473 1.60 perseant error = lfs_rf_valloc(fs, dip->di_inumber, dip->di_gen,
474 1.60 perseant p, &vp);
475 1.60 perseant if (error) {
476 1.60 perseant printf("update_inoblk: lfs_rf_valloc returned %d\n", error);
477 1.60 perseant continue;
478 1.60 perseant }
479 1.60 perseant ip = VTOI(vp);
480 1.60 perseant if (dip->di_size != ip->i_ffs_size)
481 1.60 perseant VOP_TRUNCATE(vp, dip->di_size, 0, NOCRED, p);
482 1.60 perseant /* Get mode, link count, size, and times */
483 1.60 perseant memcpy(&ip->i_din.ffs_din, dip,
484 1.60 perseant offsetof(struct dinode, di_db[0]));
485 1.60 perseant
486 1.60 perseant /* Then the rest, except di_blocks */
487 1.60 perseant ip->i_ffs_flags = dip->di_flags;
488 1.60 perseant ip->i_ffs_gen = dip->di_gen;
489 1.60 perseant ip->i_ffs_uid = dip->di_uid;
490 1.60 perseant ip->i_ffs_gid = dip->di_gid;
491 1.60 perseant
492 1.60 perseant ip->i_ffs_effnlink = dip->di_nlink;
493 1.60 perseant
494 1.60 perseant LFS_SET_UINO(ip, IN_CHANGE | IN_MODIFIED | IN_UPDATE);
495 1.60 perseant
496 1.60 perseant /* Re-initialize to get type right */
497 1.60 perseant ufs_vinit(vp->v_mount, lfs_specop_p, lfs_fifoop_p,
498 1.60 perseant &vp);
499 1.60 perseant vput(vp);
500 1.60 perseant
501 1.60 perseant /* Record change in location */
502 1.60 perseant LFS_IENTRY(ifp, fs, dip->di_inumber, ibp);
503 1.60 perseant daddr = ifp->if_daddr;
504 1.60 perseant ifp->if_daddr = dbp->b_blkno;
505 1.60 perseant error = VOP_BWRITE(ibp); /* Ifile */
506 1.60 perseant /* And do segment accounting */
507 1.60 perseant if (datosn(fs, daddr) != datosn(fs, dbp->b_blkno)) {
508 1.60 perseant if (daddr > 0) {
509 1.60 perseant LFS_SEGENTRY(sup, fs, datosn(fs, daddr),
510 1.60 perseant ibp);
511 1.60 perseant sup->su_nbytes -= DINODE_SIZE;
512 1.60 perseant VOP_BWRITE(ibp);
513 1.60 perseant }
514 1.60 perseant LFS_SEGENTRY(sup, fs, datosn(fs, dbp->b_blkno),
515 1.60 perseant ibp);
516 1.60 perseant sup->su_nbytes += DINODE_SIZE;
517 1.60 perseant VOP_BWRITE(ibp);
518 1.60 perseant }
519 1.60 perseant }
520 1.60 perseant }
521 1.60 perseant dbp->b_flags |= B_AGE;
522 1.60 perseant brelse(dbp);
523 1.60 perseant
524 1.60 perseant return 0;
525 1.60 perseant }
526 1.60 perseant
527 1.60 perseant #define CHECK_CKSUM 0x0001 /* Check the checksum to make sure it's valid */
528 1.60 perseant #define CHECK_UPDATE 0x0002 /* Update Ifile for new data blocks / inodes */
529 1.60 perseant
530 1.60 perseant static daddr_t
531 1.60 perseant check_segsum(struct lfs *fs, daddr_t offset,
532 1.60 perseant struct ucred *cred, int flags, int *pseg_flags, struct proc *p)
533 1.60 perseant {
534 1.60 perseant struct vnode *devvp;
535 1.60 perseant struct buf *bp, *dbp;
536 1.60 perseant int error, nblocks, ninos, i, j;
537 1.60 perseant SEGSUM *ssp;
538 1.60 perseant u_long *dp, *datap; /* XXX u_int32_t */
539 1.60 perseant daddr_t *iaddr, oldoffset;
540 1.60 perseant FINFO *fip;
541 1.60 perseant SEGUSE *sup;
542 1.60 perseant size_t size;
543 1.60 perseant
544 1.60 perseant devvp = VTOI(fs->lfs_ivnode)->i_devvp;
545 1.60 perseant /*
546 1.60 perseant * If the segment has a superblock and we're at the top
547 1.60 perseant * of the segment, skip the superblock.
548 1.60 perseant */
549 1.60 perseant if(sntoda(fs, datosn(fs, offset)) == offset) {
550 1.60 perseant LFS_SEGENTRY(sup, fs, datosn(fs, offset), bp);
551 1.60 perseant if(sup->su_flags & SEGUSE_SUPERBLOCK)
552 1.60 perseant offset += btodb(LFS_SBPAD);
553 1.60 perseant brelse(bp);
554 1.60 perseant }
555 1.60 perseant
556 1.60 perseant /* Read in the segment summary */
557 1.60 perseant error = bread(devvp, offset, LFS_SUMMARY_SIZE, cred, &bp);
558 1.60 perseant if(error)
559 1.60 perseant return -1;
560 1.60 perseant
561 1.60 perseant /* Check summary checksum */
562 1.60 perseant ssp = (SEGSUM *)bp->b_data;
563 1.60 perseant if(flags & CHECK_CKSUM) {
564 1.60 perseant if(ssp->ss_sumsum != cksum(&ssp->ss_datasum,
565 1.60 perseant LFS_SUMMARY_SIZE -
566 1.60 perseant sizeof(ssp->ss_sumsum))) {
567 1.60 perseant #ifdef DEBUG_LFS_RFW
568 1.60 perseant printf("Sumsum error at 0x%x\n", offset);
569 1.60 perseant #endif
570 1.60 perseant offset = -1;
571 1.60 perseant goto err1;
572 1.60 perseant }
573 1.60 perseant if (ssp->ss_nfinfo == 0 && ssp->ss_ninos == 0) {
574 1.60 perseant #ifdef DEBUG_LFS_RFW
575 1.60 perseant printf("Empty pseg at 0x%x\n", offset);
576 1.60 perseant #endif
577 1.60 perseant offset = -1;
578 1.60 perseant goto err1;
579 1.60 perseant }
580 1.60 perseant if (ssp->ss_create < fs->lfs_tstamp) {
581 1.60 perseant #ifdef DEBUG_LFS_RFW
582 1.60 perseant printf("Old data at 0x%x\n", offset);
583 1.60 perseant #endif
584 1.60 perseant offset = -1;
585 1.60 perseant goto err1;
586 1.60 perseant }
587 1.60 perseant }
588 1.60 perseant if(pseg_flags)
589 1.60 perseant *pseg_flags = ssp->ss_flags;
590 1.60 perseant oldoffset = offset;
591 1.60 perseant offset += btodb(LFS_SUMMARY_SIZE);
592 1.60 perseant
593 1.60 perseant ninos = howmany(ssp->ss_ninos, INOPB(fs));
594 1.60 perseant iaddr = (daddr_t *)(bp->b_data + LFS_SUMMARY_SIZE - sizeof(daddr_t));
595 1.60 perseant if(flags & CHECK_CKSUM) {
596 1.60 perseant /* Count blocks */
597 1.60 perseant nblocks = 0;
598 1.60 perseant fip = (FINFO *)(bp->b_data + sizeof(SEGSUM));
599 1.60 perseant for(i = 0; i < ssp->ss_nfinfo; ++i) {
600 1.60 perseant nblocks += fip->fi_nblocks;
601 1.60 perseant if(fip->fi_nblocks <= 0)
602 1.60 perseant break;
603 1.60 perseant fip = (FINFO *)(((char *)fip) + sizeof(FINFO) +
604 1.60 perseant (fip->fi_nblocks - 1) *
605 1.60 perseant sizeof(ufs_daddr_t));
606 1.60 perseant }
607 1.60 perseant nblocks += ninos;
608 1.60 perseant /* Create the sum array */
609 1.60 perseant datap = dp = (u_long *)malloc(nblocks * sizeof(u_long),
610 1.60 perseant M_SEGMENT, M_WAITOK);
611 1.60 perseant }
612 1.60 perseant
613 1.60 perseant /* Handle individual blocks */
614 1.60 perseant fip = (FINFO *)(bp->b_data + sizeof(SEGSUM));
615 1.60 perseant for(i = 0; i < ssp->ss_nfinfo || ninos; ++i) {
616 1.60 perseant /* Inode block? */
617 1.60 perseant if(ninos && *iaddr == offset) {
618 1.60 perseant if(flags & CHECK_CKSUM) {
619 1.60 perseant /* Read in the head and add to the buffer */
620 1.60 perseant error = bread(devvp, offset, fs->lfs_bsize,
621 1.60 perseant cred, &dbp);
622 1.60 perseant if(error) {
623 1.60 perseant offset = -1;
624 1.60 perseant goto err2;
625 1.60 perseant }
626 1.60 perseant (*dp++) = ((u_long *)(dbp->b_data))[0];
627 1.60 perseant dbp->b_flags |= B_AGE;
628 1.60 perseant brelse(dbp);
629 1.60 perseant }
630 1.60 perseant if(flags & CHECK_UPDATE) {
631 1.60 perseant if ((error = update_inoblk(fs, offset, cred, p))
632 1.60 perseant != 0) {
633 1.60 perseant offset = -1;
634 1.60 perseant goto err2;
635 1.60 perseant }
636 1.60 perseant }
637 1.60 perseant offset += fsbtodb(fs,1);
638 1.60 perseant --iaddr;
639 1.60 perseant --ninos;
640 1.60 perseant --i; /* compensate */
641 1.60 perseant continue;
642 1.60 perseant }
643 1.60 perseant /* printf("check: blocks from ino %d version %d\n",
644 1.60 perseant fip->fi_ino, fip->fi_version); */
645 1.60 perseant size = fs->lfs_bsize;
646 1.60 perseant for(j = 0; j < fip->fi_nblocks; ++j) {
647 1.60 perseant if (j == fip->fi_nblocks - 1)
648 1.60 perseant size = fip->fi_lastlength;
649 1.60 perseant if(flags & CHECK_CKSUM) {
650 1.60 perseant error = bread(devvp, offset, size, cred, &dbp);
651 1.60 perseant if(error) {
652 1.60 perseant offset = -1;
653 1.60 perseant goto err2;
654 1.60 perseant }
655 1.60 perseant (*dp++) = ((u_long *)(dbp->b_data))[0];
656 1.60 perseant dbp->b_flags |= B_AGE;
657 1.60 perseant brelse(dbp);
658 1.60 perseant }
659 1.60 perseant /* Account for and update any direct blocks */
660 1.60 perseant if((flags & CHECK_UPDATE) &&
661 1.60 perseant fip->fi_ino > LFS_IFILE_INUM &&
662 1.60 perseant fip->fi_blocks[j] >= 0) {
663 1.60 perseant update_meta(fs, fip->fi_ino, fip->fi_version,
664 1.60 perseant fip->fi_blocks[j], offset, size, p);
665 1.60 perseant }
666 1.60 perseant offset += btodb(size);
667 1.60 perseant }
668 1.60 perseant fip = (FINFO *)(((char *)fip) + sizeof(FINFO)
669 1.60 perseant + (fip->fi_nblocks - 1) * sizeof(ufs_daddr_t));
670 1.60 perseant }
671 1.60 perseant /* Checksum the array, compare */
672 1.60 perseant if((flags & CHECK_CKSUM) &&
673 1.60 perseant ssp->ss_datasum != cksum(datap, nblocks * sizeof(u_long)))
674 1.60 perseant {
675 1.60 perseant printf("Datasum error at 0x%x (wanted %x got %x)\n", offset,
676 1.60 perseant ssp->ss_datasum, cksum(datap, nblocks *
677 1.60 perseant sizeof(u_long)));
678 1.60 perseant offset = -1;
679 1.60 perseant goto err2;
680 1.60 perseant }
681 1.60 perseant
682 1.60 perseant /* If we're at the end of the segment, move to the next */
683 1.60 perseant if(datosn(fs, offset + btodb(LFS_SUMMARY_SIZE + fs->lfs_bsize)) !=
684 1.60 perseant datosn(fs, offset)) {
685 1.60 perseant if (datosn(fs, offset) == datosn(fs, ssp->ss_next)) {
686 1.60 perseant offset = -1;
687 1.60 perseant goto err2;
688 1.60 perseant }
689 1.60 perseant offset = ssp->ss_next;
690 1.60 perseant #ifdef DEBUG_LFS_RFW
691 1.60 perseant printf("LFS roll forward: moving on to offset 0x%x "
692 1.60 perseant " -> segment %d\n", offset, datosn(fs,offset));
693 1.60 perseant #endif
694 1.60 perseant }
695 1.60 perseant
696 1.60 perseant if (flags & CHECK_UPDATE) {
697 1.60 perseant fs->lfs_avail -= (offset - oldoffset);
698 1.60 perseant /* Don't clog the buffer queue */
699 1.60 perseant if (locked_queue_count > LFS_MAX_BUFS ||
700 1.60 perseant locked_queue_bytes > LFS_MAX_BYTES) {
701 1.60 perseant ++fs->lfs_writer;
702 1.60 perseant lfs_flush(fs, SEGM_CKP);
703 1.60 perseant if(--fs->lfs_writer==0)
704 1.60 perseant wakeup(&fs->lfs_dirops);
705 1.60 perseant }
706 1.60 perseant }
707 1.60 perseant
708 1.60 perseant err2:
709 1.60 perseant if(flags & CHECK_CKSUM)
710 1.60 perseant free(datap, M_SEGMENT);
711 1.60 perseant err1:
712 1.60 perseant bp->b_flags |= B_AGE;
713 1.60 perseant brelse(bp);
714 1.60 perseant
715 1.60 perseant return offset;
716 1.60 perseant }
717 1.60 perseant #endif /* LFS_DO_ROLLFORWARD */
718 1.60 perseant
719 1.1 mycroft /*
720 1.1 mycroft * Common code for mount and mountroot
721 1.1 mycroft * LFS specific
722 1.1 mycroft */
723 1.1 mycroft int
724 1.1 mycroft lfs_mountfs(devvp, mp, p)
725 1.48 augustss struct vnode *devvp;
726 1.1 mycroft struct mount *mp;
727 1.1 mycroft struct proc *p;
728 1.1 mycroft {
729 1.1 mycroft extern struct vnode *rootvp;
730 1.60 perseant struct dlfs *tdfs, *dfs, *adfs;
731 1.48 augustss struct lfs *fs;
732 1.48 augustss struct ufsmount *ump;
733 1.1 mycroft struct vnode *vp;
734 1.28 perseant struct buf *bp, *abp;
735 1.1 mycroft struct partinfo dpart;
736 1.1 mycroft dev_t dev;
737 1.1 mycroft int error, i, ronly, size;
738 1.3 mycroft struct ucred *cred;
739 1.59 perseant CLEANERINFO *cip;
740 1.30 perseant SEGUSE *sup;
741 1.60 perseant #ifdef LFS_DO_ROLLFORWARD
742 1.60 perseant int flags, dirty;
743 1.60 perseant daddr_t offset, oldoffset, lastgoodpseg;
744 1.60 perseant int sn, curseg;
745 1.60 perseant #endif
746 1.1 mycroft
747 1.3 mycroft cred = p ? p->p_ucred : NOCRED;
748 1.1 mycroft /*
749 1.1 mycroft * Disallow multiple mounts of the same device.
750 1.1 mycroft * Disallow mounting of a device that is currently in use
751 1.1 mycroft * (except for root, which might share swap device for miniroot).
752 1.1 mycroft * Flush out any old buffers remaining from a previous use.
753 1.1 mycroft */
754 1.10 christos if ((error = vfs_mountedon(devvp)) != 0)
755 1.1 mycroft return (error);
756 1.1 mycroft if (vcount(devvp) > 1 && devvp != rootvp)
757 1.1 mycroft return (EBUSY);
758 1.10 christos if ((error = vinvalbuf(devvp, V_SAVE, cred, p, 0, 0)) != 0)
759 1.1 mycroft return (error);
760 1.1 mycroft
761 1.1 mycroft ronly = (mp->mnt_flag & MNT_RDONLY) != 0;
762 1.10 christos error = VOP_OPEN(devvp, ronly ? FREAD : FREAD|FWRITE, FSCRED, p);
763 1.10 christos if (error)
764 1.1 mycroft return (error);
765 1.3 mycroft if (VOP_IOCTL(devvp, DIOCGPART, (caddr_t)&dpart, FREAD, cred, p) != 0)
766 1.1 mycroft size = DEV_BSIZE;
767 1.29 mycroft else
768 1.1 mycroft size = dpart.disklab->d_secsize;
769 1.1 mycroft
770 1.1 mycroft /* Don't free random space on error. */
771 1.1 mycroft bp = NULL;
772 1.50 perseant abp = NULL;
773 1.1 mycroft ump = NULL;
774 1.1 mycroft
775 1.1 mycroft /* Read in the superblock. */
776 1.10 christos error = bread(devvp, LFS_LABELPAD / size, LFS_SBPAD, cred, &bp);
777 1.10 christos if (error)
778 1.1 mycroft goto out;
779 1.24 pk dfs = (struct dlfs *)bp->b_data;
780 1.1 mycroft
781 1.50 perseant /* Check the basics. */
782 1.50 perseant if (dfs->dlfs_magic != LFS_MAGIC || dfs->dlfs_bsize > MAXBSIZE ||
783 1.50 perseant dfs->dlfs_version > LFS_VERSION ||
784 1.50 perseant dfs->dlfs_bsize < sizeof(struct dlfs)) {
785 1.50 perseant error = EINVAL; /* XXX needs translation */
786 1.50 perseant goto out;
787 1.50 perseant }
788 1.50 perseant
789 1.26 perseant /*
790 1.26 perseant * Check the second superblock to see which is newer; then mount
791 1.26 perseant * using the older of the two. This is necessary to ensure that
792 1.26 perseant * the filesystem is valid if it was not unmounted cleanly.
793 1.26 perseant */
794 1.60 perseant
795 1.50 perseant if (dfs->dlfs_sboffs[1] &&
796 1.50 perseant dfs->dlfs_sboffs[1]-(LFS_LABELPAD/size) > LFS_SBPAD/size)
797 1.50 perseant {
798 1.50 perseant error = bread(devvp, dfs->dlfs_sboffs[1], LFS_SBPAD, cred, &abp);
799 1.50 perseant if (error)
800 1.50 perseant goto out;
801 1.50 perseant adfs = (struct dlfs *)abp->b_data;
802 1.50 perseant
803 1.50 perseant if (adfs->dlfs_tstamp < dfs->dlfs_tstamp) /* XXX 1s? */
804 1.60 perseant tdfs = adfs;
805 1.60 perseant else
806 1.60 perseant tdfs = dfs;
807 1.60 perseant
808 1.60 perseant /* Check the basics. */
809 1.60 perseant if (tdfs->dlfs_magic != LFS_MAGIC ||
810 1.60 perseant tdfs->dlfs_bsize > MAXBSIZE ||
811 1.60 perseant tdfs->dlfs_version > LFS_VERSION ||
812 1.60 perseant tdfs->dlfs_bsize < sizeof(struct dlfs)) {
813 1.60 perseant error = EINVAL; /* XXX needs translation */
814 1.60 perseant goto out;
815 1.60 perseant }
816 1.50 perseant } else {
817 1.50 perseant printf("lfs_mountfs: invalid alt superblock daddr=0x%x\n",
818 1.50 perseant dfs->dlfs_sboffs[1]);
819 1.50 perseant error = EINVAL;
820 1.1 mycroft goto out;
821 1.1 mycroft }
822 1.1 mycroft
823 1.1 mycroft /* Allocate the mount structure, copy the superblock into it. */
824 1.29 mycroft fs = malloc(sizeof(struct lfs), M_UFSMNT, M_WAITOK);
825 1.60 perseant memcpy(&fs->lfs_dlfs, tdfs, sizeof(struct dlfs));
826 1.60 perseant
827 1.60 perseant #ifdef LFS_DO_ROLLFORWARD
828 1.60 perseant /* Before rolling forward, lock so vget will sleep for other procs */
829 1.60 perseant fs->lfs_flags = LFS_NOTYET;
830 1.60 perseant fs->lfs_rfpid = p->p_pid;
831 1.60 perseant #else
832 1.60 perseant fs->lfs_flags = 0;
833 1.60 perseant #endif
834 1.60 perseant
835 1.29 mycroft ump = malloc(sizeof *ump, M_UFSMNT, M_WAITOK);
836 1.29 mycroft memset((caddr_t)ump, 0, sizeof *ump);
837 1.29 mycroft ump->um_lfs = fs;
838 1.60 perseant if (sizeof(struct lfs) < LFS_SBPAD) { /* XXX why? */
839 1.1 mycroft bp->b_flags |= B_INVAL;
840 1.60 perseant abp->b_flags |= B_INVAL;
841 1.60 perseant }
842 1.1 mycroft brelse(bp);
843 1.1 mycroft bp = NULL;
844 1.26 perseant brelse(abp);
845 1.26 perseant abp = NULL;
846 1.1 mycroft
847 1.1 mycroft /* Set up the I/O information */
848 1.1 mycroft fs->lfs_iocount = 0;
849 1.34 perseant fs->lfs_diropwait = 0;
850 1.26 perseant fs->lfs_activesb = 0;
851 1.57 perseant fs->lfs_uinodes = 0;
852 1.58 perseant fs->lfs_ravail = 0;
853 1.26 perseant #ifdef LFS_CANNOT_ROLLFW
854 1.51 thorpej fs->lfs_sbactive = 0;
855 1.26 perseant #endif
856 1.26 perseant #ifdef LFS_TRACK_IOS
857 1.29 mycroft for (i=0;i<LFS_THROTTLE;i++)
858 1.26 perseant fs->lfs_pending[i] = LFS_UNUSED_DADDR;
859 1.26 perseant #endif
860 1.1 mycroft
861 1.1 mycroft /* Set up the ifile and lock aflags */
862 1.1 mycroft fs->lfs_doifile = 0;
863 1.1 mycroft fs->lfs_writer = 0;
864 1.1 mycroft fs->lfs_dirops = 0;
865 1.52 perseant fs->lfs_nadirop = 0;
866 1.1 mycroft fs->lfs_seglock = 0;
867 1.46 perseant lockinit(&fs->lfs_freelock, PINOD, "lfs_freelock", 0, 0);
868 1.1 mycroft
869 1.1 mycroft /* Set the file system readonly/modify bits. */
870 1.1 mycroft fs->lfs_ronly = ronly;
871 1.1 mycroft if (ronly == 0)
872 1.1 mycroft fs->lfs_fmod = 1;
873 1.1 mycroft
874 1.1 mycroft /* Initialize the mount structure. */
875 1.1 mycroft dev = devvp->v_rdev;
876 1.1 mycroft mp->mnt_data = (qaddr_t)ump;
877 1.1 mycroft mp->mnt_stat.f_fsid.val[0] = (long)dev;
878 1.1 mycroft mp->mnt_stat.f_fsid.val[1] = makefstype(MOUNT_LFS);
879 1.49 perseant mp->mnt_stat.f_iosize = fs->lfs_bsize;
880 1.1 mycroft mp->mnt_maxsymlinklen = fs->lfs_maxsymlinklen;
881 1.1 mycroft mp->mnt_flag |= MNT_LOCAL;
882 1.18 bouyer ump->um_flags = 0;
883 1.1 mycroft ump->um_mountp = mp;
884 1.1 mycroft ump->um_dev = dev;
885 1.1 mycroft ump->um_devvp = devvp;
886 1.1 mycroft ump->um_bptrtodb = 0;
887 1.1 mycroft ump->um_seqinc = 1 << fs->lfs_fsbtodb;
888 1.1 mycroft ump->um_nindir = fs->lfs_nindir;
889 1.61 chs ump->um_lognindir = ffs(fs->lfs_nindir) - 1;
890 1.1 mycroft for (i = 0; i < MAXQUOTAS; i++)
891 1.1 mycroft ump->um_quotas[i] = NULLVP;
892 1.44 fvdl devvp->v_specmountpoint = mp;
893 1.1 mycroft
894 1.1 mycroft /*
895 1.1 mycroft * We use the ifile vnode for almost every operation. Instead of
896 1.1 mycroft * retrieving it from the hash table each time we retrieve it here,
897 1.1 mycroft * artificially increment the reference count and keep a pointer
898 1.1 mycroft * to it in the incore copy of the superblock.
899 1.1 mycroft */
900 1.10 christos if ((error = VFS_VGET(mp, LFS_IFILE_INUM, &vp)) != 0)
901 1.1 mycroft goto out;
902 1.1 mycroft fs->lfs_ivnode = vp;
903 1.1 mycroft VREF(vp);
904 1.1 mycroft vput(vp);
905 1.30 perseant
906 1.60 perseant #ifdef LFS_DO_ROLLFORWARD
907 1.60 perseant /*
908 1.60 perseant * Roll forward.
909 1.60 perseant */
910 1.60 perseant /*
911 1.60 perseant * Phase I:
912 1.60 perseant * Find the address of the last good partial segment that was written
913 1.60 perseant * after the checkpoint. Mark the segments in question dirty, so
914 1.60 perseant * they won't be reallocated.
915 1.60 perseant */
916 1.60 perseant lastgoodpseg = oldoffset = offset = fs->lfs_offset;
917 1.60 perseant flags = 0x0;
918 1.60 perseant #ifdef DEBUG_LFS_RFW
919 1.60 perseant printf("LFS roll forward phase 1: starting at offset 0x%x\n", offset);
920 1.60 perseant #endif
921 1.60 perseant LFS_SEGENTRY(sup, fs, datosn(fs, offset), bp);
922 1.60 perseant if (!(sup->su_flags & SEGUSE_DIRTY))
923 1.60 perseant --fs->lfs_nclean;
924 1.60 perseant sup->su_flags |= SEGUSE_DIRTY;
925 1.60 perseant (void) VOP_BWRITE(bp);
926 1.60 perseant while ((offset = check_segsum(fs, offset, cred, CHECK_CKSUM, &flags,
927 1.60 perseant p)) > 0) {
928 1.60 perseant if(sntoda(fs, oldoffset) != sntoda(fs, offset)) {
929 1.60 perseant LFS_SEGENTRY(sup, fs, datosn(fs, oldoffset), bp);
930 1.60 perseant if (!(sup->su_flags & SEGUSE_DIRTY))
931 1.60 perseant --fs->lfs_nclean;
932 1.60 perseant sup->su_flags |= SEGUSE_DIRTY;
933 1.60 perseant (void) VOP_BWRITE(bp);
934 1.60 perseant }
935 1.60 perseant
936 1.60 perseant #ifdef DEBUG_LFS_RFW
937 1.60 perseant printf("LFS roll forward phase 1: offset=0x%x\n", offset);
938 1.60 perseant if(flags & SS_DIROP) {
939 1.60 perseant printf("lfs_mountfs: dirops at 0x%x\n", oldoffset);
940 1.60 perseant if(!(flags & SS_CONT))
941 1.60 perseant printf("lfs_mountfs: dirops end at 0x%x\n",
942 1.60 perseant oldoffset);
943 1.60 perseant }
944 1.60 perseant #endif
945 1.60 perseant if(!(flags & SS_CONT))
946 1.60 perseant lastgoodpseg = offset;
947 1.60 perseant oldoffset = offset;
948 1.60 perseant }
949 1.60 perseant #ifdef DEBUG_LFS_RFW
950 1.60 perseant if (flags & SS_CONT) {
951 1.60 perseant printf("LFS roll forward: warning: incomplete dirops discarded\n");
952 1.60 perseant }
953 1.60 perseant printf("LFS roll forward phase 1: completed: lastgoodpseg=0x%x\n",
954 1.60 perseant lastgoodpseg);
955 1.60 perseant #endif
956 1.60 perseant
957 1.60 perseant /* Don't accidentally overwrite what we're trying to preserve */
958 1.60 perseant offset = fs->lfs_offset;
959 1.60 perseant fs->lfs_offset = lastgoodpseg;
960 1.60 perseant fs->lfs_curseg = sntoda(fs, datosn(fs, fs->lfs_offset));
961 1.60 perseant for (sn = curseg = datosn(fs, fs->lfs_curseg);;) {
962 1.60 perseant sn = (sn + 1) % fs->lfs_nseg;
963 1.60 perseant if (sn == curseg)
964 1.60 perseant panic("lfs_mountfs: no clean segments");
965 1.60 perseant LFS_SEGENTRY(sup, fs, sn, bp);
966 1.60 perseant dirty = (sup->su_flags & SEGUSE_DIRTY);
967 1.60 perseant brelse(bp);
968 1.60 perseant if (!dirty)
969 1.60 perseant break;
970 1.60 perseant }
971 1.60 perseant fs->lfs_nextseg = sntoda(fs, sn);
972 1.60 perseant
973 1.60 perseant /*
974 1.60 perseant * Phase II: Roll forward from the first superblock.
975 1.60 perseant */
976 1.60 perseant while (offset != lastgoodpseg) {
977 1.60 perseant #ifdef DEBUG_LFS_RFW
978 1.60 perseant printf("LFS roll forward phase 2: 0x%x\n", offset);
979 1.60 perseant #endif
980 1.60 perseant oldoffset = offset;
981 1.60 perseant offset = check_segsum(fs, offset, cred, CHECK_UPDATE, NULL, p);
982 1.60 perseant }
983 1.60 perseant
984 1.60 perseant /*
985 1.60 perseant * Finish: flush our changes to disk.
986 1.60 perseant */
987 1.60 perseant lfs_segwrite(fs->lfs_ivnode->v_mount, SEGM_CKP | SEGM_SYNC);
988 1.60 perseant
989 1.60 perseant #ifdef DEBUG_LFS_RFW
990 1.60 perseant printf("LFS roll forward complete\n");
991 1.60 perseant #endif
992 1.60 perseant /* Allow vget now that roll-forward is complete */
993 1.60 perseant fs->lfs_flags &= ~(LFS_NOTYET);
994 1.60 perseant wakeup(&fs->lfs_flags);
995 1.60 perseant #endif /* LFS_DO_ROLLFORWARD */
996 1.60 perseant
997 1.30 perseant /*
998 1.59 perseant * Initialize the ifile cleaner info with information from
999 1.59 perseant * the superblock.
1000 1.59 perseant */
1001 1.59 perseant LFS_CLEANERINFO(cip, fs, bp);
1002 1.59 perseant cip->clean = fs->lfs_nclean;
1003 1.59 perseant cip->dirty = fs->lfs_nseg - fs->lfs_nclean;
1004 1.59 perseant cip->avail = fs->lfs_avail;
1005 1.59 perseant cip->bfree = fs->lfs_bfree;
1006 1.59 perseant (void) VOP_BWRITE(bp); /* Ifile */
1007 1.59 perseant
1008 1.59 perseant /*
1009 1.30 perseant * Mark the current segment as ACTIVE, since we're going to
1010 1.30 perseant * be writing to it.
1011 1.30 perseant */
1012 1.30 perseant LFS_SEGENTRY(sup, fs, datosn(fs, fs->lfs_offset), bp);
1013 1.30 perseant sup->su_flags |= SEGUSE_DIRTY | SEGUSE_ACTIVE;
1014 1.59 perseant (void) VOP_BWRITE(bp); /* Ifile */
1015 1.1 mycroft
1016 1.1 mycroft return (0);
1017 1.1 mycroft out:
1018 1.1 mycroft if (bp)
1019 1.1 mycroft brelse(bp);
1020 1.26 perseant if (abp)
1021 1.26 perseant brelse(abp);
1022 1.39 wrstuden vn_lock(devvp, LK_EXCLUSIVE | LK_RETRY);
1023 1.3 mycroft (void)VOP_CLOSE(devvp, ronly ? FREAD : FREAD|FWRITE, cred, p);
1024 1.39 wrstuden VOP_UNLOCK(devvp, 0);
1025 1.1 mycroft if (ump) {
1026 1.1 mycroft free(ump->um_lfs, M_UFSMNT);
1027 1.1 mycroft free(ump, M_UFSMNT);
1028 1.1 mycroft mp->mnt_data = (qaddr_t)0;
1029 1.1 mycroft }
1030 1.1 mycroft return (error);
1031 1.1 mycroft }
1032 1.1 mycroft
1033 1.1 mycroft /*
1034 1.1 mycroft * unmount system call
1035 1.1 mycroft */
1036 1.10 christos int
1037 1.1 mycroft lfs_unmount(mp, mntflags, p)
1038 1.1 mycroft struct mount *mp;
1039 1.1 mycroft int mntflags;
1040 1.1 mycroft struct proc *p;
1041 1.1 mycroft {
1042 1.48 augustss struct ufsmount *ump;
1043 1.48 augustss struct lfs *fs;
1044 1.11 pk int error, flags, ronly;
1045 1.26 perseant extern int lfs_allclean_wakeup;
1046 1.1 mycroft
1047 1.1 mycroft flags = 0;
1048 1.5 mycroft if (mntflags & MNT_FORCE)
1049 1.1 mycroft flags |= FORCECLOSE;
1050 1.1 mycroft
1051 1.1 mycroft ump = VFSTOUFS(mp);
1052 1.1 mycroft fs = ump->um_lfs;
1053 1.1 mycroft #ifdef QUOTA
1054 1.1 mycroft if (mp->mnt_flag & MNT_QUOTA) {
1055 1.11 pk int i;
1056 1.10 christos error = vflush(mp, fs->lfs_ivnode, SKIPSYSTEM|flags);
1057 1.10 christos if (error)
1058 1.1 mycroft return (error);
1059 1.1 mycroft for (i = 0; i < MAXQUOTAS; i++) {
1060 1.1 mycroft if (ump->um_quotas[i] == NULLVP)
1061 1.1 mycroft continue;
1062 1.1 mycroft quotaoff(p, mp, i);
1063 1.1 mycroft }
1064 1.1 mycroft /*
1065 1.1 mycroft * Here we fall through to vflush again to ensure
1066 1.1 mycroft * that we have gotten rid of all the system vnodes.
1067 1.1 mycroft */
1068 1.1 mycroft }
1069 1.1 mycroft #endif
1070 1.10 christos if ((error = vflush(mp, fs->lfs_ivnode, flags)) != 0)
1071 1.1 mycroft return (error);
1072 1.1 mycroft fs->lfs_clean = 1;
1073 1.10 christos if ((error = VFS_SYNC(mp, 1, p->p_ucred, p)) != 0)
1074 1.1 mycroft return (error);
1075 1.1 mycroft if (fs->lfs_ivnode->v_dirtyblkhd.lh_first)
1076 1.1 mycroft panic("lfs_unmount: still dirty blocks on ifile vnode\n");
1077 1.1 mycroft vrele(fs->lfs_ivnode);
1078 1.1 mycroft vgone(fs->lfs_ivnode);
1079 1.1 mycroft
1080 1.1 mycroft ronly = !fs->lfs_ronly;
1081 1.40 enami if (ump->um_devvp->v_type != VBAD)
1082 1.44 fvdl ump->um_devvp->v_specmountpoint = NULL;
1083 1.39 wrstuden vn_lock(ump->um_devvp, LK_EXCLUSIVE | LK_RETRY);
1084 1.1 mycroft error = VOP_CLOSE(ump->um_devvp,
1085 1.1 mycroft ronly ? FREAD : FREAD|FWRITE, NOCRED, p);
1086 1.39 wrstuden vput(ump->um_devvp);
1087 1.26 perseant
1088 1.26 perseant /* XXX KS - wake up the cleaner so it can die */
1089 1.26 perseant wakeup(&fs->lfs_nextseg);
1090 1.26 perseant wakeup(&lfs_allclean_wakeup);
1091 1.26 perseant
1092 1.1 mycroft free(fs, M_UFSMNT);
1093 1.1 mycroft free(ump, M_UFSMNT);
1094 1.1 mycroft mp->mnt_data = (qaddr_t)0;
1095 1.1 mycroft mp->mnt_flag &= ~MNT_LOCAL;
1096 1.1 mycroft return (error);
1097 1.1 mycroft }
1098 1.1 mycroft
1099 1.1 mycroft /*
1100 1.1 mycroft * Get file system statistics.
1101 1.1 mycroft */
1102 1.10 christos int
1103 1.1 mycroft lfs_statfs(mp, sbp, p)
1104 1.1 mycroft struct mount *mp;
1105 1.48 augustss struct statfs *sbp;
1106 1.1 mycroft struct proc *p;
1107 1.1 mycroft {
1108 1.48 augustss struct lfs *fs;
1109 1.48 augustss struct ufsmount *ump;
1110 1.1 mycroft
1111 1.1 mycroft ump = VFSTOUFS(mp);
1112 1.1 mycroft fs = ump->um_lfs;
1113 1.1 mycroft if (fs->lfs_magic != LFS_MAGIC)
1114 1.1 mycroft panic("lfs_statfs: magic");
1115 1.53 perseant
1116 1.1 mycroft sbp->f_type = 0;
1117 1.26 perseant sbp->f_bsize = fs->lfs_fsize;
1118 1.1 mycroft sbp->f_iosize = fs->lfs_bsize;
1119 1.53 perseant sbp->f_blocks = dbtofrags(fs, LFS_EST_NONMETA(fs));
1120 1.53 perseant sbp->f_bfree = dbtofrags(fs, LFS_EST_BFREE(fs));
1121 1.53 perseant sbp->f_bavail = dbtofrags(fs, (long)LFS_EST_BFREE(fs) -
1122 1.53 perseant (long)LFS_EST_RSVD(fs));
1123 1.31 perseant sbp->f_files = dbtofsb(fs,fs->lfs_bfree) * INOPB(fs);
1124 1.31 perseant sbp->f_ffree = sbp->f_files - fs->lfs_nfiles;
1125 1.1 mycroft if (sbp != &mp->mnt_stat) {
1126 1.6 mycroft bcopy(mp->mnt_stat.f_mntonname, sbp->f_mntonname, MNAMELEN);
1127 1.6 mycroft bcopy(mp->mnt_stat.f_mntfromname, sbp->f_mntfromname, MNAMELEN);
1128 1.1 mycroft }
1129 1.6 mycroft strncpy(sbp->f_fstypename, mp->mnt_op->vfs_name, MFSNAMELEN);
1130 1.1 mycroft return (0);
1131 1.1 mycroft }
1132 1.1 mycroft
1133 1.1 mycroft /*
1134 1.1 mycroft * Go through the disk queues to initiate sandbagged IO;
1135 1.1 mycroft * go through the inodes to write those that have been modified;
1136 1.1 mycroft * initiate the writing of the super block if it has been modified.
1137 1.1 mycroft *
1138 1.1 mycroft * Note: we are always called with the filesystem marked `MPBUSY'.
1139 1.1 mycroft */
1140 1.10 christos int
1141 1.1 mycroft lfs_sync(mp, waitfor, cred, p)
1142 1.1 mycroft struct mount *mp;
1143 1.1 mycroft int waitfor;
1144 1.1 mycroft struct ucred *cred;
1145 1.1 mycroft struct proc *p;
1146 1.1 mycroft {
1147 1.1 mycroft int error;
1148 1.26 perseant struct lfs *fs;
1149 1.26 perseant
1150 1.26 perseant fs = ((struct ufsmount *)mp->mnt_data)->ufsmount_u.lfs;
1151 1.56 perseant if (fs->lfs_ronly)
1152 1.56 perseant return 0;
1153 1.26 perseant while(fs->lfs_dirops)
1154 1.26 perseant error = tsleep(&fs->lfs_dirops, PRIBIO + 1, "lfs_dirops", 0);
1155 1.26 perseant fs->lfs_writer++;
1156 1.1 mycroft
1157 1.1 mycroft /* All syncs must be checkpoints until roll-forward is implemented. */
1158 1.1 mycroft error = lfs_segwrite(mp, SEGM_CKP | (waitfor ? SEGM_SYNC : 0));
1159 1.26 perseant if(--fs->lfs_writer==0)
1160 1.26 perseant wakeup(&fs->lfs_dirops);
1161 1.1 mycroft #ifdef QUOTA
1162 1.1 mycroft qsync(mp);
1163 1.1 mycroft #endif
1164 1.1 mycroft return (error);
1165 1.1 mycroft }
1166 1.1 mycroft
1167 1.26 perseant extern struct lock ufs_hashlock;
1168 1.26 perseant
1169 1.1 mycroft /*
1170 1.1 mycroft * Look up an LFS dinode number to find its incore vnode. If not already
1171 1.1 mycroft * in core, read it in from the specified device. Return the inode locked.
1172 1.1 mycroft * Detection and handling of mount points must be done by the calling routine.
1173 1.1 mycroft */
1174 1.1 mycroft int
1175 1.1 mycroft lfs_vget(mp, ino, vpp)
1176 1.1 mycroft struct mount *mp;
1177 1.1 mycroft ino_t ino;
1178 1.1 mycroft struct vnode **vpp;
1179 1.1 mycroft {
1180 1.48 augustss struct lfs *fs;
1181 1.48 augustss struct inode *ip;
1182 1.1 mycroft struct buf *bp;
1183 1.1 mycroft struct ifile *ifp;
1184 1.1 mycroft struct vnode *vp;
1185 1.1 mycroft struct ufsmount *ump;
1186 1.16 fvdl ufs_daddr_t daddr;
1187 1.1 mycroft dev_t dev;
1188 1.1 mycroft int error;
1189 1.26 perseant #ifdef LFS_ATIME_IFILE
1190 1.26 perseant struct timespec ts;
1191 1.26 perseant #endif
1192 1.1 mycroft
1193 1.1 mycroft ump = VFSTOUFS(mp);
1194 1.1 mycroft dev = ump->um_dev;
1195 1.60 perseant fs = ump->um_lfs;
1196 1.60 perseant
1197 1.60 perseant /*
1198 1.60 perseant * If the filesystem is not completely mounted yet, suspend
1199 1.60 perseant * any access requests (wait for roll-forward to complete).
1200 1.60 perseant */
1201 1.60 perseant while((fs->lfs_flags & LFS_NOTYET) && curproc->p_pid != fs->lfs_rfpid)
1202 1.60 perseant tsleep(&fs->lfs_flags, PRIBIO+1, "lfs_notyet", 0);
1203 1.26 perseant
1204 1.55 fvdl if ((*vpp = ufs_ihashget(dev, ino, LK_EXCLUSIVE)) != NULL)
1205 1.55 fvdl return (0);
1206 1.55 fvdl
1207 1.55 fvdl if ((error = getnewvnode(VT_LFS, mp, lfs_vnodeop_p, &vp)) != 0) {
1208 1.55 fvdl *vpp = NULL;
1209 1.55 fvdl return (error);
1210 1.55 fvdl }
1211 1.55 fvdl
1212 1.26 perseant do {
1213 1.55 fvdl if ((*vpp = ufs_ihashget(dev, ino, LK_EXCLUSIVE)) != NULL) {
1214 1.55 fvdl ungetnewvnode(vp);
1215 1.26 perseant return (0);
1216 1.55 fvdl }
1217 1.26 perseant } while (lockmgr(&ufs_hashlock, LK_EXCLUSIVE|LK_SLEEPFAIL, 0));
1218 1.1 mycroft
1219 1.1 mycroft /* Translate the inode number to a disk address. */
1220 1.1 mycroft if (ino == LFS_IFILE_INUM)
1221 1.1 mycroft daddr = fs->lfs_idaddr;
1222 1.1 mycroft else {
1223 1.60 perseant /* XXX bounds-check this too */
1224 1.1 mycroft LFS_IENTRY(ifp, fs, ino, bp);
1225 1.1 mycroft daddr = ifp->if_daddr;
1226 1.26 perseant #ifdef LFS_ATIME_IFILE
1227 1.26 perseant ts = ifp->if_atime; /* structure copy */
1228 1.26 perseant #endif
1229 1.1 mycroft brelse(bp);
1230 1.26 perseant if (daddr == LFS_UNUSED_DADDR) {
1231 1.60 perseant *vpp = NULLVP;
1232 1.60 perseant ungetnewvnode(vp);
1233 1.26 perseant lockmgr(&ufs_hashlock, LK_RELEASE, 0);
1234 1.1 mycroft return (ENOENT);
1235 1.26 perseant }
1236 1.1 mycroft }
1237 1.1 mycroft
1238 1.55 fvdl /* Allocate/init new vnode/inode. */
1239 1.55 fvdl lfs_vcreate(mp, ino, vp);
1240 1.1 mycroft
1241 1.1 mycroft /*
1242 1.1 mycroft * Put it onto its hash chain and lock it so that other requests for
1243 1.1 mycroft * this inode will block if they arrive while we are sleeping waiting
1244 1.1 mycroft * for old data structures to be purged or for the contents of the
1245 1.1 mycroft * disk portion of this inode to be read.
1246 1.1 mycroft */
1247 1.1 mycroft ip = VTOI(vp);
1248 1.1 mycroft ufs_ihashins(ip);
1249 1.26 perseant lockmgr(&ufs_hashlock, LK_RELEASE, 0);
1250 1.1 mycroft
1251 1.1 mycroft /*
1252 1.1 mycroft * XXX
1253 1.1 mycroft * This may not need to be here, logically it should go down with
1254 1.1 mycroft * the i_devvp initialization.
1255 1.1 mycroft * Ask Kirk.
1256 1.1 mycroft */
1257 1.1 mycroft ip->i_lfs = ump->um_lfs;
1258 1.1 mycroft
1259 1.1 mycroft /* Read in the disk contents for the inode, copy into the inode. */
1260 1.10 christos error = bread(ump->um_devvp, daddr, (int)fs->lfs_bsize, NOCRED, &bp);
1261 1.10 christos if (error) {
1262 1.1 mycroft /*
1263 1.1 mycroft * The inode does not contain anything useful, so it would
1264 1.1 mycroft * be misleading to leave it on its hash chain. With mode
1265 1.1 mycroft * still zero, it will be unlinked and returned to the free
1266 1.1 mycroft * list by vput().
1267 1.1 mycroft */
1268 1.1 mycroft vput(vp);
1269 1.1 mycroft brelse(bp);
1270 1.1 mycroft *vpp = NULL;
1271 1.1 mycroft return (error);
1272 1.1 mycroft }
1273 1.46 perseant ip->i_din.ffs_din = *lfs_ifind(fs, ino, bp);
1274 1.45 perseant ip->i_ffs_effnlink = ip->i_ffs_nlink;
1275 1.56 perseant ip->i_lfs_effnblks = ip->i_ffs_blocks;
1276 1.26 perseant #ifdef LFS_ATIME_IFILE
1277 1.26 perseant ip->i_ffs_atime = ts.tv_sec;
1278 1.26 perseant ip->i_ffs_atimensec = ts.tv_nsec;
1279 1.26 perseant #endif
1280 1.1 mycroft brelse(bp);
1281 1.1 mycroft
1282 1.1 mycroft /*
1283 1.1 mycroft * Initialize the vnode from the inode, check for aliases. In all
1284 1.1 mycroft * cases re-init ip, the underlying vnode/inode may have changed.
1285 1.1 mycroft */
1286 1.22 sommerfe error = ufs_vinit(mp, lfs_specop_p, lfs_fifoop_p, &vp);
1287 1.10 christos if (error) {
1288 1.1 mycroft vput(vp);
1289 1.1 mycroft *vpp = NULL;
1290 1.1 mycroft return (error);
1291 1.1 mycroft }
1292 1.58 perseant #ifdef DIAGNOSTIC
1293 1.26 perseant if(vp->v_type == VNON) {
1294 1.58 perseant panic("lfs_vget: ino %d is type VNON! (ifmt %o)\n",
1295 1.58 perseant ip->i_number, (ip->i_ffs_mode & IFMT) >> 12);
1296 1.58 perseant }
1297 1.26 perseant #endif
1298 1.1 mycroft /*
1299 1.1 mycroft * Finish inode initialization now that aliasing has been resolved.
1300 1.1 mycroft */
1301 1.1 mycroft ip->i_devvp = ump->um_devvp;
1302 1.1 mycroft VREF(ip->i_devvp);
1303 1.1 mycroft *vpp = vp;
1304 1.62 perseant
1305 1.62 perseant uvm_vnp_setsize(vp, ip->i_ffs_size);
1306 1.26 perseant
1307 1.1 mycroft return (0);
1308 1.1 mycroft }
1309 1.1 mycroft
1310 1.1 mycroft /*
1311 1.1 mycroft * File handle to vnode
1312 1.1 mycroft *
1313 1.1 mycroft * Have to be really careful about stale file handles:
1314 1.1 mycroft * - check that the inode number is valid
1315 1.1 mycroft * - call lfs_vget() to get the locked inode
1316 1.1 mycroft * - check for an unallocated inode (i_mode == 0)
1317 1.1 mycroft *
1318 1.1 mycroft * XXX
1319 1.1 mycroft * use ifile to see if inode is allocated instead of reading off disk
1320 1.1 mycroft * what is the relationship between my generational number and the NFS
1321 1.1 mycroft * generational number.
1322 1.1 mycroft */
1323 1.1 mycroft int
1324 1.25 wrstuden lfs_fhtovp(mp, fhp, vpp)
1325 1.48 augustss struct mount *mp;
1326 1.1 mycroft struct fid *fhp;
1327 1.1 mycroft struct vnode **vpp;
1328 1.1 mycroft {
1329 1.48 augustss struct ufid *ufhp;
1330 1.1 mycroft
1331 1.1 mycroft ufhp = (struct ufid *)fhp;
1332 1.1 mycroft if (ufhp->ufid_ino < ROOTINO)
1333 1.1 mycroft return (ESTALE);
1334 1.25 wrstuden return (ufs_fhtovp(mp, ufhp, vpp));
1335 1.1 mycroft }
1336 1.1 mycroft
1337 1.1 mycroft /*
1338 1.1 mycroft * Vnode pointer to File handle
1339 1.1 mycroft */
1340 1.1 mycroft /* ARGSUSED */
1341 1.10 christos int
1342 1.1 mycroft lfs_vptofh(vp, fhp)
1343 1.1 mycroft struct vnode *vp;
1344 1.1 mycroft struct fid *fhp;
1345 1.1 mycroft {
1346 1.48 augustss struct inode *ip;
1347 1.48 augustss struct ufid *ufhp;
1348 1.1 mycroft
1349 1.1 mycroft ip = VTOI(vp);
1350 1.1 mycroft ufhp = (struct ufid *)fhp;
1351 1.1 mycroft ufhp->ufid_len = sizeof(struct ufid);
1352 1.1 mycroft ufhp->ufid_ino = ip->i_number;
1353 1.13 bouyer ufhp->ufid_gen = ip->i_ffs_gen;
1354 1.1 mycroft return (0);
1355 1.16 fvdl }
1356 1.16 fvdl
1357 1.16 fvdl int
1358 1.16 fvdl lfs_sysctl(name, namelen, oldp, oldlenp, newp, newlen, p)
1359 1.16 fvdl int *name;
1360 1.16 fvdl u_int namelen;
1361 1.16 fvdl void *oldp;
1362 1.16 fvdl size_t *oldlenp;
1363 1.16 fvdl void *newp;
1364 1.16 fvdl size_t newlen;
1365 1.16 fvdl struct proc *p;
1366 1.16 fvdl {
1367 1.26 perseant extern int lfs_writeindir, lfs_dostats, lfs_clean_vnhead;
1368 1.26 perseant extern struct lfs_stats lfs_stats;
1369 1.26 perseant int error;
1370 1.26 perseant
1371 1.26 perseant /* all sysctl names at this level are terminal */
1372 1.26 perseant if (namelen != 1)
1373 1.26 perseant return (ENOTDIR);
1374 1.26 perseant
1375 1.26 perseant switch (name[0]) {
1376 1.26 perseant case LFS_WRITEINDIR:
1377 1.26 perseant return (sysctl_int(oldp, oldlenp, newp, newlen,
1378 1.26 perseant &lfs_writeindir));
1379 1.26 perseant case LFS_CLEAN_VNHEAD:
1380 1.26 perseant return (sysctl_int(oldp, oldlenp, newp, newlen,
1381 1.26 perseant &lfs_clean_vnhead));
1382 1.26 perseant case LFS_DOSTATS:
1383 1.26 perseant if((error = sysctl_int(oldp, oldlenp, newp, newlen,
1384 1.26 perseant &lfs_dostats)))
1385 1.26 perseant return error;
1386 1.26 perseant if(lfs_dostats == 0)
1387 1.26 perseant memset(&lfs_stats,0,sizeof(lfs_stats));
1388 1.26 perseant return 0;
1389 1.26 perseant case LFS_STATS:
1390 1.26 perseant return (sysctl_rdstruct(oldp, oldlenp, newp,
1391 1.26 perseant &lfs_stats, sizeof(lfs_stats)));
1392 1.26 perseant default:
1393 1.26 perseant return (EOPNOTSUPP);
1394 1.26 perseant }
1395 1.26 perseant /* NOTREACHED */
1396 1.1 mycroft }
1397