This is an automated email from the ASF dual-hosted git repository. He-Pin pushed a commit to branch fix-remote-send-consistency-timeout in repository https://gitbox.apache.org/repos/asf/pekko.git
commit e3c8b2139fb75f19cb572ff57501e41a91143066 Author: He-Pin <[email protected]> AuthorDate: Wed Jun 3 15:31:53 2026 +0800 fix: widen RemoteSendConsistencySpec await window to 30s Motivation: ArteryTcp/TlsTcp SendConsistencyWithOneLaneSpec flake on busy CI: "must (also with actorSelection) be able to send messages concurrently preserving order" times out at the within window (10s dilated by timefactor=2 to 20s). The test drives ~4004 round trips through TCP/TLS-TCP across four sender pairs - TLS handshake plus JIT warmup easily exceed the original budget without indicating a real regression. Modification: Bump within(10.seconds) to within(30.seconds) at lines 179 and 219. Result: Up to 60s of dilated wall-clock headroom on CI; still fails fast on genuine deadlocks. Tests: - scalafmt --test on the changed file (passes) - did not run remote/test locally (env constraints); CI Check / Test will exercise the artery variants --- .../org/apache/pekko/remote/artery/RemoteSendConsistencySpec.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/remote/src/test/scala/org/apache/pekko/remote/artery/RemoteSendConsistencySpec.scala b/remote/src/test/scala/org/apache/pekko/remote/artery/RemoteSendConsistencySpec.scala index 69590cab69..91f7b71f16 100644 --- a/remote/src/test/scala/org/apache/pekko/remote/artery/RemoteSendConsistencySpec.scala +++ b/remote/src/test/scala/org/apache/pekko/remote/artery/RemoteSendConsistencySpec.scala @@ -176,7 +176,7 @@ abstract class AbstractRemoteSendConsistencySpec(config: Config) system.actorOf(senderProps(remoteRefC)) system.actorOf(senderProps(remoteRefA)) - within(10.seconds) { + within(30.seconds) { expectMsg("success") expectMsg("success") expectMsg("success") @@ -216,7 +216,7 @@ abstract class AbstractRemoteSendConsistencySpec(config: Config) system.actorOf(senderProps(selC)) system.actorOf(senderProps(selA)) - within(10.seconds) { + within(30.seconds) { expectMsg("success2") expectMsg("success2") expectMsg("success2") --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
