sbin/quotacheck/preen.c

   1 /*
   2  * Copyright (c) 1990, 1993
   3  *      The Regents of the University of California.  All rights reserved.
   4  *
   5  * Redistribution and use in source and binary forms, with or without
   6  * modification, are permitted provided that the following conditions
   7  * are met:
   8  * 1. Redistributions of source code must retain the above copyright
   9  *    notice, this list of conditions and the following disclaimer.
  10  * 2. Redistributions in binary form must reproduce the above copyright
  11  *    notice, this list of conditions and the following disclaimer in the
  12  *    documentation and/or other materials provided with the distribution.
  13  * 4. Neither the name of the University nor the names of its contributors
  14  *    may be used to endorse or promote products derived from this software
  15  *    without specific prior written permission.
  16  *
  17  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
  18  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  19  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  20  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
  21  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  22  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  23  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  24  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  25  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  26  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  27  * SUCH DAMAGE.
  28  */
  29
  30 #if 0
  31 #ifndef lint
  32 static const char sccsid[] = "@(#)preen.c       8.5 (Berkeley) 4/28/95";
  33 #endif /* not lint */
  34 #endif
  35 #include <sys/cdefs.h>
  36 __FBSDID("$FreeBSD$");
  37
  38 #include <sys/param.h>
  39 #include <sys/stat.h>
  40 #include <sys/wait.h>
  41
  42 #include <ufs/ufs/dinode.h>
  43 #include <ufs/ffs/fs.h>
  44
  45 #include <ctype.h>
  46 #include <errno.h>
  47 #include <fstab.h>
  48 #include <string.h>
  49 #include <stdio.h>
  50 #include <stdlib.h>
  51 #include <unistd.h>
  52
  53 char *blockcheck(char *origname);
  54
  55
  56 struct part {
  57         struct  part *next;             /* forward link of partitions on disk */
  58         char    *name;                  /* device name */
  59         char    *fsname;                /* mounted file system name */
  60         void    *auxdata;               /* auxiliary data for application */
  61 } *badlist, **badnext = &badlist;
  62
  63 struct disk {
  64         char    *name;                  /* disk base name */
  65         struct  disk *next;             /* forward link for list of disks */
  66         struct  part *part;             /* head of list of partitions on disk */
  67         int     pid;                    /* If != 0, pid of proc working on */
  68 } *disks;
  69
  70 int     nrun, ndisks;
  71
  72 static void addpart(char *name, char *fsname, void *auxdata);
  73 static struct disk *finddisk(char *name);
  74 static int startdisk(struct disk *dk,
  75     int (*checkit)(char *, char *, void *, int));
  76
  77 int
  78 checkfstab(int preen, int maxrun, void *(*docheck)(struct fstab *),
  79     int (*chkit)(char *, char *, void *, int))
  80 {
  81         struct fstab *fsp;
  82         struct disk *dk, *nextdisk;
  83         struct part *pt;
  84         int ret, pid, retcode, passno, sumstatus, status;
  85         void *auxdata;
  86         char *name;
  87
  88         sumstatus = 0;
  89         for (passno = 1; passno <= 2; passno++) {
  90                 if (setfsent() == 0) {
  91                         fprintf(stderr, "Can't open checklist file: %s\n",
  92                             _PATH_FSTAB);
  93                         return (8);
  94                 }
  95                 while ((fsp = getfsent()) != 0) {
  96                         if ((auxdata = (*docheck)(fsp)) == NULL)
  97                                 continue;
  98                         if (preen == 0 ||
  99                             (passno == 1 && fsp->fs_passno == 1)) {
 100                                 if ((name = blockcheck(fsp->fs_spec)) != 0) {
 101                                         if ((sumstatus = (*chkit)(name,
 102                                             fsp->fs_file, auxdata, 0)) != 0)
 103                                                 return (sumstatus);
 104                                 } else if (preen)
 105                                         return (8);
 106                         } else if (passno == 2 && fsp->fs_passno > 1) {
 107                                 if ((name = blockcheck(fsp->fs_spec)) == NULL) {
 108                                         fprintf(stderr, "BAD DISK NAME %s\n",
 109                                                 fsp->fs_spec);
 110                                         sumstatus |= 8;
 111                                         continue;
 112                                 }
 113                                 addpart(name, fsp->fs_file, auxdata);
 114                         }
 115                 }
 116                 if (preen == 0)
 117                         return (0);
 118         }
 119         if (preen) {
 120                 if (maxrun == 0)
 121                         maxrun = ndisks;
 122                 if (maxrun > ndisks)
 123                         maxrun = ndisks;
 124                 nextdisk = disks;
 125                 for (passno = 0; passno < maxrun; ++passno) {
 126                         while ((ret = startdisk(nextdisk, chkit)) && nrun > 0)
 127                                 sleep(10);
 128                         if (ret)
 129                                 return (ret);
 130                         nextdisk = nextdisk->next;
 131                 }
 132                 while ((pid = wait(&status)) != -1) {
 133                         for (dk = disks; dk; dk = dk->next)
 134                                 if (dk->pid == pid)
 135                                         break;
 136                         if (dk == 0) {
 137                                 printf("Unknown pid %d\n", pid);
 138                                 continue;
 139                         }
 140                         if (WIFEXITED(status))
 141                                 retcode = WEXITSTATUS(status);
 142                         else
 143                                 retcode = 0;
 144                         if (WIFSIGNALED(status)) {
 145                                 printf("%s (%s): EXITED WITH SIGNAL %d\n",
 146                                         dk->part->name, dk->part->fsname,
 147                                         WTERMSIG(status));
 148                                 retcode = 8;
 149                         }
 150                         if (retcode != 0) {
 151                                 sumstatus |= retcode;
 152                                 *badnext = dk->part;
 153                                 badnext = &dk->part->next;
 154                                 dk->part = dk->part->next;
 155                                 *badnext = NULL;
 156                         } else
 157                                 dk->part = dk->part->next;
 158                         dk->pid = 0;
 159                         nrun--;
 160                         if (dk->part == NULL)
 161                                 ndisks--;
 162
 163                         if (nextdisk == NULL) {
 164                                 if (dk->part) {
 165                                         while ((ret = startdisk(dk, chkit)) &&
 166                                             nrun > 0)
 167                                                 sleep(10);
 168                                         if (ret)
 169                                                 return (ret);
 170                                 }
 171                         } else if (nrun < maxrun && nrun < ndisks) {
 172                                 for ( ;; ) {
 173                                         if ((nextdisk = nextdisk->next) == NULL)
 174                                                 nextdisk = disks;
 175                                         if (nextdisk->part != NULL &&
 176                                             nextdisk->pid == 0)
 177                                                 break;
 178                                 }
 179                                 while ((ret = startdisk(nextdisk, chkit)) &&
 180                                     nrun > 0)
 181                                         sleep(10);
 182                                 if (ret)
 183                                         return (ret);
 184                         }
 185                 }
 186         }
 187         if (sumstatus) {
 188                 if (badlist == 0)
 189                         return (sumstatus);
 190                 fprintf(stderr, "THE FOLLOWING FILE SYSTEM%s HAD AN %s\n\t",
 191                         badlist->next ? "S" : "", "UNEXPECTED INCONSISTENCY:");
 192                 for (pt = badlist; pt; pt = pt->next)
 193                         fprintf(stderr, "%s (%s)%s", pt->name, pt->fsname,
 194                             pt->next ? ", " : "\n");
 195                 return (sumstatus);
 196         }
 197         (void)endfsent();
 198         return (0);
 199 }
 200
 201 static struct disk *
 202 finddisk(char *name)
 203 {
 204         struct disk *dk, **dkp;
 205         char *p;
 206         size_t len;
 207
 208         p = strrchr(name, '/');
 209         p = p == NULL ? name : p + 1;
 210         while (*p != '\0' && !isdigit((u_char)*p))
 211                 p++;
 212         while (isdigit((u_char)*p))
 213                 p++;
 214         len = (size_t)(p - name);
 215         for (dk = disks, dkp = &disks; dk; dkp = &dk->next, dk = dk->next) {
 216                 if (strncmp(dk->name, name, len) == 0 &&
 217                     dk->name[len] == 0)
 218                         return (dk);
 219         }
 220         if ((*dkp = (struct disk *)malloc(sizeof(struct disk))) == NULL) {
 221                 fprintf(stderr, "out of memory");
 222                 exit (8);
 223         }
 224         dk = *dkp;
 225         if ((dk->name = malloc(len + 1)) == NULL) {
 226                 fprintf(stderr, "out of memory");
 227                 exit (8);
 228         }
 229         (void)strncpy(dk->name, name, len);
 230         dk->name[len] = '\0';
 231         dk->part = NULL;
 232         dk->next = NULL;
 233         dk->pid = 0;
 234         ndisks++;
 235         return (dk);
 236 }
 237
 238 static void
 239 addpart(char *name, char *fsname, void *auxdata)
 240 {
 241         struct disk *dk = finddisk(name);
 242         struct part *pt, **ppt = &dk->part;
 243
 244         for (pt = dk->part; pt; ppt = &pt->next, pt = pt->next)
 245                 if (strcmp(pt->name, name) == 0) {
 246                         printf("%s in fstab more than once!\n", name);
 247                         return;
 248                 }
 249         if ((*ppt = (struct part *)malloc(sizeof(struct part))) == NULL) {
 250                 fprintf(stderr, "out of memory");
 251                 exit (8);
 252         }
 253         pt = *ppt;
 254         if ((pt->name = malloc(strlen(name) + 1)) == NULL) {
 255                 fprintf(stderr, "out of memory");
 256                 exit (8);
 257         }
 258         (void)strcpy(pt->name, name);
 259         if ((pt->fsname = malloc(strlen(fsname) + 1)) == NULL) {
 260                 fprintf(stderr, "out of memory");
 261                 exit (8);
 262         }
 263         (void)strcpy(pt->fsname, fsname);
 264         pt->next = NULL;
 265         pt->auxdata = auxdata;
 266 }
 267
 268 static int
 269 startdisk(struct disk *dk, int (*checkit)(char *, char *, void *, int))
 270 {
 271         struct part *pt = dk->part;
 272
 273         dk->pid = fork();
 274         if (dk->pid < 0) {
 275                 perror("fork");
 276                 return (8);
 277         }
 278         if (dk->pid == 0)
 279                 exit((*checkit)(pt->name, pt->fsname, pt->auxdata, 1));
 280         nrun++;
 281         return (0);
 282 }
 283