ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [42/50] incubator-ignite git commit: holdcc/callcc fix discovered by visor
Date Thu, 23 Apr 2015 06:05:41 GMT
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-80
Commit: 0cf0dae9e22e27aa840cdc8acbd9362d5636bfda
Parents: 3d90d84
Author: Denis Magda <dmagda@gridgain.com>
Authored: Wed Apr 22 15:29:55 2015 +0300
Committer: Denis Magda <dmagda@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());
         }
     }


Mime
View raw message