Repository: incubator-geode
Updated Branches:
  refs/heads/develop 4b3ae7867 -> a0acc3ca6


GEODE-1926: Removing the extra getObjectInSerialSenderQueue call

        * This was causing few tests to hang waiting for queues to drain.


Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/a0acc3ca
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/a0acc3ca
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/a0acc3ca

Branch: refs/heads/develop
Commit: a0acc3ca646a72379f8fc25297d5301ffd95da80
Parents: 4b3ae78
Author: nabarun <n...@pivotal.io>
Authored: Mon Oct 10 14:09:43 2016 -0700
Committer: nabarun <n...@pivotal.io>
Committed: Mon Oct 10 14:09:43 2016 -0700

----------------------------------------------------------------------
 .../geode/internal/cache/wan/serial/SerialGatewaySenderQueue.java   | 1 -
 1 file changed, 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/a0acc3ca/geode-core/src/main/java/org/apache/geode/internal/cache/wan/serial/SerialGatewaySenderQueue.java
----------------------------------------------------------------------
diff --git 
a/geode-core/src/main/java/org/apache/geode/internal/cache/wan/serial/SerialGatewaySenderQueue.java
 
b/geode-core/src/main/java/org/apache/geode/internal/cache/wan/serial/SerialGatewaySenderQueue.java
index 28f5f83..79b9d86 100644
--- 
a/geode-core/src/main/java/org/apache/geode/internal/cache/wan/serial/SerialGatewaySenderQueue.java
+++ 
b/geode-core/src/main/java/org/apache/geode/internal/cache/wan/serial/SerialGatewaySenderQueue.java
@@ -811,7 +811,6 @@ public class SerialGatewaySenderQueue implements 
RegionQueue {
         logger.trace("{}: Trying head key + offset: {}", this, currentKey);
       }
       currentKey = inc(currentKey);
-      object = getObjectInSerialSenderQueue(currentKey);
       if (this.stats != null) {
         this.stats.incEventsNotQueuedConflated();
       }

Reply via email to