You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by la...@apache.org on 2017/04/29 00:12:43 UTC
[13/18] geode git commit: GEODE-2816: Redundancy recovery inititated
even if redundancy set to 0
GEODE-2816: Redundancy recovery inititated even if redundancy set to 0
Project: http://git-wip-us.apache.org/repos/asf/geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/84e36d55
Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/84e36d55
Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/84e36d55
Branch: refs/heads/feature/GEODE-2852
Commit: 84e36d558e92b3d722a7e4c6df2439a72ea8f218
Parents: ddec64a
Author: nabarun <nn...@pivotal.io>
Authored: Mon Apr 24 10:50:06 2017 -0700
Committer: Lynn Hughes-Godfrey <lh...@pivotal.io>
Committed: Fri Apr 28 17:06:33 2017 -0700
----------------------------------------------------------------------
.../org/apache/geode/internal/cache/PRHARedundancyProvider.java | 2 +-
.../java/org/apache/geode/internal/cache/PartitionedRegion.java | 5 +----
2 files changed, 2 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/geode/blob/84e36d55/geode-core/src/main/java/org/apache/geode/internal/cache/PRHARedundancyProvider.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PRHARedundancyProvider.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PRHARedundancyProvider.java
index d2f44e8..6fc4ba0 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/PRHARedundancyProvider.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PRHARedundancyProvider.java
@@ -1537,7 +1537,7 @@ public class PRHARedundancyProvider {
delay = this.prRegion.getPartitionAttributes().getRecoveryDelay();
movePrimaries = false;
}
- final boolean requiresRedundancyRecovery = delay >= 0 && redundantCopies > 0;
+ final boolean requiresRedundancyRecovery = delay >= 0;
if (!requiresRedundancyRecovery) {
return;
http://git-wip-us.apache.org/repos/asf/geode/blob/84e36d55/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegion.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegion.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegion.java
index e15eb2a..e0aae5d 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegion.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegion.java
@@ -958,10 +958,7 @@ public class PartitionedRegion extends LocalRegion
try {
if (storesData) {
this.redundancyProvider.scheduleCreateMissingBuckets();
-
- if (this.redundantCopies > 0) {
- this.redundancyProvider.startRedundancyRecovery();
- }
+ this.redundancyProvider.startRedundancyRecovery();
}
} catch (RegionDestroyedException rde) {
// Do nothing.