AbstractDriver.h

Go to the documentation of this file.

/*                                              -*- mode:C++ -*-
  AbstractDriver.h Base class for all MFM drivers
  Copyright (C) 2014 The Regents of the University of New Mexico.  All rights reserved.

  This library is free software; you can redistribute it and/or
  modify it under the terms of the GNU Lesser General Public
  License as published by the Free Software Foundation; either
  version 2.1 of the License, or (at your option) any later version.

  This library is distributed in the hope that it will be useful,
  but WITHOUT ANY WARRANTY; without even the implied warranty of
  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  Lesser General Public License for more details.

  You should have received a copy of the GNU General Public License
  along with this library; if not, write to the Free Software
  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301
  USA
*/

#ifndef ABSTRACTDRIVER_H
#define ABSTRACTDRIVER_H

#include <sys/stat.h>  /* for mkdir */
#include <sys/time.h>  /* for gettimeofday */
#include <sys/types.h> /* for mkdir */
#include <errno.h>     /* for errno */
#include "Util.h"
#include "Utils.h"     /* for GetDateTimeNow, Sleep */
#include "ExternalConfig.h"
#include "ExternalConfigFunctions.h"
#include "OverflowableCharBufferByteSink.h"
#include "FileByteSource.h"
#include "FileByteSink.h"
#include "itype.h"
#include "Grid.h"
#include "ElementTable.h"
#include "VArguments.h"
#include "StdElements.h"
#include "ElementRegistry.h"
#include "Version.h"


#define MAX_PATH_LENGTH 1000
#define MIN_PATH_RESERVED_LENGTH 100

#define MAX_NEEDED_ELEMENTS 100
#define MAX_CONFIGURATION_PATHS 32

#define INITIAL_AEPS_PER_FRAME 1

namespace MFM
{
  template<class GC>
  class AbstractDriver
  {
  protected:

    typedef typename GC::CORE_CONFIG CC;

    typedef typename CC::PARAM_CONFIG P;

    typedef typename CC::ATOM_TYPE T;

    enum { W = GC::GRID_WIDTH};

    enum { H = GC::GRID_HEIGHT};

    enum { R = P::EVENT_WINDOW_RADIUS};

    static const u32 EVENT_WINDOW_RADIUS = R;

    static const u32 GRID_WIDTH = W;

    static const u32 GRID_HEIGHT = H;

    typedef ElementRegistry<CC> OurElementRegistry;

    typedef StdElements<CC> OurStdElements;

    typedef Grid<GC> OurGrid;

    typedef ElementTable<CC> OurElementTable;

    Element<CC>* m_neededElements[MAX_NEEDED_ELEMENTS];
    u32 m_neededElementCount;

    void NeedElement(Element<CC>* element)
    {
      if(m_neededElementCount >= MAX_NEEDED_ELEMENTS)
      {
        FAIL(OUT_OF_ROOM);
      }

      m_neededElements[m_neededElementCount++] = element;
    }

    void WriteTimeBasedData(FileByteSink& fp, bool exists)
    {
      // Extract short names for parameter types
      typedef typename GC::CORE_CONFIG CC;
      typedef typename CC::PARAM_CONFIG P;
      enum { W = GC::GRID_WIDTH};
      enum { H = GC::GRID_HEIGHT};
      enum { R = P::EVENT_WINDOW_RADIUS};

      if(!exists)
      {
        fp.Printf("# AEPS AEPS/Frame AER100 Overhead100");
        for(u32 i = 0; i < m_neededElementCount; i++)
        {
          fp.WriteByte(' ');
          for(const char* p = m_neededElements[i]->GetName(); *p; p++)
          {
            if(isspace(*p))
            {
              fp.WriteByte('_');
            }
            else
            {
              fp.WriteByte(*p);
            }
          }
        }
        fp.Println();
      }

      fp.Print((u64)GetAEPS());
      fp.WriteByte(' ');
      fp.Print(GetAEPSPerFrame());
      fp.WriteByte(' ');
      fp.Print((u64)(100.0 * GetAER()));
      fp.WriteByte(' ');
      fp.Print((u64)(100.0 * GetOverheadPercent()));

      for(u32 i = 0; i < m_neededElementCount; i++)
      {
        fp.WriteByte(' ');
        fp.Print((u32)GetGrid().GetAtomCount(m_neededElements[i]->GetType()));
      }
      fp.Println();
    }

    void SetIgnoreThreadingProblems(bool value)
    {
      m_ignoreThreadingProblems = value;
    }

    void WriteTimeBasedData()
    {
      const char* path = GetSimDirPathTemporary("tbd/data.dat");
      bool exists = true;
      {
        FILE* fp = fopen(path, "r");
        if (!fp)
        {
          exists = false;
        }
        else
        {
          fclose(fp);
        }
      }
      FILE* fp = fopen(path, "a");
      FileByteSink fbs(fp);

      WriteTimeBasedData(fbs, exists);
      fclose(fp);
    }

    void UpdateGrid(OurGrid& grid)
    {
      const s32 ONE_THOUSAND = 1000;
      const s32 ONE_MILLION = ONE_THOUSAND*ONE_THOUSAND;

      grid.Unpause();  // pausing and unpausing should be overhead!

      u32 startMS = GetTicks();  // So get the ticks after unpausing
      if (m_ticksLastStopped != 0)
        m_msSpentOverhead += startMS - m_ticksLastStopped;
      else
        m_msSpentOverhead = 0;

      Sleep(m_microsSleepPerFrame/ONE_MILLION,
            (u64) (m_microsSleepPerFrame%ONE_MILLION)*ONE_THOUSAND);

      m_ticksLastStopped = GetTicks(); // and before pausing

      grid.Pause();

      u32 thisPeriodMS = m_ticksLastStopped - startMS;
      m_msSpentRunning += thisPeriodMS;

      u64 totalEvents = grid.GetTotalEventsExecuted();
      u32 totalSites = grid.GetTotalSites();
      m_AEPS = totalEvents / totalSites;
      m_AER = 1000 * (m_AEPS / m_msSpentRunning);

      u64 newEvents = totalEvents - m_lastTotalEvents;
      m_lastTotalEvents = totalEvents;

      if (thisPeriodMS == 0) {
        LOG.Warning("Zero ms in sample");
        thisPeriodMS = 1;
      }
      double thisAERsample = 1000.0 * newEvents / totalSites / thisPeriodMS;

      const double BACKWARDS_AVERAGE_RATE = 0.99;
      m_recentAER = BACKWARDS_AVERAGE_RATE * m_recentAER +
                    (1 - BACKWARDS_AVERAGE_RATE) * thisAERsample;

      m_overheadPercent = 100.0*m_msSpentOverhead/(m_msSpentRunning+m_msSpentOverhead);

      double diff = m_AEPS - m_lastFrameAEPS;
      double err = MIN(1.0, MAX(-1.0, m_aepsPerFrame - diff));

      // Correct up to 20% of current each frame
      m_microsSleepPerFrame = (100+20*err)*m_microsSleepPerFrame/100;
      m_microsSleepPerFrame = MIN(100000000, MAX(1000, m_microsSleepPerFrame));

      m_lastFrameAEPS = m_AEPS;

      CheckEpochProcessing(grid);

      PostUpdate();
    }

    void DecrementAEPSPerFrame(u32 amount)
    {
      if(m_aepsPerFrame <= amount)
      {
        m_aepsPerFrame = 1;
      }
      else
      {
        m_aepsPerFrame -= amount;
      }
    }

    void IncrementAEPSPerFrame(u32 amount)
    {
      m_aepsPerFrame += amount;
      if(m_aepsPerFrame >= 1000)
      {
        m_aepsPerFrame = 1000;
      }
    }

    virtual void PostReinit(VArguments& args)
    { }

    virtual void ReinitEden() = 0;

    void ReinitPhysics()
    {
      for(u32 i = 0; i < m_neededElementCount; i++)
      {
        GetGrid().Needed(*m_neededElements[i]);
      }

      PostReinitPhysics();
    }

    virtual void PostReinitPhysics()
    { }

    virtual void DefineNeededElements() = 0;

    virtual void PostUpdate()
    { }

    virtual void OnceOnly(VArguments& args)
    {
      if(!args.Appeared("-d"))
      {
        SetDataDirFromArgs(NULL, this);
      }

      LOG.Message("Writing to simulation directory '%s'", GetSimDirPathTemporary(""));

      const char* (subs[]) =
      {
        "", "vid", "eps", "tbd", "teps", "save", "screenshot", "autosave"
      };

      for(u32 i = 0; i < sizeof(subs) / sizeof(subs[0]); i++)
      {
        const char* path = GetSimDirPathTemporary("%s", subs[i]);
        if(mkdir(path, 0777))
        {
          args.Die("Couldn't make simulation sub-directory '%s' : %s",
                   path, strerror(errno));
        }
      }

      /* Initialize tbd.txt */
      const char* path = GetSimDirPathTemporary("tbd/tbd.txt");
      FILE* fp = fopen(path, "w");
      fprintf(fp, "#AEPS activesites empty dreg res wall sort-hits"
              "sort-misses sort-total sort-hit-pctg\n");
      fclose(fp);

      m_elementRegistry.AddPath("~/.mfm/res/elements");
      m_elementRegistry.AddPath(SHARED_DIR "/res/elements");
      m_elementRegistry.AddPath("./bin");
      m_elementRegistry.Init();

      DefineNeededElements();

      m_grid.SetIgnoreThreadingProblems(m_ignoreThreadingProblems);
    }

    virtual void RunHelper()
    {
      bool running = true;

      while(running)
      {
        UpdateGrid(m_grid);

        if(m_haltAfterAEPS > 0 && m_AEPS > m_haltAfterAEPS)
        {
          running = false;
        }
      }
    }

    void SetAEPSPerEpoch(u32 aeps)
    {
      m_AEPSPerEpoch = aeps;
    }

    u32 GetAEPSPerEpoch() const
    {
      return m_AEPSPerEpoch;
    }

  private:

    OurElementRegistry m_elementRegistry;
    OurStdElements m_se;
    OurGrid m_grid;

    u32 m_ticksLastStopped;
    u32 m_haltAfterAEPS;

    u64 m_startTimeMS;
    u64 m_msSpentRunning;
    u64 m_msSpentOverhead;
    s32 m_microsSleepPerFrame;
    double m_overheadPercent;
    double m_lastFrameAEPS;
    u32 m_aepsPerFrame;

    s32 m_AEPSPerEpoch;
    u32 m_autosavePerEpochs;
    u32 m_accelerateAfterEpochs;
    u32 m_acceleration;
    u32 m_surgeAfterEpochs;

    bool m_gridImages;
    bool m_tileImages;

    bool m_ignoreThreadingProblems;

    double m_AEPS;
    double m_AER;

    double m_recentAER;

    u64 m_lastTotalEvents;

    u32 m_nextEpochAEPS;
    u32 m_epochCount;

    VArguments m_varguments;

    u32 m_configurationPathCount;
    u32 m_currentConfigurationPath;
    const char* (m_configurationPaths[MAX_CONFIGURATION_PATHS]);

    char m_simDirBasePath[MAX_PATH_LENGTH];
    u32 m_simDirBasePathLength;

    u32 GetTicks()
    {
      struct timeval tv;
      gettimeofday(&tv, NULL);

      /* ms since epoch */
      u64 ms = tv.tv_sec * 1000 + tv.tv_usec / 1000;

      return  ms - m_startTimeMS;
    }

    /***********************************
     *      MANDATORY VARGUMENTS
     ***********************************/

    static void PrintArgUsage(const char* not_needed, void* vargs)
    {
      VArguments& args = *((VArguments*)vargs);
      args.Usage();
    }

    static void PrintVersion(const char* not_needed, void* nullForShort)
    {
      fprintf(stderr, "%s\n", nullForShort ? MFM_VERSION_STRING_LONG : MFM_VERSION_STRING_SHORT);
      exit(0);
    }

    static void SetLoggingLevel(const char* level, void* not_needed)
    {
      LOG.SetLevel(atoi(level));
    }

    static void SetSeedFromArgs(const char* seedstr, void* driver)
    {
      u32 seed = atoi(seedstr);
      if(!seed)
      {
        seed = time(0);
      }
      ((AbstractDriver*)driver)->SetSeed(seed);
    }

    static void SetAEPSPerEpochFromArgs(const char* aepsStr, void* driverptr)
    {
      AbstractDriver& driver = *((AbstractDriver*)driverptr);
      VArguments& args = driver.m_varguments;

      u32 epochAEPS = atoi(aepsStr);
      if (epochAEPS < 0)
      {
        args.Die("AEPS per epoch must be non-negative, not %d", epochAEPS);
      }
      driver.SetAEPSPerEpoch(epochAEPS);
    }

    static void SetAutosavePerEpochsFromArgs(const char* arg, void* driverptr)
    {
      AbstractDriver& driver = *((AbstractDriver*)driverptr);
      VArguments& args = driver.m_varguments;

      u32 val = atoi(arg);
      if (val < 0)
      {
        args.Die("Autosave per epochs must be non-negative, not %d", val);
      }
      driver.m_autosavePerEpochs = val;
    }

    static void SetPicturesPerRateFromArgs(const char* aeps, void* driverptr)
    {
      AbstractDriver* driver = (AbstractDriver*)driverptr;

      driver->m_accelerateAfterEpochs = atoi(aeps);
    }

    static void SetSurgePerEpochFromArgs(const char* aeps, void* driverptr)
    {
      AbstractDriver* driver = (AbstractDriver*)driverptr;

      driver->m_surgeAfterEpochs = atoi(aeps);

      if (driver->m_surgeAfterEpochs > 0)  // If actually surging
      {                                    // it'll happen immediately
        driver->m_acceleration = 0;        // so push acceleration back
      }
    }

    static void SetGridImages(const char* not_needed, void* driver)
    {
      ((AbstractDriver*)driver)->m_gridImages = 1;
    }

    static void SetTileImages(const char* not_needed, void* driver)
    {
      ((AbstractDriver*)driver)->m_tileImages = 1;
    }

    static void SetDataDirFromArgs(const char* dirPath, void* driverPtr)
    {
      AbstractDriver& driver = *((AbstractDriver*)driverPtr);
      VArguments& args = driver.m_varguments;

      if(!dirPath || strlen(dirPath) == 0)
      {
        dirPath = "/tmp";
      }

      /* Make the main data directory */
      if(mkdir(dirPath, 0777))
      {
        /* It's OK if it already exists */
        if(errno != EEXIST)
        {
          args.Die("Couldn't make directory '%s' : %s", dirPath, strerror(errno));
        }
      }

      u64 startTime = Utils::GetDateTimeNow();

      snprintf(driver.m_simDirBasePath, MAX_PATH_LENGTH - 1,
               "%s/%d%06d/", dirPath,
               Utils::GetDateFromDateTime(startTime),
               Utils::GetTimeFromDateTime(startTime));

      driver.m_simDirBasePathLength = strlen(driver.m_simDirBasePath);

      if(driver.m_simDirBasePathLength >= MAX_PATH_LENGTH - MIN_PATH_RESERVED_LENGTH)
      {
        args.Die("Path name too long '%s'", dirPath);
      }
    }

    static void RegisterElementPath(const char* path, void* driverptr)
    {
      AbstractDriver& driver = *((AbstractDriver*)driverptr);

      driver.m_elementRegistry.AddPath(path);
    }

    static void SetHaltAfterAEPSFromArgs(const char* aeps, void* driverptr)
    {
      AbstractDriver& driver = *((AbstractDriver*)driverptr);

      driver.m_haltAfterAEPS = atoi(aeps);
    }

    static void LoadFromConfigFile(const char* path, void* driverptr)
    {
      AbstractDriver& driver = *((AbstractDriver*)driverptr);
      VArguments& args = driver.m_varguments;

      if (driver.m_configurationPathCount >= MAX_CONFIGURATION_PATHS)
      {
        args.Die("Too many configuration paths, max %d, for '%s'",
                 MAX_CONFIGURATION_PATHS,
                 path);
      }
      driver.m_configurationPaths[driver.m_configurationPathCount] = path;
      ++driver.m_configurationPathCount;
    }

    static void SetIgnoreThreadingProblems(const char* not_used, void* driverptr)
    {
      AbstractDriver& driver = *((AbstractDriver*)driverptr);

      LOG.Warning("Threading errors treatead as warnings. Beware of inconsistencies.");

      driver.SetIgnoreThreadingProblems(true);
    }

    void CheckEpochProcessing(OurGrid& grid)
    {
      if (m_AEPSPerEpoch >= 0 || m_accelerateAfterEpochs > 0 || m_surgeAfterEpochs > 0)
      {
        if (m_AEPS >= m_nextEpochAEPS)
        {
          DoEpochEvents(grid, m_epochCount, m_nextEpochAEPS);
          m_nextEpochAEPS += m_AEPSPerEpoch;
          ++m_epochCount;
        }
      }
    }

  public:
    void AutosaveGrid(u32 epochs)
    {
      const char* filename =
        GetSimDirPathTemporary("autosave/%D-%D.mfs", epochs, (u32) m_AEPS);
      SaveGrid(filename);
    }

    void SaveGrid(const char* filename)
    {

      LOG.Message("Saving to: %s", filename);
      ExternalConfig<GC> cfg(this->GetGrid());
      FILE* fp = fopen(filename, "w");
      FileByteSink fs(fp);

      cfg.Write(fs);
      fs.Close();
    }

    void LoadFromConfigurationPath()
    {
      if (m_configurationPathCount > 0)
      {
        ++m_currentConfigurationPath;
        if (m_currentConfigurationPath >= m_configurationPathCount)
        {
          m_currentConfigurationPath = 0;
        }
        ReloadCurrentConfigurationPath();
      }
    }

    const char* GetSimDirPathTemporary(const char* format, ...) const
    {
      static OverflowableCharBufferByteSink<500> buf;
      buf.Reset();
      buf.Printf("%s",m_simDirBasePath);
      va_list ap;
      va_start(ap, format);
      buf.Vprintf(format, ap);
      if (buf.HasOverflowed())
      {
        FAIL(OUT_OF_ROOM);
      }
      return buf.GetZString();
    }

    void ReloadCurrentConfigurationPath()
    {
      if(m_configurationPathCount == 0)
      {
        return;
      }

      const char * path = m_configurationPaths[m_currentConfigurationPath];

      LOG.Debug("Loading configuration from %s...", path);

      ExternalConfig<GC> cfg(GetGrid());
      RegisterExternalConfigFunctions<GC>(cfg);
      FileByteSource fs(path);
      if (fs.IsOpen())
      {

        cfg.SetByteSource(fs, path);

        cfg.Read();

        fs.Close();
      }
      else
      {
        LOG.Error("Can't read configuration file '%s'", path);
      }
    }


    virtual void DoEpochEvents(OurGrid& grid, u32 epochs, u32 epochAEPS)
    {
      LOG.Debug("Epoch %d: %d AEPS", epochs, epochAEPS);

      grid.CheckCaches();

      grid.RecountAtoms();

      if (m_gridImages)
      {
        const char * path = GetSimDirPathTemporary("eps/%010d.ppm", epochAEPS);
        FILE* fp = fopen(path, "w");
        FileByteSink fbs(fp);
        grid.WriteEPSImage(fbs);
        fclose(fp);
      }

      if (m_tileImages)
      {
        const char * path = GetSimDirPathTemporary("teps/%010d-average.ppm", epochAEPS);
        FILE* fp = fopen(path, "w");
        FileByteSink fbs2(fp);
        grid.WriteEPSAverageImage(fbs2);
        fclose(fp);
      }



      if (m_autosavePerEpochs > 0 && (epochs % m_autosavePerEpochs) == 0)
      {
        this->AutosaveGrid(epochs);
      }

      if (m_accelerateAfterEpochs > 0 && (epochs % m_accelerateAfterEpochs) == 0)
      {
        this->SetAEPSPerEpoch(this->GetAEPSPerEpoch() + m_acceleration);
      }

      if (m_accelerateAfterEpochs > 0 &&
          m_surgeAfterEpochs > 0 &&
          (epochs % m_surgeAfterEpochs) == 0)
      {
        ++m_acceleration;
      }
    }


    AbstractDriver() :
      m_neededElementCount(0),
      m_grid(m_elementRegistry),
      m_ticksLastStopped(0),
      m_haltAfterAEPS(0),
      m_startTimeMS(0),
      m_msSpentRunning(0),
      m_msSpentOverhead(0),
      m_microsSleepPerFrame(50000),
      m_overheadPercent(0.0),
      m_aepsPerFrame(INITIAL_AEPS_PER_FRAME),
      m_AEPSPerEpoch(100),
      m_autosavePerEpochs(1),
      m_accelerateAfterEpochs(0),
      m_acceleration(1),
      m_surgeAfterEpochs(0),
      m_gridImages(false),
      m_tileImages(false),
      m_ignoreThreadingProblems(false),
      m_AEPS(0),
      m_recentAER(0),
      m_lastTotalEvents(0),
      m_nextEpochAEPS(0),
      m_epochCount(0),
      m_configurationPathCount(0),
      m_currentConfigurationPath(U32_MAX)
    { }

    void Init(u32 argc, const char** argv)
    {
      AddDriverArguments();

      SetSeed(1);

      m_varguments.ProcessArguments(argc, argv);

      m_startTimeMS = GetTicks();

      OnceOnly(m_varguments);
    }

    VArguments & GetVArguments()
    {
      return m_varguments;
    }

    void RegisterArgument(const char* description, const char* filter,
                          VArgumentHandleValue func, void* handlerArg,
                          bool runFunc)
    {
      m_varguments.RegisterArgument(description, filter, func, handlerArg, runFunc);
    }

    void RegisterSection(const char* sectionLabel)
    {
      m_varguments.RegisterSection(sectionLabel);
    }

    virtual void AddDriverArguments()
    {
      RegisterSection("General switches");

      RegisterArgument("Display this help message, then exit.",
                       "-h|--help", &PrintArgUsage, (void*)(&m_varguments), false);

      RegisterArgument("Amount of logging output is ARG (0 -> none, 8 -> max)",
                       "-l|--log", &SetLoggingLevel, NULL, true);

      RegisterArgument("Print the brief version number, then exit.",
                       "-v|--version", &PrintVersion, NULL, false);

      RegisterArgument("Print the full version number, then exit.",
                       "-V|--Version", &PrintVersion, this, false);

      RegisterArgument("Set master PRNG seed to ARG (u32)",
                       "-s|--seed", &SetSeedFromArgs, this, true);

      RegisterArgument("Set epoch length to ARG AEPS",
                       "-e|--epoch", &SetAEPSPerEpochFromArgs, this, true);

      RegisterArgument("Autosave grid every ARG epochs (default 1; 0 for never)",
                       "-a|--autosave", &SetAutosavePerEpochsFromArgs, this, true);

      this->RegisterArgument("Increase the epoch length every ARG epochs",
                             "--accelerate",
                             &SetPicturesPerRateFromArgs, this, true);

      this->RegisterArgument("Increase the epoch length acceleration every ARG epochs",
                             "--surge",
                             &SetSurgePerEpochFromArgs, this, true);

      RegisterArgument("Each epoch, write grid AEPS image to per-sim eps/ directory",
                       "--gridImages", &SetGridImages, this, false);

      RegisterArgument("Each epoch, write tile AEPS image to per-sim teps/ directory",
                       "--tileImages", &SetTileImages, this, false);

      RegisterArgument("If ARG > 0, Halts after ARG elapsed aeps.",
                       "--haltafteraeps", &SetHaltAfterAEPSFromArgs, this, true);

      RegisterArgument("Store data in per-sim directories under ARG (string)",
                       "-d|--dir", &SetDataDirFromArgs, this, true);

      RegisterArgument("Add ARG as a path to search for element libraries",
                       "-ep|--elementpath", &RegisterElementPath, this, true);

      RegisterArgument("Load initial configuration from file at path ARG (string)",
                       "-cp|--configpath", &LoadFromConfigFile, this, true);

      RegisterArgument("Continue execution after detected thread failures",
                       "--ignorethreadbugs", &SetIgnoreThreadingProblems,
                       this, false);
    }


    virtual void ReinitUs()
    { }

    u32 GetHaltAfterAEPS()
    {
      return m_haltAfterAEPS;
    }

    double GetAEPS()
    {
      return m_AEPS;
    }

    double GetAER()
    {
      return m_AER;
    }

    void SetAER(double aer)
    {
      m_AER = aer;
    }

    double GetRecentAER()
    {
      return m_recentAER;
    }

    void SetRecentAER(double aer)
    {
      m_recentAER = aer;
    }

    u32 GetAEPSPerFrame()
    {
      return m_aepsPerFrame;
    }

    double GetOverheadPercent()
    {
      return m_overheadPercent;
    }

    OurGrid & GetGrid()
    {
      return m_grid;
    }

    void SetSeed(u32 seed)
    {
      if(!seed)
      {
        FAIL(ILLEGAL_ARGUMENT);
      }
      m_grid.SetSeed(seed);
    }

    void Reinit()
    {
      m_lastFrameAEPS = 0;

      ReinitUs();

      m_grid.Reinit();

      m_grid.Needed(Element_Empty<CC>::THE_INSTANCE);

      ReinitPhysics();

      ReinitEden();

      PostReinit(m_varguments);

      LoadFromConfigurationPath();
    }

    void Run()
    {
      unwind_protect
      ({
        MFMPrintErrorEnvironment(stderr, &unwindProtect_errorEnvironment);
        fprintf(stderr, "Failure reached top-level! Aborting\n");
        abort();
       },
       {
         RunHelper();
       });
    }
  };
}

#endif /* ABSTRACTDRIVER_H */