1 /*
2 * CDDL HEADER START
3 *
4 * The contents of this file are subject to the terms of the
5 * Common Development and Distribution License (the "License").
6 * You may not use this file except in compliance with the License.
7 *
8 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
9 * or http://www.opensolaris.org/os/licensing.
10 * See the License for the specific language governing permissions
11 * and limitations under the License.
12 *
13 * When distributing Covered Code, include this CDDL HEADER in each
14 * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
15 * If applicable, add the following below this CDDL HEADER, with the
16 * fields enclosed by brackets "[]" replaced with your own identifying
17 * information: Portions Copyright [yyyy] [name of copyright owner]
18 *
19 * CDDL HEADER END
20 */
21 /* Copyright (c) 1984, 1986, 1987, 1988, 1989 AT&T */
22 /* All Rights Reserved */
23
24
25 /*
26 * Copyright 2009 Sun Microsystems, Inc. All rights reserved.
27 * Use is subject to license terms.
28 */
29
30 #include <sys/types.h>
31 #include <sys/t_lock.h>
32 #include <sys/param.h>
33 #include <sys/tuneable.h>
34 #include <sys/inline.h>
35 #include <sys/systm.h>
36 #include <sys/proc.h>
37 #include <sys/user.h>
38 #include <sys/var.h>
39 #include <sys/buf.h>
40 #include <sys/vfs.h>
41 #include <sys/cred.h>
42 #include <sys/kmem.h>
43 #include <sys/vnode.h>
44 #include <sys/swap.h>
45 #include <sys/vm.h>
46 #include <sys/debug.h>
47 #include <sys/cmn_err.h>
48 #include <sys/sysinfo.h>
49 #include <sys/callb.h>
50 #include <sys/reboot.h>
51 #include <sys/time.h>
52 #include <sys/fs/ufs_inode.h>
53 #include <sys/fs/ufs_bio.h>
54
55 #include <vm/hat.h>
56 #include <vm/page.h>
57 #include <vm/pvn.h>
58 #include <vm/seg_kmem.h>
59
60 int doiflush = 1; /* non-zero to turn inode flushing on */
61 int dopageflush = 1; /* non-zero to turn page flushing on */
62
63 /*
64 * To improve boot performance, don't run the inode flushing loop until
65 * the specified number of seconds after boot. To revert to the old
66 * behavior, set fsflush_iflush_delay to 0. We have not created any new
67 * filesystem danger that did not exist previously, since there is always a
68 * window in between when fsflush does the inode flush loop during which the
69 * system could crash, fail to sync the filesystem, and fsck will be needed
70 * to recover. We have, however, widened this window. Finally,
71 * we never delay inode flushing if we're booting into single user mode,
72 * where the administrator may be modifying files or using fsck. This
73 * modification avoids inode flushes during boot whose only purpose is to
74 * update atimes on files which have been accessed during boot.
75 */
76 int fsflush_iflush_delay = 60;
77
78 kcondvar_t fsflush_cv;
79 static kmutex_t fsflush_lock; /* just for the cv_wait */
80 ksema_t fsflush_sema; /* to serialize with reboot */
81
82 /*
83 * some statistics for fsflush_do_pages
84 */
85 typedef struct {
86 ulong_t fsf_scan; /* number of pages scanned */
87 ulong_t fsf_examined; /* number of page_t's actually examined, can */
88 /* be less than fsf_scan due to large pages */
89 ulong_t fsf_locked; /* pages we actually page_lock()ed */
90 ulong_t fsf_modified; /* number of modified pages found */
91 ulong_t fsf_coalesce; /* number of page coalesces done */
92 ulong_t fsf_time; /* nanoseconds of run time */
93 ulong_t fsf_releases; /* number of page_release() done */
94 } fsf_stat_t;
95
96 fsf_stat_t fsf_recent; /* counts for most recent duty cycle */
97 fsf_stat_t fsf_total; /* total of counts */
98 ulong_t fsf_cycles; /* number of runs refelected in fsf_total */
99
100 /*
101 * data used to determine when we can coalesce consecutive free pages
102 * into larger pages.
103 */
104 #define MAX_PAGESIZES 32
105 static ulong_t fsf_npgsz;
106 static pgcnt_t fsf_pgcnt[MAX_PAGESIZES];
107 static pgcnt_t fsf_mask[MAX_PAGESIZES];
108
109
110 /*
111 * Scan page_t's and issue I/O's for modified pages.
112 *
113 * Also coalesces consecutive small sized free pages into the next larger
114 * pagesize. This costs a tiny bit of time in fsflush, but will reduce time
115 * spent scanning on later passes and for anybody allocating large pages.
116 */
117 static void
fsflush_do_pages()118 fsflush_do_pages()
119 {
120 vnode_t *vp;
121 ulong_t pcount;
122 hrtime_t timer = gethrtime();
123 ulong_t releases = 0;
124 ulong_t nexamined = 0;
125 ulong_t nlocked = 0;
126 ulong_t nmodified = 0;
127 ulong_t ncoalesce = 0;
128 ulong_t cnt;
129 int mod;
130 int fspage = 1;
131 u_offset_t offset;
132 uint_t szc;
133
134 page_t *coal_page = NULL; /* 1st page in group to coalesce */
135 uint_t coal_szc = 0; /* size code, coal_page->p_szc */
136 uint_t coal_cnt = 0; /* count of pages seen */
137
138 static ulong_t nscan = 0;
139 static pgcnt_t last_total_pages = 0;
140 static page_t *pp = NULL;
141
142 /*
143 * Check to see if total_pages has changed.
144 */
145 if (total_pages != last_total_pages) {
146 last_total_pages = total_pages;
147 nscan = (last_total_pages * (tune.t_fsflushr))/v.v_autoup;
148 }
149
150 if (pp == NULL)
151 pp = memsegs->pages;
152
153 pcount = 0;
154 while (pcount < nscan) {
155
156 /*
157 * move to the next page, skipping over large pages
158 * and issuing prefetches.
159 */
160 if (pp->p_szc && fspage == 0) {
161 pfn_t pfn;
162
163 pfn = page_pptonum(pp);
164 cnt = page_get_pagecnt(pp->p_szc);
165 cnt -= pfn & (cnt - 1);
166 } else
167 cnt = 1;
168
169 pp = page_nextn(pp, cnt);
170 prefetch_page_r((void *)pp);
171 ASSERT(pp != NULL);
172 pcount += cnt;
173
174 /*
175 * Do a bunch of dirty tests (ie. no locking) to determine
176 * if we can quickly skip this page. These tests are repeated
177 * after acquiring the page lock.
178 */
179 ++nexamined;
180 if (PP_ISSWAP(pp)) {
181 fspage = 0;
182 coal_page = NULL;
183 continue;
184 }
185
186 /*
187 * skip free pages too, but try coalescing them into larger
188 * pagesizes
189 */
190 if (PP_ISFREE(pp)) {
191 /*
192 * skip pages with a file system identity or that
193 * are already maximum size
194 */
195 fspage = 0;
196 szc = pp->p_szc;
197 if (pp->p_vnode != NULL || szc == fsf_npgsz - 1) {
198 coal_page = NULL;
199 continue;
200 }
201
202 /*
203 * If not in a coalescing candidate page or the size
204 * codes are different, start a new candidate.
205 */
206 if (coal_page == NULL || coal_szc != szc) {
207
208 /*
209 * page must be properly aligned
210 */
211 if ((page_pptonum(pp) & fsf_mask[szc]) != 0) {
212 coal_page = NULL;
213 continue;
214 }
215 coal_page = pp;
216 coal_szc = szc;
217 coal_cnt = 1;
218 continue;
219 }
220
221 /*
222 * acceptable to add this to existing candidate page
223 */
224 ++coal_cnt;
225 if (coal_cnt < fsf_pgcnt[coal_szc])
226 continue;
227
228 /*
229 * We've got enough pages to coalesce, so do it.
230 * After promoting, we clear coal_page, so it will
231 * take another pass to promote this to an even
232 * larger page.
233 */
234 ++ncoalesce;
235 (void) page_promote_size(coal_page, coal_szc);
236 coal_page = NULL;
237 continue;
238 } else {
239 coal_page = NULL;
240 }
241
242 if (PP_ISKAS(pp) ||
243 PAGE_LOCKED(pp) ||
244 pp->p_lckcnt != 0 ||
245 pp->p_cowcnt != 0) {
246 fspage = 0;
247 continue;
248 }
249
250
251 /*
252 * Reject pages that can't be "exclusively" locked.
253 */
254 if (!page_trylock(pp, SE_EXCL))
255 continue;
256 ++nlocked;
257
258
259 /*
260 * After locking the page, redo the above checks.
261 * Since we locked the page, leave out the PAGE_LOCKED() test.
262 */
263 vp = pp->p_vnode;
264 if (PP_ISSWAP(pp) ||
265 PP_ISFREE(pp) ||
266 vp == NULL ||
267 PP_ISKAS(pp) ||
268 (vp->v_flag & VISSWAP) != 0) {
269 page_unlock(pp);
270 fspage = 0;
271 continue;
272 }
273 if (pp->p_lckcnt != 0 || pp->p_cowcnt != 0) {
274 page_unlock(pp);
275 continue;
276 }
277
278 fspage = 1;
279 ASSERT(vp->v_type != VCHR);
280
281 /*
282 * Check the modified bit. Leaving the bit alone in hardware.
283 * It will be cleared if we do the putpage.
284 */
285 if (IS_VMODSORT(vp))
286 mod = hat_ismod(pp);
287 else
288 mod = hat_pagesync(pp,
289 HAT_SYNC_DONTZERO | HAT_SYNC_STOPON_MOD) & P_MOD;
290
291 if (mod) {
292 ++nmodified;
293 offset = pp->p_offset;
294
295 /*
296 * Hold the vnode before releasing the page lock
297 * to prevent it from being freed and re-used by
298 * some other thread.
299 */
300 VN_HOLD(vp);
301
302 page_unlock(pp);
303
304 (void) VOP_PUTPAGE(vp, offset, PAGESIZE, B_ASYNC,
305 kcred, NULL);
306
307 VN_RELE(vp);
308 } else {
309
310 /*
311 * Catch any pages which should be on the cache list,
312 * but aren't yet.
313 */
314 if (hat_page_is_mapped(pp) == 0) {
315 ++releases;
316 (void) page_release(pp, 1);
317 } else {
318 page_unlock(pp);
319 }
320 }
321 }
322
323 /*
324 * maintain statistics
325 * reset every million wakeups, just to avoid overflow
326 */
327 if (++fsf_cycles == 1000000) {
328 fsf_cycles = 0;
329 fsf_total.fsf_scan = 0;
330 fsf_total.fsf_examined = 0;
331 fsf_total.fsf_locked = 0;
332 fsf_total.fsf_modified = 0;
333 fsf_total.fsf_coalesce = 0;
334 fsf_total.fsf_time = 0;
335 fsf_total.fsf_releases = 0;
336 } else {
337 fsf_total.fsf_scan += fsf_recent.fsf_scan = nscan;
338 fsf_total.fsf_examined += fsf_recent.fsf_examined = nexamined;
339 fsf_total.fsf_locked += fsf_recent.fsf_locked = nlocked;
340 fsf_total.fsf_modified += fsf_recent.fsf_modified = nmodified;
341 fsf_total.fsf_coalesce += fsf_recent.fsf_coalesce = ncoalesce;
342 fsf_total.fsf_time += fsf_recent.fsf_time = gethrtime() - timer;
343 fsf_total.fsf_releases += fsf_recent.fsf_releases = releases;
344 }
345 }
346
347 /*
348 * As part of file system hardening, this daemon is awakened
349 * every second to flush cached data which includes the
350 * buffer cache, the inode cache and mapped pages.
351 */
352 void
fsflush()353 fsflush()
354 {
355 struct buf *bp, *dwp;
356 struct hbuf *hp;
357 int autoup;
358 unsigned int ix, icount, count = 0;
359 callb_cpr_t cprinfo;
360 uint_t bcount;
361 kmutex_t *hmp;
362 struct vfssw *vswp;
363
364 proc_fsflush = ttoproc(curthread);
365 proc_fsflush->p_cstime = 0;
366 proc_fsflush->p_stime = 0;
367 proc_fsflush->p_cutime = 0;
368 proc_fsflush->p_utime = 0;
369 bcopy("fsflush", curproc->p_user.u_psargs, 8);
370 bcopy("fsflush", curproc->p_user.u_comm, 7);
371
372 mutex_init(&fsflush_lock, NULL, MUTEX_DEFAULT, NULL);
373 sema_init(&fsflush_sema, 0, NULL, SEMA_DEFAULT, NULL);
374
375 /*
376 * Setup page coalescing.
377 */
378 fsf_npgsz = page_num_pagesizes();
379 ASSERT(fsf_npgsz < MAX_PAGESIZES);
380 for (ix = 0; ix < fsf_npgsz - 1; ++ix) {
381 fsf_pgcnt[ix] =
382 page_get_pagesize(ix + 1) / page_get_pagesize(ix);
383 fsf_mask[ix] = page_get_pagecnt(ix + 1) - 1;
384 }
385
386 autoup = v.v_autoup * hz;
387 icount = v.v_autoup / tune.t_fsflushr;
388 CALLB_CPR_INIT(&cprinfo, &fsflush_lock, callb_generic_cpr, "fsflush");
389 loop:
390 sema_v(&fsflush_sema);
391 mutex_enter(&fsflush_lock);
392 CALLB_CPR_SAFE_BEGIN(&cprinfo);
393 cv_wait(&fsflush_cv, &fsflush_lock); /* wait for clock */
394 CALLB_CPR_SAFE_END(&cprinfo, &fsflush_lock);
395 mutex_exit(&fsflush_lock);
396 sema_p(&fsflush_sema);
397
398 /*
399 * Write back all old B_DELWRI buffers on the freelist.
400 */
401 bcount = 0;
402 for (ix = 0; ix < v.v_hbuf; ix++) {
403
404 hp = &hbuf[ix];
405 dwp = (struct buf *)&dwbuf[ix];
406
407 bcount += (hp->b_length);
408
409 if (dwp->av_forw == dwp) {
410 continue;
411 }
412
413 hmp = &hbuf[ix].b_lock;
414 mutex_enter(hmp);
415 bp = dwp->av_forw;
416
417 /*
418 * Go down only on the delayed write lists.
419 */
420 while (bp != dwp) {
421
422 ASSERT(bp->b_flags & B_DELWRI);
423
424 if ((bp->b_flags & B_DELWRI) &&
425 (ddi_get_lbolt() - bp->b_start >= autoup) &&
426 sema_tryp(&bp->b_sem)) {
427 bp->b_flags |= B_ASYNC;
428 hp->b_length--;
429 notavail(bp);
430 mutex_exit(hmp);
431 if (bp->b_vp == NULL) {
432 BWRITE(bp);
433 } else {
434 UFS_BWRITE(VTOI(bp->b_vp)->i_ufsvfs,
435 bp);
436 }
437 mutex_enter(hmp);
438 bp = dwp->av_forw;
439 } else {
440 bp = bp->av_forw;
441 }
442 }
443 mutex_exit(hmp);
444 }
445
446 /*
447 *
448 * There is no need to wakeup any thread waiting on bio_mem_cv
449 * since brelse will wake them up as soon as IO is complete.
450 */
451 bfreelist.b_bcount = bcount;
452
453 if (dopageflush)
454 fsflush_do_pages();
455
456 if (!doiflush)
457 goto loop;
458
459 /*
460 * If the system was not booted to single user mode, skip the
461 * inode flushing until after fsflush_iflush_delay secs have elapsed.
462 */
463 if ((boothowto & RB_SINGLE) == 0 &&
464 (ddi_get_lbolt64() / hz) < fsflush_iflush_delay)
465 goto loop;
466
467 /*
468 * Flush cached attribute information (e.g. inodes).
469 */
470 if (++count >= icount) {
471 count = 0;
472
473 /*
474 * Sync back cached data.
475 */
476 RLOCK_VFSSW();
477 for (vswp = &vfssw[1]; vswp < &vfssw[nfstype]; vswp++) {
478 if (ALLOCATED_VFSSW(vswp) && VFS_INSTALLED(vswp)) {
479 vfs_refvfssw(vswp);
480 RUNLOCK_VFSSW();
481 (void) fsop_sync_by_kind(vswp - vfssw,
482 SYNC_ATTR, kcred);
483 vfs_unrefvfssw(vswp);
484 RLOCK_VFSSW();
485 }
486 }
487 RUNLOCK_VFSSW();
488 }
489 goto loop;
490 }
491