1
1

Per request from Jeff, aggregate all help messages during MPI_Init thru MPI_Finalize as long as the RTE is available

Этот коммит содержится в:
Ralph Castain 2016-04-15 13:37:22 -07:00
родитель 6b38c0e1ef
Коммит 7829fbdc29

Просмотреть файл

@ -148,7 +148,7 @@ void ompi_mpi_errors_return_win_handler(struct ompi_win_t **win,
static void out(char *str, char *arg) static void out(char *str, char *arg)
{ {
if (ompi_mpi_initialized && !ompi_mpi_finalized) { if (ompi_rte_initialized && !ompi_mpi_finalized) {
if (NULL != arg) { if (NULL != arg) {
opal_output(0, str, arg); opal_output(0, str, arg);
} else { } else {
@ -180,8 +180,6 @@ static void backend_fatal_aggregate(char *type,
char *arg, *prefix, *err_msg = "Unknown error"; char *arg, *prefix, *err_msg = "Unknown error";
bool err_msg_need_free = false; bool err_msg_need_free = false;
assert(ompi_mpi_initialized && !ompi_mpi_finalized);
arg = va_arg(arglist, char*); arg = va_arg(arglist, char*);
va_end(arglist); va_end(arglist);
@ -328,9 +326,8 @@ static void backend_fatal(char *type, struct ompi_communicator_t *comm,
char *name, int *error_code, char *name, int *error_code,
va_list arglist) va_list arglist)
{ {
/* We only want aggregation after MPI_INIT and before /* We only want aggregation while the rte is initialized */
MPI_FINALIZE. */ if (ompi_rte_initialized) {
if (ompi_mpi_initialized && !ompi_mpi_finalized) {
backend_fatal_aggregate(type, comm, name, error_code, arglist); backend_fatal_aggregate(type, comm, name, error_code, arglist);
} else { } else {
backend_fatal_no_aggregate(type, comm, name, error_code, arglist); backend_fatal_no_aggregate(type, comm, name, error_code, arglist);