2 * Copyright 2000, International Business Machines Corporation and others.
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
10 #include <afsconfig.h>
11 #include <afs/param.h>
15 #include <sys/types.h>
23 #include <sys/param.h>
26 #include <netinet/in.h>
30 #include <afs/afs_assert.h>
33 #include <afs/afsint.h>
35 #include <afs/errors.h>
38 #include <afs/ihandle.h>
39 #include <afs/vnode.h>
40 #include <afs/volume.h>
41 #include <afs/partition.h>
43 #include <afs/daemon_com.h>
44 #include <afs/fssync.h>
46 #include <afs/com_err.h>
47 #include <afs/vol_prototypes.h>
50 #include "dumpstuff.h"
54 #define afs_stat stat64
55 #define afs_fstat fstat64
56 #else /* !O_LARGEFILE */
58 #define afs_fstat fstat
59 #endif /* !O_LARGEFILE */
60 #endif /* !AFS_NT40_ENV */
62 /*@printflike@*/ extern void Log(const char *format, ...);
67 /* Forward Declarations */
68 static int DumpDumpHeader(struct iod *iodp, Volume * vp,
70 static int DumpPartial(struct iod *iodp, Volume * vp,
71 afs_int32 fromtime, int dumpAllDirs);
72 static int DumpVnodeIndex(struct iod *iodp, Volume * vp,
73 VnodeClass class, afs_int32 fromtime,
75 static int DumpVnode(struct iod *iodp, struct VnodeDiskObject *v,
76 int volid, int vnodeNumber, int dumpEverything);
77 static int ReadDumpHeader(struct iod *iodp, struct DumpHeader *hp);
78 static int ReadVnodes(struct iod *iodp, Volume * vp, int incremental,
79 afs_foff_t * Lbuf, afs_int32 s1, afs_foff_t * Sbuf,
80 afs_int32 s2, afs_int32 delo);
81 static afs_fsize_t volser_WriteFile(int vn, struct iod *iodp,
82 FdHandle_t * handleP, int tag,
85 static int SizeDumpDumpHeader(struct iod *iodp, Volume * vp,
87 struct volintSize *size);
88 static int SizeDumpPartial(struct iod *iodp, Volume * vp,
89 afs_int32 fromtime, int dumpAllDirs,
90 struct volintSize *size);
91 static int SizeDumpVnodeIndex(struct iod *iodp, Volume * vp,
92 VnodeClass class, afs_int32 fromtime,
94 struct volintSize *size);
95 static int SizeDumpVnode(struct iod *iodp, struct VnodeDiskObject *v,
96 int volid, int vnodeNumber, int dumpEverything,
97 struct volintSize *size);
99 #define MAX_SECTIONS 3
100 #define MIN_TLV_TAG 5
101 #define MAX_TLV_TAG 0x60
102 #define MAX_STANDARD_TAG 0x7a
103 static afs_uint32 oldtags[MAX_SECTIONS][16];
104 int oldtagsInited = 0;
107 RegisterTag(afs_int32 section, unsigned char tag)
109 afs_uint32 off = tag >> 5;
110 afs_uint32 mask = 1 << (tag & 0x1f);
111 oldtags[section][off] |= mask;
115 initNonStandardTags(void)
117 RegisterTag(0, 'n'); /* volume name */
118 RegisterTag(0, 't'); /* fromtime, V_backupDate */
119 RegisterTag(1, 'A'); /* V_accessDate */
120 RegisterTag(1, 'C'); /* V_creationDate */
121 RegisterTag(1, 'D'); /* V_dayUseDate */
122 RegisterTag(1, 'E'); /* V_expirationDate */
123 RegisterTag(1, 'M'); /* nullstring (motd) */
124 RegisterTag(1, 'U'); /* V_updateDate */
125 RegisterTag(1, 'W'); /* V_weekUse */
126 RegisterTag(1, 'Z'); /* V_dayUse */
127 RegisterTag(1, 'O'); /* V_offlineMessage */
128 RegisterTag(1, 'b'); /* V_blessed */
129 RegisterTag(1, 'n'); /* V_name */
130 RegisterTag(1, 's'); /* V_inService */
131 RegisterTag(1, 't'); /* V_type */
132 RegisterTag(2, 'A'); /* VVnodeDiskACL */
133 RegisterTag(2, 'b'); /* modeBits */
134 RegisterTag(2, 'f'); /* small file */
135 RegisterTag(2, 'h'); /* large file */
136 RegisterTag(2, 'l'); /* linkcount */
137 RegisterTag(2, 't'); /* type */
142 iod_Init(struct iod *iodp, struct rx_call *call)
145 iodp->haveOldChar = 0;
147 iodp->calls = (struct rx_call **)0;
151 iod_InitMulti(struct iod *iodp, struct rx_call **calls, int ncalls,
156 iodp->haveOldChar = 0;
157 iodp->ncalls = ncalls;
159 iodp->call = (struct rx_call *)0;
162 /* N.B. iod_Read doesn't check for oldchar (see previous comment) */
163 #define iod_Read(iodp, buf, nbytes) rx_Read((iodp)->call, buf, nbytes)
165 /* For the single dump case, it's ok to just return the "bytes written"
166 * that rx_Write returns, since all the callers of iod_Write abort when
167 * the returned value is less than they expect. For the multi dump case,
168 * I don't think we want half the replicas to go bad just because one
169 * connection timed out, but if they all time out, then we should give up.
172 iod_Write(struct iod *iodp, char *buf, int nbytes)
177 osi_Assert((iodp->call && iodp->ncalls == 1 && !iodp->calls)
178 || (!iodp->call && iodp->ncalls >= 1 && iodp->calls));
181 code = rx_Write(iodp->call, buf, nbytes);
185 for (i = 0; i < iodp->ncalls; i++) {
186 if (iodp->calls[i] && !iodp->codes[i]) {
187 code = rx_Write(iodp->calls[i], buf, nbytes);
188 if (code != nbytes) { /* everything gets merged into a single error */
189 iodp->codes[i] = VOLSERDUMPERROR; /* but that's exactly what the */
190 } /* standard dump does, anyways */
195 } /* for all calls */
204 iod_ungetc(struct iod *iodp, int achar)
206 iodp->oldChar = achar;
207 iodp->haveOldChar = 1;
211 iod_getc(struct iod *iodp)
215 if (iodp->haveOldChar) {
216 iodp->haveOldChar = 0;
217 return iodp->oldChar;
219 if (iod_Read(iodp, (char *) &t, 1) == 1)
225 ReadShort(struct iod *iodp, unsigned short *sp)
234 *sp = (b1 << 8) | b0;
239 ReadInt32(struct iod *iodp, afs_uint32 * lp)
241 afs_uint32 b3, b2, b1, b0;
254 *lp = (((((b3 << 8) | b2) << 8) | b1) << 8) | b0;
259 ReadString(struct iod *iodp, char *to, int maxa)
268 if ((*to++ = c = iod_getc(iodp)) == 0 || c == EOF)
272 while ((c = iod_getc(iodp)) && c != EOF);
278 ReadByteString(struct iod *iodp, byte * to,
282 *to++ = iod_getc(iodp);
286 * returns 1 on success and 0 otherwise
289 ReadStandardTagLen(struct iod *iodp, unsigned char tag, afs_int32 section,
293 afs_uint32 off = tag >> 5;
294 afs_uint32 mask = 1 << (tag & 0x1f);
295 unsigned char len, buf[8], *p;
298 initNonStandardTags();
300 if (tag < MIN_TLV_TAG
301 || tag > MAX_STANDARD_TAG
302 || section >= MAX_SECTIONS
303 || (oldtags[section][ off] & mask)) {
304 Log("Trying to use ReadStandardTag with tag 0x%02x for section %d, aborting\n", tag, section);
307 if (tag <= MAX_TLV_TAG) {
308 len = iod_getc(iodp);
313 if ((code = iod_Read(iodp, (char *)buf, len)) != len)
314 return VOLSERDUMPERROR;
316 p = (unsigned char *)&buf;
317 for (i=0; i<len; i++) {
318 *length = ((*length) << 8) | *p++;
322 if (tag < MAX_STANDARD_TAG)
328 static char skipbuf[256];
331 SkipData(struct iod *iodp, afs_size_t length)
333 while (length > 256) {
334 if (iod_Read(iodp, (char *)&skipbuf, 256) != 256)
338 if (iod_Read(iodp, (char *)&skipbuf, length) != length)
343 static char *secname[3] = {"ReadDumpHeader", "ReadVolumeHeader", "ReadVnodes"};
346 HandleUnknownTag(struct iod *iodp, int tag, afs_int32 section,
349 afs_size_t taglen = 0;
353 Log("%s: unknown critical tag x%02x, aborting\n",
354 secname[section], tag);
357 Log("%s: unknown tag x%02x found, skipping\n", secname[section], tag);
358 if (tag >= 0x06 && tag <= 0x60) {
359 if (!ReadStandardTagLen(iodp, tag, 1, &taglen)) {
360 Log("%s: error reading length field for tag x%02x, aborting\n",
361 secname[section], tag);
364 if (!SkipData(iodp, taglen)) {
365 Log("%s: error skipping %llu bytes for tag x%02x, aborting\n",
366 secname[section], taglen, tag);
371 if (tag >= 0x61 && tag <= 0x7a) {
372 if (!ReadInt32(iodp, &trash)) {
373 Log("%s: error skipping int32 for tag x%02x, aborting\n",
374 secname[section], tag);
379 if (tag >= 0x7b && tag < 0x80) /* dataless tag */
381 Log("%s: unknown invalid tag x%02x, aborting\n", secname[section], tag);
386 ReadVolumeHeader(struct iod *iodp, VolumeDiskData * vol)
390 afs_int32 critical = 0;
391 memset(vol, 0, sizeof(*vol));
392 while ((tag = iod_getc(iodp)) > D_MAX && tag != EOF) {
397 if (!ReadInt32(iodp, &vol->id))
398 return VOLSERREAD_DUMPERROR;
401 if (!ReadInt32(iodp, &trash))
402 return VOLSERREAD_DUMPERROR;
405 ReadString(iodp, vol->name, sizeof(vol->name));
406 /*this means the name of the retsored volume could be possibly different. In conjunction with SAFSVolSignalRestore */
409 vol->inService = iod_getc(iodp);
412 vol->blessed = iod_getc(iodp);
415 if (!ReadInt32(iodp, &vol->uniquifier))
416 return VOLSERREAD_DUMPERROR;
419 vol->type = iod_getc(iodp);
422 if (!ReadInt32(iodp, &vol->parentId))
423 return VOLSERREAD_DUMPERROR;
426 if (!ReadInt32(iodp, &vol->cloneId))
427 return VOLSERREAD_DUMPERROR;
430 if (!ReadInt32(iodp, (afs_uint32 *) & vol->maxquota))
431 return VOLSERREAD_DUMPERROR;
434 if (!ReadInt32(iodp, (afs_uint32 *) & vol->minquota))
435 return VOLSERREAD_DUMPERROR;
438 if (!ReadInt32(iodp, (afs_uint32 *) & vol->diskused))
439 return VOLSERREAD_DUMPERROR; /* Bogus: should calculate this */
442 if (!ReadInt32(iodp, (afs_uint32 *) & vol->filecount))
443 return VOLSERREAD_DUMPERROR;
446 if (!ReadInt32(iodp, &vol->accountNumber))
447 return VOLSERREAD_DUMPERROR;
450 if (!ReadInt32(iodp, &vol->owner))
451 return VOLSERREAD_DUMPERROR;
454 if (!ReadInt32(iodp, &vol->creationDate))
455 return VOLSERREAD_DUMPERROR;
458 if (!ReadInt32(iodp, &vol->accessDate))
459 return VOLSERREAD_DUMPERROR;
462 if (!ReadInt32(iodp, &vol->updateDate))
463 return VOLSERREAD_DUMPERROR;
466 if (!ReadInt32(iodp, &vol->expirationDate))
467 return VOLSERREAD_DUMPERROR;
470 if (!ReadInt32(iodp, &vol->backupDate))
471 return VOLSERREAD_DUMPERROR;
474 ReadString(iodp, vol->offlineMessage,
475 sizeof(vol->offlineMessage));
479 * Detailed volume statistics are never stored in dumps,
480 * so we just restore either the null string if this volume
481 * had already been set to store statistics, or the old motd
482 * contents otherwise. It doesn't matter, since this field
483 * will soon get initialized anyway.
485 ReadString(iodp, (char *)(vol->stat_reads), VMSGSIZE);
488 unsigned short length;
491 if (!ReadShort(iodp, &length))
492 return VOLSERREAD_DUMPERROR;
493 for (i = 0; i < length; i++) {
494 if (!ReadInt32(iodp, &data))
495 return VOLSERREAD_DUMPERROR;
496 if (i < sizeof(vol->weekUse) / sizeof(vol->weekUse[0]))
497 vol->weekUse[i] = data;
502 if (!ReadInt32(iodp, &vol->dayUseDate))
503 return VOLSERREAD_DUMPERROR;
506 if (!ReadInt32(iodp, (afs_uint32 *) & vol->dayUse))
507 return VOLSERREAD_DUMPERROR;
510 if (!ReadInt32(iodp, (afs_uint32 *) &trash/*volUpdateCounter*/))
511 return VOLSERREAD_DUMPERROR;
517 if (!HandleUnknownTag(iodp, tag, 1, critical))
518 return VOLSERREAD_DUMPERROR;
521 iod_ungetc(iodp, tag);
526 DumpTag(struct iod *iodp, int tag)
531 return ((iod_Write(iodp, &p, 1) == 1) ? 0 : VOLSERDUMPERROR);
536 DumpByte(struct iod *iodp, char tag, byte value)
539 byte *p = (unsigned char *)tbuffer;
542 return ((iod_Write(iodp, tbuffer, 2) == 2) ? 0 : VOLSERDUMPERROR);
545 #define putint32(p, v) *p++ = v>>24, *p++ = v>>16, *p++ = v>>8, *p++ = v
546 #define putshort(p, v) *p++ = v>>8, *p++ = v
549 DumpDouble(struct iod *iodp, char tag, afs_uint32 value1,
553 byte *p = (unsigned char *)tbuffer;
557 return ((iod_Write(iodp, tbuffer, 9) == 9) ? 0 : VOLSERDUMPERROR);
561 DumpInt32(struct iod *iodp, char tag, afs_uint32 value)
564 byte *p = (unsigned char *)tbuffer;
567 return ((iod_Write(iodp, tbuffer, 5) == 5) ? 0 : VOLSERDUMPERROR);
571 DumpArrayInt32(struct iod *iodp, char tag,
572 afs_uint32 * array, int nelem)
577 byte *p = (unsigned char *)tbuffer;
580 code = iod_Write(iodp, tbuffer, 3);
582 return VOLSERDUMPERROR;
584 p = (unsigned char *)tbuffer;
585 v = *array++; /*this was register */
588 code = iod_Write(iodp, tbuffer, 4);
590 return VOLSERDUMPERROR;
596 DumpShort(struct iod *iodp, char tag, unsigned int value)
599 byte *p = (unsigned char *)tbuffer;
603 return ((iod_Write(iodp, tbuffer, 3) == 3) ? 0 : VOLSERDUMPERROR);
607 DumpBool(struct iod *iodp, char tag, unsigned int value)
610 byte *p = (unsigned char *)tbuffer;
613 return ((iod_Write(iodp, tbuffer, 2) == 2) ? 0 : VOLSERDUMPERROR);
617 DumpString(struct iod *iodp, char tag, char *s)
621 code = iod_Write(iodp, &tag, 1);
623 return VOLSERDUMPERROR;
625 code = iod_Write(iodp, s, n);
627 return VOLSERDUMPERROR;
632 DumpByteString(struct iod *iodp, char tag, byte * bs,
637 code = iod_Write(iodp, &tag, 1);
639 return VOLSERDUMPERROR;
640 code = iod_Write(iodp, (char *)bs, nbytes);
642 return VOLSERDUMPERROR;
647 DumpStandardTag(struct iod *iodp, char tag, afs_uint32 section)
650 afs_uint32 off = tag >> 5;
651 afs_uint32 mask = 1 << (tag & 0x1f);
654 initNonStandardTags();
656 if (tag < MIN_TLV_TAG
657 || tag > MAX_STANDARD_TAG
658 || section >= MAX_SECTIONS
659 || (oldtags[section][ off] & mask)) {
660 Log("Trying to use DumpStandardTag with tag 0x%02x for section %d, aborting\n", tag, section);
661 return VOLSERDUMPERROR;
663 code = iod_Write(iodp, &tag, 1);
665 return VOLSERDUMPERROR;
671 DumpStandardTagLen(struct iod *iodp, char tag, afs_uint32 section,
678 if (tag < MIN_TLV_TAG || tag > MAX_TLV_TAG) {
679 Log("Trying to use DumpStandardTagLen with tag 0x%02x for section %d, aborting\n", tag, section);
680 return VOLSERDUMPERROR;
682 code = DumpStandardTag(iodp, tag, section);
686 if (length < 128) { /* byte after tag contains length */
689 } else { /* byte after tag contains length of length field | 0x80 */
690 for (len=0; length; length=length >> 8) {
698 code = iod_Write(iodp, p, len);
700 return VOLSERDUMPERROR;
705 DumpFile(struct iod *iodp, int vnode, FdHandle_t * handleP)
707 int code = 0, error = 0;
709 afs_foff_t offset = 0;
710 afs_sfsize_t nbytes, howBig;
713 afs_foff_t howFar = 0;
718 struct afs_stat status;
722 #include <sys/statfs.h>
723 #if defined(AFS_AIX52_ENV)
724 struct statfs64 tstatfs;
725 #else /* !AFS_AIX52_ENV */
726 struct statfs tstatfs;
727 #endif /* !AFS_AIX52_ENV */
732 howBig = _filelength(handleP->fd_fd);
736 afs_fstat(handleP->fd_fd, &status);
737 howBig = status.st_size;
740 /* Unfortunately in AIX valuable fields such as st_blksize are
741 * gone from the stat structure.
743 #if defined(AFS_AIX52_ENV)
744 statfs_code = fstatfs64(handleP->fd_fd, &tstatfs);
745 #else /* !AFS_AIX52_ENV */
746 statfs_code = fstatfs(handleP->fd_fd, &tstatfs);
747 #endif /* !AFS_AIX52_ENV */
748 if (statfs_code != 0) {
749 Log("DumpFile: fstatfs returned error code %d on descriptor %d\n", errno, handleP->fd_fd);
750 return VOLSERDUMPERROR;
752 howMany = tstatfs.f_bsize;
754 howMany = status.st_blksize;
755 #endif /* AFS_AIX_ENV */
756 #endif /* AFS_NT40_ENV */
759 size = FDH_SIZE(handleP);
760 SplitInt64(size, hi, lo);
762 code = DumpInt32(iodp, 'f', lo);
764 code = DumpDouble(iodp, 'h', hi, lo);
767 return VOLSERDUMPERROR;
772 Log("1 Volser: DumpFile: not enough memory to allocate %u bytes\n", (unsigned)howMany);
773 return VOLSERDUMPERROR;
776 for (nbytes = size; (nbytes && !error); nbytes -= howMany) {
777 if (nbytes < howMany)
781 n = FDH_PREAD(handleP, p, howMany, howFar);
784 /* If read any good data and we null padded previously, log the
785 * amount that we had null padded.
787 if ((n > 0) && pad) {
788 Log("1 Volser: DumpFile: Null padding file %d bytes at offset %lld\n", pad, (long long)offset);
792 /* If didn't read enough data, null padd the rest of the buffer. This
793 * can happen if, for instance, the media has some bad spots. We don't
794 * want to quit the dump, so we start null padding.
797 /* Record the read error */
800 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));
802 Log("1 Volser: DumpFile: Error reading inode %s for vnode %d\n", PrintInode(stmp, handleP->fd_ih->ih_ino), vnode);
805 /* Pad the rest of the buffer with zeros. Remember offset we started
806 * padding. Keep total tally of padding.
808 memset(p + n, 0, howMany - n);
810 offset = (howBig - nbytes) + n;
811 pad += (howMany - n);
813 /* Now seek over the data we could not get. An error here means we
814 * can't do the next read.
816 howFar = (size_t)((size - nbytes) + howMany);
819 /* Now write the data out */
820 if (iod_Write(iodp, (char *)p, howMany) != howMany)
821 error = VOLSERDUMPERROR;
822 #ifndef AFS_PTHREAD_ENV
827 if (pad) { /* Any padding we hadn't reported yet */
828 Log("1 Volser: DumpFile: Null padding file: %d bytes at offset %lld\n",
829 pad, (long long)offset);
837 DumpVolumeHeader(struct iod *iodp, Volume * vp)
840 static char nullString[1] = ""; /*The ``contents'' of motd */
843 code = DumpTag(iodp, D_VOLUMEHEADER);
845 code = DumpInt32(iodp, 'i', V_id(vp));
848 code = DumpInt32(iodp, 'v', V_stamp(vp).version);
850 code = DumpString(iodp, 'n', V_name(vp));
852 code = DumpBool(iodp, 's', V_inService(vp));
854 code = DumpBool(iodp, 'b', V_blessed(vp));
856 code = DumpInt32(iodp, 'u', V_uniquifier(vp));
858 code = DumpByte(iodp, 't', (byte) V_type(vp));
860 code = DumpInt32(iodp, 'p', V_parentId(vp));
863 code = DumpInt32(iodp, 'c', V_cloneId(vp));
865 code = DumpInt32(iodp, 'q', V_maxquota(vp));
867 code = DumpInt32(iodp, 'm', V_minquota(vp));
869 code = DumpInt32(iodp, 'd', V_diskused(vp));
871 code = DumpInt32(iodp, 'f', V_filecount(vp));
873 code = DumpInt32(iodp, 'a', V_accountNumber(vp));
875 code = DumpInt32(iodp, 'o', V_owner(vp));
877 code = DumpInt32(iodp, 'C', V_creationDate(vp)); /* Rw volume creation date */
879 code = DumpInt32(iodp, 'A', V_accessDate(vp));
881 code = DumpInt32(iodp, 'U', V_updateDate(vp));
883 code = DumpInt32(iodp, 'E', V_expirationDate(vp));
885 code = DumpInt32(iodp, 'B', V_backupDate(vp)); /* Rw volume backup clone date */
887 code = DumpString(iodp, 'O', V_offlineMessage(vp));
889 * We do NOT dump the detailed volume statistics residing in the old
890 * motd field, since we cannot tell from the info in a dump whether
891 * statistics data has been put there. Instead, we dump a null string,
892 * just as if that was what the motd contained.
895 code = DumpString(iodp, 'M', nullString);
898 DumpArrayInt32(iodp, 'W', (afs_uint32 *) V_weekUse(vp),
899 sizeof(V_weekUse(vp)) / sizeof(V_weekUse(vp)[0]));
901 code = DumpInt32(iodp, 'D', V_dayUseDate(vp));
903 code = DumpInt32(iodp, 'Z', V_dayUse(vp));
908 DumpEnd(struct iod *iodp)
910 return (DumpInt32(iodp, D_DUMPEND, DUMPENDMAGIC));
913 /* Guts of the dump code */
915 /* Dump a whole volume */
917 DumpVolume(struct rx_call *call, Volume * vp,
918 afs_int32 fromtime, int dumpAllDirs)
922 struct iod *iodp = &iod;
923 iod_Init(iodp, call);
926 code = DumpDumpHeader(iodp, vp, fromtime);
929 code = DumpPartial(iodp, vp, fromtime, dumpAllDirs);
931 /* hack follows. Errors should be handled quite differently in this version of dump than they used to be.*/
932 if (rx_Error(iodp->call)) {
933 Log("1 Volser: DumpVolume: Rx call failed during dump, error %d\n",
934 rx_Error(iodp->call));
935 return VOLSERDUMPERROR;
938 code = DumpEnd(iodp);
943 /* Dump a volume to multiple places*/
945 DumpVolMulti(struct rx_call **calls, int ncalls, Volume * vp,
946 afs_int32 fromtime, int dumpAllDirs, int *codes)
950 iod_InitMulti(&iod, calls, ncalls, codes);
953 code = DumpDumpHeader(&iod, vp, fromtime);
955 code = DumpPartial(&iod, vp, fromtime, dumpAllDirs);
957 code = DumpEnd(&iod);
961 /* A partial dump (no dump header) */
963 DumpPartial(struct iod *iodp, Volume * vp,
964 afs_int32 fromtime, int dumpAllDirs)
968 code = DumpVolumeHeader(iodp, vp);
970 code = DumpVnodeIndex(iodp, vp, vLarge, fromtime, dumpAllDirs);
972 code = DumpVnodeIndex(iodp, vp, vSmall, fromtime, 0);
977 DumpVnodeIndex(struct iod *iodp, Volume * vp, VnodeClass class,
978 afs_int32 fromtime, int forcedump)
981 struct VnodeClassInfo *vcp = &VnodeClassInfo[class];
982 char buf[SIZEOF_LARGEDISKVNODE];
983 struct VnodeDiskObject *vnode = (struct VnodeDiskObject *)buf;
984 StreamHandle_t *file;
986 afs_sfsize_t size, nVnodes;
990 fdP = IH_OPEN(vp->vnodeIndex[class].handle);
991 osi_Assert(fdP != NULL);
992 file = FDH_FDOPEN(fdP, "r+");
993 osi_Assert(file != NULL);
994 size = OS_SIZE(fdP->fd_fd);
995 osi_Assert(size != -1);
996 nVnodes = (size / vcp->diskSize) - 1;
998 osi_Assert((nVnodes + 1) * vcp->diskSize == size);
999 osi_Assert(STREAM_ASEEK(file, vcp->diskSize) == 0);
1002 for (vnodeIndex = 0;
1003 nVnodes && STREAM_READ(vnode, vcp->diskSize, 1, file) == 1 && !code;
1004 nVnodes--, vnodeIndex++) {
1005 flag = forcedump || (vnode->serverModifyTime >= fromtime);
1006 /* Note: the >= test is very important since some old volumes may not have
1007 * a serverModifyTime. For an epoch dump, this results in 0>=0 test, which
1008 * does dump the file! */
1011 DumpVnode(iodp, vnode, V_id(vp),
1012 bitNumberToVnodeNumber(vnodeIndex, class), flag);
1013 #ifndef AFS_PTHREAD_ENV
1015 IOMGR_Poll(); /* if we dont' xfr data, but scan instead, could lose conn */
1024 DumpDumpHeader(struct iod *iodp, Volume * vp,
1028 int UseLatestReadOnlyClone = 1;
1029 afs_int32 dumpTimes[2];
1030 iodp->device = vp->device;
1031 iodp->parentId = V_parentId(vp);
1032 iodp->dumpPartition = vp->partition;
1034 code = DumpDouble(iodp, D_DUMPHEADER, DUMPBEGINMAGIC, DUMPVERSION);
1037 DumpInt32(iodp, 'v',
1038 UseLatestReadOnlyClone ? V_id(vp) : V_parentId(vp));
1040 code = DumpString(iodp, 'n', V_name(vp));
1041 dumpTimes[0] = fromtime;
1042 dumpTimes[1] = V_backupDate(vp); /* Until the time the clone was made */
1044 code = DumpArrayInt32(iodp, 't', (afs_uint32 *) dumpTimes, 2);
1049 DumpVnode(struct iod *iodp, struct VnodeDiskObject *v, int volid,
1050 int vnodeNumber, int dumpEverything)
1056 if (!v || v->type == vNull)
1059 code = DumpDouble(iodp, D_VNODE, vnodeNumber, v->uniquifier);
1060 if (!dumpEverything)
1063 code = DumpByte(iodp, 't', (byte) v->type);
1065 code = DumpShort(iodp, 'l', v->linkCount); /* May not need this */
1067 code = DumpInt32(iodp, 'v', v->dataVersion);
1069 code = DumpInt32(iodp, 'm', v->unixModifyTime);
1071 code = DumpInt32(iodp, 'a', v->author);
1073 code = DumpInt32(iodp, 'o', v->owner);
1074 if (!code && v->group)
1075 code = DumpInt32(iodp, 'g', v->group); /* default group is 0 */
1077 code = DumpShort(iodp, 'b', v->modeBits);
1079 code = DumpInt32(iodp, 'p', v->parent);
1081 code = DumpInt32(iodp, 's', v->serverModifyTime);
1082 if (v->type == vDirectory) {
1083 acl_HtonACL(VVnodeDiskACL(v));
1086 DumpByteString(iodp, 'A', (byte *) VVnodeDiskACL(v),
1089 if (VNDISK_GET_INO(v)) {
1090 IH_INIT(ihP, iodp->device, iodp->parentId, VNDISK_GET_INO(v));
1093 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);
1095 return VOLSERREAD_DUMPERROR;
1097 code = DumpFile(iodp, vnodeNumber, fdP);
1106 ProcessIndex(Volume * vp, VnodeClass class, afs_foff_t ** Bufp, int *sizep,
1109 int i, nVnodes, code;
1114 StreamHandle_t *afile;
1116 struct VnodeClassInfo *vcp = &VnodeClassInfo[class];
1117 char buf[SIZEOF_LARGEDISKVNODE], zero[SIZEOF_LARGEDISKVNODE];
1118 struct VnodeDiskObject *vnode = (struct VnodeDiskObject *)buf;
1120 memset(zero, 0, sizeof(zero)); /* zero out our proto-vnode */
1121 fdP = IH_OPEN(vp->vnodeIndex[class].handle);
1124 afile = FDH_FDOPEN(fdP, "r+");
1128 for (i = 0; i < *sizep; i++) {
1131 STREAM_ASEEK(afile, Buf[i]);
1132 code = STREAM_READ(vnode, vcp->diskSize, 1, afile);
1134 if (vnode->type != vNull && VNDISK_GET_INO(vnode)) {
1137 Log("RestoreVolume %u Cleanup: Removing old vnode=%u inode=%llu size=unknown\n",
1138 V_id(vp), bitNumberToVnodeNumber(i, class),
1139 (afs_uintmax_t) VNDISK_GET_INO(vnode));
1141 IH_DEC(V_linkHandle(vp), VNDISK_GET_INO(vnode),
1145 STREAM_ASEEK(afile, Buf[i]);
1146 (void)STREAM_WRITE(zero, vcp->diskSize, 1, afile); /* Zero it out */
1152 Log("RestoreVolume Cleanup: Removed %d inodes for volume %d\n",
1155 STREAM_FLUSH(afile); /* ensure 0s are on the disk */
1156 OS_SYNC(afile->str_fd);
1158 size = OS_SIZE(fdP->fd_fd);
1159 osi_Assert(size != -1);
1162 vcp->diskSize ? 0 : size - vcp->diskSize) >> vcp->logSize;
1165 Log("RestoreVolume ProcessIndex: Set up %d inodes for volume %d\n",
1168 Buf = malloc(nVnodes * sizeof(afs_foff_t));
1170 STREAM_CLOSE(afile);
1174 memset(Buf, 0, nVnodes * sizeof(afs_foff_t));
1175 STREAM_ASEEK(afile, offset = vcp->diskSize);
1177 code = STREAM_READ(vnode, vcp->diskSize, 1, afile);
1181 if (vnode->type != vNull && VNDISK_GET_INO(vnode)) {
1182 Buf[(offset >> vcp->logSize) - 1] = offset;
1185 offset += vcp->diskSize;
1188 Log("RestoreVolume ProcessIndex: found %d inodes\n", cnt);
1194 STREAM_CLOSE(afile);
1201 RestoreVolume(struct rx_call *call, Volume * avp, int incremental,
1202 struct restoreCookie *cookie)
1205 struct DumpHeader header;
1206 afs_uint32 endMagic;
1207 Error error = 0, vupdate;
1210 struct iod *iodp = &iod;
1211 afs_foff_t *b1 = NULL, *b2 = NULL;
1212 int s1 = 0, s2 = 0, delo = 0, tdelo;
1215 iod_Init(iodp, call);
1219 if (!ReadDumpHeader(iodp, &header)) {
1220 Log("1 Volser: RestoreVolume: Error reading header file for dump; aborted\n");
1221 return VOLSERREAD_DUMPERROR;
1223 if (iod_getc(iodp) != D_VOLUMEHEADER) {
1224 Log("1 Volser: RestoreVolume: Volume header missing from dump; not restored\n");
1225 return VOLSERREAD_DUMPERROR;
1227 if (ReadVolumeHeader(iodp, &vol) == VOLSERREAD_DUMPERROR)
1228 return VOLSERREAD_DUMPERROR;
1231 delo = ProcessIndex(vp, vLarge, &b1, &s1, 0);
1233 delo = ProcessIndex(vp, vSmall, &b2, &s2, 0);
1235 Log("1 Volser: RestoreVolume: ProcessIndex failed; not restored\n");
1236 error = VOLSERREAD_DUMPERROR;
1240 strncpy(vol.name, cookie->name, VOLSER_OLDMAXVOLNAME);
1241 vol.type = cookie->type;
1242 vol.cloneId = cookie->clone;
1243 vol.parentId = cookie->parent;
1247 if (ReadVnodes(iodp, vp, 0, b1, s1, b2, s2, tdelo)) {
1248 error = VOLSERREAD_DUMPERROR;
1251 tag = iod_getc(iodp);
1252 if (tag != D_VOLUMEHEADER)
1255 if (ReadVolumeHeader(iodp, &vol) == VOLSERREAD_DUMPERROR) {
1256 error = VOLSERREAD_DUMPERROR;
1260 if (tag != D_DUMPEND || !ReadInt32(iodp, &endMagic)
1261 || endMagic != DUMPENDMAGIC) {
1262 Log("1 Volser: RestoreVolume: End of dump not found; restore aborted\n");
1263 error = VOLSERREAD_DUMPERROR;
1268 if (iod_getc(iodp) != EOF) {
1269 Log("1 Volser: RestoreVolume: Unrecognized postamble in dump; restore aborted\n");
1270 error = VOLSERREAD_DUMPERROR;
1275 delo = ProcessIndex(vp, vLarge, &b1, &s1, 1);
1277 delo = ProcessIndex(vp, vSmall, &b2, &s2, 1);
1279 error = VOLSERREAD_DUMPERROR;
1285 ClearVolumeStats(&vol);
1286 CopyVolumeHeader(&vol, &V_disk(vp));
1287 V_destroyMe(vp) = 0;
1288 VUpdateVolume(&vupdate, vp);
1290 Log("1 Volser: RestoreVolume: Unable to rewrite volume header; restore aborted\n");
1291 error = VOLSERREAD_DUMPERROR;
1295 /* Free the malloced space above */
1304 ReadVnodes(struct iod *iodp, Volume * vp, int incremental,
1305 afs_foff_t * Lbuf, afs_int32 s1, afs_foff_t * Sbuf, afs_int32 s2,
1308 afs_int32 vnodeNumber;
1309 char buf[SIZEOF_LARGEDISKVNODE];
1311 struct VnodeDiskObject *vnode = (struct VnodeDiskObject *)buf;
1312 struct VnodeDiskObject oldvnode;
1315 struct VnodeClassInfo *vcp;
1319 afs_int32 critical = 0;
1321 tag = iod_getc(iodp);
1322 V_pref(vp, nearInode);
1323 while (tag == D_VNODE) {
1326 memset(buf, 0, sizeof(buf));
1327 if (!ReadInt32(iodp, (afs_uint32 *) & vnodeNumber))
1330 if (!ReadInt32(iodp, &vnode->uniquifier))
1331 return VOLSERREAD_DUMPERROR;
1334 Log("ReadVnodes: setup %d/%d\n", vnodeNumber, vnode->uniquifier);
1336 while ((tag = iod_getc(iodp)) > D_MAX && tag != EOF) {
1342 vnode->type = (VnodeType) iod_getc(iodp);
1347 if (!ReadShort(iodp, &tlc))
1348 return VOLSERREAD_DUMPERROR;
1349 vnode->linkCount = (signed int)tlc;
1353 if (!ReadInt32(iodp, &vnode->dataVersion))
1354 return VOLSERREAD_DUMPERROR;
1357 if (!ReadInt32(iodp, &vnode->unixModifyTime))
1358 return VOLSERREAD_DUMPERROR;
1361 if (!ReadInt32(iodp, &vnode->serverModifyTime))
1362 return VOLSERREAD_DUMPERROR;
1365 if (!ReadInt32(iodp, &vnode->author))
1366 return VOLSERREAD_DUMPERROR;
1369 if (!ReadInt32(iodp, &vnode->owner))
1370 return VOLSERREAD_DUMPERROR;
1373 if (!ReadInt32(iodp, (afs_uint32 *) & vnode->group))
1374 return VOLSERREAD_DUMPERROR;
1377 unsigned short modeBits;
1378 if (!ReadShort(iodp, &modeBits))
1379 return VOLSERREAD_DUMPERROR;
1380 vnode->modeBits = (unsigned int)modeBits;
1384 if (!ReadInt32(iodp, &vnode->parent))
1385 return VOLSERREAD_DUMPERROR;
1388 ReadByteString(iodp, (byte *) VVnodeDiskACL(vnode),
1389 VAclDiskSize(vnode));
1390 acl_NtohACL(VVnodeDiskACL(vnode));
1396 afs_fsize_t vnodeLength;
1399 Log("Volser: ReadVnodes: warning: ignoring duplicate "
1400 "file entries for vnode %lu in dump\n",
1401 (unsigned long)vnodeNumber);
1402 volser_WriteFile(vnodeNumber, iodp, NULL, tag, &error);
1408 IH_CREATE(V_linkHandle(vp), V_device(vp),
1409 VPartitionPath(V_partition(vp)), nearInode,
1410 V_parentId(vp), vnodeNumber,
1411 vnode->uniquifier, vnode->dataVersion);
1412 if (!VALID_INO(ino)) {
1413 Log("1 Volser: ReadVnodes: IH_CREATE: %s - restore aborted\n",
1414 afs_error_message(errno));
1415 return VOLSERREAD_DUMPERROR;
1418 VNDISK_SET_INO(vnode, ino);
1419 IH_INIT(tmpH, vp->device, V_parentId(vp), ino);
1420 fdP = IH_OPEN(tmpH);
1422 Log("1 Volser: ReadVnodes: IH_OPEN: %s - restore aborted\n",
1423 afs_error_message(errno));
1425 return VOLSERREAD_DUMPERROR;
1428 volser_WriteFile(vnodeNumber, iodp, fdP, tag, &error);
1429 VNDISK_SET_LEN(vnode, vnodeLength);
1430 FDH_REALLYCLOSE(fdP);
1433 Log("1 Volser: ReadVnodes: IDEC inode %llu\n",
1434 (afs_uintmax_t) ino);
1435 IH_DEC(V_linkHandle(vp), ino, V_parentId(vp));
1436 return VOLSERREAD_DUMPERROR;
1444 if (!HandleUnknownTag(iodp, tag, 2, critical))
1445 return VOLSERREAD_DUMPERROR;
1449 class = vnodeIdToClass(vnodeNumber);
1450 vcp = &VnodeClassInfo[class];
1452 /* Mark this vnode as in this dump - so we don't delete it later */
1454 idx = (vnodeIndexOffset(vcp, vnodeNumber) >> vcp->logSize) - 1;
1455 if (class == vLarge) {
1456 if (Lbuf && (idx < s1))
1459 if (Sbuf && (idx < s2))
1465 FdHandle_t *fdP = IH_OPEN(vp->vnodeIndex[class].handle);
1467 Log("1 Volser: ReadVnodes: Error opening vnode index: %s; restore aborted\n",
1468 afs_error_message(errno));
1469 return VOLSERREAD_DUMPERROR;
1471 if (FDH_PREAD(fdP, &oldvnode, sizeof(oldvnode), vnodeIndexOffset(vcp, vnodeNumber)) ==
1473 if (oldvnode.type != vNull && VNDISK_GET_INO(&oldvnode)) {
1474 IH_DEC(V_linkHandle(vp), VNDISK_GET_INO(&oldvnode),
1478 vnode->vnodeMagic = vcp->magic;
1479 if (FDH_PWRITE(fdP, vnode, vcp->diskSize, vnodeIndexOffset(vcp, vnodeNumber)) != vcp->diskSize) {
1480 Log("1 Volser: ReadVnodes: Error writing vnode index: %s; restore aborted\n",
1481 afs_error_message(errno));
1482 FDH_REALLYCLOSE(fdP);
1483 return VOLSERREAD_DUMPERROR;
1488 iod_ungetc(iodp, tag);
1494 /* called with disk file only. Note that we don't have to worry about rx_Read
1495 * needing to read an ungetc'd character, since the ReadInt32 will have read
1498 * if handleP == NULL, don't write the file anywhere; just read and discard
1502 volser_WriteFile(int vn, struct iod *iodp, FdHandle_t * handleP, int tag,
1507 afs_fsize_t filesize;
1508 afs_fsize_t written = 0;
1516 afs_uint32 filesize_high = 0L, filesize_low = 0L;
1518 if (!ReadInt32(iodp, &filesize_high)) {
1523 if (!ReadInt32(iodp, &filesize_low)) {
1527 FillInt64(filesize, filesize_high, filesize_low);
1529 p = (unsigned char *)malloc(size);
1534 for (nbytes = filesize; nbytes; nbytes -= size) {
1538 if ((code = iod_Read(iodp, (char *) p, size)) != size) {
1539 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));
1544 nBytes = FDH_PWRITE(handleP, p, size, written);
1547 if (nBytes != size) {
1548 Log("1 Volser: WriteFile: Error writing (%u) bytes to vnode %d; %s; restore aborted\n", (int)(nBytes & 0xffffffff), vn, afs_error_message(errno));
1559 ReadDumpHeader(struct iod *iodp, struct DumpHeader *hp)
1562 afs_uint32 beginMagic;
1563 afs_int32 critical = 0;
1564 if (iod_getc(iodp) != D_DUMPHEADER || !ReadInt32(iodp, &beginMagic)
1565 || !ReadInt32(iodp, (afs_uint32 *) & hp->version)
1566 || beginMagic != DUMPBEGINMAGIC)
1570 while ((tag = iod_getc(iodp)) > D_MAX) {
1571 unsigned short arrayLength;
1577 if (!ReadInt32(iodp, &hp->volumeId))
1581 ReadString(iodp, hp->volumeName, sizeof(hp->volumeName));
1584 if (!ReadShort(iodp, &arrayLength))
1586 hp->nDumpTimes = (arrayLength >> 1);
1587 for (i = 0; i < hp->nDumpTimes; i++)
1588 if (!ReadInt32(iodp, (afs_uint32 *) & hp->dumpTimes[i].from)
1589 || !ReadInt32(iodp, (afs_uint32 *) & hp->dumpTimes[i].to))
1596 if (!HandleUnknownTag(iodp, tag, 0, critical))
1597 return VOLSERREAD_DUMPERROR;
1600 if (!hp->volumeId || !hp->nDumpTimes) {
1603 iod_ungetc(iodp, tag);
1608 /* ----- Below are the calls that calculate dump size ----- */
1611 SizeDumpVolumeHeader(struct iod *iodp, Volume * vp,
1612 struct volintSize *v_size)
1615 static char nullString[1] = ""; /*The ``contents'' of motd */
1618 /* if (!code) code = DumpTag(iodp, D_VOLUMEHEADER); */
1619 FillInt64(addvar,0, 1);
1620 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1621 /* if (!code) {code = DumpInt32(iodp, 'i',V_id(vp));} */
1622 FillInt64(addvar,0, 5);
1623 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1624 /* if (!code) code = DumpInt32(iodp, 'v',V_stamp(vp).version); */
1625 FillInt64(addvar,0, 5);
1626 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1627 /* if (!code) code = DumpString(iodp, 'n',V_name(vp)); */
1628 FillInt64(addvar,0, (2 + strlen(V_name(vp))));
1629 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1630 /* if (!code) code = DumpBool(iodp, 's',V_inService(vp)); */
1631 FillInt64(addvar,0, 2);
1632 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1633 /* if (!code) code = DumpBool(iodp, 'b',V_blessed(vp)); */
1634 FillInt64(addvar,0, 2);
1635 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1636 /* if (!code) code = DumpInt32(iodp, 'u',V_uniquifier(vp)); */
1637 FillInt64(addvar,0, 5);
1638 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1639 /* if (!code) code = DumpByte(iodp, 't',(byte)V_type(vp)); */
1640 FillInt64(addvar,0, 2);
1641 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1642 /* if (!code){ code = DumpInt32(iodp, 'p',V_parentId(vp));} */
1643 FillInt64(addvar,0, 5);
1644 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1645 /* if (!code) code = DumpInt32(iodp, 'c',V_cloneId(vp)); */
1646 FillInt64(addvar,0, 5);
1647 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1648 /* if (!code) code = DumpInt32(iodp, 'q',V_maxquota(vp)); */
1649 FillInt64(addvar,0, 5);
1650 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1651 /* if (!code) code = DumpInt32(iodp, 'm',V_minquota(vp)); */
1652 FillInt64(addvar,0, 5);
1653 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1654 /* if (!code) code = DumpInt32(iodp, 'd',V_diskused(vp)); */
1655 FillInt64(addvar,0, 5);
1656 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1657 /* if (!code) code = DumpInt32(iodp, 'f',V_filecount(vp)); */
1658 FillInt64(addvar,0, 5);
1659 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1660 /* if (!code) code = DumpInt32(iodp, 'a', V_accountNumber(vp)); */
1661 FillInt64(addvar,0, 5);
1662 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1663 /* if (!code) code = DumpInt32(iodp, 'o', V_owner(vp)); */
1664 FillInt64(addvar,0, 5);
1665 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1666 /* if (!code) code = DumpInt32(iodp, 'C',V_creationDate(vp)); /\* Rw volume creation date *\/ */
1667 FillInt64(addvar,0, 5);
1668 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1669 /* if (!code) code = DumpInt32(iodp, 'A',V_accessDate(vp)); */
1670 FillInt64(addvar,0, 5);
1671 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1672 /* if (!code) code = DumpInt32(iodp, 'U',V_updateDate(vp)); */
1673 FillInt64(addvar,0, 5);
1674 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1675 /* if (!code) code = DumpInt32(iodp, 'E',V_expirationDate(vp)); */
1676 FillInt64(addvar,0, 5);
1677 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1678 /* if (!code) code = DumpInt32(iodp, 'B',V_backupDate(vp)); /\* Rw volume backup clone date *\/ */
1679 FillInt64(addvar,0, 5);
1680 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1681 /* if (!code) code = DumpString(iodp, 'O',V_offlineMessage(vp)); */
1682 FillInt64(addvar,0, (2 + strlen(V_offlineMessage(vp))));
1683 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1685 /* * We do NOT dump the detailed volume statistics residing in the old */
1686 /* * motd field, since we cannot tell from the info in a dump whether */
1687 /* * statistics data has been put there. Instead, we dump a null string, */
1688 /* * just as if that was what the motd contained. */
1690 /* if (!code) code = DumpString(iodp, 'M', nullString); */
1691 FillInt64(addvar,0, (2 + strlen(nullString)));
1692 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1693 /* if (!code) code = DumpArrayInt32(iodp, 'W', (afs_uint32 *)V_weekUse(vp), sizeof(V_weekUse(vp))/sizeof(V_weekUse(vp)[0])); */
1694 FillInt64(addvar,0, (3 + 4 * (sizeof(V_weekUse(vp)) / sizeof(V_weekUse(vp)[0]))));
1695 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1696 /* if (!code) code = DumpInt32(iodp, 'D', V_dayUseDate(vp)); */
1697 FillInt64(addvar,0, 5);
1698 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1699 /* if (!code) code = DumpInt32(iodp, 'Z', V_dayUse(vp)); */
1700 FillInt64(addvar,0, 5);
1701 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1706 SizeDumpEnd(struct iod *iodp, struct volintSize *v_size)
1710 FillInt64(addvar,0, 5);
1711 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1716 SizeDumpVolume(struct rx_call *call, Volume * vp,
1717 afs_int32 fromtime, int dumpAllDirs,
1718 struct volintSize *v_size)
1721 struct iod *iodp = (struct iod *)0;
1722 /* iod_Init(iodp, call); */
1725 code = SizeDumpDumpHeader(iodp, vp, fromtime, v_size);
1727 code = SizeDumpPartial(iodp, vp, fromtime, dumpAllDirs, v_size);
1729 code = SizeDumpEnd(iodp, v_size);
1735 SizeDumpDumpHeader(struct iod *iodp, Volume * vp,
1736 afs_int32 fromtime, struct volintSize *v_size)
1739 /* int UseLatestReadOnlyClone = 1; */
1740 /* afs_int32 dumpTimes[2]; */
1742 /* iodp->device = vp->device; */
1743 /* iodp->parentId = V_parentId(vp); */
1744 /* iodp->dumpPartition = vp->partition; */
1746 ZeroInt64(v_size->dump_size); /* initialize the size */
1747 /* if (!code) code = DumpDouble(iodp, D_DUMPHEADER, DUMPBEGINMAGIC, DUMPVERSION); */
1748 FillInt64(addvar,0, 9);
1749 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1750 /* if (!code) code = DumpInt32(iodp, 'v', UseLatestReadOnlyClone? V_id(vp): V_parentId(vp)); */
1751 FillInt64(addvar,0, 5);
1752 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1753 /* if (!code) code = DumpString(iodp, 'n',V_name(vp)); */
1754 FillInt64(addvar,0, (2 + strlen(V_name(vp))));
1755 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1756 /* dumpTimes[0] = fromtime; */
1757 /* dumpTimes[1] = V_backupDate(vp); /\* Until the time the clone was made *\/ */
1758 /* if (!code) code = DumpArrayInt32(iodp, 't', (afs_uint32 *)dumpTimes, 2); */
1759 FillInt64(addvar,0, (3 + 4 * 2));
1760 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1765 SizeDumpVnode(struct iod *iodp, struct VnodeDiskObject *v, int volid,
1766 int vnodeNumber, int dumpEverything,
1767 struct volintSize *v_size)
1772 if (!v || v->type == vNull)
1774 /* if (!code) code = DumpDouble(iodp, D_VNODE, vnodeNumber, v->uniquifier); */
1775 FillInt64(addvar,0, 9);
1776 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1777 if (!dumpEverything)
1779 /* if (!code) code = DumpByte(iodp, 't',(byte)v->type); */
1780 FillInt64(addvar,0, 2);
1781 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1782 /* if (!code) code = DumpShort(iodp, 'l', v->linkCount); /\* May not need this *\/ */
1783 FillInt64(addvar,0, 3);
1784 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1785 /* if (!code) code = DumpInt32(iodp, 'v', v->dataVersion); */
1786 FillInt64(addvar,0, 5);
1787 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1788 /* if (!code) code = DumpInt32(iodp, 'm', v->unixModifyTime); */
1789 FillInt64(addvar,0, 5);
1790 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1791 /* if (!code) code = DumpInt32(iodp, 'a', v->author); */
1792 FillInt64(addvar,0, 5);
1793 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1794 /* if (!code) code = DumpInt32(iodp, 'o', v->owner); */
1795 FillInt64(addvar,0, 5);
1796 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1797 /* if (!code && v->group) code = DumpInt32(iodp, 'g', v->group); /\* default group is 0 *\/ */
1799 FillInt64(addvar,0, 5);
1800 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1802 /* if (!code) code = DumpShort(iodp, 'b', v->modeBits); */
1803 FillInt64(addvar,0, 3);
1804 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1805 /* if (!code) code = DumpInt32(iodp, 'p', v->parent); */
1806 FillInt64(addvar,0, 5);
1807 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1808 /* if (!code) code = DumpInt32(iodp, 's', v->serverModifyTime); */
1809 FillInt64(addvar,0, 5);
1810 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1811 if (v->type == vDirectory) {
1812 /* acl_HtonACL(VVnodeDiskACL(v)); */
1813 /* if (!code) code = DumpByteString(iodp, 'A', (byte *) VVnodeDiskACL(v), VAclDiskSize(v)); */
1814 FillInt64(addvar,0, (1 + VAclDiskSize(v)));
1815 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1818 if (VNDISK_GET_INO(v)) {
1819 FillInt64(addvar,0, (v->length + 5));
1820 AddUInt64(v_size->dump_size, addvar, &v_size->dump_size);
1825 /* A partial dump (no dump header) */
1827 SizeDumpPartial(struct iod *iodp, Volume * vp,
1828 afs_int32 fromtime, int dumpAllDirs,
1829 struct volintSize *v_size)
1833 code = SizeDumpVolumeHeader(iodp, vp, v_size);
1836 SizeDumpVnodeIndex(iodp, vp, vLarge, fromtime, dumpAllDirs,
1839 code = SizeDumpVnodeIndex(iodp, vp, vSmall, fromtime, 0, v_size);
1844 SizeDumpVnodeIndex(struct iod *iodp, Volume * vp, VnodeClass class,
1845 afs_int32 fromtime, int forcedump,
1846 struct volintSize *v_size)
1849 struct VnodeClassInfo *vcp = &VnodeClassInfo[class];
1850 char buf[SIZEOF_LARGEDISKVNODE];
1851 struct VnodeDiskObject *vnode = (struct VnodeDiskObject *)buf;
1852 StreamHandle_t *file;
1854 afs_sfsize_t size, nVnodes;
1858 fdP = IH_OPEN(vp->vnodeIndex[class].handle);
1859 osi_Assert(fdP != NULL);
1860 file = FDH_FDOPEN(fdP, "r+");
1861 osi_Assert(file != NULL);
1862 size = OS_SIZE(fdP->fd_fd);
1863 osi_Assert(size != -1);
1864 nVnodes = (size / vcp->diskSize) - 1;
1866 osi_Assert((nVnodes + 1) * vcp->diskSize == size);
1867 osi_Assert(STREAM_ASEEK(file, vcp->diskSize) == 0);
1870 for (vnodeIndex = 0;
1871 nVnodes && STREAM_READ(vnode, vcp->diskSize, 1, file) == 1 && !code;
1872 nVnodes--, vnodeIndex++) {
1873 flag = forcedump || (vnode->serverModifyTime >= fromtime);
1874 /* Note: the >= test is very important since some old volumes may not have
1875 * a serverModifyTime. For an epoch dump, this results in 0>=0 test, which
1876 * does dump the file! */
1879 SizeDumpVnode(iodp, vnode, V_id(vp),
1880 bitNumberToVnodeNumber(vnodeIndex, class), flag,