Skip to content
Snippets Groups Projects
Commit 6570cbb4 authored by Thomas Jahns's avatar Thomas Jahns :cartwheel: Committed by Sergey Kosukhin
Browse files

Fix incorrect counting of open files.

parent e1669729
No related branches found
No related tags found
2 merge requests!34Version 2.2.0,!13Consolidation with CDI-PIO (develop)
......@@ -111,6 +111,7 @@ fcFileWriteAtAll(int fileID)
assert(fileID >= 0 && (size_t) fileID < openFilesSize && openFiles[fileID].name);
struct fileMPIFWAA *of = openFiles + fileID;
int iret = destroyAFiledataFileWriteAtAll(of);
--openFilesFill;
return iret;
}
......@@ -154,6 +155,7 @@ fowFileWriteAtAll(const char *filename, const char *mode)
}
}
struct fileMPIFWAA *of = openFiles + fileID;
++openFilesFill;
initAFiledataFileWriteAtAll(of, filename, conf->writeAggBufLim);
return (int) fileID;
}
......
......@@ -417,6 +417,7 @@ fcFileWriteAtReblock(int fileID)
assert(fileID >= 0 && (size_t) fileID < openFilesSize && openFiles[fileID].name);
struct fileMPIFWAR *of = openFiles + fileID;
int iret = destroyAFiledataFileWriteAtReblock(of);
--openFilesFill;
return iret;
}
......@@ -460,6 +461,7 @@ fowFileWriteAtReblock(const char *filename, const char *mode)
}
}
struct fileMPIFWAR *of = openFiles + fileID;
++openFilesFill;
initAFiledataFileWriteAtReblock(of, filename, conf);
return (int) fileID;
}
......
......@@ -97,6 +97,7 @@ fcFileWriteOrdered(int fileID)
assert(fileID >= 0 && (size_t) fileID < openFilesSize && openFiles[fileID].name);
struct fileMPIFWO *of = openFiles + fileID;
int iret = destroyAFiledataFileWriteOrdered(of);
--openFilesFill;
return iret;
}
......@@ -130,6 +131,7 @@ fowFileWriteOrdered(const char *filename, const char *mode)
}
}
struct fileMPIFWO *of = openFiles + fileID;
++openFilesFill;
initAFiledataFileWriteOrdered(of, filename, conf->writeAggBufLim);
return (int) fileID;
}
......
......@@ -194,6 +194,7 @@ fcMPINONB(int fileID)
xmpiStat(MPI_Wait(&(of->request), &status), &status);
/* remove file element */
int iret = destroyAFiledataMPINONB(of);
--openFilesFill;
return iret;
}
......@@ -237,6 +238,7 @@ fowMPINONB(const char *filename, const char *mode)
}
}
struct fileMPIFWS *of = openFiles + fileID;
++openFilesFill;
initAFiledataMPINONB(of, filename, conf->writeAggBufLim);
return (int) fileID;
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment