tephra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From poo...@apache.org
Subject [1/2] incubator-tephra git commit: TEPHRA-271 Wait for the refresh thread to stop during shutdown to prevent race conditions
Date Tue, 01 May 2018 23:51:09 GMT
Repository: incubator-tephra
Updated Branches:
  refs/heads/master 69fec910d -> 84edc08cc


TEPHRA-271 Wait for the refresh thread to stop during shutdown to prevent race conditions

Signed-off-by: poorna <poorna@apache.org>


Project: http://git-wip-us.apache.org/repos/asf/incubator-tephra/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tephra/commit/84edc08c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tephra/tree/84edc08c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tephra/diff/84edc08c

Branch: refs/heads/master
Commit: 84edc08ccc5b0cfc7112fb89ab3ebc343ab9fcb9
Parents: fab3aa3
Author: poorna <poorna@apache.org>
Authored: Wed Apr 25 16:58:22 2018 -0700
Committer: poorna <poorna@apache.org>
Committed: Tue May 1 16:50:07 2018 -0700

----------------------------------------------------------------------
 .../java/org/apache/tephra/coprocessor/TransactionStateCache.java   | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-tephra/blob/84edc08c/tephra-core/src/main/java/org/apache/tephra/coprocessor/TransactionStateCache.java
----------------------------------------------------------------------
diff --git a/tephra-core/src/main/java/org/apache/tephra/coprocessor/TransactionStateCache.java
b/tephra-core/src/main/java/org/apache/tephra/coprocessor/TransactionStateCache.java
index a80ce61..ac329f9 100644
--- a/tephra-core/src/main/java/org/apache/tephra/coprocessor/TransactionStateCache.java
+++ b/tephra-core/src/main/java/org/apache/tephra/coprocessor/TransactionStateCache.java
@@ -78,6 +78,7 @@ public class TransactionStateCache extends AbstractIdleService implements
Config
   protected void shutDown() throws Exception {
     if (refreshService != null) {
       refreshService.interrupt();
+      refreshService.join(1000);
     }
 
     if (storage != null) {


Mime
View raw message