From cfbf4762cfba0a2edab07b930163f224b30afcae Mon Sep 17 00:00:00 2001 From: Jun Rao Date: Sun, 10 Aug 2014 21:44:42 -0700 Subject: [PATCH] set alive to true only during initialization --- core/src/main/scala/kafka/network/SocketServer.scala | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/core/src/main/scala/kafka/network/SocketServer.scala b/core/src/main/scala/kafka/network/SocketServer.scala index 8e99de0..9693bc0 100644 --- a/core/src/main/scala/kafka/network/SocketServer.scala +++ b/core/src/main/scala/kafka/network/SocketServer.scala @@ -102,7 +102,7 @@ private[kafka] abstract class AbstractServerThread(connectionQuotas: ConnectionQ protected val selector = Selector.open(); private val startupLatch = new CountDownLatch(1) private val shutdownLatch = new CountDownLatch(1) - private val alive = new AtomicBoolean(false) + private val alive = new AtomicBoolean(true) /** * Initiates a graceful shutdown by signaling to stop and waiting for the shutdown to complete @@ -122,7 +122,6 @@ private[kafka] abstract class AbstractServerThread(connectionQuotas: ConnectionQ * Record that the thread startup is complete */ protected def startupComplete() = { - alive.set(true) startupLatch.countDown } -- 1.8.3.4 (Apple Git-47)