Skip to content
Permalink
Browse files
GEODE-10392: When gw sender started with cleanqueue remove EvictionCo…
…ntroller from diskstore (#7817)
  • Loading branch information
mivanac committed Jul 5, 2022
1 parent 1d25728 commit d6261cc3cce1b661714fb136c732addb8c11a33e
Showing 4 changed files with 386 additions and 0 deletions.
@@ -4079,6 +4079,15 @@ EvictionController getExistingPREvictionContoller(PartitionedRegion pr) {
}
}

void clearExistingPREvictionContoller(PartitionedRegion pr) {
final String prName = pr.getFullPath();
synchronized (prEvictionControllerMap) {
prEvictionControllerMap.remove(prName);
}
}



/**
* Lock the disk store to prevent updates. This is the first step of the backup process. Once all
* disk stores on all members are locked, we still move on to prepareBackup.
@@ -556,6 +556,15 @@ public EvictionController getPREvictionControllerFromDiskInitialization() {
return result;
}


public void clearPREvictionControllerFromDiskInitialization() {
if (getDiskStore() != null) {
getDiskStore().clearExistingPREvictionContoller(this);
}
}



@Override
public boolean remove(Object key, Object value, Object callbackArg) {
final long startTime = prStats.getTime();
@@ -497,6 +497,7 @@ public void addShadowPartitionedRegionForUserPR(PartitionedRegion userPR,

if ((prQ != null) && (index == 0) && cleanQueues) {
cleanOverflowStats(cache);
prQ.clearPREvictionControllerFromDiskInitialization();
prQ.destroyRegion(null);
prQ = null;
}

0 comments on commit d6261cc

Please sign in to comment.