You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2017/05/25 15:37:16 UTC
[13/18] ignite git commit: cc
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 <sb...@gridgain.com>
Authored: Thu May 25 13:32:03 2017 +0300
Committer: sboikov <sb...@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);
}