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

#21135: Fix fuzzing mode

Browse source
This commit is contained in:
Endre Sándor Varga 2016-08-08 17:05:47 +02:00
parent 4ca5635fde
commit 227f6cfd84
1 changed files with 1 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

10
akka-stream/src/main/scala/akka/stream/impl/fusing/GraphInterpreter.scala
View file

@ -47,8 +47,6 @@ object GraphInterpreter {
final val KeepGoingFlag = 0x4000000 final val KeepGoingFlag = 0x4000000
final val KeepGoingMask = 0x3ffffff 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, * 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. * but there is no more element to grab.
@ -401,13 +399,7 @@ final class GraphInterpreter(
val context: ActorRef) { val context: ActorRef) {
import GraphInterpreter._ import GraphInterpreter._
// Maintains additional information for events, basically elements in-flight, or failure. private[this] val ChaseLimit = if (fuzzingMode) 0 else 16
// 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)
/** /**
* INTERNAL API * INTERNAL API