You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2015/10/29 12:53:18 UTC
[24/50] ignite git commit: ignite-1792: ContinuousProcessor should
use ALWAYS_TRUE predicate instead of null
ignite-1792: ContinuousProcessor should use ALWAYS_TRUE predicate instead of null
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/b5a30693
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/b5a30693
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/b5a30693
Branch: refs/heads/ignite-1770
Commit: b5a30693498c17e5ecea04dd19c8608f54321076
Parents: e9aa4d1
Author: Andrey Gura <ag...@gridgain.com>
Authored: Tue Oct 27 14:03:27 2015 +0300
Committer: Denis Magda <dm...@gridgain.com>
Committed: Tue Oct 27 14:03:27 2015 +0300
----------------------------------------------------------------------
.../cache/query/continuous/CacheContinuousQueryManager.java | 6 ++----
1 file changed, 2 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/b5a30693/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 6a151a5..c7bf091 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
@@ -419,10 +419,8 @@ public class CacheContinuousQueryManager extends GridCacheManagerAdapter {
taskNameHash,
skipPrimaryCheck);
- IgnitePredicate<ClusterNode> pred = null;
-
- if (loc || cctx.config().getCacheMode() == CacheMode.LOCAL)
- pred = F.nodeForNodeId(cctx.localNodeId());
+ IgnitePredicate<ClusterNode> pred = (loc || cctx.config().getCacheMode() == CacheMode.LOCAL) ?
+ F.nodeForNodeId(cctx.localNodeId()) : F.<ClusterNode>alwaysTrue();
UUID id = cctx.kernalContext().continuous().startRoutine(
hnd,