X-Git-Url: http://git.treefish.org/~alex/phys/latlib.git/blobdiff_plain/57120da66874b239e28824c9790a62c3556a489e..ebc593f61243a8ead77dbe9128fdac77377d6734:/o815/obs.cpp

diff --git a/o815/obs.cpp b/o815/obs.cpp
index c10a5f4..37d1d4e 100644
--- a/o815/obs.cpp
+++ b/o815/obs.cpp
@@ -2,41 +2,43 @@
 
 #include "latlib/hypercache.h"
 
+#ifndef MPI_DISABLED
+#include <mpi.h>
+#endif
+
 void o815::obs::finish() {
   _finish();
 }
 
 void o815::obs::start() {
   if(O815->rank==0) {
-    *out << "#" << O815->programid << "-" << obsid << O815->headMaster() << endl << flush;
-    *out << "#" << O815->programid << "-" << obsid << O815->headMaster() << "-" << datadesc << endl << flush;
+    *out << "#" << O815->programid << "-" << obsid << obsidpostfix << O815->headMaster() << endl << flush;
+    *out << "#" << O815->programid << "-" << obsid << obsidpostfix << O815->headMaster() << "-" << datadesc << endl << flush;
   }
 
+#ifndef MPI_DISABLED
   if (O815->comargs.outdir=="")
     MPI_Barrier(MPI_COMM_WORLD);
-  
+#endif  
+
   _start();
 }
 
-void o815::obs::meas(bool loadedobs) {
-  _meas(loadedobs);
+void o815::obs::meas(bool loadedobs, const int& nthmeas) {
+  _meas(loadedobs, nthmeas);
 }
 
-o815::obs::obs(const string& _obsid, const string& _datadesc, o815 *_O815, const int& obsmemSize) {
+o815::obs::obs(const string& _obsid, const string& _datadesc, o815 *_O815, const int& obsmemSize, const string& _obsidpostfix) {
   obsid = _obsid;
+  obsidpostfix = _obsidpostfix;
   O815 = _O815;
   datadesc = _datadesc;
-  O815->out->newsub(obsid);
+  O815->out->newsub(obsid+obsidpostfix);
 
-  out = O815->out->out[obsid];
+  out = O815->out->out[obsid+obsidpostfix];
   log = O815->out->log;
   paraQ = O815->paraQ;
 
   ocid = hypercache::initO(O815->programid + "-" + obsid, O815->comargs.nequi, O815->comargs.nskip,
 			   O815->comargs.obscache.first, &obsMem, obsmemSize, O815->comargs.obscache.second, log);
 }
-
-void o815::obs::printParas() {
-  for (vector<string>::iterator parait = paraQ->allParaIds.begin(); parait != paraQ->allParaIds.end(); ++parait)
-    *O815->out->out[obsid] << (*paraQ)[*parait] << "\t";
-}