#include <afsconfig.h>
#include <afs/param.h>
-RCSID("$Header$");
+RCSID
+ ("$Header$");
#include <stdio.h>
#ifdef AFS_NT40_ENV
#include "fssync.h"
/* forward declarations */
-void PurgeIndex_r(Volume *vp, VnodeClass class);
-void PurgeHeader_r(Volume *vp);
+void PurgeIndex_r(Volume * vp, VnodeClass class);
+void PurgeHeader_r(Volume * vp);
-void VPurgeVolume_r(Error *ec, Volume *vp)
+void
+VPurgeVolume_r(Error * ec, Volume * vp)
{
- struct DiskPartition *tpartp = vp->partition;
+ struct DiskPartition *tpartp = vp->partition;
char purgePath[MAXPATHLEN];
/* N.B. it's important here to use the partition pointed to by the
* volume header. This routine can, under some circumstances, be called
* when two volumes with the same id exist on different partitions.
*/
- (void) afs_snprintf(purgePath, sizeof purgePath,
- "%s/%s", VPartitionPath(vp->partition),
- VolumeExternalName(V_id(vp)));
+ (void)afs_snprintf(purgePath, sizeof purgePath, "%s/%s",
+ VPartitionPath(vp->partition),
+ VolumeExternalName(V_id(vp)));
PurgeIndex_r(vp, vLarge);
PurgeIndex_r(vp, vSmall);
PurgeHeader_r(vp);
/*
* Call the fileserver to break all call backs for that volume
*/
- FSYNC_askfs(V_id(vp), tpartp->name, FSYNC_RESTOREVOLUME, 0);
+ FSYNC_askfs(V_id(vp), tpartp->name, FSYNC_RESTOREVOLUME, 0);
}
-void VPurgeVolume(Error *ec, Volume *vp)
+void
+VPurgeVolume(Error * ec, Volume * vp)
{
- VOL_LOCK
+ VOL_LOCK;
VPurgeVolume_r(ec, vp);
- VOL_UNLOCK
+ VOL_UNLOCK;
}
#define MAXOBLITATONCE 200
things work and we should be called again, 1 if success full and done, and -1
if an error occurred. It adjusts offset appropriately on 0 or 1 return codes,
and otherwise doesn't touch it */
-static int ObliterateRegion(Volume *avp, VnodeClass aclass,
- StreamHandle_t *afile, afs_int32 *aoffset)
+static int
+ObliterateRegion(Volume * avp, VnodeClass aclass, StreamHandle_t * afile,
+ afs_int32 * aoffset)
{
register struct VnodeClassInfo *vcp;
Inode inodes[MAXOBLITATONCE];
int hitEOF;
register int i;
register afs_int32 code;
- register struct VnodeDiskObject *vnode = (struct VnodeDiskObject *) buf;
+ register struct VnodeDiskObject *vnode = (struct VnodeDiskObject *)buf;
hitEOF = 0;
vcp = &VnodeClassInfo[aclass];
- offset = *aoffset; /* original offset */
+ offset = *aoffset; /* original offset */
iindex = 0;
nscanned = 0;
/* advance over up to MAXOBLITATONCE inodes. nscanned tells us how many we examined.
- We remember the inodes in an array, and idec them after zeroing them in the index.
- The reason for these contortions is to make volume deletion idempotent, even
- if we crash in the middle of a delete operation. */
+ * We remember the inodes in an array, and idec them after zeroing them in the index.
+ * The reason for these contortions is to make volume deletion idempotent, even
+ * if we crash in the middle of a delete operation. */
STREAM_SEEK(afile, offset, 0);
while (1) {
if (iindex >= MAXOBLITATONCE) {
}
if (vnode->type != vNull) {
if (vnode->vnodeMagic != vcp->magic)
- goto fail; /* something really wrong; let salvager take care of it */
+ goto fail; /* something really wrong; let salvager take care of it */
if (VNDISK_GET_INO(vnode))
inodes[iindex++] = VNDISK_GET_INO(vnode);
}
/* next, obliterate the index and fflush (and fsync) it */
STREAM_SEEK(afile, *aoffset, 0); /* seek back to start of vnode index region */
memset(buf, 0, sizeof(buf)); /* zero out our proto-vnode */
- for(i=0;i<nscanned;i++) {
+ for (i = 0; i < nscanned; i++) {
if (STREAM_WRITE(buf, vcp->diskSize, 1, afile) != 1)
goto fail;
}
- STREAM_FLUSH(afile); /* ensure 0s are on the disk */
+ STREAM_FLUSH(afile); /* ensure 0s are on the disk */
OS_SYNC(afile->str_fd);
/* finally, do the idec's */
- for(i=0;i<iindex;i++) {
+ for (i = 0; i < iindex; i++) {
IH_DEC(V_linkHandle(avp), inodes[i], V_parentId(avp));
DOPOLL;
}
/* return the new offset */
*aoffset = offset;
- return hitEOF; /* return 1 if hit EOF (don't call again), otherwise 0 */
+ return hitEOF; /* return 1 if hit EOF (don't call again), otherwise 0 */
fail:
return -1;
}
-void PurgeIndex(Volume *vp, VnodeClass class)
+void
+PurgeIndex(Volume * vp, VnodeClass class)
{
- VOL_LOCK
+ VOL_LOCK;
PurgeIndex_r(vp, class);
- VOL_UNLOCK
+ VOL_UNLOCK;
}
-void PurgeIndex_r(Volume *vp, VnodeClass class)
+void
+PurgeIndex_r(Volume * vp, VnodeClass class)
{
StreamHandle_t *ifile;
struct VnodeClassInfo *vcp = &VnodeClassInfo[class];
afs_int32 offset;
register afs_int32 code;
FdHandle_t *fdP;
-
+
fdP = IH_OPEN(vp->vnodeIndex[class].handle);
if (fdP == NULL)
}
offset = vcp->diskSize;
- while(1) {
+ while (1) {
code = ObliterateRegion(vp, class, ifile, &offset);
- if (code) break; /* if error or hit EOF */
+ if (code)
+ break; /* if error or hit EOF */
}
STREAM_CLOSE(ifile);
FDH_CLOSE(fdP);
}
-void PurgeHeader(Volume *vp)
+void
+PurgeHeader(Volume * vp)
{
- VOL_LOCK
+ VOL_LOCK;
PurgeHeader_r(vp);
- VOL_UNLOCK
+ VOL_UNLOCK;
}
-void PurgeHeader_r(Volume *vp)
+void
+PurgeHeader_r(Volume * vp)
{
IH_REALLYCLOSE(V_diskDataHandle(vp));
IH_DEC(V_linkHandle(vp), vp->vnodeIndex[vLarge].handle->ih_ino, V_id(vp));
git://git.openafs.org / openafs.git / blobdiff