geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From u..@apache.org
Subject [22/50] [abbrv] incubator-geode git commit: GEODE-1724 Now thread updates Cq stats using ClientUpdateMessage.
Date Wed, 10 Aug 2016 19:41:08 GMT
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 <hkhamesra@pivotal.io>
Authored: Wed Aug 3 13:43:34 2016 -0700
Committer: Hitesh Khamesra <hkhamesra@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)) {


Mime
View raw message