ports/openmpi
ports/openmpi
1
1
Форкнуть 0
Код Релизы Активность
c6ee421c78
openmpi/ompi/mca/coll/tuned/coll_tuned_util.h

116 строки
4.8 KiB
C
Исходник Обычный вид История

Multiple changes -added some alltoall calls (pairwise checked ok, bruck testing) -changes in use of data hung of communicator -making sendrecv call a true inline function -more use ompi_ddt routines This commit was SVN r7337.
2005-09-13 08:28:18 +04:00
/*
Update the copyright notices for IU and UTK. This commit was SVN r7999.
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.
* Copyright (c) 2004-2005 The University of Tennessee and The University
* of Tennessee Research Foundation. All rights
* reserved.
- fix compiler warning in ia64 This commit was SVN r13212.
2007-01-19 17:48:47 +03:00
* Copyright (c) 2004-2007 High Performance Computing Center Stuttgart,
Multiple changes -added some alltoall calls (pairwise checked ok, bruck testing) -changes in use of data hung of communicator -making sendrecv call a true inline function -more use ompi_ddt routines This commit was SVN r7337.
2005-09-13 08:28:18 +04:00
* 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$
*/
#ifndef MCA_COLL_TUNED_UTIL_EXPORT_H
#define MCA_COLL_TUNED_UTIL_EXPORT_H
#include "ompi_config.h"
#include "mpi.h"
Next step in the project split, mainly source code re-arranging - move files out of toplevel include/ and etc/, moving it into the sub-projects - rather than including config headers with <project>/include, have them as <project> - require all headers to be included with a project prefix, with the exception of the config headers ({opal,orte,ompi}_config.h mpi.h, and mpif.h) This commit was SVN r8985.
2006-02-12 04:33:29 +03:00
#include "opal/mca/mca.h"
#include "ompi/datatype/datatype.h"
#include "ompi/mca/coll/coll.h"
#include "ompi/request/request.h"
#include "ompi/mca/pml/pml.h"
Multiple changes -added some alltoall calls (pairwise checked ok, bruck testing) -changes in use of data hung of communicator -making sendrecv call a true inline function -more use ompi_ddt routines This commit was SVN r7337.
2005-09-13 08:28:18 +04:00
#if defined(c_plusplus) || defined(__cplusplus)
extern "C" {
#endif
/* prototypes */
Minor changes to allgather implementation with some clean-up of util code. - in allgather algorithms I replaces irecv-isend-waitall sequence with call to ompi_coll_tuned_sendrecv - most of the functions in util code and allgather decision function conform to 80 character line width. - This commit was SVN r13069.
2007-01-11 00:56:59 +03:00
int ompi_coll_tuned_sendrecv_actual( void* sendbuf, int scount,
ompi_datatype_t* sdatatype,
Correct the bcast problem where we always did a bcast with segzise of 0. Activate the reduce decision function. Others small updates (mostly TAB to spaces). This commit was SVN r12161.
2006-10-18 06:00:46 +04:00
int dest, int stag,
Minor changes to allgather implementation with some clean-up of util code. - in allgather algorithms I replaces irecv-isend-waitall sequence with call to ompi_coll_tuned_sendrecv - most of the functions in util code and allgather decision function conform to 80 character line width. - This commit was SVN r13069.
2007-01-11 00:56:59 +03:00
void* recvbuf, int rcount,
ompi_datatype_t* rdatatype,
Correct the bcast problem where we always did a bcast with segzise of 0. Activate the reduce decision function. Others small updates (mostly TAB to spaces). This commit was SVN r12161.
2006-10-18 06:00:46 +04:00
int source, int rtag,
struct ompi_communicator_t* comm,
ompi_status_public_t* status );
Multiple changes -added some alltoall calls (pairwise checked ok, bruck testing) -changes in use of data hung of communicator -making sendrecv call a true inline function -more use ompi_ddt routines This commit was SVN r7337.
2005-09-13 08:28:18 +04:00
/* inline functions */
sendrecv is a static inline. This commit was SVN r13237.
2007-01-22 08:50:23 +03:00
static inline int
Minor changes to allgather implementation with some clean-up of util code. - in allgather algorithms I replaces irecv-isend-waitall sequence with call to ompi_coll_tuned_sendrecv - most of the functions in util code and allgather decision function conform to 80 character line width. - This commit was SVN r13069.
2007-01-11 00:56:59 +03:00
ompi_coll_tuned_sendrecv( void* sendbuf, int scount, ompi_datatype_t* sdatatype,
int dest, int stag,
void* recvbuf, int rcount, ompi_datatype_t* rdatatype,
int source, int rtag,
struct ompi_communicator_t* comm,
sendrecv is a static inline. This commit was SVN r13237.
2007-01-22 08:50:23 +03:00
ompi_status_public_t* status, int myid )
{
if ((dest == myid) && (source == myid)) {
return (int) ompi_ddt_sndrcv(sendbuf, (int32_t) scount, sdatatype,
recvbuf, (int32_t) rcount, rdatatype);
}
return ompi_coll_tuned_sendrecv_actual (sendbuf, scount, sdatatype,
dest, stag,
recvbuf, rcount, rdatatype,
source, rtag, comm, status);
}
Multiple changes -added some alltoall calls (pairwise checked ok, bruck testing) -changes in use of data hung of communicator -making sendrecv call a true inline function -more use ompi_ddt routines This commit was SVN r7337.
2005-09-13 08:28:18 +04:00
Minor changes to allgather implementation with some clean-up of util code. - in allgather algorithms I replaces irecv-isend-waitall sequence with call to ompi_coll_tuned_sendrecv - most of the functions in util code and allgather decision function conform to 80 character line width. - This commit was SVN r13069.
2007-01-11 00:56:59 +03:00
int
ompi_coll_tuned_sendrecv_actual_localcompleted( void* sendbuf, int scount,
ompi_datatype_t* sdatatype,
int dest, int stag,
void* recvbuf, int rcount,
ompi_datatype_t* rdatatype,
int source, int rtag,
struct ompi_communicator_t* comm,
ompi_status_public_t* status );
a couple of changes to make barrier synchronous.. means last communication to any possible peer must be locally completing. for now using synchronous calls until the new functionality is available. then will change the code to use the new PML send flags. This commit was SVN r8867.
2006-02-01 02:21:46 +03:00
/* inline functions */
Minor changes to allgather implementation with some clean-up of util code. - in allgather algorithms I replaces irecv-isend-waitall sequence with call to ompi_coll_tuned_sendrecv - most of the functions in util code and allgather decision function conform to 80 character line width. - This commit was SVN r13069.
2007-01-11 00:56:59 +03:00
static inline int
ompi_coll_tuned_sendrecv_localcompleted( void* sendbuf, int scount,
ompi_datatype_t* sdatatype,
int dest, int stag,
void* recvbuf, int rcount,
ompi_datatype_t* rdatatype,
int source, int rtag,
struct ompi_communicator_t* comm,
ompi_status_public_t* status, int myid )
a couple of changes to make barrier synchronous.. means last communication to any possible peer must be locally completing. for now using synchronous calls until the new functionality is available. then will change the code to use the new PML send flags. This commit was SVN r8867.
2006-02-01 02:21:46 +03:00
{
Minor changes to allgather implementation with some clean-up of util code. - in allgather algorithms I replaces irecv-isend-waitall sequence with call to ompi_coll_tuned_sendrecv - most of the functions in util code and allgather decision function conform to 80 character line width. - This commit was SVN r13069.
2007-01-11 00:56:59 +03:00
if ((dest == myid) && (source == myid)) {
return (int) ompi_ddt_sndrcv(sendbuf, (int32_t) scount, sdatatype,
recvbuf, (int32_t) rcount, rdatatype);
a couple of changes to make barrier synchronous.. means last communication to any possible peer must be locally completing. for now using synchronous calls until the new functionality is available. then will change the code to use the new PML send flags. This commit was SVN r8867.
2006-02-01 02:21:46 +03:00
}
Minor changes to allgather implementation with some clean-up of util code. - in allgather algorithms I replaces irecv-isend-waitall sequence with call to ompi_coll_tuned_sendrecv - most of the functions in util code and allgather decision function conform to 80 character line width. - This commit was SVN r13069.
2007-01-11 00:56:59 +03:00
return ompi_coll_tuned_sendrecv_actual_localcompleted (sendbuf, scount,
sdatatype, dest,
stag,
recvbuf, rcount,
rdatatype,
source, rtag, comm,
status);
a couple of changes to make barrier synchronous.. means last communication to any possible peer must be locally completing. for now using synchronous calls until the new functionality is available. then will change the code to use the new PML send flags. This commit was SVN r8867.
2006-02-01 02:21:46 +03:00
}
Multiple changes -added some alltoall calls (pairwise checked ok, bruck testing) -changes in use of data hung of communicator -making sendrecv call a true inline function -more use ompi_ddt routines This commit was SVN r7337.
2005-09-13 08:28:18 +04:00
Modifying util functionality: - removing static qualification on ompi_coll_tuned_sendrecv - adding ompi_coll_tuned_isendrecv function which posts isend and irecv requests These changes are separate from but necessary for new algorithms I am working on. This commit was SVN r13161.
2007-01-18 00:29:13 +03:00
/* inline functions */
inline int
ompi_coll_tuned_isendrecv( void* sendbuf, int scount, ompi_datatype_t* sdtype,
int dest, int stag, ompi_request_t** sreq,
void* recvbuf, int rcount, ompi_datatype_t* rdtype,
int source, int rtag, ompi_request_t** rreq,
struct ompi_communicator_t* comm );
Multiple changes -added some alltoall calls (pairwise checked ok, bruck testing) -changes in use of data hung of communicator -making sendrecv call a true inline function -more use ompi_ddt routines This commit was SVN r7337.
2005-09-13 08:28:18 +04:00
#if defined(c_plusplus) || defined(__cplusplus)
}
#endif
#endif /* MCA_COLL_TUNED_UTIL_EXPORT_H */
Копировать постоянную ссылку