string truncIn, truncOut;
filedesc->filename = infile;
- filedesc->doVirtualEquilibration = false;
- filedesc->firstUsedConfig = true;
if( infile.size() < 4 ) return false;
return false;
break;
case 2:
- if (atoi(inParts) < NEQUI)
- filedesc->doVirtualEquilibration = true;
filedesc->nequi = atoi(inParts);
break;
case 3:
return NULL;
}
-/* returns number of equilibration-steps left with new read configuration
- or zero if no new configuration was read */
-void configcache::readConfig(bool& readnewconfig, int& nequileft, vector<unsigned long> *excludeFileHashes)
+void configcache::readConfig(bool *readnewconfig, int *nequileft, vector<unsigned long> *excludeFileHashes)
{
- readnewconfig = false;
+ *readnewconfig = false;
if(DATADIR == "" || MODE == CACHE_MODE_DISABLED) return;
int iDidVirtualSkips;
if( (!inFile.is_open()) && inFileIt == inFiles.end() ) {
- cout << "RETURNING..." << endl;
- nequileft = nequileft_internal;
+ if (*readnewconfig)
+ *nequileft = nequileft_internal;
return;
}
while( (!inFile.is_open()) && inFiles.size() > 0 ) {
openFileDesc = *inFileIt;
+ if (openFileDesc.nequi < NEQUI)
+ doVirtualEquilibration = true;
+ else
+ doVirtualEquilibration = false;
+
+ firstUsedConfig = true;
+
if(log) *log << "CCACHE: Opening dat-file: " << inFileIt->filename << endl << flush;
inFile.open( (DATADIR + "/" + inFileIt->filename).c_str(), std::ios::binary );
if( inFile.is_open() )
{
- if (openFileDesc.doVirtualEquilibration) {
+ if (doVirtualEquilibration) {
if(log) *log << "CCACHE: Trying virtual equilibration." << endl << flush;
- openFileDesc.doVirtualEquilibration = false;
+ doVirtualEquilibration = false;
for (iDidVirtualSkips=0; iDidVirtualSkips < (NEQUI-openFileDesc.nequi)/openFileDesc.nskip; iDidVirtualSkips++) {
if( readFullBlock(tmpConfig, configSize) != configSize || ! inFile.is_open() )
break;
else if ( (NEQUI-openFileDesc.nequi) - (iDidVirtualSkips+1)*openFileDesc.nskip < nequileft_internal ) {
memcpy(configMem, tmpConfig, configSize);
nequileft_internal = NEQUI - openFileDesc.nequi - (iDidVirtualSkips+1)*openFileDesc.nskip;
- cout << "blabla:" << nequileft_internal << endl;
- readnewconfig = true;
- openFileDesc.firstUsedConfig = false;
+ *readnewconfig = true;
+ firstUsedConfig = false;
}
}
}
if( readFullBlock(tmpConfig, configSize) == configSize && inFile.is_open() )
{
memcpy(configMem, tmpConfig, configSize);
- readnewconfig = true;
- if (openFileDesc.firstUsedConfig) {
- openFileDesc.firstUsedConfig = false;
- if (NEQUI < openFileDesc.nequi)
+ *readnewconfig = true;
+ if (firstUsedConfig) {
+ firstUsedConfig = false;
+ if (openFileDesc.nequi < NEQUI)
nequileft_internal = NEQUI - openFileDesc.nequi - iDidVirtualSkips*openFileDesc.nskip;
else
nequileft_internal = NEQUI - openFileDesc.nequi;
}
nequileft_internal -= openFileDesc.nskip;
- cout << "sadasd:" << nequileft_internal << endl;
- nequileft = nequileft_internal;
+ *nequileft = nequileft_internal;
return;
}
else {
}
void configcache::openOutFile(int actnequi)
-{
+{
time_t secstamp = time(NULL);
outFileName.str("");
void configcache::setPara(const string& parid, const double& value){
Paras[getParIndex(parid)].val = value;
+
finishOutFile();
if(inBuffer != NULL) { delete inBuffer; inBuffer=NULL; }
inFile.close();
inFiles.clear();
refetchDataFiles = true;
+ nequileft_internal = NEQUI;
}
configcache::~configcache()