exit(0);
}
- if( comargs.showjobnum ) {
- for( int i=1; i<=paraQ->getTotalJobs(); i++ ) {
- if( paraQ->getTotalJobs()%i == 0 ) cout << paraQ->getTotalJobs()/i << "@" << i << " ";
- }
- cout << endl;
- exit(0);
- }
-
if(rank==0) {
timestamp = time(NULL);
for(int idest=1; idest<numprocs; idest++)
}
void o815::mainLoop() {
+ if( comargs.showjobnum ) {
+ for( int i=1; i<=paraQ->getTotalJobs(); i++ ) {
+ if( paraQ->getTotalJobs()%i == 0 ) cout << paraQ->getTotalJobs()/i << "@" << i << " ";
+ }
+ cout << endl;
+ exit(0);
+ }
+
*out->log << "OBS: Starting main loop." << endl;
for (vector<obs*>::iterator obsit = observables.begin(); obsit != observables.end(); ++obsit)
progress measProg(comargs.nmeas);
- *out->log << "OBS: Starting measurements." << endl << flush;
+ *out->log << "OBS: Starting measurement of observables:";
+ for (vector<obs*>::iterator obsit = observables.begin(); obsit != observables.end(); ++obsit)
+ *out->log << " " << (*obsit)->obsid;
+ *out->log << endl << flush;
for( int imeas=0; imeas<comargs.nmeas; imeas++ ) {
bool nextAlready = false;
void start();
string getDataDesc() { return datadesc; };
int ocid;
+ string obsid;
private:
virtual void _meas(bool loadedobs)=0;
virtual void _finish()=0;
protected:
o815 *O815;
char *obsMem;
- string obsid, simid, datadesc;
+ string simid, datadesc;
ostream *out, *log;
+ void printParas();
+ paraq* paraQ;
};
class sim {
out = O815->out->out[obsid];
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";
+}