ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [24/49] ignite git commit: ignite-1792: ContinuousProcessor should use ALWAYS_TRUE predicate instead of null
Date Thu, 29 Oct 2015 09:02:32 GMT
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-1282
Commit: b5a30693498c17e5ecea04dd19c8608f54321076
Parents: e9aa4d1
Author: Andrey Gura <agura@gridgain.com>
Authored: Tue Oct 27 14:03:27 2015 +0300
Committer: Denis Magda <dmagda@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,


Mime
View raw message