You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by bo...@apache.org on 2015/09/17 02:40:30 UTC
incubator-geode git commit: GEODE-335: The serial gateway sender
queue size statistic is not maintained properly across restarts
Repository: incubator-geode
Updated Branches:
refs/heads/develop 6fe66f32c -> 46ec8aeaa
GEODE-335: The serial gateway sender queue size statistic is not maintained properly across restarts
Incorporated changes from GemFire
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/46ec8aea
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/46ec8aea
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/46ec8aea
Branch: refs/heads/develop
Commit: 46ec8aeaa4a2a66e6861d5eca77446067e509ded
Parents: 6fe66f3
Author: Barry Oglesby <bo...@pivotal.io>
Authored: Wed Sep 16 17:39:42 2015 -0700
Committer: Barry Oglesby <bo...@pivotal.io>
Committed: Wed Sep 16 17:39:42 2015 -0700
----------------------------------------------------------------------
.../internal/cache/wan/serial/SerialGatewaySenderQueue.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/46ec8aea/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderQueue.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderQueue.java b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderQueue.java
index d2691bd..ec8c391 100644
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderQueue.java
+++ b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderQueue.java
@@ -206,6 +206,8 @@ public class SerialGatewaySenderQueue implements RegionQueue {
this.maximumQueueMemory = abstractSender.getMaximumMemeoryPerDispatcherQueue();
this.stats = abstractSender.getStatistics();
initializeRegion(abstractSender, listener);
+ // Increment queue size. Fix for bug 51988.
+ this.stats.incQueueSize(this.region.size());
this.removalThread = new BatchRemovalThread((GemFireCacheImpl)abstractSender.getCache());
this.removalThread.start();
this.sender = abstractSender;