From 227f6cfd84e65fb613c037b4c907056a07a626ac Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Endre=20S=C3=A1ndor=20Varga?= Date: Mon, 8 Aug 2016 17:05:47 +0200 Subject: [PATCH] #21135: Fix fuzzing mode --- .../akka/stream/impl/fusing/GraphInterpreter.scala | 10 +--------- 1 file changed, 1 insertion(+), 9 deletions(-) diff --git a/akka-stream/src/main/scala/akka/stream/impl/fusing/GraphInterpreter.scala b/akka-stream/src/main/scala/akka/stream/impl/fusing/GraphInterpreter.scala index 1ca60cb2ab..57a1d6ea5c 100644 --- a/akka-stream/src/main/scala/akka/stream/impl/fusing/GraphInterpreter.scala +++ b/akka-stream/src/main/scala/akka/stream/impl/fusing/GraphInterpreter.scala @@ -47,8 +47,6 @@ object GraphInterpreter { final val KeepGoingFlag = 0x4000000 final val KeepGoingMask = 0x3ffffff - final val ChaseLimit = 16 - /** * Marker object that indicates that a port holds no element since it was already grabbed. The port is still pullable, * but there is no more element to grab. @@ -401,13 +399,7 @@ final class GraphInterpreter( val context: ActorRef) { import GraphInterpreter._ - // Maintains additional information for events, basically elements in-flight, or failure. - // Other events are encoded in the portStates bitfield. - //val connectionSlots = Array.fill[Any](assembly.connectionCount)(Empty) - - // Bitfield encoding pending events and various states for efficient querying and updates. See the documentation - // of the class for a full description. - //val portStates = Array.fill[Int](assembly.connectionCount)(InReady) + private[this] val ChaseLimit = if (fuzzingMode) 0 else 16 /** * INTERNAL API