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