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

Merge pull request #23887 from akka/wip-22192-RemoteScatterGatherSpec-patriknw

Browse source 
harden RemoteScatterGatherSpec, #22192
This commit is contained in:
Patrik Nordwall 2017-11-06 16:41:03 +01:00 • committed by GitHub
commit 2690ce1730
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 4 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

1
akka-remote-tests/src/multi-jvm/scala/akka/remote/routing/RemoteRoundRobinSpec.scala
View file

@ -25,7 +25,6 @@ class RemoteRoundRobinConfig(artery: Boolean) extends MultiNodeConfig {
commonConfig(debugConfig(on = false).withFallback(
ConfigFactory.parseString(s"""
akka.loglevel = DEBUG
akka.remote.artery.enabled = $artery
""")).withFallback(RemotingMultiNodeSpec.commonConfig))

5
akka-remote-tests/src/multi-jvm/scala/akka/remote/routing/RemoteScatterGatherSpec.scala
View file

@ -81,6 +81,9 @@ class RemoteScatterGatherSpec(multiNodeConfig: RemoteScatterGatherConfig) extend
val connectionCount = 3
val iterationCount = 10
// let them start
Thread.sleep(2000)
for (i ← 0 until iterationCount; k ← 0 until connectionCount) {
actor ! "hit"
}
@ -104,7 +107,7 @@ class RemoteScatterGatherSpec(multiNodeConfig: RemoteScatterGatherConfig) extend
enterBarrier("done")
}
enterBarrier("done")
enterBarrier("all-done")
}
}
}