ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: cc
Date Wed, 24 May 2017 12:22:40 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-5075-cc 83083534e -> 8f4eba119


cc


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

Branch: refs/heads/ignite-5075-cc
Commit: 8f4eba119d8c90796fb4fb18acef334cb3e9c44c
Parents: 8308353
Author: sboikov <sboikov@gridgain.com>
Authored: Wed May 24 15:22:34 2017 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Wed May 24 15:22:34 2017 +0300

----------------------------------------------------------------------
 .../cache/query/continuous/CacheContinuousQueryHandler.java    | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/8f4eba11/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java
index 18faff4..c046095 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java
@@ -1153,13 +1153,13 @@ public class CacheContinuousQueryHandler<K, V> implements GridContinuousHandler
 
                         long filtered = pending.filteredCount();
 
-                        boolean fire = entry.updateCounter() == lastFiredEvt + 1;;
+                        boolean fire = e.getKey() == lastFiredEvt + 1;;
 
                         if (!fire && filtered > 0)
-                            fire = entry.updateCounter() - filtered == lastFiredEvt + 1;
+                            fire = e.getKey() - filtered == lastFiredEvt + 1;
 
                         if (fire) {
-                            lastFiredEvt = entry.updateCounter();
+                            lastFiredEvt = e.getKey();
 
                             if (e.getValue() != HOLE && !e.getValue().isFiltered())
                                 entries.add(new CacheContinuousQueryEvent<K, V>(cache,
cctx, e.getValue()));


Mime
View raw message