jimzah/openafs
1
0
Fork 0
mirror of https://git.openafs.org/openafs.git synced 2025-01-21 00:10:15 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Windows: Track Mixed RO Volume Release State

Browse Source 
If the volume location information indicates that a replica site
is VLSF_NEWREPSITE then it implies that some of the replicas are
out of date.  Ignore the out of date replicas when constructing
the list and force a volume location list reset every five minutes
while the replica site info is mixed.

Change-Id: I136e66b1d2da66578970932553d14f59a666721b
Reviewed-on: http://gerrit.openafs.org/7354
Tested-by: BuildBot <buildbot@rampaginggeek.com>
Reviewed-by: Jeffrey Altman <jaltman@secure-endpoints.com>
Tested-by: Jeffrey Altman <jaltman@secure-endpoints.com>
This commit is contained in:
Jeffrey Altman 2012-05-05 21:37:00 -04:00 committed by Jeffrey Altman
parent 1af906799b
commit 193a56aa66
2 changed files with 31 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
src/WINNT/afsd/cm_volume.c
View File

@ -250,6 +250,7 @@ long cm_UpdateVolumeLocation(struct cm_cell *cellp, cm_user_t *userp, cm_req_t *
struct uvldbentry uvldbEntry;
int method = -1;
int ROcount = 0;
int isMixed = 0;
long code;
enum volstatus rwNewstate = vl_online;
enum volstatus roNewstate = vl_online;
@ -548,6 +549,15 @@ long cm_UpdateVolumeLocation(struct cm_cell *cellp, cm_user_t *userp, cm_req_t *
volp->vol[BACKVOL].ID = 0;
}
lock_ReleaseWrite(&cm_volumeLock);
/* See if the replica sites are mixed versions */
for (i=0; i<nServers; i++) {
if (serverFlags[i] & VLSF_NEWREPSITE) {
isMixed = 1;
break;
}
}
for (i=0; i<nServers; i++) {
/* create a server entry */
tflags = serverFlags[i];
@ -617,7 +627,12 @@ long cm_UpdateVolumeLocation(struct cm_cell *cellp, cm_user_t *userp, cm_req_t *
if (!(tsp->flags & CM_SERVERFLAG_DOWN))
rwServers_alldown = 0;
}
if ((tflags & VLSF_ROVOL) && (flags & VLF_ROEXISTS)) {
/*
* If there are mixed versions of RO releases on the replica
* sites, skip the servers with the out of date versions.
*/
if ((tflags & VLSF_ROVOL) && (flags & VLF_ROEXISTS) &&
(!isMixed || (tflags & VLSF_NEWREPSITE))) {
tsrp = cm_NewServerRef(tsp, roID);
cm_InsertServerList(&volp->vol[ROVOL].serversp, tsrp);
ROcount++;
@ -683,6 +698,10 @@ long cm_UpdateVolumeLocation(struct cm_cell *cellp, cm_user_t *userp, cm_req_t *
}
volp->lastUpdateTime = time(NULL);
if (isMixed)
_InterlockedOr(&volp->flags, CM_VOLUMEFLAG_RO_MIXED);
else
_InterlockedAnd(&volp->flags, ~CM_VOLUMEFLAG_RO_MIXED);
if (code == 0)
_InterlockedAnd(&volp->flags, ~CM_VOLUMEFLAG_RESET);
@ -1211,9 +1230,16 @@ void cm_RefreshVolumes(int lifetime)
if (!(volp->flags & CM_VOLUMEFLAG_RESET)) {
lock_ObtainWrite(&volp->rw);
if (volp->lastUpdateTime + lifetime <= now) {
_InterlockedOr(&volp->flags, CM_VOLUMEFLAG_RESET);
volp->lastUpdateTime = 0;
if (volp->flags & CM_VOLUMEFLAG_RO_MIXED) {
if (volp->lastUpdateTime + 300 <= now) {
_InterlockedOr(&volp->flags, CM_VOLUMEFLAG_RESET);
volp->lastUpdateTime = 0;
}
} else {
if (volp->lastUpdateTime + lifetime <= now) {
_InterlockedOr(&volp->flags, CM_VOLUMEFLAG_RESET);
volp->lastUpdateTime = 0;
}
}
lock_ReleaseWrite(&volp->rw);
}

1
src/WINNT/afsd/cm_volume.h
View File

@ -56,6 +56,7 @@ typedef struct cm_volume {
} cm_volume_t;
#define CM_VOLUMEFLAG_RESET 1 /* reload this info on next use */
#define CM_VOLUMEFLAG_RO_MIXED 2
#define CM_VOLUMEFLAG_UPDATING_VL 8
#define CM_VOLUMEFLAG_DFS_VOLUME 16
#define CM_VOLUMEFLAG_NOEXIST 32