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/07/15 20:50:12 UTC
incubator-ignite git commit: GG-9615 wip
Repository: incubator-ignite
Updated Branches:
refs/heads/ignite-gg-9615 bdd176267 -> cf2ff2d4b
GG-9615 wip
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/cf2ff2d4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/cf2ff2d4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/cf2ff2d4
Branch: refs/heads/ignite-gg-9615
Commit: cf2ff2d4ba1d7d205c03365e8e1ef8bdfe25a09f
Parents: bdd1762
Author: Pavel Tupitsyn <pt...@gridgain.com>
Authored: Wed Jul 15 21:49:50 2015 +0300
Committer: Pavel Tupitsyn <pt...@gridgain.com>
Committed: Wed Jul 15 21:49:50 2015 +0300
----------------------------------------------------------------------
.../ignite/internal/processors/service/GridServiceProcessor.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cf2ff2d4/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 bb451c7..26d18a8 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
@@ -621,6 +621,10 @@ public class GridServiceProcessor extends GridProcessorAdapter {
private void reassign(GridServiceDeployment dep, long topVer) throws IgniteCheckedException {
ServiceConfiguration cfg = dep.configuration();
+ Object nodeFilter = cfg.getNodeFilter();
+ if (nodeFilter != null)
+ ctx.resource().injectGeneric(nodeFilter);
+
int totalCnt = cfg.getTotalCount();
int maxPerNodeCnt = cfg.getMaxPerNodeCount();
String cacheName = cfg.getCacheName();