openmpi/src/errhandler/errhandler_invoke.c

/*
 * $HEADER$
 */

#include "ompi_config.h"

#include "communicator/communicator.h"
#include "win/win.h"
#include "file/file.h"
#include "errhandler/errhandler.h"


int ompi_errhandler_invoke(ompi_errhandler_t *errhandler, void *mpi_object, 
                          int err_code, const char *message)
{
  int fortran_handle;
  ompi_communicator_t *comm;
  ompi_win_t *win;
  ompi_file_t *file;

  /* If we got no errorhandler, then just invoke errors_abort */
  
  if (NULL == errhandler) {
    ompi_mpi_errors_are_fatal_handler(NULL, NULL, message);
  }

  /* Figure out what kind of errhandler it is, figure out if it's
     fortran or C, and then invoke it */

  switch (errhandler->eh_mpi_object_type) {
  case OMPI_ERRHANDLER_TYPE_COMM:
    comm = (ompi_communicator_t *) mpi_object;
    if (errhandler->eh_fortran_function) {
      fortran_handle = comm->c_f_to_c_index;
      errhandler->eh_func.fort_fn(&fortran_handle, &err_code);
    } else {
      errhandler->eh_func.c_comm_fn(&comm, &err_code, message, NULL);
    }
    break;

  case OMPI_ERRHANDLER_TYPE_WIN:
    win = (ompi_win_t *) mpi_object;
    if (errhandler->eh_fortran_function) {
      fortran_handle = win->w_f_to_c_index;
      errhandler->eh_func.fort_fn(&fortran_handle, &err_code);
    } else {
      errhandler->eh_func.c_win_fn(&win, &err_code, message, NULL);
    }
    break;

  case OMPI_ERRHANDLER_TYPE_FILE:
    file = (ompi_file_t *) mpi_object;
    if (errhandler->eh_fortran_function) {
      fortran_handle = file->f_f_to_c_index;
      errhandler->eh_func.fort_fn(&fortran_handle, &err_code);
    } else {
      errhandler->eh_func.c_file_fn(&file, &err_code, message, NULL);
    }
    break;
  }

  /* All done */

  return err_code;
}