for (vector<obs*>::iterator obsit = observables.begin(); obsit != observables.end(); ++obsit) {
(*obsit)->finish();
}
-
- //MPI_Finalize();
}
void o815::parseArgs(int argc, char **argv) {
if(rank==0)
cout << "#end" << endl << flush;
}
-
- cout << "bu:" << rank << endl;
-
delete out;
MPI_Finalize();
}
{
if(fulldir != "") {
for (map<string,ofstream*>::iterator ofit = of.begin(); ofit != of.end(); ++ofit) {
- cout << ofit->first << endl;
if( cRank[0] == '0' ) {
int jobsdone=0;
while(jobsdone<numprocs-1) {
- cout << ofit->first << endl;
- cout << "here" << endl;
string nextfile;
if( (nextfile = getdatfile(ofit->first)) == "" )
sleep(1);
DIR *dp;
struct dirent *dirp;
- cout << "getting:" << subname << endl;
-
if((dp = opendir(fulldir.c_str())) == NULL) {
logf << "Error(" << errno << ") opening " << fulldir << endl;
- cout << "blub" << endl;
return "";
}
{
myfile = string(dirp->d_name);
- cout << myfile << endl;
-
if(myfile.length() > 3 && myfile.substr(myfile.length()-4) == "part" &&
subname == myfile.substr( myfile.find("-")+1, myfile.rfind(".")-myfile.find("-")-1 ) ) {
- cout << myfile << endl;
return myfile;
}
}