/[Apache-SVN]
ViewVC logotype

Revision 1374069


Jump to revision: Previous Next
Author: jjkoshy
Date: Thu Aug 16 21:26:40 2012 UTC (11 years, 7 months ago)
Changed paths: 18
Log Message:
KAFKA-385 Fix race condition between checkSatisfied and expire in RequestPurgatory; fixed constant expiration of follower fetch requests as checkSatisfied was not getting called; add metrics to the RequestPurgatory; add a KafkaTimer convenience class; patched by Joel Koshy; reviewed by Jun Rao and Jay Kreps.

Changed paths

Path Details
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/Kafka.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/api/FetchResponse.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/metrics/ added
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/metrics/KafkaCSVMetricsReporter.scala added
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/metrics/KafkaMetricsConfig.scala added
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/metrics/KafkaMetricsGroup.scala added
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/metrics/KafkaMetricsReporter.scala added
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/metrics/KafkaTimer.scala added
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaApis.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaConfig.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/server/RequestPurgatory.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/Pool.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/LogCorruptionTest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/TopicMetadataTest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/metrics/ added
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/metrics/KafkaTimerTest.scala added
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/RequestPurgatoryTest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/project/build/KafkaProject.scala modified , text changed

infrastructure at apache.org
ViewVC Help
Powered by ViewVC 1.1.26