You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vk...@apache.org on 2016/02/12 00:28:18 UTC
[43/43] ignite git commit: IGNITE-2249 - Do not deserialize services
on client node
IGNITE-2249 - Do not deserialize services on client node
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/798e570b
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/798e570b
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/798e570b
Branch: refs/heads/ignite-2249
Commit: 798e570bb10463d93c2ec4427fa586f3384ac0a7
Parents: 6ff7391
Author: Valentin Kulichenko <va...@gmail.com>
Authored: Thu Feb 11 15:27:11 2016 -0800
Committer: Valentin Kulichenko <va...@gmail.com>
Committed: Thu Feb 11 15:27:11 2016 -0800
----------------------------------------------------------------------
.../internal/processors/service/GridServiceProcessor.java | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/798e570b/modules/core/src/main/java/org/apache/ignite/internal/processors/service/GridServiceProcessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/service/GridServiceProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/service/GridServiceProcessor.java
index a1bf11f..1a48e8c 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/service/GridServiceProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/service/GridServiceProcessor.java
@@ -173,11 +173,13 @@ public class GridServiceProcessor extends GridProcessorAdapter {
if (ctx.deploy().enabled())
ctx.cache().context().deploy().ignoreOwnership(true);
+ boolean affNode = cache.context().affinityNode();
+
cfgQryId = cache.context().continuousQueries().executeInternalQuery(
- new DeploymentListener(), null, cache.context().affinityNode(), true, true);
+ new DeploymentListener(), null, affNode, true, !affNode);
assignQryId = cache.context().continuousQueries().executeInternalQuery(
- new AssignmentListener(), null, cache.context().affinityNode(), true, true);
+ new AssignmentListener(), null, affNode, true, !affNode);
}
finally {
if (ctx.deploy().enabled())
@@ -1535,7 +1537,7 @@ public class GridServiceProcessor extends GridProcessorAdapter {
private static final long serialVersionUID = 0L;
/** */
- private static final IgniteProductVersion SINCE_VER = IgniteProductVersion.fromString("1.5.0");
+ private static final IgniteProductVersion SINCE_VER = IgniteProductVersion.fromString("1.5.7");
/** */
private final String svcName;