#include "o815.h"
+#include "latlib/hypercache.h"
+
void o815::obs::finish() {
_finish();
}
void o815::obs::start() {
if(O815->rank==0) {
- *oout << "#" << obsid << O815->headMaster() << endl << flush;
- *oout << "#" << 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;
}
if (O815->comargs.outdir=="")
_start();
}
-void o815::obs::meas() {
- _meas(true);
+void o815::obs::meas(bool loadedobs, const int& nthmeas) {
+ _meas(loadedobs, nthmeas);
}
-o815::obs::obs(const string& _obsid, const string& _datadesc, o815 *_O815, char *_obsmem, 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);
- oout = O815->out->out[obsid];
- olog = O815->out->log;
+ O815->out->newsub(obsid+obsidpostfix);
+
+ 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);
}