/[Apache-SVN]

Revision 1419692

Jump to revision:
Author:	jkreps
Date:	Mon Dec 10 19:31:29 2012 UTC (11 years, 11 months ago)
Changed paths:	16
Log Message:	KAFKA-597 Refactor scheduler. Fixes a couple of bugs, and adds the ability to mock scheduled tasks.

Changed paths

Path	Details
kafka/trunk/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala	modified , text changed
kafka/trunk/core/src/main/scala/kafka/log/Log.scala	modified , text changed
kafka/trunk/core/src/main/scala/kafka/log/LogManager.scala	modified , text changed
kafka/trunk/core/src/main/scala/kafka/server/KafkaConfig.scala	modified , text changed
kafka/trunk/core/src/main/scala/kafka/server/KafkaServer.scala	modified , text changed
kafka/trunk/core/src/main/scala/kafka/server/ReplicaManager.scala	modified , text changed
kafka/trunk/core/src/main/scala/kafka/utils/KafkaScheduler.scala	modified , text changed
kafka/trunk/core/src/main/scala/kafka/utils/MockTime.scala	deleted
kafka/trunk/core/src/main/scala/kafka/utils/Utils.scala	modified , text changed
kafka/trunk/core/src/test/scala/unit/kafka/log/LogManagerTest.scala	modified , text changed
kafka/trunk/core/src/test/scala/unit/kafka/log/LogTest.scala	modified , text changed
kafka/trunk/core/src/test/scala/unit/kafka/server/HighwatermarkPersistenceTest.scala	modified , text changed
kafka/trunk/core/src/test/scala/unit/kafka/utils/MockScheduler.scala	added
kafka/trunk/core/src/test/scala/unit/kafka/utils/MockTime.scala	added
kafka/trunk/core/src/test/scala/unit/kafka/utils/SchedulerTest.scala	added
kafka/trunk/core/src/test/scala/unit/kafka/utils/TestUtils.scala	modified , text changed

infrastructure at apache.org	ViewVC Help
Powered by ViewVC 1.1.26