You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2013/01/17 19:18:46 UTC
[5/7] git commit: KAFKA-702 Deadlock between request
handler/processor threads; reviewed by Neha Narkhede, Jun Rao
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 <jk...@apache.org>
Authored: Wed Jan 16 10:00:22 2013 -0800
Committer: Neha Narkhede <ne...@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",