}
void writeout::newsub(string subname) {
- of[subname] = new ofstream;
+ of[subname] = new ofstream;
if ( fulldir != "" ) {
if(rank>0) of[subname]->open( (fulldir + "/rank" + cRank + "-" + subname + ".tmp").c_str() );
{
if(fulldir != "") {
for (map<string,ofstream*>::iterator ofit = of.begin(); ofit != of.end(); ++ofit) {
- if( cRank[0] == '0' ) {
+ if( cRank[0] == '0' ) {
int jobsdone=0;
while(jobsdone<numprocs-1) {
string nextfile;
}
*ofit->second << "#end" << endl << flush;
ofit->second->close();
- rename( fulldir.c_str(), fulldir.substr(0, fulldir.length()-4).c_str() );
}
else {
ofit->second->close();
- rename((fulldir + "/rank" + cRank + ".tmp").c_str(),
- (fulldir + "/rank" + cRank + ".part").c_str());
+ rename((fulldir + "/rank" + cRank + "-" + ofit->first + ".tmp").c_str(),
+ (fulldir + "/rank" + cRank + "-" + ofit->first + ".part").c_str());
}
}
+ if( cRank[0] == '0' )
+ rename( fulldir.c_str(), fulldir.substr(0, fulldir.length()-4).c_str() );
}
logf << "[ " << timestring() << " ] Log ends here." << endl;
logf.close();
while ((dirp = readdir(dp)) != NULL)
{
myfile = string(dirp->d_name);
- if(myfile.length() > 3 && myfile.substr(myfile.length()-4) == "part") {
+
+ if(myfile.length() > 3 && myfile.substr(myfile.length()-4) == "part" &&
+ subname == myfile.substr( myfile.find("-")+1, myfile.rfind(".")-myfile.find("-")-1 ) ) {
return myfile;
}
}