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/52ef0943
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/52ef0943
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/52ef0943
Branch: refs/heads/feature/GEODE-1801
Commit: 52ef094368b262f9f355ad582787c515c5e12abc
Parents: 71c6325
Author: nabarun <[email protected]>
Authored: Mon Oct 10 14:09:43 2016 -0700
Committer: Udo Kohlmeyer <[email protected]>
Committed: Tue Oct 11 14:06:53 2016 +1100
----------------------------------------------------------------------
.../geode/internal/cache/wan/serial/SerialGatewaySenderQueue.java | 1 -
1 file changed, 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/52ef0943/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();
}