Commit d89f9b87 authored by Peter W. Draper's avatar Peter W. Draper
Browse files

Make sure all message have the correct MPI rank

Otherwise until engine_init we see [0000]
parent e90dd24b
...@@ -120,6 +120,10 @@ int main(int argc, char *argv[]) { ...@@ -120,6 +120,10 @@ int main(int argc, char *argv[]) {
error("MPI_Comm_size failed with error %i.", res); error("MPI_Comm_size failed with error %i.", res);
if ((res = MPI_Comm_rank(MPI_COMM_WORLD, &myrank)) != MPI_SUCCESS) if ((res = MPI_Comm_rank(MPI_COMM_WORLD, &myrank)) != MPI_SUCCESS)
error("Call to MPI_Comm_rank failed with error %i.", res); error("Call to MPI_Comm_rank failed with error %i.", res);
/* Make sure messages are stamped with the correct rank. */
engine_rank = myrank;
if ((res = MPI_Comm_set_errhandler(MPI_COMM_WORLD, MPI_ERRORS_RETURN)) != if ((res = MPI_Comm_set_errhandler(MPI_COMM_WORLD, MPI_ERRORS_RETURN)) !=
MPI_SUCCESS) MPI_SUCCESS)
error("Call to MPI_Comm_set_errhandler failed with error %i.", res); error("Call to MPI_Comm_set_errhandler failed with error %i.", res);
...@@ -131,6 +135,7 @@ int main(int argc, char *argv[]) { ...@@ -131,6 +135,7 @@ int main(int argc, char *argv[]) {
message("WARNING: you should use the non-MPI version of this program."); message("WARNING: you should use the non-MPI version of this program.");
} }
fflush(stdout); fflush(stdout);
#endif #endif
/* Let's pin the main thread */ /* Let's pin the main thread */
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment