[kafka] 01/02: MINOR: Fix transient test failure in SslTransportLayerTest (#5396)

[rs...@apache.org]

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

rsivaram pushed a commit to branch 2.0
in repository https://gitbox.apache.org/repos/asf/kafka.git

commit dd6e5064538558ec7a3872cd576341f0335b68ba
Author: Rajini Sivaram <ra...@googlemail.com>
AuthorDate: Fri Jul 20 09:16:20 2018 +0100

    MINOR: Fix transient test failure in SslTransportLayerTest (#5396)
    
    Reviewers: Jason Gustafson <ja...@confluent.io>
---
 .../src/test/java/org/apache/kafka/common/network/NioEchoServer.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/clients/src/test/java/org/apache/kafka/common/network/NioEchoServer.java b/clients/src/test/java/org/apache/kafka/common/network/NioEchoServer.java
index 0c81b53..53f9d95 100644
--- a/clients/src/test/java/org/apache/kafka/common/network/NioEchoServer.java
+++ b/clients/src/test/java/org/apache/kafka/common/network/NioEchoServer.java
@@ -159,7 +159,6 @@ public class NioEchoServer extends Thread {
                 if (closeKafkaChannels) {
                     for (KafkaChannel channel : selector.channels())
                         selector.close(channel.id());
-                    closeKafkaChannels = false;
                 }
 
                 List<NetworkReceive> completedReceives = selector.completedReceives();
@@ -220,6 +219,8 @@ public class NioEchoServer extends Thread {
             TestUtils.waitForCondition(() -> selector.channels().isEmpty(), "Channels not closed");
         } catch (InterruptedException e) {
             throw new RuntimeException(e);
+        } finally {
+            closeKafkaChannels = false;
         }
     }