Deadlock dumper

gistfile1.txt

  def dumpwaits(): Unit = {
    println("digraph waits {")

    for (i ← assembly.stages.indices) {
      println(s"""N$i [label="${assembly.stages(i)}"]""")
    }

    for (i ← portStates.indices) {
      portStates(i) match {
        case InReady ⇒
          println(s"""  N${assembly.inOwners(i)} -> N${assembly.outOwners(i)} [label="shouldPull"]; """)
        case OutReady ⇒
          println(s"""  N${assembly.outOwners(i)} -> N${assembly.inOwners(i)} [label="shouldPush"]; """)
        case _ ⇒
          println(s"""  N${assembly.inOwners(i)} -> N${assembly.outOwners(i)} [style=dotted; label="closed" dir=both]; """)
      }

    }

    println("}")

  }