From fa78ac7e0848f32f334bd6b9360849bb058a181a Mon Sep 17 00:00:00 2001 From: Tim Brooks Date: Wed, 25 Mar 2015 13:56:20 -0700 Subject: [PATCH] Avoid calling size() on concurrent queue. --- core/src/main/scala/kafka/network/SocketServer.scala | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/core/src/main/scala/kafka/network/SocketServer.scala b/core/src/main/scala/kafka/network/SocketServer.scala index 76ce41a..809aaac 100644 --- a/core/src/main/scala/kafka/network/SocketServer.scala +++ b/core/src/main/scala/kafka/network/SocketServer.scala @@ -423,10 +423,11 @@ private[kafka] class Processor(val id: Int, * Register any new connections that have been queued up */ private def configureNewConnections() { - while(newConnections.size() > 0) { - val channel = newConnections.poll() + var channel: SocketChannel = newConnections.poll() + while(channel != null) { debug("Processor " + id + " listening to new connection from " + channel.socket.getRemoteSocketAddress) channel.register(selector, SelectionKey.OP_READ) + channel = newConnections.poll() } } -- 2.3.1