X-Git-Url: http://git.treefish.org/~alex/phys/latlib.git/blobdiff_plain/a5f05e337d18c193ac57b4da0013d1cdc69f8faa..HEAD:/o815/obs.cpp?ds=inline diff --git a/o815/obs.cpp b/o815/obs.cpp index 807d4ee..37d1d4e 100644 --- a/o815/obs.cpp +++ b/o815/obs.cpp @@ -2,33 +2,40 @@ #include "latlib/hypercache.h" +#ifndef MPI_DISABLED +#include +#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;