DESunorderedSerial.h

Go to the documentation of this file.

#ifndef _DES_UNORDERED_SERIAL_H_
#define _DES_UNORDERED_SERIAL_H_

#include <deque>
#include <functional>

#include <cassert>

#include "DESabstractMain.h"

class DESunorderedSerial: public DESabstractMain {

  virtual bool isSerial () const { return true; }

  virtual void runLoop (const SimInit& simInit) {
    std::deque<GNode> worklist (simInit.getInputNodes ().begin (), simInit.getInputNodes ().end ());

    std::vector<bool> onWlFlags (simInit.getNumNodes (), false);

    // set onWlFlags for input objects
    for (std::vector<GNode>::const_iterator i = simInit.getInputNodes ().begin (), ei = simInit.getInputNodes ().end ();
        i != ei; ++i) {
      SimObject* srcObj = graph.getData (*i, Galois::NONE);
      onWlFlags[srcObj->getId ()] = true;
    }

    size_t maxPending = 0;

    size_t numEvents = 0;
    size_t numIter = 0;

    while (!worklist.empty ()) {

      GNode activeNode = worklist.front ();
      worklist.pop_front ();

      SimObject* srcObj = graph.getData (activeNode, Galois::NONE);

      maxPending = std::max (maxPending, srcObj->numPendingEvents ());

      numEvents += srcObj->simulate(graph, activeNode);


      for (Graph::neighbor_iterator i = graph.neighbor_begin (activeNode, Galois::NONE), ei =
          graph.neighbor_end (activeNode, Galois::NONE); i != ei; ++i) {
        const GNode& dst = *i;

        SimObject* dstObj = graph.getData (dst, Galois::NONE);

        dstObj->updateActive ();

        if (dstObj->isActive ()) {
          if (!onWlFlags[dstObj->getId ()]) {
            // set the flag to indicate presence on the worklist
            onWlFlags[dstObj->getId ()] = true;
            worklist.push_back (dst);
          }
        }
      }

      srcObj->updateActive();
      if (srcObj->isActive()) {
        worklist.push_back (activeNode);

      } else { 
        // reset the flag to indicate absence on the worklist
        onWlFlags[srcObj->getId ()] = false;
      }

      ++numIter;

    }


    std::cout << "Simulation ended" << std::endl;
    std::cout << "Number of events processed = " << numEvents << " Iterations = " << numIter << std::endl;
    std::cout << "Max size of pending events = " << maxPending << std::endl;

  }

};

#endif // _DES_UNORDERED_SERIAL_H_

---