geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aba...@apache.org
Subject geode git commit: GEODE-2890: Corrected debug log location in AbstractGatewaySenderEventProcessor.processQueue(). This closes #505
Date Mon, 15 May 2017 12:34:30 GMT
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 <abarve@apache.org>
Authored: Wed May 10 14:47:30 2017 +0530
Committer: Amey Barve <abarve@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);
-              }
             }
           }
 


Mime
View raw message