X-Git-Url: http://git.treefish.org/~alex/phys/latlib.git/blobdiff_plain/ad54f29de351976a096b4991fe426ffc30332df2..2a77bf6d539b1750d194de21ed287a958609693a:/configcache.h diff --git a/configcache.h b/configcache.h index 82fa3f6..158eb0a 100644 --- a/configcache.h +++ b/configcache.h @@ -7,12 +7,6 @@ #include #include -#include -#include -#include -#include -#include - #define CACHE_MODE_DISABLED 0 #define CACHE_MODE_READ 1 #define CACHE_MODE_FULL 2 @@ -28,7 +22,6 @@ struct infiledesc { string filename; int nequi; int nskip; - bool doVirtualEquilibration; bool extended; }; @@ -37,29 +30,35 @@ class configcache{ ~configcache(); configcache(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); - int readConfig(vector *excludeFileHashes=NULL); - void writeConfig(); + void readConfig(bool *readnewconfig, int *nequileft, vector *excludeFileHashes=NULL); + void writeConfig(int actnequi); void addPara(const string& parid, const double& val=0); void setPara(const string& parid, const double& value); - void writeHeader(const string& headerid, const char *header, long unsigned int size); + void writeHeader(const string& headerid, const char *header, long unsigned int size, int actnequi); void * getHeader(const string& headerid); string getOutFileName() { return outFileName.str(); } string getInFileName() { return DATADIR + "/" + openFileDesc.filename; } static unsigned long hash(const string& str); void closeInFile() { inFile.close(); } int inFilesLeft() { return inFiles.size(); } + char* getConfigMem() { return configMem; } + int getConfigSize() { return configSize; } + bool isOutFileOpen () { return outFile.is_open(); } + void finishOutFile(); private: + struct iobuffers; + iobuffers *ioBuffers; + ostream* log; infiledesc openFileDesc; - void finishOutFile(); int getParIndex(const string& parid); int NEQUI; int NSKIP; string DATADIR; string CACHEID; int MODE; - string getFileId(const bool& shortid=false); + string getFileId(int actnequi, const bool& shortid=false); ofstream outFile; ifstream inFile; @@ -68,9 +67,6 @@ class configcache{ int readnum; - boost::iostreams::filtering_istreambuf *inBuffer; - boost::iostreams::filtering_ostreambuf *outBuffer; - int inSize; int configSize; @@ -89,7 +85,7 @@ class configcache{ int readDataToMem(char *tmpData, long unsigned int dataSize); - void openOutFile(); + void openOutFile(int actnequi); int readHeader(); @@ -104,6 +100,10 @@ class configcache{ bool readAllHeaders(); vector::iterator getNextInfile(vector *excludeFileHashes); + + int nequileft_internal; + + bool doVirtualEquilibration, firstUsedConfig; }; #endif