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

=cdd #18235 Harden ddata PerformanceSpec

Browse source
This commit is contained in:
Patrik Nordwall 2015-08-26 14:26:51 +02:00
parent 27b54627d8
commit a6fe4c8ab4
1 changed files with 8 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

16
akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/PerformanceSpec.scala
View file

@ -88,7 +88,7 @@ class PerformanceSpec extends MultiNodeSpec(PerformanceSpec) with STMultiNodeSpe
block(key, i, replyTo) block(key, i, replyTo)
i += 1 i += 1
} }
Await.ready(latch, 5.seconds + (1.second * factor)) Await.ready(latch, 10.seconds + (2.second * factor))
} }
expectedAfterReplication.foreach { expected ⇒ expectedAfterReplication.foreach { expected ⇒
enterBarrier("repeat-" + key + "-before-awaitReplicated") enterBarrier("repeat-" + key + "-before-awaitReplicated")
@ -123,7 +123,7 @@ class PerformanceSpec extends MultiNodeSpec(PerformanceSpec) with STMultiNodeSpe
"Performance" must { "Performance" must {
"setup cluster" in { "setup cluster" taggedAs PerformanceTest in {
roles.foreach { join(_, n1) } roles.foreach { join(_, n1) }
within(10.seconds) { within(10.seconds) {
@ -136,7 +136,7 @@ class PerformanceSpec extends MultiNodeSpec(PerformanceSpec) with STMultiNodeSpe
enterBarrier("after-setup") enterBarrier("after-setup")
} }
"be great for ORSet Update WriteLocal" in { "be great for ORSet Update WriteLocal" taggedAs PerformanceTest in {
val keys = (1 to repeatCount).map(n ⇒ ORSetKey[Int]("A" + n)) val keys = (1 to repeatCount).map(n ⇒ ORSetKey[Int]("A" + n))
val n = 1000 * factor val n = 1000 * factor
val expectedData = (0 until n).toSet val expectedData = (0 until n).toSet
@ -147,7 +147,7 @@ class PerformanceSpec extends MultiNodeSpec(PerformanceSpec) with STMultiNodeSpe
enterBarrier("after-1") enterBarrier("after-1")
} }
"be blazingly fast for ORSet Get ReadLocal" in { "be blazingly fast for ORSet Get ReadLocal" taggedAs PerformanceTest in {
val keys = (1 to repeatCount).map(n ⇒ ORSetKey[Int]("A" + n)) val keys = (1 to repeatCount).map(n ⇒ ORSetKey[Int]("A" + n))
repeat("Get ReadLocal", keys, 100000 * factor) { (key, i, replyTo) ⇒ repeat("Get ReadLocal", keys, 100000 * factor) { (key, i, replyTo) ⇒
replicator.tell(Get(key, ReadLocal), replyTo) replicator.tell(Get(key, ReadLocal), replyTo)
@ -155,7 +155,7 @@ class PerformanceSpec extends MultiNodeSpec(PerformanceSpec) with STMultiNodeSpe
enterBarrier("after-2") enterBarrier("after-2")
} }
"be good for ORSet Update WriteLocal and gossip replication" in { "be good for ORSet Update WriteLocal and gossip replication" taggedAs PerformanceTest in {
val keys = (1 to repeatCount).map(n ⇒ ORSetKey[Int]("B" + n)) val keys = (1 to repeatCount).map(n ⇒ ORSetKey[Int]("B" + n))
val n = 200 * factor val n = 200 * factor
val expected = Some((0 until n).toSet) val expected = Some((0 until n).toSet)
@ -165,7 +165,7 @@ class PerformanceSpec extends MultiNodeSpec(PerformanceSpec) with STMultiNodeSpe
enterBarrier("after-3") enterBarrier("after-3")
} }
"be good for ORSet Update WriteLocal and gossip of existing keys" in { "be good for ORSet Update WriteLocal and gossip of existing keys" taggedAs PerformanceTest in {
val keys = (1 to repeatCount).map(n ⇒ ORSetKey[Int]("B" + n)) val keys = (1 to repeatCount).map(n ⇒ ORSetKey[Int]("B" + n))
val n = 200 * factor val n = 200 * factor
val expected = Some((0 until n).toSet ++ (0 until n).map(-_).toSet) val expected = Some((0 until n).toSet ++ (0 until n).map(-_).toSet)
@ -175,7 +175,7 @@ class PerformanceSpec extends MultiNodeSpec(PerformanceSpec) with STMultiNodeSpe
enterBarrier("after-4") enterBarrier("after-4")
} }
"be good for ORSet Update WriteTwo and gossip replication" in { "be good for ORSet Update WriteTwo and gossip replication" taggedAs PerformanceTest in {
val keys = (1 to repeatCount).map(n ⇒ ORSetKey[Int]("C" + n)) val keys = (1 to repeatCount).map(n ⇒ ORSetKey[Int]("C" + n))
val n = 200 * factor val n = 200 * factor
val expected = Some((0 until n).toSet) val expected = Some((0 until n).toSet)
@ -186,7 +186,7 @@ class PerformanceSpec extends MultiNodeSpec(PerformanceSpec) with STMultiNodeSpe
enterBarrier("after-5") enterBarrier("after-5")
} }
"be awesome for GCounter Update WriteLocal" in { "be awesome for GCounter Update WriteLocal" taggedAs PerformanceTest in {
val startTime = System.nanoTime() val startTime = System.nanoTime()
val n = 1000 * factor val n = 1000 * factor
val key = GCounterKey("D") val key = GCounterKey("D")