2004-01-12 00:26:55 +03:00
|
|
|
/*
|
2005-11-05 22:57:48 +03:00
|
|
|
* Copyright (c) 2004-2005 The Trustees of Indiana University and Indiana
|
|
|
|
* University Research and Technology
|
|
|
|
* Corporation. All rights reserved.
|
2015-02-16 01:59:18 +03:00
|
|
|
* Copyright (c) 2004-2015 The University of Tennessee and The University
|
2005-11-05 22:57:48 +03:00
|
|
|
* of Tennessee Research Foundation. All rights
|
|
|
|
* reserved.
|
2015-06-24 06:59:57 +03:00
|
|
|
* Copyright (c) 2004-2005 High Performance Computing Center Stuttgart,
|
2004-11-28 23:09:25 +03:00
|
|
|
* University of Stuttgart. All rights reserved.
|
2005-03-24 15:43:37 +03:00
|
|
|
* Copyright (c) 2004-2005 The Regents of the University of California.
|
|
|
|
* All rights reserved.
|
2015-02-24 14:45:04 +03:00
|
|
|
* Copyright (c) 2015 Cisco Systems, Inc. All rights reserved.
|
2004-11-22 04:38:40 +03:00
|
|
|
* $COPYRIGHT$
|
2015-06-24 06:59:57 +03:00
|
|
|
*
|
2004-11-22 04:38:40 +03:00
|
|
|
* Additional copyrights may follow
|
2015-06-24 06:59:57 +03:00
|
|
|
*
|
2004-01-12 00:26:55 +03:00
|
|
|
* $HEADER$
|
|
|
|
*/
|
|
|
|
|
2004-06-07 19:33:53 +04:00
|
|
|
#include "ompi_config.h"
|
2004-02-15 00:26:30 +03:00
|
|
|
#include "coll_basic.h"
|
2004-01-12 00:26:55 +03:00
|
|
|
|
|
|
|
#include "mpi.h"
|
2006-02-12 04:33:29 +03:00
|
|
|
#include "ompi/constants.h"
|
- Split the datatype engine into two parts: an MPI specific part in
OMPI
and a language agnostic part in OPAL. The convertor is completely
moved into OPAL. This offers several benefits as described in RFC
http://www.open-mpi.org/community/lists/devel/2009/07/6387.php
namely:
- Fewer basic types (int* and float* types, boolean and wchar
- Fixing naming scheme to ompi-nomenclature.
- Usability outside of the ompi-layer.
- Due to the fixed nature of simple opal types, their information is
completely
known at compile time and therefore constified
- With fewer datatypes (22), the actual sizes of bit-field types may be
reduced
from 64 to 32 bits, allowing reorganizing the opal_datatype
structure, eliminating holes and keeping data required in convertor
(upon send/recv) in one cacheline...
This has implications to the convertor-datastructure and other parts
of the code.
- Several performance tests have been run, the netpipe latency does not
change with
this patch on Linux/x86-64 on the smoky cluster.
- Extensive tests have been done to verify correctness (no new
regressions) using:
1. mpi_test_suite on linux/x86-64 using clean ompi-trunk and
ompi-ddt:
a. running both trunk and ompi-ddt resulted in no differences
(except for MPI_SHORT_INT and MPI_TYPE_MIX_LB_UB do now run
correctly).
b. with --enable-memchecker and running under valgrind (one buglet
when run with static found in test-suite, commited)
2. ibm testsuite on linux/x86-64 using clean ompi-trunk and ompi-ddt:
all passed (except for the dynamic/ tests failed!! as trunk/MTT)
3. compilation and usage of HDF5 tests on Jaguar using PGI and
PathScale compilers.
4. compilation and usage on Scicortex.
- Please note, that for the heterogeneous case, (-m32 compiled
binaries/ompi), neither
ompi-trunk, nor ompi-ddt branch would successfully launch.
This commit was SVN r21641.
2009-07-13 08:56:31 +04:00
|
|
|
#include "ompi/datatype/ompi_datatype.h"
|
2005-09-13 00:21:53 +04:00
|
|
|
#include "ompi/mca/coll/coll.h"
|
|
|
|
#include "ompi/mca/coll/base/coll_tags.h"
|
2004-01-12 00:26:55 +03:00
|
|
|
#include "coll_basic.h"
|
2005-09-13 00:21:53 +04:00
|
|
|
#include "ompi/mca/pml/pml.h"
|
2005-07-04 04:13:44 +04:00
|
|
|
#include "opal/util/bit_ops.h"
|
2004-01-12 00:26:55 +03:00
|
|
|
|
|
|
|
|
|
|
|
/*
|
2004-06-29 04:02:25 +04:00
|
|
|
* bcast_log_intra
|
2004-01-12 00:26:55 +03:00
|
|
|
*
|
|
|
|
* Function: - broadcast using O(log(N)) algorithm
|
|
|
|
* Accepts: - same arguments as MPI_Bcast()
|
|
|
|
* Returns: - MPI_SUCCESS or error code
|
|
|
|
*/
|
2005-08-10 14:51:42 +04:00
|
|
|
int
|
|
|
|
mca_coll_basic_bcast_log_intra(void *buff, int count,
|
2005-08-10 21:53:43 +04:00
|
|
|
struct ompi_datatype_t *datatype, int root,
|
2007-08-19 07:37:49 +04:00
|
|
|
struct ompi_communicator_t *comm,
|
2008-07-29 02:40:57 +04:00
|
|
|
mca_coll_base_module_t *module)
|
2004-01-12 00:26:55 +03:00
|
|
|
{
|
2004-05-08 03:09:55 +04:00
|
|
|
int i;
|
|
|
|
int size;
|
|
|
|
int rank;
|
|
|
|
int vrank;
|
|
|
|
int peer;
|
|
|
|
int dim;
|
|
|
|
int hibit;
|
|
|
|
int mask;
|
|
|
|
int err;
|
|
|
|
int nreqs;
|
2004-06-07 19:33:53 +04:00
|
|
|
ompi_request_t **preq;
|
2007-08-19 07:37:49 +04:00
|
|
|
mca_coll_basic_module_t *basic_module = (mca_coll_basic_module_t*) module;
|
|
|
|
ompi_request_t **reqs = basic_module->mccb_reqs;
|
2004-05-08 03:09:55 +04:00
|
|
|
|
2004-06-07 19:33:53 +04:00
|
|
|
size = ompi_comm_size(comm);
|
|
|
|
rank = ompi_comm_rank(comm);
|
2004-05-08 03:09:55 +04:00
|
|
|
vrank = (rank + size - root) % size;
|
|
|
|
|
|
|
|
dim = comm->c_cube_dim;
|
2005-07-04 04:13:44 +04:00
|
|
|
hibit = opal_hibit(vrank, dim);
|
2015-02-24 14:45:04 +03:00
|
|
|
if (hibit < 0) {
|
|
|
|
return MPI_ERR_OTHER;
|
|
|
|
}
|
2004-05-08 03:09:55 +04:00
|
|
|
--dim;
|
|
|
|
|
|
|
|
/* Receive data from parent in the tree. */
|
|
|
|
|
|
|
|
if (vrank > 0) {
|
2005-08-10 21:53:43 +04:00
|
|
|
peer = ((vrank & ~(1 << hibit)) + root) % size;
|
|
|
|
|
|
|
|
err = MCA_PML_CALL(recv(buff, count, datatype, peer,
|
|
|
|
MCA_COLL_BASE_TAG_BCAST,
|
|
|
|
comm, MPI_STATUS_IGNORE));
|
|
|
|
if (MPI_SUCCESS != err) {
|
|
|
|
return err;
|
|
|
|
}
|
2004-01-12 00:26:55 +03:00
|
|
|
}
|
2004-05-08 03:09:55 +04:00
|
|
|
|
|
|
|
/* Send data to the children. */
|
|
|
|
|
2004-06-29 04:02:25 +04:00
|
|
|
err = MPI_SUCCESS;
|
2004-05-08 03:09:55 +04:00
|
|
|
preq = reqs;
|
|
|
|
nreqs = 0;
|
|
|
|
for (i = hibit + 1, mask = 1 << i; i <= dim; ++i, mask <<= 1) {
|
2005-08-10 21:53:43 +04:00
|
|
|
peer = vrank | mask;
|
|
|
|
if (peer < size) {
|
|
|
|
peer = (peer + root) % size;
|
|
|
|
++nreqs;
|
|
|
|
|
|
|
|
err = MCA_PML_CALL(isend_init(buff, count, datatype, peer,
|
|
|
|
MCA_COLL_BASE_TAG_BCAST,
|
|
|
|
MCA_PML_BASE_SEND_STANDARD,
|
|
|
|
comm, preq++));
|
|
|
|
if (MPI_SUCCESS != err) {
|
2006-11-08 19:54:03 +03:00
|
|
|
mca_coll_basic_free_reqs(reqs, nreqs);
|
2005-08-10 21:53:43 +04:00
|
|
|
return err;
|
|
|
|
}
|
|
|
|
}
|
2004-01-12 00:26:55 +03:00
|
|
|
}
|
|
|
|
|
2004-05-08 03:09:55 +04:00
|
|
|
/* Start and wait on all requests. */
|
2004-01-12 00:26:55 +03:00
|
|
|
|
2004-05-08 03:09:55 +04:00
|
|
|
if (nreqs > 0) {
|
2004-01-12 00:26:55 +03:00
|
|
|
|
2005-08-10 21:53:43 +04:00
|
|
|
/* Start your engines. This will never return an error. */
|
2005-08-10 14:51:42 +04:00
|
|
|
|
2005-08-10 21:53:43 +04:00
|
|
|
MCA_PML_CALL(start(nreqs, reqs));
|
2004-01-12 00:26:55 +03:00
|
|
|
|
2005-08-10 21:53:43 +04:00
|
|
|
/* Wait for them all. If there's an error, note that we don't
|
|
|
|
* care what the error was -- just that there *was* an error.
|
|
|
|
* The PML will finish all requests, even if one or more of them
|
|
|
|
* fail. i.e., by the end of this call, all the requests are
|
|
|
|
* free-able. So free them anyway -- even if there was an
|
|
|
|
* error, and return the error after we free everything. */
|
2004-06-29 04:02:25 +04:00
|
|
|
|
2005-08-10 21:53:43 +04:00
|
|
|
err = ompi_request_wait_all(nreqs, reqs, MPI_STATUSES_IGNORE);
|
2004-06-29 04:02:25 +04:00
|
|
|
|
2005-08-10 21:53:43 +04:00
|
|
|
/* Free the reqs */
|
2005-08-10 14:51:42 +04:00
|
|
|
|
2005-08-10 21:53:43 +04:00
|
|
|
mca_coll_basic_free_reqs(reqs, nreqs);
|
2004-01-12 00:26:55 +03:00
|
|
|
}
|
|
|
|
|
2004-05-08 03:09:55 +04:00
|
|
|
/* All done */
|
2004-01-12 00:26:55 +03:00
|
|
|
|
2004-06-29 04:02:25 +04:00
|
|
|
return err;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
* bcast_lin_inter
|
|
|
|
*
|
|
|
|
* Function: - broadcast using O(N) algorithm
|
|
|
|
* Accepts: - same arguments as MPI_Bcast()
|
|
|
|
* Returns: - MPI_SUCCESS or error code
|
|
|
|
*/
|
2005-08-10 14:51:42 +04:00
|
|
|
int
|
|
|
|
mca_coll_basic_bcast_lin_inter(void *buff, int count,
|
2005-08-10 21:53:43 +04:00
|
|
|
struct ompi_datatype_t *datatype, int root,
|
2007-08-19 07:37:49 +04:00
|
|
|
struct ompi_communicator_t *comm,
|
2008-07-29 02:40:57 +04:00
|
|
|
mca_coll_base_module_t *module)
|
2004-06-29 04:02:25 +04:00
|
|
|
{
|
2004-08-04 02:12:57 +04:00
|
|
|
int i;
|
|
|
|
int rsize;
|
|
|
|
int err;
|
2007-08-19 07:37:49 +04:00
|
|
|
mca_coll_basic_module_t *basic_module = (mca_coll_basic_module_t*) module;
|
|
|
|
ompi_request_t **reqs = basic_module->mccb_reqs;
|
2004-08-04 02:12:57 +04:00
|
|
|
|
|
|
|
rsize = ompi_comm_remote_size(comm);
|
|
|
|
|
2005-08-10 14:51:42 +04:00
|
|
|
if (MPI_PROC_NULL == root) {
|
2005-08-10 21:53:43 +04:00
|
|
|
/* do nothing */
|
|
|
|
err = OMPI_SUCCESS;
|
2005-08-10 14:51:42 +04:00
|
|
|
} else if (MPI_ROOT != root) {
|
2005-08-10 21:53:43 +04:00
|
|
|
/* Non-root receive the data. */
|
|
|
|
err = MCA_PML_CALL(recv(buff, count, datatype, root,
|
|
|
|
MCA_COLL_BASE_TAG_BCAST, comm,
|
|
|
|
MPI_STATUS_IGNORE));
|
2005-08-10 14:51:42 +04:00
|
|
|
} else {
|
2005-08-10 21:53:43 +04:00
|
|
|
/* root section */
|
|
|
|
for (i = 0; i < rsize; i++) {
|
|
|
|
err = MCA_PML_CALL(isend(buff, count, datatype, i,
|
|
|
|
MCA_COLL_BASE_TAG_BCAST,
|
|
|
|
MCA_PML_BASE_SEND_STANDARD,
|
|
|
|
comm, &(reqs[i])));
|
|
|
|
if (OMPI_SUCCESS != err) {
|
|
|
|
return err;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
err = ompi_request_wait_all(rsize, reqs, MPI_STATUSES_IGNORE);
|
2004-08-04 02:12:57 +04:00
|
|
|
}
|
|
|
|
|
2005-08-10 14:51:42 +04:00
|
|
|
|
2004-08-04 02:12:57 +04:00
|
|
|
/* All done */
|
|
|
|
return err;
|
2004-06-29 04:02:25 +04:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
* bcast_log_inter
|
|
|
|
*
|
|
|
|
* Function: - broadcast using O(N) algorithm
|
|
|
|
* Accepts: - same arguments as MPI_Bcast()
|
|
|
|
* Returns: - MPI_SUCCESS or error code
|
|
|
|
*/
|
2005-08-10 14:51:42 +04:00
|
|
|
int
|
|
|
|
mca_coll_basic_bcast_log_inter(void *buff, int count,
|
2005-08-10 21:53:43 +04:00
|
|
|
struct ompi_datatype_t *datatype, int root,
|
2007-08-19 07:37:49 +04:00
|
|
|
struct ompi_communicator_t *comm,
|
2008-07-29 02:40:57 +04:00
|
|
|
mca_coll_base_module_t *module)
|
2004-06-29 04:02:25 +04:00
|
|
|
{
|
2005-08-10 14:51:42 +04:00
|
|
|
return OMPI_ERR_NOT_IMPLEMENTED;
|
2004-01-12 00:26:55 +03:00
|
|
|
}
|