raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

mark FanOutThrougputSpec as pending, #23198

Browse source 
* and include right name in the === prints
This commit is contained in:
Patrik Nordwall 2017-11-14 08:38:35 +01:00
parent af411d2f8d
commit 68a2b2fa6e
4 changed files with 8 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

5
akka-remote-tests/src/multi-jvm/scala/akka/remote/artery/BenchmarkFileReporter.scala
View file

@ -19,6 +19,7 @@ import scala.util.Try
* results can be understood later.
*/
trait BenchmarkFileReporter {
def testName: String
def reportResults(result: String): Unit
def close(): Unit
}
@ -31,8 +32,10 @@ object BenchmarkFileReporter {
val formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd-HH-mm-ss")
def apply(testName: String, system: ActorSystem): BenchmarkFileReporter =
def apply(test: String, system: ActorSystem): BenchmarkFileReporter =
new BenchmarkFileReporter {
override val testName = test
val gitCommit = {
import sys.process._
Try("git describe".!!.trim).getOrElse("[unknown]")

1
akka-remote-tests/src/multi-jvm/scala/akka/remote/artery/FanOutThrougputSpec.scala
View file

@ -175,6 +175,7 @@ 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)

2
akka-remote-tests/src/multi-jvm/scala/akka/remote/artery/LatencySpec.scala
View file

@ -133,7 +133,7 @@ object LatencySpec extends MultiNodeConfig {
def percentile(p: Double): Double = histogram.getValueAtPercentile(p) / 1000.0
val throughput = 1000.0 * histogram.getTotalCount / math.max(1, totalDurationNanos.nanos.toMillis)
reporter.reportResults(s"=== Latency $testName: RTT " +
reporter.reportResults(s"=== ${reporter.testName} $testName: RTT " +
f"50%%ile: ${percentile(50.0)}%.0f µs, " +
f"90%%ile: ${percentile(90.0)}%.0f µs, " +
f"99%%ile: ${percentile(99.0)}%.0f µs, " +

4
akka-remote-tests/src/multi-jvm/scala/akka/remote/artery/MaxThroughputSpec.scala
View file

@ -36,7 +36,7 @@ object MaxThroughputSpec extends MultiNodeConfig {
akka.test.MaxThroughputSpec.actor-selection = off
akka {
loglevel = INFO
log-dead-letters = 10000
log-dead-letters = 100
# avoid TestEventListener
loggers = ["akka.event.Logging$$DefaultLogger"]
testconductor.barrier-timeout = ${barrierTimeout.toSeconds}s
@ -237,7 +237,7 @@ object MaxThroughputSpec extends MultiNodeConfig {
val throughput = (totalReceived * 1000.0 / took)
reporter.reportResults(
s"=== MaxThroughput ${self.path.name}: " +
s"=== ${reporter.testName} ${self.path.name}: " +
f"throughput ${throughput * testSettings.senderReceiverPairs}%,.0f msg/s, " +
f"${throughput * payloadSize * testSettings.senderReceiverPairs}%,.0f bytes/s (payload), " +
f"${throughput * totalSize(context.system) * testSettings.senderReceiverPairs}%,.0f bytes/s (total" +