X-Git-Url: http://git.treefish.org/~alex/phys/latlib.git/blobdiff_plain/7f5403eed95da4350dcc03d817eb8468dab07142..db68c55d4535522352b71a8d69d3a38ba97c67a5:/hypercache.h?ds=inline diff --git a/hypercache.h b/hypercache.h index 11e1565..a30e28e 100644 --- a/hypercache.h +++ b/hypercache.h @@ -2,6 +2,7 @@ #define HYPERCACHE_H #include +#include #include "configcache.h" @@ -9,27 +10,32 @@ using namespace std; class hypercache { public: - static void initO(const string& cacheid, const int& nequi, const int& nskip, const string& datadir, - char **configmem, const int& configMemSize, const int& cachemode=CACHE_MODE_FULL, writeout *out_a=NULL) { - initCache(&O, cacheid, nequi, nskip, datadir, configmem, configMemSize, cachemode, out_a); + static int initO(const string& cacheid, const int& nequi, const int& nskip, const string& datadir, + char **configmem, const int& configMemSize, const int& cachemode=CACHE_MODE_FULL, ostream *_log=NULL) { + Os.push_back(NULL); + initCache(&Os.back(), cacheid, nequi, nskip, datadir, configmem, configMemSize, cachemode, _log); + return Os.size()-1; } static void initC(const string& cacheid, const int& nequi, const int& nskip, const string& datadir, - char **configmem, const int& configMemSize, const int& cachemode=CACHE_MODE_FULL, writeout *out_a=NULL) { - initCache(&C, cacheid, nequi, nskip, datadir, configmem, configMemSize, cachemode, out_a); + char **configmem, const int& configMemSize, const int& cachemode=CACHE_MODE_FULL, ostream *_log=NULL) { + initCache(&C, cacheid, nequi, nskip, datadir, configmem, configMemSize, cachemode, _log); } static void addPara(const string& parid, const double& val=0); static void setPara(const string& parid, const double& value); - static bool readO(); - static bool readC(); - static void writeO(); + static int readO(int obsid); + static int readC(); + static void writeO(int obsid); static void writeC(); - static void writeHeaderO(const string& headerid, char *header, long unsigned int size) { O->writeHeader(headerid, header, size); } - static void *getHeaderO(const string& headerid) { O->getHeader(headerid); } + static void writeHeaderO(int obsid, const string& headerid, char *header, long unsigned int size) { Os[obsid]->writeHeader(headerid, header, size); } + static void *getHeaderO(int obsid, const string& headerid) { Os[obsid]->getHeader(headerid); } static void writeHeaderC(const string& headerid, char *header, long unsigned int size) { C->writeHeader(headerid, header, size); } static void *getHeaderC(const string& headerid) { C->getHeader(headerid); } static void finalize(); + + static int read1CForEqui(); + static int CFilesLeft() { return C->inFilesLeft(); } private: struct para{ @@ -39,21 +45,21 @@ class hypercache { static void initCache(configcache **cache, const string& cacheid, const int& nequi, const int& nskip, const string& datadir, - char **configmem, const int& configMemSize, const int& cachemode=CACHE_MODE_FULL, writeout *out_a=NULL); + char **configmem, const int& configMemSize, const int& cachemode=CACHE_MODE_FULL, ostream* _log=NULL); static void initCache( configcache **cache, const string& cacheid, char **configmem, const int& configMemSize, const int& cachemode=CACHE_MODE_FULL); - static configcache *O; static configcache *C; + static vector Os; static vector delayedParaAdd; static vector delayedParaSet; - static writeout *out; static string fileOfPath(const string& dressedfile); static string activeCFile; static vector parentConfigs; static void addParentConfig(const unsigned long *parentconfig); + static ostream* log; }; #endif