You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by ud...@apache.org on 2016/08/10 19:41:08 UTC
[22/50] [abbrv] incubator-geode git commit: GEODE-1724 Now thread
updates Cq stats using ClientUpdateMessage.
GEODE-1724 Now thread updates Cq stats using ClientUpdateMessage.
Earlier it was feting value from disk.
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/fa36a0c3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/fa36a0c3
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/fa36a0c3
Branch: refs/heads/feature/GEODE-420
Commit: fa36a0c38c82e6157ecb9f7f4ca03a310951029b
Parents: 6ec789e
Author: Hitesh Khamesra <hk...@pivotal.io>
Authored: Wed Aug 3 13:43:34 2016 -0700
Committer: Hitesh Khamesra <hk...@pivotal.io>
Committed: Wed Aug 3 13:45:09 2016 -0700
----------------------------------------------------------------------
.../gemstone/gemfire/internal/cache/ha/HARegionQueue.java | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/fa36a0c3/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/ha/HARegionQueue.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/ha/HARegionQueue.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/ha/HARegionQueue.java
index f8f4500..6ac56ff 100755
--- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/ha/HARegionQueue.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/ha/HARegionQueue.java
@@ -1919,7 +1919,13 @@ public class HARegionQueue implements RegionQueue
if (cqService != null) {
try {
if (event instanceof HAEventWrapper) {
- event = (Conflatable)this.haContainer.get(event);
+ HAEventWrapper hw = (HAEventWrapper) event;
+ if (hw.getClientUpdateMessage() != null) {
+ event = hw.getClientUpdateMessage();
+ } else {
+ event = (Conflatable) this.haContainer.get(event);
+ }
+
if (event instanceof ClientUpdateMessage) {
if (((ClientUpdateMessage) event).hasCqs() && ((ClientUpdateMessage) event).hasCqs(clientProxyID)) {