You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by jr...@apache.org on 2023/02/14 13:28:15 UTC
[incubator-pekko-http] branch main updated: fix config in HttpServerLatencyMultiNodeSpec (#50)
This is an automated email from the ASF dual-hosted git repository.
jrudolph pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko-http.git
The following commit(s) were added to refs/heads/main by this push:
new 1cfacad41 fix config in HttpServerLatencyMultiNodeSpec (#50)
1cfacad41 is described below
commit 1cfacad416d7530b5ad6c10c1f8e21b1fdb34580
Author: Johannes Rudolph <jo...@gmail.com>
AuthorDate: Tue Feb 14 14:28:09 2023 +0100
fix config in HttpServerLatencyMultiNodeSpec (#50)
---
.../http/PekkoHttpServerLatencyMultiNodeSpec.scala | 23 +++++++++++-----------
1 file changed, 12 insertions(+), 11 deletions(-)
diff --git a/http-tests/src/multi-jvm/scala/org/apache/pekko/http/PekkoHttpServerLatencyMultiNodeSpec.scala b/http-tests/src/multi-jvm/scala/org/apache/pekko/http/PekkoHttpServerLatencyMultiNodeSpec.scala
index cea723388..4770a45d4 100644
--- a/http-tests/src/multi-jvm/scala/org/apache/pekko/http/PekkoHttpServerLatencyMultiNodeSpec.scala
+++ b/http-tests/src/multi-jvm/scala/org/apache/pekko/http/PekkoHttpServerLatencyMultiNodeSpec.scala
@@ -36,8 +36,9 @@ object PekkoHttpServerLatencyMultiNodeSpec extends MultiNodeConfig {
stream.materializer.debug.fuzzing-mode = off
testconductor.barrier-timeout = 30m
-
- test.AkkaHttpServerLatencySpec {
+ }
+ pekko {
+ test.PekkoHttpServerLatencySpec {
enable = off
rate = 10000
@@ -146,13 +147,13 @@ class PekkoHttpServerLatencyMultiNodeSpec extends MultiNodeSpec(PekkoHttpServerL
})
}
- val enableSpec = system.settings.config.getBoolean("org.apache.pekko.test.AkkaHttpServerLatencySpec.enable")
+ val enableSpec = system.settings.config.getBoolean("pekko.test.PekkoHttpServerLatencySpec.enable")
val totalRequestsFactor =
- system.settings.config.getDouble("org.apache.pekko.test.AkkaHttpServerLatencySpec.totalRequestsFactor")
+ system.settings.config.getDouble("pekko.test.PekkoHttpServerLatencySpec.totalRequestsFactor")
val requests = Math.round(10000 * totalRequestsFactor)
- val rate = system.settings.config.getInt("org.apache.pekko.test.AkkaHttpServerLatencySpec.rate")
+ val rate = system.settings.config.getInt("pekko.test.PekkoHttpServerLatencySpec.rate")
val testDuration =
- system.settings.config.getDuration("org.apache.pekko.test.AkkaHttpServerLatencySpec.duration", TimeUnit.SECONDS)
+ system.settings.config.getDuration("pekko.test.PekkoHttpServerLatencySpec.duration", TimeUnit.SECONDS)
val connections: Long = 10
override def binding = _binding
@@ -169,8 +170,8 @@ class PekkoHttpServerLatencyMultiNodeSpec extends MultiNodeSpec(PekkoHttpServerL
// ---
if (enableSpec) {
- "Akka HTTP" must {
- "start Akka HTTP" taggedAs LongRunningTest in {
+ "Pekko HTTP" must {
+ "start Pekko HTTP" taggedAs LongRunningTest in {
enterBarrier("startup")
runOn(loadGenerator) {
@@ -180,7 +181,7 @@ class PekkoHttpServerLatencyMultiNodeSpec extends MultiNodeSpec(PekkoHttpServerL
runOn(server) {
val port = 0
- info(s"Binding Akka HTTP Server to port: $port @ ${myself}")
+ info(s"Binding Pekko HTTP Server to port: $port @ ${myself}")
val binding = Http().newServerAt("0.0.0.0", port).bind(routes).futureValue
_binding = Some(binding)
@@ -237,8 +238,8 @@ class PekkoHttpServerLatencyMultiNodeSpec extends MultiNodeSpec(PekkoHttpServerL
}
}
} else {
- "Akka HTTP" must {
- "enable these performance tests by running with -Dakka.test.AkkaHttpServerLatencySpec.enable=on" in pending
+ "Pekko HTTP" must {
+ "enable these performance tests by running with -Dpekko.test.PekkoHttpServerLatencySpec.enable=on" in pending
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org