You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by ab...@apache.org on 2017/05/15 12:34:30 UTC
geode git commit: GEODE-2890: Corrected debug log location in
AbstractGatewaySenderEventProcessor.processQueue(). This closes #505
Repository: geode
Updated Branches:
refs/heads/develop 1252cae4c -> 119f84bd7
GEODE-2890: Corrected debug log location in
AbstractGatewaySenderEventProcessor.processQueue().
This closes #505
Project: http://git-wip-us.apache.org/repos/asf/geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/119f84bd
Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/119f84bd
Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/119f84bd
Branch: refs/heads/develop
Commit: 119f84bd7b41f59ebdcd7c96c99b1b467789638a
Parents: 1252cae
Author: Amey Barve <ab...@apache.org>
Authored: Wed May 10 14:47:30 2017 +0530
Committer: Amey Barve <ab...@apache.org>
Committed: Mon May 15 18:03:19 2017 +0530
----------------------------------------------------------------------
.../cache/wan/AbstractGatewaySenderEventProcessor.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/geode/blob/119f84bd/geode-core/src/main/java/org/apache/geode/internal/cache/wan/AbstractGatewaySenderEventProcessor.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/wan/AbstractGatewaySenderEventProcessor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/wan/AbstractGatewaySenderEventProcessor.java
index 263c446..30b61ad 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/wan/AbstractGatewaySenderEventProcessor.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/wan/AbstractGatewaySenderEventProcessor.java
@@ -551,13 +551,13 @@ public abstract class AbstractGatewaySenderEventProcessor extends Thread {
BucketRegion bucket = qpr.getDataStore().getLocalBucketById(bucketId);
if (bucket == null || !bucket.getBucketAdvisor().isPrimary()) {
event.setPossibleDuplicate(true);
+ if (isDebugEnabled) {
+ logger.debug(
+ "Bucket id: {} is no longer primary on this node. The event: {} will be dispatched from this node with possibleDuplicate set to true.",
+ bucketId, event);
+ }
}
}
- if (isDebugEnabled) {
- logger.debug(
- "Bucket id: {} is no longer primary on this node. The event {} will be dispatched from this node with possibleDuplicate set to true.",
- bucketId, event);
- }
}
}