issues with "expect-from" list

[ZiluTian]

[expectedWorkerSet = receive_map.getOrElse(workerId, SetInt)](

SimulationEngine/Akka/src/main/scala/core/SequentialWorkerImpl.scala

Line 166 in c8a1ca7

expectedWorkerSet = receive_map.getOrElse(workerId, Set[Int]())

)

log prints out the content of receive_map and workerId properly, but the look up always returns None. receive_map is an immutable map in Scala, which should also be thread safe. Tried explicit type conversions but the issue persisted. First noticed this issue when running Driver and Machine on different ports. Standalone mode seems fine.

Fix: [temporary] replace send-to and receive-from lists with expectAll branch. Workers send a message to every other worker at the end of each round.

[ZiluTian]

expectAll supports current three-level hierarchy. If we allow workers to dynamically spawn new workers, then it will not work directly out of box.