ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ntikho...@apache.org
Subject ignite git commit: IGNITE-2004 Fixed review notes.
Date Mon, 11 Apr 2016 16:28:00 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-2004 7adb618b1 -> cd90d65d7


IGNITE-2004 Fixed review notes.


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

Branch: refs/heads/ignite-2004
Commit: cd90d65d7bf76b2613200379428d2bc70f737ed6
Parents: 7adb618
Author: nikolay_tikhonov <ntikhonov@gridgain.com>
Authored: Mon Apr 11 19:28:16 2016 +0300
Committer: nikolay_tikhonov <ntikhonov@gridgain.com>
Committed: Mon Apr 11 19:28:16 2016 +0300

----------------------------------------------------------------------
 .../cache/query/continuous/CacheContinuousQueryManager.java     | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/cd90d65d/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
index 3a5e891..48b2546 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
@@ -295,9 +295,12 @@ public class CacheContinuousQueryManager extends GridCacheManagerAdapter
{
         boolean hasNewVal = newVal != null;
         boolean hasOldVal = oldVal != null;
 
-        if (!hasNewVal && !hasOldVal)
+        if (!hasNewVal && !hasOldVal) {
             skipUpdateEvent(lsnrCol, key, partId, updateCntr, primary, topVer);
 
+            return;
+        }
+
         EventType evtType = !hasNewVal ? REMOVED : !hasOldVal ? CREATED : UPDATED;
 
         boolean initialized = false;


Mime
View raw message