From eefd6869a58a17c16e62976062d2bf506259cd2d Mon Sep 17 00:00:00 2001 From: Patrik Nordwall Date: Tue, 14 Nov 2017 12:28:27 +0100 Subject: [PATCH] adjust burstSize in FanOutThrougputSpec, #23198 --- .../scala/akka/remote/artery/FanOutThrougputSpec.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/akka-remote-tests/src/multi-jvm/scala/akka/remote/artery/FanOutThrougputSpec.scala b/akka-remote-tests/src/multi-jvm/scala/akka/remote/artery/FanOutThrougputSpec.scala index 7ee9d93b07..acc8741af6 100644 --- a/akka-remote-tests/src/multi-jvm/scala/akka/remote/artery/FanOutThrougputSpec.scala +++ b/akka-remote-tests/src/multi-jvm/scala/akka/remote/artery/FanOutThrougputSpec.scala @@ -95,7 +95,8 @@ abstract class FanOutThroughputSpec extends RemotingMultiNodeSpec(FanOutThroughp else ActorRefTarget(ref) } - val burstSize = 2000 / senderReceiverPairs + // each sender may have 3 bursts in flight + val burstSize = 3000 / senderReceiverPairs / 3 val scenarios = List( TestSettings( testName = "warmup", @@ -175,7 +176,6 @@ abstract class FanOutThroughputSpec extends RemotingMultiNodeSpec(FanOutThroughp } "Max throughput of fan-out" must { - pending // FIXME until issue #23198 has been solved val reporter = BenchmarkFileReporter("FanOutThroughputSpec", system) for (s ← scenarios) { s"be great for ${s.testName}, burstSize = ${s.burstSize}, payloadSize = ${s.payloadSize}" in test(s, reporter)