You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by bs...@apache.org on 2017/05/03 21:48:27 UTC

geode git commit: GEODE-2875 shutdown is taking as long as 20 seconds

Repository: geode
Updated Branches:
  refs/heads/develop d4ece31fa -> c3a70efaf


GEODE-2875  shutdown is taking as long as 20 seconds

Hitesh reviewed this change for me.  A more complete fix is in the works
but needs a lot of testing.  This change will reduce the stall from 20
seconds down to 5 seconds.


Project: http://git-wip-us.apache.org/repos/asf/geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/c3a70efa
Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/c3a70efa
Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/c3a70efa

Branch: refs/heads/develop
Commit: c3a70efaf43b470bd16ab6c1a3a003e5f99686d0
Parents: d4ece31
Author: Bruce Schuchardt <bs...@pivotal.io>
Authored: Wed May 3 14:43:21 2017 -0700
Committer: Bruce Schuchardt <bs...@pivotal.io>
Committed: Wed May 3 14:48:15 2017 -0700

----------------------------------------------------------------------
 .../org/apache/geode/distributed/internal/DistributionManager.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/geode/blob/c3a70efa/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionManager.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionManager.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionManager.java
index 44baa09..df880a0 100644
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionManager.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionManager.java
@@ -1901,7 +1901,7 @@ public class DistributionManager implements DM {
         t.start();
         boolean interrupted = Thread.interrupted();
         try {
-          t.join(MAX_STOP_TIME);
+          t.join(MAX_STOP_TIME / 4);
         } catch (final InterruptedException e) {
           interrupted = true;
           t.interrupt();