ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [13/18] ignite git commit: cc
Date Thu, 25 May 2017 15:37:16 GMT
cc


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

Branch: refs/heads/ignite-5075-cc-debug
Commit: e6ffd828828ddc2aba00140742cb0cf30038b520
Parents: 0305930
Author: sboikov <sboikov@gridgain.com>
Authored: Thu May 25 13:32:03 2017 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Thu May 25 13:32:03 2017 +0300

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


http://git-wip-us.apache.org/repos/asf/ignite/blob/e6ffd828/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 98eaecb..b4f2dbd 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
@@ -456,6 +456,8 @@ public class CacheContinuousQueryHandler<K, V> implements GridContinuousHandler
 
                         if (backupQueue != null && node != null) {
                             for (CacheContinuousQueryEntry e : backupQueue) {
+                                e.markBackup();
+
                                 if (!e.isFiltered())
                                     prepareEntry(cctx, nodeId, e);
                             }
@@ -891,8 +893,6 @@ public class CacheContinuousQueryHandler<K, V> implements GridContinuousHandler
 
         CacheContinuousQueryEventBuffer buf = partitionBuffer(cctx, e.partition());
 
-        e.markBackup();
-
         buf.processEntry(e.forBackupQueue(), true);
     }
 


Mime
View raw message