Repository: incubator-ignite Updated Branches: refs/heads/master abafd4100 -> c55d9231f
GG-9615 Interop .Net: Implement GridServices API. Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/c55d9231 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/c55d9231 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/c55d9231 Branch: refs/heads/master Commit: c55d9231f5fc9459c7964bb2c3d46eb9f214d2c2 Parents: abafd41 Author: ptupitsyn <ptupit...@gridgain.com> Authored: Fri Aug 21 15:09:59 2015 +0300 Committer: ptupitsyn <ptupit...@gridgain.com> Committed: Fri Aug 21 15:09:59 2015 +0300 ---------------------------------------------------------------------- .../internal/processors/service/GridServiceProcessor.java | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c55d9231/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 78b09e6..0f43b8a 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 @@ -651,6 +651,11 @@ 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();
