lfs_segment.c revision 1.69 1 1.69 perseant /* $NetBSD: lfs_segment.c,v 1.69 2001/07/13 20:30:24 perseant Exp $ */
2 1.2 cgd
3 1.15 perseant /*-
4 1.58 perseant * Copyright (c) 1999, 2000 The NetBSD Foundation, Inc.
5 1.15 perseant * All rights reserved.
6 1.15 perseant *
7 1.15 perseant * This code is derived from software contributed to The NetBSD Foundation
8 1.15 perseant * by Konrad E. Schroder <perseant (at) hhhh.org>.
9 1.15 perseant *
10 1.15 perseant * Redistribution and use in source and binary forms, with or without
11 1.15 perseant * modification, are permitted provided that the following conditions
12 1.15 perseant * are met:
13 1.15 perseant * 1. Redistributions of source code must retain the above copyright
14 1.15 perseant * notice, this list of conditions and the following disclaimer.
15 1.15 perseant * 2. Redistributions in binary form must reproduce the above copyright
16 1.15 perseant * notice, this list of conditions and the following disclaimer in the
17 1.15 perseant * documentation and/or other materials provided with the distribution.
18 1.15 perseant * 3. All advertising materials mentioning features or use of this software
19 1.15 perseant * must display the following acknowledgement:
20 1.15 perseant * This product includes software developed by the NetBSD
21 1.15 perseant * Foundation, Inc. and its contributors.
22 1.15 perseant * 4. Neither the name of The NetBSD Foundation nor the names of its
23 1.15 perseant * contributors may be used to endorse or promote products derived
24 1.15 perseant * from this software without specific prior written permission.
25 1.15 perseant *
26 1.15 perseant * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
27 1.15 perseant * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
28 1.15 perseant * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
29 1.15 perseant * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
30 1.15 perseant * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
31 1.15 perseant * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
32 1.15 perseant * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
33 1.15 perseant * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
34 1.15 perseant * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
35 1.15 perseant * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
36 1.15 perseant * POSSIBILITY OF SUCH DAMAGE.
37 1.15 perseant */
38 1.1 mycroft /*
39 1.1 mycroft * Copyright (c) 1991, 1993
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.10 fvdl * @(#)lfs_segment.c 8.10 (Berkeley) 6/10/95
71 1.1 mycroft */
72 1.1 mycroft
73 1.16 perseant #define ivndebug(vp,str) printf("ino %d: %s\n",VTOI(vp)->i_number,(str))
74 1.16 perseant
75 1.68 mrg #if defined(_KERNEL_OPT)
76 1.30 perseant #include "opt_ddb.h"
77 1.65 jdolecek #endif
78 1.65 jdolecek
79 1.1 mycroft #include <sys/param.h>
80 1.1 mycroft #include <sys/systm.h>
81 1.1 mycroft #include <sys/namei.h>
82 1.1 mycroft #include <sys/kernel.h>
83 1.1 mycroft #include <sys/resourcevar.h>
84 1.1 mycroft #include <sys/file.h>
85 1.1 mycroft #include <sys/stat.h>
86 1.1 mycroft #include <sys/buf.h>
87 1.1 mycroft #include <sys/proc.h>
88 1.1 mycroft #include <sys/conf.h>
89 1.1 mycroft #include <sys/vnode.h>
90 1.1 mycroft #include <sys/malloc.h>
91 1.1 mycroft #include <sys/mount.h>
92 1.1 mycroft
93 1.1 mycroft #include <miscfs/specfs/specdev.h>
94 1.1 mycroft #include <miscfs/fifofs/fifo.h>
95 1.1 mycroft
96 1.1 mycroft #include <ufs/ufs/quota.h>
97 1.1 mycroft #include <ufs/ufs/inode.h>
98 1.1 mycroft #include <ufs/ufs/dir.h>
99 1.1 mycroft #include <ufs/ufs/ufsmount.h>
100 1.1 mycroft #include <ufs/ufs/ufs_extern.h>
101 1.1 mycroft
102 1.1 mycroft #include <ufs/lfs/lfs.h>
103 1.1 mycroft #include <ufs/lfs/lfs_extern.h>
104 1.1 mycroft
105 1.69 perseant extern int count_lock_queue(void);
106 1.10 fvdl extern struct simplelock vnode_free_list_slock; /* XXX */
107 1.1 mycroft
108 1.1 mycroft /*
109 1.1 mycroft * Determine if it's OK to start a partial in this segment, or if we need
110 1.1 mycroft * to go on to a new segment.
111 1.1 mycroft */
112 1.1 mycroft #define LFS_PARTIAL_FITS(fs) \
113 1.69 perseant ((fs)->lfs_fsbpseg - ((fs)->lfs_offset - (fs)->lfs_curseg) > \
114 1.69 perseant fragstofsb((fs), (fs)->lfs_frag))
115 1.1 mycroft
116 1.69 perseant void lfs_callback(struct buf *);
117 1.69 perseant int lfs_gather(struct lfs *, struct segment *,
118 1.69 perseant struct vnode *, int (*)(struct lfs *, struct buf *));
119 1.69 perseant int lfs_gatherblock(struct segment *, struct buf *, int *);
120 1.69 perseant void lfs_iset(struct inode *, ufs_daddr_t, time_t);
121 1.69 perseant int lfs_match_fake(struct lfs *, struct buf *);
122 1.69 perseant int lfs_match_data(struct lfs *, struct buf *);
123 1.69 perseant int lfs_match_dindir(struct lfs *, struct buf *);
124 1.69 perseant int lfs_match_indir(struct lfs *, struct buf *);
125 1.69 perseant int lfs_match_tindir(struct lfs *, struct buf *);
126 1.69 perseant void lfs_newseg(struct lfs *);
127 1.69 perseant void lfs_shellsort(struct buf **, ufs_daddr_t *, int);
128 1.69 perseant void lfs_supercallback(struct buf *);
129 1.69 perseant void lfs_updatemeta(struct segment *);
130 1.69 perseant int lfs_vref(struct vnode *);
131 1.69 perseant void lfs_vunref(struct vnode *);
132 1.69 perseant void lfs_writefile(struct lfs *, struct segment *, struct vnode *);
133 1.69 perseant int lfs_writeinode(struct lfs *, struct segment *, struct inode *);
134 1.69 perseant int lfs_writeseg(struct lfs *, struct segment *);
135 1.69 perseant void lfs_writesuper(struct lfs *, daddr_t);
136 1.69 perseant int lfs_writevnodes(struct lfs *fs, struct mount *mp,
137 1.69 perseant struct segment *sp, int dirops);
138 1.1 mycroft
139 1.1 mycroft int lfs_allclean_wakeup; /* Cleaner wakeup address. */
140 1.15 perseant int lfs_writeindir = 1; /* whether to flush indir on non-ckp */
141 1.25 perseant int lfs_clean_vnhead = 0; /* Allow freeing to head of vn list */
142 1.32 perseant int lfs_dirvcount = 0; /* # active dirops */
143 1.1 mycroft
144 1.1 mycroft /* Statistics Counters */
145 1.15 perseant int lfs_dostats = 1;
146 1.1 mycroft struct lfs_stats lfs_stats;
147 1.1 mycroft
148 1.62 perseant extern int locked_queue_count;
149 1.62 perseant extern long locked_queue_bytes;
150 1.62 perseant
151 1.1 mycroft /* op values to lfs_writevnodes */
152 1.15 perseant #define VN_REG 0
153 1.1 mycroft #define VN_DIROP 1
154 1.1 mycroft #define VN_EMPTY 2
155 1.15 perseant #define VN_CLEAN 3
156 1.15 perseant
157 1.15 perseant #define LFS_MAX_ACTIVE 10
158 1.15 perseant
159 1.15 perseant /*
160 1.15 perseant * XXX KS - Set modification time on the Ifile, so the cleaner can
161 1.15 perseant * read the fs mod time off of it. We don't set IN_UPDATE here,
162 1.15 perseant * since we don't really need this to be flushed to disk (and in any
163 1.15 perseant * case that wouldn't happen to the Ifile until we checkpoint).
164 1.15 perseant */
165 1.15 perseant void
166 1.69 perseant lfs_imtime(struct lfs *fs)
167 1.15 perseant {
168 1.15 perseant struct timespec ts;
169 1.15 perseant struct inode *ip;
170 1.15 perseant
171 1.15 perseant TIMEVAL_TO_TIMESPEC(&time, &ts);
172 1.15 perseant ip = VTOI(fs->lfs_ivnode);
173 1.15 perseant ip->i_ffs_mtime = ts.tv_sec;
174 1.15 perseant ip->i_ffs_mtimensec = ts.tv_nsec;
175 1.15 perseant }
176 1.1 mycroft
177 1.1 mycroft /*
178 1.1 mycroft * Ifile and meta data blocks are not marked busy, so segment writes MUST be
179 1.1 mycroft * single threaded. Currently, there are two paths into lfs_segwrite, sync()
180 1.1 mycroft * and getnewbuf(). They both mark the file system busy. Lfs_vflush()
181 1.1 mycroft * explicitly marks the file system busy. So lfs_segwrite is safe. I think.
182 1.1 mycroft */
183 1.1 mycroft
184 1.15 perseant #define SET_FLUSHING(fs,vp) (fs)->lfs_flushvp = (vp)
185 1.15 perseant #define IS_FLUSHING(fs,vp) ((fs)->lfs_flushvp == (vp))
186 1.15 perseant #define CLR_FLUSHING(fs,vp) (fs)->lfs_flushvp = NULL
187 1.15 perseant
188 1.1 mycroft int
189 1.69 perseant lfs_vflush(struct vnode *vp)
190 1.1 mycroft {
191 1.1 mycroft struct inode *ip;
192 1.1 mycroft struct lfs *fs;
193 1.1 mycroft struct segment *sp;
194 1.38 perseant struct buf *bp, *nbp, *tbp, *tnbp;
195 1.30 perseant int error, s;
196 1.19 perseant
197 1.22 perseant ip = VTOI(vp);
198 1.22 perseant fs = VFSTOUFS(vp->v_mount)->um_lfs;
199 1.22 perseant
200 1.19 perseant if(ip->i_flag & IN_CLEANING) {
201 1.19 perseant #ifdef DEBUG_LFS
202 1.19 perseant ivndebug(vp,"vflush/in_cleaning");
203 1.19 perseant #endif
204 1.56 perseant LFS_CLR_UINO(ip, IN_CLEANING);
205 1.56 perseant LFS_SET_UINO(ip, IN_MODIFIED);
206 1.56 perseant
207 1.38 perseant /*
208 1.38 perseant * Toss any cleaning buffers that have real counterparts
209 1.38 perseant * to avoid losing new data
210 1.38 perseant */
211 1.38 perseant s = splbio();
212 1.38 perseant for(bp=vp->v_dirtyblkhd.lh_first; bp; bp=nbp) {
213 1.38 perseant nbp = bp->b_vnbufs.le_next;
214 1.38 perseant if(bp->b_flags & B_CALL) {
215 1.38 perseant for(tbp=vp->v_dirtyblkhd.lh_first; tbp;
216 1.38 perseant tbp=tnbp)
217 1.38 perseant {
218 1.38 perseant tnbp = tbp->b_vnbufs.le_next;
219 1.38 perseant if(tbp->b_vp == bp->b_vp
220 1.38 perseant && tbp->b_lblkno == bp->b_lblkno
221 1.38 perseant && tbp != bp)
222 1.38 perseant {
223 1.69 perseant fs->lfs_avail += btofsb(fs, bp->b_bcount);
224 1.62 perseant wakeup(&fs->lfs_avail);
225 1.38 perseant lfs_freebuf(bp);
226 1.69 perseant bp = NULL;
227 1.69 perseant break;
228 1.38 perseant }
229 1.38 perseant }
230 1.38 perseant }
231 1.38 perseant }
232 1.38 perseant splx(s);
233 1.19 perseant }
234 1.19 perseant
235 1.19 perseant /* If the node is being written, wait until that is done */
236 1.19 perseant if(WRITEINPROG(vp)) {
237 1.19 perseant #ifdef DEBUG_LFS
238 1.19 perseant ivndebug(vp,"vflush/writeinprog");
239 1.19 perseant #endif
240 1.19 perseant tsleep(vp, PRIBIO+1, "lfs_vw", 0);
241 1.19 perseant }
242 1.1 mycroft
243 1.15 perseant /* Protect against VXLOCK deadlock in vinvalbuf() */
244 1.1 mycroft lfs_seglock(fs, SEGM_SYNC);
245 1.30 perseant
246 1.30 perseant /* If we're supposed to flush a freed inode, just toss it */
247 1.30 perseant /* XXX - seglock, so these buffers can't be gathered, right? */
248 1.30 perseant if(ip->i_ffs_mode == 0) {
249 1.30 perseant printf("lfs_vflush: ino %d is freed, not flushing\n",
250 1.30 perseant ip->i_number);
251 1.30 perseant s = splbio();
252 1.30 perseant for(bp=vp->v_dirtyblkhd.lh_first; bp; bp=nbp) {
253 1.30 perseant nbp = bp->b_vnbufs.le_next;
254 1.62 perseant if (bp->b_flags & B_DELWRI) { /* XXX always true? */
255 1.69 perseant fs->lfs_avail += btofsb(fs, bp->b_bcount);
256 1.62 perseant wakeup(&fs->lfs_avail);
257 1.62 perseant }
258 1.30 perseant /* Copied from lfs_writeseg */
259 1.30 perseant if (bp->b_flags & B_CALL) {
260 1.30 perseant /* if B_CALL, it was created with newbuf */
261 1.30 perseant lfs_freebuf(bp);
262 1.69 perseant bp = NULL;
263 1.30 perseant } else {
264 1.30 perseant bremfree(bp);
265 1.62 perseant LFS_UNLOCK_BUF(bp);
266 1.30 perseant bp->b_flags &= ~(B_ERROR | B_READ | B_DELWRI |
267 1.62 perseant B_GATHERED);
268 1.30 perseant bp->b_flags |= B_DONE;
269 1.30 perseant reassignbuf(bp, vp);
270 1.30 perseant brelse(bp);
271 1.30 perseant }
272 1.30 perseant }
273 1.30 perseant splx(s);
274 1.56 perseant LFS_CLR_UINO(ip, IN_CLEANING);
275 1.56 perseant LFS_CLR_UINO(ip, IN_MODIFIED | IN_ACCESSED);
276 1.47 perseant ip->i_flag &= ~IN_ALLMOD;
277 1.30 perseant printf("lfs_vflush: done not flushing ino %d\n",
278 1.30 perseant ip->i_number);
279 1.30 perseant lfs_segunlock(fs);
280 1.30 perseant return 0;
281 1.30 perseant }
282 1.30 perseant
283 1.15 perseant SET_FLUSHING(fs,vp);
284 1.15 perseant if (fs->lfs_nactive > LFS_MAX_ACTIVE) {
285 1.15 perseant error = lfs_segwrite(vp->v_mount, SEGM_SYNC|SEGM_CKP);
286 1.15 perseant CLR_FLUSHING(fs,vp);
287 1.15 perseant lfs_segunlock(fs);
288 1.15 perseant return error;
289 1.15 perseant }
290 1.1 mycroft sp = fs->lfs_sp;
291 1.1 mycroft
292 1.15 perseant if (vp->v_dirtyblkhd.lh_first == NULL) {
293 1.1 mycroft lfs_writevnodes(fs, vp->v_mount, sp, VN_EMPTY);
294 1.58 perseant } else if((ip->i_flag & IN_CLEANING) &&
295 1.58 perseant (fs->lfs_sp->seg_flags & SEGM_CLEAN)) {
296 1.19 perseant #ifdef DEBUG_LFS
297 1.19 perseant ivndebug(vp,"vflush/clean");
298 1.19 perseant #endif
299 1.19 perseant lfs_writevnodes(fs, vp->v_mount, sp, VN_CLEAN);
300 1.15 perseant }
301 1.15 perseant else if(lfs_dostats) {
302 1.47 perseant if(vp->v_dirtyblkhd.lh_first || (VTOI(vp)->i_flag & IN_ALLMOD))
303 1.15 perseant ++lfs_stats.vflush_invoked;
304 1.15 perseant #ifdef DEBUG_LFS
305 1.19 perseant ivndebug(vp,"vflush");
306 1.15 perseant #endif
307 1.15 perseant }
308 1.15 perseant
309 1.19 perseant #ifdef DIAGNOSTIC
310 1.21 perseant /* XXX KS This actually can happen right now, though it shouldn't(?) */
311 1.19 perseant if(vp->v_flag & VDIROP) {
312 1.21 perseant printf("lfs_vflush: flushing VDIROP, this shouldn\'t be\n");
313 1.21 perseant /* panic("VDIROP being flushed...this can\'t happen"); */
314 1.19 perseant }
315 1.19 perseant if(vp->v_usecount<0) {
316 1.69 perseant printf("usecount=%ld\n", (long)vp->v_usecount);
317 1.19 perseant panic("lfs_vflush: usecount<0");
318 1.19 perseant }
319 1.15 perseant #endif
320 1.1 mycroft
321 1.1 mycroft do {
322 1.1 mycroft do {
323 1.1 mycroft if (vp->v_dirtyblkhd.lh_first != NULL)
324 1.1 mycroft lfs_writefile(fs, sp, vp);
325 1.1 mycroft } while (lfs_writeinode(fs, sp, ip));
326 1.1 mycroft } while (lfs_writeseg(fs, sp) && ip->i_number == LFS_IFILE_INUM);
327 1.15 perseant
328 1.15 perseant if(lfs_dostats) {
329 1.15 perseant ++lfs_stats.nwrites;
330 1.15 perseant if (sp->seg_flags & SEGM_SYNC)
331 1.15 perseant ++lfs_stats.nsync_writes;
332 1.15 perseant if (sp->seg_flags & SEGM_CKP)
333 1.15 perseant ++lfs_stats.ncheckpoints;
334 1.15 perseant }
335 1.15 perseant lfs_segunlock(fs);
336 1.1 mycroft
337 1.15 perseant CLR_FLUSHING(fs,vp);
338 1.1 mycroft return (0);
339 1.1 mycroft }
340 1.1 mycroft
341 1.16 perseant #ifdef DEBUG_LFS_VERBOSE
342 1.16 perseant # define vndebug(vp,str) if(VTOI(vp)->i_flag & IN_CLEANING) printf("not writing ino %d because %s (op %d)\n",VTOI(vp)->i_number,(str),op)
343 1.16 perseant #else
344 1.16 perseant # define vndebug(vp,str)
345 1.16 perseant #endif
346 1.15 perseant
347 1.15 perseant int
348 1.69 perseant lfs_writevnodes(struct lfs *fs, struct mount *mp, struct segment *sp, int op)
349 1.1 mycroft {
350 1.1 mycroft struct inode *ip;
351 1.1 mycroft struct vnode *vp;
352 1.20 perseant int inodes_written=0, only_cleaning;
353 1.43 perseant int needs_unlock;
354 1.1 mycroft
355 1.15 perseant #ifndef LFS_NO_BACKVP_HACK
356 1.15 perseant /* BEGIN HACK */
357 1.11 kleink #define VN_OFFSET (((caddr_t)&vp->v_mntvnodes.le_next) - (caddr_t)vp)
358 1.11 kleink #define BACK_VP(VP) ((struct vnode *)(((caddr_t)VP->v_mntvnodes.le_prev) - VN_OFFSET))
359 1.11 kleink #define BEG_OF_VLIST ((struct vnode *)(((caddr_t)&mp->mnt_vnodelist.lh_first) - VN_OFFSET))
360 1.15 perseant
361 1.15 perseant /* Find last vnode. */
362 1.15 perseant loop: for (vp = mp->mnt_vnodelist.lh_first;
363 1.10 fvdl vp && vp->v_mntvnodes.le_next != NULL;
364 1.10 fvdl vp = vp->v_mntvnodes.le_next);
365 1.10 fvdl for (; vp && vp != BEG_OF_VLIST; vp = BACK_VP(vp)) {
366 1.15 perseant #else
367 1.15 perseant loop:
368 1.1 mycroft for (vp = mp->mnt_vnodelist.lh_first;
369 1.1 mycroft vp != NULL;
370 1.1 mycroft vp = vp->v_mntvnodes.le_next) {
371 1.15 perseant #endif
372 1.1 mycroft /*
373 1.1 mycroft * If the vnode that we are about to sync is no longer
374 1.1 mycroft * associated with this mount point, start over.
375 1.1 mycroft */
376 1.58 perseant if (vp->v_mount != mp) {
377 1.58 perseant printf("lfs_writevnodes: starting over\n");
378 1.1 mycroft goto loop;
379 1.58 perseant }
380 1.1 mycroft
381 1.15 perseant ip = VTOI(vp);
382 1.15 perseant if ((op == VN_DIROP && !(vp->v_flag & VDIROP)) ||
383 1.15 perseant (op != VN_DIROP && op != VN_CLEAN && (vp->v_flag & VDIROP))) {
384 1.15 perseant vndebug(vp,"dirop");
385 1.15 perseant continue;
386 1.15 perseant }
387 1.15 perseant
388 1.15 perseant if (op == VN_EMPTY && vp->v_dirtyblkhd.lh_first) {
389 1.15 perseant vndebug(vp,"empty");
390 1.1 mycroft continue;
391 1.15 perseant }
392 1.15 perseant
393 1.15 perseant if (vp->v_type == VNON) {
394 1.15 perseant continue;
395 1.15 perseant }
396 1.1 mycroft
397 1.15 perseant if(op == VN_CLEAN && ip->i_number != LFS_IFILE_INUM
398 1.38 perseant && vp != fs->lfs_flushvp
399 1.15 perseant && !(ip->i_flag & IN_CLEANING)) {
400 1.15 perseant vndebug(vp,"cleaning");
401 1.1 mycroft continue;
402 1.15 perseant }
403 1.1 mycroft
404 1.15 perseant if (lfs_vref(vp)) {
405 1.15 perseant vndebug(vp,"vref");
406 1.1 mycroft continue;
407 1.15 perseant }
408 1.1 mycroft
409 1.43 perseant needs_unlock = 0;
410 1.52 perseant if (VOP_ISLOCKED(vp)) {
411 1.43 perseant if (vp != fs->lfs_ivnode &&
412 1.43 perseant vp->v_lock.lk_lockholder != curproc->p_pid) {
413 1.43 perseant #ifdef DEBUG_LFS
414 1.58 perseant printf("lfs_writevnodes: not writing ino %d,"
415 1.58 perseant " locked by pid %d\n",
416 1.58 perseant VTOI(vp)->i_number,
417 1.58 perseant vp->v_lock.lk_lockholder);
418 1.43 perseant #endif
419 1.44 perseant lfs_vunref(vp);
420 1.43 perseant continue;
421 1.43 perseant }
422 1.46 perseant } else if (vp != fs->lfs_ivnode) {
423 1.43 perseant vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
424 1.43 perseant needs_unlock = 1;
425 1.43 perseant }
426 1.43 perseant
427 1.23 perseant only_cleaning = 0;
428 1.1 mycroft /*
429 1.55 perseant * Write the inode/file if dirty and it's not the IFILE.
430 1.1 mycroft */
431 1.47 perseant if ((ip->i_flag & IN_ALLMOD) ||
432 1.48 fredb (vp->v_dirtyblkhd.lh_first != NULL))
433 1.15 perseant {
434 1.47 perseant only_cleaning = ((ip->i_flag & IN_ALLMOD)==IN_CLEANING);
435 1.20 perseant
436 1.15 perseant if(ip->i_number != LFS_IFILE_INUM
437 1.15 perseant && vp->v_dirtyblkhd.lh_first != NULL)
438 1.15 perseant {
439 1.1 mycroft lfs_writefile(fs, sp, vp);
440 1.15 perseant }
441 1.15 perseant if(vp->v_dirtyblkhd.lh_first != NULL) {
442 1.15 perseant if(WRITEINPROG(vp)) {
443 1.15 perseant #ifdef DEBUG_LFS
444 1.16 perseant ivndebug(vp,"writevnodes/write2");
445 1.15 perseant #endif
446 1.47 perseant } else if(!(ip->i_flag & IN_ALLMOD)) {
447 1.15 perseant #ifdef DEBUG_LFS
448 1.15 perseant printf("<%d>",ip->i_number);
449 1.15 perseant #endif
450 1.56 perseant LFS_SET_UINO(ip, IN_MODIFIED);
451 1.15 perseant }
452 1.15 perseant }
453 1.1 mycroft (void) lfs_writeinode(fs, sp, ip);
454 1.15 perseant inodes_written++;
455 1.15 perseant }
456 1.15 perseant
457 1.52 perseant if (needs_unlock)
458 1.52 perseant VOP_UNLOCK(vp, 0);
459 1.43 perseant
460 1.52 perseant if (lfs_clean_vnhead && only_cleaning)
461 1.20 perseant lfs_vunref_head(vp);
462 1.20 perseant else
463 1.20 perseant lfs_vunref(vp);
464 1.1 mycroft }
465 1.15 perseant return inodes_written;
466 1.1 mycroft }
467 1.1 mycroft
468 1.69 perseant /*
469 1.69 perseant * Do a checkpoint.
470 1.69 perseant */
471 1.1 mycroft int
472 1.69 perseant lfs_segwrite(struct mount *mp, int flags)
473 1.1 mycroft {
474 1.1 mycroft struct buf *bp;
475 1.1 mycroft struct inode *ip;
476 1.1 mycroft struct lfs *fs;
477 1.1 mycroft struct segment *sp;
478 1.1 mycroft struct vnode *vp;
479 1.1 mycroft SEGUSE *segusep;
480 1.10 fvdl ufs_daddr_t ibno;
481 1.61 perseant int do_ckp, did_ckp, error, i;
482 1.15 perseant int writer_set = 0;
483 1.61 perseant int dirty;
484 1.15 perseant
485 1.1 mycroft fs = VFSTOUFS(mp)->um_lfs;
486 1.1 mycroft
487 1.53 perseant if (fs->lfs_ronly)
488 1.53 perseant return EROFS;
489 1.53 perseant
490 1.15 perseant lfs_imtime(fs);
491 1.58 perseant
492 1.61 perseant /* printf("lfs_segwrite: ifile flags are 0x%lx\n",
493 1.61 perseant (long)(VTOI(fs->lfs_ivnode)->i_flag)); */
494 1.61 perseant
495 1.58 perseant #if 0
496 1.15 perseant /*
497 1.58 perseant * If we are not the cleaner, and there is no space available,
498 1.58 perseant * wait until cleaner writes.
499 1.15 perseant */
500 1.61 perseant if(!(flags & SEGM_CLEAN) && !(fs->lfs_seglock && fs->lfs_sp &&
501 1.61 perseant (fs->lfs_sp->seg_flags & SEGM_CLEAN)))
502 1.15 perseant {
503 1.58 perseant while (fs->lfs_avail <= 0) {
504 1.61 perseant LFS_CLEANERINFO(cip, fs, bp);
505 1.61 perseant LFS_SYNC_CLEANERINFO(cip, fs, bp, 0);
506 1.61 perseant
507 1.58 perseant wakeup(&lfs_allclean_wakeup);
508 1.58 perseant wakeup(&fs->lfs_nextseg);
509 1.58 perseant error = tsleep(&fs->lfs_avail, PRIBIO + 1, "lfs_av2",
510 1.58 perseant 0);
511 1.58 perseant if (error) {
512 1.58 perseant return (error);
513 1.15 perseant }
514 1.58 perseant }
515 1.15 perseant }
516 1.58 perseant #endif
517 1.1 mycroft /*
518 1.1 mycroft * Allocate a segment structure and enough space to hold pointers to
519 1.1 mycroft * the maximum possible number of buffers which can be described in a
520 1.1 mycroft * single summary block.
521 1.1 mycroft */
522 1.15 perseant do_ckp = (flags & SEGM_CKP) || fs->lfs_nactive > LFS_MAX_ACTIVE;
523 1.1 mycroft lfs_seglock(fs, flags | (do_ckp ? SEGM_CKP : 0));
524 1.1 mycroft sp = fs->lfs_sp;
525 1.1 mycroft
526 1.15 perseant /*
527 1.16 perseant * If lfs_flushvp is non-NULL, we are called from lfs_vflush,
528 1.16 perseant * in which case we have to flush *all* buffers off of this vnode.
529 1.37 perseant * We don't care about other nodes, but write any non-dirop nodes
530 1.37 perseant * anyway in anticipation of another getnewvnode().
531 1.37 perseant *
532 1.37 perseant * If we're cleaning we only write cleaning and ifile blocks, and
533 1.37 perseant * no dirops, since otherwise we'd risk corruption in a crash.
534 1.15 perseant */
535 1.38 perseant if(sp->seg_flags & SEGM_CLEAN)
536 1.15 perseant lfs_writevnodes(fs, mp, sp, VN_CLEAN);
537 1.15 perseant else {
538 1.15 perseant lfs_writevnodes(fs, mp, sp, VN_REG);
539 1.38 perseant if(!fs->lfs_dirops || !fs->lfs_flushvp) {
540 1.38 perseant while(fs->lfs_dirops)
541 1.38 perseant if((error = tsleep(&fs->lfs_writer, PRIBIO + 1,
542 1.38 perseant "lfs writer", 0)))
543 1.38 perseant {
544 1.69 perseant /* XXX why not segunlock? */
545 1.38 perseant free(sp->bpp, M_SEGMENT);
546 1.69 perseant sp->bpp = NULL;
547 1.38 perseant free(sp, M_SEGMENT);
548 1.69 perseant fs->lfs_sp = NULL;
549 1.38 perseant return (error);
550 1.38 perseant }
551 1.38 perseant fs->lfs_writer++;
552 1.38 perseant writer_set=1;
553 1.38 perseant lfs_writevnodes(fs, mp, sp, VN_DIROP);
554 1.38 perseant ((SEGSUM *)(sp->segsum))->ss_flags &= ~(SS_CONT);
555 1.38 perseant }
556 1.15 perseant }
557 1.1 mycroft
558 1.1 mycroft /*
559 1.1 mycroft * If we are doing a checkpoint, mark everything since the
560 1.1 mycroft * last checkpoint as no longer ACTIVE.
561 1.1 mycroft */
562 1.15 perseant if (do_ckp) {
563 1.1 mycroft for (ibno = fs->lfs_cleansz + fs->lfs_segtabsz;
564 1.1 mycroft --ibno >= fs->lfs_cleansz; ) {
565 1.61 perseant dirty = 0;
566 1.15 perseant if (bread(fs->lfs_ivnode, ibno, fs->lfs_bsize, NOCRED, &bp))
567 1.1 mycroft
568 1.15 perseant panic("lfs_segwrite: ifile read");
569 1.1 mycroft segusep = (SEGUSE *)bp->b_data;
570 1.69 perseant for (i = fs->lfs_sepb; i--;) {
571 1.61 perseant if (segusep->su_flags & SEGUSE_ACTIVE) {
572 1.61 perseant segusep->su_flags &= ~SEGUSE_ACTIVE;
573 1.61 perseant ++dirty;
574 1.61 perseant }
575 1.69 perseant if (fs->lfs_version > 1)
576 1.69 perseant ++segusep;
577 1.69 perseant else
578 1.69 perseant segusep = (SEGUSE *)
579 1.69 perseant ((SEGUSE_V1 *)segusep + 1);
580 1.61 perseant }
581 1.1 mycroft
582 1.15 perseant /* But the current segment is still ACTIVE */
583 1.51 perseant segusep = (SEGUSE *)bp->b_data;
584 1.69 perseant if (dtosn(fs, fs->lfs_curseg) / fs->lfs_sepb ==
585 1.61 perseant (ibno-fs->lfs_cleansz)) {
586 1.69 perseant if (fs->lfs_version > 1)
587 1.69 perseant segusep[dtosn(fs, fs->lfs_curseg) %
588 1.69 perseant fs->lfs_sepb].su_flags |=
589 1.69 perseant SEGUSE_ACTIVE;
590 1.69 perseant else
591 1.69 perseant ((SEGUSE *)
592 1.69 perseant ((SEGUSE_V1 *)(bp->b_data) +
593 1.69 perseant (dtosn(fs, fs->lfs_curseg) %
594 1.69 perseant fs->lfs_sepb)))->su_flags
595 1.69 perseant |= SEGUSE_ACTIVE;
596 1.61 perseant --dirty;
597 1.61 perseant }
598 1.61 perseant if (dirty)
599 1.61 perseant error = VOP_BWRITE(bp); /* Ifile */
600 1.61 perseant else
601 1.61 perseant brelse(bp);
602 1.1 mycroft }
603 1.15 perseant }
604 1.61 perseant
605 1.61 perseant did_ckp = 0;
606 1.1 mycroft if (do_ckp || fs->lfs_doifile) {
607 1.63 perseant do {
608 1.63 perseant vp = fs->lfs_ivnode;
609 1.55 perseant
610 1.63 perseant vget(vp, LK_EXCLUSIVE | LK_CANRECURSE | LK_RETRY);
611 1.55 perseant
612 1.63 perseant ip = VTOI(vp);
613 1.63 perseant if (vp->v_dirtyblkhd.lh_first != NULL)
614 1.63 perseant lfs_writefile(fs, sp, vp);
615 1.63 perseant if (ip->i_flag & IN_ALLMOD)
616 1.63 perseant ++did_ckp;
617 1.63 perseant (void) lfs_writeinode(fs, sp, ip);
618 1.63 perseant
619 1.63 perseant vput(vp);
620 1.63 perseant } while (lfs_writeseg(fs, sp) && do_ckp);
621 1.15 perseant
622 1.61 perseant /* The ifile should now be all clear */
623 1.61 perseant LFS_CLR_UINO(ip, IN_ALLMOD);
624 1.15 perseant } else {
625 1.1 mycroft (void) lfs_writeseg(fs, sp);
626 1.15 perseant }
627 1.15 perseant
628 1.1 mycroft /*
629 1.15 perseant * If the I/O count is non-zero, sleep until it reaches zero.
630 1.15 perseant * At the moment, the user's process hangs around so we can
631 1.15 perseant * sleep.
632 1.1 mycroft */
633 1.1 mycroft fs->lfs_doifile = 0;
634 1.15 perseant if(writer_set && --fs->lfs_writer==0)
635 1.15 perseant wakeup(&fs->lfs_dirops);
636 1.61 perseant
637 1.61 perseant /*
638 1.61 perseant * If we didn't write the Ifile, we didn't really do anything.
639 1.61 perseant * That means that (1) there is a checkpoint on disk and (2)
640 1.61 perseant * nothing has changed since it was written.
641 1.61 perseant *
642 1.61 perseant * Take the flags off of the segment so that lfs_segunlock
643 1.61 perseant * doesn't have to write the superblock either.
644 1.61 perseant */
645 1.61 perseant if (did_ckp == 0) {
646 1.61 perseant sp->seg_flags &= ~(SEGM_SYNC|SEGM_CKP);
647 1.61 perseant /* if(do_ckp) printf("lfs_segwrite: no checkpoint\n"); */
648 1.61 perseant }
649 1.61 perseant
650 1.15 perseant if(lfs_dostats) {
651 1.15 perseant ++lfs_stats.nwrites;
652 1.15 perseant if (sp->seg_flags & SEGM_SYNC)
653 1.15 perseant ++lfs_stats.nsync_writes;
654 1.15 perseant if (sp->seg_flags & SEGM_CKP)
655 1.15 perseant ++lfs_stats.ncheckpoints;
656 1.15 perseant }
657 1.1 mycroft lfs_segunlock(fs);
658 1.1 mycroft return (0);
659 1.1 mycroft }
660 1.1 mycroft
661 1.1 mycroft /*
662 1.1 mycroft * Write the dirty blocks associated with a vnode.
663 1.1 mycroft */
664 1.1 mycroft void
665 1.69 perseant lfs_writefile(struct lfs *fs, struct segment *sp, struct vnode *vp)
666 1.1 mycroft {
667 1.1 mycroft struct buf *bp;
668 1.1 mycroft struct finfo *fip;
669 1.1 mycroft IFILE *ifp;
670 1.15 perseant
671 1.15 perseant
672 1.1 mycroft if (sp->seg_bytes_left < fs->lfs_bsize ||
673 1.1 mycroft sp->sum_bytes_left < sizeof(struct finfo))
674 1.1 mycroft (void) lfs_writeseg(fs, sp);
675 1.15 perseant
676 1.10 fvdl sp->sum_bytes_left -= sizeof(struct finfo) - sizeof(ufs_daddr_t);
677 1.1 mycroft ++((SEGSUM *)(sp->segsum))->ss_nfinfo;
678 1.1 mycroft
679 1.15 perseant if(vp->v_flag & VDIROP)
680 1.15 perseant ((SEGSUM *)(sp->segsum))->ss_flags |= (SS_DIROP|SS_CONT);
681 1.15 perseant
682 1.1 mycroft fip = sp->fip;
683 1.1 mycroft fip->fi_nblocks = 0;
684 1.1 mycroft fip->fi_ino = VTOI(vp)->i_number;
685 1.1 mycroft LFS_IENTRY(ifp, fs, fip->fi_ino, bp);
686 1.1 mycroft fip->fi_version = ifp->if_version;
687 1.1 mycroft brelse(bp);
688 1.15 perseant
689 1.38 perseant if(sp->seg_flags & SEGM_CLEAN)
690 1.38 perseant {
691 1.38 perseant lfs_gather(fs, sp, vp, lfs_match_fake);
692 1.38 perseant /*
693 1.38 perseant * For a file being flushed, we need to write *all* blocks.
694 1.38 perseant * This means writing the cleaning blocks first, and then
695 1.38 perseant * immediately following with any non-cleaning blocks.
696 1.38 perseant * The same is true of the Ifile since checkpoints assume
697 1.38 perseant * that all valid Ifile blocks are written.
698 1.38 perseant */
699 1.38 perseant if(IS_FLUSHING(fs,vp) || VTOI(vp)->i_number == LFS_IFILE_INUM)
700 1.38 perseant lfs_gather(fs, sp, vp, lfs_match_data);
701 1.38 perseant } else
702 1.38 perseant lfs_gather(fs, sp, vp, lfs_match_data);
703 1.38 perseant
704 1.1 mycroft /*
705 1.1 mycroft * It may not be necessary to write the meta-data blocks at this point,
706 1.1 mycroft * as the roll-forward recovery code should be able to reconstruct the
707 1.1 mycroft * list.
708 1.15 perseant *
709 1.15 perseant * We have to write them anyway, though, under two conditions: (1) the
710 1.15 perseant * vnode is being flushed (for reuse by vinvalbuf); or (2) we are
711 1.15 perseant * checkpointing.
712 1.1 mycroft */
713 1.15 perseant if(lfs_writeindir
714 1.15 perseant || IS_FLUSHING(fs,vp)
715 1.15 perseant || (sp->seg_flags & SEGM_CKP))
716 1.15 perseant {
717 1.15 perseant lfs_gather(fs, sp, vp, lfs_match_indir);
718 1.15 perseant lfs_gather(fs, sp, vp, lfs_match_dindir);
719 1.15 perseant lfs_gather(fs, sp, vp, lfs_match_tindir);
720 1.15 perseant }
721 1.1 mycroft fip = sp->fip;
722 1.1 mycroft if (fip->fi_nblocks != 0) {
723 1.15 perseant sp->fip = (FINFO*)((caddr_t)fip + sizeof(struct finfo) +
724 1.15 perseant sizeof(ufs_daddr_t) * (fip->fi_nblocks-1));
725 1.1 mycroft sp->start_lbp = &sp->fip->fi_blocks[0];
726 1.1 mycroft } else {
727 1.15 perseant sp->sum_bytes_left += sizeof(FINFO) - sizeof(ufs_daddr_t);
728 1.1 mycroft --((SEGSUM *)(sp->segsum))->ss_nfinfo;
729 1.1 mycroft }
730 1.1 mycroft }
731 1.1 mycroft
732 1.1 mycroft int
733 1.69 perseant lfs_writeinode(struct lfs *fs, struct segment *sp, struct inode *ip)
734 1.1 mycroft {
735 1.1 mycroft struct buf *bp, *ibp;
736 1.53 perseant struct dinode *cdp;
737 1.1 mycroft IFILE *ifp;
738 1.1 mycroft SEGUSE *sup;
739 1.10 fvdl ufs_daddr_t daddr;
740 1.53 perseant daddr_t *daddrp;
741 1.1 mycroft ino_t ino;
742 1.69 perseant int error, i, ndx, fsb = 0;
743 1.1 mycroft int redo_ifile = 0;
744 1.5 mycroft struct timespec ts;
745 1.69 perseant int gotblk = 0;
746 1.15 perseant
747 1.47 perseant if (!(ip->i_flag & IN_ALLMOD))
748 1.1 mycroft return(0);
749 1.15 perseant
750 1.1 mycroft /* Allocate a new inode block if necessary. */
751 1.27 perseant if ((ip->i_number != LFS_IFILE_INUM || sp->idp==NULL) && sp->ibp == NULL) {
752 1.1 mycroft /* Allocate a new segment if necessary. */
753 1.69 perseant if (sp->seg_bytes_left < fs->lfs_ibsize ||
754 1.10 fvdl sp->sum_bytes_left < sizeof(ufs_daddr_t))
755 1.1 mycroft (void) lfs_writeseg(fs, sp);
756 1.1 mycroft
757 1.1 mycroft /* Get next inode block. */
758 1.1 mycroft daddr = fs->lfs_offset;
759 1.69 perseant fs->lfs_offset += btofsb(fs, fs->lfs_ibsize);
760 1.1 mycroft sp->ibp = *sp->cbpp++ =
761 1.69 perseant getblk(VTOI(fs->lfs_ivnode)->i_devvp, fsbtodb(fs, daddr),
762 1.69 perseant fs->lfs_ibsize, 0, 0);
763 1.24 perseant gotblk++;
764 1.24 perseant
765 1.1 mycroft /* Zero out inode numbers */
766 1.1 mycroft for (i = 0; i < INOPB(fs); ++i)
767 1.1 mycroft ((struct dinode *)sp->ibp->b_data)[i].di_inumber = 0;
768 1.15 perseant
769 1.1 mycroft ++sp->start_bpp;
770 1.69 perseant fs->lfs_avail -= btofsb(fs, fs->lfs_ibsize);
771 1.1 mycroft /* Set remaining space counters. */
772 1.69 perseant sp->seg_bytes_left -= fs->lfs_ibsize;
773 1.10 fvdl sp->sum_bytes_left -= sizeof(ufs_daddr_t);
774 1.69 perseant ndx = fs->lfs_sumsize / sizeof(ufs_daddr_t) -
775 1.15 perseant sp->ninodes / INOPB(fs) - 1;
776 1.10 fvdl ((ufs_daddr_t *)(sp->segsum))[ndx] = daddr;
777 1.1 mycroft }
778 1.27 perseant
779 1.1 mycroft /* Update the inode times and copy the inode onto the inode page. */
780 1.9 pk TIMEVAL_TO_TIMESPEC(&time, &ts);
781 1.15 perseant LFS_ITIMES(ip, &ts, &ts, &ts);
782 1.16 perseant
783 1.27 perseant /*
784 1.27 perseant * If this is the Ifile, and we've already written the Ifile in this
785 1.27 perseant * partial segment, just overwrite it (it's not on disk yet) and
786 1.27 perseant * continue.
787 1.27 perseant *
788 1.27 perseant * XXX we know that the bp that we get the second time around has
789 1.27 perseant * already been gathered.
790 1.27 perseant */
791 1.27 perseant if(ip->i_number == LFS_IFILE_INUM && sp->idp) {
792 1.27 perseant *(sp->idp) = ip->i_din.ffs_din;
793 1.27 perseant return 0;
794 1.27 perseant }
795 1.27 perseant
796 1.1 mycroft bp = sp->ibp;
797 1.53 perseant cdp = ((struct dinode *)bp->b_data) + (sp->ninodes % INOPB(fs));
798 1.53 perseant *cdp = ip->i_din.ffs_din;
799 1.69 perseant #ifdef LFS_IFILE_FRAG_ADDRESSING
800 1.69 perseant if (fs->lfs_version > 1)
801 1.69 perseant fsb = (sp->ninodes % INOPB(fs)) / INOPF(fs);
802 1.69 perseant #endif
803 1.53 perseant
804 1.53 perseant /*
805 1.53 perseant * If we are cleaning, ensure that we don't write UNWRITTEN disk
806 1.53 perseant * addresses to disk.
807 1.53 perseant */
808 1.53 perseant if (ip->i_lfs_effnblks != ip->i_ffs_blocks) {
809 1.55 perseant #ifdef DEBUG_LFS
810 1.53 perseant printf("lfs_writeinode: cleansing ino %d (%d != %d)\n",
811 1.53 perseant ip->i_number, ip->i_lfs_effnblks, ip->i_ffs_blocks);
812 1.55 perseant #endif
813 1.53 perseant for (daddrp = cdp->di_db; daddrp < cdp->di_ib + NIADDR;
814 1.53 perseant daddrp++) {
815 1.53 perseant if (*daddrp == UNWRITTEN) {
816 1.54 perseant #ifdef DEBUG_LFS
817 1.53 perseant printf("lfs_writeinode: wiping UNWRITTEN\n");
818 1.53 perseant #endif
819 1.53 perseant *daddrp = 0;
820 1.53 perseant }
821 1.53 perseant }
822 1.53 perseant }
823 1.27 perseant
824 1.55 perseant if(ip->i_flag & IN_CLEANING)
825 1.56 perseant LFS_CLR_UINO(ip, IN_CLEANING);
826 1.55 perseant else {
827 1.56 perseant /* XXX IN_ALLMOD */
828 1.56 perseant LFS_CLR_UINO(ip, IN_ACCESSED | IN_ACCESS | IN_CHANGE |
829 1.56 perseant IN_UPDATE);
830 1.56 perseant if (ip->i_lfs_effnblks == ip->i_ffs_blocks)
831 1.56 perseant LFS_CLR_UINO(ip, IN_MODIFIED);
832 1.63 perseant #ifdef DEBUG_LFS
833 1.63 perseant else
834 1.63 perseant printf("lfs_writeinode: ino %d: real blks=%d, "
835 1.63 perseant "eff=%d\n", ip->i_number, ip->i_ffs_blocks,
836 1.63 perseant ip->i_lfs_effnblks);
837 1.63 perseant #endif
838 1.55 perseant }
839 1.55 perseant
840 1.27 perseant if(ip->i_number == LFS_IFILE_INUM) /* We know sp->idp == NULL */
841 1.53 perseant sp->idp = ((struct dinode *)bp->b_data) +
842 1.53 perseant (sp->ninodes % INOPB(fs));
843 1.24 perseant if(gotblk) {
844 1.62 perseant LFS_LOCK_BUF(bp);
845 1.24 perseant brelse(bp);
846 1.24 perseant }
847 1.15 perseant
848 1.1 mycroft /* Increment inode count in segment summary block. */
849 1.1 mycroft ++((SEGSUM *)(sp->segsum))->ss_ninos;
850 1.15 perseant
851 1.1 mycroft /* If this page is full, set flag to allocate a new page. */
852 1.1 mycroft if (++sp->ninodes % INOPB(fs) == 0)
853 1.1 mycroft sp->ibp = NULL;
854 1.15 perseant
855 1.1 mycroft /*
856 1.1 mycroft * If updating the ifile, update the super-block. Update the disk
857 1.1 mycroft * address and access times for this inode in the ifile.
858 1.1 mycroft */
859 1.1 mycroft ino = ip->i_number;
860 1.1 mycroft if (ino == LFS_IFILE_INUM) {
861 1.1 mycroft daddr = fs->lfs_idaddr;
862 1.69 perseant fs->lfs_idaddr = dbtofsb(fs, bp->b_blkno);
863 1.1 mycroft } else {
864 1.1 mycroft LFS_IENTRY(ifp, fs, ino, ibp);
865 1.1 mycroft daddr = ifp->if_daddr;
866 1.69 perseant ifp->if_daddr = dbtofsb(fs, bp->b_blkno) + fsb;
867 1.30 perseant #ifdef LFS_DEBUG_NEXTFREE
868 1.30 perseant if(ino > 3 && ifp->if_nextfree) {
869 1.30 perseant vprint("lfs_writeinode",ITOV(ip));
870 1.30 perseant printf("lfs_writeinode: updating free ino %d\n",
871 1.30 perseant ip->i_number);
872 1.30 perseant }
873 1.30 perseant #endif
874 1.58 perseant error = VOP_BWRITE(ibp); /* Ifile */
875 1.1 mycroft }
876 1.15 perseant
877 1.1 mycroft /*
878 1.60 toshii * Account the inode: it no longer belongs to its former segment,
879 1.60 toshii * though it will not belong to the new segment until that segment
880 1.60 toshii * is actually written.
881 1.1 mycroft */
882 1.58 perseant #ifdef DEBUG
883 1.60 toshii /*
884 1.60 toshii * The inode's last address should not be in the current partial
885 1.60 toshii * segment, except under exceptional circumstances (lfs_writevnodes
886 1.60 toshii * had to start over, and in the meantime more blocks were written
887 1.60 toshii * to a vnode). Although the previous inode won't be accounted in
888 1.60 toshii * su_nbytes until lfs_writeseg, this shouldn't be a problem as we
889 1.60 toshii * have more data blocks in the current partial segment.
890 1.60 toshii */
891 1.69 perseant if (daddr >= fs->lfs_lastpseg && daddr <= dbtofsb(fs, bp->b_blkno))
892 1.49 perseant printf("lfs_writeinode: last inode addr in current pseg "
893 1.53 perseant "(ino %d daddr 0x%x)\n", ino, daddr);
894 1.58 perseant #endif
895 1.49 perseant if (daddr != LFS_UNUSED_DADDR) {
896 1.69 perseant LFS_SEGENTRY(sup, fs, dtosn(fs, daddr), bp);
897 1.1 mycroft #ifdef DIAGNOSTIC
898 1.13 thorpej if (sup->su_nbytes < DINODE_SIZE) {
899 1.53 perseant printf("lfs_writeinode: negative bytes "
900 1.53 perseant "(segment %d short by %d)\n",
901 1.69 perseant dtosn(fs, daddr),
902 1.53 perseant (int)DINODE_SIZE - sup->su_nbytes);
903 1.27 perseant panic("lfs_writeinode: negative bytes");
904 1.27 perseant sup->su_nbytes = DINODE_SIZE;
905 1.1 mycroft }
906 1.1 mycroft #endif
907 1.69 perseant #ifdef DEBUG_SU_NBYTES
908 1.69 perseant printf("seg %d -= %d for ino %d inode\n",
909 1.69 perseant dtosn(fs, daddr), DINODE_SIZE, ino);
910 1.69 perseant #endif
911 1.13 thorpej sup->su_nbytes -= DINODE_SIZE;
912 1.1 mycroft redo_ifile =
913 1.15 perseant (ino == LFS_IFILE_INUM && !(bp->b_flags & B_GATHERED));
914 1.58 perseant error = VOP_BWRITE(bp); /* Ifile */
915 1.1 mycroft }
916 1.1 mycroft return (redo_ifile);
917 1.1 mycroft }
918 1.1 mycroft
919 1.1 mycroft int
920 1.69 perseant lfs_gatherblock(struct segment *sp, struct buf *bp, int *sptr)
921 1.1 mycroft {
922 1.1 mycroft struct lfs *fs;
923 1.1 mycroft int version;
924 1.15 perseant
925 1.1 mycroft /*
926 1.1 mycroft * If full, finish this segment. We may be doing I/O, so
927 1.1 mycroft * release and reacquire the splbio().
928 1.1 mycroft */
929 1.1 mycroft #ifdef DIAGNOSTIC
930 1.1 mycroft if (sp->vp == NULL)
931 1.1 mycroft panic ("lfs_gatherblock: Null vp in segment");
932 1.1 mycroft #endif
933 1.1 mycroft fs = sp->fs;
934 1.10 fvdl if (sp->sum_bytes_left < sizeof(ufs_daddr_t) ||
935 1.10 fvdl sp->seg_bytes_left < bp->b_bcount) {
936 1.1 mycroft if (sptr)
937 1.1 mycroft splx(*sptr);
938 1.1 mycroft lfs_updatemeta(sp);
939 1.15 perseant
940 1.1 mycroft version = sp->fip->fi_version;
941 1.1 mycroft (void) lfs_writeseg(fs, sp);
942 1.15 perseant
943 1.1 mycroft sp->fip->fi_version = version;
944 1.1 mycroft sp->fip->fi_ino = VTOI(sp->vp)->i_number;
945 1.1 mycroft /* Add the current file to the segment summary. */
946 1.1 mycroft ++((SEGSUM *)(sp->segsum))->ss_nfinfo;
947 1.1 mycroft sp->sum_bytes_left -=
948 1.15 perseant sizeof(struct finfo) - sizeof(ufs_daddr_t);
949 1.15 perseant
950 1.1 mycroft if (sptr)
951 1.1 mycroft *sptr = splbio();
952 1.1 mycroft return(1);
953 1.1 mycroft }
954 1.15 perseant
955 1.15 perseant #ifdef DEBUG
956 1.15 perseant if(bp->b_flags & B_GATHERED) {
957 1.15 perseant printf("lfs_gatherblock: already gathered! Ino %d, lbn %d\n",
958 1.15 perseant sp->fip->fi_ino, bp->b_lblkno);
959 1.15 perseant return(0);
960 1.15 perseant }
961 1.15 perseant #endif
962 1.1 mycroft /* Insert into the buffer list, update the FINFO block. */
963 1.1 mycroft bp->b_flags |= B_GATHERED;
964 1.1 mycroft *sp->cbpp++ = bp;
965 1.1 mycroft sp->fip->fi_blocks[sp->fip->fi_nblocks++] = bp->b_lblkno;
966 1.15 perseant
967 1.10 fvdl sp->sum_bytes_left -= sizeof(ufs_daddr_t);
968 1.10 fvdl sp->seg_bytes_left -= bp->b_bcount;
969 1.1 mycroft return(0);
970 1.1 mycroft }
971 1.1 mycroft
972 1.15 perseant int
973 1.69 perseant lfs_gather(struct lfs *fs, struct segment *sp, struct vnode *vp, int (*match)(struct lfs *, struct buf *))
974 1.1 mycroft {
975 1.1 mycroft struct buf *bp;
976 1.15 perseant int s, count=0;
977 1.15 perseant
978 1.1 mycroft sp->vp = vp;
979 1.1 mycroft s = splbio();
980 1.15 perseant
981 1.15 perseant #ifndef LFS_NO_BACKBUF_HACK
982 1.15 perseant loop: for (bp = vp->v_dirtyblkhd.lh_first; bp; bp = bp->b_vnbufs.le_next) {
983 1.15 perseant #else /* LFS_NO_BACKBUF_HACK */
984 1.10 fvdl /* This is a hack to see if ordering the blocks in LFS makes a difference. */
985 1.15 perseant # define BUF_OFFSET (((void *)&bp->b_vnbufs.le_next) - (void *)bp)
986 1.15 perseant # define BACK_BUF(BP) ((struct buf *)(((void *)BP->b_vnbufs.le_prev) - BUF_OFFSET))
987 1.15 perseant # define BEG_OF_LIST ((struct buf *)(((void *)&vp->v_dirtyblkhd.lh_first) - BUF_OFFSET))
988 1.10 fvdl /* Find last buffer. */
989 1.15 perseant loop: for (bp = vp->v_dirtyblkhd.lh_first; bp && bp->b_vnbufs.le_next != NULL;
990 1.10 fvdl bp = bp->b_vnbufs.le_next);
991 1.10 fvdl for (; bp && bp != BEG_OF_LIST; bp = BACK_BUF(bp)) {
992 1.15 perseant #endif /* LFS_NO_BACKBUF_HACK */
993 1.15 perseant if ((bp->b_flags & (B_BUSY|B_GATHERED)) || !match(fs, bp))
994 1.1 mycroft continue;
995 1.30 perseant if(vp->v_type == VBLK) {
996 1.30 perseant /* For block devices, just write the blocks. */
997 1.30 perseant /* XXX Do we really need to even do this? */
998 1.30 perseant #ifdef DEBUG_LFS
999 1.30 perseant if(count==0)
1000 1.30 perseant printf("BLK(");
1001 1.30 perseant printf(".");
1002 1.30 perseant #endif
1003 1.30 perseant /* Get the block before bwrite, so we don't corrupt the free list */
1004 1.30 perseant bp->b_flags |= B_BUSY;
1005 1.30 perseant bremfree(bp);
1006 1.30 perseant bwrite(bp);
1007 1.30 perseant } else {
1008 1.1 mycroft #ifdef DIAGNOSTIC
1009 1.43 perseant if ((bp->b_flags & (B_CALL|B_INVAL))==B_INVAL) {
1010 1.43 perseant printf("lfs_gather: lbn %d is B_INVAL\n",
1011 1.43 perseant bp->b_lblkno);
1012 1.43 perseant VOP_PRINT(bp->b_vp);
1013 1.43 perseant }
1014 1.30 perseant if (!(bp->b_flags & B_DELWRI))
1015 1.30 perseant panic("lfs_gather: bp not B_DELWRI");
1016 1.30 perseant if (!(bp->b_flags & B_LOCKED)) {
1017 1.58 perseant printf("lfs_gather: lbn %d blk %d"
1018 1.58 perseant " not B_LOCKED\n", bp->b_lblkno,
1019 1.69 perseant dbtofsb(fs, bp->b_blkno));
1020 1.30 perseant VOP_PRINT(bp->b_vp);
1021 1.30 perseant panic("lfs_gather: bp not B_LOCKED");
1022 1.30 perseant }
1023 1.1 mycroft #endif
1024 1.30 perseant if (lfs_gatherblock(sp, bp, &s)) {
1025 1.30 perseant goto loop;
1026 1.30 perseant }
1027 1.30 perseant }
1028 1.15 perseant count++;
1029 1.1 mycroft }
1030 1.1 mycroft splx(s);
1031 1.30 perseant #ifdef DEBUG_LFS
1032 1.30 perseant if(vp->v_type == VBLK && count)
1033 1.30 perseant printf(")\n");
1034 1.30 perseant #endif
1035 1.1 mycroft lfs_updatemeta(sp);
1036 1.1 mycroft sp->vp = NULL;
1037 1.15 perseant return count;
1038 1.1 mycroft }
1039 1.1 mycroft
1040 1.1 mycroft /*
1041 1.1 mycroft * Update the metadata that points to the blocks listed in the FINFO
1042 1.1 mycroft * array.
1043 1.1 mycroft */
1044 1.1 mycroft void
1045 1.69 perseant lfs_updatemeta(struct segment *sp)
1046 1.1 mycroft {
1047 1.1 mycroft SEGUSE *sup;
1048 1.55 perseant struct buf *bp;
1049 1.1 mycroft struct lfs *fs;
1050 1.1 mycroft struct vnode *vp;
1051 1.1 mycroft struct indir a[NIADDR + 2], *ap;
1052 1.1 mycroft struct inode *ip;
1053 1.10 fvdl ufs_daddr_t daddr, lbn, off;
1054 1.43 perseant daddr_t ooff;
1055 1.10 fvdl int error, i, nblocks, num;
1056 1.53 perseant int bb;
1057 1.15 perseant
1058 1.1 mycroft vp = sp->vp;
1059 1.1 mycroft nblocks = &sp->fip->fi_blocks[sp->fip->fi_nblocks] - sp->start_lbp;
1060 1.10 fvdl if (nblocks < 0)
1061 1.10 fvdl panic("This is a bad thing\n");
1062 1.1 mycroft if (vp == NULL || nblocks == 0)
1063 1.1 mycroft return;
1064 1.15 perseant
1065 1.1 mycroft /* Sort the blocks. */
1066 1.15 perseant /*
1067 1.15 perseant * XXX KS - We have to sort even if the blocks come from the
1068 1.15 perseant * cleaner, because there might be other pending blocks on the
1069 1.15 perseant * same inode...and if we don't sort, and there are fragments
1070 1.15 perseant * present, blocks may be written in the wrong place.
1071 1.15 perseant */
1072 1.15 perseant /* if (!(sp->seg_flags & SEGM_CLEAN)) */
1073 1.15 perseant lfs_shellsort(sp->start_bpp, sp->start_lbp, nblocks);
1074 1.15 perseant
1075 1.1 mycroft /*
1076 1.10 fvdl * Record the length of the last block in case it's a fragment.
1077 1.10 fvdl * If there are indirect blocks present, they sort last. An
1078 1.10 fvdl * indirect block will be lfs_bsize and its presence indicates
1079 1.10 fvdl * that you cannot have fragments.
1080 1.10 fvdl */
1081 1.10 fvdl sp->fip->fi_lastlength = sp->start_bpp[nblocks - 1]->b_bcount;
1082 1.15 perseant
1083 1.10 fvdl /*
1084 1.1 mycroft * Assign disk addresses, and update references to the logical
1085 1.1 mycroft * block and the segment usage information.
1086 1.1 mycroft */
1087 1.1 mycroft fs = sp->fs;
1088 1.1 mycroft for (i = nblocks; i--; ++sp->start_bpp) {
1089 1.1 mycroft lbn = *sp->start_lbp++;
1090 1.15 perseant
1091 1.69 perseant (*sp->start_bpp)->b_blkno = fsbtodb(fs, fs->lfs_offset);
1092 1.69 perseant off = fs->lfs_offset;
1093 1.17 perseant if((*sp->start_bpp)->b_blkno == (*sp->start_bpp)->b_lblkno) {
1094 1.58 perseant printf("lfs_updatemeta: ino %d blk %d"
1095 1.58 perseant " has same lbn and daddr\n",
1096 1.58 perseant VTOI(vp)->i_number, off);
1097 1.17 perseant }
1098 1.67 joff #ifdef DIAGNOSTIC
1099 1.67 joff if((*sp->start_bpp)->b_bcount < fs->lfs_bsize && i != 0)
1100 1.67 joff panic("lfs_updatemeta: fragment is not last block\n");
1101 1.67 joff #endif
1102 1.69 perseant bb = fragstofsb(fs, numfrags(fs, (*sp->start_bpp)->b_bcount));
1103 1.53 perseant fs->lfs_offset += bb;
1104 1.4 christos error = ufs_bmaparray(vp, lbn, &daddr, a, &num, NULL);
1105 1.69 perseant if (daddr > 0)
1106 1.69 perseant daddr = dbtofsb(fs, daddr);
1107 1.4 christos if (error)
1108 1.1 mycroft panic("lfs_updatemeta: ufs_bmaparray %d", error);
1109 1.1 mycroft ip = VTOI(vp);
1110 1.1 mycroft switch (num) {
1111 1.1 mycroft case 0:
1112 1.43 perseant ooff = ip->i_ffs_db[lbn];
1113 1.55 perseant #ifdef DEBUG
1114 1.55 perseant if (ooff == 0) {
1115 1.53 perseant printf("lfs_updatemeta[1]: warning: writing "
1116 1.55 perseant "ino %d lbn %d at 0x%x, was 0x0\n",
1117 1.55 perseant ip->i_number, lbn, off);
1118 1.55 perseant }
1119 1.43 perseant #endif
1120 1.55 perseant if (ooff == UNWRITTEN)
1121 1.55 perseant ip->i_ffs_blocks += bb;
1122 1.55 perseant ip->i_ffs_db[lbn] = off;
1123 1.1 mycroft break;
1124 1.1 mycroft case 1:
1125 1.43 perseant ooff = ip->i_ffs_ib[a[0].in_off];
1126 1.55 perseant #ifdef DEBUG
1127 1.55 perseant if (ooff == 0) {
1128 1.53 perseant printf("lfs_updatemeta[2]: warning: writing "
1129 1.55 perseant "ino %d lbn %d at 0x%x, was 0x0\n",
1130 1.55 perseant ip->i_number, lbn, off);
1131 1.55 perseant }
1132 1.43 perseant #endif
1133 1.55 perseant if (ooff == UNWRITTEN)
1134 1.55 perseant ip->i_ffs_blocks += bb;
1135 1.55 perseant ip->i_ffs_ib[a[0].in_off] = off;
1136 1.1 mycroft break;
1137 1.1 mycroft default:
1138 1.1 mycroft ap = &a[num - 1];
1139 1.1 mycroft if (bread(vp, ap->in_lbn, fs->lfs_bsize, NOCRED, &bp))
1140 1.1 mycroft panic("lfs_updatemeta: bread bno %d",
1141 1.15 perseant ap->in_lbn);
1142 1.43 perseant
1143 1.43 perseant ooff = ((ufs_daddr_t *)bp->b_data)[ap->in_off];
1144 1.55 perseant #if DEBUG
1145 1.55 perseant if (ooff == 0) {
1146 1.53 perseant printf("lfs_updatemeta[3]: warning: writing "
1147 1.55 perseant "ino %d lbn %d at 0x%x, was 0x0\n",
1148 1.55 perseant ip->i_number, lbn, off);
1149 1.55 perseant }
1150 1.43 perseant #endif
1151 1.55 perseant if (ooff == UNWRITTEN)
1152 1.55 perseant ip->i_ffs_blocks += bb;
1153 1.55 perseant ((ufs_daddr_t *)bp->b_data)[ap->in_off] = off;
1154 1.58 perseant (void) VOP_BWRITE(bp);
1155 1.1 mycroft }
1156 1.55 perseant #ifdef DEBUG
1157 1.49 perseant if (daddr >= fs->lfs_lastpseg && daddr <= off) {
1158 1.49 perseant printf("lfs_updatemeta: ino %d, lbn %d, addr = %x "
1159 1.49 perseant "in same pseg\n", VTOI(sp->vp)->i_number,
1160 1.49 perseant (*sp->start_bpp)->b_lblkno, daddr);
1161 1.49 perseant }
1162 1.55 perseant #endif
1163 1.55 perseant /* Update segment usage information. */
1164 1.49 perseant if (daddr > 0) {
1165 1.69 perseant LFS_SEGENTRY(sup, fs, dtosn(fs, daddr), bp);
1166 1.1 mycroft #ifdef DIAGNOSTIC
1167 1.10 fvdl if (sup->su_nbytes < (*sp->start_bpp)->b_bcount) {
1168 1.1 mycroft /* XXX -- Change to a panic. */
1169 1.55 perseant printf("lfs_updatemeta: negative bytes "
1170 1.55 perseant "(segment %d short by %ld)\n",
1171 1.69 perseant dtosn(fs, daddr),
1172 1.55 perseant (*sp->start_bpp)->b_bcount -
1173 1.55 perseant sup->su_nbytes);
1174 1.55 perseant printf("lfs_updatemeta: ino %d, lbn %d, "
1175 1.69 perseant "addr = 0x%x\n", VTOI(sp->vp)->i_number,
1176 1.55 perseant (*sp->start_bpp)->b_lblkno, daddr);
1177 1.27 perseant panic("lfs_updatemeta: negative bytes");
1178 1.27 perseant sup->su_nbytes = (*sp->start_bpp)->b_bcount;
1179 1.1 mycroft }
1180 1.1 mycroft #endif
1181 1.69 perseant #ifdef DEBUG_SU_NBYTES
1182 1.69 perseant printf("seg %d -= %ld for ino %d lbn %d db 0x%x\n",
1183 1.69 perseant dtosn(fs, daddr), (*sp->start_bpp)->b_bcount,
1184 1.69 perseant VTOI(sp->vp)->i_number,
1185 1.69 perseant (*sp->start_bpp)->b_lblkno, daddr);
1186 1.69 perseant #endif
1187 1.10 fvdl sup->su_nbytes -= (*sp->start_bpp)->b_bcount;
1188 1.58 perseant error = VOP_BWRITE(bp); /* Ifile */
1189 1.1 mycroft }
1190 1.1 mycroft }
1191 1.1 mycroft }
1192 1.1 mycroft
1193 1.1 mycroft /*
1194 1.1 mycroft * Start a new segment.
1195 1.1 mycroft */
1196 1.1 mycroft int
1197 1.69 perseant lfs_initseg(struct lfs *fs)
1198 1.1 mycroft {
1199 1.1 mycroft struct segment *sp;
1200 1.1 mycroft SEGUSE *sup;
1201 1.1 mycroft SEGSUM *ssp;
1202 1.1 mycroft struct buf *bp;
1203 1.1 mycroft int repeat;
1204 1.15 perseant
1205 1.1 mycroft sp = fs->lfs_sp;
1206 1.69 perseant
1207 1.1 mycroft repeat = 0;
1208 1.1 mycroft /* Advance to the next segment. */
1209 1.1 mycroft if (!LFS_PARTIAL_FITS(fs)) {
1210 1.55 perseant /* lfs_avail eats the remaining space */
1211 1.69 perseant fs->lfs_avail -= fs->lfs_fsbpseg - (fs->lfs_offset -
1212 1.55 perseant fs->lfs_curseg);
1213 1.1 mycroft /* Wake up any cleaning procs waiting on this file system. */
1214 1.1 mycroft wakeup(&lfs_allclean_wakeup);
1215 1.10 fvdl wakeup(&fs->lfs_nextseg);
1216 1.1 mycroft lfs_newseg(fs);
1217 1.1 mycroft repeat = 1;
1218 1.1 mycroft fs->lfs_offset = fs->lfs_curseg;
1219 1.69 perseant sp->seg_number = dtosn(fs, fs->lfs_curseg);
1220 1.69 perseant sp->seg_bytes_left = fsbtob(fs, fs->lfs_fsbpseg);
1221 1.1 mycroft /*
1222 1.1 mycroft * If the segment contains a superblock, update the offset
1223 1.1 mycroft * and summary address to skip over it.
1224 1.1 mycroft */
1225 1.1 mycroft LFS_SEGENTRY(sup, fs, sp->seg_number, bp);
1226 1.1 mycroft if (sup->su_flags & SEGUSE_SUPERBLOCK) {
1227 1.69 perseant fs->lfs_offset += btofsb(fs, LFS_SBPAD);
1228 1.1 mycroft sp->seg_bytes_left -= LFS_SBPAD;
1229 1.1 mycroft }
1230 1.1 mycroft brelse(bp);
1231 1.69 perseant /* Segment zero could also contain the labelpad */
1232 1.69 perseant if (fs->lfs_version > 1 && sp->seg_number == 0 &&
1233 1.69 perseant fs->lfs_start < btofsb(fs, LFS_LABELPAD)) {
1234 1.69 perseant fs->lfs_offset += btofsb(fs, LFS_LABELPAD) - fs->lfs_start;
1235 1.69 perseant sp->seg_bytes_left -= LFS_LABELPAD - fsbtob(fs, fs->lfs_start);
1236 1.69 perseant }
1237 1.1 mycroft } else {
1238 1.69 perseant sp->seg_number = dtosn(fs, fs->lfs_curseg);
1239 1.69 perseant sp->seg_bytes_left = fsbtob(fs, fs->lfs_fsbpseg -
1240 1.58 perseant (fs->lfs_offset - fs->lfs_curseg));
1241 1.1 mycroft }
1242 1.1 mycroft fs->lfs_lastpseg = fs->lfs_offset;
1243 1.15 perseant
1244 1.1 mycroft sp->fs = fs;
1245 1.1 mycroft sp->ibp = NULL;
1246 1.27 perseant sp->idp = NULL;
1247 1.1 mycroft sp->ninodes = 0;
1248 1.69 perseant
1249 1.1 mycroft /* Get a new buffer for SEGSUM and enter it into the buffer list. */
1250 1.1 mycroft sp->cbpp = sp->bpp;
1251 1.69 perseant *sp->cbpp = lfs_newbuf(fs, VTOI(fs->lfs_ivnode)->i_devvp,
1252 1.69 perseant fsbtodb(fs, fs->lfs_offset), fs->lfs_sumsize);
1253 1.1 mycroft sp->segsum = (*sp->cbpp)->b_data;
1254 1.69 perseant bzero(sp->segsum, fs->lfs_sumsize);
1255 1.1 mycroft sp->start_bpp = ++sp->cbpp;
1256 1.69 perseant fs->lfs_offset += btofsb(fs, fs->lfs_sumsize);
1257 1.15 perseant
1258 1.1 mycroft /* Set point to SEGSUM, initialize it. */
1259 1.1 mycroft ssp = sp->segsum;
1260 1.1 mycroft ssp->ss_next = fs->lfs_nextseg;
1261 1.1 mycroft ssp->ss_nfinfo = ssp->ss_ninos = 0;
1262 1.10 fvdl ssp->ss_magic = SS_MAGIC;
1263 1.1 mycroft
1264 1.1 mycroft /* Set pointer to first FINFO, initialize it. */
1265 1.69 perseant sp->fip = (struct finfo *)((caddr_t)sp->segsum + SEGSUM_SIZE(fs));
1266 1.1 mycroft sp->fip->fi_nblocks = 0;
1267 1.1 mycroft sp->start_lbp = &sp->fip->fi_blocks[0];
1268 1.10 fvdl sp->fip->fi_lastlength = 0;
1269 1.15 perseant
1270 1.69 perseant sp->seg_bytes_left -= fs->lfs_sumsize;
1271 1.69 perseant sp->sum_bytes_left = fs->lfs_sumsize - SEGSUM_SIZE(fs);
1272 1.15 perseant
1273 1.1 mycroft return(repeat);
1274 1.1 mycroft }
1275 1.1 mycroft
1276 1.1 mycroft /*
1277 1.1 mycroft * Return the next segment to write.
1278 1.1 mycroft */
1279 1.1 mycroft void
1280 1.69 perseant lfs_newseg(struct lfs *fs)
1281 1.1 mycroft {
1282 1.1 mycroft CLEANERINFO *cip;
1283 1.1 mycroft SEGUSE *sup;
1284 1.1 mycroft struct buf *bp;
1285 1.1 mycroft int curseg, isdirty, sn;
1286 1.15 perseant
1287 1.69 perseant LFS_SEGENTRY(sup, fs, dtosn(fs, fs->lfs_nextseg), bp);
1288 1.69 perseant #ifdef DEBUG_SU_NBYTES
1289 1.69 perseant printf("lfs_newseg: seg %d := 0 in newseg\n", /* XXXDEBUG */
1290 1.69 perseant dtosn(fs, fs->lfs_nextseg)); /* XXXDEBUG */
1291 1.69 perseant #endif
1292 1.15 perseant sup->su_flags |= SEGUSE_DIRTY | SEGUSE_ACTIVE;
1293 1.1 mycroft sup->su_nbytes = 0;
1294 1.1 mycroft sup->su_nsums = 0;
1295 1.1 mycroft sup->su_ninos = 0;
1296 1.58 perseant (void) VOP_BWRITE(bp); /* Ifile */
1297 1.1 mycroft
1298 1.1 mycroft LFS_CLEANERINFO(cip, fs, bp);
1299 1.1 mycroft --cip->clean;
1300 1.1 mycroft ++cip->dirty;
1301 1.15 perseant fs->lfs_nclean = cip->clean;
1302 1.61 perseant LFS_SYNC_CLEANERINFO(cip, fs, bp, 1);
1303 1.15 perseant
1304 1.1 mycroft fs->lfs_lastseg = fs->lfs_curseg;
1305 1.1 mycroft fs->lfs_curseg = fs->lfs_nextseg;
1306 1.69 perseant for (sn = curseg = dtosn(fs, fs->lfs_curseg) + fs->lfs_interleave;;) {
1307 1.1 mycroft sn = (sn + 1) % fs->lfs_nseg;
1308 1.1 mycroft if (sn == curseg)
1309 1.1 mycroft panic("lfs_nextseg: no clean segments");
1310 1.1 mycroft LFS_SEGENTRY(sup, fs, sn, bp);
1311 1.1 mycroft isdirty = sup->su_flags & SEGUSE_DIRTY;
1312 1.1 mycroft brelse(bp);
1313 1.1 mycroft if (!isdirty)
1314 1.1 mycroft break;
1315 1.1 mycroft }
1316 1.15 perseant
1317 1.1 mycroft ++fs->lfs_nactive;
1318 1.69 perseant fs->lfs_nextseg = sntod(fs, sn);
1319 1.15 perseant if(lfs_dostats) {
1320 1.15 perseant ++lfs_stats.segsused;
1321 1.15 perseant }
1322 1.1 mycroft }
1323 1.1 mycroft
1324 1.1 mycroft int
1325 1.69 perseant lfs_writeseg(struct lfs *fs, struct segment *sp)
1326 1.1 mycroft {
1327 1.53 perseant struct buf **bpp, *bp, *cbp, *newbp;
1328 1.1 mycroft SEGUSE *sup;
1329 1.1 mycroft SEGSUM *ssp;
1330 1.1 mycroft dev_t i_dev;
1331 1.69 perseant char *datap, *dp;
1332 1.69 perseant int do_again, i, nblocks, s, el_size;
1333 1.15 perseant #ifdef LFS_TRACK_IOS
1334 1.15 perseant int j;
1335 1.15 perseant #endif
1336 1.69 perseant int (*strategy)(void *);
1337 1.1 mycroft struct vop_strategy_args vop_strategy_a;
1338 1.1 mycroft u_short ninos;
1339 1.15 perseant struct vnode *devvp;
1340 1.1 mycroft char *p;
1341 1.69 perseant struct vnode *vp;
1342 1.26 perseant struct inode *ip;
1343 1.53 perseant daddr_t *daddrp;
1344 1.55 perseant int changed;
1345 1.15 perseant #if defined(DEBUG) && defined(LFS_PROPELLER)
1346 1.15 perseant static int propeller;
1347 1.15 perseant char propstring[4] = "-\\|/";
1348 1.15 perseant
1349 1.15 perseant printf("%c\b",propstring[propeller++]);
1350 1.15 perseant if(propeller==4)
1351 1.15 perseant propeller = 0;
1352 1.15 perseant #endif
1353 1.15 perseant
1354 1.1 mycroft /*
1355 1.1 mycroft * If there are no buffers other than the segment summary to write
1356 1.1 mycroft * and it is not a checkpoint, don't do anything. On a checkpoint,
1357 1.1 mycroft * even if there aren't any buffers, you need to write the superblock.
1358 1.1 mycroft */
1359 1.1 mycroft if ((nblocks = sp->cbpp - sp->bpp) == 1)
1360 1.1 mycroft return (0);
1361 1.15 perseant
1362 1.27 perseant i_dev = VTOI(fs->lfs_ivnode)->i_dev;
1363 1.27 perseant devvp = VTOI(fs->lfs_ivnode)->i_devvp;
1364 1.27 perseant
1365 1.10 fvdl /* Update the segment usage information. */
1366 1.10 fvdl LFS_SEGENTRY(sup, fs, sp->seg_number, bp);
1367 1.15 perseant
1368 1.10 fvdl /* Loop through all blocks, except the segment summary. */
1369 1.27 perseant for (bpp = sp->bpp; ++bpp < sp->cbpp; ) {
1370 1.69 perseant if((*bpp)->b_vp != devvp) {
1371 1.27 perseant sup->su_nbytes += (*bpp)->b_bcount;
1372 1.69 perseant #ifdef DEBUG_SU_NBYTES
1373 1.69 perseant printf("seg %d += %ld for ino %d lbn %d db 0x%x\n",
1374 1.69 perseant sp->seg_number, (*bpp)->b_bcount,
1375 1.69 perseant VTOI((*bpp)->b_vp)->i_number,
1376 1.69 perseant (*bpp)->b_lblkno, (*bpp)->b_blkno);
1377 1.69 perseant #endif
1378 1.69 perseant }
1379 1.27 perseant }
1380 1.15 perseant
1381 1.1 mycroft ssp = (SEGSUM *)sp->segsum;
1382 1.15 perseant
1383 1.1 mycroft ninos = (ssp->ss_ninos + INOPB(fs) - 1) / INOPB(fs);
1384 1.69 perseant #ifdef DEBUG_SU_NBYTES
1385 1.69 perseant printf("seg %d += %d for %d inodes\n", /* XXXDEBUG */
1386 1.69 perseant sp->seg_number, ssp->ss_ninos * DINODE_SIZE,
1387 1.69 perseant ssp->ss_ninos);
1388 1.69 perseant #endif
1389 1.27 perseant sup->su_nbytes += ssp->ss_ninos * DINODE_SIZE;
1390 1.69 perseant /* sup->su_nbytes += fs->lfs_sumsize; */
1391 1.69 perseant if (fs->lfs_version == 1)
1392 1.69 perseant sup->su_olastmod = time.tv_sec;
1393 1.69 perseant else
1394 1.69 perseant sup->su_lastmod = time.tv_sec;
1395 1.1 mycroft sup->su_ninos += ninos;
1396 1.1 mycroft ++sup->su_nsums;
1397 1.69 perseant fs->lfs_dmeta += (btofsb(fs, fs->lfs_sumsize) + btofsb(fs, ninos *
1398 1.69 perseant fs->lfs_ibsize));
1399 1.69 perseant fs->lfs_avail -= btofsb(fs, fs->lfs_sumsize);
1400 1.15 perseant
1401 1.1 mycroft do_again = !(bp->b_flags & B_GATHERED);
1402 1.58 perseant (void)VOP_BWRITE(bp); /* Ifile */
1403 1.1 mycroft /*
1404 1.53 perseant * Mark blocks B_BUSY, to prevent then from being changed between
1405 1.53 perseant * the checksum computation and the actual write.
1406 1.53 perseant *
1407 1.53 perseant * If we are cleaning, check indirect blocks for UNWRITTEN, and if
1408 1.53 perseant * there are any, replace them with copies that have UNASSIGNED
1409 1.53 perseant * instead.
1410 1.53 perseant */
1411 1.53 perseant for (bpp = sp->bpp, i = nblocks - 1; i--;) {
1412 1.53 perseant ++bpp;
1413 1.53 perseant if((*bpp)->b_flags & B_CALL)
1414 1.53 perseant continue;
1415 1.53 perseant bp = *bpp;
1416 1.53 perseant again:
1417 1.53 perseant s = splbio();
1418 1.53 perseant if(bp->b_flags & B_BUSY) {
1419 1.53 perseant #ifdef DEBUG
1420 1.53 perseant printf("lfs_writeseg: avoiding potential data "
1421 1.53 perseant "summary corruption for ino %d, lbn %d\n",
1422 1.53 perseant VTOI(bp->b_vp)->i_number, bp->b_lblkno);
1423 1.53 perseant #endif
1424 1.53 perseant bp->b_flags |= B_WANTED;
1425 1.53 perseant tsleep(bp, (PRIBIO + 1), "lfs_writeseg", 0);
1426 1.53 perseant splx(s);
1427 1.53 perseant goto again;
1428 1.53 perseant }
1429 1.53 perseant bp->b_flags |= B_BUSY;
1430 1.53 perseant splx(s);
1431 1.53 perseant /* Check and replace indirect block UNWRITTEN bogosity */
1432 1.53 perseant if(bp->b_lblkno < 0 && bp->b_vp != devvp && bp->b_vp &&
1433 1.53 perseant VTOI(bp->b_vp)->i_ffs_blocks !=
1434 1.53 perseant VTOI(bp->b_vp)->i_lfs_effnblks) {
1435 1.54 perseant #ifdef DEBUG_LFS
1436 1.53 perseant printf("lfs_writeseg: cleansing ino %d (%d != %d)\n",
1437 1.53 perseant VTOI(bp->b_vp)->i_number,
1438 1.53 perseant VTOI(bp->b_vp)->i_lfs_effnblks,
1439 1.53 perseant VTOI(bp->b_vp)->i_ffs_blocks);
1440 1.54 perseant #endif
1441 1.53 perseant /* Make a copy we'll make changes to */
1442 1.69 perseant newbp = lfs_newbuf(fs, bp->b_vp, bp->b_lblkno,
1443 1.53 perseant bp->b_bcount);
1444 1.53 perseant newbp->b_blkno = bp->b_blkno;
1445 1.53 perseant memcpy(newbp->b_data, bp->b_data,
1446 1.53 perseant newbp->b_bcount);
1447 1.53 perseant *bpp = newbp;
1448 1.53 perseant
1449 1.55 perseant changed = 0;
1450 1.53 perseant for (daddrp = (daddr_t *)(newbp->b_data);
1451 1.53 perseant daddrp < (daddr_t *)(newbp->b_data +
1452 1.53 perseant newbp->b_bcount); daddrp++) {
1453 1.53 perseant if (*daddrp == UNWRITTEN) {
1454 1.55 perseant ++changed;
1455 1.54 perseant #ifdef DEBUG_LFS
1456 1.54 perseant printf("lfs_writeseg: replacing UNWRITTEN\n");
1457 1.53 perseant #endif
1458 1.53 perseant *daddrp = 0;
1459 1.53 perseant }
1460 1.53 perseant }
1461 1.55 perseant /*
1462 1.55 perseant * Get rid of the old buffer. Don't mark it clean,
1463 1.55 perseant * though, if it still has dirty data on it.
1464 1.55 perseant */
1465 1.55 perseant if (changed) {
1466 1.55 perseant bp->b_flags &= ~(B_ERROR | B_GATHERED);
1467 1.69 perseant if (bp->b_flags & B_CALL) {
1468 1.55 perseant lfs_freebuf(bp);
1469 1.69 perseant bp = NULL;
1470 1.69 perseant } else {
1471 1.57 perseant /* Still on free list, leave it there */
1472 1.57 perseant s = splbio();
1473 1.57 perseant bp->b_flags &= ~B_BUSY;
1474 1.57 perseant if (bp->b_flags & B_WANTED)
1475 1.57 perseant wakeup(bp);
1476 1.57 perseant splx(s);
1477 1.62 perseant /*
1478 1.62 perseant * We have to re-decrement lfs_avail
1479 1.62 perseant * since this block is going to come
1480 1.62 perseant * back around to us in the next
1481 1.62 perseant * segment.
1482 1.62 perseant */
1483 1.69 perseant fs->lfs_avail -= btofsb(fs, bp->b_bcount);
1484 1.57 perseant }
1485 1.55 perseant } else {
1486 1.55 perseant bp->b_flags &= ~(B_ERROR | B_READ | B_DELWRI |
1487 1.62 perseant B_GATHERED);
1488 1.62 perseant LFS_UNLOCK_BUF(bp);
1489 1.69 perseant if (bp->b_flags & B_CALL) {
1490 1.55 perseant lfs_freebuf(bp);
1491 1.69 perseant bp = NULL;
1492 1.69 perseant } else {
1493 1.55 perseant bremfree(bp);
1494 1.55 perseant bp->b_flags |= B_DONE;
1495 1.55 perseant reassignbuf(bp, bp->b_vp);
1496 1.55 perseant brelse(bp);
1497 1.55 perseant }
1498 1.55 perseant }
1499 1.69 perseant
1500 1.53 perseant }
1501 1.53 perseant }
1502 1.53 perseant /*
1503 1.1 mycroft * Compute checksum across data and then across summary; the first
1504 1.1 mycroft * block (the summary block) is skipped. Set the create time here
1505 1.1 mycroft * so that it's guaranteed to be later than the inode mod times.
1506 1.1 mycroft *
1507 1.1 mycroft * XXX
1508 1.1 mycroft * Fix this to do it inline, instead of malloc/copy.
1509 1.1 mycroft */
1510 1.69 perseant if (fs->lfs_version == 1)
1511 1.69 perseant el_size = sizeof(u_long);
1512 1.69 perseant else
1513 1.69 perseant el_size = sizeof(u_int32_t);
1514 1.69 perseant datap = dp = malloc(nblocks * el_size, M_SEGMENT, M_WAITOK);
1515 1.1 mycroft for (bpp = sp->bpp, i = nblocks - 1; i--;) {
1516 1.15 perseant if (((*++bpp)->b_flags & (B_CALL|B_INVAL)) == (B_CALL|B_INVAL)) {
1517 1.69 perseant if (copyin((*bpp)->b_saveaddr, dp, el_size))
1518 1.53 perseant panic("lfs_writeseg: copyin failed [1]: "
1519 1.53 perseant "ino %d blk %d",
1520 1.53 perseant VTOI((*bpp)->b_vp)->i_number,
1521 1.53 perseant (*bpp)->b_lblkno);
1522 1.53 perseant } else
1523 1.69 perseant memcpy(dp, (*bpp)->b_data, el_size);
1524 1.69 perseant dp += el_size;
1525 1.69 perseant }
1526 1.69 perseant if (fs->lfs_version == 1)
1527 1.69 perseant ssp->ss_ocreate = time.tv_sec;
1528 1.69 perseant else {
1529 1.69 perseant ssp->ss_create = time.tv_sec;
1530 1.69 perseant ssp->ss_serial = ++fs->lfs_serial;
1531 1.69 perseant ssp->ss_ident = fs->lfs_ident;
1532 1.1 mycroft }
1533 1.69 perseant ssp->ss_datasum = cksum(datap, (nblocks - 1) * el_size);
1534 1.1 mycroft ssp->ss_sumsum =
1535 1.69 perseant cksum(&ssp->ss_datasum, fs->lfs_sumsize - sizeof(ssp->ss_sumsum));
1536 1.1 mycroft free(datap, M_SEGMENT);
1537 1.69 perseant datap = dp = NULL;
1538 1.69 perseant #ifdef DIAGNOSTIC
1539 1.69 perseant if (fs->lfs_bfree < btofsb(fs, ninos * fs->lfs_ibsize) + btofsb(fs, fs->lfs_sumsize))
1540 1.69 perseant panic("lfs_writeseg: No diskspace for summary");
1541 1.69 perseant #endif
1542 1.69 perseant fs->lfs_bfree -= (btofsb(fs, ninos * fs->lfs_ibsize) +
1543 1.69 perseant btofsb(fs, fs->lfs_sumsize));
1544 1.1 mycroft
1545 1.15 perseant strategy = devvp->v_op[VOFFSET(vop_strategy)];
1546 1.1 mycroft
1547 1.1 mycroft /*
1548 1.1 mycroft * When we simply write the blocks we lose a rotation for every block
1549 1.1 mycroft * written. To avoid this problem, we allocate memory in chunks, copy
1550 1.15 perseant * the buffers into the chunk and write the chunk. CHUNKSIZE is the
1551 1.1 mycroft * largest size I/O devices can handle.
1552 1.41 soren * When the data is copied to the chunk, turn off the B_LOCKED bit
1553 1.1 mycroft * and brelse the buffer (which will move them to the LRU list). Add
1554 1.1 mycroft * the B_CALL flag to the buffer header so we can count I/O's for the
1555 1.1 mycroft * checkpoints and so we can release the allocated memory.
1556 1.1 mycroft *
1557 1.1 mycroft * XXX
1558 1.1 mycroft * This should be removed if the new virtual memory system allows us to
1559 1.1 mycroft * easily make the buffers contiguous in kernel memory and if that's
1560 1.1 mycroft * fast enough.
1561 1.1 mycroft */
1562 1.15 perseant
1563 1.15 perseant #define CHUNKSIZE MAXPHYS
1564 1.15 perseant
1565 1.15 perseant if(devvp==NULL)
1566 1.15 perseant panic("devvp is NULL");
1567 1.15 perseant for (bpp = sp->bpp,i = nblocks; i;) {
1568 1.69 perseant cbp = lfs_newbuf(fs, devvp, (*bpp)->b_blkno, CHUNKSIZE);
1569 1.1 mycroft cbp->b_dev = i_dev;
1570 1.1 mycroft cbp->b_flags |= B_ASYNC | B_BUSY;
1571 1.10 fvdl cbp->b_bcount = 0;
1572 1.1 mycroft
1573 1.17 perseant #ifdef DIAGNOSTIC
1574 1.69 perseant if(dtosn(fs, dbtofsb(fs, (*bpp)->b_blkno) + btofsb(fs, (*bpp)->b_bcount) - 1) !=
1575 1.69 perseant dtosn(fs, dbtofsb(fs, cbp->b_blkno))) {
1576 1.17 perseant panic("lfs_writeseg: Segment overwrite");
1577 1.17 perseant }
1578 1.17 perseant #endif
1579 1.17 perseant
1580 1.36 perseant s = splbio();
1581 1.15 perseant if(fs->lfs_iocount >= LFS_THROTTLE) {
1582 1.15 perseant tsleep(&fs->lfs_iocount, PRIBIO+1, "lfs throttle", 0);
1583 1.15 perseant }
1584 1.1 mycroft ++fs->lfs_iocount;
1585 1.15 perseant #ifdef LFS_TRACK_IOS
1586 1.15 perseant for(j=0;j<LFS_THROTTLE;j++) {
1587 1.15 perseant if(fs->lfs_pending[j]==LFS_UNUSED_DADDR) {
1588 1.69 perseant fs->lfs_pending[j] = dbtofsb(fs, cbp->b_blkno);
1589 1.15 perseant break;
1590 1.15 perseant }
1591 1.15 perseant }
1592 1.15 perseant #endif /* LFS_TRACK_IOS */
1593 1.15 perseant for (p = cbp->b_data; i && cbp->b_bcount < CHUNKSIZE; i--) {
1594 1.10 fvdl bp = *bpp;
1595 1.15 perseant
1596 1.15 perseant if (bp->b_bcount > (CHUNKSIZE - cbp->b_bcount))
1597 1.10 fvdl break;
1598 1.10 fvdl
1599 1.1 mycroft /*
1600 1.1 mycroft * Fake buffers from the cleaner are marked as B_INVAL.
1601 1.1 mycroft * We need to copy the data from user space rather than
1602 1.1 mycroft * from the buffer indicated.
1603 1.1 mycroft * XXX == what do I do on an error?
1604 1.1 mycroft */
1605 1.15 perseant if ((bp->b_flags & (B_CALL|B_INVAL)) == (B_CALL|B_INVAL)) {
1606 1.1 mycroft if (copyin(bp->b_saveaddr, p, bp->b_bcount))
1607 1.15 perseant panic("lfs_writeseg: copyin failed [2]");
1608 1.1 mycroft } else
1609 1.1 mycroft bcopy(bp->b_data, p, bp->b_bcount);
1610 1.1 mycroft p += bp->b_bcount;
1611 1.10 fvdl cbp->b_bcount += bp->b_bcount;
1612 1.62 perseant LFS_UNLOCK_BUF(bp);
1613 1.1 mycroft bp->b_flags &= ~(B_ERROR | B_READ | B_DELWRI |
1614 1.62 perseant B_GATHERED);
1615 1.69 perseant vp = bp->b_vp;
1616 1.1 mycroft if (bp->b_flags & B_CALL) {
1617 1.1 mycroft /* if B_CALL, it was created with newbuf */
1618 1.15 perseant lfs_freebuf(bp);
1619 1.69 perseant bp = NULL;
1620 1.1 mycroft } else {
1621 1.1 mycroft bremfree(bp);
1622 1.1 mycroft bp->b_flags |= B_DONE;
1623 1.69 perseant if(vp)
1624 1.69 perseant reassignbuf(bp, vp);
1625 1.1 mycroft brelse(bp);
1626 1.15 perseant }
1627 1.26 perseant
1628 1.26 perseant bpp++;
1629 1.26 perseant
1630 1.26 perseant /*
1631 1.26 perseant * If this is the last block for this vnode, but
1632 1.26 perseant * there are other blocks on its dirty list,
1633 1.26 perseant * set IN_MODIFIED/IN_CLEANING depending on what
1634 1.26 perseant * sort of block. Only do this for our mount point,
1635 1.26 perseant * not for, e.g., inode blocks that are attached to
1636 1.26 perseant * the devvp.
1637 1.69 perseant * XXX KS - Shouldn't we set *both* if both types
1638 1.69 perseant * of blocks are present (traverse the dirty list?)
1639 1.26 perseant */
1640 1.69 perseant if((i == 1 ||
1641 1.69 perseant (i > 1 && vp && *bpp && (*bpp)->b_vp != vp)) &&
1642 1.69 perseant (bp = vp->v_dirtyblkhd.lh_first) != NULL &&
1643 1.69 perseant vp->v_mount == fs->lfs_ivnode->v_mount)
1644 1.26 perseant {
1645 1.69 perseant ip = VTOI(vp);
1646 1.26 perseant #ifdef DEBUG_LFS
1647 1.69 perseant printf("lfs_writeseg: marking ino %d\n",
1648 1.69 perseant ip->i_number);
1649 1.26 perseant #endif
1650 1.56 perseant if(bp->b_flags & B_CALL)
1651 1.56 perseant LFS_SET_UINO(ip, IN_CLEANING);
1652 1.56 perseant else
1653 1.56 perseant LFS_SET_UINO(ip, IN_MODIFIED);
1654 1.26 perseant }
1655 1.69 perseant wakeup(vp);
1656 1.1 mycroft }
1657 1.1 mycroft ++cbp->b_vp->v_numoutput;
1658 1.1 mycroft splx(s);
1659 1.1 mycroft /*
1660 1.1 mycroft * XXXX This is a gross and disgusting hack. Since these
1661 1.1 mycroft * buffers are physically addressed, they hang off the
1662 1.1 mycroft * device vnode (devvp). As a result, they have no way
1663 1.1 mycroft * of getting to the LFS superblock or lfs structure to
1664 1.1 mycroft * keep track of the number of I/O's pending. So, I am
1665 1.1 mycroft * going to stuff the fs into the saveaddr field of
1666 1.1 mycroft * the buffer (yuk).
1667 1.1 mycroft */
1668 1.1 mycroft cbp->b_saveaddr = (caddr_t)fs;
1669 1.1 mycroft vop_strategy_a.a_desc = VDESC(vop_strategy);
1670 1.1 mycroft vop_strategy_a.a_bp = cbp;
1671 1.1 mycroft (strategy)(&vop_strategy_a);
1672 1.1 mycroft }
1673 1.62 perseant #if 1 || defined(DEBUG)
1674 1.1 mycroft /*
1675 1.62 perseant * After doing a big write, we recalculate how many buffers are
1676 1.1 mycroft * really still left on the locked queue.
1677 1.1 mycroft */
1678 1.58 perseant s = splbio();
1679 1.58 perseant lfs_countlocked(&locked_queue_count, &locked_queue_bytes);
1680 1.58 perseant splx(s);
1681 1.1 mycroft wakeup(&locked_queue_count);
1682 1.62 perseant #endif /* 1 || DEBUG */
1683 1.15 perseant if(lfs_dostats) {
1684 1.15 perseant ++lfs_stats.psegwrites;
1685 1.15 perseant lfs_stats.blocktot += nblocks - 1;
1686 1.15 perseant if (fs->lfs_sp->seg_flags & SEGM_SYNC)
1687 1.15 perseant ++lfs_stats.psyncwrites;
1688 1.15 perseant if (fs->lfs_sp->seg_flags & SEGM_CLEAN) {
1689 1.15 perseant ++lfs_stats.pcleanwrites;
1690 1.15 perseant lfs_stats.cleanblocks += nblocks - 1;
1691 1.15 perseant }
1692 1.1 mycroft }
1693 1.1 mycroft return (lfs_initseg(fs) || do_again);
1694 1.1 mycroft }
1695 1.1 mycroft
1696 1.1 mycroft void
1697 1.69 perseant lfs_writesuper(struct lfs *fs, daddr_t daddr)
1698 1.1 mycroft {
1699 1.1 mycroft struct buf *bp;
1700 1.1 mycroft dev_t i_dev;
1701 1.69 perseant int (*strategy)(void *);
1702 1.1 mycroft int s;
1703 1.1 mycroft struct vop_strategy_args vop_strategy_a;
1704 1.1 mycroft
1705 1.15 perseant /*
1706 1.15 perseant * If we can write one superblock while another is in
1707 1.15 perseant * progress, we risk not having a complete checkpoint if we crash.
1708 1.15 perseant * So, block here if a superblock write is in progress.
1709 1.15 perseant */
1710 1.36 perseant s = splbio();
1711 1.15 perseant while(fs->lfs_sbactive) {
1712 1.15 perseant tsleep(&fs->lfs_sbactive, PRIBIO+1, "lfs sb", 0);
1713 1.15 perseant }
1714 1.15 perseant fs->lfs_sbactive = daddr;
1715 1.36 perseant splx(s);
1716 1.1 mycroft i_dev = VTOI(fs->lfs_ivnode)->i_dev;
1717 1.1 mycroft strategy = VTOI(fs->lfs_ivnode)->i_devvp->v_op[VOFFSET(vop_strategy)];
1718 1.1 mycroft
1719 1.15 perseant /* Set timestamp of this version of the superblock */
1720 1.69 perseant if (fs->lfs_version == 1)
1721 1.69 perseant fs->lfs_otstamp = time.tv_sec;
1722 1.15 perseant fs->lfs_tstamp = time.tv_sec;
1723 1.15 perseant
1724 1.1 mycroft /* Checksum the superblock and copy it into a buffer. */
1725 1.12 pk fs->lfs_cksum = lfs_sb_cksum(&(fs->lfs_dlfs));
1726 1.69 perseant bp = lfs_newbuf(fs, VTOI(fs->lfs_ivnode)->i_devvp, fsbtodb(fs, daddr), LFS_SBPAD);
1727 1.12 pk *(struct dlfs *)bp->b_data = fs->lfs_dlfs;
1728 1.15 perseant
1729 1.1 mycroft bp->b_dev = i_dev;
1730 1.1 mycroft bp->b_flags |= B_BUSY | B_CALL | B_ASYNC;
1731 1.1 mycroft bp->b_flags &= ~(B_DONE | B_ERROR | B_READ | B_DELWRI);
1732 1.1 mycroft bp->b_iodone = lfs_supercallback;
1733 1.15 perseant /* XXX KS - same nasty hack as above */
1734 1.15 perseant bp->b_saveaddr = (caddr_t)fs;
1735 1.15 perseant
1736 1.1 mycroft vop_strategy_a.a_desc = VDESC(vop_strategy);
1737 1.1 mycroft vop_strategy_a.a_bp = bp;
1738 1.1 mycroft s = splbio();
1739 1.1 mycroft ++bp->b_vp->v_numoutput;
1740 1.52 perseant ++fs->lfs_iocount;
1741 1.1 mycroft splx(s);
1742 1.1 mycroft (strategy)(&vop_strategy_a);
1743 1.1 mycroft }
1744 1.1 mycroft
1745 1.1 mycroft /*
1746 1.1 mycroft * Logical block number match routines used when traversing the dirty block
1747 1.1 mycroft * chain.
1748 1.1 mycroft */
1749 1.1 mycroft int
1750 1.69 perseant lfs_match_fake(struct lfs *fs, struct buf *bp)
1751 1.15 perseant {
1752 1.19 perseant return (bp->b_flags & B_CALL);
1753 1.15 perseant }
1754 1.15 perseant
1755 1.15 perseant int
1756 1.69 perseant lfs_match_data(struct lfs *fs, struct buf *bp)
1757 1.1 mycroft {
1758 1.1 mycroft return (bp->b_lblkno >= 0);
1759 1.1 mycroft }
1760 1.1 mycroft
1761 1.1 mycroft int
1762 1.69 perseant lfs_match_indir(struct lfs *fs, struct buf *bp)
1763 1.1 mycroft {
1764 1.1 mycroft int lbn;
1765 1.1 mycroft
1766 1.1 mycroft lbn = bp->b_lblkno;
1767 1.1 mycroft return (lbn < 0 && (-lbn - NDADDR) % NINDIR(fs) == 0);
1768 1.1 mycroft }
1769 1.1 mycroft
1770 1.1 mycroft int
1771 1.69 perseant lfs_match_dindir(struct lfs *fs, struct buf *bp)
1772 1.1 mycroft {
1773 1.1 mycroft int lbn;
1774 1.1 mycroft
1775 1.1 mycroft lbn = bp->b_lblkno;
1776 1.1 mycroft return (lbn < 0 && (-lbn - NDADDR) % NINDIR(fs) == 1);
1777 1.1 mycroft }
1778 1.1 mycroft
1779 1.1 mycroft int
1780 1.69 perseant lfs_match_tindir(struct lfs *fs, struct buf *bp)
1781 1.1 mycroft {
1782 1.1 mycroft int lbn;
1783 1.1 mycroft
1784 1.1 mycroft lbn = bp->b_lblkno;
1785 1.1 mycroft return (lbn < 0 && (-lbn - NDADDR) % NINDIR(fs) == 2);
1786 1.1 mycroft }
1787 1.1 mycroft
1788 1.1 mycroft /*
1789 1.15 perseant * XXX - The only buffers that are going to hit these functions are the
1790 1.15 perseant * segment write blocks, or the segment summaries, or the superblocks.
1791 1.15 perseant *
1792 1.15 perseant * All of the above are created by lfs_newbuf, and so do not need to be
1793 1.15 perseant * released via brelse.
1794 1.1 mycroft */
1795 1.1 mycroft void
1796 1.69 perseant lfs_callback(struct buf *bp)
1797 1.1 mycroft {
1798 1.1 mycroft struct lfs *fs;
1799 1.15 perseant #ifdef LFS_TRACK_IOS
1800 1.15 perseant int j;
1801 1.15 perseant #endif
1802 1.1 mycroft
1803 1.1 mycroft fs = (struct lfs *)bp->b_saveaddr;
1804 1.1 mycroft #ifdef DIAGNOSTIC
1805 1.1 mycroft if (fs->lfs_iocount == 0)
1806 1.1 mycroft panic("lfs_callback: zero iocount\n");
1807 1.1 mycroft #endif
1808 1.15 perseant if (--fs->lfs_iocount < LFS_THROTTLE)
1809 1.1 mycroft wakeup(&fs->lfs_iocount);
1810 1.15 perseant #ifdef LFS_TRACK_IOS
1811 1.15 perseant for(j=0;j<LFS_THROTTLE;j++) {
1812 1.69 perseant if(fs->lfs_pending[j]==dbtofsb(fs, bp->b_blkno)) {
1813 1.15 perseant fs->lfs_pending[j] = LFS_UNUSED_DADDR;
1814 1.15 perseant wakeup(&(fs->lfs_pending[j]));
1815 1.15 perseant break;
1816 1.15 perseant }
1817 1.15 perseant }
1818 1.15 perseant #endif /* LFS_TRACK_IOS */
1819 1.1 mycroft
1820 1.15 perseant lfs_freebuf(bp);
1821 1.1 mycroft }
1822 1.1 mycroft
1823 1.1 mycroft void
1824 1.69 perseant lfs_supercallback(struct buf *bp)
1825 1.1 mycroft {
1826 1.15 perseant struct lfs *fs;
1827 1.15 perseant
1828 1.15 perseant fs = (struct lfs *)bp->b_saveaddr;
1829 1.45 thorpej fs->lfs_sbactive = 0;
1830 1.15 perseant wakeup(&fs->lfs_sbactive);
1831 1.52 perseant if (--fs->lfs_iocount < LFS_THROTTLE)
1832 1.52 perseant wakeup(&fs->lfs_iocount);
1833 1.15 perseant lfs_freebuf(bp);
1834 1.1 mycroft }
1835 1.1 mycroft
1836 1.1 mycroft /*
1837 1.1 mycroft * Shellsort (diminishing increment sort) from Data Structures and
1838 1.1 mycroft * Algorithms, Aho, Hopcraft and Ullman, 1983 Edition, page 290;
1839 1.1 mycroft * see also Knuth Vol. 3, page 84. The increments are selected from
1840 1.1 mycroft * formula (8), page 95. Roughly O(N^3/2).
1841 1.1 mycroft */
1842 1.1 mycroft /*
1843 1.1 mycroft * This is our own private copy of shellsort because we want to sort
1844 1.1 mycroft * two parallel arrays (the array of buffer pointers and the array of
1845 1.1 mycroft * logical block numbers) simultaneously. Note that we cast the array
1846 1.1 mycroft * of logical block numbers to a unsigned in this routine so that the
1847 1.1 mycroft * negative block numbers (meta data blocks) sort AFTER the data blocks.
1848 1.1 mycroft */
1849 1.15 perseant
1850 1.1 mycroft void
1851 1.69 perseant lfs_shellsort(struct buf **bp_array, ufs_daddr_t *lb_array, int nmemb)
1852 1.1 mycroft {
1853 1.1 mycroft static int __rsshell_increments[] = { 4, 1, 0 };
1854 1.42 augustss int incr, *incrp, t1, t2;
1855 1.1 mycroft struct buf *bp_temp;
1856 1.1 mycroft u_long lb_temp;
1857 1.1 mycroft
1858 1.4 christos for (incrp = __rsshell_increments; (incr = *incrp++) != 0;)
1859 1.1 mycroft for (t1 = incr; t1 < nmemb; ++t1)
1860 1.1 mycroft for (t2 = t1 - incr; t2 >= 0;)
1861 1.1 mycroft if (lb_array[t2] > lb_array[t2 + incr]) {
1862 1.1 mycroft lb_temp = lb_array[t2];
1863 1.1 mycroft lb_array[t2] = lb_array[t2 + incr];
1864 1.1 mycroft lb_array[t2 + incr] = lb_temp;
1865 1.1 mycroft bp_temp = bp_array[t2];
1866 1.1 mycroft bp_array[t2] = bp_array[t2 + incr];
1867 1.1 mycroft bp_array[t2 + incr] = bp_temp;
1868 1.1 mycroft t2 -= incr;
1869 1.1 mycroft } else
1870 1.1 mycroft break;
1871 1.1 mycroft }
1872 1.1 mycroft
1873 1.1 mycroft /*
1874 1.1 mycroft * Check VXLOCK. Return 1 if the vnode is locked. Otherwise, vget it.
1875 1.1 mycroft */
1876 1.4 christos int
1877 1.69 perseant lfs_vref(struct vnode *vp)
1878 1.1 mycroft {
1879 1.15 perseant /*
1880 1.15 perseant * If we return 1 here during a flush, we risk vinvalbuf() not
1881 1.15 perseant * being able to flush all of the pages from this vnode, which
1882 1.15 perseant * will cause it to panic. So, return 0 if a flush is in progress.
1883 1.15 perseant */
1884 1.15 perseant if (vp->v_flag & VXLOCK) {
1885 1.15 perseant if(IS_FLUSHING(VTOI(vp)->i_lfs,vp)) {
1886 1.15 perseant return 0;
1887 1.15 perseant }
1888 1.1 mycroft return(1);
1889 1.15 perseant }
1890 1.1 mycroft return (vget(vp, 0));
1891 1.1 mycroft }
1892 1.1 mycroft
1893 1.10 fvdl /*
1894 1.10 fvdl * This is vrele except that we do not want to VOP_INACTIVE this vnode. We
1895 1.10 fvdl * inline vrele here to avoid the vn_lock and VOP_INACTIVE call at the end.
1896 1.10 fvdl */
1897 1.1 mycroft void
1898 1.69 perseant lfs_vunref(struct vnode *vp)
1899 1.1 mycroft {
1900 1.17 perseant /*
1901 1.17 perseant * Analogous to lfs_vref, if the node is flushing, fake it.
1902 1.17 perseant */
1903 1.17 perseant if((vp->v_flag & VXLOCK) && IS_FLUSHING(VTOI(vp)->i_lfs,vp)) {
1904 1.17 perseant return;
1905 1.17 perseant }
1906 1.17 perseant
1907 1.10 fvdl simple_lock(&vp->v_interlock);
1908 1.15 perseant #ifdef DIAGNOSTIC
1909 1.17 perseant if(vp->v_usecount<=0) {
1910 1.52 perseant printf("lfs_vunref: inum is %d\n", VTOI(vp)->i_number);
1911 1.69 perseant printf("lfs_vunref: flags are 0x%lx\n", (u_long)vp->v_flag);
1912 1.69 perseant printf("lfs_vunref: usecount = %ld\n", (long)vp->v_usecount);
1913 1.15 perseant panic("lfs_vunref: v_usecount<0");
1914 1.15 perseant }
1915 1.15 perseant #endif
1916 1.10 fvdl vp->v_usecount--;
1917 1.10 fvdl if (vp->v_usecount > 0) {
1918 1.15 perseant simple_unlock(&vp->v_interlock);
1919 1.15 perseant return;
1920 1.15 perseant }
1921 1.15 perseant /*
1922 1.10 fvdl * insert at tail of LRU list
1923 1.1 mycroft */
1924 1.10 fvdl simple_lock(&vnode_free_list_slock);
1925 1.40 perseant if (vp->v_holdcnt > 0)
1926 1.40 perseant TAILQ_INSERT_TAIL(&vnode_hold_list, vp, v_freelist);
1927 1.40 perseant else
1928 1.40 perseant TAILQ_INSERT_TAIL(&vnode_free_list, vp, v_freelist);
1929 1.10 fvdl simple_unlock(&vnode_free_list_slock);
1930 1.10 fvdl simple_unlock(&vp->v_interlock);
1931 1.1 mycroft }
1932 1.15 perseant
1933 1.15 perseant /*
1934 1.15 perseant * We use this when we have vnodes that were loaded in solely for cleaning.
1935 1.15 perseant * There is no reason to believe that these vnodes will be referenced again
1936 1.15 perseant * soon, since the cleaning process is unrelated to normal filesystem
1937 1.15 perseant * activity. Putting cleaned vnodes at the tail of the list has the effect
1938 1.15 perseant * of flushing the vnode LRU. So, put vnodes that were loaded only for
1939 1.15 perseant * cleaning at the head of the list, instead.
1940 1.15 perseant */
1941 1.15 perseant void
1942 1.69 perseant lfs_vunref_head(struct vnode *vp)
1943 1.15 perseant {
1944 1.15 perseant simple_lock(&vp->v_interlock);
1945 1.15 perseant #ifdef DIAGNOSTIC
1946 1.15 perseant if(vp->v_usecount==0) {
1947 1.15 perseant panic("lfs_vunref: v_usecount<0");
1948 1.15 perseant }
1949 1.15 perseant #endif
1950 1.15 perseant vp->v_usecount--;
1951 1.15 perseant if (vp->v_usecount > 0) {
1952 1.15 perseant simple_unlock(&vp->v_interlock);
1953 1.15 perseant return;
1954 1.15 perseant }
1955 1.15 perseant /*
1956 1.15 perseant * insert at head of LRU list
1957 1.15 perseant */
1958 1.15 perseant simple_lock(&vnode_free_list_slock);
1959 1.15 perseant TAILQ_INSERT_HEAD(&vnode_free_list, vp, v_freelist);
1960 1.15 perseant simple_unlock(&vnode_free_list_slock);
1961 1.15 perseant simple_unlock(&vp->v_interlock);
1962 1.15 perseant }
1963 1.15 perseant
1964