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

fix InterpreterStressSpec GC problem

Browse source
This commit is contained in:
Roland Kuhn 2016-01-20 17:26:21 +01:00
parent e5baba2b29
commit 96b5bdacd6
2 changed files with 12 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

15
akka-stream-tests/src/test/scala/akka/stream/impl/fusing/InterpreterStressSpec.scala
View file

@ -16,11 +16,11 @@ class InterpreterStressSpec extends AkkaSpec with GraphInterpreterSpecKit {
val halfLength = chainLength / 2
val repetition = 100
val f = (x: Int) ⇒ x + 1
val map = Map((x: Int) ⇒ x + 1, stoppingDecider).toGS
"Interpreter" must {
"work with a massive chain of maps" in new OneBoundedSetup[Int](Array.fill(chainLength)(Map(f, stoppingDecider))) {
"work with a massive chain of maps" in new OneBoundedSetup[Int](Vector.fill(chainLength)(map): _*) {
lastEvents() should be(Set.empty)
val tstamp = System.nanoTime()
@ -42,9 +42,10 @@ class InterpreterStressSpec extends AkkaSpec with GraphInterpreterSpecKit {
info(s"Chain finished in $time seconds ${(chainLength * repetition) / (time * 1000 * 1000)} million maps/s")
}
"work with a massive chain of maps with early complete" in new OneBoundedSetup[Int](Vector.fill(halfLength)(Map((x: Int) ⇒ x + 1, stoppingDecider)) ++
Seq(Take(repetition / 2)) ++
Seq.fill(halfLength)(Map((x: Int) ⇒ x + 1, stoppingDecider))) {
"work with a massive chain of maps with early complete" in new OneBoundedSetup[Int](
Vector.fill(halfLength)(map) ++
Seq(Take(repetition / 2).toGS) ++
Vector.fill(halfLength)(map): _*) {
lastEvents() should be(Set.empty)
val tstamp = System.nanoTime()
@ -70,7 +71,7 @@ class InterpreterStressSpec extends AkkaSpec with GraphInterpreterSpecKit {
info(s"Chain finished in $time seconds ${(chainLength * repetition) / (time * 1000 * 1000)} million maps/s")
}
"work with a massive chain of takes" in new OneBoundedSetup[Int](Vector.fill(chainLength)(Take(1))) {
"work with a massive chain of takes" in new OneBoundedSetup[Int](Vector.fill(chainLength / 10)(Take(1))) {
lastEvents() should be(Set.empty)
downstream.requestOne()
@ -99,7 +100,7 @@ class InterpreterStressSpec extends AkkaSpec with GraphInterpreterSpecKit {
}
"work with a massive chain of conflates by overflowing to the heap" in new OneBoundedSetup[Int](Vector.fill(100000)(Conflate(
"work with a massive chain of conflates by overflowing to the heap" in new OneBoundedSetup[Int](Vector.fill(chainLength / 10)(Conflate(
(in: Int) ⇒ in,
(agg: Int, in: Int) ⇒ agg + in,
Supervision.stoppingDecider))) {