[curator] branch master updated: CURATOR-536 break infinite loop in internalLeave() on timeout

[shayshim]

This is an automated email from the ASF dual-hosted git repository.

shayshim pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/curator.git


The following commit(s) were added to refs/heads/master by this push:
     new 9fb8dad  CURATOR-536 break infinite loop in internalLeave() on timeout
     new 0e4994b  Merge pull request #322 from abcdenis/CURATOR-536
9fb8dad is described below

commit 9fb8dadba00f6b030c5d7e6038fe971397f5538b
Author: abcdenis <abcde...@users.noreply.github.com>
AuthorDate: Thu Aug 8 12:17:23 2019 +0300

    CURATOR-536 break infinite loop in internalLeave() on timeout
    
    subj!
---
 .../curator/framework/recipes/barriers/DistributedDoubleBarrier.java     | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/curator-recipes/src/main/java/org/apache/curator/framework/recipes/barriers/DistributedDoubleBarrier.java
 
b/curator-recipes/src/main/java/org/apache/curator/framework/recipes/barriers/DistributedDoubleBarrier.java
index 2315178..e6b300f 100644
--- 
a/curator-recipes/src/main/java/org/apache/curator/framework/recipes/barriers/DistributedDoubleBarrier.java
+++ 
b/curator-recipes/src/main/java/org/apache/curator/framework/recipes/barriers/DistributedDoubleBarrier.java
@@ -263,6 +263,7 @@ public class DistributedDoubleBarrier
                     if ( thisWaitMs <= 0 )
                     {
                         result = false;
+                        break;
                     }
                     else
                     {