fsutil.c revision 118302
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 * 3. All advertising materials mentioning features or use of this software 1466864Sadrian * must display the following acknowledgement: 1566864Sadrian * This product includes software developed by the University of 1666864Sadrian * California, Berkeley and its contributors. 1766864Sadrian * 4. Neither the name of the University nor the names of its contributors 1866864Sadrian * may be used to endorse or promote products derived from this software 1966864Sadrian * without specific prior written permission. 2066864Sadrian * 2166864Sadrian * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND 2266864Sadrian * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 2366864Sadrian * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 2466864Sadrian * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE 2566864Sadrian * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 2666864Sadrian * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 2766864Sadrian * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 2866864Sadrian * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 2966864Sadrian * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 3066864Sadrian * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 3166864Sadrian * SUCH DAMAGE. 3266864Sadrian */ 3366864Sadrian 34114589Sobrien#if 0 3566864Sadrian#ifndef lint 3666864Sadrianstatic const char sccsid[] = "@(#)utilities.c 8.6 (Berkeley) 5/19/95"; 37114589Sobrien#endif /* not lint */ 3866864Sadrian#endif 39114589Sobrien#include <sys/cdefs.h> 40114589Sobrien__FBSDID("$FreeBSD: head/sbin/fsck_ffs/fsutil.c 118302 2003-08-01 11:31:19Z ru $"); 4166864Sadrian 4266864Sadrian#include <sys/param.h> 43107671Siedowse#include <sys/time.h> 4466864Sadrian#include <sys/types.h> 4586514Siedowse#include <sys/sysctl.h> 4698542Smckusick#include <sys/disklabel.h> 4766864Sadrian#include <sys/stat.h> 4896475Sphk#include <sys/disklabel.h> 4966864Sadrian 5066864Sadrian#include <ufs/ufs/dinode.h> 5166864Sadrian#include <ufs/ufs/dir.h> 5266864Sadrian#include <ufs/ffs/fs.h> 5366864Sadrian 5466864Sadrian#include <err.h> 5566864Sadrian#include <errno.h> 5666864Sadrian#include <string.h> 5766864Sadrian#include <ctype.h> 5866864Sadrian#include <fstab.h> 59101037Smux#include <stdint.h> 6066864Sadrian#include <stdio.h> 6166864Sadrian#include <stdlib.h> 6266864Sadrian#include <unistd.h> 6366864Sadrian 6466864Sadrian#include "fsck.h" 6566864Sadrian 66107671Siedowsestatic void slowio_start(void); 67107671Siedowsestatic void slowio_end(void); 68107671Siedowse 6966864Sadrianlong diskreads, totalreads; /* Disk cache statistics */ 70107671Siedowsestruct timeval slowio_starttime; 71107671Siedowseint slowio_delay_usec = 10000; /* Initial IO delay for background fsck */ 72107671Siedowseint slowio_pollcnt; 7366864Sadrian 7466864Sadrianint 7598542Smckusickftypeok(union dinode *dp) 7666864Sadrian{ 7798542Smckusick switch (DIP(dp, di_mode) & IFMT) { 7866864Sadrian 7966864Sadrian case IFDIR: 8066864Sadrian case IFREG: 8166864Sadrian case IFBLK: 8266864Sadrian case IFCHR: 8366864Sadrian case IFLNK: 8466864Sadrian case IFSOCK: 8566864Sadrian case IFIFO: 8666864Sadrian return (1); 8766864Sadrian 8866864Sadrian default: 8966864Sadrian if (debug) 9098542Smckusick printf("bad file type 0%o\n", DIP(dp, di_mode)); 9166864Sadrian return (0); 9266864Sadrian } 9366864Sadrian} 9466864Sadrian 9566864Sadrianint 96100935Sphkreply(const char *question) 9766864Sadrian{ 9866864Sadrian int persevere; 9966864Sadrian char c; 10066864Sadrian 10166864Sadrian if (preen) 10266864Sadrian pfatal("INTERNAL ERROR: GOT TO reply()"); 10366864Sadrian persevere = !strcmp(question, "CONTINUE"); 10466864Sadrian printf("\n"); 10574556Smckusick if (!persevere && (nflag || (fswritefd < 0 && bkgrdflag == 0))) { 10666864Sadrian printf("%s? no\n\n", question); 10766864Sadrian resolved = 0; 10866864Sadrian return (0); 10966864Sadrian } 11066864Sadrian if (yflag || (persevere && nflag)) { 11166864Sadrian printf("%s? yes\n\n", question); 11266864Sadrian return (1); 11366864Sadrian } 11466864Sadrian do { 11566864Sadrian printf("%s? [yn] ", question); 11666864Sadrian (void) fflush(stdout); 11766864Sadrian c = getc(stdin); 11866864Sadrian while (c != '\n' && getc(stdin) != '\n') { 11966864Sadrian if (feof(stdin)) { 12066864Sadrian resolved = 0; 12166864Sadrian return (0); 12266864Sadrian } 12366864Sadrian } 12466864Sadrian } while (c != 'y' && c != 'Y' && c != 'n' && c != 'N'); 12566864Sadrian printf("\n"); 12666864Sadrian if (c == 'y' || c == 'Y') 12766864Sadrian return (1); 12866864Sadrian resolved = 0; 12966864Sadrian return (0); 13066864Sadrian} 13166864Sadrian 13266864Sadrian/* 13366864Sadrian * Look up state information for an inode. 13466864Sadrian */ 13566864Sadrianstruct inostat * 13692839Simpinoinfo(ino_t inum) 13766864Sadrian{ 13866864Sadrian static struct inostat unallocated = { USTATE, 0, 0 }; 13966864Sadrian struct inostatlist *ilp; 14066864Sadrian int iloff; 14166864Sadrian 14266864Sadrian if (inum > maxino) 14366864Sadrian errx(EEXIT, "inoinfo: inumber %d out of range", inum); 14466864Sadrian ilp = &inostathead[inum / sblock.fs_ipg]; 14566864Sadrian iloff = inum % sblock.fs_ipg; 14666864Sadrian if (iloff >= ilp->il_numalloced) 14766864Sadrian return (&unallocated); 14866864Sadrian return (&ilp->il_stat[iloff]); 14966864Sadrian} 15066864Sadrian 15166864Sadrian/* 15266864Sadrian * Malloc buffers and set up cache. 15366864Sadrian */ 15466864Sadrianvoid 15592839Simpbufinit(void) 15666864Sadrian{ 15792806Sobrien struct bufarea *bp; 15866864Sadrian long bufcnt, i; 15966864Sadrian char *bufp; 16066864Sadrian 16166864Sadrian pbp = pdirbp = (struct bufarea *)0; 16266864Sadrian bufp = malloc((unsigned int)sblock.fs_bsize); 16366864Sadrian if (bufp == 0) 16466864Sadrian errx(EEXIT, "cannot allocate buffer pool"); 16566864Sadrian cgblk.b_un.b_buf = bufp; 16666864Sadrian initbarea(&cgblk); 16766864Sadrian bufhead.b_next = bufhead.b_prev = &bufhead; 16866864Sadrian bufcnt = MAXBUFSPACE / sblock.fs_bsize; 16966864Sadrian if (bufcnt < MINBUFS) 17066864Sadrian bufcnt = MINBUFS; 17166864Sadrian for (i = 0; i < bufcnt; i++) { 17266864Sadrian bp = (struct bufarea *)malloc(sizeof(struct bufarea)); 17366864Sadrian bufp = malloc((unsigned int)sblock.fs_bsize); 17466864Sadrian if (bp == NULL || bufp == NULL) { 17566864Sadrian if (i >= MINBUFS) 17666864Sadrian break; 17766864Sadrian errx(EEXIT, "cannot allocate buffer pool"); 17866864Sadrian } 17966864Sadrian bp->b_un.b_buf = bufp; 18066864Sadrian bp->b_prev = &bufhead; 18166864Sadrian bp->b_next = bufhead.b_next; 18266864Sadrian bufhead.b_next->b_prev = bp; 18366864Sadrian bufhead.b_next = bp; 18466864Sadrian initbarea(bp); 18566864Sadrian } 18666864Sadrian bufhead.b_size = i; /* save number of buffers */ 18766864Sadrian} 18866864Sadrian 18966864Sadrian/* 19066864Sadrian * Manage a cache of directory blocks. 19166864Sadrian */ 19266864Sadrianstruct bufarea * 19398542Smckusickgetdatablk(ufs2_daddr_t blkno, long size) 19466864Sadrian{ 19592806Sobrien struct bufarea *bp; 19666864Sadrian 19766864Sadrian for (bp = bufhead.b_next; bp != &bufhead; bp = bp->b_next) 19866864Sadrian if (bp->b_bno == fsbtodb(&sblock, blkno)) 19966864Sadrian goto foundit; 20066864Sadrian for (bp = bufhead.b_prev; bp != &bufhead; bp = bp->b_prev) 20166864Sadrian if ((bp->b_flags & B_INUSE) == 0) 20266864Sadrian break; 20366864Sadrian if (bp == &bufhead) 20466864Sadrian errx(EEXIT, "deadlocked buffer pool"); 20566864Sadrian getblk(bp, blkno, size); 20666864Sadrian /* fall through */ 20766864Sadrianfoundit: 20866864Sadrian bp->b_prev->b_next = bp->b_next; 20966864Sadrian bp->b_next->b_prev = bp->b_prev; 21066864Sadrian bp->b_prev = &bufhead; 21166864Sadrian bp->b_next = bufhead.b_next; 21266864Sadrian bufhead.b_next->b_prev = bp; 21366864Sadrian bufhead.b_next = bp; 21466864Sadrian bp->b_flags |= B_INUSE; 21566864Sadrian return (bp); 21666864Sadrian} 21766864Sadrian 21866864Sadrianvoid 21998542Smckusickgetblk(struct bufarea *bp, ufs2_daddr_t blk, long size) 22066864Sadrian{ 22198542Smckusick ufs2_daddr_t dblk; 22266864Sadrian 22395897Smckusick totalreads++; 22466864Sadrian dblk = fsbtodb(&sblock, blk); 22566864Sadrian if (bp->b_bno != dblk) { 22666864Sadrian flush(fswritefd, bp); 22766864Sadrian diskreads++; 22866864Sadrian bp->b_errs = bread(fsreadfd, bp->b_un.b_buf, dblk, size); 22966864Sadrian bp->b_bno = dblk; 23066864Sadrian bp->b_size = size; 23166864Sadrian } 23266864Sadrian} 23366864Sadrian 23466864Sadrianvoid 23592839Simpflush(int fd, struct bufarea *bp) 23666864Sadrian{ 23792806Sobrien int i, j; 23866864Sadrian 23966864Sadrian if (!bp->b_dirty) 24066864Sadrian return; 24174556Smckusick bp->b_dirty = 0; 24274556Smckusick if (fswritefd < 0) { 24374556Smckusick pfatal("WRITING IN READ_ONLY MODE.\n"); 24474556Smckusick return; 24574556Smckusick } 24666864Sadrian if (bp->b_errs != 0) 247100935Sphk pfatal("WRITING %sZERO'ED BLOCK %lld TO DISK\n", 24866864Sadrian (bp->b_errs == bp->b_size / dev_bsize) ? "" : "PARTIALLY ", 249100935Sphk (long long)bp->b_bno); 25066864Sadrian bp->b_errs = 0; 25166864Sadrian bwrite(fd, bp->b_un.b_buf, bp->b_bno, (long)bp->b_size); 25266864Sadrian if (bp != &sblk) 25366864Sadrian return; 25466864Sadrian for (i = 0, j = 0; i < sblock.fs_cssize; i += sblock.fs_bsize, j++) { 25571073Siedowse bwrite(fswritefd, (char *)sblock.fs_csp + i, 25666864Sadrian fsbtodb(&sblock, sblock.fs_csaddr + j * sblock.fs_frag), 25766864Sadrian sblock.fs_cssize - i < sblock.fs_bsize ? 25866864Sadrian sblock.fs_cssize - i : sblock.fs_bsize); 25966864Sadrian } 26066864Sadrian} 26166864Sadrian 26274556Smckusickvoid 263100935Sphkrwerror(const char *mesg, ufs2_daddr_t blk) 26466864Sadrian{ 26566864Sadrian 26675927Smckusick if (bkgrdcheck) 26775927Smckusick exit(EEXIT); 26866864Sadrian if (preen == 0) 26966864Sadrian printf("\n"); 27086514Siedowse pfatal("CANNOT %s: %ld", mesg, (long)blk); 27166864Sadrian if (reply("CONTINUE") == 0) 27266864Sadrian exit(EEXIT); 27366864Sadrian} 27466864Sadrian 27566864Sadrianvoid 27692839Simpckfini(int markclean) 27766864Sadrian{ 27892806Sobrien struct bufarea *bp, *nbp; 27966864Sadrian int ofsmodified, cnt = 0; 28066864Sadrian 28174556Smckusick if (bkgrdflag) { 28274556Smckusick unlink(snapname); 28374556Smckusick if ((!(sblock.fs_flags & FS_UNCLEAN)) != markclean) { 28474556Smckusick cmd.value = FS_UNCLEAN; 28574556Smckusick cmd.size = markclean ? -1 : 1; 28674556Smckusick if (sysctlbyname("vfs.ffs.setflags", 0, 0, 28774556Smckusick &cmd, sizeof cmd) == -1) 288118302Sru rwerror("SET FILE SYSTEM FLAGS", FS_UNCLEAN); 28974556Smckusick if (!preen) { 29074556Smckusick printf("\n***** FILE SYSTEM MARKED %s *****\n", 29174556Smckusick markclean ? "CLEAN" : "DIRTY"); 29274556Smckusick if (!markclean) 29374556Smckusick rerun = 1; 29474556Smckusick } 29574556Smckusick } else if (!preen && !markclean) { 29674556Smckusick printf("\n***** FILE SYSTEM STILL DIRTY *****\n"); 29774556Smckusick rerun = 1; 29874556Smckusick } 29974556Smckusick } 30066864Sadrian if (fswritefd < 0) { 30166864Sadrian (void)close(fsreadfd); 30266864Sadrian return; 30366864Sadrian } 30466864Sadrian flush(fswritefd, &sblk); 30598542Smckusick if (havesb && cursnapshot == 0 && sblock.fs_magic == FS_UFS2_MAGIC && 306107294Smckusick sblk.b_bno != sblock.fs_sblockloc / dev_bsize && 30766864Sadrian !preen && reply("UPDATE STANDARD SUPERBLOCK")) { 308107294Smckusick sblk.b_bno = sblock.fs_sblockloc / dev_bsize; 30966864Sadrian sbdirty(); 31066864Sadrian flush(fswritefd, &sblk); 31166864Sadrian } 31266864Sadrian flush(fswritefd, &cgblk); 31366864Sadrian free(cgblk.b_un.b_buf); 31466864Sadrian for (bp = bufhead.b_prev; bp && bp != &bufhead; bp = nbp) { 31566864Sadrian cnt++; 31666864Sadrian flush(fswritefd, bp); 31766864Sadrian nbp = bp->b_prev; 31866864Sadrian free(bp->b_un.b_buf); 31966864Sadrian free((char *)bp); 32066864Sadrian } 32166864Sadrian if (bufhead.b_size != cnt) 32266864Sadrian errx(EEXIT, "panic: lost %d buffers", bufhead.b_size - cnt); 32366864Sadrian pbp = pdirbp = (struct bufarea *)0; 32474556Smckusick if (cursnapshot == 0 && sblock.fs_clean != markclean) { 325105436Smckusick if ((sblock.fs_clean = markclean) != 0) { 32675557Smckusick sblock.fs_flags &= ~(FS_UNCLEAN | FS_NEEDSFSCK); 327105436Smckusick sblock.fs_pendingblocks = 0; 328105436Smckusick sblock.fs_pendinginodes = 0; 329105436Smckusick } 33066864Sadrian sbdirty(); 33166864Sadrian ofsmodified = fsmodified; 33266864Sadrian flush(fswritefd, &sblk); 33366864Sadrian fsmodified = ofsmodified; 33466864Sadrian if (!preen) { 33566864Sadrian printf("\n***** FILE SYSTEM MARKED %s *****\n", 33666864Sadrian markclean ? "CLEAN" : "DIRTY"); 33766864Sadrian if (!markclean) 33866864Sadrian rerun = 1; 33966864Sadrian } 34066864Sadrian } else if (!preen && !markclean) { 34166864Sadrian printf("\n***** FILE SYSTEM STILL DIRTY *****\n"); 34266864Sadrian rerun = 1; 34366864Sadrian } 34475557Smckusick if (debug && totalreads > 0) 34566864Sadrian printf("cache missed %ld of %ld (%d%%)\n", diskreads, 34666864Sadrian totalreads, (int)(diskreads * 100 / totalreads)); 34766864Sadrian (void)close(fsreadfd); 34866864Sadrian (void)close(fswritefd); 34966864Sadrian} 35066864Sadrian 35166864Sadrianint 35298542Smckusickbread(int fd, char *buf, ufs2_daddr_t blk, long size) 35366864Sadrian{ 35466864Sadrian char *cp; 35566864Sadrian int i, errs; 35666864Sadrian off_t offset; 35766864Sadrian 35866864Sadrian offset = blk; 35966864Sadrian offset *= dev_bsize; 360107671Siedowse if (bkgrdflag) 361107671Siedowse slowio_start(); 36266864Sadrian if (lseek(fd, offset, 0) < 0) 36374556Smckusick rwerror("SEEK BLK", blk); 364107671Siedowse else if (read(fd, buf, (int)size) == size) { 365107671Siedowse if (bkgrdflag) 366107671Siedowse slowio_end(); 36766864Sadrian return (0); 368107671Siedowse } 36974556Smckusick rwerror("READ BLK", blk); 37066864Sadrian if (lseek(fd, offset, 0) < 0) 37174556Smckusick rwerror("SEEK BLK", blk); 37266864Sadrian errs = 0; 37366864Sadrian memset(buf, 0, (size_t)size); 37466864Sadrian printf("THE FOLLOWING DISK SECTORS COULD NOT BE READ:"); 37566864Sadrian for (cp = buf, i = 0; i < size; i += secsize, cp += secsize) { 37666864Sadrian if (read(fd, cp, (int)secsize) != secsize) { 37766864Sadrian (void)lseek(fd, offset + i + secsize, 0); 37866864Sadrian if (secsize != dev_bsize && dev_bsize != 1) 379101037Smux printf(" %jd (%jd),", 380101037Smux (intmax_t)(blk * dev_bsize + i) / secsize, 381101037Smux (intmax_t)blk + i / dev_bsize); 38266864Sadrian else 383101037Smux printf(" %jd,", (intmax_t)blk + i / dev_bsize); 38466864Sadrian errs++; 38566864Sadrian } 38666864Sadrian } 38766864Sadrian printf("\n"); 38866864Sadrian if (errs) 38966864Sadrian resolved = 0; 39066864Sadrian return (errs); 39166864Sadrian} 39266864Sadrian 39366864Sadrianvoid 39498542Smckusickbwrite(int fd, char *buf, ufs2_daddr_t blk, long size) 39566864Sadrian{ 39666864Sadrian int i; 39766864Sadrian char *cp; 39866864Sadrian off_t offset; 39966864Sadrian 40066864Sadrian if (fd < 0) 40166864Sadrian return; 40266864Sadrian offset = blk; 40366864Sadrian offset *= dev_bsize; 40466864Sadrian if (lseek(fd, offset, 0) < 0) 40574556Smckusick rwerror("SEEK BLK", blk); 40666864Sadrian else if (write(fd, buf, (int)size) == size) { 40766864Sadrian fsmodified = 1; 40866864Sadrian return; 40966864Sadrian } 41066864Sadrian resolved = 0; 41174556Smckusick rwerror("WRITE BLK", blk); 41266864Sadrian if (lseek(fd, offset, 0) < 0) 41374556Smckusick rwerror("SEEK BLK", blk); 41466864Sadrian printf("THE FOLLOWING SECTORS COULD NOT BE WRITTEN:"); 41566864Sadrian for (cp = buf, i = 0; i < size; i += dev_bsize, cp += dev_bsize) 41666864Sadrian if (write(fd, cp, (int)dev_bsize) != dev_bsize) { 41766864Sadrian (void)lseek(fd, offset + i + dev_bsize, 0); 418101037Smux printf(" %jd,", (intmax_t)blk + i / dev_bsize); 41966864Sadrian } 42066864Sadrian printf("\n"); 42166864Sadrian return; 42266864Sadrian} 42366864Sadrian 42466864Sadrian/* 42566864Sadrian * allocate a data block with the specified number of fragments 42666864Sadrian */ 42798542Smckusickufs2_daddr_t 42892839Simpallocblk(long frags) 42966864Sadrian{ 43066864Sadrian int i, j, k, cg, baseblk; 43166864Sadrian struct cg *cgp = &cgrp; 43266864Sadrian 43366864Sadrian if (frags <= 0 || frags > sblock.fs_frag) 43466864Sadrian return (0); 43566864Sadrian for (i = 0; i < maxfsblock - sblock.fs_frag; i += sblock.fs_frag) { 43666864Sadrian for (j = 0; j <= sblock.fs_frag - frags; j++) { 43766864Sadrian if (testbmap(i + j)) 43866864Sadrian continue; 43966864Sadrian for (k = 1; k < frags; k++) 44066864Sadrian if (testbmap(i + j + k)) 44166864Sadrian break; 44266864Sadrian if (k < frags) { 44366864Sadrian j += k; 44466864Sadrian continue; 44566864Sadrian } 44666864Sadrian cg = dtog(&sblock, i + j); 44766864Sadrian getblk(&cgblk, cgtod(&sblock, cg), sblock.fs_cgsize); 44866864Sadrian if (!cg_chkmagic(cgp)) 44966864Sadrian pfatal("CG %d: BAD MAGIC NUMBER\n", cg); 45066864Sadrian baseblk = dtogd(&sblock, i + j); 45166864Sadrian for (k = 0; k < frags; k++) { 45266864Sadrian setbmap(i + j + k); 45366864Sadrian clrbit(cg_blksfree(cgp), baseblk + k); 45466864Sadrian } 45566864Sadrian n_blks += frags; 45666864Sadrian if (frags == sblock.fs_frag) 45766864Sadrian cgp->cg_cs.cs_nbfree--; 45866864Sadrian else 45966864Sadrian cgp->cg_cs.cs_nffree -= frags; 46066864Sadrian cgdirty(); 46166864Sadrian return (i + j); 46266864Sadrian } 46366864Sadrian } 46466864Sadrian return (0); 46566864Sadrian} 46666864Sadrian 46766864Sadrian/* 46866864Sadrian * Free a previously allocated block 46966864Sadrian */ 47066864Sadrianvoid 47198542Smckusickfreeblk(ufs2_daddr_t blkno, long frags) 47266864Sadrian{ 47366864Sadrian struct inodesc idesc; 47466864Sadrian 47566864Sadrian idesc.id_blkno = blkno; 47666864Sadrian idesc.id_numfrags = frags; 47766864Sadrian (void)pass4check(&idesc); 47866864Sadrian} 47966864Sadrian 480107671Siedowse/* Slow down IO so as to leave some disk bandwidth for other processes */ 481107671Siedowsevoid 482107671Siedowseslowio_start() 483107671Siedowse{ 484107671Siedowse 485107671Siedowse /* Delay one in every 8 operations by 16 times the average IO delay */ 486107671Siedowse slowio_pollcnt = (slowio_pollcnt + 1) & 7; 487107671Siedowse if (slowio_pollcnt == 0) { 488107671Siedowse usleep(slowio_delay_usec * 16); 489107671Siedowse gettimeofday(&slowio_starttime, NULL); 490107671Siedowse } 491107671Siedowse} 492107671Siedowse 493107671Siedowsevoid 494107671Siedowseslowio_end() 495107671Siedowse{ 496107671Siedowse struct timeval tv; 497107671Siedowse int delay_usec; 498107671Siedowse 499107671Siedowse if (slowio_pollcnt != 0) 500107671Siedowse return; 501107671Siedowse 502107671Siedowse /* Update the slowdown interval. */ 503107671Siedowse gettimeofday(&tv, NULL); 504107671Siedowse delay_usec = (tv.tv_sec - slowio_starttime.tv_sec) * 1000000 + 505107671Siedowse (tv.tv_usec - slowio_starttime.tv_usec); 506107671Siedowse if (delay_usec < 64) 507107671Siedowse delay_usec = 64; 508107671Siedowse if (delay_usec > 1000000) 509107671Siedowse delay_usec = 1000000; 510107671Siedowse slowio_delay_usec = (slowio_delay_usec * 63 + delay_usec) >> 6; 511107671Siedowse} 512107671Siedowse 51366864Sadrian/* 51466864Sadrian * Find a pathname 51566864Sadrian */ 51666864Sadrianvoid 51792839Simpgetpathname(char *namebuf, ino_t curdir, ino_t ino) 51866864Sadrian{ 51966864Sadrian int len; 52092806Sobrien char *cp; 52166864Sadrian struct inodesc idesc; 52266864Sadrian static int busy = 0; 52366864Sadrian 52466864Sadrian if (curdir == ino && ino == ROOTINO) { 52566864Sadrian (void)strcpy(namebuf, "/"); 52666864Sadrian return; 52766864Sadrian } 52866864Sadrian if (busy || 52966864Sadrian (inoinfo(curdir)->ino_state != DSTATE && 53066864Sadrian inoinfo(curdir)->ino_state != DFOUND)) { 53166864Sadrian (void)strcpy(namebuf, "?"); 53266864Sadrian return; 53366864Sadrian } 53466864Sadrian busy = 1; 53566864Sadrian memset(&idesc, 0, sizeof(struct inodesc)); 53666864Sadrian idesc.id_type = DATA; 53766864Sadrian idesc.id_fix = IGNORE; 53866864Sadrian cp = &namebuf[MAXPATHLEN - 1]; 53966864Sadrian *cp = '\0'; 54066864Sadrian if (curdir != ino) { 54166864Sadrian idesc.id_parent = curdir; 54266864Sadrian goto namelookup; 54366864Sadrian } 54466864Sadrian while (ino != ROOTINO) { 54566864Sadrian idesc.id_number = ino; 54666864Sadrian idesc.id_func = findino; 547100935Sphk idesc.id_name = strdup(".."); 54866864Sadrian if ((ckinode(ginode(ino), &idesc) & FOUND) == 0) 54966864Sadrian break; 55066864Sadrian namelookup: 55166864Sadrian idesc.id_number = idesc.id_parent; 55266864Sadrian idesc.id_parent = ino; 55366864Sadrian idesc.id_func = findname; 55466864Sadrian idesc.id_name = namebuf; 55566864Sadrian if ((ckinode(ginode(idesc.id_number), &idesc)&FOUND) == 0) 55666864Sadrian break; 55766864Sadrian len = strlen(namebuf); 55866864Sadrian cp -= len; 55966864Sadrian memmove(cp, namebuf, (size_t)len); 56066864Sadrian *--cp = '/'; 56166864Sadrian if (cp < &namebuf[MAXNAMLEN]) 56266864Sadrian break; 56366864Sadrian ino = idesc.id_number; 56466864Sadrian } 56566864Sadrian busy = 0; 56666864Sadrian if (ino != ROOTINO) 56766864Sadrian *--cp = '?'; 56866864Sadrian memmove(namebuf, cp, (size_t)(&namebuf[MAXPATHLEN] - cp)); 56966864Sadrian} 57066864Sadrian 57166864Sadrianvoid 572100935Sphkcatch(int sig __unused) 57366864Sadrian{ 57496483Sphk 57596483Sphk ckfini(0); 57666864Sadrian exit(12); 57766864Sadrian} 57866864Sadrian 57966864Sadrian/* 58066864Sadrian * When preening, allow a single quit to signal 581102231Strhodes * a special exit after file system checks complete 58266864Sadrian * so that reboot sequence may be interrupted. 58366864Sadrian */ 58466864Sadrianvoid 585100935Sphkcatchquit(int sig __unused) 58666864Sadrian{ 587102231Strhodes printf("returning to single-user after file system check\n"); 58866864Sadrian returntosingle = 1; 58966864Sadrian (void)signal(SIGQUIT, SIG_DFL); 59066864Sadrian} 59166864Sadrian 59266864Sadrian/* 59366864Sadrian * determine whether an inode should be fixed. 59466864Sadrian */ 59566864Sadrianint 596100935Sphkdofix(struct inodesc *idesc, const char *msg) 59766864Sadrian{ 59866864Sadrian 59966864Sadrian switch (idesc->id_fix) { 60066864Sadrian 60166864Sadrian case DONTKNOW: 60266864Sadrian if (idesc->id_type == DATA) 60366864Sadrian direrror(idesc->id_number, msg); 60466864Sadrian else 60581911Skris pwarn("%s", msg); 60666864Sadrian if (preen) { 60766864Sadrian printf(" (SALVAGED)\n"); 60866864Sadrian idesc->id_fix = FIX; 60966864Sadrian return (ALTERED); 61066864Sadrian } 61166864Sadrian if (reply("SALVAGE") == 0) { 61266864Sadrian idesc->id_fix = NOFIX; 61366864Sadrian return (0); 61466864Sadrian } 61566864Sadrian idesc->id_fix = FIX; 61666864Sadrian return (ALTERED); 61766864Sadrian 61866864Sadrian case FIX: 61966864Sadrian return (ALTERED); 62066864Sadrian 62166864Sadrian case NOFIX: 62266864Sadrian case IGNORE: 62366864Sadrian return (0); 62466864Sadrian 62566864Sadrian default: 62666864Sadrian errx(EEXIT, "UNKNOWN INODESC FIX MODE %d", idesc->id_fix); 62766864Sadrian } 62866864Sadrian /* NOTREACHED */ 62966864Sadrian return (0); 63066864Sadrian} 63166864Sadrian 63266864Sadrian#include <stdarg.h> 63366864Sadrian 63466864Sadrian/* 63566864Sadrian * An unexpected inconsistency occured. 636102231Strhodes * Die if preening or file system is running with soft dependency protocol, 63766864Sadrian * otherwise just print message and continue. 63866864Sadrian */ 63966864Sadrianvoid 64066864Sadrianpfatal(const char *fmt, ...) 64166864Sadrian{ 64266864Sadrian va_list ap; 64366864Sadrian va_start(ap, fmt); 64466864Sadrian if (!preen) { 64575927Smckusick (void)vfprintf(stdout, fmt, ap); 64666864Sadrian va_end(ap); 64766864Sadrian if (usedsoftdep) 64875927Smckusick (void)fprintf(stdout, 64966864Sadrian "\nUNEXPECTED SOFT UPDATE INCONSISTENCY\n"); 65075557Smckusick /* 65175557Smckusick * Force foreground fsck to clean up inconsistency. 65275557Smckusick */ 65375557Smckusick if (bkgrdflag) { 65475557Smckusick cmd.value = FS_NEEDSFSCK; 65575557Smckusick cmd.size = 1; 65675557Smckusick if (sysctlbyname("vfs.ffs.setflags", 0, 0, 65775557Smckusick &cmd, sizeof cmd) == -1) 65875557Smckusick pwarn("CANNOT SET FS_NEEDSFSCK FLAG\n"); 65975927Smckusick fprintf(stdout, "CANNOT RUN IN BACKGROUND\n"); 66075557Smckusick ckfini(0); 66175557Smckusick exit(EEXIT); 66275557Smckusick } 66366864Sadrian return; 66466864Sadrian } 66566864Sadrian if (cdevname == NULL) 666100935Sphk cdevname = strdup("fsck"); 66775927Smckusick (void)fprintf(stdout, "%s: ", cdevname); 66875927Smckusick (void)vfprintf(stdout, fmt, ap); 66975927Smckusick (void)fprintf(stdout, 67066864Sadrian "\n%s: UNEXPECTED%sINCONSISTENCY; RUN fsck MANUALLY.\n", 67166864Sadrian cdevname, usedsoftdep ? " SOFT UPDATE " : " "); 67275557Smckusick /* 67375557Smckusick * Force foreground fsck to clean up inconsistency. 67475557Smckusick */ 67575557Smckusick if (bkgrdflag) { 67675557Smckusick cmd.value = FS_NEEDSFSCK; 67775557Smckusick cmd.size = 1; 67875557Smckusick if (sysctlbyname("vfs.ffs.setflags", 0, 0, 67975557Smckusick &cmd, sizeof cmd) == -1) 68075557Smckusick pwarn("CANNOT SET FS_NEEDSFSCK FLAG\n"); 68175557Smckusick } 68266864Sadrian ckfini(0); 68366864Sadrian exit(EEXIT); 68466864Sadrian} 68566864Sadrian 68666864Sadrian/* 68766864Sadrian * Pwarn just prints a message when not preening or running soft dependency 68866864Sadrian * protocol, or a warning (preceded by filename) when preening. 68966864Sadrian */ 69066864Sadrianvoid 69166864Sadrianpwarn(const char *fmt, ...) 69266864Sadrian{ 69366864Sadrian va_list ap; 69466864Sadrian va_start(ap, fmt); 69566864Sadrian if (preen) 69675927Smckusick (void)fprintf(stdout, "%s: ", cdevname); 69775927Smckusick (void)vfprintf(stdout, fmt, ap); 69866864Sadrian va_end(ap); 69966864Sadrian} 70066864Sadrian 70166864Sadrian/* 70266864Sadrian * Stub for routines from kernel. 70366864Sadrian */ 70466864Sadrianvoid 70566864Sadrianpanic(const char *fmt, ...) 70666864Sadrian{ 70766864Sadrian va_list ap; 70866864Sadrian va_start(ap, fmt); 70966864Sadrian pfatal("INTERNAL INCONSISTENCY:"); 71075927Smckusick (void)vfprintf(stdout, fmt, ap); 71166864Sadrian va_end(ap); 71266864Sadrian exit(EEXIT); 71366864Sadrian} 714