return NULL;
}
-bool configcache::readConfig(vector<string> *excludefiles)
-{
- if(DATADIR == "" || MODE == CACHE_MODE_DISABLED) return false;
+/* returns number of equilibration-steps left */
+int configcache::readConfig(vector<unsigned long> *excludeFileHashes)
+{
+ int nequileft = NEQUI;
+
+ if(DATADIR == "" || MODE == CACHE_MODE_DISABLED) return nequileft;
if(refetchDataFiles){
refetchDataFiles = false;
while(true)
{
- if( (!inFile.is_open()) && inFiles.size() == 0 ) return false;
+ if( (!inFile.is_open()) && inFiles.size() == 0 ) return nequileft;
while( (!inFile.is_open()) && inFiles.size() > 0 ) {
bool excludethisfile=false;
openFileDesc = inFiles.back();
- if (excludefiles != NULL)
- for (vector<string>::iterator exit = excludefiles->begin(); exit != excludefiles->end(); ++exit)
- if ( *exit == inFiles.back().filename ) {
+ if (excludeFileHashes != NULL)
+ for (vector<unsigned long>::iterator exit = excludeFileHashes->begin(); exit != excludeFileHashes->end(); ++exit)
+ if ( *exit == hash(inFiles.back().filename) ) {
excludethisfile = true;
break;
}
for (int iskip=0; iskip < (NEQUI-openFileDesc.nequi)/openFileDesc.nskip; iskip++) {
if( readFullBlock(tmpConfig, configSize) != configSize || ! inFile.is_open() )
break;
+ else if ( (NEQUI-openFileDesc.nequi) - (iskip+1)*openFileDesc.nskip < nequileft ) {
+ memcpy(configMem, tmpConfig, configSize);
+ nequileft = (NEQUI-openFileDesc.nequi) - (iskip+1)*openFileDesc.nskip;
+ }
}
}
if( readFullBlock(tmpConfig, configSize) == configSize && inFile.is_open() )
{
memcpy(configMem, tmpConfig, configSize);
- return true;
+ return -1;
}
else {
if(out) *out->log << "CCACHE: Could not read configuration. Closing dat-file: " << openFileDesc.filename << endl << flush;