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

Merge pull request #1564 from drewhk/wip-3466-retry-limit-off-apt-stress-drewhk

Browse source 
Turn of retry-limit for AkkaProtocolStressTest #3466
This commit is contained in:
drewhk 2013-06-25 05:51:25 -07:00
commit 402f6eba94
1 changed files with 6 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

13
akka-remote/src/test/scala/akka/remote/transport/AkkaProtocolStressTest.scala
View file

@ -25,7 +25,10 @@ object AkkaProtocolStressTest {
acceptable-heartbeat-pause = 0.01 s
}
remote.retry-window = 1 s
remote.maximum-retries-in-window = 3
# This test drops messages, but dropping too much will make it fail. The reason is that this test
# expects at least a few of the final messages to arrive to prove that the Remoting does not get stuck
# in an irrecoverable state. The retry limit enabled case is covered by the SystemMessageDelivery tests.
remote.maximum-retries-in-window = 100
remote.netty.tcp {
applied-adapters = ["gremlin"]
@ -33,7 +36,7 @@ object AkkaProtocolStressTest {
}
}
""")
""")
class SequenceVerifier(remote: ActorRef, controller: ActorRef) extends Actor {
import context.dispatcher
@ -68,11 +71,7 @@ object AkkaProtocolStressTest {
class AkkaProtocolStressTest extends AkkaSpec(configA) with ImplicitSender with DefaultTimeout {
val systemB = ActorSystem(
"systemB",
// Retry limit for system B should be high enough that it does not trigger during this test. Otherwise
// too much messages can be dropped causing the test to fail sporadically.
ConfigFactory.parseString("akka.remote.maximum-retries-in-window = 20").withFallback(system.settings.config))
val systemB = ActorSystem("systemB", system.settings.config)
val remote = systemB.actorOf(Props(new Actor {
def receive = {
case seq: Int ⇒ sender ! seq