The following are essential “private” notes to sort out the call sequence used as data flows through DataStream processes and Core processes.

• Started with DataStream::execute
  • Calls DataStream::initialiseMemoryBuffer
    • Launches DataStream::launchNewFileReadThread or DataStream::launchNewNetworkReadThread
      • Calls DataStream::loopfileread or DataStream::loopnetworkread
• Continues running execute

• Loops managing MPI requests and data sends

• loopfileread loops over
  • DataStream::openfile
    • initialiseFile (Overloaded in mk5.cpp)
  • DataStream::diskToMemory
    • read (System call)
    • testForSync (Overloaded in mk5.cpp)

• Core::Core
  • Initialises arrays/mutexes etc and

• Started with Core::execute
  • Create threads with pthread_create calling launchNewProcessThread
    • Calls loopprocess
      • Loops over processdata
        • Loops over Mode::process for each batch of FFTs
          • Calls Mode::unpack Overloaded in mk5mode.cpp
  • Loops over Core::receivedata
    • This calls a few MPI_Irecv and locks/unlocks mutexes