Repository: geode
Updated Branches:
  refs/heads/develop 21d4ab2cf -> 149e06d53


GEODE-2879: LonerDistributionManager shutdown called from close

        * LonerDistributionManager shutdown was not being called from close() 
method call.
        * This resulted in the thread pool's threads to wait for 1 minute of 
inactivity for them to be killed.
        * This resulted in an extra delay while test executions.
        * shutdown called from close method


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

Branch: refs/heads/develop
Commit: 149e06d53a33fa7363da15bf3f9cb248d94fabf5
Parents: 21d4ab2
Author: nabarun <[email protected]>
Authored: Thu May 4 17:17:52 2017 -0700
Committer: nabarun <[email protected]>
Committed: Thu May 4 17:17:52 2017 -0700

----------------------------------------------------------------------
 .../geode/distributed/internal/LonerDistributionManager.java     | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/geode/blob/149e06d5/geode-core/src/main/java/org/apache/geode/distributed/internal/LonerDistributionManager.java
----------------------------------------------------------------------
diff --git 
a/geode-core/src/main/java/org/apache/geode/distributed/internal/LonerDistributionManager.java
 
b/geode-core/src/main/java/org/apache/geode/distributed/internal/LonerDistributionManager.java
index fdb6a13..d700175 100644
--- 
a/geode-core/src/main/java/org/apache/geode/distributed/internal/LonerDistributionManager.java
+++ 
b/geode-core/src/main/java/org/apache/geode/distributed/internal/LonerDistributionManager.java
@@ -284,7 +284,9 @@ public class LonerDistributionManager implements DM {
     return null;
   }
 
-  public void close() {}
+  public void close() {
+    shutdown();
+  }
 
   public void restartCommunications() {
 

Reply via email to