X-Git-Url: http://git.treefish.org/~alex/phys/latlib.git/blobdiff_plain/31dc8788f9711670917daaa5cc544d0d87ec3afc..40171a80594f79b137900fae122a2e33a3a88f95:/hypercache.cpp?ds=inline diff --git a/hypercache.cpp b/hypercache.cpp index 7e0f0e5..2d38b21 100644 --- a/hypercache.cpp +++ b/hypercache.cpp @@ -4,6 +4,9 @@ configcache *hypercache::O = NULL; configcache *hypercache::C = NULL; vector hypercache::delayedParaAdd; vector hypercache::delayedParaSet; +string hypercache::activeCFile = ""; +vector hypercache::parentConfigs; +writeout *hypercache::out = NULL; void hypercache::initCache(configcache **cache, const string& cacheid, const int& nequi, const int& nskip, const string& datadir, @@ -14,6 +17,9 @@ void hypercache::initCache(configcache **cache, if (O == NULL || C == NULL) allInitBefore = false; + if ( out_a != NULL ) + out = out_a; + *cache = new configcache(cacheid, nequi, nskip, datadir, configmem, configMemSize, cachemode, out_a); if (O != NULL && C != NULL && !allInitBefore) { @@ -51,6 +57,8 @@ void hypercache::setPara(const string& parid, const double& val) { else { O->setPara(parid, val); C->setPara(parid, val); + activeCFile = ""; + parentConfigs.clear(); } } @@ -58,3 +66,56 @@ void hypercache::finalize() { delete C; delete O; } + +string hypercache::fileOfPath(const string& dressedfile) { + return dressedfile.substr(dressedfile.find_last_of("\\/")+1); +} + +int hypercache::readC() { + int readret; + + readret = C->readConfig(&parentConfigs); + + if ( readret == -1 ) + activeCFile = fileOfPath(C->getInFileName()); + else + activeCFile = ""; + + return readret; +} + +void hypercache::writeC() { + C->writeConfig(); + activeCFile = fileOfPath( C->getOutFileName().substr( 0, C->getOutFileName().length()-4 ) ); +} + +void hypercache::writeO() { + if ( activeCFile != "" ) { + unsigned long afilehash = configcache::hash(activeCFile); + O->writeHeader("concurrent_cfile", (char*)(&afilehash), sizeof(unsigned long)); + } + + O->writeConfig(); +} + +int hypercache::readO() { + int readret; + + readret = O->readConfig(); + + if ( readret == -1 ) { + unsigned long *parentconfig = (unsigned long*)O->getHeader("concurrent_cfile"); + if ( parentconfig != NULL ) + addParentConfig(parentconfig); + } + + return readret; +} + +void hypercache::addParentConfig(const unsigned long *parentconfig) { + for (vector::iterator parit = parentConfigs.begin(); parit != parentConfigs.end(); ++parit) + if ( *parit == *parentconfig ) + return; + + parentConfigs.push_back(*parentconfig); +}