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

Unwrap single string interpolation syntax

Browse source
This commit is contained in:
Matthew de Detrich 2023-05-22 20:47:29 +02:00
parent dc216add10
commit 480f516398
No known key found for this signature in database
GPG key ID: 196CBC8FEAA4CC64
94 changed files with 276 additions and 276 deletions
Download patch file Download diff file Expand all files Collapse all files

2
remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/artery/LatencySpec.scala
View file

@ -164,7 +164,7 @@ object LatencySpec extends MultiNodeConfig {
f"50%%ile: ${percentile(50.0)}%.0f µs, " +
f"90%%ile: ${percentile(90.0)}%.0f µs, " +
f"99%%ile: ${percentile(99.0)}%.0f µs, " +
f"rate: ${throughput}%,.0f msg/s")
f"rate: $throughput%,.0f msg/s")
println("Histogram of RTT latencies in microseconds.")
histogram.outputPercentileDistribution(System.out, 1000.0)

2
remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/artery/PlotResult.scala
View file

@ -26,7 +26,7 @@ final case class PlotResult(values: Vector[(String, Number)] = Vector.empty) {
def csvValues: String = values.map(_._2).mkString("\"", "\",\"", "\"")
// this can be split to two lines with bash: cut -d':' -f2,3 | tr ':' $'\n'
def csv(name: String): String = s"PLOT_${name}:${csvLabels}:${csvValues}"
def csv(name: String): String = s"PLOT_$name:$csvLabels:$csvValues"
}

8
remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/artery/TestRateReporter.scala
View file

@ -26,13 +26,13 @@ class TestRateReporter(name: String)
if (totalBytes > 0) {
println(
name +
f": ${messagesPerSec}%,.0f msgs/sec, ${bytesPerSec}%,.0f bytes/sec, " +
f"totals ${totalMessages}%,d messages ${totalBytes / (1024 * 1024)}%,d MB")
f": $messagesPerSec%,.0f msgs/sec, $bytesPerSec%,.0f bytes/sec, " +
f"totals $totalMessages%,d messages ${totalBytes / (1024 * 1024)}%,d MB")
} else {
println(
name +
f": ${messagesPerSec}%,.0f msgs/sec " +
f"total ${totalMessages}%,d messages")
f": $messagesPerSec%,.0f msgs/sec " +
f"total $totalMessages%,d messages")
}
}
}) {}

2
remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/artery/aeron/AeronStreamLatencySpec.scala
View file

@ -148,7 +148,7 @@ abstract class AeronStreamLatencySpec
f"50%%ile: ${percentile(50.0)}%.0f µs, " +
f"90%%ile: ${percentile(90.0)}%.0f µs, " +
f"99%%ile: ${percentile(99.0)}%.0f µs, " +
f"rate: ${throughput}%,.0f msg/s")
f"rate: $throughput%,.0f msg/s")
println("Histogram of RTT latencies in microseconds.")
histogram.outputPercentileDistribution(System.out, 1000.0)

2
remote-tests/src/multi-jvm/scala/org/apache/pekko/remote/artery/aeron/AeronStreamMaxThroughputSpec.scala
View file

@ -141,7 +141,7 @@ abstract class AeronStreamMaxThroughputSpec
val throughput = 1000.0 * total / d
println(
f"=== AeronStreamMaxThroughput $testName: " +
f"${throughput}%,.0f msg/s, ${throughput * payloadSize}%,.0f bytes/s, " +
f"$throughput%,.0f msg/s, ${throughput * payloadSize}%,.0f bytes/s, " +
s"payload size $payloadSize, " +
s"$d ms to deliver $total messages")
plot = plot.add(testName, throughput * payloadSize / 1024 / 1024)