6aac54b02e
Not sure what happened here, but the resulting trunk wouldn't even configure. After spending time fixing that problem, I found it wouldn't compile due to multiple syntax errors that had been introduced in both the OPAL and OMPI layer. This raised questions as to the completeness of the work. Given that the author is departing, I pinged Jeff about it and we agreed to revert this for now. Hopefully, it can either be fixed by the author prior to actual departure, or someone else can pick it up (now that it is in the history) and fix it. This commit was SVN r27511. The following SVN revision numbers were found above: r27508 --> open-mpi/ompi@12c3c743de r27509 --> open-mpi/ompi@79e4a8ca38 r27510 --> open-mpi/ompi@1ad5ff625a
114 строки
3.7 KiB
C
114 строки
3.7 KiB
C
/*
|
|
* 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-2008 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 <stdio.h>
|
|
|
|
#include "ompi/mpi/c/bindings.h"
|
|
#include "ompi/runtime/params.h"
|
|
#include "ompi/communicator/communicator.h"
|
|
#include "ompi/errhandler/errhandler.h"
|
|
#include "ompi/datatype/ompi_datatype.h"
|
|
#include "ompi/memchecker.h"
|
|
|
|
#if OPAL_HAVE_WEAK_SYMBOLS && OMPI_PROFILING_DEFINES
|
|
#pragma weak MPI_Bcast = PMPI_Bcast
|
|
#endif
|
|
|
|
#if OMPI_PROFILING_DEFINES
|
|
#include "ompi/mpi/c/profile/defines.h"
|
|
#endif
|
|
|
|
static const char FUNC_NAME[] = "MPI_Bcast";
|
|
|
|
|
|
int MPI_Bcast(void *buffer, int count, MPI_Datatype datatype,
|
|
int root, MPI_Comm comm)
|
|
{
|
|
int err;
|
|
|
|
MEMCHECKER(
|
|
memchecker_datatype(datatype);
|
|
memchecker_comm(comm);
|
|
if (OMPI_COMM_IS_INTRA(comm)) {
|
|
if (ompi_comm_rank(comm) == root) {
|
|
/* check whether root's send buffer is defined. */
|
|
memchecker_call(&opal_memchecker_base_isdefined, buffer, count, datatype);
|
|
}
|
|
/* check whether receive buffer is addressable. */
|
|
memchecker_call(&opal_memchecker_base_isaddressable, buffer, count, datatype);
|
|
} else {
|
|
if (MPI_ROOT == root) {
|
|
/* check whether root's send buffer is defined. */
|
|
memchecker_call(&opal_memchecker_base_isdefined, buffer, count, datatype);
|
|
} else if (MPI_PROC_NULL != root) {
|
|
/* check whether receive buffer is addressable. */
|
|
memchecker_call(&opal_memchecker_base_isaddressable, buffer, count, datatype);
|
|
}
|
|
}
|
|
);
|
|
|
|
if (MPI_PARAM_CHECK) {
|
|
err = MPI_SUCCESS;
|
|
OMPI_ERR_INIT_FINALIZE(FUNC_NAME);
|
|
if (ompi_comm_invalid(comm)) {
|
|
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_COMM,
|
|
FUNC_NAME);
|
|
}
|
|
|
|
/* Errors for all ranks */
|
|
|
|
OMPI_CHECK_DATATYPE_FOR_SEND(err, datatype, count);
|
|
OMPI_ERRHANDLER_CHECK(err, comm, err, FUNC_NAME);
|
|
if (MPI_IN_PLACE == buffer) {
|
|
return OMPI_ERRHANDLER_INVOKE(comm, MPI_ERR_ARG, FUNC_NAME);
|
|
}
|
|
|
|
/* Errors for intracommunicators */
|
|
|
|
if (OMPI_COMM_IS_INTRA(comm)) {
|
|
if ((root >= ompi_comm_size(comm)) || (root < 0)) {
|
|
return OMPI_ERRHANDLER_INVOKE(comm, MPI_ERR_ROOT, FUNC_NAME);
|
|
}
|
|
}
|
|
|
|
/* Errors for intercommunicators */
|
|
|
|
else {
|
|
if (! ((root >= 0 && root < ompi_comm_remote_size(comm)) ||
|
|
MPI_ROOT == root || MPI_PROC_NULL == root)) {
|
|
return OMPI_ERRHANDLER_INVOKE(comm, MPI_ERR_ROOT, FUNC_NAME);
|
|
}
|
|
}
|
|
}
|
|
|
|
/* If there's only one node, or if the count is 0, we're done */
|
|
|
|
if ((OMPI_COMM_IS_INTRA(comm) && ompi_comm_size(comm) <= 1) ||
|
|
0 == count) {
|
|
return MPI_SUCCESS;
|
|
}
|
|
|
|
OPAL_CR_ENTER_LIBRARY();
|
|
|
|
/* Invoke the coll component to perform the back-end operation */
|
|
|
|
err = comm->c_coll.coll_bcast(buffer, count, datatype, root, comm,
|
|
comm->c_coll.coll_bcast_module);
|
|
OMPI_ERRHANDLER_RETURN(err, comm, err, FUNC_NAME);
|
|
}
|