This is an automated email from the ASF dual-hosted git repository.
He-Pin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko.git
The following commit(s) were added to refs/heads/main by this push:
new 153c151950 fix: widen RemoteSendConsistencySpec await window to 30s
(#3041)
153c151950 is described below
commit 153c151950294d280ceab1a7450ae0d1bd9f39eb
Author: He-Pin(kerr) <[email protected]>
AuthorDate: Thu Jun 4 11:05:28 2026 +0800
fix: widen RemoteSendConsistencySpec await window to 30s (#3041)
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]
