#include <string>
#include <fstream>
#include <sstream>
+#include <ostream>
#include <boost/iostreams/filtering_streambuf.hpp>
#include <boost/iostreams/stream.hpp>
double val;
};
+struct infiledesc {
+ string filename;
+ int nequi;
+ int nskip;
+ bool doVirtualEquilibration;
+ bool extended;
+ int readEquilibratedConfigs;
+};
+
class configcache{
public:
~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);
- bool readConfig();
- void writeConfig();
+ 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);
+ void readConfig(bool& readnewconfig, int& nequileft, vector<unsigned long> *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, 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(); }
+
private:
+ ostream* log;
+ infiledesc openFileDesc;
void finishOutFile();
int getParIndex(const string& parid);
int NEQUI;
string DATADIR;
string CACHEID;
int MODE;
- string getFileId(const bool& shortid=false);
+ string getFileId(int actnequi, const bool& shortid=false);
ofstream outFile;
ifstream inFile;
void fetchDataFiles();
- bool isValidInFile(const string& infile);
+ bool isValidInFile(const string& infile, infiledesc *filedesc);
- vector<string> inFiles;
+ vector<infiledesc> inFiles;
vector<parameter> Paras;
+
+ int readDataToMem(char *tmpData, long unsigned int dataSize);
+
+ void openOutFile(int actnequi);
+
+ int readHeader();
+
+ bool headerWritten;
+
+ int readFullBlock(char *tmpData, long unsigned int dataSize);
+
+ vector< pair<unsigned long, void *> > headerStore;
+
+ void deleteHeaderStore();
+
+ bool readAllHeaders();
+
+ vector<infiledesc>::iterator getNextInfile(vector<unsigned long> *excludeFileHashes);
};
#endif