From 0c41e008d957bdc2b7291fbd9398eb1664a8ca20 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Endre=20S=C3=A1ndor=20Varga?= Date: Mon, 3 Mar 2014 15:06:12 +0100 Subject: [PATCH] =rem #3902: Reduce disassociate errors in remote stress-test --- .../scala/akka/remote/transport/AkkaProtocolStressTest.scala | 2 +- 1 file changed, 1 insertion(+), 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 520ad0840d..b952790251 100644 --- a/akka-remote/src/test/scala/akka/remote/transport/AkkaProtocolStressTest.scala +++ b/akka-remote/src/test/scala/akka/remote/transport/AkkaProtocolStressTest.scala @@ -104,7 +104,7 @@ class AkkaProtocolStressTest extends AkkaSpec(configA) with ImplicitSender with "guarantee at-most-once delivery and message ordering despite packet loss" taggedAs TimingTest in { system.eventStream.publish(TestEvent.Mute(DeadLettersFilter[Any])) systemB.eventStream.publish(TestEvent.Mute(DeadLettersFilter[Any])) - Await.result(RARP(system).provider.transport.managementCommand(One(addressB, Drop(0.3, 0.3))), 3.seconds.dilated) + Await.result(RARP(system).provider.transport.managementCommand(One(addressB, Drop(0.1, 0.1))), 3.seconds.dilated) val tester = system.actorOf(Props(classOf[SequenceVerifier], here, self)) ! "start"