# ignite-47 Cleanup code.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/d41ceef5 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/d41ceef5 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/d41ceef5 Branch: refs/heads/ignite-47 Commit: d41ceef50b3468ac36eb0c338b165fadf806b379 Parents: 2c29387 Author: sevdokimov <[email protected]> Authored: Sat Mar 7 21:54:45 2015 +0300 Committer: sevdokimov <[email protected]> Committed: Sat Mar 7 21:54:45 2015 +0300 ---------------------------------------------------------------------- .../processors/closure/GridClosureProcessor.java | 17 ++++++----------- 1 file changed, 6 insertions(+), 11 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d41ceef5/modules/core/src/main/java/org/apache/ignite/internal/processors/closure/GridClosureProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/closure/GridClosureProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/closure/GridClosureProcessor.java index f6103e3..0f611e4 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/closure/GridClosureProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/closure/GridClosureProcessor.java @@ -590,7 +590,7 @@ public class GridClosureProcessor extends GridProcessorAdapter { ctx.task().setThreadContext(TC_SUBGRID, nodes); - return ctx.task().execute(new T11<>(job, arg), null, false); + return ctx.task().execute(new T11<>(job), arg, false); } finally { leaveBusy(); @@ -614,7 +614,7 @@ public class GridClosureProcessor extends GridProcessorAdapter { ctx.task().setThreadContext(TC_SUBGRID, nodes); ctx.task().setThreadContext(TC_NO_FAILOVER, true); - return ctx.task().execute(new T11<>(job, arg), null, false); + return ctx.task().execute(new T11<>(job), arg, false); } finally { leaveBusy(); @@ -1540,7 +1540,7 @@ public class GridClosureProcessor extends GridProcessorAdapter { /** */ - private class T11<T, R> extends GridPeerDeployAwareTaskAdapter<Void, Collection<R>> + private class T11<T, R> extends GridPeerDeployAwareTaskAdapter<T, Collection<R>> implements GridNoImplicitInjection { /** */ private static final long serialVersionUID = 0L; @@ -1548,22 +1548,17 @@ public class GridClosureProcessor extends GridProcessorAdapter { /** */ private final IgniteClosure<T, R> job; - /** */ - private final T arg; - /** * @param job Job. - * @param arg Job argument. */ - private T11(IgniteClosure<T, R> job, @Nullable T arg) { + private T11(IgniteClosure<T, R> job) { super(U.peerDeployAware(job)); this.job = job; - this.arg = arg; } /** {@inheritDoc} */ - @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, @Nullable Void arg) { + @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, @Nullable T arg) { if (F.isEmpty(subgrid)) return Collections.emptyMap(); @@ -1571,7 +1566,7 @@ public class GridClosureProcessor extends GridProcessorAdapter { JobMapper mapper = new JobMapper(subgrid.size()); for (ClusterNode n : subgrid) - mapper.map(job(job, this.arg), n); + mapper.map(job(job, arg), n); return mapper.map(); }
