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