kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rsiva...@apache.org
Subject [kafka] branch trunk updated: MINOR: Fix transient test failure in SslTransportLayerTest (#5396)
Date Fri, 20 Jul 2018 08:16:26 GMT
This is an automated email from the ASF dual-hosted git repository.

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


The following commit(s) were added to refs/heads/trunk by this push:
     new be02dbe  MINOR: Fix transient test failure in SslTransportLayerTest (#5396)
be02dbe is described below

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

    MINOR: Fix transient test failure in SslTransportLayerTest (#5396)
    
    Reviewers: Jason Gustafson <jason@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;
         }
     }
 


Mime
View raw message