src/volser/dumpstuff.c

   1 /*
   2  * Copyright 2000, International Business Machines Corporation and others.
   3  * All Rights Reserved.
   4  *
   5  * This software has been released under the terms of the IBM Public
   6  * License.  For details, see the LICENSE file in the top-level source
   7  * directory or online at http://www.openafs.org/dl/license10.html
   8  */
   9
  10 #include <afsconfig.h>
  11 #include <afs/param.h>
  12
  13 #include <roken.h>
  14
  15 #include <ctype.h>
  16
  17 #include <afs/afs_assert.h>
  18 #include <rx/xdr.h>
  19 #include <rx/rx.h>
  20 #include <afs/afsint.h>
  21 #include <afs/nfs.h>
  22 #include <afs/errors.h>
  23 #include <lock.h>
  24 #include <lwp.h>
  25 #include <afs/ihandle.h>
  26 #include <afs/vnode.h>
  27 #include <afs/volume.h>
  28 #include <afs/partition.h>
  29 #include <afs/daemon_com.h>
  30 #include <afs/fssync.h>
  31 #include <afs/acl.h>
  32 #include <afs/com_err.h>
  33 #include <afs/vol_prototypes.h>
  34
  35 #include "dump.h"
  36 #include "volser.h"
  37 #include "volint.h"
  38 #include "dumpstuff.h"
  39
  40 #ifndef AFS_NT40_ENV
  41 #ifdef O_LARGEFILE
  42 #define afs_stat        stat64
  43 #define afs_fstat       fstat64
  44 #else /* !O_LARGEFILE */
  45 #define afs_stat        stat
  46 #define afs_fstat       fstat
  47 #endif /* !O_LARGEFILE */
  48 #endif /* !AFS_NT40_ENV */
  49
  50 /*@printflike@*/ extern void Log(const char *format, ...);
  51
  52 extern int DoLogging;
  53
  54
  55 /* Forward Declarations */
  56 static int DumpDumpHeader(struct iod *iodp, Volume * vp,
  57                           afs_int32 fromtime);
  58 static int DumpPartial(struct iod *iodp, Volume * vp,
  59                        afs_int32 fromtime, int dumpAllDirs);
  60 static int DumpVnodeIndex(struct iod *iodp, Volume * vp,
  61                           VnodeClass class, afs_int32 fromtime,
  62                           int forcedump);
  63 static int DumpVnode(struct iod *iodp, struct VnodeDiskObject *v,
  64                      int volid, int vnodeNumber, int dumpEverything);
  65 static int ReadDumpHeader(struct iod *iodp, struct DumpHeader *hp);
  66 static int ReadVnodes(struct iod *iodp, Volume * vp, int incremental,
  67                       afs_foff_t * Lbuf, afs_int32 s1, afs_foff_t * Sbuf,
  68                       afs_int32 s2, afs_int32 delo);
  69 static afs_fsize_t volser_WriteFile(int vn, struct iod *iodp,
  70                                     FdHandle_t * handleP, int tag,
  71                                     Error * status);
  72
  73 static int SizeDumpDumpHeader(struct iod *iodp, Volume * vp,
  74                               afs_int32 fromtime,
  75                               struct volintSize *size);
  76 static int SizeDumpPartial(struct iod *iodp, Volume * vp,
  77                            afs_int32 fromtime, int dumpAllDirs,
  78                            struct volintSize *size);
  79 static int SizeDumpVnodeIndex(struct iod *iodp, Volume * vp,
  80                               VnodeClass class, afs_int32 fromtime,
  81                               int forcedump,
  82                               struct volintSize *size);
  83 static int SizeDumpVnode(struct iod *iodp, struct VnodeDiskObject *v,
  84                          int volid, int vnodeNumber, int dumpEverything,
  85                          struct volintSize *size);
  86
  87 #define MAX_SECTIONS    3
  88 #define MIN_TLV_TAG     5
  89 #define MAX_TLV_TAG     0x60
  90 #define MAX_STANDARD_TAG 0x7a
  91 static afs_uint32 oldtags[MAX_SECTIONS][16];
  92 int oldtagsInited = 0;
  93
  94 static void
  95 RegisterTag(afs_int32 section, unsigned char tag)
  96 {
  97     afs_uint32 off = tag >> 5;
  98     afs_uint32 mask = 1 << (tag & 0x1f);
  99     oldtags[section][off] |= mask;
 100 }
 101
 102 static void
 103 initNonStandardTags(void)
 104 {
 105     RegisterTag(0, 'n');                /* volume name */
 106     RegisterTag(0, 't');                /* fromtime, V_backupDate */
 107     RegisterTag(1, 'A');                /* V_accessDate */
 108     RegisterTag(1, 'C');                /* V_creationDate */
 109     RegisterTag(1, 'D');                /* V_dayUseDate */
 110     RegisterTag(1, 'E');                /* V_expirationDate */
 111     RegisterTag(1, 'M');                /* nullstring (motd) */
 112     RegisterTag(1, 'U');                /* V_updateDate */
 113     RegisterTag(1, 'W');                /* V_weekUse */
 114     RegisterTag(1, 'Z');                /* V_dayUse */
 115     RegisterTag(1, 'O');                /* V_offlineMessage */
 116     RegisterTag(1, 'b');                /* V_blessed */
 117     RegisterTag(1, 'n');                /* V_name */
 118     RegisterTag(1, 's');                /* V_inService */
 119     RegisterTag(1, 't');                /* V_type */
 120     RegisterTag(2, 'A');                /* VVnodeDiskACL */
 121     RegisterTag(2, 'b');                /* modeBits */
 122     RegisterTag(2, 'f');                /* small file */
 123     RegisterTag(2, 'h');                /* large file */
 124     RegisterTag(2, 'l');                /* linkcount */
 125     RegisterTag(2, 't');                /* type */
 126     oldtagsInited = 1;
 127 }
 128
 129 static void
 130 iod_Init(struct iod *iodp, struct rx_call *call)
 131 {
 132     iodp->call = call;
 133     iodp->haveOldChar = 0;
 134     iodp->ncalls = 1;
 135     iodp->calls = (struct rx_call **)0;
 136 }
 137
 138 static void
 139 iod_InitMulti(struct iod *iodp, struct rx_call **calls, int ncalls,
 140               int *codes)
 141 {
 142
 143     iodp->calls = calls;
 144     iodp->haveOldChar = 0;
 145     iodp->ncalls = ncalls;
 146     iodp->codes = codes;
 147     iodp->call = (struct rx_call *)0;
 148 }
 149
 150 /* N.B. iod_Read doesn't check for oldchar (see previous comment) */
 151 #define iod_Read(iodp, buf, nbytes) rx_Read((iodp)->call, buf, nbytes)
 152
 153 /* For the single dump case, it's ok to just return the "bytes written"
 154  * that rx_Write returns, since all the callers of iod_Write abort when
 155  * the returned value is less than they expect.  For the multi dump case,
 156  * I don't think we want half the replicas to go bad just because one
 157  * connection timed out, but if they all time out, then we should give up.
 158  */
 159 static int
 160 iod_Write(struct iod *iodp, char *buf, int nbytes)
 161 {
 162     int code, i;
 163     int one_success = 0;
 164
 165     osi_Assert((iodp->call && iodp->ncalls == 1 && !iodp->calls)
 166            || (!iodp->call && iodp->ncalls >= 1 && iodp->calls));
 167
 168     if (iodp->call) {
 169         code = rx_Write(iodp->call, buf, nbytes);
 170         return code;
 171     }
 172
 173     for (i = 0; i < iodp->ncalls; i++) {
 174         if (iodp->calls[i] && !iodp->codes[i]) {
 175             code = rx_Write(iodp->calls[i], buf, nbytes);
 176             if (code != nbytes) {       /* everything gets merged into a single error */
 177                 iodp->codes[i] = VOLSERDUMPERROR;       /* but that's exactly what the */
 178             } /* standard dump does, anyways */
 179             else {
 180                 one_success = TRUE;
 181             }
 182         }
 183     }                           /* for all calls */
 184
 185     if (one_success)
 186         return nbytes;
 187     else
 188         return 0;
 189 }
 190
 191 static void
 192 iod_ungetc(struct iod *iodp, int achar)
 193 {
 194     iodp->oldChar = achar;
 195     iodp->haveOldChar = 1;
 196 }
 197
 198 static int
 199 iod_getc(struct iod *iodp)
 200 {
 201     unsigned char t;
 202
 203     if (iodp->haveOldChar) {
 204         iodp->haveOldChar = 0;
 205         return iodp->oldChar;
 206     }
 207     if (iod_Read(iodp, (char *) &t, 1) == 1)
 208         return t;
 209     return EOF;
 210 }
 211
 212 static int
 213 ReadShort(struct iod *iodp, unsigned short *sp)
 214 {
 215     int b1, b0;
 216     b1 = iod_getc(iodp);
 217     if (b1 == EOF)
 218         return 0;
 219     b0 = iod_getc(iodp);
 220     if (b0 == EOF)
 221         return 0;
 222     *sp = (b1 << 8) | b0;
 223     return 1;
 224 }
 225
 226 static int
 227 ReadInt32(struct iod *iodp, afs_uint32 * lp)
 228 {
 229     afs_uint32 b3, b2, b1, b0;
 230     b3 = iod_getc(iodp);
 231     if (b3 == EOF)
 232         return 0;
 233     b2 = iod_getc(iodp);
 234     if (b2 == EOF)
 235         return 0;
 236     b1 = iod_getc(iodp);
 237     if (b1 == EOF)
 238         return 0;
 239     b0 = iod_getc(iodp);
 240     if (b0 == EOF)
 241         return 0;
 242     *lp = (((((b3 << 8) | b2) << 8) | b1) << 8) | b0;
 243     return 1;
 244 }
 245
 246 static void
 247 ReadString(struct iod *iodp, char *to, int maxa)
 248 {
 249     int c;
 250
 251     *to = '\0';
 252     if (maxa == 0)
 253         return;
 254
 255     while (maxa--) {
 256         if ((*to++ = c = iod_getc(iodp)) == 0 || c == EOF)
 257             break;
 258     }
 259     if (to[-1]) {
 260         while ((c = iod_getc(iodp)) && c != EOF);
 261         to[-1] = '\0';
 262     }
 263 }
 264
 265 static void
 266 ReadByteString(struct iod *iodp, byte * to,
 267                int size)
 268 {
 269     while (size--)
 270         *to++ = iod_getc(iodp);
 271 }
 272
 273 /*
 274  * returns 1 on success and 0 otherwise
 275  */
 276 static afs_int32
 277 ReadStandardTagLen(struct iod *iodp, unsigned char tag, afs_int32 section,
 278                         afs_size_t *length)
 279 {
 280     afs_int32 code, i;
 281     afs_uint32 off = tag >> 5;
 282     afs_uint32 mask = 1 << (tag & 0x1f);
 283     unsigned char len, buf[8], *p;
 284
 285     if (!oldtagsInited)
 286         initNonStandardTags();
 287
 288     if (tag < MIN_TLV_TAG
 289       || tag > MAX_STANDARD_TAG
 290       || section >= MAX_SECTIONS
 291       || (oldtags[section][ off] & mask)) {
 292         Log("Trying to use ReadStandardTag with tag 0x%02x for section %d, aborting\n", tag, section);
 293         return 0;
 294     }
 295     if (tag <= MAX_TLV_TAG) {
 296         len = iod_getc(iodp);
 297         if (len < 128)
 298             *length = len;
 299         else {
 300             len &= 0x7f;
 301             if ((code = iod_Read(iodp, (char *)buf, len)) != len)
 302                 return VOLSERDUMPERROR;
 303             *length = 0;
 304             p = (unsigned char *)&buf;
 305             for (i=0; i<len; i++) {
 306                 *length = ((*length) << 8) | *p++;
 307             }
 308         }
 309     } else {
 310         if (tag < MAX_STANDARD_TAG)
 311             *length = 4;
 312     }
 313     return 1;
 314 }
 315
 316 static char skipbuf[256];
 317
 318 static afs_int32
 319 SkipData(struct iod *iodp, afs_size_t length)
 320 {
 321     while (length > 256) {
 322         if (iod_Read(iodp, (char *)&skipbuf, 256) != 256)
 323             return 0;
 324         length -= 256;
 325     }
 326     if (iod_Read(iodp, (char *)&skipbuf, length) != length)
 327         return 0;
 328     return 1;
 329 }
 330
 331 static char *secname[3] = {"ReadDumpHeader", "ReadVolumeHeader", "ReadVnodes"};
 332
 333 static int
 334 HandleUnknownTag(struct iod *iodp, int tag, afs_int32 section,
 335                 afs_int32 critical)
 336 {
 337     afs_size_t taglen = 0;
 338     afs_uint32 trash;
 339
 340     if (critical) {
 341         Log("%s: unknown critical tag x%02x, aborting\n",
 342                 secname[section], tag);
 343         return 0;
 344     }
 345     Log("%s: unknown tag x%02x found, skipping\n", secname[section], tag);
 346     if (tag >= 0x06 && tag <= 0x60) {
 347         if (!ReadStandardTagLen(iodp, tag, 1, &taglen)) {
 348             Log("%s: error reading length field for tag x%02x, aborting\n",
 349                 secname[section], tag);
 350             return 0;
 351         }
 352         if (!SkipData(iodp, taglen)) {
 353             Log("%s: error skipping %llu bytes for tag x%02x, aborting\n",
 354                 secname[section], taglen, tag);
 355             return 0;
 356         }
 357         return 1;
 358     }
 359     if (tag >= 0x61 && tag <= 0x7a) {
 360         if (!ReadInt32(iodp, &trash)) {
 361             Log("%s: error skipping int32 for tag x%02x, aborting\n",
 362                 secname[section], tag);
 363             return 0;
 364         }
 365         return 1;
 366     }
 367     if (tag >= 0x7b && tag < 0x80)      /* dataless tag */
 368         return 1;
 369     Log("%s: unknown invalid tag x%02x, aborting\n", secname[section], tag);
 370     return 0;
 371 }
 372
 373 static int
 374 ReadVolumeHeader(struct iod *iodp, VolumeDiskData * vol)
 375 {
 376     int tag;
 377     afs_uint32 trash;
 378     afs_int32 critical = 0;
 379     memset(vol, 0, sizeof(*vol));
 380     while ((tag = iod_getc(iodp)) > D_MAX && tag != EOF) {
 381         if (critical)
 382             critical--;
 383         switch (tag) {
 384         case 'i':
 385             if (!ReadInt32(iodp, &vol->id))
 386                 return VOLSERREAD_DUMPERROR;
 387             break;
 388         case 'v':
 389             if (!ReadInt32(iodp, &trash))
 390                 return VOLSERREAD_DUMPERROR;
 391             break;
 392         case 'n':
 393             ReadString(iodp, vol->name, sizeof(vol->name));
 394             /*this means the name of the retsored volume could be possibly different. In conjunction with SAFSVolSignalRestore */
 395             break;
 396         case 's':
 397             vol->inService = iod_getc(iodp);
 398             break;
 399         case 'b':
 400             vol->blessed = iod_getc(iodp);
 401             break;
 402         case 'u':
 403             if (!ReadInt32(iodp, &vol->uniquifier))
 404                 return VOLSERREAD_DUMPERROR;
 405             break;
 406         case 't':
 407             vol->type = iod_getc(iodp);
 408             break;
 409         case 'p':
 410             if (!ReadInt32(iodp, &vol->parentId))
 411                 return VOLSERREAD_DUMPERROR;
 412             break;
 413         case 'c':
 414             if (!ReadInt32(iodp, &vol->cloneId))
 415                 return VOLSERREAD_DUMPERROR;
 416             break;
 417         case 'q':
 418             if (!ReadInt32(iodp, (afs_uint32 *) & vol->maxquota))
 419                 return VOLSERREAD_DUMPERROR;
 420             break;
 421         case 'm':
 422             if (!ReadInt32(iodp, (afs_uint32 *) & vol->minquota))
 423                 return VOLSERREAD_DUMPERROR;
 424             break;
 425         case 'd':
 426             if (!ReadInt32(iodp, (afs_uint32 *) & vol->diskused))
 427                 return VOLSERREAD_DUMPERROR;    /* Bogus:  should calculate this */
 428             break;
 429         case 'f':
 430             if (!ReadInt32(iodp, (afs_uint32 *) & vol->filecount))
 431                 return VOLSERREAD_DUMPERROR;
 432             break;
 433         case 'a':
 434             if (!ReadInt32(iodp, &vol->accountNumber))
 435                 return VOLSERREAD_DUMPERROR;
 436             break;
 437         case 'o':
 438             if (!ReadInt32(iodp, &vol->owner))
 439                 return VOLSERREAD_DUMPERROR;
 440             break;
 441         case 'C':
 442             if (!ReadInt32(iodp, &vol->creationDate))
 443                 return VOLSERREAD_DUMPERROR;
 444             break;
 445         case 'A':
 446             if (!ReadInt32(iodp, &vol->accessDate))
 447                 return VOLSERREAD_DUMPERROR;
 448             break;
 449         case 'U':
 450             if (!ReadInt32(iodp, &vol->updateDate))
 451                 return VOLSERREAD_DUMPERROR;
 452             break;
 453         case 'E':
 454             if (!ReadInt32(iodp, &vol->expirationDate))
 455                 return VOLSERREAD_DUMPERROR;
 456             break;
 457         case 'B':
 458             if (!ReadInt32(iodp, &vol->backupDate))
 459                 return VOLSERREAD_DUMPERROR;
 460             break;
 461         case 'O':
 462             ReadString(iodp, vol->offlineMessage,
 463                        sizeof(vol->offlineMessage));
 464             break;
 465         case 'M':
 466             /*
 467              * Detailed volume statistics are never stored in dumps,
 468              * so we just restore either the null string if this volume
 469              * had already been set to store statistics, or the old motd
 470              * contents otherwise.  It doesn't matter, since this field
 471              * will soon get initialized anyway.
 472              */
 473             ReadString(iodp, (char *)(vol->stat_reads), VMSGSIZE);
 474             break;
 475         case 'W':{
 476                 unsigned short length;
 477                 int i;
 478                 afs_uint32 data;
 479                 if (!ReadShort(iodp, &length))
 480                     return VOLSERREAD_DUMPERROR;
 481                 for (i = 0; i < length; i++) {
 482                     if (!ReadInt32(iodp, &data))
 483                         return VOLSERREAD_DUMPERROR;
 484                     if (i < sizeof(vol->weekUse) / sizeof(vol->weekUse[0]))
 485                         vol->weekUse[i] = data;
 486                 }
 487                 break;
 488             }
 489         case 'D':
 490             if (!ReadInt32(iodp, &vol->dayUseDate))
 491                 return VOLSERREAD_DUMPERROR;
 492             break;
 493         case 'Z':
 494             if (!ReadInt32(iodp, (afs_uint32 *) & vol->dayUse))
 495                 return VOLSERREAD_DUMPERROR;
 496             break;
 497         case 'V':
 498             if (!ReadInt32(iodp, (afs_uint32 *) &trash/*volUpdateCounter*/))
 499                 return VOLSERREAD_DUMPERROR;
 500             break;
 501         case 0x7e:
 502             critical = 2;
 503             break;
 504         default:
 505             if (!HandleUnknownTag(iodp, tag, 1, critical))
 506                 return VOLSERREAD_DUMPERROR;
 507         }
 508     }
 509     iod_ungetc(iodp, tag);
 510     return 0;
 511 }
 512
 513 static int
 514 DumpTag(struct iod *iodp, int tag)
 515 {
 516     char p;
 517
 518     p = tag;
 519     return ((iod_Write(iodp, &p, 1) == 1) ? 0 : VOLSERDUMPERROR);
 520
 521 }
 522
 523 static int
 524 DumpByte(struct iod *iodp, char tag, byte value)
 525 {
 526     char tbuffer[2];
 527     byte *p = (unsigned char *)tbuffer;
 528     *p++ = tag;
 529     *p = value;
 530     return ((iod_Write(iodp, tbuffer, 2) == 2) ? 0 : VOLSERDUMPERROR);
 531 }
 532
 533 #define afs_putint32(p, v)  *p++ = v>>24, *p++ = v>>16, *p++ = v>>8, *p++ = v
 534 #define afs_putshort(p, v) *p++ = v>>8, *p++ = v
 535
 536 static int
 537 DumpDouble(struct iod *iodp, char tag, afs_uint32 value1,
 538            afs_uint32 value2)
 539 {
 540     char tbuffer[9];
 541     byte *p = (unsigned char *)tbuffer;
 542     *p++ = tag;
 543     afs_putint32(p, value1);
 544     afs_putint32(p, value2);
 545     return ((iod_Write(iodp, tbuffer, 9) == 9) ? 0 : VOLSERDUMPERROR);
 546 }
 547
 548 static int
 549 DumpInt32(struct iod *iodp, char tag, afs_uint32 value)
 550 {
 551     char tbuffer[5];
 552     byte *p = (unsigned char *)tbuffer;
 553     *p++ = tag;
 554     afs_putint32(p, value);
 555     return ((iod_Write(iodp, tbuffer, 5) == 5) ? 0 : VOLSERDUMPERROR);
 556 }
 557
 558 static int
 559 DumpArrayInt32(struct iod *iodp, char tag,
 560                afs_uint32 * array, int nelem)
 561 {
 562     char tbuffer[4];
 563     afs_uint32 v;
 564     int code = 0;
 565     byte *p = (unsigned char *)tbuffer;
 566     *p++ = tag;
 567     afs_putshort(p, nelem);
 568     code = iod_Write(iodp, tbuffer, 3);
 569     if (code != 3)
 570         return VOLSERDUMPERROR;
 571     while (nelem--) {
 572         p = (unsigned char *)tbuffer;
 573         v = *array++;           /*this was register */
 574
 575         afs_putint32(p, v);
 576         code = iod_Write(iodp, tbuffer, 4);
 577         if (code != 4)
 578             return VOLSERDUMPERROR;
 579     }
 580     return 0;
 581 }
 582
 583 static int
 584 DumpShort(struct iod *iodp, char tag, unsigned int value)
 585 {
 586     char tbuffer[3];
 587     byte *p = (unsigned char *)tbuffer;
 588     *p++ = tag;
 589     *p++ = value >> 8;
 590     *p = value;
 591     return ((iod_Write(iodp, tbuffer, 3) == 3) ? 0 : VOLSERDUMPERROR);
 592 }
 593
 594 static int
 595 DumpBool(struct iod *iodp, char tag, unsigned int value)
 596 {
 597     char tbuffer[2];
 598     byte *p = (unsigned char *)tbuffer;
 599     *p++ = tag;
 600     *p = value;
 601     return ((iod_Write(iodp, tbuffer, 2) == 2) ? 0 : VOLSERDUMPERROR);
 602 }
 603
 604 static int
 605 DumpString(struct iod *iodp, char tag, char *s)
 606 {
 607     int n;
 608     int code = 0;
 609     code = iod_Write(iodp, &tag, 1);
 610     if (code != 1)
 611         return VOLSERDUMPERROR;
 612     n = strlen(s) + 1;
 613     code = iod_Write(iodp, s, n);
 614     if (code != n)
 615         return VOLSERDUMPERROR;
 616     return 0;
 617 }
 618
 619 static int
 620 DumpByteString(struct iod *iodp, char tag, byte * bs,
 621                int nbytes)
 622 {
 623     int code = 0;
 624
 625     code = iod_Write(iodp, &tag, 1);
 626     if (code != 1)
 627         return VOLSERDUMPERROR;
 628     code = iod_Write(iodp, (char *)bs, nbytes);
 629     if (code != nbytes)
 630         return VOLSERDUMPERROR;
 631     return 0;
 632 }
 633
 634 static afs_int32
 635 DumpStandardTag(struct iod *iodp, char tag, afs_uint32 section)
 636 {
 637     afs_int32 code;
 638     afs_uint32 off = tag >> 5;
 639     afs_uint32 mask = 1 << (tag & 0x1f);
 640
 641     if (!oldtagsInited)
 642         initNonStandardTags();
 643
 644     if (tag < MIN_TLV_TAG
 645       || tag > MAX_STANDARD_TAG
 646       || section >= MAX_SECTIONS
 647       || (oldtags[section][ off] & mask)) {
 648         Log("Trying to use DumpStandardTag with tag 0x%02x for section %d, aborting\n", tag, section);
 649         return VOLSERDUMPERROR;
 650     }
 651     code = iod_Write(iodp, &tag, 1);
 652     if (code != 1)
 653         return VOLSERDUMPERROR;
 654     return 0;
 655 }
 656
 657 AFS_UNUSED
 658 static afs_int32
 659 DumpStandardTagLen(struct iod *iodp, char tag, afs_uint32 section,
 660                         afs_size_t length)
 661 {
 662     char buf[10];
 663     char *p;
 664     afs_int32 code, len;
 665
 666     if (tag < MIN_TLV_TAG || tag > MAX_TLV_TAG) {
 667         Log("Trying to use DumpStandardTagLen with tag 0x%02x for section %d, aborting\n", tag, section);
 668         return VOLSERDUMPERROR;
 669     }
 670     code = DumpStandardTag(iodp, tag, section);
 671     if (code)
 672         return code;
 673     p = &buf[9];
 674     if (length < 128) { /* byte after tag contains length */
 675         *p-- = length;
 676         len = 1;
 677     } else {            /* byte after tag contains length of length field | 0x80 */
 678         for (len=0; length; length=length >> 8) {
 679             *p-- = length;
 680             len++;
 681         }
 682         *p-- = len + 128;
 683         len += 1;
 684     }
 685     p++;
 686     code = iod_Write(iodp, p, len);
 687     if (code != len)
 688         return VOLSERDUMPERROR;
 689     return 0;
 690 }
 691
 692 static int
 693 DumpFile(struct iod *iodp, int vnode, FdHandle_t * handleP)
 694 {
 695     int code = 0, error = 0;
 696     afs_int32 pad = 0;
 697     afs_foff_t offset = 0;
 698     afs_sfsize_t nbytes, howBig;
 699     ssize_t n;
 700     size_t howMany;
 701     afs_foff_t howFar = 0;
 702     byte *p;
 703     afs_uint32 hi, lo;
 704     afs_ino_str_t stmp;
 705 #ifndef AFS_NT40_ENV
 706     struct afs_stat status;
 707 #endif
 708 #ifdef  AFS_AIX_ENV
 709 #include <sys/statfs.h>
 710 #if defined(AFS_AIX52_ENV)
 711     struct statfs64 tstatfs;
 712 #else /* !AFS_AIX52_ENV */
 713     struct statfs tstatfs;
 714 #endif /* !AFS_AIX52_ENV */
 715     int statfs_code;
 716 #endif
 717
 718 #ifdef AFS_NT40_ENV
 719     howBig = _filelength(handleP->fd_fd);
 720     howMany = 4096;
 721
 722 #else
 723     afs_fstat(handleP->fd_fd, &status);
 724     howBig = status.st_size;
 725
 726 #ifdef  AFS_AIX_ENV
 727     /* Unfortunately in AIX valuable fields such as st_blksize are
 728      * gone from the stat structure.
 729      */
 730 #if defined(AFS_AIX52_ENV)
 731     statfs_code = fstatfs64(handleP->fd_fd, &tstatfs);
 732 #else /* !AFS_AIX52_ENV */
 733     statfs_code = fstatfs(handleP->fd_fd, &tstatfs);
 734 #endif /* !AFS_AIX52_ENV */
 735     if (statfs_code != 0) {
 736         Log("DumpFile: fstatfs returned error code %d on descriptor %d\n", errno, handleP->fd_fd);
 737         return VOLSERDUMPERROR;
 738     }
 739     howMany = tstatfs.f_bsize;
 740 #else
 741     howMany = status.st_blksize;
 742 #endif /* AFS_AIX_ENV */
 743 #endif /* AFS_NT40_ENV */
 744
 745
 746     SplitInt64(howBig, hi, lo);
 747     if (hi == 0L) {
 748         code = DumpInt32(iodp, 'f', lo);
 749     } else {
 750         code = DumpDouble(iodp, 'h', hi, lo);
 751     }
 752     if (code) {
 753         return VOLSERDUMPERROR;
 754     }
 755
 756     p = malloc(howMany);
 757     if (!p) {
 758         Log("1 Volser: DumpFile: not enough memory to allocate %u bytes\n", (unsigned)howMany);
 759         return VOLSERDUMPERROR;
 760     }
 761
 762     for (nbytes = howBig; (nbytes && !error); nbytes -= howMany) {
 763         if (nbytes < howMany)
 764             howMany = nbytes;
 765
 766         /* Read the data */
 767         n = FDH_PREAD(handleP, p, howMany, howFar);
 768         howFar += n;
 769
 770         /* If read any good data and we null padded previously, log the
 771          * amount that we had null padded.
 772          */
 773         if ((n > 0) && pad) {
 774             Log("1 Volser: DumpFile: Null padding file %d bytes at offset %lld\n", pad, (long long)offset);
 775             pad = 0;
 776         }
 777
 778         /* If didn't read enough data, null padd the rest of the buffer. This
 779          * can happen if, for instance, the media has some bad spots. We don't
 780          * want to quit the dump, so we start null padding.
 781          */
 782         if (n < howMany) {
 783             /* Record the read error */
 784             if (n < 0) {
 785                 n = 0;
 786                 Log("1 Volser: DumpFile: Error reading inode %s for vnode %d: %s\n", PrintInode(stmp, handleP->fd_ih->ih_ino), vnode, afs_error_message(errno));
 787             } else if (!pad) {
 788                 Log("1 Volser: DumpFile: Error reading inode %s for vnode %d\n", PrintInode(stmp, handleP->fd_ih->ih_ino), vnode);
 789             }
 790
 791             /* Pad the rest of the buffer with zeros. Remember offset we started
 792              * padding. Keep total tally of padding.
 793              */
 794             memset(p + n, 0, howMany - n);
 795             if (!pad)
 796                 offset = (howBig - nbytes) + n;
 797             pad += (howMany - n);
 798
 799             /* Now seek over the data we could not get. An error here means we
 800              * can't do the next read.
 801              */
 802             howFar = (size_t)((howBig - nbytes) + howMany);
 803         }
 804
 805         /* Now write the data out */
 806         if (iod_Write(iodp, (char *)p, howMany) != howMany)
 807             error = VOLSERDUMPERROR;
 808 #ifndef AFS_PTHREAD_ENV
 809         IOMGR_Poll();
 810 #endif
 811     }
 812
 813     if (pad) {                  /* Any padding we hadn't reported yet */
 814         Log("1 Volser: DumpFile: Null padding file: %d bytes at offset %lld\n",
 815             pad, (long long)offset);
 816     }
 817
 818     free(p);
 819     return error;
 820 }
 821
 822 static int
 823 DumpVolumeHeader(struct iod *iodp, Volume * vp)
 824 {
 825     int code = 0;
 826     static char nullString[1] = "";     /*The ``contents'' of motd */
 827
 828     if (!code)
 829         code = DumpTag(iodp, D_VOLUMEHEADER);
 830     if (!code) {
 831         code = DumpInt32(iodp, 'i', V_id(vp));
 832     }
 833     if (!code)
 834         code = DumpInt32(iodp, 'v', V_stamp(vp).version);
 835     if (!code)
 836         code = DumpString(iodp, 'n', V_name(vp));
 837     if (!code)
 838         code = DumpBool(iodp, 's', V_inService(vp));
 839     if (!code)
 840         code = DumpBool(iodp, 'b', V_blessed(vp));
 841     if (!code)
 842         code = DumpInt32(iodp, 'u', V_uniquifier(vp));
 843     if (!code)
 844         code = DumpByte(iodp, 't', (byte) V_type(vp));
 845     if (!code) {
 846         code = DumpInt32(iodp, 'p', V_parentId(vp));
 847     }
 848     if (!code)
 849         code = DumpInt32(iodp, 'c', V_cloneId(vp));
 850     if (!code)
 851         code = DumpInt32(iodp, 'q', V_maxquota(vp));
 852     if (!code)
 853         code = DumpInt32(iodp, 'm', V_minquota(vp));
 854     if (!code)
 855         code = DumpInt32(iodp, 'd', V_diskused(vp));
 856     if (!code)
 857         code = DumpInt32(iodp, 'f', V_filecount(vp));
 858     if (!code)
 859         code = DumpInt32(iodp, 'a', V_accountNumber(vp));
 860     if (!code)
 861         code = DumpInt32(iodp, 'o', V_owner(vp));
 862     if (!code)
 863         code = DumpInt32(iodp, 'C', V_creationDate(vp));        /* Rw volume creation date */
 864     if (!code)
 865         code = DumpInt32(iodp, 'A', V_accessDate(vp));
 866     if (!code)
 867         code = DumpInt32(iodp, 'U', V_updateDate(vp));
 868     if (!code)
 869         code = DumpInt32(iodp, 'E', V_expirationDate(vp));
 870     if (!code)
 871         code = DumpInt32(iodp, 'B', V_backupDate(vp));  /* Rw volume backup clone date */
 872     if (!code)
 873         code = DumpString(iodp, 'O', V_offlineMessage(vp));
 874     /*
 875      * We do NOT dump the detailed volume statistics residing in the old
 876      * motd field, since we cannot tell from the info in a dump whether
 877      * statistics data has been put there.  Instead, we dump a null string,
 878      * just as if that was what the motd contained.
 879      */
 880     if (!code)
 881         code = DumpString(iodp, 'M', nullString);
 882     if (!code)
 883         code =
 884             DumpArrayInt32(iodp, 'W', (afs_uint32 *) V_weekUse(vp),
 885                            sizeof(V_weekUse(vp)) / sizeof(V_weekUse(vp)[0]));
 886     if (!code)
 887         code = DumpInt32(iodp, 'D', V_dayUseDate(vp));
 888     if (!code)
 889         code = DumpInt32(iodp, 'Z', V_dayUse(vp));
 890     return code;
 891 }
 892
 893 static int
 894 DumpEnd(struct iod *iodp)
 895 {
 896     return (DumpInt32(iodp, D_DUMPEND, DUMPENDMAGIC));
 897 }
 898
 899 /* Guts of the dump code */
 900
 901 /* Dump a whole volume */
 902 int
 903 DumpVolume(struct rx_call *call, Volume * vp,
 904            afs_int32 fromtime, int dumpAllDirs)
 905 {
 906     struct iod iod;
 907     int code = 0;
 908     struct iod *iodp = &iod;
 909     iod_Init(iodp, call);
 910
 911     if (!code)
 912         code = DumpDumpHeader(iodp, vp, fromtime);
 913
 914     if (!code)
 915         code = DumpPartial(iodp, vp, fromtime, dumpAllDirs);
 916
 917 /* hack follows.  Errors should be handled quite differently in this version of dump than they used to be.*/
 918     if (rx_Error(iodp->call)) {
 919         Log("1 Volser: DumpVolume: Rx call failed during dump, error %d\n",
 920             rx_Error(iodp->call));
 921         return VOLSERDUMPERROR;
 922     }
 923     if (!code)
 924         code = DumpEnd(iodp);
 925
 926     return code;
 927 }
 928
 929 /* Dump a volume to multiple places*/
 930 int
 931 DumpVolMulti(struct rx_call **calls, int ncalls, Volume * vp,
 932              afs_int32 fromtime, int dumpAllDirs, int *codes)
 933 {
 934     struct iod iod;
 935     int code = 0;
 936     iod_InitMulti(&iod, calls, ncalls, codes);
 937
 938     if (!code)
 939         code = DumpDumpHeader(&iod, vp, fromtime);
 940     if (!code)
 941         code = DumpPartial(&iod, vp, fromtime, dumpAllDirs);
 942     if (!code)
 943         code = DumpEnd(&iod);
 944     return code;
 945 }
 946
 947 /* A partial dump (no dump header) */
 948 static int
 949 DumpPartial(struct iod *iodp, Volume * vp,
 950             afs_int32 fromtime, int dumpAllDirs)
 951 {
 952     int code = 0;
 953     if (!code)
 954         code = DumpVolumeHeader(iodp, vp);
 955     if (!code)
 956         code = DumpVnodeIndex(iodp, vp, vLarge, fromtime, dumpAllDirs);
 957     if (!code)
 958         code = DumpVnodeIndex(iodp, vp, vSmall, fromtime, 0);
 959     return code;
 960 }
 961
 962 static int
 963 DumpVnodeIndex(struct iod *iodp, Volume * vp, VnodeClass class,
 964                afs_int32 fromtime, int forcedump)
 965 {
 966     int code = 0;
 967     struct VnodeClassInfo *vcp = &VnodeClassInfo[class];
 968     char buf[SIZEOF_LARGEDISKVNODE];
 969     struct VnodeDiskObject *vnode = (struct VnodeDiskObject *)buf;
 970     StreamHandle_t *file;
 971     FdHandle_t *fdP;
 972     afs_sfsize_t size, nVnodes;
 973     int flag;
 974     int vnodeIndex;
 975
 976     fdP = IH_OPEN(vp->vnodeIndex[class].handle);
 977     osi_Assert(fdP != NULL);
 978     file = FDH_FDOPEN(fdP, "r+");
 979     osi_Assert(file != NULL);
 980     size = OS_SIZE(fdP->fd_fd);
 981     osi_Assert(size != -1);
 982     nVnodes = (size / vcp->diskSize) - 1;
 983     if (nVnodes > 0) {
 984         osi_Assert((nVnodes + 1) * vcp->diskSize == size);
 985         osi_Assert(STREAM_ASEEK(file, vcp->diskSize) == 0);
 986     } else
 987         nVnodes = 0;
 988     for (vnodeIndex = 0;
 989          nVnodes && STREAM_READ(vnode, vcp->diskSize, 1, file) == 1 && !code;
 990          nVnodes--, vnodeIndex++) {
 991         flag = forcedump || (vnode->serverModifyTime >= fromtime);
 992         /* Note:  the >= test is very important since some old volumes may not have
 993          * a serverModifyTime.  For an epoch dump, this results in 0>=0 test, which
 994          * does dump the file! */
 995         if (!code)
 996             code =
 997                 DumpVnode(iodp, vnode, V_id(vp),
 998                           bitNumberToVnodeNumber(vnodeIndex, class), flag);
 999 #ifndef AFS_PTHREAD_ENV
1000         if (!flag)
1001             IOMGR_Poll();       /* if we dont' xfr data, but scan instead, could lose conn */
1002 #endif
1003     }
1004     STREAM_CLOSE(file);
1005     FDH_CLOSE(fdP);
1006     return code;
1007 }
1008
1009 static int
1010 DumpDumpHeader(struct iod *iodp, Volume * vp,
1011                afs_int32 fromtime)
1012 {
1013     int code = 0;
1014     int UseLatestReadOnlyClone = 1;
1015     afs_int32 dumpTimes[2];
1016     iodp->device = vp->device;
1017     iodp->parentId = V_parentId(vp);
1018     iodp->dumpPartition = vp->partition;
1019     if (!code)
1020         code = DumpDouble(iodp, D_DUMPHEADER, DUMPBEGINMAGIC, DUMPVERSION);
1021     if (!code)
1022         code =
1023             DumpInt32(iodp, 'v',
1024                       UseLatestReadOnlyClone ? V_id(vp) : V_parentId(vp));
1025     if (!code)
1026         code = DumpString(iodp, 'n', V_name(vp));
1027     dumpTimes[0] = fromtime;
1028     dumpTimes[1] = V_backupDate(vp);    /* Until the time the clone was made */
1029     if (!code)
1030         code = DumpArrayInt32(iodp, 't', (afs_uint32 *) dumpTimes, 2);
1031     return code;
1032 }
1033
1034 static int
1035 DumpVnode(struct iod *iodp, struct VnodeDiskObject *v, int volid,
1036           int vnodeNumber, int dumpEverything)
1037 {
1038     int code = 0;
1039     IHandle_t *ihP;
1040     FdHandle_t *fdP;
1041
1042     if (!v || v->type == vNull)
1043         return code;
1044     if (!code)
1045         code = DumpDouble(iodp, D_VNODE, vnodeNumber, v->uniquifier);
1046     if (!dumpEverything)
1047         return code;
1048     if (!code)
1049         code = DumpByte(iodp, 't', (byte) v->type);
1050     if (!code)
1051         code = DumpShort(iodp, 'l', v->linkCount);      /* May not need this */
1052     if (!code)
1053         code = DumpInt32(iodp, 'v', v->dataVersion);
1054     if (!code)
1055         code = DumpInt32(iodp, 'm', v->unixModifyTime);
1056     if (!code)
1057         code = DumpInt32(iodp, 'a', v->author);
1058     if (!code)
1059         code = DumpInt32(iodp, 'o', v->owner);
1060     if (!code && v->group)
1061         code = DumpInt32(iodp, 'g', v->group);  /* default group is 0 */
1062     if (!code)
1063         code = DumpShort(iodp, 'b', v->modeBits);
1064     if (!code)
1065         code = DumpInt32(iodp, 'p', v->parent);
1066     if (!code)
1067         code = DumpInt32(iodp, 's', v->serverModifyTime);
1068     if (v->type == vDirectory) {
1069         acl_HtonACL(VVnodeDiskACL(v));
1070         if (!code)
1071             code =
1072                 DumpByteString(iodp, 'A', (byte *) VVnodeDiskACL(v),
1073                                VAclDiskSize(v));
1074     }
1075     if (VNDISK_GET_INO(v)) {
1076         IH_INIT(ihP, iodp->device, iodp->parentId, VNDISK_GET_INO(v));
1077         fdP = IH_OPEN(ihP);
1078         if (fdP == NULL) {
1079             Log("1 Volser: DumpVnode: dump: Unable to open inode %llu for vnode %u (volume %i); not dumped, error %d\n", (afs_uintmax_t) VNDISK_GET_INO(v), vnodeNumber, volid, errno);
1080             IH_RELEASE(ihP);
1081             return VOLSERREAD_DUMPERROR;
1082         }
1083         code = DumpFile(iodp, vnodeNumber, fdP);
1084         FDH_CLOSE(fdP);
1085         IH_RELEASE(ihP);
1086     }
1087     return code;
1088 }
1089
1090
1091 int
1092 ProcessIndex(Volume * vp, VnodeClass class, afs_foff_t ** Bufp, int *sizep,
1093              int del)
1094 {
1095     int i, nVnodes, code;
1096     afs_foff_t offset;
1097     afs_foff_t *Buf;
1098     int cnt = 0;
1099     afs_sfsize_t size;
1100     StreamHandle_t *afile;
1101     FdHandle_t *fdP;
1102     struct VnodeClassInfo *vcp = &VnodeClassInfo[class];
1103     char buf[SIZEOF_LARGEDISKVNODE], zero[SIZEOF_LARGEDISKVNODE];
1104     struct VnodeDiskObject *vnode = (struct VnodeDiskObject *)buf;
1105
1106     memset(zero, 0, sizeof(zero));      /* zero out our proto-vnode */
1107     fdP = IH_OPEN(vp->vnodeIndex[class].handle);
1108     if (fdP == NULL)
1109         return -1;
1110     afile = FDH_FDOPEN(fdP, "r+");
1111     if (del) {
1112         int cnt1 = 0;
1113         Buf = *Bufp;
1114         for (i = 0; i < *sizep; i++) {
1115             if (Buf[i]) {
1116                 cnt++;
1117                 STREAM_ASEEK(afile, Buf[i]);
1118                 code = STREAM_READ(vnode, vcp->diskSize, 1, afile);
1119                 if (code == 1) {
1120                     if (vnode->type != vNull && VNDISK_GET_INO(vnode)) {
1121                         cnt1++;
1122                         if (DoLogging) {
1123                             Log("RestoreVolume %u Cleanup: Removing old vnode=%u inode=%llu size=unknown\n",
1124                      V_id(vp), bitNumberToVnodeNumber(i, class),
1125                      (afs_uintmax_t) VNDISK_GET_INO(vnode));
1126                         }
1127                         IH_DEC(V_linkHandle(vp), VNDISK_GET_INO(vnode),
1128                                V_parentId(vp));
1129                         DOPOLL;
1130                     }
1131                     STREAM_ASEEK(afile, Buf[i]);
1132                     (void)STREAM_WRITE(zero, vcp->diskSize, 1, afile);  /* Zero it out */
1133                 }
1134                 Buf[i] = 0;
1135             }
1136         }
1137         if (DoLogging) {
1138             Log("RestoreVolume Cleanup: Removed %d inodes for volume %d\n",
1139                 cnt1, V_id(vp));
1140         }
1141         STREAM_FLUSH(afile);    /* ensure 0s are on the disk */
1142         OS_SYNC(afile->str_fd);
1143     } else {
1144         size = OS_SIZE(fdP->fd_fd);
1145         osi_Assert(size != -1);
1146         nVnodes =
1147             (size <=
1148              vcp->diskSize ? 0 : size - vcp->diskSize) >> vcp->logSize;
1149         if (nVnodes > 0) {
1150             if (DoLogging) {
1151                 Log("RestoreVolume ProcessIndex: Set up %d inodes for volume %d\n",
1152                     nVnodes, V_id(vp));
1153             }
1154             Buf = malloc(nVnodes * sizeof(afs_foff_t));
1155             if (Buf == NULL) {
1156                 STREAM_CLOSE(afile);
1157                 FDH_CLOSE(fdP);
1158                 return -1;
1159             }
1160             memset(Buf, 0, nVnodes * sizeof(afs_foff_t));
1161             STREAM_ASEEK(afile, offset = vcp->diskSize);
1162             while (1) {
1163                 code = STREAM_READ(vnode, vcp->diskSize, 1, afile);
1164                 if (code != 1) {
1165                     break;
1166                 }
1167                 if (vnode->type != vNull && VNDISK_GET_INO(vnode)) {
1168                     Buf[(offset >> vcp->logSize) - 1] = offset;
1169                     cnt++;
1170                 }
1171                 offset += vcp->diskSize;
1172             }
1173             if (DoLogging) {
1174                 Log("RestoreVolume ProcessIndex: found %d inodes\n", cnt);
1175             }
1176             *Bufp = Buf;
1177             *sizep = nVnodes;
1178         }
1179     }
1180     STREAM_CLOSE(afile);
1181     FDH_CLOSE(fdP);
1182     return 0;
1183 }
1184
1185
1186 int
1187 RestoreVolume(struct rx_call *call, Volume * avp, int incremental,
1188               struct restoreCookie *cookie)
1189 {
1190     VolumeDiskData vol;
1191     struct DumpHeader header;
1192     afs_uint32 endMagic;
1193     Error error = 0, vupdate;
1194     Volume *vp;
1195     struct iod iod;
1196     struct iod *iodp = &iod;
1197     afs_foff_t *b1 = NULL, *b2 = NULL;
1198     int s1 = 0, s2 = 0, delo = 0, tdelo;
1199     int tag;
1200
1201     iod_Init(iodp, call);
1202
1203     vp = avp;
1204
1205     if (!ReadDumpHeader(iodp, &header)) {
1206         Log("1 Volser: RestoreVolume: Error reading header file for dump; aborted\n");
1207         return VOLSERREAD_DUMPERROR;
1208     }
1209     if (iod_getc(iodp) != D_VOLUMEHEADER) {
1210         Log("1 Volser: RestoreVolume: Volume header missing from dump; not restored\n");
1211         return VOLSERREAD_DUMPERROR;
1212     }
1213     if (ReadVolumeHeader(iodp, &vol) == VOLSERREAD_DUMPERROR)
1214         return VOLSERREAD_DUMPERROR;
1215
1216     if (!delo)
1217         delo = ProcessIndex(vp, vLarge, &b1, &s1, 0);
1218     if (!delo)
1219         delo = ProcessIndex(vp, vSmall, &b2, &s2, 0);
1220     if (delo < 0) {
1221         Log("1 Volser: RestoreVolume: ProcessIndex failed; not restored\n");
1222         error = VOLSERREAD_DUMPERROR;
1223         goto out;
1224     }
1225
1226     strncpy(vol.name, cookie->name, VOLSER_OLDMAXVOLNAME);
1227     vol.type = cookie->type;
1228     vol.cloneId = cookie->clone;
1229     vol.parentId = cookie->parent;
1230
1231     tdelo = delo;
1232     while (1) {
1233         if (ReadVnodes(iodp, vp, 0, b1, s1, b2, s2, tdelo)) {
1234             error = VOLSERREAD_DUMPERROR;
1235             goto clean;
1236         }
1237         tag = iod_getc(iodp);
1238         if (tag != D_VOLUMEHEADER)
1239             break;
1240
1241         if (ReadVolumeHeader(iodp, &vol) == VOLSERREAD_DUMPERROR) {
1242             error = VOLSERREAD_DUMPERROR;
1243             goto out;
1244         }
1245     }
1246     if (tag != D_DUMPEND || !ReadInt32(iodp, &endMagic)
1247         || endMagic != DUMPENDMAGIC) {
1248         Log("1 Volser: RestoreVolume: End of dump not found; restore aborted\n");
1249         error = VOLSERREAD_DUMPERROR;
1250         goto clean;
1251     }
1252
1253
1254     if (iod_getc(iodp) != EOF) {
1255         Log("1 Volser: RestoreVolume: Unrecognized postamble in dump; restore aborted\n");
1256         error = VOLSERREAD_DUMPERROR;
1257         goto clean;
1258     }
1259
1260     if (!delo) {
1261         delo = ProcessIndex(vp, vLarge, &b1, &s1, 1);
1262         if (!delo)
1263             delo = ProcessIndex(vp, vSmall, &b2, &s2, 1);
1264         if (delo < 0) {
1265             error = VOLSERREAD_DUMPERROR;
1266             goto clean;
1267         }
1268     }
1269
1270   clean:
1271     ClearVolumeStats(&vol);
1272     CopyVolumeHeader(&vol, &V_disk(vp));
1273     V_destroyMe(vp) = 0;
1274     VUpdateVolume(&vupdate, vp);
1275     if (vupdate) {
1276         Log("1 Volser: RestoreVolume: Unable to rewrite volume header; restore aborted\n");
1277         error = VOLSERREAD_DUMPERROR;
1278         goto out;
1279     }
1280   out:
1281     /* Free the malloced space above */
1282     if (b1)
1283         free((char *)b1);
1284     if (b2)
1285         free((char *)b2);
1286     return error;
1287 }
1288
1289 static int
1290 ReadVnodes(struct iod *iodp, Volume * vp, int incremental,
1291            afs_foff_t * Lbuf, afs_int32 s1, afs_foff_t * Sbuf, afs_int32 s2,
1292            afs_int32 delo)
1293 {
1294     afs_int32 vnodeNumber;
1295     char buf[SIZEOF_LARGEDISKVNODE];
1296     int tag;
1297     struct VnodeDiskObject *vnode = (struct VnodeDiskObject *)buf;
1298     struct VnodeDiskObject oldvnode;
1299     int idx;
1300     VnodeClass class;
1301     struct VnodeClassInfo *vcp;
1302     IHandle_t *tmpH;
1303     FdHandle_t *fdP;
1304     Inode nearInode AFS_UNUSED;
1305     afs_int32 critical = 0;
1306
1307     tag = iod_getc(iodp);
1308     V_pref(vp, nearInode);
1309     while (tag == D_VNODE) {
1310         int haveStuff = 0;
1311         int saw_f = 0;
1312         memset(buf, 0, sizeof(buf));
1313         if (!ReadInt32(iodp, (afs_uint32 *) & vnodeNumber))
1314             break;
1315
1316         if (!ReadInt32(iodp, &vnode->uniquifier))
1317             return VOLSERREAD_DUMPERROR;
1318
1319         if (DoLogging) {
1320             Log("ReadVnodes: setup %d/%d\n", vnodeNumber, vnode->uniquifier);
1321         }
1322         while ((tag = iod_getc(iodp)) > D_MAX && tag != EOF) {
1323             haveStuff = 1;
1324             if (critical)
1325                 critical--;
1326             switch (tag) {
1327             case 't':
1328                 vnode->type = (VnodeType) iod_getc(iodp);
1329                 break;
1330             case 'l':
1331                 {
1332                     unsigned short tlc;
1333                     if (!ReadShort(iodp, &tlc))
1334                         return VOLSERREAD_DUMPERROR;
1335                     vnode->linkCount = (signed int)tlc;
1336                 }
1337                 break;
1338             case 'v':
1339                 if (!ReadInt32(iodp, &vnode->dataVersion))
1340                     return VOLSERREAD_DUMPERROR;
1341                 break;
1342             case 'm':
1343                 if (!ReadInt32(iodp, &vnode->unixModifyTime))
1344                     return VOLSERREAD_DUMPERROR;
1345                 break;
1346             case 's':
1347                 if (!ReadInt32(iodp, &vnode->serverModifyTime))
1348                     return VOLSERREAD_DUMPERROR;
1349                 break;
1350             case 'a':
1351                 if (!ReadInt32(iodp, &vnode->author))
1352                     return VOLSERREAD_DUMPERROR;
1353                 break;
1354             case 'o':
1355                 if (!ReadInt32(iodp, &vnode->owner))
1356                     return VOLSERREAD_DUMPERROR;
1357                 break;
1358             case 'g':
1359                 if (!ReadInt32(iodp, (afs_uint32 *) & vnode->group))
1360                     return VOLSERREAD_DUMPERROR;
1361                 break;
1362             case 'b':{
1363                     unsigned short modeBits;
1364                     if (!ReadShort(iodp, &modeBits))
1365                         return VOLSERREAD_DUMPERROR;
1366                     vnode->modeBits = (unsigned int)modeBits;
1367                     break;
1368                 }
1369             case 'p':
1370                 if (!ReadInt32(iodp, &vnode->parent))
1371                     return VOLSERREAD_DUMPERROR;
1372                 break;
1373             case 'A':
1374                 ReadByteString(iodp, (byte *) VVnodeDiskACL(vnode),
1375                                VAclDiskSize(vnode));
1376                 acl_NtohACL(VVnodeDiskACL(vnode));
1377                 break;
1378             case 'h':
1379             case 'f':{
1380                     Inode ino;
1381                     Error error;
1382                     afs_fsize_t vnodeLength;
1383
1384                     if (saw_f) {
1385                         Log("Volser: ReadVnodes: warning: ignoring duplicate "
1386                             "file entries for vnode %lu in dump\n",
1387                             (unsigned long)vnodeNumber);
1388                         volser_WriteFile(vnodeNumber, iodp, NULL, tag, &error);
1389                         break;
1390                     }
1391                     saw_f = 1;
1392
1393                     ino =
1394                         IH_CREATE(V_linkHandle(vp), V_device(vp),
1395                                   VPartitionPath(V_partition(vp)), nearInode,
1396                                   V_parentId(vp), vnodeNumber,
1397                                   vnode->uniquifier, vnode->dataVersion);
1398                     if (!VALID_INO(ino)) {
1399                         Log("1 Volser: ReadVnodes: IH_CREATE: %s - restore aborted\n",
1400                             afs_error_message(errno));
1401                         V_needsSalvaged(vp) = 1;
1402                         return VOLSERREAD_DUMPERROR;
1403                     }
1404                     nearInode = ino;
1405                     VNDISK_SET_INO(vnode, ino);
1406                     IH_INIT(tmpH, vp->device, V_parentId(vp), ino);
1407                     fdP = IH_OPEN(tmpH);
1408                     if (fdP == NULL) {
1409                         Log("1 Volser: ReadVnodes: IH_OPEN: %s - restore aborted\n",
1410                             afs_error_message(errno));
1411                         IH_RELEASE(tmpH);
1412                         V_needsSalvaged(vp) = 1;
1413                         return VOLSERREAD_DUMPERROR;
1414                     }
1415                     vnodeLength =
1416                         volser_WriteFile(vnodeNumber, iodp, fdP, tag, &error);
1417                     VNDISK_SET_LEN(vnode, vnodeLength);
1418                     FDH_REALLYCLOSE(fdP);
1419                     IH_RELEASE(tmpH);
1420                     if (error) {
1421                         Log("1 Volser: ReadVnodes: IDEC inode %llu\n",
1422                             (afs_uintmax_t) ino);
1423                         IH_DEC(V_linkHandle(vp), ino, V_parentId(vp));
1424                         V_needsSalvaged(vp) = 1;
1425                         return VOLSERREAD_DUMPERROR;
1426                     }
1427                     break;
1428                 }
1429             case 0x7e:
1430                 critical = 2;
1431                 break;
1432             default:
1433                 if (!HandleUnknownTag(iodp, tag, 2, critical))
1434                     return VOLSERREAD_DUMPERROR;
1435             }
1436         }
1437
1438         class = vnodeIdToClass(vnodeNumber);
1439         vcp = &VnodeClassInfo[class];
1440
1441         /* Mark this vnode as in this dump - so we don't delete it later */
1442         if (!delo) {
1443             idx = (vnodeIndexOffset(vcp, vnodeNumber) >> vcp->logSize) - 1;
1444             if (class == vLarge) {
1445                 if (Lbuf && (idx < s1))
1446                     Lbuf[idx] = 0;
1447             } else {
1448                 if (Sbuf && (idx < s2))
1449                     Sbuf[idx] = 0;
1450             }
1451         }
1452
1453         if (haveStuff) {
1454             FdHandle_t *fdP = IH_OPEN(vp->vnodeIndex[class].handle);
1455             if (fdP == NULL) {
1456                 Log("1 Volser: ReadVnodes: Error opening vnode index: %s; restore aborted\n",
1457                     afs_error_message(errno));
1458                 V_needsSalvaged(vp) = 1;
1459                 return VOLSERREAD_DUMPERROR;
1460             }
1461             if (FDH_PREAD(fdP, &oldvnode, sizeof(oldvnode), vnodeIndexOffset(vcp, vnodeNumber)) ==
1462                 sizeof(oldvnode)) {
1463                 if (oldvnode.type != vNull && VNDISK_GET_INO(&oldvnode)) {
1464                     IH_DEC(V_linkHandle(vp), VNDISK_GET_INO(&oldvnode),
1465                            V_parentId(vp));
1466                 }
1467             }
1468             vnode->vnodeMagic = vcp->magic;
1469             if (FDH_PWRITE(fdP, vnode, vcp->diskSize, vnodeIndexOffset(vcp, vnodeNumber)) != vcp->diskSize) {
1470                 Log("1 Volser: ReadVnodes: Error writing vnode index: %s; restore aborted\n",
1471                     afs_error_message(errno));
1472                 FDH_REALLYCLOSE(fdP);
1473                 V_needsSalvaged(vp) = 1;
1474                 return VOLSERREAD_DUMPERROR;
1475             }
1476             FDH_CLOSE(fdP);
1477         }
1478     }
1479     iod_ungetc(iodp, tag);
1480
1481     return 0;
1482 }
1483
1484
1485 /* called with disk file only.  Note that we don't have to worry about rx_Read
1486  * needing to read an ungetc'd character, since the ReadInt32 will have read
1487  * it instead.
1488  *
1489  * if handleP == NULL, don't write the file anywhere; just read and discard
1490  * the file contents
1491  */
1492 static afs_fsize_t
1493 volser_WriteFile(int vn, struct iod *iodp, FdHandle_t * handleP, int tag,
1494                  Error * status)
1495 {
1496     afs_int32 code;
1497     ssize_t nBytes;
1498     afs_fsize_t filesize;
1499     afs_fsize_t written = 0;
1500     size_t size = 8192;
1501     afs_fsize_t nbytes;
1502     unsigned char *p;
1503
1504
1505     *status = 0;
1506     {
1507         afs_uint32 filesize_high = 0L, filesize_low = 0L;
1508         if (tag == 'h') {
1509             if (!ReadInt32(iodp, &filesize_high)) {
1510                 *status = 1;
1511                 return 0;
1512             }
1513         }
1514         if (!ReadInt32(iodp, &filesize_low)) {
1515             *status = 1;
1516             return 0;
1517         }
1518         FillInt64(filesize, filesize_high, filesize_low);
1519     }
1520     p = (unsigned char *)malloc(size);
1521     if (p == NULL) {
1522         *status = 2;
1523         return (0);
1524     }
1525     for (nbytes = filesize; nbytes; nbytes -= size) {
1526         if (nbytes < size)
1527             size = nbytes;
1528
1529         if ((code = iod_Read(iodp, (char *) p, size)) != size) {
1530             Log("1 Volser: WriteFile: Error reading dump file %d size=%llu nbytes=%u (%d of %u): %s; restore aborted\n", vn, (afs_uintmax_t) filesize, nbytes, code, (unsigned)size, afs_error_message(errno));
1531             *status = 3;
1532             break;
1533         }
1534         if (handleP) {
1535             nBytes = FDH_PWRITE(handleP, p, size, written);
1536             if (nBytes > 0)
1537                 written += nBytes;
1538             if (nBytes != size) {
1539                 Log("1 Volser: WriteFile: Error writing (%u) bytes to vnode %d; %s; restore aborted\n", (int)(nBytes & 0xffffffff), vn, afs_error_message(errno));
1540                 *status = 4;
1541                 break;
1542             }
1543         }
1544     }
1545     free(p);
1546     return (written);
1547 }
1548
1549 static int
1550 ReadDumpHeader(struct iod *iodp, struct DumpHeader *hp)
1551 {
1552     int tag;
1553     afs_uint32 beginMagic;
1554     afs_int32 critical = 0;
1555     if (iod_getc(iodp) != D_DUMPHEADER || !ReadInt32(iodp, &beginMagic)
1556         || !ReadInt32(iodp, (afs_uint32 *) & hp->version)
1557         || beginMagic != DUMPBEGINMAGIC)
1558         return 0;
1559     hp->volumeId = 0;
1560     hp->nDumpTimes = 0;
1561     while ((tag = iod_getc(iodp)) > D_MAX) {
1562         unsigned short arrayLength;
1563         int i;
1564         if (critical)
1565             critical--;
1566         switch (tag) {
1567         case 'v':
1568             if (!ReadInt32(iodp, &hp->volumeId))
1569                 return 0;
1570             break;
1571         case 'n':
1572             ReadString(iodp, hp->volumeName, sizeof(hp->volumeName));
1573             break;
1574         case 't':
1575             if (!ReadShort(iodp, &arrayLength))
1576                 return 0;
1577             hp->nDumpTimes = (arrayLength >> 1);
1578             for (i = 0; i < hp->nDumpTimes; i++)
1579                 if (!ReadInt32(iodp, (afs_uint32 *) & hp->dumpTimes[i].from)
1580                     || !ReadInt32(iodp, (afs_uint32 *) & hp->dumpTimes[i].to))
1581                     return 0;
1582             break;
1583         case 0x7e:
1584             critical = 2;
1585             break;
1586         default:
1587             if (!HandleUnknownTag(iodp, tag, 0, critical))
1588                 return VOLSERREAD_DUMPERROR;
1589         }
1590     }
1591     if (!hp->volumeId || !hp->nDumpTimes) {
1592         return 0;
1593     }
1594     iod_ungetc(iodp, tag);
1595     return 1;
1596 }
1597
1598
1599 /* ----- Below are the calls that calculate dump size ----- */
1600
1601 static int
1602 SizeDumpVolumeHeader(struct iod *iodp, Volume * vp,
1603                      struct volintSize *v_size)
1604 {
1605     int code = 0;
1606     static char nullString[1] = "";     /*The ``contents'' of motd */
1607     afs_uint64 addvar;
1608
1609 /*     if (!code) code = DumpTag(iodp, D_VOLUMEHEADER); */
1610     FillInt64(addvar,0, 1);
1611     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1612 /*     if (!code) {code = DumpInt32(iodp, 'i',V_id(vp));} */
1613     FillInt64(addvar,0, 5);
1614     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1615 /*     if (!code) code = DumpInt32(iodp, 'v',V_stamp(vp).version); */
1616     FillInt64(addvar,0, 5);
1617     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1618 /*     if (!code) code = DumpString(iodp, 'n',V_name(vp)); */
1619     FillInt64(addvar,0, (2 + strlen(V_name(vp))));
1620     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1621 /*     if (!code) code = DumpBool(iodp, 's',V_inService(vp)); */
1622     FillInt64(addvar,0, 2);
1623     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1624 /*     if (!code) code = DumpBool(iodp, 'b',V_blessed(vp)); */
1625     FillInt64(addvar,0, 2);
1626     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1627 /*     if (!code) code = DumpInt32(iodp, 'u',V_uniquifier(vp)); */
1628     FillInt64(addvar,0, 5);
1629     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1630 /*     if (!code) code = DumpByte(iodp, 't',(byte)V_type(vp)); */
1631     FillInt64(addvar,0, 2);
1632     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1633 /*     if (!code){ code = DumpInt32(iodp, 'p',V_parentId(vp));} */
1634     FillInt64(addvar,0, 5);
1635     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1636 /*     if (!code) code = DumpInt32(iodp, 'c',V_cloneId(vp)); */
1637     FillInt64(addvar,0, 5);
1638     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1639 /*     if (!code) code = DumpInt32(iodp, 'q',V_maxquota(vp)); */
1640     FillInt64(addvar,0, 5);
1641     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1642 /*     if (!code) code = DumpInt32(iodp, 'm',V_minquota(vp)); */
1643     FillInt64(addvar,0, 5);
1644     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1645 /*     if (!code) code = DumpInt32(iodp, 'd',V_diskused(vp)); */
1646     FillInt64(addvar,0, 5);
1647     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1648 /*     if (!code) code = DumpInt32(iodp, 'f',V_filecount(vp)); */
1649     FillInt64(addvar,0, 5);
1650     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1651 /*     if (!code) code = DumpInt32(iodp, 'a', V_accountNumber(vp)); */
1652     FillInt64(addvar,0, 5);
1653     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1654 /*     if (!code) code = DumpInt32(iodp, 'o', V_owner(vp)); */
1655     FillInt64(addvar,0, 5);
1656     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1657 /*     if (!code) code = DumpInt32(iodp, 'C',V_creationDate(vp));       /\* Rw volume creation date *\/ */
1658     FillInt64(addvar,0, 5);
1659     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1660 /*     if (!code) code = DumpInt32(iodp, 'A',V_accessDate(vp)); */
1661     FillInt64(addvar,0, 5);
1662     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1663 /*     if (!code) code = DumpInt32(iodp, 'U',V_updateDate(vp)); */
1664     FillInt64(addvar,0, 5);
1665     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1666 /*     if (!code) code = DumpInt32(iodp, 'E',V_expirationDate(vp)); */
1667     FillInt64(addvar,0, 5);
1668     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1669 /*     if (!code) code = DumpInt32(iodp, 'B',V_backupDate(vp));         /\* Rw volume backup clone date *\/ */
1670     FillInt64(addvar,0, 5);
1671     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1672 /*     if (!code) code = DumpString(iodp, 'O',V_offlineMessage(vp)); */
1673     FillInt64(addvar,0, (2 + strlen(V_offlineMessage(vp))));
1674     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1675 /*     /\* */
1676 /*      * We do NOT dump the detailed volume statistics residing in the old */
1677 /*      * motd field, since we cannot tell from the info in a dump whether */
1678 /*      * statistics data has been put there.  Instead, we dump a null string, */
1679 /*      * just as if that was what the motd contained. */
1680 /*      *\/ */
1681 /*     if (!code) code = DumpString(iodp, 'M', nullString); */
1682     FillInt64(addvar,0, (2 + strlen(nullString)));
1683     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1684 /*     if (!code) code = DumpArrayInt32(iodp, 'W', (afs_uint32 *)V_weekUse(vp), sizeof(V_weekUse(vp))/sizeof(V_weekUse(vp)[0])); */
1685     FillInt64(addvar,0, (3 + 4 * (sizeof(V_weekUse(vp)) / sizeof(V_weekUse(vp)[0]))));
1686     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1687 /*     if (!code) code = DumpInt32(iodp, 'D', V_dayUseDate(vp)); */
1688     FillInt64(addvar,0, 5);
1689     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1690 /*     if (!code) code = DumpInt32(iodp, 'Z', V_dayUse(vp)); */
1691     FillInt64(addvar,0, 5);
1692     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1693     return code;
1694 }
1695
1696 static int
1697 SizeDumpEnd(struct iod *iodp, struct volintSize *v_size)
1698 {
1699     int code = 0;
1700     afs_uint64 addvar;
1701     FillInt64(addvar,0, 5);
1702     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1703     return code;
1704 }
1705
1706 int
1707 SizeDumpVolume(struct rx_call *call, Volume * vp,
1708                afs_int32 fromtime, int dumpAllDirs,
1709                struct volintSize *v_size)
1710 {
1711     int code = 0;
1712     struct iod *iodp = (struct iod *)0;
1713 /*    iod_Init(iodp, call); */
1714
1715     if (!code)
1716         code = SizeDumpDumpHeader(iodp, vp, fromtime, v_size);
1717     if (!code)
1718         code = SizeDumpPartial(iodp, vp, fromtime, dumpAllDirs, v_size);
1719     if (!code)
1720         code = SizeDumpEnd(iodp, v_size);
1721
1722     return code;
1723 }
1724
1725 static int
1726 SizeDumpDumpHeader(struct iod *iodp, Volume * vp,
1727                    afs_int32 fromtime, struct volintSize *v_size)
1728 {
1729     int code = 0;
1730 /*    int UseLatestReadOnlyClone = 1; */
1731 /*    afs_int32 dumpTimes[2]; */
1732     afs_uint64 addvar;
1733 /*    iodp->device = vp->device; */
1734 /*    iodp->parentId = V_parentId(vp); */
1735 /*    iodp->dumpPartition = vp->partition; */
1736
1737     ZeroInt64(v_size->dump_size);       /* initialize the size */
1738 /*     if (!code) code = DumpDouble(iodp, D_DUMPHEADER, DUMPBEGINMAGIC, DUMPVERSION); */
1739     FillInt64(addvar,0, 9);
1740     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1741 /*     if (!code) code = DumpInt32(iodp, 'v', UseLatestReadOnlyClone? V_id(vp): V_parentId(vp)); */
1742     FillInt64(addvar,0, 5);
1743     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1744 /*     if (!code) code = DumpString(iodp, 'n',V_name(vp)); */
1745     FillInt64(addvar,0, (2 + strlen(V_name(vp))));
1746     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1747 /*     dumpTimes[0] = fromtime; */
1748 /*     dumpTimes[1] = V_backupDate(vp); /\* Until the time the clone was made *\/ */
1749 /*     if (!code) code = DumpArrayInt32(iodp, 't', (afs_uint32 *)dumpTimes, 2); */
1750     FillInt64(addvar,0, (3 + 4 * 2));
1751     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1752     return code;
1753 }
1754
1755 static int
1756 SizeDumpVnode(struct iod *iodp, struct VnodeDiskObject *v, int volid,
1757               int vnodeNumber, int dumpEverything,
1758               struct volintSize *v_size)
1759 {
1760     int code = 0;
1761     afs_uint64 addvar;
1762
1763     if (!v || v->type == vNull)
1764         return code;
1765 /*     if (!code) code = DumpDouble(iodp, D_VNODE, vnodeNumber, v->uniquifier); */
1766     FillInt64(addvar,0, 9);
1767     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1768     if (!dumpEverything)
1769         return code;
1770 /*     if (!code)  code = DumpByte(iodp, 't',(byte)v->type); */
1771     FillInt64(addvar,0, 2);
1772     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1773 /*     if (!code) code = DumpShort(iodp, 'l', v->linkCount); /\* May not need this *\/ */
1774     FillInt64(addvar,0, 3);
1775     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1776 /*     if (!code) code = DumpInt32(iodp, 'v', v->dataVersion); */
1777     FillInt64(addvar,0, 5);
1778     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1779 /*     if (!code) code = DumpInt32(iodp, 'm', v->unixModifyTime); */
1780     FillInt64(addvar,0, 5);
1781     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1782 /*     if (!code) code = DumpInt32(iodp, 'a', v->author); */
1783     FillInt64(addvar,0, 5);
1784     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1785 /*     if (!code) code = DumpInt32(iodp, 'o', v->owner); */
1786     FillInt64(addvar,0, 5);
1787     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1788 /*     if (!code && v->group) code = DumpInt32(iodp, 'g', v->group);    /\* default group is 0 *\/ */
1789     if (v->group) {
1790         FillInt64(addvar,0, 5);
1791         AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1792     }
1793 /*     if (!code) code = DumpShort(iodp, 'b', v->modeBits); */
1794     FillInt64(addvar,0, 3);
1795     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1796 /*     if (!code) code = DumpInt32(iodp, 'p', v->parent); */
1797     FillInt64(addvar,0, 5);
1798     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1799 /*     if (!code) code = DumpInt32(iodp, 's', v->serverModifyTime); */
1800     FillInt64(addvar,0, 5);
1801     AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1802     if (v->type == vDirectory) {
1803 /*      acl_HtonACL(VVnodeDiskACL(v)); */
1804 /*      if (!code) code = DumpByteString(iodp, 'A', (byte *) VVnodeDiskACL(v), VAclDiskSize(v)); */
1805         FillInt64(addvar,0, (1 + VAclDiskSize(v)));
1806         AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1807     }
1808
1809     if (VNDISK_GET_INO(v)) {
1810         FillInt64(addvar,0, (v->length + 5));
1811         AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1812     }
1813     return code;
1814 }
1815
1816 /* A partial dump (no dump header) */
1817 static int
1818 SizeDumpPartial(struct iod *iodp, Volume * vp,
1819                 afs_int32 fromtime, int dumpAllDirs,
1820                 struct volintSize *v_size)
1821 {
1822     int code = 0;
1823     if (!code)
1824         code = SizeDumpVolumeHeader(iodp, vp, v_size);
1825     if (!code)
1826         code =
1827             SizeDumpVnodeIndex(iodp, vp, vLarge, fromtime, dumpAllDirs,
1828                                v_size);
1829     if (!code)
1830         code = SizeDumpVnodeIndex(iodp, vp, vSmall, fromtime, 0, v_size);
1831     return code;
1832 }
1833
1834 static int
1835 SizeDumpVnodeIndex(struct iod *iodp, Volume * vp, VnodeClass class,
1836                    afs_int32 fromtime, int forcedump,
1837                    struct volintSize *v_size)
1838 {
1839     int code = 0;
1840     struct VnodeClassInfo *vcp = &VnodeClassInfo[class];
1841     char buf[SIZEOF_LARGEDISKVNODE];
1842     struct VnodeDiskObject *vnode = (struct VnodeDiskObject *)buf;
1843     StreamHandle_t *file;
1844     FdHandle_t *fdP;
1845     afs_sfsize_t size, nVnodes;
1846     int flag;
1847     int vnodeIndex;
1848
1849     fdP = IH_OPEN(vp->vnodeIndex[class].handle);
1850     osi_Assert(fdP != NULL);
1851     file = FDH_FDOPEN(fdP, "r+");
1852     osi_Assert(file != NULL);
1853     size = OS_SIZE(fdP->fd_fd);
1854     osi_Assert(size != -1);
1855     nVnodes = (size / vcp->diskSize) - 1;
1856     if (nVnodes > 0) {
1857         osi_Assert((nVnodes + 1) * vcp->diskSize == size);
1858         osi_Assert(STREAM_ASEEK(file, vcp->diskSize) == 0);
1859     } else
1860         nVnodes = 0;
1861     for (vnodeIndex = 0;
1862          nVnodes && STREAM_READ(vnode, vcp->diskSize, 1, file) == 1 && !code;
1863          nVnodes--, vnodeIndex++) {
1864         flag = forcedump || (vnode->serverModifyTime >= fromtime);
1865         /* Note:  the >= test is very important since some old volumes may not have
1866          * a serverModifyTime.  For an epoch dump, this results in 0>=0 test, which
1867          * does dump the file! */
1868         if (!code)
1869             code =
1870                 SizeDumpVnode(iodp, vnode, V_id(vp),
1871                               bitNumberToVnodeNumber(vnodeIndex, class), flag,
1872                               v_size);
1873     }
1874     STREAM_CLOSE(file);
1875     FDH_CLOSE(fdP);
1876     return code;
1877 }