holdcc/callcc fix discovered by visor
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/0cf0dae9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/0cf0dae9 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/0cf0dae9 Branch: refs/heads/ignite-709_1 Commit: 0cf0dae9e22e27aa840cdc8acbd9362d5636bfda Parents: 3d90d84 Author: Denis Magda <dma...@gridgain.com> Authored: Wed Apr 22 15:29:55 2015 +0300 Committer: Denis Magda <dma...@gridgain.com> Committed: Wed Apr 22 15:29:55 2015 +0300 ---------------------------------------------------------------------- .../ignite/internal/processors/job/GridJobProcessor.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/0cf0dae9/modules/core/src/main/java/org/apache/ignite/internal/processors/job/GridJobProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/job/GridJobProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/job/GridJobProcessor.java index a13e170..48e9686 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/job/GridJobProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/job/GridJobProcessor.java @@ -1639,6 +1639,9 @@ public class GridJobProcessor extends GridProcessorAdapter { if (log.isDebugEnabled()) log.debug("Received onHeld() callback [worker=" + worker + ']'); + if (worker.isInternal()) + return true; + boolean res = false; if (activeJobs.containsKey(worker.getJobId())) { @@ -1661,6 +1664,9 @@ public class GridJobProcessor extends GridProcessorAdapter { log.debug("Received onUnheld() callback [worker=" + worker + ", active=" + activeJobs + ", held=" + heldJobs + ']'); + if (worker.isInternal()) + return true; + return heldJobs.remove(worker.getJobId()); } }
