You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by av...@apache.org on 2017/07/07 13:47:35 UTC
ignite git commit: IGNITE-5554 ServiceProcessor may process failed
reassignments in timeout thread
Repository: ignite
Updated Branches:
refs/heads/master d1d680237 -> 45cd87fe7
IGNITE-5554 ServiceProcessor may process failed reassignments in timeout thread
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/45cd87fe
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/45cd87fe
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/45cd87fe
Branch: refs/heads/master
Commit: 45cd87fe73db117f5148ed2006f8de8d2517bbfe
Parents: d1d6802
Author: mcherkasov <mc...@gridgain.com>
Authored: Fri Jun 30 20:23:55 2017 +0300
Committer: Anton Vinogradov <av...@apache.org>
Committed: Fri Jul 7 16:47:13 2017 +0300
----------------------------------------------------------------------
.../service/GridServiceProcessor.java | 24 +++++++++-----------
1 file changed, 11 insertions(+), 13 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/45cd87fe/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 d67f2d1..23a29f8 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
@@ -26,6 +26,7 @@ import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.UUID;
+import java.util.concurrent.Callable;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.ExecutorService;
@@ -1509,18 +1510,11 @@ public class GridServiceProcessor extends GridProcessorAdapter implements Ignite
}
@Override public void onTimeout() {
- GridSpinBusyLock busyLock = GridServiceProcessor.this.busyLock;
-
- if (busyLock == null || !busyLock.enterBusy())
- return;
-
- try {
- // Try again.
- onDeployment(dep, topVer);
- }
- finally {
- busyLock.leaveBusy();
- }
+ depExe.execute(new DepRunnable() {
+ @Override public void run0() {
+ onDeployment(dep, topVer);
+ }
+ });
}
});
}
@@ -1716,7 +1710,11 @@ public class GridServiceProcessor extends GridProcessorAdapter implements Ignite
}
@Override public void onTimeout() {
- onReassignmentFailed(topVer, retries);
+ depExe.execute(new Runnable() {
+ public void run() {
+ onReassignmentFailed(topVer, retries);
+ }
+ });
}
});
}