*/
-#define SalvageVersion "2.4"
-
-/* Main program file. Define globals. */
-#define MAIN 1
-
#include <afsconfig.h>
#include <afs/param.h>
-RCSID("$Header$");
+#ifndef AFS_NT40_ENV
+#include <sys/param.h>
+#include <sys/file.h>
+#ifndef ITIMER_REAL
+#include <sys/time.h>
+#endif /* ITIMER_REAL */
+#endif
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#ifdef AFS_NT40_ENV
#include <io.h>
#include <WINNT/afsevent.h>
-#else
-#include <sys/param.h>
-#include <sys/file.h>
-#ifndef ITIMER_REAL
-#include <sys/time.h>
-#endif /* ITIMER_REAL */
#endif
-#if defined(AFS_AIX_ENV)
-#define WCOREDUMP(x) (x & 0200)
+#ifndef WCOREDUMP
+#define WCOREDUMP(x) ((x) & 0200)
#endif
#include <rx/xdr.h>
#include <afs/afsint.h>
#else /* AFS_VFSINCL_ENV */
#ifdef AFS_OSF_ENV
#include <ufs/inode.h>
-#else /* AFS_OSF_ENV */
+#else /* AFS_OSF_ENV */
#if !defined(AFS_LINUX20_ENV) && !defined(AFS_XBSD_ENV)
#include <sys/inode.h>
#endif
#include <afs/osi_inode.h>
#endif
#include <afs/cmd.h>
+#include <afs/dir.h>
#include <afs/afsutil.h>
#include <afs/fileutil.h>
-#include <afs/procmgmt.h> /* signal(), kill(), wait(), etc. */
+#include <afs/procmgmt.h> /* signal(), kill(), wait(), etc. */
#ifndef AFS_NT40_ENV
#include <syslog.h>
#endif
#include "vnode.h"
#include "volume.h"
#include "partition.h"
+#include "daemon_com.h"
#include "fssync.h"
+#include "volume_inline.h"
+#include "salvsync.h"
#include "viceinode.h"
#include "salvage.h"
-#include "volinodes.h" /* header magic number, etc. stuff */
+#include "volinodes.h" /* header magic number, etc. stuff */
+#include "vol-salvage.h"
+#include "vol_internal.h"
+#include <afs/acl.h>
+#include <afs/prs_fs.h>
+
+#ifdef FSSYNC_BUILD_CLIENT
+#include "vg_cache.h"
+#endif
+
#ifdef AFS_NT40_ENV
#include <pthread.h>
#endif
+/*@+fcnmacros +macrofcndecl@*/
+#ifdef O_LARGEFILE
+#ifdef S_SPLINT_S
+extern off64_t afs_lseek(int FD, off64_t O, int F);
+#endif /*S_SPLINT_S */
+#define afs_lseek(FD, O, F) lseek64(FD, (off64_t) (O), F)
+#define afs_stat stat64
+#define afs_fstat fstat64
+#define afs_open open64
+#define afs_fopen fopen64
+#else /* !O_LARGEFILE */
+#ifdef S_SPLINT_S
+extern off_t afs_lseek(int FD, off_t O, int F);
+#endif /*S_SPLINT_S */
+#define afs_lseek(FD, O, F) lseek(FD, (off_t) (O), F)
+#define afs_stat stat
+#define afs_fstat fstat
+#define afs_open open
+#define afs_fopen fopen
+#endif /* !O_LARGEFILE */
+/*@=fcnmacros =macrofcndecl@*/
+
#ifdef AFS_OSF_ENV
extern void *calloc();
#endif
-extern char *vol_DevName();
static char *TimeStamp(time_t clock, int precision);
-#define ORPH_IGNORE 0
-#define ORPH_REMOVE 1
-#define ORPH_ATTACH 2
-
-
-int debug; /* -d flag */
-int Testing=0; /* -n flag */
-int ListInodeOption; /* -i flag */
-int ShowRootFiles; /* -r flag */
-int RebuildDirs; /* -sal flag */
-int Parallel = 4; /* -para X flag */
-int PartsPerDisk = 8; /* Salvage up to 8 partitions on same disk sequentially */
-int forceR = 0; /* -b flag */
-int ShowLog = 0; /* -showlog flag */
-int ShowSuid = 0; /* -showsuid flag */
-int ShowMounts = 0; /* -showmounts flag */
-int orphans = ORPH_IGNORE; /* -orphans option */
-int Showmode = 0;
+
+int debug; /* -d flag */
+extern int Testing; /* -n flag */
+int ListInodeOption; /* -i flag */
+int ShowRootFiles; /* -r flag */
+int RebuildDirs; /* -sal flag */
+int Parallel = 4; /* -para X flag */
+int PartsPerDisk = 8; /* Salvage up to 8 partitions on same disk sequentially */
+int forceR = 0; /* -b flag */
+int ShowLog = 0; /* -showlog flag */
+int ShowSuid = 0; /* -showsuid flag */
+int ShowMounts = 0; /* -showmounts flag */
+int orphans = ORPH_IGNORE; /* -orphans option */
+int Showmode = 0;
+
#ifndef AFS_NT40_ENV
-int useSyslog = 0; /* -syslog flag */
-int useSyslogFacility = LOG_DAEMON; /* -syslogfacility option */
+int useSyslog = 0; /* -syslog flag */
+int useSyslogFacility = LOG_DAEMON; /* -syslogfacility option */
+#endif
+
+#ifdef AFS_NT40_ENV
+int canfork = 0;
+#else
+int canfork = 1;
#endif
#define MAXPARALLEL 32
-int OKToZap; /* -o flag */
-int ForceSalvage; /* If salvage should occur despite the DONT_SALVAGE flag
- in the volume header */
+int OKToZap; /* -o flag */
+int ForceSalvage; /* If salvage should occur despite the DONT_SALVAGE flag
+ * in the volume header */
-static FILE *logFile = 0; /* one of {/usr/afs/logs,/vice/file}/SalvageLog */
+FILE *logFile = 0; /* one of {/usr/afs/logs,/vice/file}/SalvageLog */
#define ROOTINODE 2 /* Root inode of a 4.2 Unix file system
- partition */
-Device fileSysDevice; /* The device number of the current
- partition being salvaged */
+ * partition */
+Device fileSysDevice; /* The device number of the current
+ * partition being salvaged */
#ifdef AFS_NT40_ENV
char fileSysPath[8];
#else
-char *fileSysPath; /* The path of the mounted partition currently
- being salvaged, i.e. the directory
- containing the volume headers */
+char *fileSysPath; /* The path of the mounted partition currently
+ * being salvaged, i.e. the directory
+ * containing the volume headers */
#endif
-char *fileSysPathName; /* NT needs this to make name pretty in log. */
+char *fileSysPathName; /* NT needs this to make name pretty in log. */
IHandle_t *VGLinkH; /* Link handle for current volume group. */
int VGLinkH_cnt; /* # of references to lnk handle. */
-struct DiskPartition *fileSysPartition; /* Partition being salvaged */
+struct DiskPartition64 *fileSysPartition; /* Partition being salvaged */
#ifndef AFS_NT40_ENV
-char *fileSysDeviceName; /* The block device where the file system
- being salvaged was mounted */
-char *filesysfulldev;
+char *fileSysDeviceName; /* The block device where the file system
+ * being salvaged was mounted */
+char *filesysfulldev;
#endif
-int VolumeChanged; /* Set by any routine which would change the volume in
- a way which would require callback is to be broken if the
- volume was put back on line by an active file server */
-
-VolumeDiskData VolInfo; /* A copy of the last good or salvaged volume header dealt with */
-
-struct InodeSummary { /* Inode summary file--an entry for each
- volume in the inode file for a partition */
- VolId volumeId; /* Volume id */
- VolId RWvolumeId; /* RW volume associated */
- int index; /* index into inode file (0, 1, 2 ...) */
- int nInodes; /* Number of inodes for this volume */
- int nSpecialInodes; /* Number of special inodes, i.e. volume
- header, index, etc. These are all
- marked (viceinode.h) and will all be sorted
- to the beginning of the information for
- this volume. Read-only volumes should
- ONLY have special inodes (all the other
- inodes look as if they belong to the
- original RW volume). */
- Unique maxUniquifier; /* The maximum uniquifier found in all the inodes.
- This is only useful for RW volumes and is used
- to compute a new volume uniquifier in the event
- that the header needs to be recreated. The inode
- uniquifier may be a truncated version of vnode
- uniquifier (AFS_3DISPARES). The real maxUniquifer
- is from the vnodes and later calcuated from it */
- struct VolumeSummary *volSummary;
- /* Either a pointer to the original volume
- header summary, or constructed summary
- information */
-} *inodeSummary;
-#define readOnly(isp) ((isp)->volumeId != (isp)->RWvolumeId)
+int VolumeChanged; /* Set by any routine which would change the volume in
+ * a way which would require callback is to be broken if the
+ * volume was put back on line by an active file server */
+
+VolumeDiskData VolInfo; /* A copy of the last good or salvaged volume header dealt with */
+
int nVolumesInInodeFile; /* Number of read-write volumes summarized */
int inodeFd; /* File descriptor for inode file */
-struct VolumeSummary { /* Volume summary an entry for each
- volume in a volume directory.
- Assumption: one volume directory per
- partition */
- char *fileName; /* File name on the partition for the volume
- header */
- struct VolumeHeader header;
- /* volume number, rw volume number, inode
- numbers of each major component of
- the volume */
- IHandle_t *volumeInfoHandle;
- byte wouldNeedCallback; /* set if the file server should issue
- call backs for all the files in this volume when
- the volume goes back on line */
-};
-
-struct VnodeInfo {
- IHandle_t *handle; /* Inode containing this index */
- int nVnodes; /* Total number of vnodes in index */
- int nAllocatedVnodes; /* Total number actually used */
- int volumeBlockCount; /* Total number of blocks used by volume */
- Inode *inodes; /* Directory only */
- struct VnodeEssence {
- short count; /* Number of references to vnode; MUST BE SIGNED */
- unsigned claimed:1; /* Set when a parent directory containing an entry
- referencing this vnode is found. The claim
- is that the parent in "parent" can point to
- this vnode, and no other */
- unsigned changed:1; /* Set if any parameters (other than the count)
- in the vnode change. It is determined if the
- link count has changed by noting whether it is
- 0 after scanning all directories */
- unsigned salvaged:1;/* Set if this directory vnode has already been salvaged. */
- unsigned todelete:1;/* Set if this vnode is to be deleted (should not be claimed) */
- afs_uint32 blockCount;
- /* Number of blocks (1K) used by this vnode,
- approximately */
- VnodeId parent; /* parent in vnode */
- Unique unique; /* Must match entry! */
- char *name; /* Name of directory entry */
- int modeBits; /* File mode bits */
- Inode InodeNumber; /* file's inode */
- int type; /* File type */
- int author; /* File author */
- int owner; /* File owner */
- int group; /* File group */
- } *vnodes;
-} vnodeInfo[nVNODECLASSES];
-
-struct DirSummary {
- struct DirHandle dirHandle;
- VnodeId vnodeNumber;
- Unique unique;
- unsigned haveDot, haveDotDot;
- VolumeId rwVid;
- int copied; /* If the copy-on-write stuff has been applied */
- VnodeId parent;
- char *name;
- char *vname;
- IHandle_t *ds_linkH;
-};
+struct VnodeInfo vnodeInfo[nVNODECLASSES];
-struct VolumeSummary *volumeSummaryp; /* Holds all the volumes in a part */
+struct VolumeSummary *volumeSummaryp = NULL; /* Holds all the volumes in a part */
int nVolumes; /* Number of volumes (read-write and read-only)
- in volume summary */
+ * in volume summary */
-#ifdef AFS_NT40_ENV
-/* For NT, we can fork the per partition salvagers to gain the required
- * safety against Aborts. But there's too many complex data structures at
- * the per volume salvager layer to easilty copy the data across.
- * childJobNumber is resset from -1 to the job number if this is a
- * per partition child of the main salvager. This information is passed
- * out-of-band in the extra data area setup for the now unused parent/child
- * data transfer.
- */
-#define SALVAGER_MAGIC 0x00BBaaDD
-#define NOT_CHILD -1 /* job numbers start at 0 */
-/* If new options need to be passed to child, add them here. */
-typedef struct {
- int cj_magic;
- int cj_number;
- char cj_part[32];
-} childJob_t;
-
-/* Child job this process is running. */
-childJob_t myjob = { SALVAGER_MAGIC, NOT_CHILD};
-
-int nt_SalvagePartition(char *partName, int jobn);
-int nt_SetupPartitionSalvage(void *datap, int len);
-
-typedef struct {
- struct InodeSummary *svgp_inodeSummaryp;
- int svgp_count;
-} SVGParms_t;
-#define canfork 0
-#else
-#define canfork 1
-#endif
+char *tmpdir = NULL;
/* Forward declarations */
-void Log(), Abort(), Exit();
-int Fork(void);
-int Wait(char *prog);
-char * ToString(char *s);
-void AskOffline(VolumeId volumeId);
-void AskOnline(VolumeId volumeId, char *partition);
-void CheckLogFile(void);
-void ClearROInUseBit(struct VolumeSummary *summary);
-void CopyAndSalvage(register struct DirSummary *dir);
-int CopyInode(Device device, Inode inode1, Inode inode2, int rwvolume);
-void CopyOnWrite(register struct DirSummary *dir);
-void CountVolumeInodes(register struct ViceInodeInfo *ip, int maxInodes,
- register struct InodeSummary * summary);
-void DeleteExtraVolumeHeaderFile(register struct VolumeSummary *vsp);
-void DistilVnodeEssence(VolumeId vid, VnodeClass class, Inode ino,
- Unique *maxu);
-int GetInodeSummary(char *path, VolumeId singleVolumeNumber);
-void GetVolumeSummary(VolumeId singleVolumeNumber);
-void JudgeEntry(struct DirSummary *dir, char *name, VnodeId vnodeNumber,
- Unique unique);
-void MaybeZapVolume(register struct InodeSummary *isp, char *message,
- int deleteMe,
- int check);
-void ObtainSalvageLock(void);
-void PrintInodeList(void);
-void PrintInodeSummary(void);
-void PrintVolumeSummary(void);
-int QuickCheck(register struct InodeSummary *isp, int nVols);
-void RemoveTheForce(char *path);
-void SalvageDir(char *name, VolumeId rwVid, struct VnodeInfo *dirVnodeInfo,
- IHandle_t *alinkH, int i, struct DirSummary *rootdir,
- int *rootdirfound);
-void SalvageFileSysParallel(struct DiskPartition *partP);
-void SalvageFileSys(struct DiskPartition *partP, VolumeId singleVolumeNumber);
-void SalvageFileSys1(struct DiskPartition *partP, VolumeId singleVolumeNumber);
-int SalvageHeader(register struct stuff *sp, struct InodeSummary *isp,
- int check, int *deleteMe);
-int SalvageIndex(Inode ino, VnodeClass class, int RW,
- register struct ViceInodeInfo *ip,
- int nInodes, struct VolumeSummary *volSummary, int check);
-int SalvageVnodes(register struct InodeSummary *rwIsp,
- register struct InodeSummary * thisIsp,
- register struct ViceInodeInfo * inodes, int check);
-int SalvageVolume(register struct InodeSummary *rwIsp, IHandle_t *alinkH);
-void DoSalvageVolumeGroup(register struct InodeSummary *isp, int nVols);
-#ifdef AFS_NT40_ENV
-void SalvageVolumeGroup(register struct InodeSummary *isp, int nVols);
-#else
-#define SalvageVolumeGroup DoSalvageVolumeGroup
-#endif
-int SalvageVolumeHeaderFile(register struct InodeSummary *isp,
- register struct ViceInodeInfo *inodes,
- int RW, int check, int *deleteMe);
-void showlog(void);
-int UseTheForceLuke(char *path);
-
+/*@printflike@*/ void Log(const char *format, ...);
+/*@printflike@*/ void Abort(const char *format, ...);
static int IsVnodeOrphaned(VnodeId vnode);
+static int AskVolumeSummary(VolumeId singleVolumeNumber);
+
+#ifdef AFS_DEMAND_ATTACH_FS
+static int LockVolume(VolumeId volumeId);
+#endif /* AFS_DEMAND_ATTACH_FS */
/* Uniquifier stored in the Inode */
-static Unique IUnique(u)
- Unique u;
+static Unique
+IUnique(Unique u)
{
#ifdef AFS_3DISPARES
- return(u & 0x3fffff);
+ return (u & 0x3fffff);
#else
#if defined(AFS_SGI_EXMAG)
- return(u & SGI_UNIQMASK);
+ return (u & SGI_UNIQMASK);
#else
- return(u);
+ return (u);
#endif /* AFS_SGI_EXMAG */
#endif
}
-static int BadError(aerror)
-register int aerror; {
+static int
+BadError(register int aerror)
+{
if (aerror == EPERM || aerror == ENXIO || aerror == ENOENT)
return 1;
- return 0; /* otherwise may be transient, e.g. EMFILE */
-}
-
-
-char *tmpdir = 0;
-static handleit(as)
- struct cmd_syndesc *as;
-{
- register struct cmd_item *ti;
- char pname[100], *temp;
- afs_int32 seenpart = 0, seenvol = 0, vid = 0;
- struct DiskPartition *partP;
-
-#ifdef AFS_SGI_VNODE_GLUE
- if (afs_init_kernel_config(-1) <0) {
- printf("Can't determine NUMA configuration, not starting salvager.\n");
- exit(1);
- }
-#endif
-
- if (ti = as->parms[0].items) { /* -partition */
- seenpart = 1;
- strncpy(pname, ti->data, 100);
- }
- if (ti = as->parms[1].items) { /* -volumeid */
- if (!seenpart) {
- printf("You must also specify '-partition' option with the '-volumeid' option\n");
- exit(-1);
- }
- seenvol = 1;
- vid = atoi(ti->data);
- }
- if (as->parms[2].items) /* -debug */
- debug = 1;
- if (as->parms[3].items) /* -nowrite */
- Testing = 1;
- if (as->parms[4].items) /* -inodes */
- ListInodeOption = 1;
- if (as->parms[5].items) /* -force */
- ForceSalvage = 1;
- if (as->parms[6].items) /* -oktozap */
- OKToZap = 1;
- if (as->parms[7].items) /* -rootinodes */
- ShowRootFiles = 1;
- if (as->parms[8].items) /* -RebuildDirs */
- RebuildDirs = 1;
- if (as->parms[9].items) /* -ForceReads */
- forceR = 1;
- if (ti = as->parms[10].items) {/* -Parallel # */
- temp = ti->data;
- if (strncmp(temp,"all",3) == 0) {
- PartsPerDisk = 1;
- temp += 3;
- }
- if (strlen(temp) != 0) {
- Parallel = atoi(temp);
- if (Parallel < 1) Parallel = 1;
- if (Parallel > MAXPARALLEL) {
- printf("Setting parallel salvages to maximum of %d \n", MAXPARALLEL);
- Parallel = MAXPARALLEL;
- }
- }
- }
- if (ti = as->parms[11].items) {/* -tmpdir */
- DIR *dirp;
-
- tmpdir = ti->data;
- dirp = opendir(tmpdir);
- if (!dirp) {
- printf("Can't open temporary placeholder dir %s; using current partition \n", tmpdir);
- tmpdir = (char *)0;
- } else
- closedir(dirp);
- }
- if (ti = as->parms[12].items) /* -showlog */
- ShowLog = 1;
- if (ti = as->parms[13].items) { /* -log */
- Testing = 1;
- ShowSuid = 1;
- Showmode = 1;
- }
- if (ti = as->parms[14].items) { /* -showmounts */
- Testing = 1;
- Showmode = 1;
- ShowMounts = 1;
- }
- if (ti = as->parms[15].items) { /* -orphans */
- if (Testing)
- orphans = ORPH_IGNORE;
- else if (strcmp(ti->data, "remove")==0 || strcmp(ti->data, "r")==0)
- orphans = ORPH_REMOVE;
- else if (strcmp(ti->data, "attach")==0 || strcmp(ti->data, "a")==0)
- orphans = ORPH_ATTACH;
- }
-
-#ifndef AFS_NT40_ENV /* ignore options on NT */
- if ( ti = as->parms[16].items) { /* -syslog */
- useSyslog = 1;
- ShowLog = 0;
- }
- if ( ti = as->parms[17].items) { /* -syslogfacility */
- useSyslogFacility = atoi(ti->data);
- }
-#endif
-
-
-#ifdef FAST_RESTART
- if (ti = as->parms[18].items) { /* -DontSalvage */
- printf("Exiting immediately without salvage. Look into the FileLog");
- printf(" to find volumes which really need to be salvaged!\n");
- Exit(0);
- }
-#endif /* FAST_RESTART */
-
- /* Note: if seemvol we initialize this as a standard volume utility: this has the
- implication that the file server may be running; negotations have to be made with
- the file server in this case to take the read write volume and associated read-only
- volumes off line before salvaging */
-#ifdef AFS_NT40_ENV
- if (seenvol) {
- if (afs_winsockInit()<0) {
- ReportErrorEventAlt(AFSEVT_SVR_WINSOCK_INIT_FAILED, 0,
- AFSDIR_SALVAGER_FILE, 0);
- Log("Failed to initailize winsock, exiting.\n");
- Exit(1);
- }
- }
-#endif
- VInitVolumePackage(seenvol ? volumeUtility: salvager, 5, 5, DONT_CONNECT_FS, 0);
- DInit(10);
-#ifdef AFS_NT40_ENV
- if (myjob.cj_number != NOT_CHILD) {
- if (!seenpart) {
- seenpart = 1;
- (void) strcpy(pname, myjob.cj_part);
- }
- }
-#endif
- if (seenpart == 0) {
- for (partP = DiskPartitionList; partP; partP = partP->next) {
- SalvageFileSysParallel(partP);
- }
- SalvageFileSysParallel(0);
- }
- else {
- partP = VGetPartition(pname, 0);
- if (!partP) {
- Log("salvage: Unknown or unmounted partition %s; salvage aborted\n",
- pname);
- Exit(1);
- }
- if (!seenvol)
- SalvageFileSys(partP, 0);
- else {
- /* Salvage individual volume */
- if (vid <= 0) {
- Log("salvage: invalid volume id specified; salvage aborted\n");
- Exit(1);
- }
- SalvageFileSys (partP, vid);
- }
- }
- return (0);
+ return 0; /* otherwise may be transient, e.g. EMFILE */
}
-
-#ifndef AFS_NT40_ENV
-#include "AFS_component_version_number.c"
-#endif
#define MAX_ARGS 128
#ifdef AFS_NT40_ENV
char *save_args[MAX_ARGS];
int n_save_args = 0;
-pthread_t main_thread;
+extern pthread_t main_thread;
+childJob_t myjob = { SALVAGER_MAGIC, NOT_CHILD, "" };
#endif
-main(argc,argv)
-char **argv;
+/**
+ * Get the salvage lock if not already held. Hold until process exits.
+ *
+ * @param[in] locktype READ_LOCK or WRITE_LOCK
+ */
+static void
+_ObtainSalvageLock(int locktype)
{
- struct cmd_syndesc *ts;
- int err = 0;
- char commandLine[150];
-
- int i;
- extern char cml_version_number[];
-
-#ifdef AFS_AIX32_ENV
- /*
- * The following signal action for AIX is necessary so that in case of a
- * crash (i.e. core is generated) we can include the user's data section
- * in the core dump. Unfortunately, by default, only a partial core is
- * generated which, in many cases, isn't too useful.
- */
- struct sigaction nsa;
-
- sigemptyset(&nsa.sa_mask);
- nsa.sa_handler = SIG_DFL;
- nsa.sa_flags = SA_FULLDUMP;
- sigaction(SIGABRT, &nsa, NULL);
- sigaction(SIGSEGV, &nsa, NULL);
-#endif
-
- /* Initialize directory paths */
- if (!(initAFSDirPath() & AFSDIR_SERVER_PATHS_OK)) {
-#ifdef AFS_NT40_ENV
- ReportErrorEventAlt(AFSEVT_SVR_NO_INSTALL_DIR, 0, argv[0], 0);
-#endif
- fprintf(stderr,"%s: Unable to obtain AFS server directory.\n", argv[0]);
- exit(2);
- }
-#ifdef AFS_NT40_ENV
- main_thread = pthread_self();
- if (spawnDatap && spawnDataLen) {
- /* This is a child per partition salvager. Don't setup log or
- * try to lock the salvager lock.
- */
- if (nt_SetupPartitionSalvage(spawnDatap, spawnDataLen)<0)
- exit(3);
- }
- else {
-#endif
- for (commandLine[0] = '\0', i=0; i<argc; i++) {
- if (i > 0) strcat(commandLine, " ");
- strcat(commandLine, argv[i]);
- }
-
- /* All entries to the log will be appended. Useful if there are
- * multiple salvagers appending to the log.
- */
-
- CheckLogFile();
-#ifndef AFS_NT40_ENV
-#ifdef AFS_LINUX20_ENV
- fcntl(fileno(logFile), F_SETFL, O_APPEND); /* Isn't this redundant? */
-#else
- fcntl(fileno(logFile), F_SETFL, FAPPEND); /* Isn't this redundant? */
-#endif
-#endif
- setlinebuf(logFile);
-
-#ifndef AFS_NT40_ENV
- if (geteuid() != 0) {
- printf("Salvager must be run as root.\n");
- fflush(stdout);
- Exit(0);
- }
-#endif
-
- /* bad for normal help flag processing, but can do nada */
-
- fprintf(logFile, "%s\n", cml_version_number);
- Log("STARTING AFS SALVAGER %s (%s)\n", SalvageVersion, commandLine);
+ struct VLockFile salvageLock;
+ int offset = 0;
+ int nonblock = 1;
+ int code;
- /* Get and hold a lock for the duration of the salvage to make sure
- * that no other salvage runs at the same time. The routine
- * VInitVolumePackage (called below) makes sure that a file server or
- * other volume utilities don't interfere with the salvage.
- */
- ObtainSalvageLock();
-#ifdef AFS_NT40_ENV
- }
-#endif
+ VLockFileInit(&salvageLock, AFSDIR_SERVER_SLVGLOCK_FILEPATH);
- ts = cmd_CreateSyntax("initcmd", handleit, 0, "initialize the program");
- cmd_AddParm(ts, "-partition", CMD_SINGLE,CMD_OPTIONAL, "Name of partition to salvage");
- cmd_AddParm(ts, "-volumeid", CMD_SINGLE,CMD_OPTIONAL, "Volume Id to salvage");
- cmd_AddParm(ts, "-debug", CMD_FLAG,CMD_OPTIONAL, "Run in Debugging mode");
- cmd_AddParm(ts, "-nowrite", CMD_FLAG,CMD_OPTIONAL, "Run readonly/test mode");
- cmd_AddParm(ts, "-inodes", CMD_FLAG,CMD_OPTIONAL, "Just list affected afs inodes - debugging flag");
- cmd_AddParm(ts, "-force", CMD_FLAG,CMD_OPTIONAL, "Force full salvaging");
- cmd_AddParm(ts, "-oktozap", CMD_FLAG,CMD_OPTIONAL, "Give permission to destroy bogus inodes/volumes - debugging flag");
- cmd_AddParm(ts, "-rootinodes", CMD_FLAG,CMD_OPTIONAL, "Show inodes owned by root - debugging flag");
- cmd_AddParm(ts, "-salvagedirs", CMD_FLAG,CMD_OPTIONAL, "Force rebuild/salvage of all directories");
- cmd_AddParm(ts, "-blockreads", CMD_FLAG,CMD_OPTIONAL, "Read smaller blocks to handle IO/bad blocks");
- cmd_AddParm(ts, "-parallel", CMD_SINGLE,CMD_OPTIONAL, "# of max parallel partition salvaging");
- cmd_AddParm(ts, "-tmpdir", CMD_SINGLE,CMD_OPTIONAL, "Name of dir to place tmp files ");
- cmd_AddParm(ts, "-showlog", CMD_FLAG,CMD_OPTIONAL, "Show log file upon completion");
- cmd_AddParm(ts, "-showsuid", CMD_FLAG,CMD_OPTIONAL, "Report on suid/sgid files");
- cmd_AddParm(ts, "-showmounts", CMD_FLAG,CMD_OPTIONAL, "Report on mountpoints");
- cmd_AddParm(ts, "-orphans", CMD_SINGLE, CMD_OPTIONAL, "ignore | remove | attach");
-
- /* note - syslog isn't avail on NT, but if we make it conditional, have
- to deal with screwy offsets for cmd params */
- cmd_AddParm(ts, "-syslog", CMD_FLAG, CMD_OPTIONAL, "Write salvage log to syslogs");
- cmd_AddParm(ts, "-syslogfacility", CMD_SINGLE, CMD_OPTIONAL, "Syslog facility number to use");
-
-#ifdef FAST_RESTART
- cmd_AddParm(ts, "-DontSalvage", CMD_FLAG, CMD_OPTIONAL, "Don't salvage. This my be set in BosConfig to let the fileserver restart immediately after a crash. Bad volumes will be taken offline");
-#endif /* FAST_RESTART */
- err = cmd_Dispatch(argc, argv);
- Exit(err);
-}
-
-/* Get the salvage lock if not already held. Hold until process exits. */
-void ObtainSalvageLock(void)
-{
- int salvageLock;
-
-#ifdef AFS_NT40_ENV
- salvageLock = (int) CreateFile(AFSDIR_SERVER_SLVGLOCK_FILEPATH, 0, 0, NULL,
- OPEN_ALWAYS, FILE_ATTRIBUTE_NORMAL,
- NULL);
- if (salvageLock == (int)INVALID_HANDLE_VALUE) {
+ code = VLockFileLock(&salvageLock, offset, locktype, nonblock);
+ if (code == EBUSY) {
fprintf(stderr,
- "salvager: There appears to be another salvager running! Aborted.\n");
+ "salvager: There appears to be another salvager running! "
+ "Aborted.\n");
Exit(1);
- }
-#else
- salvageLock = open(AFSDIR_SERVER_SLVGLOCK_FILEPATH, O_CREAT|O_RDWR, 0666);
- assert(salvageLock >= 0);
-#ifdef AFS_DARWIN_ENV
- if (flock(salvageLock, LOCK_EX) == -1) {
-#else
- if (lockf(salvageLock, F_LOCK, 0) == -1) {
-#endif
+ } else if (code) {
fprintf(stderr,
- "salvager: There appears to be another salvager running! Aborted.\n");
+ "salvager: Error %d trying to acquire salvage lock! "
+ "Aborted.\n", code);
Exit(1);
}
-#endif
+}
+void
+ObtainSalvageLock(void)
+{
+ _ObtainSalvageLock(WRITE_LOCK);
+}
+void
+ObtainSharedSalvageLock(void)
+{
+ _ObtainSalvageLock(READ_LOCK);
}
/* Check if the given partition is mounted. For XFS, the root inode is not a
* constant. So we check the hard way.
*/
-int IsPartitionMounted(char *part)
+int
+IsPartitionMounted(char *part)
{
FILE *mntfp;
struct mntent *mntent;
-
+
assert(mntfp = setmntent(MOUNTED, "r"));
while (mntent = getmntent(mntfp)) {
if (!strcmp(part, mntent->mnt_dir))
break;
}
endmntent(mntfp);
-
+
return mntent ? 1 : 1;
}
#endif
/* Check if the given inode is the root of the filesystem. */
#ifndef AFS_SGI_XFS_IOPS_ENV
-int IsRootInode(status)
-struct stat *status;
+int
+IsRootInode(struct afs_stat *status)
{
- /* The root inode is not a fixed value in XFS partitions. So we need to see if
- * the partition is in the list of mounted partitions. This only affects the
- * SalvageFileSys path, so we check there.
+ /*
+ * The root inode is not a fixed value in XFS partitions. So we need to
+ * see if the partition is in the list of mounted partitions. This only
+ * affects the SalvageFileSys path, so we check there.
*/
return (status->st_ino == ROOTINODE);
}
#endif
#ifdef AFS_AIX42_ENV
+#ifndef AFS_NAMEI_ENV
/* We don't want to salvage big files filesystems, since we can't put volumes on
* them.
*/
-int CheckIfBigFilesFS(mountPoint, devName)
- char *mountPoint;
- char *devName;
+int
+CheckIfBigFilesFS(char *mountPoint, char *devName)
{
struct superblock fs;
char name[128];
if (strncmp(devName, "/dev/", 5)) {
- (void) sprintf(name, "/dev/%s", devName);
- }
- else {
- (void) strcpy(name, devName);
+ (void)sprintf(name, "/dev/%s", devName);
+ } else {
+ (void)strcpy(name, devName);
}
- if (ReadSuper(&fs, name)<0) {
- Log("Unable to read superblock. Not salvaging partition %s.\n", mountPoint);
+ if (ReadSuper(&fs, name) < 0) {
+ Log("Unable to read superblock. Not salvaging partition %s.\n",
+ mountPoint);
return 1;
}
if (IsBigFilesFileSystem(&fs)) {
- Log("Partition %s is a big files filesystem, not salvaging.\n", mountPoint);
+ Log("Partition %s is a big files filesystem, not salvaging.\n",
+ mountPoint);
return 1;
}
return 0;
}
#endif
+#endif
#ifdef AFS_NT40_ENV
#define HDSTR "\\Device\\Harddisk"
-#define HDLEN (sizeof(HDSTR)-1) /* Length of "\Device\Harddisk" */
-int SameDisk(struct DiskPartition *p1, struct DiskPartition *p2)
+#define HDLEN (sizeof(HDSTR)-1) /* Length of "\Device\Harddisk" */
+int
+SameDisk(struct DiskPartition64 *p1, struct DiskPartition64 *p2)
{
#define RES_LEN 256
char res[RES_LEN];
int d1, d2;
- static int dowarn=1;
-
- if (!QueryDosDevice(p1->devName, res, RES_LEN-1))
+ static int dowarn = 1;
+
+ if (!QueryDosDevice(p1->devName, res, RES_LEN - 1))
return 1;
if (strncmp(res, HDSTR, HDLEN)) {
if (dowarn) {
}
d1 = atoi(&res[HDLEN]);
- if (!QueryDosDevice(p2->devName, res, RES_LEN-1))
+ if (!QueryDosDevice(p2->devName, res, RES_LEN - 1))
return 1;
if (strncmp(res, HDSTR, HDLEN)) {
if (dowarn) {
return 1;
}
d2 = atoi(&res[HDLEN]);
-
+
return d1 == d2;
}
#else
/* This assumes that two partitions with the same device number divided by
* PartsPerDisk are on the same disk.
*/
-void SalvageFileSysParallel(struct DiskPartition *partP)
+void
+SalvageFileSysParallel(struct DiskPartition64 *partP)
{
struct job {
- struct DiskPartition *partP;
- int pid; /* Pid for this job */
- int jobnumb; /* Log file job number */
- struct job *nextjob; /* Next partition on disk to salvage */
+ struct DiskPartition64 *partP;
+ int pid; /* Pid for this job */
+ int jobnumb; /* Log file job number */
+ struct job *nextjob; /* Next partition on disk to salvage */
};
- static struct job *jobs[MAXPARALLEL] = {0}; /* Need to zero this */
+ static struct job *jobs[MAXPARALLEL] = { 0 }; /* Need to zero this */
struct job *thisjob = 0;
static int numjobs = 0;
static int jobcount = 0;
int i, j, pid;
if (partP) {
- /* We have a partition to salvage. Copy it into thisjob */
- thisjob = (struct job *) malloc(sizeof(struct job));
- if (!thisjob) {
- Log("Can't salvage '%s'. Not enough memory\n", partP->name);
- return;
- }
- memset(thisjob, 0, sizeof(struct job));
- thisjob->partP = partP;
- thisjob->jobnumb = jobcount;
- jobcount++;
- }
- else if (jobcount == 0) {
- /* We are asking to wait for all jobs (partp == 0), yet we never
- * started any.
- */
- Log("No file system partitions named %s* found; not salvaged\n",
- VICE_PARTITION_PREFIX);
- return;
+ /* We have a partition to salvage. Copy it into thisjob */
+ thisjob = (struct job *)malloc(sizeof(struct job));
+ if (!thisjob) {
+ Log("Can't salvage '%s'. Not enough memory\n", partP->name);
+ return;
+ }
+ memset(thisjob, 0, sizeof(struct job));
+ thisjob->partP = partP;
+ thisjob->jobnumb = jobcount;
+ jobcount++;
+ } else if (jobcount == 0) {
+ /* We are asking to wait for all jobs (partp == 0), yet we never
+ * started any.
+ */
+ Log("No file system partitions named %s* found; not salvaged\n",
+ VICE_PARTITION_PREFIX);
+ return;
}
if (debug || Parallel == 1) {
if (thisjob) {
- SalvageFileSys(thisjob->partP, 0);
- free(thisjob);
+ SalvageFileSys(thisjob->partP, 0);
+ free(thisjob);
}
return;
}
if (thisjob) {
- /* Check to see if thisjob is for a disk that we are already
- * salvaging. If it is, link it in as the next job to do. The
- * jobs array has 1 entry per disk being salvages. numjobs is
- * the total number of disks currently being salvaged. In
- * order to keep thejobs array compact, when a disk is
- * completed, the hightest element in the jobs array is moved
- * down to now open slot.
- */
- for (j=0; j<numjobs; j++) {
- if (SameDisk(jobs[j]->partP, thisjob->partP)) {
- /* On same disk, add it to this list and return */
- thisjob->nextjob = jobs[j]->nextjob;
- jobs[j]->nextjob = thisjob;
- thisjob = 0;
- break;
- }
- }
+ /* Check to see if thisjob is for a disk that we are already
+ * salvaging. If it is, link it in as the next job to do. The
+ * jobs array has 1 entry per disk being salvages. numjobs is
+ * the total number of disks currently being salvaged. In
+ * order to keep thejobs array compact, when a disk is
+ * completed, the hightest element in the jobs array is moved
+ * down to now open slot.
+ */
+ for (j = 0; j < numjobs; j++) {
+ if (SameDisk(jobs[j]->partP, thisjob->partP)) {
+ /* On same disk, add it to this list and return */
+ thisjob->nextjob = jobs[j]->nextjob;
+ jobs[j]->nextjob = thisjob;
+ thisjob = 0;
+ break;
+ }
+ }
}
/* Loop until we start thisjob or until all existing jobs are finished */
- while ( thisjob || (!partP && (numjobs > 0)) ) {
- startjob = -1; /* No new job to start */
-
- if ( (numjobs >= Parallel) || (!partP && (numjobs > 0)) ) {
- /* Either the max jobs are running or we have to wait for all
- * the jobs to finish. In either case, we wait for at least one
- * job to finish. When it's done, clean up after it.
- */
- pid = wait(&wstatus);
- assert(pid != -1);
- for (j=0; j<numjobs; j++) { /* Find which job it is */
- if (pid == jobs[j]->pid) break;
- }
- assert(j < numjobs);
- if (WCOREDUMP(wstatus)) { /* Say if the job core dumped */
- Log("Salvage of %s core dumped!\n", jobs[j]->partP->name);
- }
-
- numjobs--; /* job no longer running */
- oldjob = jobs[j]; /* remember */
- jobs[j] = jobs[j]->nextjob; /* Step to next part on same disk */
- free(oldjob); /* free the old job */
-
- /* If there is another partition on the disk to salvage, then
- * say we will start it (startjob). If not, then put thisjob there
- * and say we will start it.
- */
- if (jobs[j]) { /* Another partitions to salvage */
- startjob = j; /* Will start it */
- } else { /* There is not another partition to salvage */
- if (thisjob) {
- jobs[j] = thisjob; /* Add thisjob */
+ while (thisjob || (!partP && (numjobs > 0))) {
+ startjob = -1; /* No new job to start */
+
+ if ((numjobs >= Parallel) || (!partP && (numjobs > 0))) {
+ /* Either the max jobs are running or we have to wait for all
+ * the jobs to finish. In either case, we wait for at least one
+ * job to finish. When it's done, clean up after it.
+ */
+ pid = wait(&wstatus);
+ assert(pid != -1);
+ for (j = 0; j < numjobs; j++) { /* Find which job it is */
+ if (pid == jobs[j]->pid)
+ break;
+ }
+ assert(j < numjobs);
+ if (WCOREDUMP(wstatus)) { /* Say if the job core dumped */
+ Log("Salvage of %s core dumped!\n", jobs[j]->partP->name);
+ }
+
+ numjobs--; /* job no longer running */
+ oldjob = jobs[j]; /* remember */
+ jobs[j] = jobs[j]->nextjob; /* Step to next part on same disk */
+ free(oldjob); /* free the old job */
+
+ /* If there is another partition on the disk to salvage, then
+ * say we will start it (startjob). If not, then put thisjob there
+ * and say we will start it.
+ */
+ if (jobs[j]) { /* Another partitions to salvage */
+ startjob = j; /* Will start it */
+ } else { /* There is not another partition to salvage */
+ if (thisjob) {
+ jobs[j] = thisjob; /* Add thisjob */
+ thisjob = 0;
+ startjob = j; /* Will start it */
+ } else {
+ jobs[j] = jobs[numjobs]; /* Move last job up to this slot */
+ startjob = -1; /* Don't start it - already running */
+ }
+ }
+ } else {
+ /* We don't have to wait for a job to complete */
+ if (thisjob) {
+ jobs[numjobs] = thisjob; /* Add this job */
thisjob = 0;
- startjob = j; /* Will start it */
- } else {
- jobs[j] = jobs[numjobs]; /* Move last job up to this slot */
- startjob = -1; /* Don't start it - already running */
- }
- }
- } else {
- /* We don't have to wait for a job to complete */
- if (thisjob) {
- jobs[numjobs] = thisjob; /* Add this job */
- thisjob = 0;
- startjob = numjobs; /* Will start it */
- }
- }
+ startjob = numjobs; /* Will start it */
+ }
+ }
- /* Start up a new salvage job on a partition in job slot "startjob" */
- if (startjob != -1) {
- if (!Showmode)
- Log("Starting salvage of file system partition %s\n",
- jobs[startjob]->partP->name);
+ /* Start up a new salvage job on a partition in job slot "startjob" */
+ if (startjob != -1) {
+ if (!Showmode)
+ Log("Starting salvage of file system partition %s\n",
+ jobs[startjob]->partP->name);
#ifdef AFS_NT40_ENV
- /* For NT, we not only fork, but re-exec the salvager. Pass in the
- * commands and pass the child job number via the data path.
- */
- pid = nt_SalvagePartition(jobs[startjob]->partP->name,
+ /* For NT, we not only fork, but re-exec the salvager. Pass in the
+ * commands and pass the child job number via the data path.
+ */
+ pid =
+ nt_SalvagePartition(jobs[startjob]->partP->name,
jobs[startjob]->jobnumb);
- jobs[startjob]->pid = pid;
- numjobs++;
+ jobs[startjob]->pid = pid;
+ numjobs++;
#else
- pid = Fork();
- if (pid) {
- jobs[startjob]->pid = pid;
- numjobs++;
- } else {
- int fd;
-
- ShowLog = 0;
- for (fd =0; fd < 16; fd++) close(fd);
- open("/", 0); dup2(0, 1); dup2(0, 2);
+ pid = Fork();
+ if (pid) {
+ jobs[startjob]->pid = pid;
+ numjobs++;
+ } else {
+ int fd;
+
+ ShowLog = 0;
+ for (fd = 0; fd < 16; fd++)
+ close(fd);
+ open("/", 0);
+ dup2(0, 1);
+ dup2(0, 2);
#ifndef AFS_NT40_ENV
- if ( useSyslog ) {
- openlog(NULL, LOG_PID, useSyslogFacility);
- } else
+ if (useSyslog) {
+ openlog("salvager", LOG_PID, useSyslogFacility);
+ } else
#endif
- {
- sprintf(logFileName, "%s.%d", AFSDIR_SERVER_SLVGLOG_FILEPATH, jobs[startjob]->jobnumb);
- logFile = fopen(logFileName, "w");
- }
- if (!logFile) logFile = stdout;
+ {
+ (void)afs_snprintf(logFileName, sizeof logFileName,
+ "%s.%d",
+ AFSDIR_SERVER_SLVGLOG_FILEPATH,
+ jobs[startjob]->jobnumb);
+ logFile = afs_fopen(logFileName, "w");
+ }
+ if (!logFile)
+ logFile = stdout;
- SalvageFileSys1(jobs[startjob]->partP, 0);
- Exit(0);
- }
+ SalvageFileSys1(jobs[startjob]->partP, 0);
+ Exit(0);
+ }
#endif
- }
- } /* while ( thisjob || (!partP && numjobs > 0) ) */
+ }
+ } /* while ( thisjob || (!partP && numjobs > 0) ) */
/* If waited for all jobs to complete, now collect log files and return */
#ifndef AFS_NT40_ENV
- if ( ! useSyslog ) /* if syslogging - no need to collect */
-#endif
- if (!partP) {
- for (i=0; i<jobcount; i++) {
- sprintf(logFileName, "%s.%d", AFSDIR_SERVER_SLVGLOG_FILEPATH, i);
- if (passLog = fopen(logFileName, "r")) {
- while(fgets(buf, sizeof(buf), passLog)) {
- fputs(buf, logFile);
- }
- fclose(passLog);
- }
- (void)unlink(logFileName);
- }
- fflush(logFile);
- }
- return;
+ if (!useSyslog) /* if syslogging - no need to collect */
+#endif
+ if (!partP) {
+ for (i = 0; i < jobcount; i++) {
+ (void)afs_snprintf(logFileName, sizeof logFileName, "%s.%d",
+ AFSDIR_SERVER_SLVGLOG_FILEPATH, i);
+ if ((passLog = afs_fopen(logFileName, "r"))) {
+ while (fgets(buf, sizeof(buf), passLog)) {
+ fputs(buf, logFile);
+ }
+ fclose(passLog);
+ }
+ (void)unlink(logFileName);
+ }
+ fflush(logFile);
+ }
+ return;
}
-void SalvageFileSys(struct DiskPartition *partP, VolumeId singleVolumeNumber)
+void
+SalvageFileSys(struct DiskPartition64 *partP, VolumeId singleVolumeNumber)
{
if (!canfork || debug || Fork() == 0) {
SalvageFileSys1(partP, singleVolumeNumber);
ShowLog = 0;
Exit(0);
}
- }
- else
+ } else
Wait("SalvageFileSys");
}
-char *get_DevName(pbuffer, wpath)
-char *wpath, *pbuffer;
+char *
+get_DevName(char *pbuffer, char *wpath)
{
char pbuf[128], *ptr;
strcpy(pbuf, pbuffer);
*ptr = '\0';
strcpy(wpath, pbuf);
} else
- return (char *)0;
- ptr = (char *)strrchr(pbuffer, '/');
+ return NULL;
+ ptr = (char *)strrchr(pbuffer, '/');
if (ptr) {
- strcpy(pbuffer, ptr+1);
+ strcpy(pbuffer, ptr + 1);
return pbuffer;
} else
- return (char *)0;
+ return NULL;
}
-void SalvageFileSys1(struct DiskPartition *partP, VolumeId singleVolumeNumber)
+void
+SalvageFileSys1(struct DiskPartition64 *partP, VolumeId singleVolumeNumber)
{
char *name, *tdir;
- char inodeListPath[50];
+ char inodeListPath[256];
+ FILE *inodeFile = NULL;
static char tmpDevName[100];
static char wpath[100];
struct VolumeSummary *vsp, *esp;
- int i,j;
+ int i, j;
+ int code;
+ int tries = 0;
+
+ retry:
+ tries++;
+ if (inodeFile) {
+ fclose(inodeFile);
+ inodeFile = NULL;
+ }
+ if (tries > VOL_MAX_CHECKOUT_RETRIES) {
+ Abort("Raced too many times with fileserver restarts while trying to "
+ "checkout/lock volumes; Aborted\n");
+ }
+#ifdef AFS_DEMAND_ATTACH_FS
+ if (tries > 1) {
+ /* unlock all previous volume locks, since we're about to lock them
+ * again */
+ VLockFileReinit(&partP->volLockFile);
+ }
+#endif /* AFS_DEMAND_ATTACH_FS */
fileSysPartition = partP;
fileSysDevice = fileSysPartition->device;
#ifdef AFS_NT40_ENV
/* Opendir can fail on "C:" but not on "C:\" if C is empty! */
- (void) sprintf(fileSysPath, "%s\\", fileSysPathName);
+ (void)sprintf(fileSysPath, "%s\\", fileSysPathName);
name = partP->devName;
#else
fileSysPath = fileSysPathName;
filesysfulldev = wpath;
#endif
- VLockPartition(partP->name);
- if (singleVolumeNumber || ForceSalvage)
+ if (singleVolumeNumber) {
+#ifndef AFS_DEMAND_ATTACH_FS
+ /* only non-DAFS locks the partition when salvaging a single volume;
+ * DAFS will lock the individual volumes in the VG */
+ VLockPartition(partP->name);
+#endif /* !AFS_DEMAND_ATTACH_FS */
+
ForceSalvage = 1;
- else
- ForceSalvage = UseTheForceLuke(fileSysPath);
- if (singleVolumeNumber) {
- if (!VConnectFS()) {
+ /* salvageserver already setup fssync conn for us */
+ if ((programType != salvageServer) && !VConnectFS()) {
Abort("Couldn't connect to file server\n");
}
- AskOffline(singleVolumeNumber);
- }
- else {
- if (!Showmode) Log("SALVAGING FILE SYSTEM PARTITION %s (device=%s%s)\n", partP->name, name, (Testing? "(READONLY mode)":""));
+
+ AskOffline(singleVolumeNumber, partP->name);
+#ifdef AFS_DEMAND_ATTACH_FS
+ if (LockVolume(singleVolumeNumber)) {
+ goto retry;
+ }
+#endif /* AFS_DEMAND_ATTACH_FS */
+
+ } else {
+ VLockPartition(partP->name);
+ if (ForceSalvage) {
+ ForceSalvage = 1;
+ } else {
+ ForceSalvage = UseTheForceLuke(fileSysPath);
+ }
+ if (!Showmode)
+ Log("SALVAGING FILE SYSTEM PARTITION %s (device=%s%s)\n",
+ partP->name, name, (Testing ? "(READONLY mode)" : ""));
if (ForceSalvage)
Log("***Forced salvage of all volumes on this partition***\n");
}
struct dirent *dp;
assert((dirp = opendir(fileSysPath)) != NULL);
- while (dp = readdir(dirp)) {
- if (!strncmp(dp->d_name, "salvage.inodes.", 15) ||
- !strncmp(dp->d_name, "salvage.temp.", 13)) {
+ while ((dp = readdir(dirp))) {
+ if (!strncmp(dp->d_name, "salvage.inodes.", 15)
+ || !strncmp(dp->d_name, "salvage.temp.", 13)) {
char npath[1024];
Log("Removing old salvager temp files %s\n", dp->d_name);
strcpy(npath, fileSysPath);
}
tdir = (tmpdir ? tmpdir : fileSysPath);
#ifdef AFS_NT40_ENV
- (void) _putenv("TMP="); /* If "TMP" is set, then that overrides tdir. */
- (void) strcpy(inodeListPath, _tempnam(tdir, "salvage.inodes."));
+ (void)_putenv("TMP="); /* If "TMP" is set, then that overrides tdir. */
+ (void)strncpy(inodeListPath, _tempnam(tdir, "salvage.inodes."), 255);
#else
- sprintf(inodeListPath, "%s/salvage.inodes.%s.%d", tdir, name, getpid());
+ snprintf(inodeListPath, 255, "%s/salvage.inodes.%s.%d", tdir, name,
+ getpid());
#endif
- if (GetInodeSummary(inodeListPath, singleVolumeNumber) < 0) {
- unlink(inodeListPath);
- return;
+
+ inodeFile = fopen(inodeListPath, "w+b");
+ if (!inodeFile) {
+ Abort("Error %d when creating inode description file %s; not salvaged\n", errno, inodeListPath);
}
#ifdef AFS_NT40_ENV
/* Using nt_unlink here since we're really using the delete on close
* mean to unlink the file at that point. Those places have been
* modified to actually do that so that the NT crt can be used there.
*/
- inodeFd = _open_osfhandle((long)nt_open(inodeListPath, O_RDWR, 0), O_RDWR);
- nt_unlink(inodeListPath); /* NT's crt unlink won't if file is open. */
+ code = nt_unlink(inodeListPath);
#else
- inodeFd = open(inodeListPath, O_RDONLY);
- unlink(inodeListPath);
+ code = unlink(inodeListPath);
#endif
+ if (code < 0) {
+ Log("Error %d when trying to unlink %s\n", errno, inodeListPath);
+ }
+
+ if (GetInodeSummary(inodeFile, singleVolumeNumber) < 0) {
+ fclose(inodeFile);
+ return;
+ }
+ inodeFd = fileno(inodeFile);
if (inodeFd == -1)
- Abort("Temporary file %s is missing...\n",
- inodeListPath);
+ Abort("Temporary file %s is missing...\n", inodeListPath);
+ afs_lseek(inodeFd, 0L, SEEK_SET);
if (ListInodeOption) {
PrintInodeList();
return;
}
/* enumerate volumes in the partition.
- figure out sets of read-only + rw volumes.
- salvage each set, read-only volumes first, then read-write.
- Fix up inodes on last volume in set (whether it is read-write
- or read-only).
- */
- GetVolumeSummary(singleVolumeNumber);
-
- for (i = j = 0,vsp = volumeSummaryp,esp = vsp+nVolumes; i < nVolumesInInodeFile; i = j) {
+ * figure out sets of read-only + rw volumes.
+ * salvage each set, read-only volumes first, then read-write.
+ * Fix up inodes on last volume in set (whether it is read-write
+ * or read-only).
+ */
+ if (GetVolumeSummary(singleVolumeNumber)) {
+ goto retry;
+ }
+
+ for (i = j = 0, vsp = volumeSummaryp, esp = vsp + nVolumes;
+ i < nVolumesInInodeFile; i = j) {
VolumeId rwvid = inodeSummary[i].RWvolumeId;
- for (j=i; j < nVolumesInInodeFile
- && inodeSummary[j].RWvolumeId == rwvid; j++) {
+ for (j = i;
+ j < nVolumesInInodeFile && inodeSummary[j].RWvolumeId == rwvid;
+ j++) {
VolumeId vid = inodeSummary[j].volumeId;
struct VolumeSummary *tsp;
/* Scan volume list (from partition root directory) looking for the
- current rw volume number in the volume list from the inode scan.
- If there is one here that is not in the inode volume list,
- delete it now. */
- for ( ; vsp<esp && (vsp->header.parent < rwvid); vsp++) {
+ * current rw volume number in the volume list from the inode scan.
+ * If there is one here that is not in the inode volume list,
+ * delete it now. */
+ for (; vsp < esp && (vsp->header.parent < rwvid); vsp++) {
if (vsp->fileName)
DeleteExtraVolumeHeaderFile(vsp);
}
/* Now match up the volume summary info from the root directory with the
- entry in the volume list obtained from scanning inodes */
+ * entry in the volume list obtained from scanning inodes */
inodeSummary[j].volSummary = NULL;
- for (tsp = vsp; tsp<esp && (tsp->header.parent == rwvid); tsp++) {
+ for (tsp = vsp; tsp < esp && (tsp->header.parent == rwvid); tsp++) {
if (tsp->header.id == vid) {
inodeSummary[j].volSummary = tsp;
tsp->fileName = 0;
break;
}
}
- }
+ }
/* Salvage the group of volumes (several read-only + 1 read/write)
* starting with the current read-only volume we're looking at.
*/
- SalvageVolumeGroup(&inodeSummary[i], j-i);
+ SalvageVolumeGroup(&inodeSummary[i], j - i);
}
/* Delete any additional volumes that were listed in the partition but which didn't have any corresponding inodes */
- for ( ; vsp<esp; vsp++) {
- if (vsp->fileName)
+ for (; vsp < esp; vsp++) {
+ if (vsp->fileName)
DeleteExtraVolumeHeaderFile(vsp);
}
- if (!singleVolumeNumber) /* Remove the FORCESALVAGE file */
- RemoveTheForce(fileSysPath);
+ if (!singleVolumeNumber) /* Remove the FORCESALVAGE file */
+ RemoveTheForce(fileSysPath);
if (!Testing && singleVolumeNumber) {
- AskOnline(singleVolumeNumber, fileSysPartition->name);
+#ifdef AFS_DEMAND_ATTACH_FS
+ /* unlock vol headers so the fs can attach them when we AskOnline */
+ VLockFileReinit(&fileSysPartition->volLockFile);
+#endif /* AFS_DEMAND_ATTACH_FS */
- /* Step through the volumeSummary list and set all volumes on-line.
- * The volumes were taken off-line in GetVolumeSummary.
- */
- for (j=0; j<nVolumes; j++) {
- AskOnline(volumeSummaryp[j].header.id, fileSysPartition->name);
- }
- }
- else {
- if (!Showmode)
- Log("SALVAGING OF PARTITION %s%s COMPLETED\n",
- fileSysPartition->name, (Testing ? " (READONLY mode)":""));
+ AskOnline(singleVolumeNumber, fileSysPartition->name);
+
+ /* Step through the volumeSummary list and set all volumes on-line.
+ * The volumes were taken off-line in GetVolumeSummary.
+ */
+ for (j = 0; j < nVolumes; j++) {
+ AskOnline(volumeSummaryp[j].header.id, fileSysPartition->name);
+ }
+ } else {
+ if (!Showmode)
+ Log("SALVAGING OF PARTITION %s%s COMPLETED\n",
+ fileSysPartition->name, (Testing ? " (READONLY mode)" : ""));
}
- close(inodeFd); /* SalvageVolumeGroup was the last which needed it. */
+ fclose(inodeFile); /* SalvageVolumeGroup was the last which needed it. */
}
-void DeleteExtraVolumeHeaderFile(register struct VolumeSummary *vsp)
+void
+DeleteExtraVolumeHeaderFile(register struct VolumeSummary *vsp)
{
- if (!Showmode) Log("The volume header file %s is not associated with any actual data (%sdeleted)\n",
- vsp->fileName, (Testing? "would have been ":""));
- if (!Testing)
- unlink(vsp->fileName);
+ char path[64];
+ sprintf(path, "%s/%s", fileSysPath, vsp->fileName);
+
+ if (!Showmode)
+ Log("The volume header file %s is not associated with any actual data (%sdeleted)\n", path, (Testing ? "would have been " : ""));
+ if (!Testing) {
+ afs_int32 code;
+ code = VDestroyVolumeDiskHeader(fileSysPartition, vsp->header.id, vsp->header.parent);
+ if (code) {
+ Log("Error %ld destroying volume disk header for volume %lu\n",
+ afs_printable_int32_ld(code),
+ afs_printable_uint32_lu(vsp->header.id));
+ }
+
+ /* make sure we actually delete the fileName file; ENOENT
+ * is fine, since VDestroyVolumeDiskHeader probably already
+ * unlinked it */
+ if (unlink(path) && errno != ENOENT) {
+ Log("Unable to unlink %s (errno = %d)\n", path, errno);
+ }
+ }
vsp->fileName = 0;
}
-CompareInodes(_p1,_p2)
- const void *_p1,*_p2;
+int
+CompareInodes(const void *_p1, const void *_p2)
{
register const struct ViceInodeInfo *p1 = _p1;
register const struct ViceInodeInfo *p2 = _p2;
- if (p1->u.vnode.vnodeNumber == INODESPECIAL ||
- p2->u.vnode.vnodeNumber == INODESPECIAL) {
+ if (p1->u.vnode.vnodeNumber == INODESPECIAL
+ || p2->u.vnode.vnodeNumber == INODESPECIAL) {
VolumeId p1rwid, p2rwid;
- p1rwid = (p1->u.vnode.vnodeNumber==INODESPECIAL
- ? p1->u.special.parentId : p1->u.vnode.volumeId);
- p2rwid = (p2->u.vnode.vnodeNumber==INODESPECIAL
- ? p2->u.special.parentId : p2->u.vnode.volumeId);
+ p1rwid =
+ (p1->u.vnode.vnodeNumber ==
+ INODESPECIAL ? p1->u.special.parentId : p1->u.vnode.volumeId);
+ p2rwid =
+ (p2->u.vnode.vnodeNumber ==
+ INODESPECIAL ? p2->u.special.parentId : p2->u.vnode.volumeId);
if (p1rwid < p2rwid)
return -1;
if (p1rwid > p2rwid)
if (p1->u.vnode.vnodeNumber == INODESPECIAL
&& p2->u.vnode.vnodeNumber == INODESPECIAL) {
if (p1->u.vnode.volumeId == p2->u.vnode.volumeId)
- return (p1->u.special.type < p2->u.special.type? -1: 1);
+ return (p1->u.special.type < p2->u.special.type ? -1 : 1);
if (p1->u.vnode.volumeId == p1rwid)
return -1;
if (p2->u.vnode.volumeId == p2rwid)
return 1;
- return (p1->u.vnode.volumeId < p2->u.vnode.volumeId? -1: 1);
+ return (p1->u.vnode.volumeId < p2->u.vnode.volumeId ? -1 : 1);
}
if (p1->u.vnode.vnodeNumber != INODESPECIAL)
- return (p2->u.vnode.volumeId == p2rwid? 1: -1);
- return (p1->u.vnode.volumeId == p1rwid? -1: 1);
+ return (p2->u.vnode.volumeId == p2rwid ? 1 : -1);
+ return (p1->u.vnode.volumeId == p1rwid ? -1 : 1);
}
- if (p1->u.vnode.volumeId<p2->u.vnode.volumeId)
+ if (p1->u.vnode.volumeId < p2->u.vnode.volumeId)
return -1;
- if (p1->u.vnode.volumeId>p2->u.vnode.volumeId)
+ if (p1->u.vnode.volumeId > p2->u.vnode.volumeId)
return 1;
if (p1->u.vnode.vnodeNumber < p2->u.vnode.vnodeNumber)
return -1;
if (p1->u.vnode.vnodeNumber > p2->u.vnode.vnodeNumber)
return 1;
/* The following tests are reversed, so that the most desirable
- of several similar inodes comes first */
+ * of several similar inodes comes first */
if (p1->u.vnode.vnodeUniquifier > p2->u.vnode.vnodeUniquifier) {
#ifdef AFS_3DISPARES
- if (p1->u.vnode.vnodeUniquifier > 3775414 /* 90% of 4.2M */ &&
- p2->u.vnode.vnodeUniquifier < 419490 /* 10% of 4.2M */)
+ if (p1->u.vnode.vnodeUniquifier > 3775414 /* 90% of 4.2M */ &&
+ p2->u.vnode.vnodeUniquifier < 419490 /* 10% of 4.2M */ )
return 1;
#endif
#ifdef AFS_SGI_EXMAG
- if (p1->u.vnode.vnodeUniquifier > 15099494 /* 90% of 16M */ &&
- p2->u.vnode.vnodeUniquifier < 1677721 /* 10% of 16M */)
+ if (p1->u.vnode.vnodeUniquifier > 15099494 /* 90% of 16M */ &&
+ p2->u.vnode.vnodeUniquifier < 1677721 /* 10% of 16M */ )
return 1;
#endif
return -1;
}
if (p1->u.vnode.vnodeUniquifier < p2->u.vnode.vnodeUniquifier) {
#ifdef AFS_3DISPARES
- if (p2->u.vnode.vnodeUniquifier > 3775414 /* 90% of 4.2M */ &&
- p1->u.vnode.vnodeUniquifier < 419490 /* 10% of 4.2M */)
+ if (p2->u.vnode.vnodeUniquifier > 3775414 /* 90% of 4.2M */ &&
+ p1->u.vnode.vnodeUniquifier < 419490 /* 10% of 4.2M */ )
return -1;
#endif
#ifdef AFS_SGI_EXMAG
- if (p2->u.vnode.vnodeUniquifier > 15099494 /* 90% of 16M */ &&
- p1->u.vnode.vnodeUniquifier < 1677721 /* 10% of 16M */)
+ if (p2->u.vnode.vnodeUniquifier > 15099494 /* 90% of 16M */ &&
+ p1->u.vnode.vnodeUniquifier < 1677721 /* 10% of 16M */ )
return 1;
#endif
return 1;
}
if (p1->u.vnode.inodeDataVersion > p2->u.vnode.inodeDataVersion) {
#ifdef AFS_3DISPARES
- if (p1->u.vnode.inodeDataVersion > 1887437 /* 90% of 2.1M */ &&
- p2->u.vnode.inodeDataVersion < 209716 /* 10% of 2.1M */)
+ if (p1->u.vnode.inodeDataVersion > 1887437 /* 90% of 2.1M */ &&
+ p2->u.vnode.inodeDataVersion < 209716 /* 10% of 2.1M */ )
return 1;
#endif
#ifdef AFS_SGI_EXMAG
- if (p1->u.vnode.inodeDataVersion > 15099494 /* 90% of 16M */ &&
- p2->u.vnode.inodeDataVersion < 1677721 /* 10% of 16M */)
+ if (p1->u.vnode.inodeDataVersion > 15099494 /* 90% of 16M */ &&
+ p2->u.vnode.inodeDataVersion < 1677721 /* 10% of 16M */ )
return 1;
#endif
return -1;
}
if (p1->u.vnode.inodeDataVersion < p2->u.vnode.inodeDataVersion) {
#ifdef AFS_3DISPARES
- if (p2->u.vnode.inodeDataVersion > 1887437 /* 90% of 2.1M */ &&
- p1->u.vnode.inodeDataVersion < 209716 /* 10% of 2.1M */)
+ if (p2->u.vnode.inodeDataVersion > 1887437 /* 90% of 2.1M */ &&
+ p1->u.vnode.inodeDataVersion < 209716 /* 10% of 2.1M */ )
return -1;
#endif
#ifdef AFS_SGI_EXMAG
- if (p2->u.vnode.inodeDataVersion > 15099494 /* 90% of 16M */ &&
- p1->u.vnode.inodeDataVersion < 1677721 /* 10% of 16M */)
+ if (p2->u.vnode.inodeDataVersion > 15099494 /* 90% of 16M */ &&
+ p1->u.vnode.inodeDataVersion < 1677721 /* 10% of 16M */ )
return 1;
#endif
return 1;
return 0;
}
-void CountVolumeInodes(register struct ViceInodeInfo *ip, int maxInodes,
- register struct InodeSummary * summary)
+void
+CountVolumeInodes(register struct ViceInodeInfo *ip, int maxInodes,
+ register struct InodeSummary *summary)
{
- int volume = ip->u.vnode.volumeId;
- int rwvolume = volume;
- register n, nSpecial;
+ VolumeId volume = ip->u.vnode.volumeId;
+ VolumeId rwvolume = volume;
+ register int n, nSpecial;
register Unique maxunique;
n = nSpecial = 0;
maxunique = 0;
nSpecial++;
rwvolume = ip->u.special.parentId;
/* This isn't quite right, as there could (in error) be different
- parent inodes in different special vnodes */
- }
- else {
+ * parent inodes in different special vnodes */
+ } else {
if (maxunique < ip->u.vnode.vnodeUniquifier)
maxunique = ip->u.vnode.vnodeUniquifier;
}
}
summary->volumeId = volume;
summary->RWvolumeId = rwvolume;
- summary->nInodes =n;
+ summary->nInodes = n;
summary->nSpecialInodes = nSpecial;
summary->maxUniquifier = maxunique;
}
-int OnlyOneVolume(inodeinfo, singleVolumeNumber)
- struct ViceInodeInfo *inodeinfo;
- VolumeId singleVolumeNumber;
+int
+OnlyOneVolume(struct ViceInodeInfo *inodeinfo, afs_uint32 singleVolumeNumber, void *rock)
{
if (inodeinfo->u.vnode.vnodeNumber == INODESPECIAL)
return (inodeinfo->u.special.parentId == singleVolumeNumber);
* unlink the file and abort. For lessor errors, return -1. The file will
* be unlinked by the caller.
*/
-int GetInodeSummary(char *path, VolumeId singleVolumeNumber)
+int
+GetInodeSummary(FILE *inodeFile, VolumeId singleVolumeNumber)
{
- struct stat status;
- int summaryFd, forceSal, err;
+ struct afs_stat status;
+ int forceSal, err;
+ int code;
struct ViceInodeInfo *ip;
struct InodeSummary summary;
char summaryFileName[50];
char *tdir;
/* This file used to come from vfsck; cobble it up ourselves now... */
- if ((err = ListViceInodes(dev, fileSysPath, path, singleVolumeNumber?OnlyOneVolume:0, singleVolumeNumber, &forceSal, forceR, wpath)) < 0) {
- if (err == -2) {
- Log("*** I/O error %d when writing a tmp inode file %s; Not salvaged %s ***\nIncrease space on partition or use '-tmpdir'\n",
- errno, path, dev);
+ if ((err =
+ ListViceInodes(dev, fileSysPath, inodeFile,
+ singleVolumeNumber ? OnlyOneVolume : 0,
+ singleVolumeNumber, &forceSal, forceR, wpath, NULL)) < 0) {
+ if (err == -2) {
+ Log("*** I/O error %d when writing a tmp inode file; Not salvaged %s ***\nIncrease space on partition or use '-tmpdir'\n", errno, dev);
return -1;
}
- unlink(path);
Abort("Unable to get inodes for \"%s\"; not salvaged\n", dev);
}
if (forceSal && !ForceSalvage) {
Log("***Forced salvage of all volumes on this partition***\n");
ForceSalvage = 1;
}
- inodeFd = open(path, O_RDWR);
- if (inodeFd == -1 || fstat(inodeFd, &status) == -1) {
- unlink(path);
+ fseek(inodeFile, 0L, SEEK_SET);
+ inodeFd = fileno(inodeFile);
+ if (inodeFd == -1 || afs_fstat(inodeFd, &status) == -1) {
Abort("No inode description file for \"%s\"; not salvaged\n", dev);
}
tdir = (tmpdir ? tmpdir : part);
#ifdef AFS_NT40_ENV
- (void) _putenv("TMP="); /* If "TMP" is set, then that overrides tdir. */
- (void) strcpy(summaryFileName, _tempnam(tdir, "salvage.temp"));
+ (void)_putenv("TMP="); /* If "TMP" is set, then that overrides tdir. */
+ (void)strcpy(summaryFileName, _tempnam(tdir, "salvage.temp"));
#else
- sprintf(summaryFileName, "%s/salvage.temp.%d", tdir, getpid());
+ (void)afs_snprintf(summaryFileName, sizeof summaryFileName,
+ "%s/salvage.temp.%d", tdir, getpid());
#endif
- summaryFile = fopen(summaryFileName, "a+");
+ summaryFile = afs_fopen(summaryFileName, "a+");
if (summaryFile == NULL) {
- close(inodeFd);
- unlink(path);
Abort("Unable to create inode summary file\n");
}
+
+#ifdef AFS_NT40_ENV
+ /* Using nt_unlink here since we're really using the delete on close
+ * semantics of unlink. In most places in the salvager, we really do
+ * mean to unlink the file at that point. Those places have been
+ * modified to actually do that so that the NT crt can be used there.
+ */
+ code = nt_unlink(summaryFileName);
+#else
+ code = unlink(summaryFileName);
+#endif
+ if (code < 0) {
+ Log("Error %d when trying to unlink %s\n", errno, summaryFileName);
+ }
+
if (!canfork || debug || Fork() == 0) {
- int nInodes;
- nInodes = status.st_size / sizeof(struct ViceInodeInfo);
+ int nInodes;
+ unsigned long st_size=(unsigned long) status.st_size;
+ nInodes = st_size / sizeof(struct ViceInodeInfo);
if (nInodes == 0) {
- fclose(summaryFile); close(inodeFd);
- unlink(summaryFileName);
- if (!singleVolumeNumber) /* Remove the FORCESALVAGE file */
- RemoveTheForce(fileSysPath);
+ fclose(summaryFile);
+ if (!singleVolumeNumber) /* Remove the FORCESALVAGE file */
+ RemoveTheForce(fileSysPath);
+ else {
+ struct VolumeSummary *vsp;
+ int i;
+
+ GetVolumeSummary(singleVolumeNumber);
+
+ for (i = 0, vsp = volumeSummaryp; i < nVolumes; i++) {
+ if (vsp->fileName)
+ DeleteExtraVolumeHeaderFile(vsp);
+ }
+ }
Log("%s vice inodes on %s; not salvaged\n",
- singleVolumeNumber? "No applicable": "No", dev);
+ singleVolumeNumber ? "No applicable" : "No", dev);
return -1;
}
- ip = (struct ViceInodeInfo *) malloc(status.st_size);
+ ip = (struct ViceInodeInfo *)malloc(nInodes*sizeof(struct ViceInodeInfo));
if (ip == NULL) {
- fclose(summaryFile); close(inodeFd);
- unlink(path);
- unlink(summaryFileName);
- Abort("Unable to allocate enough space to read inode table; %s not salvaged\n", dev);
- }
- if (read(inodeFd, ip, status.st_size) != status.st_size) {
- fclose(summaryFile); close(inodeFd);
- unlink(path);
- unlink(summaryFileName);
+ fclose(summaryFile);
+ Abort
+ ("Unable to allocate enough space to read inode table; %s not salvaged\n",
+ dev);
+ }
+ if (read(inodeFd, ip, st_size) != st_size) {
+ fclose(summaryFile);
Abort("Unable to read inode table; %s not salvaged\n", dev);
}
qsort(ip, nInodes, sizeof(struct ViceInodeInfo), CompareInodes);
- if (lseek(inodeFd, 0, SEEK_SET) == -1 ||
- write(inodeFd, ip, status.st_size) != status.st_size) {
- fclose(summaryFile); close(inodeFd);
- unlink(path);
- unlink(summaryFileName);
+ if (afs_lseek(inodeFd, 0, SEEK_SET) == -1
+ || write(inodeFd, ip, st_size) != st_size) {
+ fclose(summaryFile);
Abort("Unable to rewrite inode table; %s not salvaged\n", dev);
}
summary.index = 0;
while (nInodes) {
CountVolumeInodes(ip, nInodes, &summary);
- if (fwrite(&summary, sizeof (summary), 1, summaryFile) != 1) {
+ if (fwrite(&summary, sizeof(summary), 1, summaryFile) != 1) {
Log("Difficulty writing summary file (errno = %d); %s not salvaged\n", errno, dev);
- fclose(summaryFile); close(inodeFd);
+ fclose(summaryFile);
return -1;
}
summary.index += (summary.nInodes);
/* Following fflush is not fclose, because if it was debug mode would not work */
if (fflush(summaryFile) == EOF || fsync(fileno(summaryFile)) == -1) {
Log("Unable to write summary file (errno = %d); %s not salvaged\n", errno, dev);
- fclose(summaryFile); close(inodeFd);
+ fclose(summaryFile);
return -1;
}
if (canfork && !debug) {
ShowLog = 0;
Exit(0);
}
- }
- else {
+ } else {
if (Wait("Inode summary") == -1) {
- fclose(summaryFile); close(inodeFd);
- unlink(path);
- unlink(summaryFileName);
- Exit(1); /* salvage of this partition aborted */
+ fclose(summaryFile);
+ Exit(1); /* salvage of this partition aborted */
}
}
- assert(fstat(fileno(summaryFile), &status) != -1);
- if ( status.st_size != 0 ) {
+ assert(afs_fstat(fileno(summaryFile), &status) != -1);
+ if (status.st_size != 0) {
int ret;
- inodeSummary = (struct InodeSummary *) malloc(status.st_size);
+ unsigned long st_status=(unsigned long)status.st_size;
+ inodeSummary = (struct InodeSummary *)malloc(st_status);
assert(inodeSummary != NULL);
/* For GNU we need to do lseek to get the file pointer moved. */
- assert(lseek(fileno(summaryFile), 0, SEEK_SET) == 0);
- ret = read(fileno(summaryFile), inodeSummary, status.st_size);
- assert(ret == status.st_size);
+ assert(afs_lseek(fileno(summaryFile), 0, SEEK_SET) == 0);
+ ret = read(fileno(summaryFile), inodeSummary, st_status);
+ assert(ret == st_status);
}
- nVolumesInInodeFile = status.st_size / sizeof (struct InodeSummary);
+ nVolumesInInodeFile =(unsigned long)(status.st_size) / sizeof(struct InodeSummary);
+ Log("%d nVolumesInInodeFile %d \n",nVolumesInInodeFile,(unsigned long)(status.st_size));
fclose(summaryFile);
- close(inodeFd);
- unlink(summaryFileName);
return 0;
}
/* Comparison routine for volume sort.
This is setup so that a read-write volume comes immediately before
any read-only clones of that volume */
-CompareVolumes(_p1,_p2)
- const void *_p1,*_p2;
+int
+CompareVolumes(const void *_p1, const void *_p2)
{
register const struct VolumeSummary *p1 = _p1;
register const struct VolumeSummary *p2 = _p2;
if (p1->header.parent != p2->header.parent)
- return p1->header.parent < p2->header.parent? -1: 1;
- if (p1->header.id == p1->header.parent) /* p1 is rw volume */
+ return p1->header.parent < p2->header.parent ? -1 : 1;
+ if (p1->header.id == p1->header.parent) /* p1 is rw volume */
return -1;
- if (p2->header.id == p2->header.parent) /* p2 is rw volume */
+ if (p2->header.id == p2->header.parent) /* p2 is rw volume */
return 1;
- return p1->header.id < p2->header.id ? -1: 1; /* Both read-only */
+ return p1->header.id < p2->header.id ? -1 : 1; /* Both read-only */
}
-void GetVolumeSummary(VolumeId singleVolumeNumber)
-{
- DIR *dirp;
- afs_int32 nvols = 0;
- struct VolumeSummary *vsp, vs;
- struct VolumeDiskHeader diskHeader;
- struct dirent *dp;
-
- /* Get headers from volume directory */
- if (chdir(fileSysPath) == -1 || (dirp = opendir(".")) == NULL)
- Abort("Can't read directory %s; not salvaged\n", fileSysPath);
- if (!singleVolumeNumber) {
- while (dp = readdir(dirp)) {
- char *p = dp->d_name;
- p = strrchr(dp->d_name, '.');
- if (p != NULL && strcmp(p, VHDREXT) == 0) {
- int fd;
- if ((fd = open(dp->d_name, O_RDONLY)) != -1 &&
- read(fd, (char*)&diskHeader, sizeof (diskHeader))
- == sizeof (diskHeader) &&
- diskHeader.stamp.magic == VOLUMEHEADERMAGIC) {
- DiskToVolumeHeader(&vs.header, &diskHeader);
- nvols++;
+/**
+ * Gleans volumeSummary information by asking the fileserver
+ *
+ * @param[in] singleVolumeNumber the volume we're salvaging. 0 if we're
+ * salvaging a whole partition
+ *
+ * @return whether we obtained the volume summary information or not
+ * @retval 0 success; we obtained the volume summary information
+ * @retval -1 we raced with a fileserver restart; volume locks and checkout
+ * must be retried
+ * @retval 1 we did not get the volume summary information; either the
+ * fileserver responded with an error, or we are not supposed to
+ * ask the fileserver for the information (e.g. we are salvaging
+ * the entire partition or we are not the salvageserver)
+ *
+ * @note for non-DAFS, always returns 1
+ */
+static int
+AskVolumeSummary(VolumeId singleVolumeNumber)
+{
+ afs_int32 code = 1;
+#if defined(FSSYNC_BUILD_CLIENT) && defined(AFS_DEMAND_ATTACH_FS)
+ if (programType == salvageServer) {
+ if (singleVolumeNumber) {
+ FSSYNC_VGQry_response_t q_res;
+ SYNC_response res;
+ struct VolumeSummary *vsp;
+ int i;
+ struct VolumeDiskHeader diskHdr;
+
+ memset(&res, 0, sizeof(res));
+
+ code = FSYNC_VGCQuery(fileSysPartition->name, singleVolumeNumber, &q_res, &res);
+
+ /*
+ * We must wait for the partition to finish scanning before
+ * can continue, since we will not know if we got the entire
+ * VG membership unless the partition is fully scanned.
+ * We could, in theory, just scan the partition ourselves if
+ * the VG cache is not ready, but we would be doing the exact
+ * same scan the fileserver is doing; it will almost always
+ * be faster to wait for the fileserver. The only exceptions
+ * are if the partition does not take very long to scan, and
+ * in that case it's fast either way, so who cares?
+ */
+ if (code == SYNC_FAILED && res.hdr.reason == FSYNC_PART_SCANNING) {
+ Log("waiting for fileserver to finish scanning partition %s...\n",
+ fileSysPartition->name);
+
+ for (i = 1; code == SYNC_FAILED && res.hdr.reason == FSYNC_PART_SCANNING; i++) {
+ /* linearly ramp up from 1 to 10 seconds; nothing fancy,
+ * just so small partitions don't need to wait over 10
+ * seconds every time, and large partitions are generally
+ * polled only once every ten seconds. */
+ sleep((i > 10) ? (i = 10) : i);
+
+ code = FSYNC_VGCQuery(fileSysPartition->name, singleVolumeNumber, &q_res, &res);
}
- close(fd);
- }
- }
-#ifdef AFS_NT40_ENV
- closedir(dirp); dirp = opendir("."); /* No rewinddir for NT */
-#else
- rewinddir(dirp);
-#endif
- if (!nvols) nvols = 1;
- volumeSummaryp = (struct VolumeSummary *)malloc(nvols * sizeof(struct VolumeSummary));
- } else
- volumeSummaryp = (struct VolumeSummary *)malloc(20 * sizeof(struct VolumeSummary));
- assert(volumeSummaryp != NULL);
+ }
+
+ if (code == SYNC_FAILED && res.hdr.reason == FSYNC_UNKNOWN_VOLID) {
+ /* This can happen if there's no header for the volume
+ * we're salvaging, or no headers exist for the VG (if
+ * we're salvaging an RW). Act as if we got a response
+ * with no VG members. The headers may be created during
+ * salvaging, if there are inodes in this VG. */
+ code = 0;
+ memset(&q_res, 0, sizeof(q_res));
+ q_res.rw = singleVolumeNumber;
+ }
- nVolumes = 0;
- vsp = volumeSummaryp;
- while (dp = readdir(dirp)) {
- char *p = dp->d_name;
- p = strrchr(dp->d_name, '.');
- if (p != NULL && strcmp(p, VHDREXT) == 0) {
- int error = 0;
- int fd;
- if ((fd = open(dp->d_name, O_RDONLY)) == -1
- || read(fd, &diskHeader, sizeof (diskHeader))
- != sizeof (diskHeader)
- || diskHeader.stamp.magic != VOLUMEHEADERMAGIC) {
- error = 1;
+ if (code) {
+ Log("fileserver refused VGCQuery request for volume %lu on "
+ "partition %s, code %ld reason %ld\n",
+ afs_printable_uint32_lu(singleVolumeNumber),
+ fileSysPartition->name,
+ afs_printable_int32_ld(code),
+ afs_printable_int32_ld(res.hdr.reason));
+ goto done;
}
- close(fd);
- if (error) {
- if (!singleVolumeNumber) {
- if (!Showmode) Log("%s/%s is not a legitimate volume header file; %sdeleted\n", fileSysPathName,
- dp->d_name, (Testing? "it would have been ":""));
- if (!Testing)
- unlink(dp->d_name);
+
+ if (q_res.rw != singleVolumeNumber) {
+ Log("fileserver requested salvage of clone %lu; scheduling salvage of volume group %lu...\n",
+ afs_printable_uint32_lu(singleVolumeNumber),
+ afs_printable_uint32_lu(q_res.rw));
+#ifdef SALVSYNC_BUILD_CLIENT
+ if (SALVSYNC_LinkVolume(q_res.rw,
+ singleVolumeNumber,
+ fileSysPartition->name,
+ NULL) != SYNC_OK) {
+ Log("schedule request failed\n");
}
+#endif /* SALVSYNC_BUILD_CLIENT */
+ Exit(SALSRV_EXIT_VOLGROUP_LINK);
}
- else {
- char nameShouldBe[64];
- DiskToVolumeHeader(&vsp->header, &diskHeader);
- if (singleVolumeNumber && vsp->header.id==singleVolumeNumber && vsp->header.parent!=singleVolumeNumber) {
- Log("%u is a read-only volume; not salvaged\n", singleVolumeNumber);
- Exit(1);
+
+ volumeSummaryp = malloc(VOL_VG_MAX_VOLS * sizeof(struct VolumeSummary));
+ assert(volumeSummaryp != NULL);
+
+ nVolumes = 0;
+ vsp = volumeSummaryp;
+
+ for (i = 0; i < VOL_VG_MAX_VOLS; i++) {
+ char name[VMAXPATHLEN];
+
+ if (!q_res.children[i]) {
+ continue;
}
- if (!singleVolumeNumber || (vsp->header.id==singleVolumeNumber || vsp->header.parent==singleVolumeNumber)) {
- sprintf(nameShouldBe, VFORMAT, vsp->header.id);
- if (singleVolumeNumber)
- AskOffline(vsp->header.id);
- if (strcmp(nameShouldBe, dp->d_name)) {
- if (!Showmode) Log("Volume header file %s is incorrectly named; %sdeleted (it will be recreated later, if necessary)\n", dp->d_name, (Testing ? "it would have been ":""));
- if (!Testing)
- unlink(dp->d_name);
+
+ /* AskOffline for singleVolumeNumber was called much earlier */
+ if (q_res.children[i] != singleVolumeNumber) {
+ AskOffline(q_res.children[i], fileSysPartition->name);
+ if (LockVolume(q_res.children[i])) {
+ /* need to retry */
+ return -1;
}
- else {
- vsp->fileName = ToString(dp->d_name);
- nVolumes++;
- vsp++;
+ }
+
+ code = VReadVolumeDiskHeader(q_res.children[i], fileSysPartition, &diskHdr);
+ if (code) {
+ Log("Cannot read header for %lu; trying to salvage group anyway\n",
+ afs_printable_uint32_lu(q_res.children[i]));
+ code = 0;
+ continue;
+ }
+
+ DiskToVolumeHeader(&vsp->header, &diskHdr);
+ VolumeExternalName_r(q_res.children[i], name, sizeof(name));
+ vsp->fileName = ToString(name);
+ nVolumes++;
+ vsp++;
+ }
+
+ qsort(volumeSummaryp, nVolumes, sizeof(struct VolumeSummary),
+ CompareVolumes);
+ }
+ done:
+ if (code) {
+ Log("Cannot get volume summary from fileserver; falling back to scanning "
+ "entire partition\n");
+ }
+ }
+#endif /* FSSYNC_BUILD_CLIENT && AFS_DEMAND_ATTACH_FS */
+ return code;
+}
+
+/**
+ * count how many volume headers are found by VWalkVolumeHeaders.
+ *
+ * @param[in] dp the disk partition (unused)
+ * @param[in] name full path to the .vol header (unused)
+ * @param[in] hdr the header data (unused)
+ * @param[in] last whether this is the last try or not (unused)
+ * @param[in] rock actually an afs_int32*; the running count of how many
+ * volumes we have found
+ *
+ * @retval 0 always
+ */
+static int
+CountHeader(struct DiskPartition64 *dp, const char *name,
+ struct VolumeDiskHeader *hdr, int last, void *rock)
+{
+ afs_int32 *nvols = (afs_int32 *)rock;
+ (*nvols)++;
+ return 0;
+}
+
+/**
+ * parameters to pass to the VWalkVolumeHeaders callbacks when recording volume
+ * data.
+ */
+struct SalvageScanParams {
+ VolumeId singleVolumeNumber; /**< 0 for a partition-salvage, otherwise the
+ * vol id of the VG we're salvaging */
+ struct VolumeSummary *vsp; /**< ptr to the current volume summary object
+ * we're filling in */
+ afs_int32 nVolumes; /**< # of vols we've encountered */
+ afs_int32 totalVolumes; /**< max # of vols we should encounter (the
+ * # of vols we've alloc'd memory for) */
+ int retry; /**< do we need to retry vol lock/checkout? */
+};
+
+/**
+ * records volume summary info found from VWalkVolumeHeaders.
+ *
+ * Found volumes are also taken offline if they are in the specific volume
+ * group we are looking for.
+ *
+ * @param[in] dp the disk partition
+ * @param[in] name full path to the .vol header
+ * @param[in] hdr the header data
+ * @param[in] last 1 if this is the last try to read the header, 0 otherwise
+ * @param[in] rock actually a struct SalvageScanParams*, containing the
+ * information needed to record the volume summary data
+ *
+ * @return operation status
+ * @retval 0 success
+ * @retval -1 volume locking raced with fileserver restart; checking out
+ * and locking volumes needs to be retried
+ * @retval 1 volume header is mis-named and should be deleted
+ */
+static int
+RecordHeader(struct DiskPartition64 *dp, const char *name,
+ struct VolumeDiskHeader *hdr, int last, void *rock)
+{
+ char nameShouldBe[64];
+ struct SalvageScanParams *params;
+ struct VolumeSummary summary;
+ VolumeId singleVolumeNumber;
+
+ params = (struct SalvageScanParams *)rock;
+
+ singleVolumeNumber = params->singleVolumeNumber;
+
+ DiskToVolumeHeader(&summary.header, hdr);
+
+ if (singleVolumeNumber && summary.header.id == singleVolumeNumber
+ && summary.header.parent != singleVolumeNumber) {
+
+ if (programType == salvageServer) {
+#ifdef SALVSYNC_BUILD_CLIENT
+ Log("fileserver requested salvage of clone %u; scheduling salvage of volume group %u...\n",
+ summary.header.id, summary.header.parent);
+ if (SALVSYNC_LinkVolume(summary.header.parent,
+ summary.header.id,
+ dp->name,
+ NULL) != SYNC_OK) {
+ Log("schedule request failed\n");
+ }
+#endif
+ Exit(SALSRV_EXIT_VOLGROUP_LINK);
+
+ } else {
+ Log("%u is a read-only volume; not salvaged\n",
+ singleVolumeNumber);
+ Exit(1);
+ }
+ }
+
+ if (!singleVolumeNumber || summary.header.id == singleVolumeNumber
+ || summary.header.parent == singleVolumeNumber) {
+
+ /* check if the header file is incorrectly named */
+ int badname = 0;
+ const char *base = strrchr(name, '/');
+ if (base) {
+ base++;
+ } else {
+ base = name;
+ }
+
+ (void)afs_snprintf(nameShouldBe, sizeof nameShouldBe,
+ VFORMAT, afs_printable_uint32_lu(summary.header.id));
+
+
+ if (strcmp(nameShouldBe, base)) {
+ /* .vol file has wrong name; retry/delete */
+ badname = 1;
+ }
+
+ if (!badname || last) {
+ /* only offline the volume if the header is good, or if this is
+ * the last try looking at it; avoid AskOffline'ing the same vol
+ * multiple times */
+
+ if (singleVolumeNumber
+ && summary.header.id != singleVolumeNumber) {
+ /* don't offline singleVolumeNumber; we already did that
+ * earlier */
+
+ AskOffline(summary.header.id, fileSysPartition->name);
+
+#ifdef AFS_DEMAND_ATTACH_FS
+ if (!badname) {
+ /* don't lock the volume if the header is bad, since we're
+ * about to delete it anyway. */
+ if (LockVolume(summary.header.id)) {
+ params->retry = 1;
+ return -1;
}
}
+#endif /* AFS_DEMAND_ATTACH_FS */
}
- close(fd);
}
+ if (badname) {
+ if (last && !Showmode) {
+ Log("Volume header file %s is incorrectly named (should be %s "
+ "not %s); %sdeleted (it will be recreated later, if "
+ "necessary)\n", name, nameShouldBe, base,
+ (Testing ? "it would have been " : ""));
+ }
+ return 1;
+ }
+
+ summary.fileName = ToString(base);
+ params->nVolumes++;
+
+ if (params->nVolumes > params->totalVolumes) {
+ /* We found more volumes than we found on the first partition walk;
+ * apparently something created a volume while we were
+ * partition-salvaging, or we found more than 20 vols when salvaging a
+ * particular volume. Abort if we detect this, since other programs
+ * supposed to not touch the partition while it is partition-salvaging,
+ * and we shouldn't find more than 20 vols in a VG.
+ */
+ Abort("Found %ld vol headers, but should have found at most %ld! "
+ "Make sure the volserver/fileserver are not running at the "
+ "same time as a partition salvage\n",
+ afs_printable_int32_ld(params->nVolumes),
+ afs_printable_int32_ld(params->totalVolumes));
+ }
+
+ memcpy(params->vsp, &summary, sizeof(summary));
+ params->vsp++;
+ }
+
+ return 0;
+}
+
+/**
+ * possibly unlinks bad volume headers found from VWalkVolumeHeaders.
+ *
+ * If the header could not be read in at all, the header is always unlinked.
+ * If instead RecordHeader said the header was bad (that is, the header file
+ * is mis-named), we only unlink if we are doing a partition salvage, as
+ * opposed to salvaging a specific volume group.
+ *
+ * @param[in] dp the disk partition
+ * @param[in] name full path to the .vol header
+ * @param[in] hdr header data, or NULL if the header could not be read
+ * @param[in] rock actually a struct SalvageScanParams*, with some information
+ * about the scan
+ */
+static void
+UnlinkHeader(struct DiskPartition64 *dp, const char *name,
+ struct VolumeDiskHeader *hdr, void *rock)
+{
+ struct SalvageScanParams *params;
+ int dounlink = 0;
+
+ params = (struct SalvageScanParams *)rock;
+
+ if (!hdr) {
+ /* no header; header is too bogus to read in at all */
+ if (!Showmode) {
+ Log("%s is not a legitimate volume header file; %sdeleted\n", name, (Testing ? "it would have been " : ""));
+ }
+ if (!Testing) {
+ dounlink = 1;
+ }
+
+ } else if (!params->singleVolumeNumber) {
+ /* We were able to read in a header, but RecordHeader said something
+ * was wrong with it. We only unlink those if we are doing a partition
+ * salvage. */
+ if (!Testing) {
+ dounlink = 1;
+ }
+ }
+
+ if (dounlink && unlink(name)) {
+ Log("Error %d while trying to unlink %s\n", errno, name);
+ }
+}
+
+/**
+ * Populates volumeSummaryp with volume summary information, either by asking
+ * the fileserver for VG information, or by scanning the /vicepX partition.
+ *
+ * @param[in] singleVolumeNumber the volume ID of the single volume group we
+ * are salvaging, or 0 if this is a partition
+ * salvage
+ *
+ * @return operation status
+ * @retval 0 success
+ * @retval -1 we raced with a fileserver restart; checking out and locking
+ * volumes must be retried
+ */
+int
+GetVolumeSummary(VolumeId singleVolumeNumber)
+{
+ afs_int32 nvols = 0;
+ struct SalvageScanParams params;
+ int code;
+
+ code = AskVolumeSummary(singleVolumeNumber);
+ if (code == 0) {
+ /* we successfully got the vol information from the fileserver; no
+ * need to scan the partition */
+ return 0;
+ }
+ if (code < 0) {
+ /* we need to retry volume checkout */
+ return code;
+ }
+
+ if (!singleVolumeNumber) {
+ /* Count how many volumes we have in /vicepX */
+ code = VWalkVolumeHeaders(fileSysPartition, fileSysPath, CountHeader,
+ NULL, &nvols);
+ if (code < 0) {
+ Abort("Can't read directory %s; not salvaged\n", fileSysPath);
+ }
+ if (!nvols)
+ nvols = 1;
+ } else {
+ nvols = VOL_VG_MAX_VOLS;
+ }
+
+ volumeSummaryp = malloc(nvols * sizeof(struct VolumeSummary));
+ assert(volumeSummaryp != NULL);
+
+ params.singleVolumeNumber = singleVolumeNumber;
+ params.vsp = volumeSummaryp;
+ params.nVolumes = 0;
+ params.totalVolumes = nvols;
+ params.retry = 0;
+
+ /* walk the partition directory of volume headers and record the info
+ * about them; unlinking invalid headers */
+ code = VWalkVolumeHeaders(fileSysPartition, fileSysPath, RecordHeader,
+ UnlinkHeader, ¶ms);
+ if (params.retry) {
+ /* we apparently need to retry checking-out/locking volumes */
+ return -1;
}
- closedir(dirp);
- qsort(volumeSummaryp,nVolumes,sizeof (struct VolumeSummary),CompareVolumes);
+ if (code < 0) {
+ Abort("Failed to get volume header summary\n");
+ }
+ nVolumes = params.nVolumes;
+
+ qsort(volumeSummaryp, nVolumes, sizeof(struct VolumeSummary),
+ CompareVolumes);
+
+ return 0;
}
/* Find the link table. This should be associated with the RW volume or, if
* a RO only site, then the RO volume. For now, be cautious and hunt carefully.
*/
-Inode FindLinkHandle(register struct InodeSummary *isp, int nVols,
- struct ViceInodeInfo *allInodes)
+Inode
+FindLinkHandle(register struct InodeSummary *isp, int nVols,
+ struct ViceInodeInfo *allInodes)
{
int i, j;
struct ViceInodeInfo *ip;
- for (i=0; i<nVols; i++) {
+ for (i = 0; i < nVols; i++) {
ip = allInodes + isp[i].index;
- for (j=0; j<isp[i].nSpecialInodes; j++) {
+ for (j = 0; j < isp[i].nSpecialInodes; j++) {
if (ip[j].u.special.type == VI_LINKTABLE)
return ip[j].inodeNumber;
}
}
- return (Inode)-1;
+ return (Inode) - 1;
}
-int CreateLinkTable(register struct InodeSummary *isp, Inode ino)
+int
+CreateLinkTable(register struct InodeSummary *isp, Inode ino)
{
struct versionStamp version;
FdHandle_t *fdP;
if (!VALID_INO(ino))
- ino = IH_CREATE(NULL, fileSysDevice, fileSysPath, 0,
- isp->volumeId, INODESPECIAL,
- VI_LINKTABLE, isp->RWvolumeId);
+ ino =
+ IH_CREATE(NULL, fileSysDevice, fileSysPath, 0, isp->volumeId,
+ INODESPECIAL, VI_LINKTABLE, isp->RWvolumeId);
if (!VALID_INO(ino))
- Abort("Unable to allocate link table inode for volume %u (error = %d)\n",
- isp->RWvolumeId, errno);
+ Abort
+ ("Unable to allocate link table inode for volume %u (error = %d)\n",
+ isp->RWvolumeId, errno);
IH_INIT(VGLinkH, fileSysDevice, isp->RWvolumeId, ino);
fdP = IH_OPEN(VGLinkH);
if (fdP == NULL)
Abort("Can't open link table for volume %u (error = %d)\n",
isp->RWvolumeId, errno);
- if (FDH_TRUNC(fdP, 0)<0)
+ if (FDH_TRUNC(fdP, sizeof(version) + sizeof(short)) < 0)
Abort("Can't truncate link table for volume %u (error = %d)\n",
isp->RWvolumeId, errno);
version.magic = LINKTABLEMAGIC;
version.version = LINKTABLEVERSION;
- if (FDH_WRITE(fdP, (char*)&version, sizeof(version))
+ if (FDH_WRITE(fdP, (char *)&version, sizeof(version))
!= sizeof(version))
Abort("Can't truncate link table for volume %u (error = %d)\n",
isp->RWvolumeId, errno);
}
#ifdef AFS_NT40_ENV
-void *nt_SVG(void *arg)
+void *
+nt_SVG(void *arg)
{
- SVGParms_t *parms = (SVGParms_t*)arg;
+ SVGParms_t *parms = (SVGParms_t *) arg;
DoSalvageVolumeGroup(parms->svgp_inodeSummaryp, parms->svgp_count);
return NULL;
}
-void SalvageVolumeGroup(register struct InodeSummary *isp, int nVols)
+void
+SalvageVolumeGroup(register struct InodeSummary *isp, int nVols)
{
pthread_t tid;
pthread_attr_t tattr;
}
code = pthread_attr_setdetachstate(&tattr, PTHREAD_CREATE_JOINABLE);
if (code) {
- Log("Failed to salvage volume group %u: pthread_attr_setdetachstate()\n",
- isp->RWvolumeId);
+ Log("Failed to salvage volume group %u: pthread_attr_setdetachstate()\n", isp->RWvolumeId);
return;
}
code = pthread_create(&tid, &tattr, nt_SVG, &parms);
isp->RWvolumeId);
return;
}
- (void) pthread_join(tid, NULL);
+ (void)pthread_join(tid, NULL);
}
#endif /* AFS_NT40_ENV */
-void DoSalvageVolumeGroup(register struct InodeSummary *isp, int nVols)
+void
+DoSalvageVolumeGroup(register struct InodeSummary *isp, int nVols)
{
- struct ViceInodeInfo *inodes,*allInodes,*ip;
+ struct ViceInodeInfo *inodes, *allInodes, *ip;
int i, totalInodes, size, salvageTo;
int haveRWvolume;
int check;
Inode ino;
int dec_VGLinkH = 0;
- int VGLinkH_p1;
+ int VGLinkH_p1 =0;
FdHandle_t *fdP = NULL;
VGLinkH_cnt = 0;
- haveRWvolume = (isp->volumeId==isp->RWvolumeId && isp->nSpecialInodes>0);
+ haveRWvolume = (isp->volumeId == isp->RWvolumeId
+ && isp->nSpecialInodes > 0);
if ((!ShowMounts) || (ShowMounts && !haveRWvolume)) {
if (!ForceSalvage && QuickCheck(isp, nVols))
return;
if (ShowMounts && !haveRWvolume)
return;
if (canfork && !debug && Fork() != 0) {
- (void) Wait("Salvage volume group");
+ (void)Wait("Salvage volume group");
return;
}
- for (i = 0, totalInodes = 0; i<nVols; i++)
+ for (i = 0, totalInodes = 0; i < nVols; i++)
totalInodes += isp[i].nInodes;
- size = totalInodes * sizeof (struct ViceInodeInfo);
- inodes = (struct ViceInodeInfo *) malloc(size);
- allInodes = inodes - isp->index; /* this would the base of all the inodes
- for the partition, if all the inodes
- had been read into memory */
- assert(lseek(inodeFd,isp->index*sizeof(struct ViceInodeInfo),SEEK_SET) != -1)
- assert(read(inodeFd,inodes,size) == size)
+ size = totalInodes * sizeof(struct ViceInodeInfo);
+ inodes = (struct ViceInodeInfo *)malloc(size);
+ allInodes = inodes - isp->index; /* this would the base of all the inodes
+ * for the partition, if all the inodes
+ * had been read into memory */
+ assert(afs_lseek
+ (inodeFd, isp->index * sizeof(struct ViceInodeInfo),
+ SEEK_SET) != -1);
+ assert(read(inodeFd, inodes, size) == size);
/* Don't try to salvage a read write volume if there isn't one on this
- partition */
- salvageTo = haveRWvolume? 0:1;
+ * partition */
+ salvageTo = haveRWvolume ? 0 : 1;
#ifdef AFS_NAMEI_ENV
ino = FindLinkHandle(isp, nVols, allInodes);
}
if (!VALID_INO(ino) || fdP == NULL) {
Log("%s link table for volume %u.\n",
- Testing ? "Would have recreated" :"Recreating", isp->RWvolumeId);
+ Testing ? "Would have recreated" : "Recreating", isp->RWvolumeId);
if (Testing) {
IH_INIT(VGLinkH, fileSysDevice, -1, -1);
- }
- else {
+ } else {
+ int i, j;
+ struct ViceInodeInfo *ip;
CreateLinkTable(isp, ino);
+ fdP = IH_OPEN(VGLinkH);
+ /* Sync fake 1 link counts to the link table, now that it exists */
+ if (fdP) {
+ for (i = 0; i < nVols; i++) {
+ ip = allInodes + isp[i].index;
+ for (j = isp[i].nSpecialInodes; j < isp[i].nInodes; j++) {
+#ifdef AFS_NT40_ENV
+ nt_SetLinkCount(fdP, ip[j].inodeNumber, 1, 1);
+#else
+ namei_SetLinkCount(fdP, ip[j].inodeNumber, 1, 1);
+#endif
+ }
+ }
+ }
}
}
if (fdP)
#endif
/* Salvage in reverse order--read/write volume last; this way any
- Inodes not referenced by the time we salvage the read/write volume
- can be picked up by the read/write volume */
+ * Inodes not referenced by the time we salvage the read/write volume
+ * can be picked up by the read/write volume */
/* ACTUALLY, that's not done right now--the inodes just vanish */
- for (i = nVols-1; i>=salvageTo; i--) {
+ for (i = nVols - 1; i >= salvageTo; i--) {
int rw = (i == 0);
struct InodeSummary *lisp = &isp[i];
#ifdef AFS_NAMEI_ENV
}
}
#endif
- if (!Showmode) Log("%s VOLUME %u%s.\n", rw? "SALVAGING": "CHECKING CLONED",
- lisp->volumeId, (Testing?"(READONLY mode)":""));
+ if (!Showmode)
+ Log("%s VOLUME %u%s.\n", rw ? "SALVAGING" : "CHECKING CLONED",
+ lisp->volumeId, (Testing ? "(READONLY mode)" : ""));
/* Check inodes twice. The second time do things seriously. This
- way the whole RO volume can be deleted, below, if anything goes wrong */
- for (check = 1; check>=0; check--) {
+ * way the whole RO volume can be deleted, below, if anything goes wrong */
+ for (check = 1; check >= 0; check--) {
int deleteMe;
- if (SalvageVolumeHeaderFile(lisp,allInodes,rw,check, &deleteMe) == -1) {
- MaybeZapVolume(lisp,"Volume header",deleteMe, check);
+ if (SalvageVolumeHeaderFile(lisp, allInodes, rw, check, &deleteMe)
+ == -1) {
+ MaybeZapVolume(lisp, "Volume header", deleteMe, check);
if (rw && deleteMe) {
- haveRWvolume = 0; /* This will cause its inodes to be deleted--since salvage
- volume won't be called */
+ haveRWvolume = 0; /* This will cause its inodes to be deleted--since salvage
+ * volume won't be called */
break;
}
if (!rw)
}
if (rw && check == 1)
continue;
- if (SalvageVnodes(isp,lisp,allInodes,check) == -1) {
- MaybeZapVolume(lisp,"Vnode index", 0, check);
+ if (SalvageVnodes(isp, lisp, allInodes, check) == -1) {
+ MaybeZapVolume(lisp, "Vnode index", 0, check);
break;
}
}
/* Fix actual inode counts */
if (!Showmode) {
- for (ip = inodes; totalInodes; ip++,totalInodes--) {
+ Log("totalInodes %d\n",totalInodes);
+ for (ip = inodes; totalInodes; ip++, totalInodes--) {
static int TraceBadLinkCounts = 0;
#ifdef AFS_NAMEI_ENV
if (VGLinkH->ih_ino == ip->inodeNumber) {
dec_VGLinkH = ip->linkCount - VGLinkH_cnt;
VGLinkH_p1 = ip->u.param[0];
- continue; /* Deal with this last. */
+ continue; /* Deal with this last. */
}
#endif
if (ip->linkCount != 0 && TraceBadLinkCounts) {
- TraceBadLinkCounts--; /* Limit reports, per volume */
- Log("#### DEBUG #### Link count incorrect by %d; inode %s, size %u, p=(%u,%u,%u,%u)\n",
- ip->linkCount, PrintInode(NULL, ip->inodeNumber),
- ip->byteCount, ip->u.param[0], ip->u.param[1],
- ip->u.param[2], ip->u.param[3]);
+ TraceBadLinkCounts--; /* Limit reports, per volume */
+ Log("#### DEBUG #### Link count incorrect by %d; inode %s, size %llu, p=(%u,%u,%u,%u)\n", ip->linkCount, PrintInode(NULL, ip->inodeNumber), (afs_uintmax_t) ip->byteCount, ip->u.param[0], ip->u.param[1], ip->u.param[2], ip->u.param[3]);
}
while (ip->linkCount > 0) {
/* below used to assert, not break */
if (!Testing) {
if (IH_DEC(VGLinkH, ip->inodeNumber, ip->u.param[0])) {
- Log ("idec failed. inode %s errno %d\n",
- PrintInode(NULL, ip->inodeNumber), errno);
+ Log("idec failed. inode %s errno %d\n",
+ PrintInode(NULL, ip->inodeNumber), errno);
break;
}
}
while (ip->linkCount < 0) {
/* these used to be asserts */
if (!Testing) {
- if (IH_INC(VGLinkH ,ip->inodeNumber, ip->u.param[0])) {
- Log ("iinc failed. inode %s errno %d\n",
- PrintInode(NULL, ip->inodeNumber) ,errno);
+ if (IH_INC(VGLinkH, ip->inodeNumber, ip->u.param[0])) {
+ Log("iinc failed. inode %s errno %d\n",
+ PrintInode(NULL, ip->inodeNumber), errno);
break;
}
}
}
#ifdef AFS_NAMEI_ENV
while (dec_VGLinkH > 0) {
- if (IH_DEC(VGLinkH, VGLinkH->ih_ino, VGLinkH_p1)<0) {
+ if (IH_DEC(VGLinkH, VGLinkH->ih_ino, VGLinkH_p1) < 0) {
Log("idec failed on link table, errno = %d\n", errno);
}
- dec_VGLinkH --;
+ dec_VGLinkH--;
}
while (dec_VGLinkH < 0) {
- if (IH_INC(VGLinkH, VGLinkH->ih_ino, VGLinkH_p1)<0) {
+ if (IH_INC(VGLinkH, VGLinkH->ih_ino, VGLinkH_p1) < 0) {
Log("iinc failed on link table, errno = %d\n", errno);
}
- dec_VGLinkH ++;
+ dec_VGLinkH++;
}
#endif
}
}
}
-int QuickCheck(register struct InodeSummary *isp, int nVols)
+int
+QuickCheck(register struct InodeSummary *isp, int nVols)
{
/* Check headers BEFORE forking */
register int i;
IHandle_t *h;
- for (i = 0; i<nVols; i++) {
+ for (i = 0; i < nVols; i++) {
struct VolumeSummary *vs = isp[i].volSummary;
VolumeDiskData volHeader;
if (!vs) {
/* Don't salvage just because phantom rw volume is there... */
/* (If a read-only volume exists, read/write inodes must also exist) */
- if (i == 0 && isp->nSpecialInodes == 0 && nVols >1)
+ if (i == 0 && isp->nSpecialInodes == 0 && nVols > 1)
continue;
return 0;
}
IH_INIT(h, fileSysDevice, vs->header.parent, vs->header.volumeInfo);
- if (IH_IREAD(h, 0, (char*)&volHeader, sizeof(volHeader))
+ if (IH_IREAD(h, 0, (char *)&volHeader, sizeof(volHeader))
== sizeof(volHeader)
&& volHeader.stamp.magic == VOLUMEINFOMAGIC
&& volHeader.dontSalvage == DONT_SALVAGE
- && volHeader.needsSalvaged == 0
- && volHeader.destroyMe == 0) {
- if (volHeader.inUse == 1) {
+ && volHeader.needsSalvaged == 0 && volHeader.destroyMe == 0) {
+ if (volHeader.inUse != 0) {
volHeader.inUse = 0;
volHeader.inService = 1;
if (!Testing) {
- if (IH_IWRITE(h, 0, (char*)&volHeader, sizeof(volHeader))
+ if (IH_IWRITE(h, 0, (char *)&volHeader, sizeof(volHeader))
!= sizeof(volHeader)) {
IH_RELEASE(h);
return 0;
}
}
IH_RELEASE(h);
- }
- else {
+ } else {
IH_RELEASE(h);
return 0;
}
* Calls SalvageHeader for each possible type of volume special file.
*/
-int SalvageVolumeHeaderFile(register struct InodeSummary *isp,
- register struct ViceInodeInfo *inodes,
- int RW, int check, int *deleteMe)
+int
+SalvageVolumeHeaderFile(register struct InodeSummary *isp,
+ register struct ViceInodeInfo *inodes, int RW,
+ int check, int *deleteMe)
{
- int headerFd = 0;
int i;
register struct ViceInodeInfo *ip;
int allinodesobsolete = 1;
struct VolumeDiskHeader diskHeader;
+ afs_int32 (*writefunc)(VolumeDiskHeader_t *, struct DiskPartition64 *) = NULL;
+ int *skip;
+
+ /* keeps track of special inodes that are probably 'good'; they are
+ * referenced in the vol header, and are included in the given inodes
+ * array */
+ struct {
+ int valid;
+ Inode inode;
+ } goodspecial[MAXINODETYPE];
if (deleteMe)
- *deleteMe = 0;
+ *deleteMe = 0;
+
+ memset(goodspecial, 0, sizeof(goodspecial));
+
+ skip = malloc(isp->nSpecialInodes * sizeof(*skip));
+ if (skip) {
+ memset(skip, 0, isp->nSpecialInodes * sizeof(*skip));
+ } else {
+ Log("cannot allocate memory for inode skip array when salvaging "
+ "volume %lu; not performing duplicate special inode recovery\n",
+ afs_printable_uint32_lu(isp->volumeId));
+ /* still try to perform the salvage; the skip array only does anything
+ * if we detect duplicate special inodes */
+ }
+
+ /*
+ * First, look at the special inodes and see if any are referenced by
+ * the existing volume header. If we find duplicate special inodes, we
+ * can use this information to use the referenced inode (it's more
+ * likely to be the 'good' one), and throw away the duplicates.
+ */
+ if (isp->volSummary && skip) {
+ /* use tempHeader, so we can use the stuff[] array to easily index
+ * into the isp->volSummary special inodes */
+ memcpy(&tempHeader, &isp->volSummary->header, sizeof(struct VolumeHeader));
+
+ for (i = 0; i < isp->nSpecialInodes; i++) {
+ ip = &inodes[isp->index + i];
+ if (ip->u.special.type <= 0 || ip->u.special.type > MAXINODETYPE) {
+ /* will get taken care of in a later loop */
+ continue;
+ }
+ if (ip->inodeNumber == *(stuff[ip->u.special.type - 1].inode)) {
+ goodspecial[ip->u.special.type-1].valid = 1;
+ goodspecial[ip->u.special.type-1].inode = ip->inodeNumber;
+ }
+ }
+ }
+
memset(&tempHeader, 0, sizeof(tempHeader));
tempHeader.stamp.magic = VOLUMEHEADERMAGIC;
tempHeader.stamp.version = VOLUMEHEADERVERSION;
tempHeader.id = isp->volumeId;
tempHeader.parent = isp->RWvolumeId;
+
/* Check for duplicates (inodes are sorted by type field) */
- for (i = 0; i<isp->nSpecialInodes-1; i++) {
- ip = &inodes[isp->index+i];
- if (ip->u.special.type == (ip+1)->u.special.type) {
- if (!Showmode) Log("Duplicate special inodes in volume header; salvage of volume %u aborted\n", isp->volumeId);
- return -1;
+ for (i = 0; i < isp->nSpecialInodes - 1; i++) {
+ ip = &inodes[isp->index + i];
+ if (ip->u.special.type == (ip + 1)->u.special.type) {
+ afs_ino_str_t stmp1, stmp2;
+
+ if (ip->u.special.type <= 0 || ip->u.special.type > MAXINODETYPE) {
+ /* Will be caught in the loop below */
+ continue;
+ }
+ if (!Showmode) {
+ Log("Duplicate special %d inodes for volume %u found (%s, %s);\n",
+ ip->u.special.type, isp->volumeId,
+ PrintInode(stmp1, ip->inodeNumber),
+ PrintInode(stmp2, (ip+1)->inodeNumber));
+ }
+ if (skip && goodspecial[ip->u.special.type-1].valid) {
+ Inode gi = goodspecial[ip->u.special.type-1].inode;
+
+ if (!Showmode) {
+ Log("using special inode referenced by vol header (%s)\n",
+ PrintInode(stmp1, gi));
+ }
+
+ /* the volume header references some special inode of
+ * this type in the inodes array; are we it? */
+ if (ip->inodeNumber != gi) {
+ skip[i] = 1;
+ } else if ((ip+1)->inodeNumber != gi) {
+ /* in case this is the last iteration; we need to
+ * make sure we check ip+1, too */
+ skip[i+1] = 1;
+ }
+ } else {
+ if (!Showmode)
+ Log("cannot determine which is correct; salvage of volume %u aborted\n", isp->volumeId);
+ if (skip) {
+ free(skip);
+ }
+ return -1;
+ }
}
}
- for (i = 0; i<isp->nSpecialInodes; i++) {
- ip = &inodes[isp->index+i];
+ for (i = 0; i < isp->nSpecialInodes; i++) {
+ ip = &inodes[isp->index + i];
if (ip->u.special.type <= 0 || ip->u.special.type > MAXINODETYPE) {
if (check) {
- Log("Rubbish header inode\n");
+ Log("Rubbish header inode %s of type %d\n",
+ PrintInode(NULL, ip->inodeNumber),
+ ip->u.special.type);
+ if (skip) {
+ free(skip);
+ }
return -1;
}
- Log("Rubbish header inode; deleted\n");
- }
- else if (!stuff[ip->u.special.type-1].obsolete) {
- *(stuff[ip->u.special.type-1].inode) = ip->inodeNumber;
+ Log("Rubbish header inode %s of type %d; deleted\n",
+ PrintInode(NULL, ip->inodeNumber),
+ ip->u.special.type);
+ } else if (!stuff[ip->u.special.type - 1].obsolete) {
+ if (skip && skip[i]) {
+ if (orphans == ORPH_REMOVE) {
+ Log("Removing orphan special inode %s of type %d\n",
+ PrintInode(NULL, ip->inodeNumber), ip->u.special.type);
+ continue;
+ } else {
+ Log("Ignoring orphan special inode %s of type %d\n",
+ PrintInode(NULL, ip->inodeNumber), ip->u.special.type);
+ /* fall through to the ip->linkCount--; line below */
+ }
+ } else {
+ *(stuff[ip->u.special.type - 1].inode) = ip->inodeNumber;
+ allinodesobsolete = 0;
+ }
if (!check && ip->u.special.type != VI_LINKTABLE)
ip->linkCount--; /* Keep the inode around */
- allinodesobsolete = 0;
}
}
+ if (skip) {
+ free(skip);
+ }
+ skip = NULL;
if (allinodesobsolete) {
if (deleteMe)
}
if (!check)
- VGLinkH_cnt ++; /* one for every header. */
+ VGLinkH_cnt++; /* one for every header. */
if (!RW && !check && isp->volSummary) {
ClearROInUseBit(isp->volSummary);
return 0;
}
- for (i = 0; i< MAXINODETYPE; i++) {
+ for (i = 0; i < MAXINODETYPE; i++) {
if (stuff[i].inodeType == VI_LINKTABLE) {
/* Gross hack: SalvageHeader does a bcmp on the volume header.
* And we may have recreated the link table earlier, so set the
}
continue;
}
- if (SalvageHeader(&stuff[i],isp,check,deleteMe) == -1 && check)
+ if (SalvageHeader(&stuff[i], isp, check, deleteMe) == -1 && check)
return -1;
}
if (isp->volSummary == NULL) {
- char name[64];
- sprintf(name, VFORMAT, isp->volumeId);
+ char path[64];
+ char headerName[64];
+ (void)afs_snprintf(headerName, sizeof headerName, VFORMAT, afs_printable_uint32_lu(isp->volumeId));
+ (void)afs_snprintf(path, sizeof path, "%s/%s", fileSysPath, headerName);
if (check) {
Log("No header file for volume %u\n", isp->volumeId);
return -1;
}
- if (!Showmode) Log("No header file for volume %u; %screating %s/%s\n",
- isp->volumeId, (Testing?"it would have been ":""),
- fileSysPathName, name);
- headerFd = open(name, O_RDWR|O_CREAT|O_TRUNC, 0644);
- assert(headerFd != -1)
+ if (!Showmode)
+ Log("No header file for volume %u; %screating %s\n",
+ isp->volumeId, (Testing ? "it would have been " : ""),
+ path);
isp->volSummary = (struct VolumeSummary *)
malloc(sizeof(struct VolumeSummary));
- isp->volSummary->fileName = ToString(name);
- }
- else {
- char name[64];
+ isp->volSummary->fileName = ToString(headerName);
+
+ writefunc = VCreateVolumeDiskHeader;
+ } else {
+ char path[64];
+ char headerName[64];
/* hack: these two fields are obsolete... */
- isp->volSummary->header.volumeAcl = 0;
+ isp->volSummary->header.volumeAcl = 0;
isp->volSummary->header.volumeMountTable = 0;
- if (memcmp(&isp->volSummary->header, &tempHeader, sizeof(struct VolumeHeader))) {
+ if (memcmp
+ (&isp->volSummary->header, &tempHeader,
+ sizeof(struct VolumeHeader))) {
/* We often remove the name before calling us, so we make a fake one up */
if (isp->volSummary->fileName) {
- strcpy(name, isp->volSummary->fileName);
+ strcpy(headerName, isp->volSummary->fileName);
} else {
- sprintf(name, VFORMAT, isp->volumeId);
- isp->volSummary->fileName = ToString(name);
+ (void)afs_snprintf(headerName, sizeof headerName, VFORMAT, afs_printable_uint32_lu(isp->volumeId));
+ isp->volSummary->fileName = ToString(headerName);
}
+ (void)afs_snprintf(path, sizeof path, "%s/%s", fileSysPath, headerName);
- Log("Header file %s is damaged or no longer valid%s\n",
- name, (check ? "" : "; repairing"));
+ Log("Header file %s is damaged or no longer valid%s\n", path,
+ (check ? "" : "; repairing"));
if (check)
return -1;
- headerFd = open(name, O_RDWR|O_TRUNC, 0644);
- assert(headerFd != -1)
- }
+ writefunc = VWriteVolumeDiskHeader;
+ }
}
- if (headerFd) {
- memcpy(&isp->volSummary->header, &tempHeader, sizeof(struct VolumeHeader));
+ if (writefunc) {
+ memcpy(&isp->volSummary->header, &tempHeader,
+ sizeof(struct VolumeHeader));
if (Testing) {
- if (!Showmode) Log("It would have written a new header file for volume %u\n", isp->volumeId);
+ if (!Showmode)
+ Log("It would have written a new header file for volume %u\n",
+ isp->volumeId);
} else {
+ afs_int32 code;
VolumeHeaderToDisk(&diskHeader, &tempHeader);
- if (write(headerFd, &diskHeader, sizeof(struct VolumeDiskHeader))
- != sizeof(struct VolumeDiskHeader)) {
- Log("Couldn't rewrite volume header file!\n");
- close(headerFd);
+ code = (*writefunc)(&diskHeader, fileSysPartition);
+ if (code) {
+ Log("Error %ld writing volume header file for volume %lu\n",
+ afs_printable_int32_ld(code),
+ afs_printable_uint32_lu(diskHeader.id));
return -1;
}
}
- close(headerFd);
}
- IH_INIT(isp->volSummary->volumeInfoHandle, fileSysDevice,
- isp->RWvolumeId, isp->volSummary->header.volumeInfo);
+ IH_INIT(isp->volSummary->volumeInfoHandle, fileSysDevice, isp->RWvolumeId,
+ isp->volSummary->header.volumeInfo);
return 0;
}
-int SalvageHeader(register struct stuff *sp, struct InodeSummary *isp,
- int check, int *deleteMe)
+int
+SalvageHeader(register struct stuff *sp, struct InodeSummary *isp, int check,
+ int *deleteMe)
{
union {
- VolumeDiskData volumeInfo;
- struct versionStamp fileHeader;
+ VolumeDiskData volumeInfo;
+ struct versionStamp fileHeader;
} header;
IHandle_t *specH;
int recreate = 0;
afs_int32 code;
FdHandle_t *fdP;
-
+
if (sp->obsolete)
return 0;
#ifndef AFS_NAMEI_ENV
- if ( sp->inodeType == VI_LINKTABLE)
+ if (sp->inodeType == VI_LINKTABLE)
return 0;
#endif
if (*(sp->inode) == 0) {
Log("Missing inode in volume header (%s)\n", sp->description);
return -1;
}
- if (!Showmode) Log("Missing inode in volume header (%s); %s\n",
- sp->description, (Testing ? "it would have recreated it": "recreating"));
+ if (!Showmode)
+ Log("Missing inode in volume header (%s); %s\n", sp->description,
+ (Testing ? "it would have recreated it" : "recreating"));
if (!Testing) {
- *(sp->inode) = IH_CREATE(NULL, fileSysDevice, fileSysPath, 0,
- isp->volumeId, INODESPECIAL,
- sp->inodeType, isp->RWvolumeId);
- if (!VALID_INO(*(sp->inode)))
- Abort("Unable to allocate inode (%s) for volume header (error = %d)\n",
- sp->description, errno);
+ *(sp->inode) =
+ IH_CREATE(NULL, fileSysDevice, fileSysPath, 0, isp->volumeId,
+ INODESPECIAL, sp->inodeType, isp->RWvolumeId);
+ if (!VALID_INO(*(sp->inode)))
+ Abort
+ ("Unable to allocate inode (%s) for volume header (error = %d)\n",
+ sp->description, errno);
}
recreate = 1;
}
fdP = IH_OPEN(specH);
if (OKToZap && (fdP == NULL) && BadError(errno)) {
/* bail out early and destroy the volume */
- if (!Showmode) Log("Still can't open volume header inode (%s), destroying volume\n",
- sp->description);
- if (deleteMe) *deleteMe = 1;
+ if (!Showmode)
+ Log("Still can't open volume header inode (%s), destroying volume\n", sp->description);
+ if (deleteMe)
+ *deleteMe = 1;
IH_RELEASE(specH);
return -1;
}
if (fdP == NULL)
- Abort("Unable to open inode (%s) of volume header (error = %d)\n",
- sp->description, errno);
-
- if (!recreate &&
- (FDH_READ(fdP, (char*)&header, sp->size) != sp->size
- || header.fileHeader.magic != sp->stamp.magic)) {
+ Abort("Unable to open inode (%s) of volume header (error = %d)\n",
+ sp->description, errno);
+
+ if (!recreate
+ && (FDH_READ(fdP, (char *)&header, sp->size) != sp->size
+ || header.fileHeader.magic != sp->stamp.magic)) {
if (check) {
Log("Part of the header (%s) is corrupted\n", sp->description);
FDH_REALLYCLOSE(fdP);
return -1;
}
Log("Part of the header (%s) is corrupted; recreating\n",
- sp->description);
+ sp->description);
recreate = 1;
}
- if (sp->inodeType == VI_VOLINFO && header.volumeInfo.destroyMe == DESTROY_ME) {
+ if (sp->inodeType == VI_VOLINFO
+ && header.volumeInfo.destroyMe == DESTROY_ME) {
if (deleteMe)
*deleteMe = 1;
FDH_REALLYCLOSE(fdP);
return -1;
}
if (recreate && !Testing) {
- if (check)
- Abort("Internal error: recreating volume header (%s) in check mode\n",
+ if (check)
+ Abort
+ ("Internal error: recreating volume header (%s) in check mode\n",
sp->description);
code = FDH_TRUNC(fdP, 0);
if (code == -1)
- Abort("Unable to truncate volume header file (%s) (error = %d)\n",
- sp->description, errno);
+ Abort("Unable to truncate volume header file (%s) (error = %d)\n",
+ sp->description, errno);
/* The following code should be moved into vutil.c */
if (sp->inodeType == VI_VOLINFO) {
struct timeval tp;
- memset(&header.volumeInfo, 0, sizeof (header.volumeInfo));
+ memset(&header.volumeInfo, 0, sizeof(header.volumeInfo));
header.volumeInfo.stamp = sp->stamp;
header.volumeInfo.id = isp->volumeId;
header.volumeInfo.parentId = isp->RWvolumeId;
- sprintf(header.volumeInfo.name, "bogus.%u",isp->volumeId);
- Log("Warning: the name of volume %u is now \"bogus.%u\"\n", isp->volumeId, isp->volumeId);
+ sprintf(header.volumeInfo.name, "bogus.%u", isp->volumeId);
+ Log("Warning: the name of volume %u is now \"bogus.%u\"\n",
+ isp->volumeId, isp->volumeId);
header.volumeInfo.inService = 0;
header.volumeInfo.blessed = 0;
/* The + 1000 is a hack in case there are any files out in venus caches */
- header.volumeInfo.uniquifier = (isp->maxUniquifier+1)+1000;
- header.volumeInfo.type =
- (isp->volumeId == isp->RWvolumeId? readwriteVolume:readonlyVolume); /* XXXX */
+ header.volumeInfo.uniquifier = (isp->maxUniquifier + 1) + 1000;
+ header.volumeInfo.type = (isp->volumeId == isp->RWvolumeId ? readwriteVolume : readonlyVolume); /* XXXX */
header.volumeInfo.needsCallback = 0;
- gettimeofday(&tp,0);
+ gettimeofday(&tp, 0);
header.volumeInfo.creationDate = tp.tv_sec;
- if(FDH_SEEK(fdP,0,SEEK_SET)<0) {
- Abort("Unable to seek to beginning of volume header file (%s) (errno = %d)\n",sp->description,errno);
+ if (FDH_SEEK(fdP, 0, SEEK_SET) < 0) {
+ Abort
+ ("Unable to seek to beginning of volume header file (%s) (errno = %d)\n",
+ sp->description, errno);
}
- code = FDH_WRITE(fdP, (char*)&header.volumeInfo,
- sizeof(header.volumeInfo));
+ code =
+ FDH_WRITE(fdP, (char *)&header.volumeInfo,
+ sizeof(header.volumeInfo));
if (code != sizeof(header.volumeInfo)) {
- if (code < 0)
- Abort("Unable to write volume header file (%s) (errno = %d)\n",
- sp->description, errno);
- Abort("Unable to write entire volume header file (%s)\n",
- sp->description);
+ if (code < 0)
+ Abort
+ ("Unable to write volume header file (%s) (errno = %d)\n",
+ sp->description, errno);
+ Abort("Unable to write entire volume header file (%s)\n",
+ sp->description);
+ }
+ } else {
+ if (FDH_SEEK(fdP, 0, SEEK_SET) < 0) {
+ Abort
+ ("Unable to seek to beginning of volume header file (%s) (errno = %d)\n",
+ sp->description, errno);
}
- }
- else {
- if(FDH_SEEK(fdP,0,SEEK_SET)<0) {
- Abort("Unable to seek to beginning of volume header file (%s) (errno = %d)\n",sp->description,errno);
- }
- code = FDH_WRITE(fdP, (char*)&sp->stamp, sizeof(sp->stamp));
- if (code != sizeof(sp->stamp)) {
- if (code < 0)
- Abort("Unable to write version stamp in volume header file (%s) (errno = %d)\n",
- sp->description, errno);
- Abort("Unable to write entire version stamp in volume header file (%s)\n",
- sp->description);
+ code = FDH_WRITE(fdP, (char *)&sp->stamp, sizeof(sp->stamp));
+ if (code != sizeof(sp->stamp)) {
+ if (code < 0)
+ Abort
+ ("Unable to write version stamp in volume header file (%s) (errno = %d)\n",
+ sp->description, errno);
+ Abort
+ ("Unable to write entire version stamp in volume header file (%s)\n",
+ sp->description);
}
}
}
char update[25];
if (VolInfo.updateDate) {
strcpy(update, TimeStamp(VolInfo.updateDate, 0));
- if (!Showmode) Log("%s (%u) %supdated %s\n", VolInfo.name, VolInfo.id,
- (Testing?"it would have been ":""), update);
+ if (!Showmode)
+ Log("%s (%u) %supdated %s\n", VolInfo.name, VolInfo.id,
+ (Testing ? "it would have been " : ""), update);
} else {
strcpy(update, TimeStamp(VolInfo.creationDate, 0));
- if (!Showmode) Log("%s (%u) not updated (created %s)\n", VolInfo.name, VolInfo.id, update);
+ if (!Showmode)
+ Log("%s (%u) not updated (created %s)\n", VolInfo.name,
+ VolInfo.id, update);
}
}
- }
+ }
return 0;
}
-int SalvageVnodes(register struct InodeSummary *rwIsp,
- register struct InodeSummary * thisIsp,
- register struct ViceInodeInfo * inodes, int check)
+int
+SalvageVnodes(register struct InodeSummary *rwIsp,
+ register struct InodeSummary *thisIsp,
+ register struct ViceInodeInfo *inodes, int check)
{
int ilarge, ismall, ioffset, RW, nInodes;
- ioffset = rwIsp->index+rwIsp->nSpecialInodes; /* first inode */
- if (Showmode) return 0;
+ ioffset = rwIsp->index + rwIsp->nSpecialInodes; /* first inode */
+ if (Showmode)
+ return 0;
RW = (rwIsp == thisIsp);
nInodes = (rwIsp->nInodes - rwIsp->nSpecialInodes);
- ismall = SalvageIndex(thisIsp->volSummary->header.smallVnodeIndex,
- vSmall, RW, &inodes[ioffset], nInodes, thisIsp->volSummary, check);
+ ismall =
+ SalvageIndex(thisIsp->volSummary->header.smallVnodeIndex, vSmall, RW,
+ &inodes[ioffset], nInodes, thisIsp->volSummary, check);
if (check && ismall == -1)
return -1;
- ilarge = SalvageIndex(thisIsp->volSummary->header.largeVnodeIndex,
- vLarge, RW, &inodes[ioffset], nInodes, thisIsp->volSummary, check);
- return (ilarge==0 && ismall==0 ? 0: -1);
+ ilarge =
+ SalvageIndex(thisIsp->volSummary->header.largeVnodeIndex, vLarge, RW,
+ &inodes[ioffset], nInodes, thisIsp->volSummary, check);
+ return (ilarge == 0 && ismall == 0 ? 0 : -1);
}
-int SalvageIndex(Inode ino, VnodeClass class, int RW,
- register struct ViceInodeInfo *ip,
- int nInodes, struct VolumeSummary *volSummary, int check)
+int
+SalvageIndex(Inode ino, VnodeClass class, int RW,
+ register struct ViceInodeInfo *ip, int nInodes,
+ struct VolumeSummary *volSummary, int check)
{
VolumeId volumeNumber;
char buf[SIZEOF_LARGEDISKVNODE];
- struct VnodeDiskObject *vnode = (struct VnodeDiskObject *) buf;
+ struct VnodeDiskObject *vnode = (struct VnodeDiskObject *)buf;
int err = 0;
StreamHandle_t *file;
struct VnodeClassInfo *vcp;
- int size;
+ afs_sfsize_t size;
+ afs_fsize_t vnodeLength;
int vnodeIndex, nVnodes;
afs_ino_str_t stmp1, stmp2;
IHandle_t *handle;
fdP = IH_OPEN(handle);
assert(fdP != NULL);
file = FDH_FDOPEN(fdP, "r+");
- assert(file != NULL)
+ assert(file != NULL);
vcp = &VnodeClassInfo[class];
size = OS_SIZE(fdP->fd_fd);
assert(size != -1);
nVnodes = (size / vcp->diskSize) - 1;
if (nVnodes > 0) {
- assert((nVnodes+1) * vcp->diskSize == size)
- assert(STREAM_SEEK(file, vcp->diskSize, 0) == 0)
- }
- else {
+ assert((nVnodes + 1) * vcp->diskSize == size);
+ assert(STREAM_SEEK(file, vcp->diskSize, 0) == 0);
+ } else {
nVnodes = 0;
}
for (vnodeIndex = 0;
- nVnodes && STREAM_READ(vnode, vcp->diskSize, 1, file) == 1;
- nVnodes--, vnodeIndex++) {
+ nVnodes && STREAM_READ(vnode, vcp->diskSize, 1, file) == 1;
+ nVnodes--, vnodeIndex++) {
if (vnode->type != vNull) {
int vnodeChanged = 0;
int vnodeNumber = bitNumberToVnodeNumber(vnodeIndex, class);
/* Log programs that belong to root (potentially suid root);
- don't bother for read-only or backup volumes */
-#ifdef notdef /* This is done elsewhere */
- if (ShowRootFiles && RW && vnode->owner==0 && vnodeNumber != 1)
- Log("OWNER IS ROOT %s %u dir %u vnode %u author %u owner %u mode %o\n",
- VolInfo.name, volumeNumber, vnode->parent, vnodeNumber, vnode->author,
- vnode->owner, vnode->modeBits);
+ * don't bother for read-only or backup volumes */
+#ifdef notdef /* This is done elsewhere */
+ if (ShowRootFiles && RW && vnode->owner == 0 && vnodeNumber != 1)
+ Log("OWNER IS ROOT %s %u dir %u vnode %u author %u owner %u mode %o\n", VolInfo.name, volumeNumber, vnode->parent, vnodeNumber, vnode->author, vnode->owner, vnode->modeBits);
#endif
if (VNDISK_GET_INO(vnode) == 0) {
if (RW) {
memset(vnode, 0, vcp->diskSize);
vnodeChanged = 1;
}
- }
- else {
+ } else {
if (vcp->magic != vnode->vnodeMagic) {
/* bad magic #, probably partially created vnode */
- Log("Partially allocated vnode %d deleted.\n", vnodeNumber);
+ Log("Partially allocated vnode %d deleted.\n",
+ vnodeNumber);
memset(vnode, 0, vcp->diskSize);
vnodeChanged = 1;
goto vnodeDone;
}
/* ****** Should do a bit more salvage here: e.g. make sure
- vnode type matches what it should be given the index */
+ * vnode type matches what it should be given the index */
while (nInodes && ip->u.vnode.vnodeNumber < vnodeNumber) {
/* if (vnodeIdToClass(ip->u.vnode.vnodeNumber) == class && RW) {
* Log("Inode %d: says it belongs to non-existing vnode %d\n",
if (!RW) {
while (nInodes && ip->u.vnode.vnodeNumber == vnodeNumber) {
/* The following doesn't work, because the version number
- is not maintained correctly by the file server */
+ * is not maintained correctly by the file server */
/*if (vnode->uniquifier == ip->u.vnode.vnodeUniquifier &&
- vnode->dataVersion == ip->u.vnode.inodeDataVersion)
- break;*/
+ * vnode->dataVersion == ip->u.vnode.inodeDataVersion)
+ * break; */
if (VNDISK_GET_INO(vnode) == ip->inodeNumber)
break;
ip++;
nInodes--;
}
- }
- else {
+ } else {
/* For RW volume, look for vnode with matching inode number;
- if no such match, take the first determined by our sort
- order */
+ * if no such match, take the first determined by our sort
+ * order */
register struct ViceInodeInfo *lip = ip;
- register lnInodes = nInodes;
- while (lnInodes && lip->u.vnode.vnodeNumber == vnodeNumber) {
+ register int lnInodes = nInodes;
+ while (lnInodes
+ && lip->u.vnode.vnodeNumber == vnodeNumber) {
if (VNDISK_GET_INO(vnode) == lip->inodeNumber) {
ip = lip;
nInodes = lnInodes;
if (nInodes && ip->u.vnode.vnodeNumber == vnodeNumber) {
/* "Matching" inode */
if (RW) {
- Unique vu,iu;
- FileVersion vd,id;
+ Unique vu, iu;
+ FileVersion vd, id;
vu = vnode->uniquifier;
iu = ip->u.vnode.vnodeUniquifier;
vd = vnode->dataVersion;
*/
if (IUnique(vu) != IUnique(iu)) {
if (!Showmode) {
- Log("Vnode %u: vnode.unique, %u, does not match inode unique, %u; fixed, but status will be wrong\n",
- vnodeNumber, IUnique(vu), IUnique(iu));
+ Log("Vnode %u: vnode.unique, %u, does not match inode unique, %u; fixed, but status will be wrong\n", vnodeNumber, IUnique(vu), IUnique(iu));
}
-
+
vnode->uniquifier = iu;
#ifdef AFS_3DISPARES
- vnode->dataVersion = (id >= vd ?
- /* 90% of 2.1M */ ((id-vd) > 1887437 ? vd:id):
- /* 90% of 2.1M */ ((vd-id) > 1887437 ? id:vd));
+ vnode->dataVersion = (id >= vd ?
+ /* 90% of 2.1M */
+ ((id - vd) >
+ 1887437 ? vd : id) :
+ /* 90% of 2.1M */
+ ((vd - id) >
+ 1887437 ? id : vd));
#else
#if defined(AFS_SGI_EXMAG)
- vnode->dataVersion = (id >= vd ?
- /* 90% of 16M */ ((id-vd) > 15099494 ? vd:id):
- /* 90% of 16M */ ((vd-id) > 15099494 ? id:vd));
+ vnode->dataVersion = (id >= vd ?
+ /* 90% of 16M */
+ ((id - vd) >
+ 15099494 ? vd : id) :
+ /* 90% of 16M */
+ ((vd - id) >
+ 15099494 ? id : vd));
#else
- vnode->dataVersion = (id>vd ? id:vd);
+ vnode->dataVersion = (id > vd ? id : vd);
#endif /* AFS_SGI_EXMAG */
-#endif /* AFS_3DISPARES */
+#endif /* AFS_3DISPARES */
vnodeChanged = 1;
- }
- else {
+ } else {
/* don't bother checking for vd > id any more, since
- partial file transfers always result in this state,
- and you can't do much else anyway (you've already
- found the best data you can) */
+ * partial file transfers always result in this state,
+ * and you can't do much else anyway (you've already
+ * found the best data you can) */
#ifdef AFS_3DISPARES
- if (!vnodeIsDirectory(vnodeNumber) &&
- ((vd < id && (id-vd) < 1887437) ||
- ((vd > id && (vd-id) > 1887437)))) {
+ if (!vnodeIsDirectory(vnodeNumber)
+ && ((vd < id && (id - vd) < 1887437)
+ || ((vd > id && (vd - id) > 1887437)))) {
#else
#if defined(AFS_SGI_EXMAG)
- if (!vnodeIsDirectory(vnodeNumber) &&
- ((vd < id && (id-vd) < 15099494) ||
- ((vd > id && (vd-id) > 15099494)))) {
+ if (!vnodeIsDirectory(vnodeNumber)
+ && ((vd < id && (id - vd) < 15099494)
+ || ((vd > id && (vd - id) > 15099494)))) {
#else
if (!vnodeIsDirectory(vnodeNumber) && vd < id) {
#endif /* AFS_SGI_EXMAG */
#endif
- if (!Showmode) Log("Vnode %d: version < inode version; fixed (old status)\n", vnodeNumber);
+ if (!Showmode)
+ Log("Vnode %d: version < inode version; fixed (old status)\n", vnodeNumber);
vnode->dataVersion = id;
vnodeChanged = 1;
}
if (ip->inodeNumber != VNDISK_GET_INO(vnode)) {
if (check) {
if (!Showmode) {
- Log("Vnode %d: inode number incorrect (is %s should be %s). FileSize=%d\n",
- PrintInode(stmp1, VNDISK_GET_INO(vnode)),
- PrintInode(stmp2, ip->inodeNumber),
- ip->byteCount);
+ Log("Vnode %d: inode number incorrect (is %s should be %s). FileSize=%llu\n", vnodeNumber, PrintInode(stmp1, VNDISK_GET_INO(vnode)), PrintInode(stmp2, ip->inodeNumber), (afs_uintmax_t) ip->byteCount);
}
VNDISK_SET_INO(vnode, ip->inodeNumber);
err = -1;
goto zooks;
}
if (!Showmode) {
- Log("Vnode %d: inode number incorrect; changed from %s to %s. FileSize=%d\n",
- vnodeNumber,
- PrintInode(stmp1, VNDISK_GET_INO(vnode)),
- PrintInode(stmp2, ip->inodeNumber),
- ip->byteCount);
+ Log("Vnode %d: inode number incorrect; changed from %s to %s. FileSize=%llu\n", vnodeNumber, PrintInode(stmp1, VNDISK_GET_INO(vnode)), PrintInode(stmp2, ip->inodeNumber), (afs_uintmax_t) ip->byteCount);
}
VNDISK_SET_INO(vnode, ip->inodeNumber);
vnodeChanged = 1;
}
- if (ip->byteCount != vnode->length) {
+ VNDISK_GET_LEN(vnodeLength, vnode);
+ if (ip->byteCount != vnodeLength) {
if (check) {
- if (!Showmode) Log("Vnode %d: length incorrect; (is %d should be %d)\n",
- vnodeNumber, vnode->length, ip->byteCount);
+ if (!Showmode)
+ Log("Vnode %d: length incorrect; (is %llu should be %llu)\n", vnodeNumber, (afs_uintmax_t) vnodeLength, (afs_uintmax_t) ip->byteCount);
err = -1;
goto zooks;
}
- if (!Showmode) Log("Vnode %d: length incorrect; changed from %d to %d\n",
- vnodeNumber, vnode->length, ip->byteCount);
- vnode->length = ip->byteCount;
+ if (!Showmode)
+ Log("Vnode %d: length incorrect; changed from %llu to %llu\n", vnodeNumber, (afs_uintmax_t) vnodeLength, (afs_uintmax_t) ip->byteCount);
+ VNDISK_SET_LEN(vnode, ip->byteCount);
vnodeChanged = 1;
}
if (!check)
- ip->linkCount--; /* Keep the inode around */
+ ip->linkCount--; /* Keep the inode around */
ip++;
nInodes--;
- }
- else { /* no matching inode */
- if (VNDISK_GET_INO(vnode) != 0 || vnode->type == vDirectory) {
+ } else { /* no matching inode */
+ if (VNDISK_GET_INO(vnode) != 0
+ || vnode->type == vDirectory) {
/* No matching inode--get rid of the vnode */
if (check) {
if (VNDISK_GET_INO(vnode)) {
if (!Showmode) {
- Log("Vnode %d (unique %d): corresponding inode %s is missing\n",
- vnodeNumber, vnode->uniquifier,
- PrintInode(NULL, VNDISK_GET_INO(vnode)));
+ Log("Vnode %d (unique %u): corresponding inode %s is missing\n", vnodeNumber, vnode->uniquifier, PrintInode(NULL, VNDISK_GET_INO(vnode)));
}
} else {
- if (!Showmode) Log("Vnode %d (unique %d): bad directory vnode (no inode number listed)\n", vnodeNumber, vnode->uniquifier);
+ if (!Showmode)
+ Log("Vnode %d (unique %u): bad directory vnode (no inode number listed)\n", vnodeNumber, vnode->uniquifier);
}
err = -1;
goto zooks;
}
if (VNDISK_GET_INO(vnode)) {
if (!Showmode) {
- Log("Vnode %d (unique %d): corresponding inode %s is missing; vnode deleted, vnode mod time=%s",
- vnodeNumber, vnode->uniquifier,
- PrintInode(NULL, VNDISK_GET_INO(vnode)),
- ctime((time_t *)&(vnode->serverModifyTime)));
+ time_t serverModifyTime = vnode->serverModifyTime;
+ Log("Vnode %d (unique %u): corresponding inode %s is missing; vnode deleted, vnode mod time=%s", vnodeNumber, vnode->uniquifier, PrintInode(NULL, VNDISK_GET_INO(vnode)), ctime(&serverModifyTime));
}
} else {
- if (!Showmode) Log("Vnode %d (unique %d): bad directory vnode (no inode number listed); vnode deleted, vnode mod time=%s", vnodeNumber, vnode->uniquifier, ctime((time_t *)&(vnode->serverModifyTime)));
+ if (!Showmode) {
+ time_t serverModifyTime = vnode->serverModifyTime;
+ Log("Vnode %d (unique %u): bad directory vnode (no inode number listed); vnode deleted, vnode mod time=%s", vnodeNumber, vnode->uniquifier, ctime(&serverModifyTime));
+ }
}
memset(vnode, 0, vcp->diskSize);
vnodeChanged = 1;
} else {
- /* Should not reach here becuase we checked for
- * (inodeNumber == 0) above. And where we zero the vnode,
- * we also goto vnodeDone.
- */
+ /* Should not reach here becuase we checked for
+ * (inodeNumber == 0) above. And where we zero the vnode,
+ * we also goto vnodeDone.
+ */
}
}
while (nInodes && ip->u.vnode.vnodeNumber == vnodeNumber) {
ip++;
nInodes--;
}
- } /* VNDISK_GET_INO(vnode) != 0 */
+ } /* VNDISK_GET_INO(vnode) != 0 */
vnodeDone:
assert(!(vnodeChanged && check));
if (vnodeChanged && !Testing) {
- assert(IH_IWRITE(handle, vnodeIndexOffset(vcp,vnodeNumber),
- (char*)vnode, vcp->diskSize)
- == vcp->diskSize);
+ assert(IH_IWRITE
+ (handle, vnodeIndexOffset(vcp, vnodeNumber),
+ (char *)vnode, vcp->diskSize)
+ == vcp->diskSize);
VolumeChanged = 1; /* For break call back */
}
}
}
-zooks:
+ zooks:
STREAM_CLOSE(file);
FDH_CLOSE(fdP);
IH_RELEASE(handle);
return err;
}
-struct VnodeEssence *CheckVnodeNumber(vnodeNumber)
- VnodeId vnodeNumber;
+struct VnodeEssence *
+CheckVnodeNumber(VnodeId vnodeNumber)
{
VnodeClass class;
struct VnodeInfo *vip;
class = vnodeIdToClass(vnodeNumber);
vip = &vnodeInfo[class];
offset = vnodeIdToBitNumber(vnodeNumber);
- return (offset >= vip->nVnodes? NULL: &vip->vnodes[offset]);
+ return (offset >= vip->nVnodes ? NULL : &vip->vnodes[offset]);
}
-
-void CopyOnWrite(register struct DirSummary *dir)
+void
+CopyOnWrite(register struct DirSummary *dir)
{
/* Copy the directory unconditionally if we are going to change it:
* not just if was cloned.
struct VnodeDiskObject vnode;
struct VnodeClassInfo *vcp = &VnodeClassInfo[vLarge];
Inode oldinode, newinode;
- int code;
+ afs_sfsize_t code;
if (dir->copied || Testing)
- return;
- DFlush(); /* Well justified paranoia... */
+ return;
+ DFlush(); /* Well justified paranoia... */
- code = IH_IREAD(vnodeInfo[vLarge].handle,
- vnodeIndexOffset(vcp, dir->vnodeNumber),
- (char*)&vnode, sizeof (vnode));
+ code =
+ IH_IREAD(vnodeInfo[vLarge].handle,
+ vnodeIndexOffset(vcp, dir->vnodeNumber), (char *)&vnode,
+ sizeof(vnode));
assert(code == sizeof(vnode));
oldinode = VNDISK_GET_INO(&vnode);
/* Increment the version number by a whole lot to avoid problems with
* clients that were promised new version numbers--but the file server
* crashed before the versions were written to disk.
*/
- newinode = IH_CREATE(dir->ds_linkH, fileSysDevice, fileSysPath, 0,
- dir->rwVid, dir->vnodeNumber,
- vnode.uniquifier, vnode.dataVersion += 200);
+ newinode =
+ IH_CREATE(dir->ds_linkH, fileSysDevice, fileSysPath, 0, dir->rwVid,
+ dir->vnodeNumber, vnode.uniquifier, vnode.dataVersion +=
+ 200);
assert(VALID_INO(newinode));
assert(CopyInode(fileSysDevice, oldinode, newinode, dir->rwVid) == 0);
vnode.cloned = 0;
VNDISK_SET_INO(&vnode, newinode);
- code = IH_IWRITE(vnodeInfo[vLarge].handle,
- vnodeIndexOffset(vcp, dir->vnodeNumber),
- (char*)&vnode, sizeof (vnode));
- assert(code == sizeof (vnode));
+ code =
+ IH_IWRITE(vnodeInfo[vLarge].handle,
+ vnodeIndexOffset(vcp, dir->vnodeNumber), (char *)&vnode,
+ sizeof(vnode));
+ assert(code == sizeof(vnode));
SetSalvageDirHandle(&dir->dirHandle, dir->dirHandle.dirh_handle->ih_vid,
fileSysDevice, newinode);
*/
dir->copied = 1;
}
-
-/* This function should either successfully create a new dir, or give up and leave
- * things the way they were. In particular, if it fails to write the new dir properly,
- * it should return w/o changing the reference to the old dir.
+
+/*
+ * This function should either successfully create a new dir, or give up
+ * and leave things the way they were. In particular, if it fails to write
+ * the new dir properly, it should return w/o changing the reference to the
+ * old dir.
*/
-void CopyAndSalvage(register struct DirSummary *dir)
+void
+CopyAndSalvage(register struct DirSummary *dir)
{
struct VnodeDiskObject vnode;
struct VnodeClassInfo *vcp = &VnodeClassInfo[vLarge];
Inode oldinode, newinode;
DirHandle newdir;
- register afs_int32 code;
- afs_int32 parentUnique= 1;
+ FdHandle_t *fdP;
+ afs_int32 code;
+ afs_sfsize_t lcode;
+ afs_int32 parentUnique = 1;
struct VnodeEssence *vnodeEssence;
+ afs_fsize_t length;
if (Testing)
return;
Log("Salvaging directory %u...\n", dir->vnodeNumber);
- code = IH_IREAD(vnodeInfo[vLarge].handle,
- vnodeIndexOffset(vcp, dir->vnodeNumber),
- (char*)&vnode, sizeof (vnode));
- assert(code == sizeof (vnode));
+ lcode =
+ IH_IREAD(vnodeInfo[vLarge].handle,
+ vnodeIndexOffset(vcp, dir->vnodeNumber), (char *)&vnode,
+ sizeof(vnode));
+ assert(lcode == sizeof(vnode));
oldinode = VNDISK_GET_INO(&vnode);
/* Increment the version number by a whole lot to avoid problems with
* clients that were promised new version numbers--but the file server
* crashed before the versions were written to disk.
*/
- newinode = IH_CREATE(dir->ds_linkH, fileSysDevice, fileSysPath, 0,
- dir->rwVid, dir->vnodeNumber,
- vnode.uniquifier,
- vnode.dataVersion += 200);
+ newinode =
+ IH_CREATE(dir->ds_linkH, fileSysDevice, fileSysPath, 0, dir->rwVid,
+ dir->vnodeNumber, vnode.uniquifier, vnode.dataVersion +=
+ 200);
assert(VALID_INO(newinode));
SetSalvageDirHandle(&newdir, dir->rwVid, fileSysDevice, newinode);
* The uniquifier for .. might be set to a bogus value of 1 and
* the salvager will later clean it up.
*/
- if ( vnode.parent && (vnodeEssence = CheckVnodeNumber(vnode.parent)) ) {
- parentUnique = (vnodeEssence->unique ? vnodeEssence->unique : 1);
- }
- code = DirSalvage(&dir->dirHandle, &newdir,
- dir->vnodeNumber, vnode.uniquifier,
- (vnode.parent?vnode.parent:dir->vnodeNumber),
- parentUnique);
- if (code == 0) code = DFlush();
+ if (vnode.parent && (vnodeEssence = CheckVnodeNumber(vnode.parent))) {
+ parentUnique = (vnodeEssence->unique ? vnodeEssence->unique : 1);
+ }
+ code =
+ DirSalvage(&dir->dirHandle, &newdir, dir->vnodeNumber,
+ vnode.uniquifier,
+ (vnode.parent ? vnode.parent : dir->vnodeNumber),
+ parentUnique);
+ if (code == 0)
+ code = DFlush();
if (code) {
/* didn't really build the new directory properly, let's just give up. */
code = IH_DEC(dir->ds_linkH, newinode, dir->rwVid);
- assert(code == 0);
Log("Directory salvage returned code %d, continuing.\n", code);
+ if (code) {
+ Log("also failed to decrement link count on new inode");
+ }
assert(1 == 2);
}
Log("Checking the results of the directory salvage...\n");
}
vnode.cloned = 0;
VNDISK_SET_INO(&vnode, newinode);
- vnode.length = Length(&newdir);
- code = IH_IWRITE(vnodeInfo[vLarge].handle,
- vnodeIndexOffset(vcp, dir->vnodeNumber),
- (char*)&vnode, sizeof (vnode));
- assert(code == sizeof (vnode));
+ length = Length(&newdir);
+ VNDISK_SET_LEN(&vnode, length);
+ lcode =
+ IH_IWRITE(vnodeInfo[vLarge].handle,
+ vnodeIndexOffset(vcp, dir->vnodeNumber), (char *)&vnode,
+ sizeof(vnode));
+ assert(lcode == sizeof(vnode));
+#if 0
#ifdef AFS_NT40_ENV
nt_sync(fileSysDevice);
#else
- sync(); /* this is slow, but hopefully rarely called. We don't have
- * an open FD on the file itself to fsync.
- */
+ sync(); /* this is slow, but hopefully rarely called. We don't have
+ * an open FD on the file itself to fsync.
+ */
+#endif
+#else
+ vnodeInfo[vLarge].handle->ih_synced = 1;
#endif
+ /* make sure old directory file is really closed */
+ fdP = IH_OPEN(dir->dirHandle.dirh_handle);
+ FDH_REALLYCLOSE(fdP);
+
code = IH_DEC(dir->ds_linkH, oldinode, dir->rwVid);
assert(code == 0);
dir->dirHandle = newdir;
}
-void JudgeEntry(struct DirSummary *dir, char *name, VnodeId vnodeNumber,
- Unique unique)
+int
+JudgeEntry(void *dirVal, char *name, afs_int32 vnodeNumber,
+ afs_int32 unique)
{
+ struct DirSummary *dir = (struct DirSummary *)dirVal;
struct VnodeEssence *vnodeEssence;
afs_int32 dirOrphaned, todelete;
vnodeEssence = CheckVnodeNumber(vnodeNumber);
if (vnodeEssence == NULL) {
if (!Showmode) {
- Log("dir vnode %d: invalid entry deleted: %s/%s (vnode %d, unique %d)\n",
- dir->vnodeNumber, dir->name?dir->name:"??",
- name, vnodeNumber, unique);
+ Log("dir vnode %u: invalid entry deleted: %s/%s (vnode %u, unique %u)\n", dir->vnodeNumber, dir->name ? dir->name : "??", name, vnodeNumber, unique);
}
if (!Testing) {
CopyOnWrite(dir);
- assert(Delete(&dir->dirHandle, name) == 0)
- }
- return;
+ assert(Delete(&dir->dirHandle, name) == 0);
+ }
+ return 0;
}
-
#ifdef AFS_AIX_ENV
+#ifndef AFS_NAMEI_ENV
/* On AIX machines, don't allow entries to point to inode 0. That is a special
* mount inode for the partition. If this inode were deleted, it would crash
* the machine.
*/
if (vnodeEssence->InodeNumber == 0) {
- Log("dir vnode %d: invalid entry: %s/%s has no inode (vnode %d, unique %d)%s\n",
- dir->vnodeNumber, (dir->name?dir->name:"??"),
- name, vnodeNumber, unique,
- (Testing?"-- would have deleted":" -- deleted"));
- if (!Testing) {
- CopyOnWrite(dir);
- assert(Delete(&dir->dirHandle, name) == 0);
- }
- return;
- }
-#endif
-
- if (!(vnodeNumber & 1) && !Showmode &&
- !(vnodeEssence->count || vnodeEssence->unique || vnodeEssence->modeBits)) {
- Log("dir vnode %d: invalid entry: %s/%s (vnode %d, unique %d)%s\n",
- dir->vnodeNumber, (dir->name?dir->name:"??"),
- name, vnodeNumber, unique,
- ((!unique)?(Testing?"-- would have deleted":" -- deleted"):""));
- if (!unique) {
- if (!Testing) {
- CopyOnWrite(dir);
- assert(Delete(&dir->dirHandle, name) == 0);
- }
- return;
- }
+ Log("dir vnode %d: invalid entry: %s/%s has no inode (vnode %d, unique %d)%s\n", dir->vnodeNumber, (dir->name ? dir->name : "??"), name, vnodeNumber, unique, (Testing ? "-- would have deleted" : " -- deleted"));
+ if (!Testing) {
+ CopyOnWrite(dir);
+ assert(Delete(&dir->dirHandle, name) == 0);
+ }
+ return 0;
+ }
+#endif
+#endif
+
+ if (!(vnodeNumber & 1) && !Showmode
+ && !(vnodeEssence->count || vnodeEssence->unique
+ || vnodeEssence->modeBits)) {
+ Log("dir vnode %u: invalid entry: %s/%s (vnode %u, unique %u)%s\n",
+ dir->vnodeNumber, (dir->name ? dir->name : "??"), name,
+ vnodeNumber, unique,
+ ((!unique) ? (Testing ? "-- would have deleted" : " -- deleted") :
+ ""));
+ if (!unique) {
+ if (!Testing) {
+ CopyOnWrite(dir);
+ assert(Delete(&dir->dirHandle, name) == 0);
+ }
+ return 0;
+ }
}
/* Check if the Uniquifiers match. If not, change the directory entry
* so its unique matches the vnode unique. Delete if the unique is zero
* or if the directory is orphaned.
*/
- if (!IUnique(vnodeEssence->unique) ||
- (IUnique(vnodeEssence->unique) != IUnique(unique)) ) {
- if ( !IUnique(vnodeEssence->unique) &&
- ((strcmp(name,"..")==0) || (strcmp(name,".")==0)) ) {
- /* This is an orphaned directory. Don't delete the . or ..
- * entry. Otherwise, it will get created in the next
- * salvage and deleted again here. So Just skip it.
- */
- return;
+ if (!vnodeEssence->unique || (vnodeEssence->unique) != unique) {
+ if (!vnodeEssence->unique
+ && ((strcmp(name, "..") == 0) || (strcmp(name, ".") == 0))) {
+ /* This is an orphaned directory. Don't delete the . or ..
+ * entry. Otherwise, it will get created in the next
+ * salvage and deleted again here. So Just skip it.
+ */
+ return 0;
}
-
+
todelete = ((!vnodeEssence->unique || dirOrphaned) ? 1 : 0);
if (!Showmode) {
- Log("dir vnode %d: %s/%s (vnode %d): unique changed from %d to %d %s\n",
- dir->vnodeNumber, (dir->name ? dir->name : "??"),
- name, vnodeNumber, unique, vnodeEssence->unique,
- (!todelete?"":(Testing?"-- would have deleted":"-- deleted")));
+ Log("dir vnode %u: %s/%s (vnode %u): unique changed from %u to %u %s\n", dir->vnodeNumber, (dir->name ? dir->name : "??"), name, vnodeNumber, unique, vnodeEssence->unique, (!todelete ? "" : (Testing ? "-- would have deleted" : "-- deleted")));
}
if (!Testing) {
- ViceFid fid;
+ AFSFid fid;
fid.Vnode = vnodeNumber;
fid.Unique = vnodeEssence->unique;
CopyOnWrite(dir);
- assert(Delete(&dir->dirHandle, name) == 0)
+ assert(Delete(&dir->dirHandle, name) == 0);
if (!todelete)
- assert(Create(&dir->dirHandle, name, &fid) == 0)
+ assert(Create(&dir->dirHandle, name, &fid) == 0);
}
- if (todelete) return; /* no need to continue */
+ if (todelete)
+ return 0; /* no need to continue */
}
- if (strcmp(name,".") == 0) {
- if (dir->vnodeNumber != vnodeNumber || (IUnique(dir->unique) != IUnique(unique))) {
- ViceFid fid;
- if (!Showmode) Log("directory vnode %d.%d: bad '.' entry (was %d.%d); fixed\n",
- dir->vnodeNumber, dir->unique, vnodeNumber, unique);
+ if (strcmp(name, ".") == 0) {
+ if (dir->vnodeNumber != vnodeNumber || (dir->unique != unique)) {
+ AFSFid fid;
+ if (!Showmode)
+ Log("directory vnode %u.%u: bad '.' entry (was %u.%u); fixed\n", dir->vnodeNumber, dir->unique, vnodeNumber, unique);
if (!Testing) {
CopyOnWrite(dir);
- assert(Delete(&dir->dirHandle, ".") == 0)
+ assert(Delete(&dir->dirHandle, ".") == 0);
fid.Vnode = dir->vnodeNumber;
fid.Unique = dir->unique;
- assert(Create(&dir->dirHandle, ".", &fid) == 0)
+ assert(Create(&dir->dirHandle, ".", &fid) == 0);
}
- vnodeNumber = fid.Vnode; /* Get the new Essence */
+ vnodeNumber = fid.Vnode; /* Get the new Essence */
unique = fid.Unique;
vnodeEssence = CheckVnodeNumber(vnodeNumber);
}
dir->haveDot = 1;
- }
- else if (strcmp(name,"..") == 0) {
- ViceFid pa;
+ } else if (strcmp(name, "..") == 0) {
+ AFSFid pa;
if (dir->parent) {
struct VnodeEssence *dotdot;
pa.Vnode = dir->parent;
dotdot = CheckVnodeNumber(pa.Vnode);
- assert (dotdot != NULL); /* XXX Should not be assert */
+ assert(dotdot != NULL); /* XXX Should not be assert */
pa.Unique = dotdot->unique;
- }
- else {
+ } else {
pa.Vnode = dir->vnodeNumber;
pa.Unique = dir->unique;
}
- if ((pa.Vnode != vnodeNumber) || (IUnique(pa.Unique) != IUnique(unique))) {
- if (!Showmode) Log("directory vnode %d.%d: bad '..' entry (was %d.%d); fixed\n",
- dir->vnodeNumber, IUnique(dir->unique), vnodeNumber, IUnique(unique));
+ if ((pa.Vnode != vnodeNumber) || (pa.Unique != unique)) {
+ if (!Showmode)
+ Log("directory vnode %u.%u: bad '..' entry (was %u.%u); fixed\n", dir->vnodeNumber, dir->unique, vnodeNumber, unique);
if (!Testing) {
CopyOnWrite(dir);
assert(Delete(&dir->dirHandle, "..") == 0);
assert(Create(&dir->dirHandle, "..", &pa) == 0);
}
- vnodeNumber = pa.Vnode; /* Get the new Essence */
+ vnodeNumber = pa.Vnode; /* Get the new Essence */
unique = pa.Unique;
vnodeEssence = CheckVnodeNumber(vnodeNumber);
}
dir->haveDotDot = 1;
- } else if (strncmp(name,".__afs",6) == 0) {
- if (!Showmode) {
- Log("dir vnode %d: special old unlink-while-referenced file %s %s deleted (vnode %d)\n",
- dir->vnodeNumber, name, (Testing?"would have been":"is"), vnodeNumber);
+ } else if (strncmp(name, ".__afs", 6) == 0) {
+ if (!Showmode) {
+ Log("dir vnode %u: special old unlink-while-referenced file %s %s deleted (vnode %u)\n", dir->vnodeNumber, name, (Testing ? "would have been" : "is"), vnodeNumber);
}
- if (!Testing) {
+ if (!Testing) {
CopyOnWrite(dir);
- assert(Delete(&dir->dirHandle, name) == 0)
+ assert(Delete(&dir->dirHandle, name) == 0);
}
- vnodeEssence->claimed = 0; /* Not claimed: Orphaned */
- vnodeEssence->todelete = 1; /* Will later delete vnode and decr inode */
- return;
- }
- else {
+ vnodeEssence->claimed = 0; /* Not claimed: Orphaned */
+ vnodeEssence->todelete = 1; /* Will later delete vnode and decr inode */
+ return 0;
+ } else {
if (ShowSuid && (vnodeEssence->modeBits & 06000))
- Log("FOUND suid/sgid file: %s/%s (%u.%u %05o) author %u (vnode %u dir %u)\n", dir->name?dir->name:"??", name,
- vnodeEssence->owner, vnodeEssence->group, vnodeEssence->modeBits, vnodeEssence->author,vnodeNumber, dir->vnodeNumber);
- if (ShowMounts && (vnodeEssence->type == vSymlink) && !(vnodeEssence->modeBits & 0111)) {
- int code, size;
- char buf[1024];
+ Log("FOUND suid/sgid file: %s/%s (%u.%u %05o) author %u (vnode %u dir %u)\n", dir->name ? dir->name : "??", name, vnodeEssence->owner, vnodeEssence->group, vnodeEssence->modeBits, vnodeEssence->author, vnodeNumber, dir->vnodeNumber);
+ if (/* ShowMounts && */ (vnodeEssence->type == vSymlink)
+ && !(vnodeEssence->modeBits & 0111)) {
+ int code, size;
+ char buf[1025];
IHandle_t *ihP;
FdHandle_t *fdP;
IH_INIT(ihP, fileSysDevice, dir->dirHandle.dirh_handle->ih_vid,
vnodeEssence->InodeNumber);
fdP = IH_OPEN(ihP);
- assert(fdP != NULL);
+ if (fdP == NULL) {
+ Log("ERROR %s could not open mount point vnode %u\n", dir->vname, vnodeNumber);
+ IH_RELEASE(ihP);
+ return 0;
+ }
size = FDH_SIZE(fdP);
- assert(size != -1);
- memset(buf, 0, 1024);
- if (size > 1024) size = 1024;
+ if (size < 0) {
+ Log("ERROR %s mount point has invalid size %d, vnode %u\n", dir->vname, size, vnodeNumber);
+ FDH_REALLYCLOSE(fdP);
+ IH_RELEASE(ihP);
+ return 0;
+ }
+
+ if (size > 1024)
+ size = 1024;
code = FDH_READ(fdP, buf, size);
- assert(code == size);
- Log("In volume %u (%s) found mountpoint %s/%s to '%s'\n",
- dir->dirHandle.dirh_handle->ih_vid, dir->vname,
- dir->name?dir->name:"??", name, buf);
+ if (code == size) {
+ buf[size] = '\0';
+ if ( (*buf != '#' && *buf != '%') || buf[strlen(buf)-1] != '.' ) {
+ Log("Volume %u (%s) mount point %s/%s to '%s' invalid, %s to symbolic link\n",
+ dir->dirHandle.dirh_handle->ih_vid, dir->vname, dir->name ? dir->name : "??", name, buf,
+ Testing ? "would convert" : "converted");
+ vnodeEssence->modeBits |= 0111;
+ vnodeEssence->changed = 1;
+ } else if (ShowMounts) Log("In volume %u (%s) found mountpoint %s/%s to '%s'\n",
+ dir->dirHandle.dirh_handle->ih_vid, dir->vname,
+ dir->name ? dir->name : "??", name, buf);
+ } else {
+ Log("Volume %s cound not read mount point vnode %u size %d code %d\n",
+ dir->vname, vnodeNumber, size, code);
+ }
FDH_REALLYCLOSE(fdP);
IH_RELEASE(ihP);
}
- if (ShowRootFiles && vnodeEssence->owner==0 && vnodeNumber != 1)
- Log("FOUND root file: %s/%s (%u.%u %05o) author %u (vnode %u dir %u)\n", dir->name?dir->name:"??", name,
- vnodeEssence->owner, vnodeEssence->group, vnodeEssence->modeBits, vnodeEssence->author, vnodeNumber, dir->vnodeNumber);
- if (vnodeIdToClass(vnodeNumber) == vLarge && vnodeEssence->name == (char *)0) {
+ if (ShowRootFiles && vnodeEssence->owner == 0 && vnodeNumber != 1)
+ Log("FOUND root file: %s/%s (%u.%u %05o) author %u (vnode %u dir %u)\n", dir->name ? dir->name : "??", name, vnodeEssence->owner, vnodeEssence->group, vnodeEssence->modeBits, vnodeEssence->author, vnodeNumber, dir->vnodeNumber);
+ if (vnodeIdToClass(vnodeNumber) == vLarge
+ && vnodeEssence->name == NULL) {
char *n;
- if (n = (char*)malloc(strlen(name)+1))
+ if ((n = (char *)malloc(strlen(name) + 1)))
strcpy(n, name);
vnodeEssence->name = n;
}
* from different directories.
*/
if (vnodeEssence->parent != dir->vnodeNumber) {
- if (!vnodeEssence->claimed && !dirOrphaned) {
- /* Vnode does not point back to this directory.
- * Orphaned dirs cannot claim a file (it may belong to
- * another non-orphaned dir).
- */
- if (!Showmode) {
- Log("dir vnode %d: %s/%s (vnode %d, unique %d) -- parent vnode %schanged from %d to %d\n",
- dir->vnodeNumber, (dir->name ? dir->name : "??"), name,
- vnodeNumber, unique, (Testing?"would have been ":""),
- vnodeEssence->parent, dir->vnodeNumber);
- }
- vnodeEssence->parent = dir->vnodeNumber;
- vnodeEssence->changed = 1;
- } else {
- /* Vnode was claimed by another directory */
- if (!Showmode) {
- if (dirOrphaned) {
- Log("dir vnode %d: %s/%s parent vnode is %d (vnode %d, unique %d) -- %sdeleted\n",
- dir->vnodeNumber, (dir->name ? dir->name : "??"), name,
- vnodeEssence->parent, vnodeNumber, unique,
- (Testing?"would have been ":""));
- } else {
- Log("dir vnode %d: %s/%s already claimed by directory vnode %d (vnode %d, unique %d) -- %sdeleted\n",
- dir->vnodeNumber, (dir->name ? dir->name : "??"), name,
- vnodeEssence->parent, vnodeNumber, unique,
- (Testing?"would have been ":""));
- }
- }
- if (!Testing) {
- CopyOnWrite(dir);
- assert(Delete(&dir->dirHandle, name) == 0);
- }
- return;
- }
+ if (!vnodeEssence->claimed && !dirOrphaned && vnodeNumber != 1) {
+ /* Vnode does not point back to this directory.
+ * Orphaned dirs cannot claim a file (it may belong to
+ * another non-orphaned dir).
+ */
+ if (!Showmode) {
+ Log("dir vnode %u: %s/%s (vnode %u, unique %u) -- parent vnode %schanged from %u to %u\n", dir->vnodeNumber, (dir->name ? dir->name : "??"), name, vnodeNumber, unique, (Testing ? "would have been " : ""), vnodeEssence->parent, dir->vnodeNumber);
+ }
+ vnodeEssence->parent = dir->vnodeNumber;
+ vnodeEssence->changed = 1;
+ } else {
+ /* Vnode was claimed by another directory */
+ if (!Showmode) {
+ if (dirOrphaned) {
+ Log("dir vnode %u: %s/%s parent vnode is %u (vnode %u, unique %u) -- %sdeleted\n", dir->vnodeNumber, (dir->name ? dir->name : "??"), name, vnodeEssence->parent, vnodeNumber, unique, (Testing ? "would have been " : ""));
+ } else if (vnodeNumber == 1) {
+ Log("dir vnode %d: %s/%s is invalid (vnode %d, unique %d) -- %sdeleted\n", dir->vnodeNumber, (dir->name ? dir->name : "??"), name, vnodeNumber, unique, (Testing ? "would have been " : ""));
+ } else {
+ Log("dir vnode %u: %s/%s already claimed by directory vnode %u (vnode %u, unique %u) -- %sdeleted\n", dir->vnodeNumber, (dir->name ? dir->name : "??"), name, vnodeEssence->parent, vnodeNumber, unique, (Testing ? "would have been " : ""));
+ }
+ }
+ if (!Testing) {
+ CopyOnWrite(dir);
+ assert(Delete(&dir->dirHandle, name) == 0);
+ }
+ return 0;
+ }
}
/* This directory claims the vnode */
vnodeEssence->claimed = 1;
}
vnodeEssence->count--;
+ return 0;
}
-void DistilVnodeEssence(VolumeId rwVId, VnodeClass class, Inode ino,
- Unique *maxu)
+void
+DistilVnodeEssence(VolumeId rwVId, VnodeClass class, Inode ino, Unique * maxu)
{
register struct VnodeInfo *vip = &vnodeInfo[class];
struct VnodeClassInfo *vcp = &VnodeClassInfo[class];
char buf[SIZEOF_LARGEDISKVNODE];
- struct VnodeDiskObject *vnode = (struct VnodeDiskObject *) buf;
- int code;
- int size;
+ struct VnodeDiskObject *vnode = (struct VnodeDiskObject *)buf;
+ afs_sfsize_t size;
StreamHandle_t *file;
int vnodeIndex;
int nVnodes;
IH_INIT(vip->handle, fileSysDevice, rwVId, ino);
fdP = IH_OPEN(vip->handle);
- assert(fdP != NULL)
+ assert(fdP != NULL);
file = FDH_FDOPEN(fdP, "r+");
assert(file != NULL);
size = OS_SIZE(fdP->fd_fd);
assert(size != -1);
vip->nVnodes = (size / vcp->diskSize) - 1;
if (vip->nVnodes > 0) {
- assert((vip->nVnodes+1)*vcp->diskSize == size)
- assert(STREAM_SEEK(file, vcp->diskSize, 0) == 0)
+ assert((vip->nVnodes + 1) * vcp->diskSize == size);
+ assert(STREAM_SEEK(file, vcp->diskSize, 0) == 0);
assert((vip->vnodes = (struct VnodeEssence *)
- calloc(vip->nVnodes, sizeof(struct VnodeEssence))) != NULL)
+ calloc(vip->nVnodes, sizeof(struct VnodeEssence))) != NULL);
if (class == vLarge) {
assert((vip->inodes = (Inode *)
- calloc(vip->nVnodes, sizeof (Inode))) != NULL)
- }
- else {
+ calloc(vip->nVnodes, sizeof(Inode))) != NULL);
+ } else {
vip->inodes = NULL;
}
- }
- else {
+ } else {
vip->nVnodes = 0;
vip->vnodes = NULL;
vip->inodes = NULL;
}
vip->volumeBlockCount = vip->nAllocatedVnodes = 0;
for (vnodeIndex = 0, nVnodes = vip->nVnodes;
- nVnodes && STREAM_READ(vnode, vcp->diskSize, 1, file) == 1;
- nVnodes--, vnodeIndex++) {
+ nVnodes && STREAM_READ(vnode, vcp->diskSize, 1, file) == 1;
+ nVnodes--, vnodeIndex++) {
if (vnode->type != vNull) {
register struct VnodeEssence *vep = &vip->vnodes[vnodeIndex];
+ afs_fsize_t vnodeLength;
vip->nAllocatedVnodes++;
vep->count = vnode->linkCount;
- vep->blockCount = nBlocks(vnode->length);
+ VNDISK_GET_LEN(vnodeLength, vnode);
+ vep->blockCount = nBlocks(vnodeLength);
vip->volumeBlockCount += vep->blockCount;
vep->parent = vnode->parent;
vep->unique = vnode->uniquifier;
if (*maxu < vnode->uniquifier)
- *maxu = vnode->uniquifier;
+ *maxu = vnode->uniquifier;
vep->modeBits = vnode->modeBits;
vep->InodeNumber = VNDISK_GET_INO(vnode);
vep->type = vnode->type;
vep->owner = vnode->owner;
vep->group = vnode->group;
if (vnode->type == vDirectory) {
- assert(class == vLarge)
- vip->inodes[vnodeIndex] = VNDISK_GET_INO(vnode);
+ if (class != vLarge) {
+ VnodeId vnodeNumber = bitNumberToVnodeNumber(vnodeIndex, class);
+ vip->nAllocatedVnodes--;
+ memset(vnode, 0, sizeof(vnode));
+ IH_IWRITE(vnodeInfo[vSmall].handle,
+ vnodeIndexOffset(vcp, vnodeNumber),
+ (char *)&vnode, sizeof(vnode));
+ VolumeChanged = 1;
+ } else
+ vip->inodes[vnodeIndex] = VNDISK_GET_INO(vnode);
}
}
- }
+ }
STREAM_CLOSE(file);
FDH_CLOSE(fdP);
}
-static char *GetDirName(vnode, vp, path)
- VnodeId vnode;
- struct VnodeEssence *vp;
- char *path;
+static char *
+GetDirName(VnodeId vnode, struct VnodeEssence *vp, char *path)
{
struct VnodeEssence *parentvp;
-
+
if (vnode == 1) {
strcpy(path, ".");
return path;
}
- if (vp->parent && vp->name && (parentvp = CheckVnodeNumber(vp->parent)) && GetDirName(vp->parent, parentvp, path)) {
+ if (vp->parent && vp->name && (parentvp = CheckVnodeNumber(vp->parent))
+ && GetDirName(vp->parent, parentvp, path)) {
strcat(path, "/");
strcat(path, vp->name);
return path;
/* To determine if a vnode is orhpaned or not, the vnode and all its parent
* vnodes must be "claimed". The vep->claimed flag is set in JudgeEntry().
*/
-static int IsVnodeOrphaned(vnode)
- VnodeId vnode;
+static int
+IsVnodeOrphaned(VnodeId vnode)
{
struct VnodeEssence *vep;
-
- if (vnode == 0) return(1); /* Vnode zero does not exist */
- if (vnode == 1) return(0); /* The root dir vnode is always claimed */
- vep = CheckVnodeNumber(vnode); /* Get the vnode essence */
- if (!vep || !vep->claimed) return(1); /* Vnode is not claimed - it is orphaned */
-
- return( IsVnodeOrphaned(vep->parent) );
+
+ if (vnode == 0)
+ return (1); /* Vnode zero does not exist */
+ if (vnode == 1)
+ return (0); /* The root dir vnode is always claimed */
+ vep = CheckVnodeNumber(vnode); /* Get the vnode essence */
+ if (!vep || !vep->claimed)
+ return (1); /* Vnode is not claimed - it is orphaned */
+
+ return (IsVnodeOrphaned(vep->parent));
}
-void SalvageDir(char *name, VolumeId rwVid, struct VnodeInfo *dirVnodeInfo,
- IHandle_t *alinkH, int i, struct DirSummary *rootdir,
- int *rootdirfound)
+void
+SalvageDir(char *name, VolumeId rwVid, struct VnodeInfo *dirVnodeInfo,
+ IHandle_t * alinkH, int i, struct DirSummary *rootdir,
+ int *rootdirfound)
{
static struct DirSummary dir;
static struct DirHandle dirHandle;
int dirok, code;
if (dirVnodeInfo->vnodes[i].salvaged)
- return; /* already salvaged */
+ return; /* already salvaged */
dir.rwVid = rwVid;
dirVnodeInfo->vnodes[i].salvaged = 1;
-
+
if (dirVnodeInfo->inodes[i] == 0)
- return; /* Not allocated to a directory */
+ return; /* Not allocated to a directory */
+
+ if (bitNumberToVnodeNumber(i, vLarge) == 1) {
+ if (dirVnodeInfo->vnodes[i].parent) {
+ Log("Bad parent, vnode 1; %s...\n",
+ (Testing ? "skipping" : "salvaging"));
+ dirVnodeInfo->vnodes[i].parent = 0;
+ dirVnodeInfo->vnodes[i].changed = 1;
+ }
+ } else {
+ parent = CheckVnodeNumber(dirVnodeInfo->vnodes[i].parent);
+ if (parent && parent->salvaged == 0)
+ SalvageDir(name, rwVid, dirVnodeInfo, alinkH,
+ vnodeIdToBitNumber(dirVnodeInfo->vnodes[i].parent),
+ rootdir, rootdirfound);
+ }
- parent = CheckVnodeNumber(dirVnodeInfo->vnodes[i].parent);
- if (parent && parent->salvaged == 0)
- SalvageDir(name, rwVid, dirVnodeInfo, alinkH,
- vnodeIdToBitNumber(dirVnodeInfo->vnodes[i].parent),
- rootdir, rootdirfound);
dir.vnodeNumber = bitNumberToVnodeNumber(i, vLarge);
dir.unique = dirVnodeInfo->vnodes[i].unique;
dir.copied = 0;
dir.parent = dirVnodeInfo->vnodes[i].parent;
dir.haveDot = dir.haveDotDot = 0;
dir.ds_linkH = alinkH;
- SetSalvageDirHandle(&dir.dirHandle, dir.rwVid, fileSysDevice, dirVnodeInfo->inodes[i]);
+ SetSalvageDirHandle(&dir.dirHandle, dir.rwVid, fileSysDevice,
+ dirVnodeInfo->inodes[i]);
dirok = ((RebuildDirs && !Testing) ? 0 : DirOK(&dir.dirHandle));
if (!dirok) {
if (!RebuildDirs) {
- Log("Directory bad, vnode %d; %s...\n",
- dir.vnodeNumber, (Testing ? "skipping" : "salvaging"));
+ Log("Directory bad, vnode %u; %s...\n", dir.vnodeNumber,
+ (Testing ? "skipping" : "salvaging"));
}
if (!Testing) {
- CopyAndSalvage(&dir);
- dirok = 1;
+ CopyAndSalvage(&dir);
+ dirok = 1;
}
}
dirHandle = dir.dirHandle;
- dir.name = GetDirName(bitNumberToVnodeNumber(i,vLarge), &dirVnodeInfo->vnodes[i], path);
-
+ dir.name =
+ GetDirName(bitNumberToVnodeNumber(i, vLarge),
+ &dirVnodeInfo->vnodes[i], path);
+
if (dirok) {
- /* If enumeration failed for random reasons, we will probably delete
- * too much stuff, so we guard against this instead.
- */
- assert(EnumerateDir(&dirHandle, JudgeEntry, &dir) == 0);
+ /* If enumeration failed for random reasons, we will probably delete
+ * too much stuff, so we guard against this instead.
+ */
+ assert(EnumerateDir(&dirHandle, JudgeEntry, &dir) == 0);
}
-
+
/* Delete the old directory if it was copied in order to salvage.
* CopyOnWrite has written the new inode # to the disk, but we still
* have the old one in our local structure here. Thus, we idec the
return;
}
-int SalvageVolume(register struct InodeSummary *rwIsp, IHandle_t *alinkH)
+/**
+ * Get a new FID that can be used to create a new file.
+ *
+ * @param[in] volHeader vol header for the volume
+ * @param[in] class what type of vnode we'll be creating (vLarge or vSmall)
+ * @param[out] afid the FID that we can use (only Vnode and Unique are set)
+ * @param[inout] maxunique max uniquifier for all vnodes in the volume;
+ * updated to the new max unique if we create a new
+ * vnode
+ */
+static void
+GetNewFID(VolumeDiskData *volHeader, VnodeClass class, AFSFid *afid,
+ Unique *maxunique)
+{
+ int i;
+ for (i = 0; i < vnodeInfo[class].nVnodes; i++) {
+ if (vnodeInfo[class].vnodes[i].type == vNull) {
+ break;
+ }
+ }
+ if (i == vnodeInfo[class].nVnodes) {
+ /* no free vnodes; make a new one */
+ vnodeInfo[class].nVnodes++;
+ vnodeInfo[class].vnodes = realloc(vnodeInfo[class].vnodes,
+ sizeof(struct VnodeEssence) * (i+1));
+ vnodeInfo[class].vnodes[i].type = vNull;
+ }
+
+ afid->Vnode = bitNumberToVnodeNumber(i, class);
+
+ if (volHeader->uniquifier < (*maxunique + 1)) {
+ /* header uniq is bad; it will get bumped by 2000 later */
+ afid->Unique = *maxunique + 1 + 2000;
+ (*maxunique)++;
+ } else {
+ /* header uniq seems okay; just use that */
+ afid->Unique = *maxunique = volHeader->uniquifier++;
+ }
+}
+
+/**
+ * Create a vnode for a README file explaining not to use a recreated-root vol.
+ *
+ * @param[in] volHeader vol header for the volume
+ * @param[in] alinkH ihandle for i/o for the volume
+ * @param[in] vid volume id
+ * @param[inout] maxunique max uniquifier for all vnodes in the volume;
+ * updated to the new max unique if we create a new
+ * vnode
+ * @param[out] afid FID for the new readme vnode
+ * @param[out] ainode the inode for the new readme file
+ *
+ * @return operation status
+ * @retval 0 success
+ * @retval -1 error
+ */
+static int
+CreateReadme(VolumeDiskData *volHeader, IHandle_t *alinkH,
+ VolumeId vid, Unique *maxunique, AFSFid *afid, Inode *ainode)
+{
+ Inode readmeinode;
+ struct VnodeDiskObject *rvnode = NULL;
+ afs_sfsize_t bytes;
+ IHandle_t *readmeH = NULL;
+ struct VnodeEssence *vep;
+ afs_fsize_t length;
+ time_t now = time(NULL);
+
+ /* Try to make the note brief, but informative. Only administrators should
+ * be able to read this file at first, so we can hopefully assume they
+ * know what AFS is, what a volume is, etc. */
+ char readme[] =
+"This volume has been salvaged, but has lost its original root directory.\n"
+"The root directory that exists now has been recreated from orphan files\n"
+"from the rest of the volume. This recreated root directory may interfere\n"
+"with old cached data on clients, and there is no way the salvager can\n"
+"reasonably prevent that. So, it is recommended that you do not continue to\n"
+"use this volume, but only copy the salvaged data to a new volume.\n"
+"Continuing to use this volume as it exists now may cause some clients to\n"
+"behave oddly when accessing this volume.\n"
+"\n\t -- Your friendly neighborhood OpenAFS salvager\n";
+ /* ^ the person reading this probably just lost some data, so they could
+ * use some cheering up. */
+
+ /* -1 for the trailing NUL */
+ length = sizeof(readme) - 1;
+
+ GetNewFID(volHeader, vSmall, afid, maxunique);
+
+ vep = &vnodeInfo[vSmall].vnodes[vnodeIdToBitNumber(afid->Vnode)];
+
+ /* create the inode and write the contents */
+ readmeinode = IH_CREATE(alinkH, fileSysDevice, fileSysPath, 0, vid,
+ afid->Vnode, afid->Unique, 1);
+ if (!VALID_INO(readmeinode)) {
+ Log("CreateReadme: readme IH_CREATE failed\n");
+ goto error;
+ }
+
+ IH_INIT(readmeH, fileSysDevice, vid, readmeinode);
+ bytes = IH_IWRITE(readmeH, 0, readme, length);
+ IH_RELEASE(readmeH);
+
+ if (bytes != length) {
+ Log("CreateReadme: IWRITE failed (%d/%d)\n", (int)bytes,
+ (int)sizeof(readme));
+ goto error;
+ }
+
+ /* create the vnode and write it out */
+ rvnode = malloc(SIZEOF_SMALLDISKVNODE);
+ if (!rvnode) {
+ Log("CreateRootDir: error alloc'ing memory\n");
+ goto error;
+ }
+
+ rvnode->type = vFile;
+ rvnode->cloned = 0;
+ rvnode->modeBits = 0777;
+ rvnode->linkCount = 1;
+ VNDISK_SET_LEN(rvnode, length);
+ rvnode->uniquifier = afid->Unique;
+ rvnode->dataVersion = 1;
+ VNDISK_SET_INO(rvnode, readmeinode);
+ rvnode->unixModifyTime = rvnode->serverModifyTime = now;
+ rvnode->author = 0;
+ rvnode->owner = 0;
+ rvnode->parent = 1;
+ rvnode->group = 0;
+ rvnode->vnodeMagic = VnodeClassInfo[vSmall].magic;
+
+ bytes = IH_IWRITE(vnodeInfo[vSmall].handle,
+ vnodeIndexOffset(&VnodeClassInfo[vSmall], afid->Vnode),
+ (char*)rvnode, SIZEOF_SMALLDISKVNODE);
+
+ if (bytes != SIZEOF_SMALLDISKVNODE) {
+ Log("CreateReadme: IH_IWRITE failed (%d/%d)\n", (int)bytes,
+ (int)SIZEOF_SMALLDISKVNODE);
+ goto error;
+ }
+
+ /* update VnodeEssence for new readme vnode */
+ vnodeInfo[vSmall].nAllocatedVnodes++;
+ vep->count = 0;
+ vep->blockCount = nBlocks(length);
+ vnodeInfo[vSmall].volumeBlockCount += vep->blockCount;
+ vep->parent = rvnode->parent;
+ vep->unique = rvnode->uniquifier;
+ vep->modeBits = rvnode->modeBits;
+ vep->InodeNumber = VNDISK_GET_INO(rvnode);
+ vep->type = rvnode->type;
+ vep->author = rvnode->author;
+ vep->owner = rvnode->owner;
+ vep->group = rvnode->group;
+
+ free(rvnode);
+ rvnode = NULL;
+
+ vep->claimed = 1;
+ vep->changed = 0;
+ vep->salvaged = 1;
+ vep->todelete = 0;
+
+ *ainode = readmeinode;
+
+ return 0;
+
+ error:
+ if (IH_DEC(alinkH, readmeinode, vid)) {
+ Log("CreateReadme (recovery): IH_DEC failed\n");
+ }
+
+ if (rvnode) {
+ free(rvnode);
+ rvnode = NULL;
+ }
+
+ return -1;
+}
+
+/**
+ * create a root dir for a volume that lacks one.
+ *
+ * @param[in] volHeader vol header for the volume
+ * @param[in] alinkH ihandle for disk access for this volume group
+ * @param[in] vid volume id we're dealing with
+ * @param[out] rootdir populated with info about the new root dir
+ * @param[inout] maxunique max uniquifier for all vnodes in the volume;
+ * updated to the new max unique if we create a new
+ * vnode
+ *
+ * @return operation status
+ * @retval 0 success
+ * @retval -1 error
+ */
+static int
+CreateRootDir(VolumeDiskData *volHeader, IHandle_t *alinkH, VolumeId vid,
+ struct DirSummary *rootdir, Unique *maxunique)
+{
+ FileVersion dv;
+ int decroot = 0, decreadme = 0;
+ AFSFid did, readmeid;
+ afs_fsize_t length;
+ Inode rootinode;
+ struct VnodeDiskObject *rootvnode;
+ struct acl_accessList *ACL;
+ Inode *ip;
+ afs_sfsize_t bytes;
+ struct VnodeEssence *vep;
+ Inode readmeinode;
+ time_t now = time(NULL);
+
+ if (!vnodeInfo[vLarge].vnodes && !vnodeInfo[vSmall].vnodes) {
+ Log("Not creating new root dir; volume appears to lack any vnodes\n");
+ goto error;
+ }
+
+ if (!vnodeInfo[vLarge].vnodes) {
+ /* We don't have any large vnodes in the volume; allocate room
+ * for one so we can recreate the root dir */
+ vnodeInfo[vLarge].nVnodes = 1;
+ vnodeInfo[vLarge].vnodes = calloc(1, sizeof(struct VnodeEssence));
+ vnodeInfo[vLarge].inodes = calloc(1, sizeof(Inode));
+
+ assert(vnodeInfo[vLarge].vnodes);
+ assert(vnodeInfo[vLarge].inodes);
+ }
+
+ vep = &vnodeInfo[vLarge].vnodes[vnodeIdToBitNumber(1)];
+ ip = &vnodeInfo[vLarge].inodes[vnodeIdToBitNumber(1)];
+ if (vep->type != vNull) {
+ Log("Not creating new root dir; existing vnode 1 is non-null\n");
+ goto error;
+ }
+
+ if (CreateReadme(volHeader, alinkH, vid, maxunique, &readmeid, &readmeinode)) {
+ goto error;
+ }
+ decreadme = 1;
+
+ /* set the DV to a very high number, so it is unlikely that we collide
+ * with a cached DV */
+ dv = 1 << 30;
+
+ rootinode = IH_CREATE(alinkH, fileSysDevice, fileSysPath, 0, vid, 1, 1, dv);
+ if (!VALID_INO(rootinode)) {
+ Log("CreateRootDir: IH_CREATE failed\n");
+ goto error;
+ }
+ decroot = 1;
+
+ SetSalvageDirHandle(&rootdir->dirHandle, vid, fileSysDevice, rootinode);
+ did.Volume = vid;
+ did.Vnode = 1;
+ did.Unique = 1;
+ if (MakeDir(&rootdir->dirHandle, (afs_int32*)&did, (afs_int32*)&did)) {
+ Log("CreateRootDir: MakeDir failed\n");
+ goto error;
+ }
+ if (Create(&rootdir->dirHandle, "README.ROOTDIR", &readmeid)) {
+ Log("CreateRootDir: Create failed\n");
+ goto error;
+ }
+ DFlush();
+ length = Length(&rootdir->dirHandle);
+ DZap((void *)&rootdir->dirHandle);
+
+ /* create the new root dir vnode */
+ rootvnode = malloc(SIZEOF_LARGEDISKVNODE);
+ if (!rootvnode) {
+ Log("CreateRootDir: malloc failed\n");
+ goto error;
+ }
+
+ /* only give 'rl' permissions to 'system:administrators'. We do this to
+ * try to catch the attention of an administrator, that they should not
+ * be writing to this directory or continue to use it. */
+ ACL = VVnodeDiskACL(rootvnode);
+ ACL->size = sizeof(struct acl_accessList);
+ ACL->version = ACL_ACLVERSION;
+ ACL->total = 1;
+ ACL->positive = 1;
+ ACL->negative = 0;
+ ACL->entries[0].id = -204; /* system:administrators */
+ ACL->entries[0].rights = PRSFS_READ | PRSFS_LOOKUP;
+
+ rootvnode->type = vDirectory;
+ rootvnode->cloned = 0;
+ rootvnode->modeBits = 0777;
+ rootvnode->linkCount = 2;
+ VNDISK_SET_LEN(rootvnode, length);
+ rootvnode->uniquifier = 1;
+ rootvnode->dataVersion = dv;
+ VNDISK_SET_INO(rootvnode, rootinode);
+ rootvnode->unixModifyTime = rootvnode->serverModifyTime = now;
+ rootvnode->author = 0;
+ rootvnode->owner = 0;
+ rootvnode->parent = 0;
+ rootvnode->group = 0;
+ rootvnode->vnodeMagic = VnodeClassInfo[vLarge].magic;
+
+ /* write it out to disk */
+ bytes = IH_IWRITE(vnodeInfo[vLarge].handle,
+ vnodeIndexOffset(&VnodeClassInfo[vLarge], 1),
+ (char*)rootvnode, SIZEOF_LARGEDISKVNODE);
+
+ if (bytes != SIZEOF_LARGEDISKVNODE) {
+ /* just cast to int and don't worry about printing real 64-bit ints;
+ * a large disk vnode isn't anywhere near the 32-bit limit */
+ Log("CreateRootDir: IH_IWRITE failed (%d/%d)\n", (int)bytes,
+ (int)SIZEOF_LARGEDISKVNODE);
+ goto error;
+ }
+
+ /* update VnodeEssence for the new root vnode */
+ vnodeInfo[vLarge].nAllocatedVnodes++;
+ vep->count = 0;
+ vep->blockCount = nBlocks(length);
+ vnodeInfo[vLarge].volumeBlockCount += vep->blockCount;
+ vep->parent = rootvnode->parent;
+ vep->unique = rootvnode->uniquifier;
+ vep->modeBits = rootvnode->modeBits;
+ vep->InodeNumber = VNDISK_GET_INO(rootvnode);
+ vep->type = rootvnode->type;
+ vep->author = rootvnode->author;
+ vep->owner = rootvnode->owner;
+ vep->group = rootvnode->group;
+
+ free(rootvnode);
+ rootvnode = NULL;
+
+ vep->claimed = 0;
+ vep->changed = 0;
+ vep->salvaged = 1;
+ vep->todelete = 0;
+
+ /* update DirSummary for the new root vnode */
+ rootdir->vnodeNumber = 1;
+ rootdir->unique = 1;
+ rootdir->haveDot = 1;
+ rootdir->haveDotDot = 1;
+ rootdir->rwVid = vid;
+ rootdir->copied = 0;
+ rootdir->parent = 0;
+ rootdir->name = strdup(".");
+ rootdir->vname = volHeader->name;
+ rootdir->ds_linkH = alinkH;
+
+ *ip = rootinode;
+
+ return 0;
+
+ error:
+ if (decroot && IH_DEC(alinkH, rootinode, vid)) {
+ Log("CreateRootDir (recovery): IH_DEC (root) failed\n");
+ }
+ if (decreadme && IH_DEC(alinkH, readmeinode, vid)) {
+ Log("CreateRootDir (recovery): IH_DEC (readme) failed\n");
+ }
+ if (rootvnode) {
+ free(rootvnode);
+ rootvnode = NULL;
+ }
+ return -1;
+}
+
+int
+SalvageVolume(register struct InodeSummary *rwIsp, IHandle_t * alinkH)
{
/* This routine, for now, will only be called for read-write volumes */
int i, j, code;
VolumeDiskData volHeader;
VolumeId vid;
int orphaned, rootdirfound = 0;
- Unique maxunique = 0; /* the maxUniquifier from the vnodes */
- afs_int32 ofiles=0, oblocks=0; /* Number of orphaned files/blocks */
+ Unique maxunique = 0; /* the maxUniquifier from the vnodes */
+ afs_int32 ofiles = 0, oblocks = 0; /* Number of orphaned files/blocks */
struct VnodeEssence *vep;
afs_int32 v, pv;
IHandle_t *h;
- int nBytes;
- ViceFid pa;
+ afs_sfsize_t nBytes;
+ AFSFid pa;
VnodeId LFVnode, ThisVnode;
- Unique LFUnique, ThisUnique;
+ Unique LFUnique, ThisUnique;
char npath[128];
+ int newrootdir = 0;
vid = rwIsp->volSummary->header.id;
IH_INIT(h, fileSysDevice, vid, rwIsp->volSummary->header.volumeInfo);
- nBytes = IH_IREAD(h, 0, (char*)&volHeader, sizeof(volHeader));
+ nBytes = IH_IREAD(h, 0, (char *)&volHeader, sizeof(volHeader));
assert(nBytes == sizeof(volHeader));
assert(volHeader.stamp.magic == VOLUMEINFOMAGIC);
- assert (volHeader.destroyMe != DESTROY_ME);
+ assert(volHeader.destroyMe != DESTROY_ME);
/* (should not have gotten this far with DESTROY_ME flag still set!) */
- DistilVnodeEssence(vid, vLarge,
- rwIsp->volSummary->header.largeVnodeIndex,
+ DistilVnodeEssence(vid, vLarge, rwIsp->volSummary->header.largeVnodeIndex,
&maxunique);
- DistilVnodeEssence(vid, vSmall,
- rwIsp->volSummary->header.smallVnodeIndex,
+ DistilVnodeEssence(vid, vSmall, rwIsp->volSummary->header.smallVnodeIndex,
&maxunique);
dirVnodeInfo = &vnodeInfo[vLarge];
for (i = 0; i < dirVnodeInfo->nVnodes; i++) {
- SalvageDir(volHeader.name, vid, dirVnodeInfo, alinkH, i,
- &rootdir, &rootdirfound);
+ SalvageDir(volHeader.name, vid, dirVnodeInfo, alinkH, i, &rootdir,
+ &rootdirfound);
}
+#ifdef AFS_NT40_ENV
+ nt_sync(fileSysDevice);
+#else
+ sync(); /* This used to be done lower level, for every dir */
+#endif
if (Showmode) {
IH_RELEASE(h);
return 0;
}
+ if (!rootdirfound && (orphans == ORPH_ATTACH) && !Testing) {
+
+ Log("Cannot find root directory for volume %lu; attempting to create "
+ "a new one\n", afs_printable_uint32_lu(vid));
+
+ code = CreateRootDir(&volHeader, alinkH, vid, &rootdir, &maxunique);
+ if (code == 0) {
+ rootdirfound = 1;
+ newrootdir = 1;
+ }
+ }
+
/* Parse each vnode looking for orphaned vnodes and
* connect them to the tree as orphaned (if requested).
*/
oldrootdir = rootdir;
- for (class=0; class < nVNODECLASSES; class++) {
- for (v=0; v < vnodeInfo[class].nVnodes; v++) {
- vep = &(vnodeInfo[class].vnodes[v]);
- ThisVnode = bitNumberToVnodeNumber(v, class);
- ThisUnique = vep->unique;
-
- if ((vep->type == 0) || vep->claimed || ThisVnode == 1)
- continue; /* Ignore unused, claimed, and root vnodes */
-
- /* This vnode is orphaned. If it is a directory vnode, then the '..'
- * entry in this vnode had incremented the parent link count (In
- * JudgeEntry()). We need to go to the parent and decrement that
- * link count. But if the parent's unique is zero, then the parent
- * link count was not incremented in JudgeEntry().
- */
- if (class == vLarge) { /* directory vnode */
- pv = vnodeIdToBitNumber(vep->parent);
- if (IUnique(vnodeInfo[vLarge].vnodes[pv].unique) != 0)
- vnodeInfo[vLarge].vnodes[pv].count++;
- }
-
- if (!rootdirfound)
- continue; /* If no rootdir, can't attach orphaned files */
-
- /* Here we attach orphaned files and directories into the
- * root directory, LVVnode, making sure link counts stay correct.
- */
- if ((orphans == ORPH_ATTACH) && !vep->todelete && !Testing) {
- LFVnode = rootdir.vnodeNumber; /* Lost+Found vnode number */
- LFUnique = rootdir.unique; /* Lost+Found uniquifier */
-
- /* Update this orphaned vnode's info. Its parent info and
- * link count (do for orphaned directories and files).
- */
- vep->parent = LFVnode; /* Parent is the root dir */
- vep->unique = LFUnique;
- vep->changed = 1;
- vep->claimed = 1;
- vep->count--; /* Inc link count (root dir will pt to it) */
-
- /* If this orphaned vnode is a directory, change '..'.
- * The name of the orphaned dir/file is unknown, so we
- * build a unique name. No need to CopyOnWrite the directory
- * since it is not connected to tree in BK or RO volume and
- * won't be visible there.
- */
- if (class == vLarge) {
- ViceFid pa;
- DirHandle dh;
-
- /* Remove and recreate the ".." entry in this orphaned directory */
- SetSalvageDirHandle(&dh,vid,fileSysDevice,vnodeInfo[class].inodes[v]);
- pa.Vnode = LFVnode;
- pa.Unique = LFUnique;
- assert(Delete(&dh, "..") == 0);
- assert(Create(&dh, "..", &pa) == 0);
-
- /* The original parent's link count was decremented above.
- * Here we increment the new parent's link count.
+ for (class = 0; class < nVNODECLASSES; class++) {
+ for (v = 0; v < vnodeInfo[class].nVnodes; v++) {
+ vep = &(vnodeInfo[class].vnodes[v]);
+ ThisVnode = bitNumberToVnodeNumber(v, class);
+ ThisUnique = vep->unique;
+
+ if ((vep->type == 0) || vep->claimed || ThisVnode == 1)
+ continue; /* Ignore unused, claimed, and root vnodes */
+
+ /* This vnode is orphaned. If it is a directory vnode, then the '..'
+ * entry in this vnode had incremented the parent link count (In
+ * JudgeEntry()). We need to go to the parent and decrement that
+ * link count. But if the parent's unique is zero, then the parent
+ * link count was not incremented in JudgeEntry().
+ */
+ if (class == vLarge) { /* directory vnode */
+ pv = vnodeIdToBitNumber(vep->parent);
+ if (vnodeInfo[vLarge].vnodes[pv].unique != 0) {
+ if (vep->parent == 1 && newrootdir) {
+ /* this vnode's parent was the volume root, and
+ * we just created the volume root. So, the parent
+ * dir didn't exist during JudgeEntry, so the link
+ * count was not inc'd there, so don't dec it here.
+ */
+
+ /* noop */
+
+ } else {
+ vnodeInfo[vLarge].vnodes[pv].count++;
+ }
+ }
+ }
+
+ if (!rootdirfound)
+ continue; /* If no rootdir, can't attach orphaned files */
+
+ /* Here we attach orphaned files and directories into the
+ * root directory, LVVnode, making sure link counts stay correct.
+ */
+ if ((orphans == ORPH_ATTACH) && !vep->todelete && !Testing) {
+ LFVnode = rootdir.vnodeNumber; /* Lost+Found vnode number */
+ LFUnique = rootdir.unique; /* Lost+Found uniquifier */
+
+ /* Update this orphaned vnode's info. Its parent info and
+ * link count (do for orphaned directories and files).
+ */
+ vep->parent = LFVnode; /* Parent is the root dir */
+ vep->unique = LFUnique;
+ vep->changed = 1;
+ vep->claimed = 1;
+ vep->count--; /* Inc link count (root dir will pt to it) */
+
+ /* If this orphaned vnode is a directory, change '..'.
+ * The name of the orphaned dir/file is unknown, so we
+ * build a unique name. No need to CopyOnWrite the directory
+ * since it is not connected to tree in BK or RO volume and
+ * won't be visible there.
+ */
+ if (class == vLarge) {
+ AFSFid pa;
+ DirHandle dh;
+
+ /* Remove and recreate the ".." entry in this orphaned directory */
+ SetSalvageDirHandle(&dh, vid, fileSysDevice,
+ vnodeInfo[class].inodes[v]);
+ pa.Vnode = LFVnode;
+ pa.Unique = LFUnique;
+ assert(Delete(&dh, "..") == 0);
+ assert(Create(&dh, "..", &pa) == 0);
+
+ /* The original parent's link count was decremented above.
+ * Here we increment the new parent's link count.
+ */
+ pv = vnodeIdToBitNumber(LFVnode);
+ vnodeInfo[vLarge].vnodes[pv].count--;
+
+ }
+
+ /* Go to the root dir and add this entry. The link count of the
+ * root dir was incremented when ".." was created. Try 10 times.
*/
- pv = vnodeIdToBitNumber(LFVnode);
- vnodeInfo[vLarge].vnodes[pv].count--;
-
- }
-
- /* Go to the root dir and add this entry. The link count of the
- * root dir was incremented when ".." was created. Try 10 times.
- */
- for (j=0; j<10; j++) {
- pa.Vnode = ThisVnode;
- pa.Unique = ThisUnique;
-
- sprintf(npath, "%s.%d.%d",
- ((class == vLarge)?"__ORPHANDIR__":"__ORPHANFILE__"),
- ThisVnode, ThisUnique);
-
- CopyOnWrite(&rootdir);
- code = Create(&rootdir.dirHandle, npath, &pa);
- if (!code) break;
-
- ThisUnique += 50; /* Try creating a different file */
- }
- assert(code == 0);
- Log("Attaching orphaned %s to volume's root dir as %s\n",
- ((class == vLarge)?"directory":"file"), npath);
- }
- } /* for each vnode in the class */
- } /* for each class of vnode */
+ for (j = 0; j < 10; j++) {
+ pa.Vnode = ThisVnode;
+ pa.Unique = ThisUnique;
+
+ (void)afs_snprintf(npath, sizeof npath, "%s.%u.%u",
+ ((class ==
+ vLarge) ? "__ORPHANDIR__" :
+ "__ORPHANFILE__"), ThisVnode,
+ ThisUnique);
+
+ CopyOnWrite(&rootdir);
+ code = Create(&rootdir.dirHandle, npath, &pa);
+ if (!code)
+ break;
+
+ ThisUnique += 50; /* Try creating a different file */
+ }
+ assert(code == 0);
+ Log("Attaching orphaned %s to volume's root dir as %s\n",
+ ((class == vLarge) ? "directory" : "file"), npath);
+ }
+ } /* for each vnode in the class */
+ } /* for each class of vnode */
/* Delete the old rootinode directory if the rootdir was CopyOnWrite */
DFlush();
if (!oldrootdir.copied && rootdir.copied) {
- code = IH_DEC(oldrootdir.ds_linkH, oldrootdir.dirHandle.dirh_inode, oldrootdir.rwVid);
- assert(code == 0);
- /* dirVnodeInfo->inodes[?] is not updated with new inode number */
+ code =
+ IH_DEC(oldrootdir.ds_linkH, oldrootdir.dirHandle.dirh_inode,
+ oldrootdir.rwVid);
+ assert(code == 0);
+ /* dirVnodeInfo->inodes[?] is not updated with new inode number */
}
- DFlush(); /* Flush the changes */
+ DFlush(); /* Flush the changes */
if (!rootdirfound && (orphans == ORPH_ATTACH)) {
- Log("Cannot attach orphaned files and directories: Root directory not found\n");
- orphans = ORPH_IGNORE;
+ Log("Cannot attach orphaned files and directories: Root directory not found\n");
+ orphans = ORPH_IGNORE;
}
/* Write out all changed vnodes. Orphaned files and directories
* will get removed here also (if requested).
*/
- for (class = 0; class < nVNODECLASSES; class++){
+ for (class = 0; class < nVNODECLASSES; class++) {
int nVnodes = vnodeInfo[class].nVnodes;
struct VnodeClassInfo *vcp = &VnodeClassInfo[class];
struct VnodeEssence *vnodes = vnodeInfo[class].vnodes;
FilesInVolume += vnodeInfo[class].nAllocatedVnodes;
BlocksInVolume += vnodeInfo[class].volumeBlockCount;
- for (i = 0; i<nVnodes; i++) {
+ for (i = 0; i < nVnodes; i++) {
register struct VnodeEssence *vnp = &vnodes[i];
- VnodeId vnodeNumber = bitNumberToVnodeNumber(i,class);
+ VnodeId vnodeNumber = bitNumberToVnodeNumber(i, class);
/* If the vnode is good but is unclaimed (not listed in
* any directory entries), then it is orphaned.
*/
orphaned = -1;
- if ((vnp->type != 0) && (orphaned=IsVnodeOrphaned(vnodeNumber))) {
- vnp->claimed = 0; /* Makes IsVnodeOrphaned calls faster */
- vnp->changed = 1;
+ if ((vnp->type != 0) && (orphaned = IsVnodeOrphaned(vnodeNumber))) {
+ vnp->claimed = 0; /* Makes IsVnodeOrphaned calls faster */
+ vnp->changed = 1;
}
if (vnp->changed || vnp->count) {
int oldCount;
int code;
- nBytes = IH_IREAD(vnodeInfo[class].handle,
- vnodeIndexOffset(vcp, vnodeNumber),
- (char*)&vnode, sizeof (vnode));
+ nBytes =
+ IH_IREAD(vnodeInfo[class].handle,
+ vnodeIndexOffset(vcp, vnodeNumber),
+ (char *)&vnode, sizeof(vnode));
assert(nBytes == sizeof(vnode));
vnode.parent = vnp->parent;
vnode.linkCount = vnode.linkCount - vnp->count;
if (orphaned == -1)
- orphaned = IsVnodeOrphaned(vnodeNumber);
+ orphaned = IsVnodeOrphaned(vnodeNumber);
if (orphaned) {
if (!vnp->todelete) {
- /* Orphans should have already been attached (if requested) */
- assert(orphans != ORPH_ATTACH);
- oblocks += vnp->blockCount;
- ofiles++;
+ /* Orphans should have already been attached (if requested) */
+ assert(orphans != ORPH_ATTACH);
+ oblocks += vnp->blockCount;
+ ofiles++;
}
- if (((orphans == ORPH_REMOVE) || vnp->todelete) && !Testing) {
- BlocksInVolume -= vnp->blockCount;
- FilesInVolume--;
- if (VNDISK_GET_INO(&vnode)) {
- code = IH_DEC(alinkH, VNDISK_GET_INO(&vnode), vid);
- assert(code == 0);
- }
- memset(&vnode, 0, sizeof(vnode));
+ if (((orphans == ORPH_REMOVE) || vnp->todelete)
+ && !Testing) {
+ BlocksInVolume -= vnp->blockCount;
+ FilesInVolume--;
+ if (VNDISK_GET_INO(&vnode)) {
+ code =
+ IH_DEC(alinkH, VNDISK_GET_INO(&vnode), vid);
+ assert(code == 0);
+ }
+ memset(&vnode, 0, sizeof(vnode));
}
} else if (vnp->count) {
if (!Showmode) {
- Log("Vnode %d: link count incorrect (was %d, %s %d)\n",
- vnodeNumber, oldCount,
- (Testing?"would have changed to":"now"), vnode.linkCount);
+ Log("Vnode %u: link count incorrect (was %d, %s %d)\n", vnodeNumber, oldCount, (Testing ? "would have changed to" : "now"), vnode.linkCount);
}
+ } else {
+ vnode.modeBits = vnp->modeBits;
}
vnode.dataVersion++;
if (!Testing) {
- nBytes = IH_IWRITE(vnodeInfo[class].handle,
- vnodeIndexOffset(vcp, vnodeNumber),
- (char*)&vnode, sizeof (vnode));
+ nBytes =
+ IH_IWRITE(vnodeInfo[class].handle,
+ vnodeIndexOffset(vcp, vnodeNumber),
+ (char *)&vnode, sizeof(vnode));
assert(nBytes == sizeof(vnode));
- }
+ }
VolumeChanged = 1;
}
}
}
if (!Showmode && ofiles) {
- Log("%s %d orphaned files and directories (approx. %u KB)\n",
- (!Testing && (orphans == ORPH_REMOVE))?"Removed":"Found",
- ofiles, oblocks);
+ Log("%s %d orphaned files and directories (approx. %u KB)\n",
+ (!Testing
+ && (orphans == ORPH_REMOVE)) ? "Removed" : "Found", ofiles,
+ oblocks);
}
for (class = 0; class < nVNODECLASSES; class++) {
- register struct VnodeInfo *vip = &vnodeInfo[class];
- for (i=0; i<vip->nVnodes; i++)
- if (vip->vnodes[i].name) free(vip->vnodes[i].name);
- if (vip->vnodes) free(vip->vnodes);
- if (vip->inodes) free(vip->inodes);
+ register struct VnodeInfo *vip = &vnodeInfo[class];
+ for (i = 0; i < vip->nVnodes; i++)
+ if (vip->vnodes[i].name)
+ free(vip->vnodes[i].name);
+ if (vip->vnodes)
+ free(vip->vnodes);
+ if (vip->inodes)
+ free(vip->inodes);
}
/* Set correct resource utilization statistics */
/* Make sure the uniquifer is big enough: maxunique is the real maxUniquifier */
if (volHeader.uniquifier < (maxunique + 1)) {
- if (!Showmode) Log("Volume uniquifier is too low; fixed\n");
+ if (!Showmode)
+ Log("Volume uniquifier is too low; fixed\n");
/* Plus 2,000 in case there are workstations out there with
* cached vnodes that have since been deleted
*/
volHeader.uniquifier = (maxunique + 1 + 2000);
}
+ if (newrootdir) {
+ Log("*** WARNING: Root directory recreated, but volume is fragile! "
+ "Only use this salvaged volume to copy data to another volume; "
+ "do not continue to use this volume (%lu) as-is.\n",
+ afs_printable_uint32_lu(vid));
+ }
+
/* Turn off the inUse bit; the volume's been salvaged! */
- volHeader.inUse = 0; /* clear flag indicating inUse@last crash */
+ volHeader.inUse = 0; /* clear flag indicating inUse@last crash */
volHeader.needsSalvaged = 0; /* clear 'damaged' flag */
- volHeader.inService = 1; /* allow service again */
- volHeader.needsCallback = (VolumeChanged != 0);
+ volHeader.inService = 1; /* allow service again */
+ volHeader.needsCallback = (VolumeChanged != 0);
volHeader.dontSalvage = DONT_SALVAGE;
VolumeChanged = 0;
if (!Testing) {
- nBytes = IH_IWRITE(h, 0, (char*)&volHeader, sizeof(volHeader));
+ nBytes = IH_IWRITE(h, 0, (char *)&volHeader, sizeof(volHeader));
assert(nBytes == sizeof(volHeader));
}
if (!Showmode) {
- Log("%sSalvaged %s (%u): %d files, %d blocks\n",
- (Testing?"It would have ":""), volHeader.name,
- volHeader.id, FilesInVolume, BlocksInVolume);
- }
+ Log("%sSalvaged %s (%u): %d files, %d blocks\n",
+ (Testing ? "It would have " : ""), volHeader.name, volHeader.id,
+ FilesInVolume, BlocksInVolume);
+ }
IH_RELEASE(vnodeInfo[vSmall].handle);
IH_RELEASE(vnodeInfo[vLarge].handle);
IH_RELEASE(h);
return 0;
}
-void ClearROInUseBit(struct VolumeSummary *summary)
+void
+ClearROInUseBit(struct VolumeSummary *summary)
{
IHandle_t *h = summary->volumeInfoHandle;
- int nBytes;
+ afs_sfsize_t nBytes;
VolumeDiskData volHeader;
-
- nBytes = IH_IREAD(h, 0, (char*)&volHeader, sizeof(volHeader));
+
+ nBytes = IH_IREAD(h, 0, (char *)&volHeader, sizeof(volHeader));
assert(nBytes == sizeof(volHeader));
- assert(volHeader.stamp.magic == VOLUMEINFOMAGIC)
+ assert(volHeader.stamp.magic == VOLUMEINFOMAGIC);
volHeader.inUse = 0;
volHeader.needsSalvaged = 0;
volHeader.inService = 1;
volHeader.dontSalvage = DONT_SALVAGE;
if (!Testing) {
- nBytes = IH_IREAD(h, 0, (char*)&volHeader, sizeof(volHeader));
+ nBytes = IH_IWRITE(h, 0, (char *)&volHeader, sizeof(volHeader));
assert(nBytes == sizeof(volHeader));
}
}
*
* deleteMe - Always do so, only a partial volume.
*/
-void MaybeZapVolume(register struct InodeSummary *isp, char *message,
- int deleteMe,
- int check)
+void
+MaybeZapVolume(register struct InodeSummary *isp, char *message, int deleteMe,
+ int check)
{
if (readOnly(isp) || deleteMe) {
if (isp->volSummary && isp->volSummary->fileName) {
if (deleteMe) {
- if (!Showmode) Log("Volume %u (is only a partial volume--probably an attempt was made to move/restore it when a machine crash occured.\n", isp->volumeId);
- if (!Showmode) Log("It will be deleted on this server (you may find it elsewhere)\n");
+ if (!Showmode)
+ Log("Volume %u (is only a partial volume--probably an attempt was made to move/restore it when a machine crash occured.\n", isp->volumeId);
+ if (!Showmode)
+ Log("It will be deleted on this server (you may find it elsewhere)\n");
} else {
- if (!Showmode) Log("Volume %u needs to be salvaged. Since it is read-only, however,\n",isp->volumeId);
- if (!Showmode) Log("it will be deleted instead. It should be recloned.\n");
+ if (!Showmode)
+ Log("Volume %u needs to be salvaged. Since it is read-only, however,\n", isp->volumeId);
+ if (!Showmode)
+ Log("it will be deleted instead. It should be recloned.\n");
+ }
+ if (!Testing) {
+ afs_int32 code;
+ char path[64];
+ sprintf(path, "%s/%s", fileSysPath, isp->volSummary->fileName);
+
+ code = VDestroyVolumeDiskHeader(fileSysPartition, isp->volumeId, isp->RWvolumeId);
+ if (code) {
+ Log("Error %ld destroying volume disk header for volume %lu\n",
+ afs_printable_int32_ld(code),
+ afs_printable_uint32_lu(isp->volumeId));
+ }
+
+ /* make sure we actually delete the fileName file; ENOENT
+ * is fine, since VDestroyVolumeDiskHeader probably already
+ * unlinked it */
+ if (unlink(path) && errno != ENOENT) {
+ Log("Unable to unlink %s (errno = %d)\n", path, errno);
+ }
}
- if (!Testing)
- unlink(isp->volSummary->fileName);
}
- }
- else if (!check) {
- Log("%s salvage was unsuccessful: read-write volume %u\n",
- message, isp->volumeId);
- Abort("Salvage of volume %u aborted\n",
+ } else if (!check) {
+ Log("%s salvage was unsuccessful: read-write volume %u\n", message,
isp->volumeId);
+ Abort("Salvage of volume %u aborted\n", isp->volumeId);
}
}
+#ifdef AFS_DEMAND_ATTACH_FS
+/**
+ * Locks a volume on disk for salvaging.
+ *
+ * @param[in] volumeId volume ID to lock
+ *
+ * @return operation status
+ * @retval 0 success
+ * @retval -1 volume lock raced with a fileserver restart; all volumes must
+ * checked out and locked again
+ *
+ * @note DAFS only
+ */
+static int
+LockVolume(VolumeId volumeId)
+{
+ afs_int32 code;
+ int locktype;
+
+ /* should always be WRITE_LOCK, but keep the lock-type logic all
+ * in one place, in VVolLockType. Params will be ignored, but
+ * try to provide what we're logically doing. */
+ locktype = VVolLockType(V_VOLUPD, 1);
+
+ code = VLockVolumeByIdNB(volumeId, fileSysPartition, locktype);
+ if (code) {
+ if (code == EBUSY) {
+ Abort("Someone else appears to be using volume %lu; Aborted\n",
+ afs_printable_uint32_lu(volumeId));
+ }
+ Abort("Error %ld trying to lock volume %lu; Aborted\n",
+ afs_printable_int32_ld(code),
+ afs_printable_uint32_lu(volumeId));
+ }
+
+ code = FSYNC_VerifyCheckout(volumeId, fileSysPathName, FSYNC_VOL_OFF, FSYNC_SALVAGE);
+ if (code == SYNC_DENIED) {
+ /* need to retry checking out volumes */
+ return -1;
+ }
+ if (code != SYNC_OK) {
+ Abort("FSYNC_VerifyCheckout failed for volume %lu with code %ld\n",
+ afs_printable_uint32_lu(volumeId), afs_printable_int32_ld(code));
+ }
+
+ /* set inUse = programType in the volume header to ensure that nobody
+ * tries to use this volume again without salvaging, if we somehow crash
+ * or otherwise exit before finishing the salvage.
+ */
+ if (!Testing) {
+ IHandle_t *h;
+ struct VolumeHeader header;
+ struct VolumeDiskHeader diskHeader;
+ struct VolumeDiskData volHeader;
+
+ code = VReadVolumeDiskHeader(volumeId, fileSysPartition, &diskHeader);
+ if (code) {
+ return 0;
+ }
+
+ DiskToVolumeHeader(&header, &diskHeader);
+
+ IH_INIT(h, fileSysDevice, header.parent, header.volumeInfo);
+ if (IH_IREAD(h, 0, (char*)&volHeader, sizeof(volHeader)) != sizeof(volHeader) ||
+ volHeader.stamp.magic != VOLUMEINFOMAGIC) {
+
+ IH_RELEASE(h);
+ return 0;
+ }
+
+ volHeader.inUse = programType;
+
+ /* If we can't re-write the header, bail out and error. We don't
+ * assert when reading the header, since it's possible the
+ * header isn't really there (when there's no data associated
+ * with the volume; we just delete the vol header file in that
+ * case). But if it's there enough that we can read it, but
+ * somehow we cannot write to it to signify we're salvaging it,
+ * we've got a big problem and we cannot continue. */
+ assert(IH_IWRITE(h, 0, (char*)&volHeader, sizeof(volHeader)) == sizeof(volHeader));
-void AskOffline(VolumeId volumeId)
+ IH_RELEASE(h);
+ }
+
+ return 0;
+}
+#endif /* AFS_DEMAND_ATTACH_FS */
+
+void
+AskOffline(VolumeId volumeId, char * partition)
{
- if (FSYNC_askfs(volumeId, (char *)0, FSYNC_OFF, FSYNC_SALVAGE) == FSYNC_DENIED) {
- Log("AskOffline: file server denied offline request; a general salvage is required.\n");
- Abort("Salvage aborted\n");
+ afs_int32 code, i;
+ SYNC_response res;
+
+ memset(&res, 0, sizeof(res));
+
+ for (i = 0; i < 3; i++) {
+ code = FSYNC_VolOp(volumeId, partition, FSYNC_VOL_OFF, FSYNC_SALVAGE, &res);
+
+ if (code == SYNC_OK) {
+ break;
+ } else if (code == SYNC_DENIED) {
+#ifdef DEMAND_ATTACH_ENABLE
+ Log("AskOffline: file server denied offline request; a general salvage may be required.\n");
+#else
+ Log("AskOffline: file server denied offline request; a general salvage is required.\n");
+#endif
+ Abort("Salvage aborted\n");
+ } else if (code == SYNC_BAD_COMMAND) {
+ Log("AskOffline: fssync protocol mismatch (bad command word '%d'); salvage aborting.\n",
+ FSYNC_VOL_OFF);
+#ifdef DEMAND_ATTACH_ENABLE
+ Log("AskOffline: please make sure fileserver, volserver, salvageserver and salvager binaries are same version.\n");
+#else
+ Log("AskOffline: please make sure fileserver, volserver and salvager binaries are same version.\n");
+#endif
+ Abort("Salvage aborted\n");
+ } else if (i < 2) {
+ /* try it again */
+ Log("AskOffline: request for fileserver to take volume offline failed; trying again...\n");
+ FSYNC_clientFinis();
+ FSYNC_clientInit();
+ }
+ }
+ if (code != SYNC_OK) {
+ Log("AskOffline: request for fileserver to take volume offline failed; salvage aborting.\n");
+ Abort("Salvage aborted\n");
}
}
-void AskOnline(VolumeId volumeId, char *partition)
+void
+AskOnline(VolumeId volumeId, char *partition)
{
- if (FSYNC_askfs(volumeId, partition, FSYNC_ON, 0) == FSYNC_DENIED) {
- Log("AskOnline: file server denied online request to volume %u partition %s\n",
- volumeId, partition);
+ afs_int32 code, i;
+
+ for (i = 0; i < 3; i++) {
+ code = FSYNC_VolOp(volumeId, partition, FSYNC_VOL_ON, FSYNC_WHATEVER, NULL);
+
+ if (code == SYNC_OK) {
+ break;
+ } else if (code == SYNC_DENIED) {
+ Log("AskOnline: file server denied online request to volume %u partition %s; trying again...\n", volumeId, partition);
+ } else if (code == SYNC_BAD_COMMAND) {
+ Log("AskOnline: fssync protocol mismatch (bad command word '%d')\n",
+ FSYNC_VOL_ON);
+#ifdef DEMAND_ATTACH_ENABLE
+ Log("AskOnline: please make sure fileserver, volserver, salvageserver and salvager binaries are same version.\n");
+#else
+ Log("AskOnline: please make sure fileserver, volserver and salvager binaries are same version.\n");
+#endif
+ break;
+ } else if (i < 2) {
+ /* try it again */
+ Log("AskOnline: request for fileserver to take volume offline failed; trying again...\n");
+ FSYNC_clientFinis();
+ FSYNC_clientInit();
+ }
}
}
-int CopyInode(Device device, Inode inode1, Inode inode2, int rwvolume)
+int
+CopyInode(Device device, Inode inode1, Inode inode2, int rwvolume)
{
/* Volume parameter is passed in case iopen is upgraded in future to
* require a volume Id to be passed
char buf[4096];
IHandle_t *srcH, *destH;
FdHandle_t *srcFdP, *destFdP;
- register int n;
+ register int n = 0;
IH_INIT(srcH, device, rwvolume, inode1);
srcFdP = IH_OPEN(srcH);
assert(n != -1);
while ((n = FDH_READ(srcFdP, buf, sizeof(buf))) > 0)
assert(FDH_WRITE(destFdP, buf, n) == n);
- assert (n == 0);
+ assert(n == 0);
FDH_REALLYCLOSE(srcFdP);
FDH_REALLYCLOSE(destFdP);
- IH_RELEASE(srcH);
+ IH_RELEASE(srcH);
IH_RELEASE(destH);
return 0;
}
-void PrintInodeList(void)
+void
+PrintInodeList(void)
{
register struct ViceInodeInfo *ip;
struct ViceInodeInfo *buf;
- struct stat status;
- register nInodes;
+ struct afs_stat status;
+ register int nInodes;
- assert(fstat(inodeFd, &status) == 0);
- buf = (struct ViceInodeInfo *) malloc(status.st_size);
+ assert(afs_fstat(inodeFd, &status) == 0);
+ buf = (struct ViceInodeInfo *)malloc(status.st_size);
assert(buf != NULL);
nInodes = status.st_size / sizeof(struct ViceInodeInfo);
assert(read(inodeFd, buf, status.st_size) == status.st_size);
- for(ip = buf; nInodes--; ip++) {
- Log("Inode:%s, linkCount=%d, size=%u, p=(%u,%u,%u,%u)\n",
- PrintInode(NULL, ip->inodeNumber), ip->linkCount, ip->byteCount,
- ip->u.param[0], ip->u.param[1], ip->u.param[2], ip->u.param[3]);
+ for (ip = buf; nInodes--; ip++) {
+ Log("Inode:%s, linkCount=%d, size=%#llx, p=(%u,%u,%u,%u)\n",
+ PrintInode(NULL, ip->inodeNumber), ip->linkCount,
+ (afs_uintmax_t) ip->byteCount, ip->u.param[0], ip->u.param[1],
+ ip->u.param[2], ip->u.param[3]);
}
free(buf);
}
-void PrintInodeSummary(void)
+void
+PrintInodeSummary(void)
{
- int i;
- struct InodeSummary *isp;
+ int i;
+ struct InodeSummary *isp;
- for (i=0; i<nVolumesInInodeFile; i++) {
- isp = &inodeSummary[i];
- Log("VID:%u, RW:%u, index:%d, nInodes:%d, nSpecialInodes:%d, maxUniquifier:%u, volSummary\n",
- isp->volumeId, isp->RWvolumeId, isp->index, isp->nInodes,
- isp->nSpecialInodes, isp->maxUniquifier);
- }
+ for (i = 0; i < nVolumesInInodeFile; i++) {
+ isp = &inodeSummary[i];
+ Log("VID:%u, RW:%u, index:%d, nInodes:%d, nSpecialInodes:%d, maxUniquifier:%u, volSummary\n", isp->volumeId, isp->RWvolumeId, isp->index, isp->nInodes, isp->nSpecialInodes, isp->maxUniquifier);
+ }
}
-void PrintVolumeSummary(void)
+void
+PrintVolumeSummary(void)
{
- int i;
- struct VolumeSummary *vsp;
+ int i;
+ struct VolumeSummary *vsp;
- for (i=0, vsp=volumeSummaryp; i<nVolumes; vsp++, i++) {
- Log("fileName:%s, header, wouldNeedCallback\n", vsp->fileName);
- }
+ for (i = 0, vsp = volumeSummaryp; i < nVolumes; vsp++, i++) {
+ Log("fileName:%s, header, wouldNeedCallback\n", vsp->fileName);
+ }
}
-int Fork(void) {
+int
+Fork(void)
+{
int f;
#ifdef AFS_NT40_ENV
f = 0;
- assert(0); /* Fork is never executed in the NT code path */
+ assert(0); /* Fork is never executed in the NT code path */
#else
f = fork();
- assert(f >= 0)
+ assert(f >= 0);
+#ifdef AFS_DEMAND_ATTACH_FS
+ if ((f == 0) && (programType == salvageServer)) {
+ /* we are a salvageserver child */
+#ifdef FSSYNC_BUILD_CLIENT
+ VChildProcReconnectFS_r();
#endif
+#ifdef SALVSYNC_BUILD_CLIENT
+ VReconnectSALV_r();
+#endif
+ }
+#endif /* AFS_DEMAND_ATTACH_FS */
+#endif /* !AFS_NT40_ENV */
return f;
}
-void Exit(code)
- int code;
+void
+Exit(int code)
{
- if (ShowLog) showlog();
+ if (ShowLog)
+ showlog();
+
+#ifdef AFS_DEMAND_ATTACH_FS
+ if (programType == salvageServer) {
+#ifdef SALVSYNC_BUILD_CLIENT
+ VDisconnectSALV();
+#endif
+#ifdef FSSYNC_BUILD_CLIENT
+ VDisconnectFS();
+#endif
+ }
+#endif /* AFS_DEMAND_ATTACH_FS */
+
#ifdef AFS_NT40_ENV
if (main_thread != pthread_self())
- pthread_exit((void*)code);
+ pthread_exit((void *)code);
else
exit(code);
#else
#endif
}
-int Wait(char *prog)
+int
+Wait(char *prog)
{
int status;
int pid;
pid = wait(&status);
- assert(pid != -1)
+ assert(pid != -1);
if (WCOREDUMP(status))
Log("\"%s\" core dumped!\n", prog);
if (WIFSIGNALED(status) != 0 || WEXITSTATUS(status) != 0)
return pid;
}
-static char *TimeStamp(time_t clock, int precision)
+static char *
+TimeStamp(time_t clock, int precision)
{
struct tm *lt;
static char timestamp[20];
lt = localtime(&clock);
if (precision)
- strftime (timestamp, 20, "%m/%d/%Y %T", lt);
+ (void)strftime(timestamp, 20, "%m/%d/%Y %H:%M:%S", lt);
else
- strftime (timestamp, 20, "%m/%d/%Y %H:%M", lt);
+ (void)strftime(timestamp, 20, "%m/%d/%Y %H:%M", lt);
return timestamp;
}
-void CheckLogFile(void)
+void
+CheckLogFile(char * log_path)
{
- char oldSlvgLog[AFSDIR_PATH_MAX];
+ char oldSlvgLog[AFSDIR_PATH_MAX];
#ifndef AFS_NT40_ENV
- if ( useSyslog ) {
- ShowLog = 0;
- return;
- }
+ if (useSyslog) {
+ ShowLog = 0;
+ return;
+ }
#endif
- strcpy(oldSlvgLog, AFSDIR_SERVER_SLVGLOG_FILEPATH);
- strcat(oldSlvgLog, ".old");
+ strcpy(oldSlvgLog, log_path);
+ strcat(oldSlvgLog, ".old");
if (!logFile) {
- renamefile(AFSDIR_SERVER_SLVGLOG_FILEPATH, oldSlvgLog);
- logFile = fopen(AFSDIR_SERVER_SLVGLOG_FILEPATH, "a");
+ renamefile(log_path, oldSlvgLog);
+ logFile = afs_fopen(log_path, "a");
- if (!logFile) { /* still nothing, use stdout */
+ if (!logFile) { /* still nothing, use stdout */
logFile = stdout;
ShowLog = 0;
}
-
#ifndef AFS_NAMEI_ENV
AFS_DEBUG_IOPS_LOG(logFile);
#endif
}
}
-void showlog(void)
+#ifndef AFS_NT40_ENV
+void
+TimeStampLogFile(char * log_path)
+{
+ char stampSlvgLog[AFSDIR_PATH_MAX];
+ struct tm *lt;
+ time_t now;
+
+ now = time(0);
+ lt = localtime(&now);
+ (void)afs_snprintf(stampSlvgLog, sizeof stampSlvgLog,
+ "%s.%04d-%02d-%02d.%02d:%02d:%02d",
+ log_path, lt->tm_year + 1900,
+ lt->tm_mon + 1, lt->tm_mday, lt->tm_hour, lt->tm_min,
+ lt->tm_sec);
+
+ /* try to link the logfile to a timestamped filename */
+ /* if it fails, oh well, nothing we can do */
+ link(log_path, stampSlvgLog);
+}
+#endif
+
+void
+showlog(void)
{
char line[256];
#ifndef AFS_NT40_ENV
- if ( useSyslog ) {
- printf("Can't show log since using syslog.\n");
- fflush(stdout);
- return;
- }
+ if (useSyslog) {
+ printf("Can't show log since using syslog.\n");
+ fflush(stdout);
+ return;
+ }
#endif
- rewind(logFile);
- fclose(logFile);
+ if (logFile) {
+ rewind(logFile);
+ fclose(logFile);
+ }
- logFile = fopen(AFSDIR_SERVER_SLVGLOG_FILEPATH, "r");
+ logFile = afs_fopen(AFSDIR_SERVER_SLVGLOG_FILEPATH, "r");
if (!logFile)
printf("Can't read %s, exiting\n", AFSDIR_SERVER_SLVGLOG_FILEPATH);
else {
rewind(logFile);
while (fgets(line, sizeof(line), logFile))
- printf("%s",line);
+ printf("%s", line);
fflush(stdout);
}
}
-void Log(a,b,c,d,e,f,g,h,i,j,k)
-char *a, *b, *c, *d, *e, *f, *g, *h, *i, *j, *k;
+void
+Log(const char *format, ...)
{
struct timeval now;
+ char tmp[1024];
+ va_list args;
+ va_start(args, format);
+ (void)afs_vsnprintf(tmp, sizeof tmp, format, args);
+ va_end(args);
#ifndef AFS_NT40_ENV
- if ( useSyslog )
- {
- syslog(LOG_INFO, a,b,c,d,e,f,g,h,i,j,k);
- } else
+ if (useSyslog) {
+ syslog(LOG_INFO, "%s", tmp);
+ } else
#endif
- {
+ if (logFile) {
gettimeofday(&now, 0);
- fprintf(logFile, "%s ", TimeStamp(now.tv_sec, 1));
- fprintf(logFile, a,b,c,d,e,f,g,h,i,j,k);
+ fprintf(logFile, "%s %s", TimeStamp(now.tv_sec, 1), tmp);
fflush(logFile);
}
}
-void Abort(a,b,c,d,e,f,g,h,i,j,k)
-char *a, *b, *c, *d, *e, *f, *g, *h, *i, *j, *k;
+void
+Abort(const char *format, ...)
{
+ va_list args;
+ char tmp[1024];
+
+ va_start(args, format);
+ (void)afs_vsnprintf(tmp, sizeof tmp, format, args);
+ va_end(args);
#ifndef AFS_NT40_ENV
- if ( useSyslog )
- {
- syslog(LOG_INFO, a,b,c,d,e,f,g,h,i,j,k);
- } else
+ if (useSyslog) {
+ syslog(LOG_INFO, "%s", tmp);
+ } else
#endif
- {
- fprintf(logFile, a,b,c,d,e,f,g,h,i,j,k);
+ if (logFile) {
+ fprintf(logFile, "%s", tmp);
fflush(logFile);
- if (ShowLog) showlog();
+ if (ShowLog)
+ showlog();
}
+
if (debug)
abort();
Exit(1);
}
-char * ToString(char *s)
+char *
+ToString(const char *s)
{
register char *p;
- p = (char *) malloc(strlen(s)+1);
- assert(p != NULL)
- strcpy(p,s);
+ p = (char *)malloc(strlen(s) + 1);
+ assert(p != NULL);
+ strcpy(p, s);
return p;
-
}
/* Remove the FORCESALVAGE file */
-void RemoveTheForce(char *path)
+void
+RemoveTheForce(char *path)
{
- if (!Testing && ForceSalvage) {
- if (chdir(path) == 0)
- unlink("FORCESALVAGE");
- }
+ char target[1024];
+ struct afs_stat force; /* so we can use afs_stat to find it */
+ strcpy(target,path);
+ strcat(target,"/FORCESALVAGE");
+ if (!Testing && ForceSalvage) {
+ if (afs_stat(target,&force) == 0) unlink(target);
+ }
}
#ifndef AFS_AIX32_ENV
/*
* UseTheForceLuke - see if we can use the force
*/
-int UseTheForceLuke(char *path)
+int
+UseTheForceLuke(char *path)
{
- struct stat force;
-
- assert(chdir(path) != -1);
+ struct afs_stat force;
+ char target[1024];
+ strcpy(target,path);
+ strcat(target,"/FORCESALVAGE");
- return (stat("FORCESALVAGE", &force) == 0);
+ return (afs_stat(target, &force) == 0);
}
#else
/*
*
* NOTE:
* The VRMIX fsck will not muck with the filesystem it is supposedly
- * fixing and create a "FORCESAVAGE" file (by design). Instead, we
+ * fixing and create a "FORCESALVAGE" file (by design). Instead, we
* muck directly with the root inode, which is within the normal
* domain of fsck.
* ListViceInodes() has a side effect of setting ForceSalvage if
* it detects a need, based on root inode examination.
*/
-int UseTheForceLuke(char *path)
+int
+UseTheForceLuke(char *path)
{
- return 0; /* sorry OB1 */
+ return 0; /* sorry OB1 */
}
#endif
/* NT support routines */
static char execpathname[MAX_PATH];
-int nt_SalvagePartition(char *partName, int jobn)
+int
+nt_SalvagePartition(char *partName, int jobn)
{
int pid;
int n;
childJob_t job;
if (!*execpathname) {
- n = GetModuleFileName(NULL, execpathname, MAX_PATH-1);
+ n = GetModuleFileName(NULL, execpathname, MAX_PATH - 1);
if (!n || n == 1023)
return -1;
}
job.cj_magic = SALVAGER_MAGIC;
job.cj_number = jobn;
- (void) strcpy(job.cj_part, partName);
- pid = (int)spawnprocveb(execpathname, save_args, NULL,
- &job, sizeof(job));
+ (void)strcpy(job.cj_part, partName);
+ pid = (int)spawnprocveb(execpathname, save_args, NULL, &job, sizeof(job));
return pid;
}
-int nt_SetupPartitionSalvage(void *datap, int len)
+int
+nt_SetupPartitionSalvage(void *datap, int len)
{
- childJob_t *jobp = (childJob_t*)datap;
+ childJob_t *jobp = (childJob_t *) datap;
char logname[AFSDIR_PATH_MAX];
if (len != sizeof(childJob_t))
myjob = *jobp;
/* Open logFile */
- (void) sprintf(logname, "%s.%d", AFSDIR_SERVER_SLVGLOG_FILEPATH,
- myjob.cj_number);
- logFile = fopen(logname, "w");
- if (!logFile) logFile = stdout;
+ (void)sprintf(logname, "%s.%d", AFSDIR_SERVER_SLVGLOG_FILEPATH,
+ myjob.cj_number);
+ logFile = afs_fopen(logname, "w");
+ if (!logFile)
+ logFile = stdout;
return 0;
}