kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject [5/7] git commit: KAFKA-702 Deadlock between request handler/processor threads; reviewed by Neha Narkhede, Jun Rao
Date Thu, 17 Jan 2013 18:18:46 GMT
KAFKA-702 Deadlock between request handler/processor threads; reviewed by Neha Narkhede, Jun
Rao


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/da7f1467
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/da7f1467
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/da7f1467

Branch: refs/heads/trunk
Commit: da7f14676e677bb6b4fc1ea75fe9792709954591
Parents: 777f662
Author: Edward Jay Kreps <jkreps@apache.org>
Authored: Wed Jan 16 10:00:22 2013 -0800
Committer: Neha Narkhede <neha.narkhede@gmail.com>
Committed: Wed Jan 16 10:00:31 2013 -0800

----------------------------------------------------------------------
 .../main/scala/kafka/network/RequestChannel.scala  |    2 +-
 1 files changed, 1 insertions(+), 1 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/da7f1467/core/src/main/scala/kafka/network/RequestChannel.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/network/RequestChannel.scala b/core/src/main/scala/kafka/network/RequestChannel.scala
index 0e5b7cb..848c877 100644
--- a/core/src/main/scala/kafka/network/RequestChannel.scala
+++ b/core/src/main/scala/kafka/network/RequestChannel.scala
@@ -98,7 +98,7 @@ class RequestChannel(val numProcessors: Int, val queueSize: Int) extends
KafkaMe
   private val requestQueue = new ArrayBlockingQueue[RequestChannel.Request](queueSize)
   private val responseQueues = new Array[BlockingQueue[RequestChannel.Response]](numProcessors)
   for(i <- 0 until numProcessors)
-    responseQueues(i) = new ArrayBlockingQueue[RequestChannel.Response](queueSize)
+    responseQueues(i) = new LinkedBlockingQueue[RequestChannel.Response]()
 
   newGauge(
     "RequestQueueSize",


Mime
View raw message