X-Git-Url: http://git.treefish.org/~alex/phys/latlib.git/blobdiff_plain/fbbe6f07bc8720030541b7319acb02c9233cd622..66dd4bd348bacf6b43b59c2b349a913b722c6504:/hypercache.h

diff --git a/hypercache.h b/hypercache.h
index 53e0f67..1a64373 100644
--- a/hypercache.h
+++ b/hypercache.h
@@ -2,6 +2,7 @@
 #define HYPERCACHE_H
 
 #include <iostream>
+#include <ostream>
 
 #include "configcache.h"
 
@@ -9,57 +10,74 @@ using namespace std;
 
 class hypercache {
  public:
-  static void initO(const string& cacheid, const int& nequi, const int& nskip, const string& datadir, 
-		    char **configmem, const int& configMemSize, const int& cachemode=CACHE_MODE_FULL, writeout *out_a=NULL) {
-    initCache(O, cacheid, nequi, nskip, datadir+"/o", configmem, configMemSize, cachemode, out_a);
+  struct observable{
+    configcache *c;
+    int lastWrittenObsEquis;
+  };
+
+  static int initO(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) {
+    observable newobs;
+    
+    newobs.c = NULL;
+    newobs.lastWrittenObsEquis = 0;
+    Os.push_back(newobs);
+
+    initCache(&Os.back().c, cacheid, nequi, nskip, datadir, configmem, configMemSize, cachemode, _log);
+    return Os.size()-1;
   }
   static void initC(const string& cacheid, const int& nequi, const int& nskip, const string& datadir, 
-		    char **configmem, const int& configMemSize, const int& cachemode=CACHE_MODE_FULL, writeout *out_a=NULL) {
-    initCache(C, cacheid, nequi, nskip, datadir+"/c", configmem, configMemSize, cachemode, out_a);
-  }
-  
-  static void initO(const string& cacheid, char **configmem, const int& configMemSize, const int& cachemode=CACHE_MODE_FULL) {
-    initCache(O, "o", cacheid, configmem, configMemSize, cachemode);
-  }
-  static void initC(const string& cacheid, char **configmem, const int& configMemSize, const int& cachemode=CACHE_MODE_FULL) {
-    initCache(C, "c", cacheid, configmem, configMemSize, cachemode);
+		    char **configmem, const int& configMemSize, const int& cachemode=CACHE_MODE_FULL, ostream *_log=NULL) {
+    initCache(&C, cacheid, nequi, nskip, datadir, configmem, configMemSize, cachemode, _log);
+    mostEquilibratedConfig.second = new char[configMemSize];
   }
+
+  static int getNEquiLeft() { return nequileft; }
   
   static void addPara(const string& parid, const double& val=0);
   static void setPara(const string& parid, const double& value);
-  static bool readO() { return O->readConfig(); }
-  static bool readC() { return C->readConfig(); }
-  static void writeO() { O->writeConfig(); }
-  static void writeC() { C->writeConfig(); }
-  static void writeHeaderO(const string& headerid, char *header, long unsigned int size) { O->writeHeader(headerid, header, size); }
-  static void *getHeaderO(const string& headerid) { O->getHeader(headerid); }
-  static void writeHeaderC(const string& headerid, char *header, long unsigned int size) { C->writeHeader(headerid, header, size); }
+  static void readO(int obsid, bool *readNewObsConfig, int *nequiObsLeft);
+  static bool readC();
+  static void writeO(int obsid);
+  static void writeC();
+  static void writeHeaderO(int obsid, const string& headerid, char *header, long unsigned int size, int actnequi) { Os[obsid].c->writeHeader(headerid, header, size, actnequi); }
+  static void *getHeaderO(int obsid, const string& headerid) { Os[obsid].c->getHeader(headerid); }
+  static void writeHeaderC(const string& headerid, char *header, long unsigned int size, int actnequi) { C->writeHeader(headerid, header, size, actnequi); }
   static void *getHeaderC(const string& headerid) { C->getHeader(headerid); }
+
+  static void finalize();
+
+  static int CFilesLeft() { return C->inFilesLeft(); }
   
  private:
-  struct defaults{
-    int nequi;
-    int nskip;
-    string datadir;
-    writeout *out;
-  };
   struct para{
     string parid;
     double val;
   };
 
-  static void initCache(configcache *cache,
+  static void initCache(configcache **cache,
 			const string& cacheid, const int& nequi, const int& nskip, const string& datadir, 
-			char **configmem, const int& configMemSize, const int& cachemode=CACHE_MODE_FULL, writeout *out_a=NULL); 
+			char **configmem, const int& configMemSize, const int& cachemode=CACHE_MODE_FULL, ostream* _log=NULL); 
 
-  static void initCache( configcache *cache, const string& subdir,
+  static void initCache( configcache **cache,
 			 const string& cacheid, char **configmem, const int& configMemSize, const int& cachemode=CACHE_MODE_FULL);
-  
-  static configcache *O;
+
   static configcache *C;
-  static defaults *Defaults; 
+  static vector<observable> Os;
   static vector<para> delayedParaAdd;
   static vector<para> delayedParaSet;
+
+  static string fileOfPath(const string& dressedfile);
+  static string activeCFile;
+  static vector<unsigned long> parentConfigs;
+  static void addParentConfig(const unsigned long *parentconfig);
+  static ostream* log;
+
+  static int NEQUI;
+  static int NSKIP;
+  static int nequileft;
+
+  static pair<int, char*> mostEquilibratedConfig;
 };
 
 #endif