fsutil.c revision 247212
166864Sadrian/* 266864Sadrian * Copyright (c) 1980, 1986, 1993 366864Sadrian * The Regents of the University of California. All rights reserved. 466864Sadrian * 566864Sadrian * Redistribution and use in source and binary forms, with or without 666864Sadrian * modification, are permitted provided that the following conditions 766864Sadrian * are met: 866864Sadrian * 1. Redistributions of source code must retain the above copyright 966864Sadrian * notice, this list of conditions and the following disclaimer. 1066864Sadrian * 2. Redistributions in binary form must reproduce the above copyright 1166864Sadrian * notice, this list of conditions and the following disclaimer in the 1266864Sadrian * documentation and/or other materials provided with the distribution. 1366864Sadrian * 4. Neither the name of the University nor the names of its contributors 1466864Sadrian * may be used to endorse or promote products derived from this software 1566864Sadrian * without specific prior written permission. 1666864Sadrian * 1766864Sadrian * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND 1866864Sadrian * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 1966864Sadrian * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 2066864Sadrian * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE 2166864Sadrian * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 2266864Sadrian * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 2366864Sadrian * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 2466864Sadrian * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 2566864Sadrian * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 2666864Sadrian * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 2766864Sadrian * SUCH DAMAGE. 2866864Sadrian */ 2966864Sadrian 30114589Sobrien#if 0 3166864Sadrian#ifndef lint 3266864Sadrianstatic const char sccsid[] = "@(#)utilities.c 8.6 (Berkeley) 5/19/95"; 33114589Sobrien#endif /* not lint */ 3466864Sadrian#endif 35114589Sobrien#include <sys/cdefs.h> 36114589Sobrien__FBSDID("$FreeBSD: head/sbin/fsck_ffs/fsutil.c 247212 2013-02-24 06:44:29Z mckusick $"); 3766864Sadrian 3866864Sadrian#include <sys/param.h> 39107671Siedowse#include <sys/time.h> 4066864Sadrian#include <sys/types.h> 4186514Siedowse#include <sys/sysctl.h> 42221233Sdes#include <sys/disk.h> 4398542Smckusick#include <sys/disklabel.h> 44221233Sdes#include <sys/ioctl.h> 4566864Sadrian#include <sys/stat.h> 4666864Sadrian 4766864Sadrian#include <ufs/ufs/dinode.h> 4866864Sadrian#include <ufs/ufs/dir.h> 4966864Sadrian#include <ufs/ffs/fs.h> 5066864Sadrian 5166864Sadrian#include <err.h> 5266864Sadrian#include <errno.h> 5366864Sadrian#include <string.h> 5466864Sadrian#include <ctype.h> 5566864Sadrian#include <fstab.h> 56101037Smux#include <stdint.h> 5766864Sadrian#include <stdio.h> 5866864Sadrian#include <stdlib.h> 59247212Smckusick#include <time.h> 6066864Sadrian#include <unistd.h> 6166864Sadrian 6266864Sadrian#include "fsck.h" 6366864Sadrian 64107671Siedowsestatic void slowio_start(void); 65107671Siedowsestatic void slowio_end(void); 66247212Smckusickstatic void printIOstats(void); 67107671Siedowse 68247212Smckusickstatic long diskreads, totaldiskreads, totalreads; /* Disk cache statistics */ 69247212Smckusickstatic struct timespec startpass, finishpass; 70107671Siedowsestruct timeval slowio_starttime; 71107671Siedowseint slowio_delay_usec = 10000; /* Initial IO delay for background fsck */ 72107671Siedowseint slowio_pollcnt; 73246812Smckusickstatic TAILQ_HEAD(buflist, bufarea) bufhead; /* head of buffer cache list */ 74246812Smckusickstatic int numbufs; /* size of buffer cache */ 75247212Smckusickstatic char *buftype[BT_NUMBUFTYPES] = BT_NAMES; 7666864Sadrian 7766864Sadrianint 7898542Smckusickftypeok(union dinode *dp) 7966864Sadrian{ 8098542Smckusick switch (DIP(dp, di_mode) & IFMT) { 8166864Sadrian 8266864Sadrian case IFDIR: 8366864Sadrian case IFREG: 8466864Sadrian case IFBLK: 8566864Sadrian case IFCHR: 8666864Sadrian case IFLNK: 8766864Sadrian case IFSOCK: 8866864Sadrian case IFIFO: 8966864Sadrian return (1); 9066864Sadrian 9166864Sadrian default: 9266864Sadrian if (debug) 9398542Smckusick printf("bad file type 0%o\n", DIP(dp, di_mode)); 9466864Sadrian return (0); 9566864Sadrian } 9666864Sadrian} 9766864Sadrian 9866864Sadrianint 99100935Sphkreply(const char *question) 10066864Sadrian{ 10166864Sadrian int persevere; 10266864Sadrian char c; 10366864Sadrian 10466864Sadrian if (preen) 10566864Sadrian pfatal("INTERNAL ERROR: GOT TO reply()"); 10666864Sadrian persevere = !strcmp(question, "CONTINUE"); 10766864Sadrian printf("\n"); 10874556Smckusick if (!persevere && (nflag || (fswritefd < 0 && bkgrdflag == 0))) { 10966864Sadrian printf("%s? no\n\n", question); 11066864Sadrian resolved = 0; 11166864Sadrian return (0); 11266864Sadrian } 11366864Sadrian if (yflag || (persevere && nflag)) { 11466864Sadrian printf("%s? yes\n\n", question); 11566864Sadrian return (1); 11666864Sadrian } 11766864Sadrian do { 11866864Sadrian printf("%s? [yn] ", question); 11966864Sadrian (void) fflush(stdout); 12066864Sadrian c = getc(stdin); 12166864Sadrian while (c != '\n' && getc(stdin) != '\n') { 12266864Sadrian if (feof(stdin)) { 12366864Sadrian resolved = 0; 12466864Sadrian return (0); 12566864Sadrian } 12666864Sadrian } 12766864Sadrian } while (c != 'y' && c != 'Y' && c != 'n' && c != 'N'); 12866864Sadrian printf("\n"); 12966864Sadrian if (c == 'y' || c == 'Y') 13066864Sadrian return (1); 13166864Sadrian resolved = 0; 13266864Sadrian return (0); 13366864Sadrian} 13466864Sadrian 13566864Sadrian/* 13666864Sadrian * Look up state information for an inode. 13766864Sadrian */ 13866864Sadrianstruct inostat * 13992839Simpinoinfo(ino_t inum) 14066864Sadrian{ 14166864Sadrian static struct inostat unallocated = { USTATE, 0, 0 }; 14266864Sadrian struct inostatlist *ilp; 14366864Sadrian int iloff; 14466864Sadrian 14566864Sadrian if (inum > maxino) 146241012Smdf errx(EEXIT, "inoinfo: inumber %ju out of range", 147241012Smdf (uintmax_t)inum); 14866864Sadrian ilp = &inostathead[inum / sblock.fs_ipg]; 14966864Sadrian iloff = inum % sblock.fs_ipg; 15066864Sadrian if (iloff >= ilp->il_numalloced) 15166864Sadrian return (&unallocated); 15266864Sadrian return (&ilp->il_stat[iloff]); 15366864Sadrian} 15466864Sadrian 15566864Sadrian/* 15666864Sadrian * Malloc buffers and set up cache. 15766864Sadrian */ 15866864Sadrianvoid 15992839Simpbufinit(void) 16066864Sadrian{ 16192806Sobrien struct bufarea *bp; 16266864Sadrian long bufcnt, i; 16366864Sadrian char *bufp; 16466864Sadrian 16566864Sadrian pbp = pdirbp = (struct bufarea *)0; 16666864Sadrian bufp = malloc((unsigned int)sblock.fs_bsize); 16766864Sadrian if (bufp == 0) 16866864Sadrian errx(EEXIT, "cannot allocate buffer pool"); 16966864Sadrian cgblk.b_un.b_buf = bufp; 170247212Smckusick initbarea(&cgblk, BT_CYLGRP); 171246812Smckusick TAILQ_INIT(&bufhead); 172246812Smckusick bufcnt = MAXBUFS; 17366864Sadrian if (bufcnt < MINBUFS) 17466864Sadrian bufcnt = MINBUFS; 17566864Sadrian for (i = 0; i < bufcnt; i++) { 17666864Sadrian bp = (struct bufarea *)malloc(sizeof(struct bufarea)); 17766864Sadrian bufp = malloc((unsigned int)sblock.fs_bsize); 17866864Sadrian if (bp == NULL || bufp == NULL) { 17966864Sadrian if (i >= MINBUFS) 18066864Sadrian break; 18166864Sadrian errx(EEXIT, "cannot allocate buffer pool"); 18266864Sadrian } 18366864Sadrian bp->b_un.b_buf = bufp; 184246812Smckusick TAILQ_INSERT_HEAD(&bufhead, bp, b_list); 185247212Smckusick initbarea(bp, BT_UNKNOWN); 18666864Sadrian } 187246812Smckusick numbufs = i; /* save number of buffers */ 188247212Smckusick for (i = 0; i < BT_NUMBUFTYPES; i++) { 189247212Smckusick readtime[i].tv_sec = totalreadtime[i].tv_sec = 0; 190247212Smckusick readtime[i].tv_nsec = totalreadtime[i].tv_nsec = 0; 191247212Smckusick readcnt[i] = totalreadcnt[i] = 0; 192247212Smckusick } 19366864Sadrian} 19466864Sadrian 19566864Sadrian/* 19666864Sadrian * Manage a cache of directory blocks. 19766864Sadrian */ 19866864Sadrianstruct bufarea * 199247212Smckusickgetdatablk(ufs2_daddr_t blkno, long size, int type) 20066864Sadrian{ 20192806Sobrien struct bufarea *bp; 20266864Sadrian 203246812Smckusick TAILQ_FOREACH(bp, &bufhead, b_list) 20466864Sadrian if (bp->b_bno == fsbtodb(&sblock, blkno)) 20566864Sadrian goto foundit; 206246812Smckusick TAILQ_FOREACH_REVERSE(bp, &bufhead, buflist, b_list) 20766864Sadrian if ((bp->b_flags & B_INUSE) == 0) 20866864Sadrian break; 209246812Smckusick if (bp == NULL) 21066864Sadrian errx(EEXIT, "deadlocked buffer pool"); 211247212Smckusick bp->b_type = type; 21266864Sadrian getblk(bp, blkno, size); 21366864Sadrian /* fall through */ 21466864Sadrianfoundit: 215247212Smckusick if (debug && bp->b_type != type) 216247212Smckusick printf("Buffer type changed from %s to %s\n", 217247212Smckusick buftype[bp->b_type], buftype[type]); 218246812Smckusick TAILQ_REMOVE(&bufhead, bp, b_list); 219246812Smckusick TAILQ_INSERT_HEAD(&bufhead, bp, b_list); 22066864Sadrian bp->b_flags |= B_INUSE; 22166864Sadrian return (bp); 22266864Sadrian} 22366864Sadrian 224247212Smckusick/* 225247212Smckusick * Timespec operations (from <sys/time.h>). 226247212Smckusick */ 227247212Smckusick#define timespecsub(vvp, uvp) \ 228247212Smckusick do { \ 229247212Smckusick (vvp)->tv_sec -= (uvp)->tv_sec; \ 230247212Smckusick (vvp)->tv_nsec -= (uvp)->tv_nsec; \ 231247212Smckusick if ((vvp)->tv_nsec < 0) { \ 232247212Smckusick (vvp)->tv_sec--; \ 233247212Smckusick (vvp)->tv_nsec += 1000000000; \ 234247212Smckusick } \ 235247212Smckusick } while (0) 236247212Smckusick#define timespecadd(vvp, uvp) \ 237247212Smckusick do { \ 238247212Smckusick (vvp)->tv_sec += (uvp)->tv_sec; \ 239247212Smckusick (vvp)->tv_nsec += (uvp)->tv_nsec; \ 240247212Smckusick if ((vvp)->tv_nsec >= 1000000000) { \ 241247212Smckusick (vvp)->tv_sec++; \ 242247212Smckusick (vvp)->tv_nsec -= 1000000000; \ 243247212Smckusick } \ 244247212Smckusick } while (0) 245247212Smckusick 24666864Sadrianvoid 24798542Smckusickgetblk(struct bufarea *bp, ufs2_daddr_t blk, long size) 24866864Sadrian{ 24998542Smckusick ufs2_daddr_t dblk; 250247212Smckusick struct timespec start, finish; 25166864Sadrian 25266864Sadrian dblk = fsbtodb(&sblock, blk); 253247212Smckusick if (bp->b_bno == dblk) { 254247212Smckusick totalreads++; 255247212Smckusick } else { 25666864Sadrian flush(fswritefd, bp); 257247212Smckusick if (debug) { 258247212Smckusick readcnt[bp->b_type]++; 259247212Smckusick clock_gettime(CLOCK_REALTIME_PRECISE, &start); 260247212Smckusick } 261163845Spjd bp->b_errs = blread(fsreadfd, bp->b_un.b_buf, dblk, size); 262247212Smckusick if (debug) { 263247212Smckusick clock_gettime(CLOCK_REALTIME_PRECISE, &finish); 264247212Smckusick timespecsub(&finish, &start); 265247212Smckusick timespecadd(&readtime[bp->b_type], &finish); 266247212Smckusick } 26766864Sadrian bp->b_bno = dblk; 26866864Sadrian bp->b_size = size; 26966864Sadrian } 27066864Sadrian} 27166864Sadrian 27266864Sadrianvoid 27392839Simpflush(int fd, struct bufarea *bp) 27466864Sadrian{ 27592806Sobrien int i, j; 27666864Sadrian 27766864Sadrian if (!bp->b_dirty) 27866864Sadrian return; 27974556Smckusick bp->b_dirty = 0; 28074556Smckusick if (fswritefd < 0) { 28174556Smckusick pfatal("WRITING IN READ_ONLY MODE.\n"); 28274556Smckusick return; 28374556Smckusick } 28466864Sadrian if (bp->b_errs != 0) 285100935Sphk pfatal("WRITING %sZERO'ED BLOCK %lld TO DISK\n", 28666864Sadrian (bp->b_errs == bp->b_size / dev_bsize) ? "" : "PARTIALLY ", 287100935Sphk (long long)bp->b_bno); 28866864Sadrian bp->b_errs = 0; 289240406Sobrien blwrite(fd, bp->b_un.b_buf, bp->b_bno, bp->b_size); 29066864Sadrian if (bp != &sblk) 29166864Sadrian return; 29266864Sadrian for (i = 0, j = 0; i < sblock.fs_cssize; i += sblock.fs_bsize, j++) { 293163845Spjd blwrite(fswritefd, (char *)sblock.fs_csp + i, 29466864Sadrian fsbtodb(&sblock, sblock.fs_csaddr + j * sblock.fs_frag), 29566864Sadrian sblock.fs_cssize - i < sblock.fs_bsize ? 29666864Sadrian sblock.fs_cssize - i : sblock.fs_bsize); 29766864Sadrian } 29866864Sadrian} 29966864Sadrian 30074556Smckusickvoid 301100935Sphkrwerror(const char *mesg, ufs2_daddr_t blk) 30266864Sadrian{ 30366864Sadrian 30475927Smckusick if (bkgrdcheck) 30575927Smckusick exit(EEXIT); 30666864Sadrian if (preen == 0) 30766864Sadrian printf("\n"); 30886514Siedowse pfatal("CANNOT %s: %ld", mesg, (long)blk); 30966864Sadrian if (reply("CONTINUE") == 0) 31066864Sadrian exit(EEXIT); 31166864Sadrian} 31266864Sadrian 31366864Sadrianvoid 31492839Simpckfini(int markclean) 31566864Sadrian{ 31692806Sobrien struct bufarea *bp, *nbp; 317246812Smckusick int ofsmodified, cnt; 31866864Sadrian 31974556Smckusick if (bkgrdflag) { 32074556Smckusick unlink(snapname); 32174556Smckusick if ((!(sblock.fs_flags & FS_UNCLEAN)) != markclean) { 32274556Smckusick cmd.value = FS_UNCLEAN; 32374556Smckusick cmd.size = markclean ? -1 : 1; 32474556Smckusick if (sysctlbyname("vfs.ffs.setflags", 0, 0, 32574556Smckusick &cmd, sizeof cmd) == -1) 326118302Sru rwerror("SET FILE SYSTEM FLAGS", FS_UNCLEAN); 32774556Smckusick if (!preen) { 32874556Smckusick printf("\n***** FILE SYSTEM MARKED %s *****\n", 32974556Smckusick markclean ? "CLEAN" : "DIRTY"); 33074556Smckusick if (!markclean) 33174556Smckusick rerun = 1; 33274556Smckusick } 33374556Smckusick } else if (!preen && !markclean) { 33474556Smckusick printf("\n***** FILE SYSTEM STILL DIRTY *****\n"); 33574556Smckusick rerun = 1; 33674556Smckusick } 33774556Smckusick } 338246812Smckusick if (debug && totalreads > 0) 339246812Smckusick printf("cache with %d buffers missed %ld of %ld (%d%%)\n", 340247212Smckusick numbufs, totaldiskreads, totalreads, 341247212Smckusick (int)(totaldiskreads * 100 / totalreads)); 34266864Sadrian if (fswritefd < 0) { 34366864Sadrian (void)close(fsreadfd); 34466864Sadrian return; 34566864Sadrian } 34666864Sadrian flush(fswritefd, &sblk); 34798542Smckusick if (havesb && cursnapshot == 0 && sblock.fs_magic == FS_UFS2_MAGIC && 348107294Smckusick sblk.b_bno != sblock.fs_sblockloc / dev_bsize && 34966864Sadrian !preen && reply("UPDATE STANDARD SUPERBLOCK")) { 350107294Smckusick sblk.b_bno = sblock.fs_sblockloc / dev_bsize; 35166864Sadrian sbdirty(); 35266864Sadrian flush(fswritefd, &sblk); 35366864Sadrian } 35466864Sadrian flush(fswritefd, &cgblk); 35566864Sadrian free(cgblk.b_un.b_buf); 356246812Smckusick cnt = 0; 357246812Smckusick TAILQ_FOREACH_REVERSE_SAFE(bp, &bufhead, buflist, b_list, nbp) { 358246812Smckusick TAILQ_REMOVE(&bufhead, bp, b_list); 35966864Sadrian cnt++; 36066864Sadrian flush(fswritefd, bp); 36166864Sadrian free(bp->b_un.b_buf); 36266864Sadrian free((char *)bp); 36366864Sadrian } 364246812Smckusick if (numbufs != cnt) 365246812Smckusick errx(EEXIT, "panic: lost %d buffers", numbufs - cnt); 36666864Sadrian pbp = pdirbp = (struct bufarea *)0; 36774556Smckusick if (cursnapshot == 0 && sblock.fs_clean != markclean) { 368105436Smckusick if ((sblock.fs_clean = markclean) != 0) { 36975557Smckusick sblock.fs_flags &= ~(FS_UNCLEAN | FS_NEEDSFSCK); 370105436Smckusick sblock.fs_pendingblocks = 0; 371105436Smckusick sblock.fs_pendinginodes = 0; 372105436Smckusick } 37366864Sadrian sbdirty(); 37466864Sadrian ofsmodified = fsmodified; 37566864Sadrian flush(fswritefd, &sblk); 37666864Sadrian fsmodified = ofsmodified; 37766864Sadrian if (!preen) { 37866864Sadrian printf("\n***** FILE SYSTEM MARKED %s *****\n", 37966864Sadrian markclean ? "CLEAN" : "DIRTY"); 38066864Sadrian if (!markclean) 38166864Sadrian rerun = 1; 38266864Sadrian } 383188110Smckusick } else if (!preen) { 384188110Smckusick if (markclean) { 385188110Smckusick printf("\n***** FILE SYSTEM IS CLEAN *****\n"); 386188110Smckusick } else { 387188110Smckusick printf("\n***** FILE SYSTEM STILL DIRTY *****\n"); 388188110Smckusick rerun = 1; 389188110Smckusick } 39066864Sadrian } 39166864Sadrian (void)close(fsreadfd); 39266864Sadrian (void)close(fswritefd); 39366864Sadrian} 39466864Sadrian 395247212Smckusick/* 396247212Smckusick * Print out I/O statistics. 397247212Smckusick */ 398247212Smckusickvoid 399247212SmckusickIOstats(char *what) 400247212Smckusick{ 401247212Smckusick int i; 402247212Smckusick 403247212Smckusick if (debug == 0) 404247212Smckusick return; 405247212Smckusick if (diskreads == 0) { 406247212Smckusick printf("%s: no I/O\n\n", what); 407247212Smckusick return; 408247212Smckusick } 409247212Smckusick if (startpass.tv_sec == 0) 410247212Smckusick startpass = startprog; 411247212Smckusick printf("%s: I/O statistics\n", what); 412247212Smckusick printIOstats(); 413247212Smckusick totaldiskreads += diskreads; 414247212Smckusick diskreads = 0; 415247212Smckusick for (i = 0; i < BT_NUMBUFTYPES; i++) { 416247212Smckusick timespecadd(&totalreadtime[i], &readtime[i]); 417247212Smckusick totalreadcnt[i] += readcnt[i]; 418247212Smckusick readtime[i].tv_sec = readtime[i].tv_nsec = 0; 419247212Smckusick readcnt[i] = 0; 420247212Smckusick } 421247212Smckusick clock_gettime(CLOCK_REALTIME_PRECISE, &startpass); 422247212Smckusick} 423247212Smckusick 424247212Smckusickvoid 425247212SmckusickfinalIOstats(void) 426247212Smckusick{ 427247212Smckusick int i; 428247212Smckusick 429247212Smckusick if (debug == 0) 430247212Smckusick return; 431247212Smckusick printf("Final I/O statistics\n"); 432247212Smckusick totaldiskreads += diskreads; 433247212Smckusick diskreads = totaldiskreads; 434247212Smckusick startpass = startprog; 435247212Smckusick for (i = 0; i < BT_NUMBUFTYPES; i++) { 436247212Smckusick timespecadd(&totalreadtime[i], &readtime[i]); 437247212Smckusick totalreadcnt[i] += readcnt[i]; 438247212Smckusick readtime[i] = totalreadtime[i]; 439247212Smckusick readcnt[i] = totalreadcnt[i]; 440247212Smckusick } 441247212Smckusick printIOstats(); 442247212Smckusick} 443247212Smckusick 444247212Smckusickstatic void printIOstats(void) 445247212Smckusick{ 446247212Smckusick long long msec, totalmsec; 447247212Smckusick int i; 448247212Smckusick 449247212Smckusick clock_gettime(CLOCK_REALTIME_PRECISE, &finishpass); 450247212Smckusick timespecsub(&finishpass, &startpass); 451247212Smckusick printf("Running time: %ld msec\n", 452247212Smckusick finishpass.tv_sec * 1000 + finishpass.tv_nsec / 1000000); 453247212Smckusick printf("buffer reads by type:\n"); 454247212Smckusick for (totalmsec = 0, i = 0; i < BT_NUMBUFTYPES; i++) 455247212Smckusick totalmsec += readtime[i].tv_sec * 1000 + 456247212Smckusick readtime[i].tv_nsec / 1000000; 457247212Smckusick if (totalmsec == 0) 458247212Smckusick totalmsec = 1; 459247212Smckusick for (i = 0; i < BT_NUMBUFTYPES; i++) { 460247212Smckusick if (readcnt[i] == 0) 461247212Smckusick continue; 462247212Smckusick msec = readtime[i].tv_sec * 1000 + readtime[i].tv_nsec / 1000000; 463247212Smckusick printf("%21s:%8ld %2ld.%ld%% %8lld msec %2lld.%lld%%\n", 464247212Smckusick buftype[i], readcnt[i], readcnt[i] * 100 / diskreads, 465247212Smckusick (readcnt[i] * 1000 / diskreads) % 10, msec, 466247212Smckusick msec * 100 / totalmsec, (msec * 1000 / totalmsec) % 10); 467247212Smckusick } 468247212Smckusick printf("\n"); 469247212Smckusick} 470247212Smckusick 47166864Sadrianint 472163845Spjdblread(int fd, char *buf, ufs2_daddr_t blk, long size) 47366864Sadrian{ 47466864Sadrian char *cp; 47566864Sadrian int i, errs; 47666864Sadrian off_t offset; 47766864Sadrian 47866864Sadrian offset = blk; 47966864Sadrian offset *= dev_bsize; 480107671Siedowse if (bkgrdflag) 481107671Siedowse slowio_start(); 482247212Smckusick totalreads++; 483247212Smckusick diskreads++; 48466864Sadrian if (lseek(fd, offset, 0) < 0) 48574556Smckusick rwerror("SEEK BLK", blk); 486107671Siedowse else if (read(fd, buf, (int)size) == size) { 487107671Siedowse if (bkgrdflag) 488107671Siedowse slowio_end(); 48966864Sadrian return (0); 490107671Siedowse } 49174556Smckusick rwerror("READ BLK", blk); 49266864Sadrian if (lseek(fd, offset, 0) < 0) 49374556Smckusick rwerror("SEEK BLK", blk); 49466864Sadrian errs = 0; 49566864Sadrian memset(buf, 0, (size_t)size); 49666864Sadrian printf("THE FOLLOWING DISK SECTORS COULD NOT BE READ:"); 49766864Sadrian for (cp = buf, i = 0; i < size; i += secsize, cp += secsize) { 49866864Sadrian if (read(fd, cp, (int)secsize) != secsize) { 49966864Sadrian (void)lseek(fd, offset + i + secsize, 0); 50066864Sadrian if (secsize != dev_bsize && dev_bsize != 1) 501101037Smux printf(" %jd (%jd),", 502101037Smux (intmax_t)(blk * dev_bsize + i) / secsize, 503101037Smux (intmax_t)blk + i / dev_bsize); 50466864Sadrian else 505101037Smux printf(" %jd,", (intmax_t)blk + i / dev_bsize); 50666864Sadrian errs++; 50766864Sadrian } 50866864Sadrian } 50966864Sadrian printf("\n"); 51066864Sadrian if (errs) 51166864Sadrian resolved = 0; 51266864Sadrian return (errs); 51366864Sadrian} 51466864Sadrian 51566864Sadrianvoid 516240406Sobrienblwrite(int fd, char *buf, ufs2_daddr_t blk, ssize_t size) 51766864Sadrian{ 51866864Sadrian int i; 51966864Sadrian char *cp; 52066864Sadrian off_t offset; 52166864Sadrian 52266864Sadrian if (fd < 0) 52366864Sadrian return; 52466864Sadrian offset = blk; 52566864Sadrian offset *= dev_bsize; 52666864Sadrian if (lseek(fd, offset, 0) < 0) 52774556Smckusick rwerror("SEEK BLK", blk); 528240406Sobrien else if (write(fd, buf, size) == size) { 52966864Sadrian fsmodified = 1; 53066864Sadrian return; 53166864Sadrian } 53266864Sadrian resolved = 0; 53374556Smckusick rwerror("WRITE BLK", blk); 53466864Sadrian if (lseek(fd, offset, 0) < 0) 53574556Smckusick rwerror("SEEK BLK", blk); 53666864Sadrian printf("THE FOLLOWING SECTORS COULD NOT BE WRITTEN:"); 53766864Sadrian for (cp = buf, i = 0; i < size; i += dev_bsize, cp += dev_bsize) 538240406Sobrien if (write(fd, cp, dev_bsize) != dev_bsize) { 53966864Sadrian (void)lseek(fd, offset + i + dev_bsize, 0); 540101037Smux printf(" %jd,", (intmax_t)blk + i / dev_bsize); 54166864Sadrian } 54266864Sadrian printf("\n"); 54366864Sadrian return; 54466864Sadrian} 54566864Sadrian 546221233Sdesvoid 547221233Sdesblerase(int fd, ufs2_daddr_t blk, long size) 548221233Sdes{ 549221233Sdes off_t ioarg[2]; 550221233Sdes 551221233Sdes if (fd < 0) 552221233Sdes return; 553221233Sdes ioarg[0] = blk * dev_bsize; 554221233Sdes ioarg[1] = size; 555221233Sdes ioctl(fd, DIOCGDELETE, ioarg); 556221233Sdes /* we don't really care if we succeed or not */ 557221233Sdes return; 558221233Sdes} 559221233Sdes 56066864Sadrian/* 561188110Smckusick * Verify cylinder group's magic number and other parameters. If the 562188110Smckusick * test fails, offer an option to rebuild the whole cylinder group. 563178088Sdelphij */ 564188110Smckusickint 565178088Sdelphijcheck_cgmagic(int cg, struct cg *cgp) 566178088Sdelphij{ 567178088Sdelphij 568188110Smckusick /* 569188110Smckusick * Extended cylinder group checks. 570188110Smckusick */ 571188110Smckusick if (cg_chkmagic(cgp) && 572188110Smckusick ((sblock.fs_magic == FS_UFS1_MAGIC && 573188110Smckusick cgp->cg_old_niblk == sblock.fs_ipg && 574188110Smckusick cgp->cg_ndblk <= sblock.fs_fpg && 575201700Smckusick cgp->cg_old_ncyl <= sblock.fs_old_cpg) || 576188110Smckusick (sblock.fs_magic == FS_UFS2_MAGIC && 577188110Smckusick cgp->cg_niblk == sblock.fs_ipg && 578188110Smckusick cgp->cg_ndblk <= sblock.fs_fpg && 579188110Smckusick cgp->cg_initediblk <= sblock.fs_ipg))) { 580188110Smckusick return (1); 581178088Sdelphij } 582188110Smckusick pfatal("CYLINDER GROUP %d: BAD MAGIC NUMBER", cg); 583188110Smckusick if (!reply("REBUILD CYLINDER GROUP")) { 584188110Smckusick printf("YOU WILL NEED TO RERUN FSCK.\n"); 585188110Smckusick rerun = 1; 586188110Smckusick return (1); 587188110Smckusick } 588188110Smckusick /* 589188110Smckusick * Zero out the cylinder group and then initialize critical fields. 590188110Smckusick * Bit maps and summaries will be recalculated by later passes. 591188110Smckusick */ 592188110Smckusick memset(cgp, 0, (size_t)sblock.fs_cgsize); 593188110Smckusick cgp->cg_magic = CG_MAGIC; 594188110Smckusick cgp->cg_cgx = cg; 595188110Smckusick cgp->cg_niblk = sblock.fs_ipg; 596188110Smckusick cgp->cg_initediblk = sblock.fs_ipg < 2 * INOPB(&sblock) ? 597188110Smckusick sblock.fs_ipg : 2 * INOPB(&sblock); 598188110Smckusick if (cgbase(&sblock, cg) + sblock.fs_fpg < sblock.fs_size) 599188110Smckusick cgp->cg_ndblk = sblock.fs_fpg; 600188110Smckusick else 601188110Smckusick cgp->cg_ndblk = sblock.fs_size - cgbase(&sblock, cg); 602188110Smckusick cgp->cg_iusedoff = &cgp->cg_space[0] - (u_char *)(&cgp->cg_firstfield); 603188110Smckusick if (sblock.fs_magic == FS_UFS1_MAGIC) { 604188110Smckusick cgp->cg_niblk = 0; 605188110Smckusick cgp->cg_initediblk = 0; 606188110Smckusick cgp->cg_old_ncyl = sblock.fs_old_cpg; 607188110Smckusick cgp->cg_old_niblk = sblock.fs_ipg; 608188110Smckusick cgp->cg_old_btotoff = cgp->cg_iusedoff; 609188110Smckusick cgp->cg_old_boff = cgp->cg_old_btotoff + 610188110Smckusick sblock.fs_old_cpg * sizeof(int32_t); 611188110Smckusick cgp->cg_iusedoff = cgp->cg_old_boff + 612188110Smckusick sblock.fs_old_cpg * sizeof(u_int16_t); 613188110Smckusick } 614188110Smckusick cgp->cg_freeoff = cgp->cg_iusedoff + howmany(sblock.fs_ipg, CHAR_BIT); 615188110Smckusick cgp->cg_nextfreeoff = cgp->cg_freeoff + howmany(sblock.fs_fpg,CHAR_BIT); 616188110Smckusick if (sblock.fs_contigsumsize > 0) { 617188110Smckusick cgp->cg_nclusterblks = cgp->cg_ndblk / sblock.fs_frag; 618188110Smckusick cgp->cg_clustersumoff = 619188110Smckusick roundup(cgp->cg_nextfreeoff, sizeof(u_int32_t)); 620188110Smckusick cgp->cg_clustersumoff -= sizeof(u_int32_t); 621188110Smckusick cgp->cg_clusteroff = cgp->cg_clustersumoff + 622188110Smckusick (sblock.fs_contigsumsize + 1) * sizeof(u_int32_t); 623188110Smckusick cgp->cg_nextfreeoff = cgp->cg_clusteroff + 624188110Smckusick howmany(fragstoblks(&sblock, sblock.fs_fpg), CHAR_BIT); 625188110Smckusick } 626188110Smckusick cgdirty(); 627188110Smckusick return (0); 628178088Sdelphij} 629178088Sdelphij 630178088Sdelphij/* 63166864Sadrian * allocate a data block with the specified number of fragments 63266864Sadrian */ 63398542Smckusickufs2_daddr_t 63492839Simpallocblk(long frags) 63566864Sadrian{ 63666864Sadrian int i, j, k, cg, baseblk; 63766864Sadrian struct cg *cgp = &cgrp; 63866864Sadrian 63966864Sadrian if (frags <= 0 || frags > sblock.fs_frag) 64066864Sadrian return (0); 64166864Sadrian for (i = 0; i < maxfsblock - sblock.fs_frag; i += sblock.fs_frag) { 64266864Sadrian for (j = 0; j <= sblock.fs_frag - frags; j++) { 64366864Sadrian if (testbmap(i + j)) 64466864Sadrian continue; 64566864Sadrian for (k = 1; k < frags; k++) 64666864Sadrian if (testbmap(i + j + k)) 64766864Sadrian break; 64866864Sadrian if (k < frags) { 64966864Sadrian j += k; 65066864Sadrian continue; 65166864Sadrian } 65266864Sadrian cg = dtog(&sblock, i + j); 65366864Sadrian getblk(&cgblk, cgtod(&sblock, cg), sblock.fs_cgsize); 654188110Smckusick if (!check_cgmagic(cg, cgp)) 655188110Smckusick return (0); 65666864Sadrian baseblk = dtogd(&sblock, i + j); 65766864Sadrian for (k = 0; k < frags; k++) { 65866864Sadrian setbmap(i + j + k); 65966864Sadrian clrbit(cg_blksfree(cgp), baseblk + k); 66066864Sadrian } 66166864Sadrian n_blks += frags; 66266864Sadrian if (frags == sblock.fs_frag) 66366864Sadrian cgp->cg_cs.cs_nbfree--; 66466864Sadrian else 66566864Sadrian cgp->cg_cs.cs_nffree -= frags; 66666864Sadrian cgdirty(); 66766864Sadrian return (i + j); 66866864Sadrian } 66966864Sadrian } 67066864Sadrian return (0); 67166864Sadrian} 67266864Sadrian 67366864Sadrian/* 67466864Sadrian * Free a previously allocated block 67566864Sadrian */ 67666864Sadrianvoid 67798542Smckusickfreeblk(ufs2_daddr_t blkno, long frags) 67866864Sadrian{ 67966864Sadrian struct inodesc idesc; 68066864Sadrian 68166864Sadrian idesc.id_blkno = blkno; 68266864Sadrian idesc.id_numfrags = frags; 68366864Sadrian (void)pass4check(&idesc); 68466864Sadrian} 68566864Sadrian 686107671Siedowse/* Slow down IO so as to leave some disk bandwidth for other processes */ 687107671Siedowsevoid 688107671Siedowseslowio_start() 689107671Siedowse{ 690107671Siedowse 691129401Sscottl /* Delay one in every 8 operations */ 692107671Siedowse slowio_pollcnt = (slowio_pollcnt + 1) & 7; 693107671Siedowse if (slowio_pollcnt == 0) { 694107671Siedowse gettimeofday(&slowio_starttime, NULL); 695107671Siedowse } 696107671Siedowse} 697107671Siedowse 698107671Siedowsevoid 699107671Siedowseslowio_end() 700107671Siedowse{ 701107671Siedowse struct timeval tv; 702107671Siedowse int delay_usec; 703107671Siedowse 704107671Siedowse if (slowio_pollcnt != 0) 705107671Siedowse return; 706107671Siedowse 707107671Siedowse /* Update the slowdown interval. */ 708107671Siedowse gettimeofday(&tv, NULL); 709107671Siedowse delay_usec = (tv.tv_sec - slowio_starttime.tv_sec) * 1000000 + 710107671Siedowse (tv.tv_usec - slowio_starttime.tv_usec); 711107671Siedowse if (delay_usec < 64) 712107671Siedowse delay_usec = 64; 713129401Sscottl if (delay_usec > 2500000) 714129401Sscottl delay_usec = 2500000; 715107671Siedowse slowio_delay_usec = (slowio_delay_usec * 63 + delay_usec) >> 6; 716129401Sscottl /* delay by 8 times the average IO delay */ 717129401Sscottl if (slowio_delay_usec > 64) 718129401Sscottl usleep(slowio_delay_usec * 8); 719107671Siedowse} 720107671Siedowse 72166864Sadrian/* 72266864Sadrian * Find a pathname 72366864Sadrian */ 72466864Sadrianvoid 72592839Simpgetpathname(char *namebuf, ino_t curdir, ino_t ino) 72666864Sadrian{ 72766864Sadrian int len; 72892806Sobrien char *cp; 72966864Sadrian struct inodesc idesc; 73066864Sadrian static int busy = 0; 73166864Sadrian 73266864Sadrian if (curdir == ino && ino == ROOTINO) { 73366864Sadrian (void)strcpy(namebuf, "/"); 73466864Sadrian return; 73566864Sadrian } 736136281Struckman if (busy || !INO_IS_DVALID(curdir)) { 73766864Sadrian (void)strcpy(namebuf, "?"); 73866864Sadrian return; 73966864Sadrian } 74066864Sadrian busy = 1; 74166864Sadrian memset(&idesc, 0, sizeof(struct inodesc)); 74266864Sadrian idesc.id_type = DATA; 74366864Sadrian idesc.id_fix = IGNORE; 74466864Sadrian cp = &namebuf[MAXPATHLEN - 1]; 74566864Sadrian *cp = '\0'; 74666864Sadrian if (curdir != ino) { 74766864Sadrian idesc.id_parent = curdir; 74866864Sadrian goto namelookup; 74966864Sadrian } 75066864Sadrian while (ino != ROOTINO) { 75166864Sadrian idesc.id_number = ino; 75266864Sadrian idesc.id_func = findino; 753100935Sphk idesc.id_name = strdup(".."); 75466864Sadrian if ((ckinode(ginode(ino), &idesc) & FOUND) == 0) 75566864Sadrian break; 75666864Sadrian namelookup: 75766864Sadrian idesc.id_number = idesc.id_parent; 75866864Sadrian idesc.id_parent = ino; 75966864Sadrian idesc.id_func = findname; 76066864Sadrian idesc.id_name = namebuf; 76166864Sadrian if ((ckinode(ginode(idesc.id_number), &idesc)&FOUND) == 0) 76266864Sadrian break; 76366864Sadrian len = strlen(namebuf); 76466864Sadrian cp -= len; 76566864Sadrian memmove(cp, namebuf, (size_t)len); 76666864Sadrian *--cp = '/'; 76766864Sadrian if (cp < &namebuf[MAXNAMLEN]) 76866864Sadrian break; 76966864Sadrian ino = idesc.id_number; 77066864Sadrian } 77166864Sadrian busy = 0; 77266864Sadrian if (ino != ROOTINO) 77366864Sadrian *--cp = '?'; 77466864Sadrian memmove(namebuf, cp, (size_t)(&namebuf[MAXPATHLEN] - cp)); 77566864Sadrian} 77666864Sadrian 77766864Sadrianvoid 778100935Sphkcatch(int sig __unused) 77966864Sadrian{ 78096483Sphk 78196483Sphk ckfini(0); 78266864Sadrian exit(12); 78366864Sadrian} 78466864Sadrian 78566864Sadrian/* 78666864Sadrian * When preening, allow a single quit to signal 787102231Strhodes * a special exit after file system checks complete 78866864Sadrian * so that reboot sequence may be interrupted. 78966864Sadrian */ 79066864Sadrianvoid 791100935Sphkcatchquit(int sig __unused) 79266864Sadrian{ 793102231Strhodes printf("returning to single-user after file system check\n"); 79466864Sadrian returntosingle = 1; 79566864Sadrian (void)signal(SIGQUIT, SIG_DFL); 79666864Sadrian} 79766864Sadrian 79866864Sadrian/* 79966864Sadrian * determine whether an inode should be fixed. 80066864Sadrian */ 80166864Sadrianint 802100935Sphkdofix(struct inodesc *idesc, const char *msg) 80366864Sadrian{ 80466864Sadrian 80566864Sadrian switch (idesc->id_fix) { 80666864Sadrian 80766864Sadrian case DONTKNOW: 80866864Sadrian if (idesc->id_type == DATA) 80966864Sadrian direrror(idesc->id_number, msg); 81066864Sadrian else 81181911Skris pwarn("%s", msg); 81266864Sadrian if (preen) { 81366864Sadrian printf(" (SALVAGED)\n"); 81466864Sadrian idesc->id_fix = FIX; 81566864Sadrian return (ALTERED); 81666864Sadrian } 81766864Sadrian if (reply("SALVAGE") == 0) { 81866864Sadrian idesc->id_fix = NOFIX; 81966864Sadrian return (0); 82066864Sadrian } 82166864Sadrian idesc->id_fix = FIX; 82266864Sadrian return (ALTERED); 82366864Sadrian 82466864Sadrian case FIX: 82566864Sadrian return (ALTERED); 82666864Sadrian 82766864Sadrian case NOFIX: 82866864Sadrian case IGNORE: 82966864Sadrian return (0); 83066864Sadrian 83166864Sadrian default: 83266864Sadrian errx(EEXIT, "UNKNOWN INODESC FIX MODE %d", idesc->id_fix); 83366864Sadrian } 83466864Sadrian /* NOTREACHED */ 83566864Sadrian return (0); 83666864Sadrian} 83766864Sadrian 83866864Sadrian#include <stdarg.h> 83966864Sadrian 84066864Sadrian/* 841229778Suqs * An unexpected inconsistency occurred. 842102231Strhodes * Die if preening or file system is running with soft dependency protocol, 84366864Sadrian * otherwise just print message and continue. 84466864Sadrian */ 84566864Sadrianvoid 84666864Sadrianpfatal(const char *fmt, ...) 84766864Sadrian{ 84866864Sadrian va_list ap; 84966864Sadrian va_start(ap, fmt); 85066864Sadrian if (!preen) { 85175927Smckusick (void)vfprintf(stdout, fmt, ap); 85266864Sadrian va_end(ap); 85366864Sadrian if (usedsoftdep) 85475927Smckusick (void)fprintf(stdout, 85566864Sadrian "\nUNEXPECTED SOFT UPDATE INCONSISTENCY\n"); 85675557Smckusick /* 85775557Smckusick * Force foreground fsck to clean up inconsistency. 85875557Smckusick */ 85975557Smckusick if (bkgrdflag) { 86075557Smckusick cmd.value = FS_NEEDSFSCK; 86175557Smckusick cmd.size = 1; 86275557Smckusick if (sysctlbyname("vfs.ffs.setflags", 0, 0, 86375557Smckusick &cmd, sizeof cmd) == -1) 86475557Smckusick pwarn("CANNOT SET FS_NEEDSFSCK FLAG\n"); 86575927Smckusick fprintf(stdout, "CANNOT RUN IN BACKGROUND\n"); 86675557Smckusick ckfini(0); 86775557Smckusick exit(EEXIT); 86875557Smckusick } 86966864Sadrian return; 87066864Sadrian } 87166864Sadrian if (cdevname == NULL) 872100935Sphk cdevname = strdup("fsck"); 87375927Smckusick (void)fprintf(stdout, "%s: ", cdevname); 87475927Smckusick (void)vfprintf(stdout, fmt, ap); 87575927Smckusick (void)fprintf(stdout, 87666864Sadrian "\n%s: UNEXPECTED%sINCONSISTENCY; RUN fsck MANUALLY.\n", 87766864Sadrian cdevname, usedsoftdep ? " SOFT UPDATE " : " "); 87875557Smckusick /* 87975557Smckusick * Force foreground fsck to clean up inconsistency. 88075557Smckusick */ 88175557Smckusick if (bkgrdflag) { 88275557Smckusick cmd.value = FS_NEEDSFSCK; 88375557Smckusick cmd.size = 1; 88475557Smckusick if (sysctlbyname("vfs.ffs.setflags", 0, 0, 88575557Smckusick &cmd, sizeof cmd) == -1) 88675557Smckusick pwarn("CANNOT SET FS_NEEDSFSCK FLAG\n"); 88775557Smckusick } 88866864Sadrian ckfini(0); 88966864Sadrian exit(EEXIT); 89066864Sadrian} 89166864Sadrian 89266864Sadrian/* 89366864Sadrian * Pwarn just prints a message when not preening or running soft dependency 89466864Sadrian * protocol, or a warning (preceded by filename) when preening. 89566864Sadrian */ 89666864Sadrianvoid 89766864Sadrianpwarn(const char *fmt, ...) 89866864Sadrian{ 89966864Sadrian va_list ap; 90066864Sadrian va_start(ap, fmt); 90166864Sadrian if (preen) 90275927Smckusick (void)fprintf(stdout, "%s: ", cdevname); 90375927Smckusick (void)vfprintf(stdout, fmt, ap); 90466864Sadrian va_end(ap); 90566864Sadrian} 90666864Sadrian 90766864Sadrian/* 90866864Sadrian * Stub for routines from kernel. 90966864Sadrian */ 91066864Sadrianvoid 91166864Sadrianpanic(const char *fmt, ...) 91266864Sadrian{ 91366864Sadrian va_list ap; 91466864Sadrian va_start(ap, fmt); 91566864Sadrian pfatal("INTERNAL INCONSISTENCY:"); 91675927Smckusick (void)vfprintf(stdout, fmt, ap); 91766864Sadrian va_end(ap); 91866864Sadrian exit(EEXIT); 91966864Sadrian} 920