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

Make sure that all nodes use tha same number of rounds. See #3050

Browse source
This commit is contained in:
Björn Antonsson 2013-02-26 08:14:09 +01:00
parent 6321663471
commit 2df3bc7363
1 changed files with 13 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -75,15 +75,16 @@ object StressMultiJvmSpec extends MultiNodeConfig {
nr-of-nodes-shutdown = 2 nr-of-nodes-shutdown = 2
nr-of-nodes-join-remove = 2 nr-of-nodes-join-remove = 2
# not scaled # not scaled
# scale the *-duration settings with this factor
duration-factor = 1
join-remove-duration = 90s join-remove-duration = 90s
work-batch-size = 100 work-batch-size = 100
work-batch-interval = 2s work-batch-interval = 2s
payload-size = 1000 payload-size = 1000
# scale the *-duration settings with this factor
duration-factor = 1
normal-throughput-duration = 30s normal-throughput-duration = 30s
high-throughput-duration = 10s high-throughput-duration = 10s
supervision-duration = 10s supervision-duration = 10s
supervision-one-iteration = 1s
# actors are created in a tree structure defined # actors are created in a tree structure defined
# by tree-width (number of children for each actor) and # by tree-width (number of children for each actor) and
# tree-levels, total number of actors can be calculated by # tree-levels, total number of actors can be calculated by
@ -167,6 +168,7 @@ object StressMultiJvmSpec extends MultiNodeConfig {
val normalThroughputDuration = getDuration("normal-throughput-duration") * dFactor val normalThroughputDuration = getDuration("normal-throughput-duration") * dFactor
val highThroughputDuration = getDuration("high-throughput-duration") * dFactor val highThroughputDuration = getDuration("high-throughput-duration") * dFactor
val supervisionDuration = getDuration("supervision-duration") * dFactor val supervisionDuration = getDuration("supervision-duration") * dFactor
val supervisionOneIteration = getDuration("supervision-one-iteration") * dFactor
val treeWidth = getInt("tree-width") val treeWidth = getInt("tree-width")
val treeLevels = getInt("tree-levels") val treeLevels = getInt("tree-levels")
val reportMetricsInterval = getDuration("report-metrics-interval") val reportMetricsInterval = getDuration("report-metrics-interval")
@ -801,12 +803,12 @@ abstract class StressSpec
def exerciseJoinRemove(title: String, duration: FiniteDuration): Unit = { def exerciseJoinRemove(title: String, duration: FiniteDuration): Unit = {
val activeRoles = roles.take(numberOfNodesJoinRemove) val activeRoles = roles.take(numberOfNodesJoinRemove)
val loopDuration = 10.seconds + convergenceWithin(4.seconds, nbrUsedRoles + activeRoles.size) val loopDuration = 10.seconds + convergenceWithin(4.seconds, nbrUsedRoles + activeRoles.size)
val deadline = Deadline.now + duration - loopDuration val rounds = ((duration - loopDuration).toMillis / loopDuration.toMillis).max(1).toInt
val usedRoles = roles.take(nbrUsedRoles) val usedRoles = roles.take(nbrUsedRoles)
val usedAddresses = usedRoles.map(address(_)).toSet val usedAddresses = usedRoles.map(address(_)).toSet
@tailrec def loop(counter: Int, previousAS: Option[ActorSystem], allPreviousAddresses: Set[Address]): Option[ActorSystem] = { @tailrec def loop(counter: Int, previousAS: Option[ActorSystem], allPreviousAddresses: Set[Address]): Option[ActorSystem] = {
if (deadline.isOverdue) previousAS if (counter > rounds) previousAS
else { else {
val t = title + " round " + counter val t = title + " round " + counter
runOn(usedRoles: _*) { runOn(usedRoles: _*) {
@ -902,10 +904,11 @@ abstract class StressSpec
workResult workResult
} }
def exerciseSupervision(title: String, duration: FiniteDuration): Unit = def exerciseSupervision(title: String, duration: FiniteDuration, oneIteration: Duration): Unit =
within(duration + 10.seconds) { within(duration + 10.seconds) {
val rounds = (duration.toMillis / oneIteration.toMillis).max(1).toInt
val supervisor = system.actorOf(Props[Supervisor], "supervisor") val supervisor = system.actorOf(Props[Supervisor], "supervisor")
while (remaining > 10.seconds) { for (count <- 0 until rounds) {
createResultAggregator(title, expectedResults = nbrUsedRoles, includeInHistory = false) createResultAggregator(title, expectedResults = nbrUsedRoles, includeInHistory = false)
reportResult { reportResult {
@ -1027,13 +1030,13 @@ abstract class StressSpec
enterBarrier("after-" + step) enterBarrier("after-" + step)
} }
"excercise join/remove/join/remove" taggedAs LongRunningTest in { "exercise join/remove/join/remove" taggedAs LongRunningTest in {
exerciseJoinRemove("excercise join/remove", joinRemoveDuration) exerciseJoinRemove("exercise join/remove", joinRemoveDuration)
enterBarrier("after-" + step) enterBarrier("after-" + step)
} }
"excercise supervision" taggedAs LongRunningTest in { "exercise supervision" taggedAs LongRunningTest in {
exerciseSupervision("excercise supervision", supervisionDuration) exerciseSupervision("exercise supervision", supervisionDuration, supervisionOneIteration)
enterBarrier("after-" + step) enterBarrier("after-" + step)
} }