hypercache.h

   1 #ifndef HYPERCACHE_H
   2 #define HYPERCACHE_H
   3
   4 #include <iostream>
   5 #include <ostream>
   6
   7 #include "configcache.h"
   8
   9 using namespace std;
  10
  11 class hypercache {
  12  public:
  13   struct observable{
  14     configcache *c;
  15     int lastWrittenObsEquis;
  16   };
  17
  18   static int initO(const string& cacheid, const int& nequi, const int& nskip, const string& datadir,
  19                    char **configmem, const int& configMemSize, const int& cachemode=CACHE_MODE_RW, ostream *_log=NULL) {
  20     observable newobs;
  21
  22     newobs.c = NULL;
  23     newobs.lastWrittenObsEquis = 0;
  24     Os.push_back(newobs);
  25
  26     initCache(&Os.back().c, cacheid, nequi, nskip, datadir, configmem, configMemSize, cachemode, _log);
  27     return Os.size()-1;
  28   }
  29   static void initC(const string& cacheid, const int& nequi, const int& nskip, const string& datadir,
  30                     char **configmem, const int& configMemSize, const int& cachemode=CACHE_MODE_RW, ostream *_log=NULL) {
  31     initCache(&C, cacheid, nequi, nskip, datadir, configmem, configMemSize, cachemode, _log);
  32     mostEquilibratedConfig.second = new char[configMemSize];
  33   }
  34
  35   static int getNEquiLeft() { return nequileft; }
  36
  37   static void addPara(const string& parid, const double& val=0);
  38   static void setPara(const string& parid, const double& value);
  39   static void readO(int obsid, bool *readNewObsConfig, int *nequiObsLeft);
  40   static bool readC();
  41   static void writeO(int obsid);
  42   static void writeC();
  43   static void writeHeaderO(int obsid, const string& headerid, char *header, long unsigned int size, int actnequi) { Os[obsid].c->writeHeader(headerid, header, size, actnequi); }
  44   static void *getHeaderO(int obsid, const string& headerid) { Os[obsid].c->getHeader(headerid); }
  45   static void writeHeaderC(const string& headerid, char *header, long unsigned int size, int actnequi) { C->writeHeader(headerid, header, size, actnequi); }
  46   static void *getHeaderC(const string& headerid) { C->getHeader(headerid); }
  47
  48   static void finalize();
  49
  50   static int CFilesLeft() { return C->inFilesLeft(); }
  51
  52  private:
  53   struct para{
  54     string parid;
  55     double val;
  56   };
  57
  58   static void initCache(configcache **cache,
  59                         const string& cacheid, const int& nequi, const int& nskip, const string& datadir,
  60                         char **configmem, const int& configMemSize, const int& cachemode=CACHE_MODE_RW, ostream* _log=NULL);
  61
  62   static void initCache( configcache **cache,
  63                          const string& cacheid, char **configmem, const int& configMemSize, const int& cachemode=CACHE_MODE_RW);
  64
  65   static configcache *C;
  66   static vector<observable> Os;
  67   static vector<para> delayedParaAdd;
  68   static vector<para> delayedParaSet;
  69
  70   static string fileOfPath(const string& dressedfile);
  71   static string activeCFile;
  72   static vector<unsigned long> parentConfigs;
  73   static void addParentConfig(const unsigned long *parentconfig);
  74   static ostream* log;
  75
  76   static int NEQUI;
  77   static int NSKIP;
  78   static int nequileft;
  79
  80   static pair<int, char*> mostEquilibratedConfig;
  81 };
  82
  83 #endif