ICODE-ADC/lammps
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

check for I/O error before closing restart file

Browse Source
This commit is contained in:
Axel Kohlmeyer
2020-03-09 17:42:00 -04:00
parent cf64ba4059
commit 6fb42a42b8
1 changed files with 15 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/write_restart.cpp
View File

@ -293,9 +293,11 @@ void WriteRestart::write(char *file)
// close header file, open multiname file on each writing proc, // close header file, open multiname file on each writing proc,
// write PROCSPERFILE into new file // write PROCSPERFILE into new file
int io_error = 0;
if (multiproc) { if (multiproc) {
if (me == 0 && fp) { if (me == 0 && fp) {
magic_string(); magic_string();
if (ferror(fp)) io_error = 1;
fclose(fp); fclose(fp);
fp = NULL; fp = NULL;
} }
@ -379,20 +381,20 @@ void WriteRestart::write(char *file)
if (mpiioflag) { if (mpiioflag) {
if (me == 0 && fp) { if (me == 0 && fp) {
magic_string(); magic_string();
if (ferror(fp)) io_error = 1;
fclose(fp); fclose(fp);
fp = NULL; fp = NULL;
} }
mpiio->openForWrite(file); mpiio->openForWrite(file);
mpiio->write(headerOffset,send_size,buf); mpiio->write(headerOffset,send_size,buf);
mpiio->close(); mpiio->close();
} } else {
// output of one or more native files // output of one or more native files
// filewriter = 1 = this proc writes to file // filewriter = 1 = this proc writes to file
// ping each proc in my cluster, receive its data, write data to file // ping each proc in my cluster, receive its data, write data to file
// else wait for ping from fileproc, send my data to fileproc // else wait for ping from fileproc, send my data to fileproc
else {
int tmp,recv_size; int tmp,recv_size;
if (filewriter) { if (filewriter) {
@ -409,6 +411,7 @@ void WriteRestart::write(char *file)
write_double_vec(PERPROC,recv_size,buf); write_double_vec(PERPROC,recv_size,buf);
} }
magic_string(); magic_string();
if (ferror(fp)) io_error = 1;
fclose(fp); fclose(fp);
fp = NULL; fp = NULL;
@ -418,6 +421,12 @@ void WriteRestart::write(char *file)
} }
} }
// Check for I/O error status
int io_all = 0;
MPI_Allreduce(&io_error,&io_all,1,MPI_INT,MPI_MAX,world);
if (io_all) error->all(FLERR,"I/O error while writing restart");
// clean up // clean up
memory->destroy(buf); memory->destroy(buf);