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