This is an automated email from the ASF dual-hosted git repository.
pjfanning pushed a commit to branch 1.7.x
in repository https://gitbox.apache.org/repos/asf/pekko.git
The following commit(s) were added to refs/heads/1.7.x by this push:
new fb4bc8fb3b Update MetricsBasedResizerSpec.scala (#3047)
fb4bc8fb3b is described below
commit fb4bc8fb3ba95ea518d526fdf38417c2ef7fd298
Author: PJ Fanning <[email protected]>
AuthorDate: Sat Jun 6 10:25:13 2026 +0100
Update MetricsBasedResizerSpec.scala (#3047)
---
.../apache/pekko/routing/MetricsBasedResizerSpec.scala | 17 +++++++++++++----
1 file changed, 13 insertions(+), 4 deletions(-)
diff --git
a/actor-tests/src/test/scala/org/apache/pekko/routing/MetricsBasedResizerSpec.scala
b/actor-tests/src/test/scala/org/apache/pekko/routing/MetricsBasedResizerSpec.scala
index 0c930e491e..59752e01b4 100644
---
a/actor-tests/src/test/scala/org/apache/pekko/routing/MetricsBasedResizerSpec.scala
+++
b/actor-tests/src/test/scala/org/apache/pekko/routing/MetricsBasedResizerSpec.scala
@@ -150,6 +150,10 @@ class MetricsBasedResizerSpec extends
PekkoSpec(ResizerSpec.config) with Default
val router = TestRouter(routees(2))
router.sendToAll(await = true)
+ // Send additional messages to ensure mailbox is non-empty when checked,
+ // avoiding a race condition where currentMessage could be null
momentarily
+ router.mockSend(await = false, routeeIdx = 0)
+ router.mockSend(await = false, routeeIdx = 1)
resizer.reportMessageCount(router.routees, router.msgs.size)
resizer.record.underutilizationStreak shouldBe empty
@@ -187,8 +191,13 @@ class MetricsBasedResizerSpec extends
PekkoSpec(ResizerSpec.config) with Default
underutilizationStreak = Some(UnderUtilizationStreak(start =
LocalDateTime.now, highestUtilization = 1)))
val router = TestRouter(routees(3))
+ // Send messages to routee 0 and 1, await ensures the actor started
processing
router.mockSend(await = true, routeeIdx = 0)
router.mockSend(await = true, routeeIdx = 1)
+ // Send additional messages to ensure mailbox is non-empty when checked,
+ // avoiding a race condition where currentMessage could be null
momentarily
+ router.mockSend(await = false, routeeIdx = 0)
+ router.mockSend(await = false, routeeIdx = 1)
resizer.reportMessageCount(router.routees, router.msgs.size)
resizer.record.underutilizationStreak.get.highestUtilization shouldBe 2
@@ -226,12 +235,12 @@ class MetricsBasedResizerSpec extends
PekkoSpec(ResizerSpec.config) with Default
"record the performance log with the correct pool size" in {
val resizer = DefaultOptimalSizeExploringResizer()
val router = TestRouter(routees(2))
- val msgs = router.sendToAll(await = true)
+ val msgs1 = router.sendToAll(await = true)
+ val msgs2 = router.sendToAll(await = false)
resizer.reportMessageCount(router.routees, router.msgs.size)
- msgs.head.second.open()
+ msgs1.head.second.open()
- router.mockSend(await = true, routeeIdx = 0)
- router.mockSend(await = false, routeeIdx = 1)
+ Await.ready(msgs2.head.first, timeout.duration)
resizer.reportMessageCount(router.routees, router.msgs.size)
resizer.performanceLog.get(2) should not be empty
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
