From b7a34198a4b3500fd766722ccac0239ec96b5d41 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Endre=20S=C3=A1ndor=20Varga?= Date: Fri, 21 Jun 2013 15:23:04 +0200 Subject: [PATCH 1/2] Tweaked drop policy to be less aggressive on the other system --- .../scala/akka/remote/transport/AkkaProtocolStressTest.scala | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/akka-remote/src/test/scala/akka/remote/transport/AkkaProtocolStressTest.scala b/akka-remote/src/test/scala/akka/remote/transport/AkkaProtocolStressTest.scala index 8c26b62c30..7af4ab04d1 100644 --- a/akka-remote/src/test/scala/akka/remote/transport/AkkaProtocolStressTest.scala +++ b/akka-remote/src/test/scala/akka/remote/transport/AkkaProtocolStressTest.scala @@ -68,7 +68,9 @@ object AkkaProtocolStressTest { class AkkaProtocolStressTest extends AkkaSpec(configA) with ImplicitSender with DefaultTimeout { - val systemB = ActorSystem("systemB", system.settings.config) + val systemB = ActorSystem( + "systemB", + ConfigFactory.parseString("akka.remote.maximum-retries-in-window = 10").withFallback(system.settings.config)) val remote = systemB.actorOf(Props(new Actor { def receive = { case seq: Int ⇒ sender ! seq From 99508e2bf0d52cd40afe8f6598847c6828b7184f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Endre=20S=C3=A1ndor=20Varga?= Date: Mon, 24 Jun 2013 09:33:16 +0200 Subject: [PATCH 2/2] Added comment --- .../scala/akka/remote/transport/AkkaProtocolStressTest.scala | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/akka-remote/src/test/scala/akka/remote/transport/AkkaProtocolStressTest.scala b/akka-remote/src/test/scala/akka/remote/transport/AkkaProtocolStressTest.scala index 7af4ab04d1..ce226b190b 100644 --- a/akka-remote/src/test/scala/akka/remote/transport/AkkaProtocolStressTest.scala +++ b/akka-remote/src/test/scala/akka/remote/transport/AkkaProtocolStressTest.scala @@ -70,7 +70,9 @@ class AkkaProtocolStressTest extends AkkaSpec(configA) with ImplicitSender with val systemB = ActorSystem( "systemB", - ConfigFactory.parseString("akka.remote.maximum-retries-in-window = 10").withFallback(system.settings.config)) + // 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 remote = systemB.actorOf(Props(new Actor { def receive = { case seq: Int ⇒ sender ! seq