"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "core/src/test/scala/unit/kafka/coordinator/AbstractCoordinatorConcurrencyTest.scala" between
kafka-2.1.1-src.tgz and kafka-2.2.0-src.tgz

About: Apache kafka is a distributed streaming platform.

AbstractCoordinatorConcurrencyTest.scala  (kafka-2.1.1-src.tgz):AbstractCoordinatorConcurrencyTest.scala  (kafka-2.2.0-src.tgz)
skipping to change at line 161 skipping to change at line 161
object AbstractCoordinatorConcurrencyTest { object AbstractCoordinatorConcurrencyTest {
trait Action extends Runnable { trait Action extends Runnable {
def await(): Unit def await(): Unit
} }
trait CoordinatorMember { trait CoordinatorMember {
} }
class TestReplicaManager extends ReplicaManager( class TestReplicaManager extends ReplicaManager(
null, null, null, null, null, null, null, null, null, null, null, null, null , null, None) { null, null, null, null, null, null, null, null, null, null, null, null, null , null, null, None) {
var producePurgatory: DelayedOperationPurgatory[DelayedProduce] = _ var producePurgatory: DelayedOperationPurgatory[DelayedProduce] = _
var watchKeys: mutable.Set[TopicPartitionOperationKey] = _ var watchKeys: mutable.Set[TopicPartitionOperationKey] = _
def createDelayedProducePurgatory(timer: MockTimer): Unit = { def createDelayedProducePurgatory(timer: MockTimer): Unit = {
producePurgatory = new DelayedOperationPurgatory[DelayedProduce]("Produce" , timer, 1, reaperEnabled = false) producePurgatory = new DelayedOperationPurgatory[DelayedProduce]("Produce" , timer, 1, reaperEnabled = false)
watchKeys = Collections.newSetFromMap(new ConcurrentHashMap[TopicPartition OperationKey, java.lang.Boolean]()).asScala watchKeys = Collections.newSetFromMap(new ConcurrentHashMap[TopicPartition OperationKey, java.lang.Boolean]()).asScala
} }
def tryCompleteDelayedRequests(): Unit = { def tryCompleteDelayedRequests(): Unit = {
watchKeys.map(producePurgatory.checkAndComplete) watchKeys.map(producePurgatory.checkAndComplete)
} }
 End of changes. 1 change blocks. 
1 lines changed or deleted 1 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)