/* * Copyright (c) 2004-2007 The Trustees of Indiana University and Indiana * University Research and Technology * Corporation. All rights reserved. * Copyright (c) 2004-2005 The University of Tennessee and The University * of Tennessee Research Foundation. All rights * reserved. * Copyright (c) 2004-2006 High Performance Computing Center Stuttgart, * University of Stuttgart. All rights reserved. * Copyright (c) 2004-2005 The Regents of the University of California. * All rights reserved. * $COPYRIGHT$ * * Additional copyrights may follow * * $HEADER$ */ #include "ompi_config.h" #include "opal/util/show_help.h" #include "ompi/mpi/c/bindings.h" #include "ompi/constants.h" #if OMPI_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES #pragma weak MPI_Init_thread = PMPI_Init_thread #endif #if OMPI_PROFILING_DEFINES #include "ompi/mpi/c/profile/defines.h" #endif static const char FUNC_NAME[] = "MPI_Init_thread"; int MPI_Init_thread(int *argc, char ***argv, int required, int *provided) { int err; OPAL_CR_TEST_CHECKPOINT_READY(); if ( MPI_PARAM_CHECK ) { if (required < MPI_THREAD_SINGLE || required > MPI_THREAD_MULTIPLE) { ompi_mpi_errors_are_fatal_comm_handler(NULL, NULL, FUNC_NAME); } } /* * A thread compliant MPI implementation will be able to return provided * = MPI_THREAD_MULTIPLE. Such an implementation may always return provided * = MPI_THREAD_MULTIPLE, irrespective of the value of required. */ #if OMPI_ENABLE_MPI_THREADS *provided = MPI_THREAD_MULTIPLE; #else *provided = MPI_THREAD_SINGLE; #endif /* Ensure that we were not already initialized or finalized */ if (ompi_mpi_finalized) { if (0 == ompi_comm_rank(MPI_COMM_WORLD)) { opal_show_help("help-mpi-api.txt", "mpi-function-after-finalize", true, FUNC_NAME); } return ompi_errhandler_invoke(NULL, NULL, OMPI_ERRHANDLER_TYPE_COMM, MPI_ERR_OTHER, FUNC_NAME); } else if (ompi_mpi_initialized) { if (0 == ompi_comm_rank(MPI_COMM_WORLD)) { opal_show_help("help-mpi-api.txt", "mpi-initialize-twice", true, FUNC_NAME); } return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_OTHER, FUNC_NAME); } /* Call the back-end initialization function (we need to put as little in this function as possible so that if it's profiled, we don't lose anything) */ if (NULL != argc && NULL != argv) { err = ompi_mpi_init(*argc, *argv, required, provided); } else { err = ompi_mpi_init(0, NULL, required, provided); } /* Since we don't have a communicator to invoke an errorhandler on here, don't use the fancy-schmancy ERRHANDLER macros; they're really designed for real communicator objects. Just use the back-end function directly. */ if (MPI_SUCCESS != err) { return ompi_errhandler_invoke(NULL, NULL, OMPI_ERRHANDLER_TYPE_COMM, err < 0 ? ompi_errcode_get_mpi_code(err) : err, FUNC_NAME); } return MPI_SUCCESS; }