openmpi/src/errhandler/errhandler_predefined.c

/*
 * $HEADER$
 */

#include <stdlib.h>
#if __STDC__
#include <stdarg.h>
#else
#include <varargs.h>
#endif

#include "util/output.h"
#include "errhandler/errhandler.h"
#include "errhandler/errhandler_predefined.h"
#include "errhandler/errcode.h"
#include "communicator/communicator.h"
#include "file/file.h"
#include "win/win.h"
#include "runtime/runtime.h"


void ompi_mpi_errors_are_fatal_comm_handler(struct ompi_communicator_t **comm,
					    int *error_code, ...)
{
  char *arg;
  va_list arglist;

#if __STDC__
  va_start(arglist, error_code);
#else
  va_start(arglist);
#endif

  fflush(stdout);
  fflush(stderr);
  arg = va_arg(arglist, char*);
  if (NULL != arg) {
    ompi_output(0, "*** An error occurred in %s", arg);
  } else {
    ompi_output(0, "*** An error occurred");
  }

  if (NULL != comm && ompi_mpi_initialized && !ompi_mpi_finalized) {
    ompi_output(0, "*** on communicator %s", (*comm)->c_name);
  } else if (!ompi_mpi_initialized) {
    ompi_output(0, "*** before MPI was initialized");
  } else if (ompi_mpi_finalized) {
    ompi_output(0, "*** after MPI was finalized");
  } else if (NULL == comm) {
    ompi_output(0, "*** on a NULL communicator");
  }

  if (NULL != error_code) {
    char *tmp = ompi_mpi_errcode_get_string(*error_code);
    if (NULL != tmp) {
      ompi_output(0, "*** %s\n", tmp);
    } else {
      ompi_output(0, "*** Error code: %d (no associated error message)\n",
                  *error_code);
    }
  }
  ompi_output(0, "*** MPI_ERRORS_ARE_FATAL (goodbye)");
  va_end(arglist);

  /* Should we do something more intelligent here? */

  abort();
}


void ompi_mpi_errors_are_fatal_file_handler(struct ompi_file_t **file,
					    int *error_code, ...)
{
  char *arg;
  va_list arglist;

#if __STDC__
  va_start(arglist, error_code);
#else
  va_start(arglist);
#endif

  fflush(stdout);
  fflush(stderr);
  arg = va_arg(arglist, char*);
  if (NULL != arg) {
    ompi_output(0, "*** An error occurred in %s", arg);
  } else {
    ompi_output(0, "*** An error occurred");
  }

  if (NULL != file && ompi_mpi_initialized && !ompi_mpi_finalized) {
    ompi_output(0, "*** on file %s", (*file)->f_filename);
  } else if (!ompi_mpi_initialized) {
    ompi_output(0, "*** before MPI was initialized");
  } else if (ompi_mpi_finalized) {
    ompi_output(0, "*** after MPI was finalized");
  } else if (NULL == file) {
    ompi_output(0, "*** on a NULL file");
  }

  if (NULL != error_code) {
    char *tmp = ompi_mpi_errcode_get_string(*error_code);
    if (NULL != tmp) {
      ompi_output(0, "*** %s\n", tmp);
    } else {
      ompi_output(0, "*** Error code: %d (no associated error message)\n",
                  *error_code);
    }
  }
  ompi_output(0, "*** MPI_ERRORS_ARE_FATAL (goodbye)");
  va_end(arglist);

  /* Should we do something more intelligent here? */

  abort();
}

void ompi_mpi_errors_are_fatal_win_handler(struct ompi_win_t **win,
					   int *error_code, ...)
{
  char *arg;
  va_list arglist;

#if __STDC__
  va_start(arglist, error_code);
#else
  va_start(arglist);
#endif

  fflush(stdout);
  fflush(stderr);
  arg = va_arg(arglist, char*);
  if (NULL != arg) {
    ompi_output(0, "*** An error occurred in %s", arg);
  } else {
    ompi_output(0, "*** An error occurred");
  }

  if (NULL != win && ompi_mpi_initialized && !ompi_mpi_finalized) {
    ompi_output(0, "*** on win %s", (*win)->w_name);
  } else if (!ompi_mpi_initialized) {
    ompi_output(0, "*** before MPI was initialized");
  } else if (ompi_mpi_finalized) {
    ompi_output(0, "*** after MPI was finalized");
  } else if (NULL == win) {
    ompi_output(0, "*** on a NULL window");
  }

  if (NULL != error_code) {
    char *tmp = ompi_mpi_errcode_get_string(*error_code);
    if (NULL != tmp) {
      ompi_output(0, "*** %s\n", tmp);
    } else {
      ompi_output(0, "*** Error code: %d (no associated error message)\n",
                  *error_code);
    }
  }
  ompi_output(0, "*** MPI_ERRORS_ARE_FATAL (goodbye)");
  va_end(arglist);

  /* Should we do something more intelligent here? */

  abort();
}

void ompi_mpi_errors_return_comm_handler(struct ompi_communicator_t **comm,
					 int *error_code, ...)
{
  /* Don't need anything more -- just need this function to exist */
}

void ompi_mpi_errors_return_file_handler(struct ompi_file_t **file,
					 int *error_code, ...)
{
    /* Don't need anything more -- just need this function to exist */
}

void ompi_mpi_errors_return_win_handler(struct ompi_win_t **win,
					int *error_code, ...)
{
  /* Don't need anything more -- just need this function to exist */
}