raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Dump diagnostics (Coroner's Report) if a test takes too long. Fixes #3110

Browse source
This commit is contained in:
Rich Dougherty 2013-02-28 15:45:12 +13:00
parent 370d6451c7
commit f6a14cb5ac
6 changed files with 305 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-cluster/src/multi-jvm/scala/akka/cluster/StressSpec.scala
View file

@ -85,6 +85,7 @@ object StressMultiJvmSpec extends MultiNodeConfig {
high-throughput-duration = 10s
supervision-duration = 10s
supervision-one-iteration = 1s
expected-test-duration = 600s
# actors are created in a tree structure defined
# by tree-width (number of children for each actor) and
# tree-levels, total number of actors can be calculated by
@ -169,6 +170,7 @@ object StressMultiJvmSpec extends MultiNodeConfig {
val highThroughputDuration = getDuration("high-throughput-duration") * dFactor
val supervisionDuration = getDuration("supervision-duration") * dFactor
val supervisionOneIteration = getDuration("supervision-one-iteration") * dFactor
val expectedTestDuration = getDuration("expected-test-duration") * dFactor
val treeWidth = getInt("tree-width")
val treeLevels = getInt("tree-levels")
val reportMetricsInterval = getDuration("report-metrics-interval")
@ -617,6 +619,8 @@ abstract class StressSpec
override def beforeEach(): Unit = { step += 1 }
override def expectedTestDuration = settings.expectedTestDuration
override def muteLog(sys: ActorSystem = system): Unit = {
super.muteLog(sys)
sys.eventStream.publish(Mute(EventFilter[RuntimeException](pattern = ".*Simulated exception.*")))