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