* finish the TEG/UNIQ/PTL removal
This commit was SVN r9118.
Этот коммит содержится в:
родитель
08b3bad09d
Коммит
2eb76ff0cd
@ -34,7 +34,6 @@
|
|||||||
#include "ompi/attribute/attribute.h"
|
#include "ompi/attribute/attribute.h"
|
||||||
#include "ompi/communicator/communicator.h"
|
#include "ompi/communicator/communicator.h"
|
||||||
#include "ompi/mca/pml/pml.h"
|
#include "ompi/mca/pml/pml.h"
|
||||||
#include "ompi/mca/ptl/base/ptl_base_comm.h"
|
|
||||||
#include "ompi/request/request.h"
|
#include "ompi/request/request.h"
|
||||||
|
|
||||||
/*
|
/*
|
||||||
|
@ -24,7 +24,6 @@
|
|||||||
#if defined(c_plusplus) || defined(__cplusplus)
|
#if defined(c_plusplus) || defined(__cplusplus)
|
||||||
extern "C" {
|
extern "C" {
|
||||||
#endif
|
#endif
|
||||||
struct mca_ptl_base_send_request_t;
|
|
||||||
|
|
||||||
OMPI_DECLSPEC int mca_pml_base_bsend_init(bool enable_mpi_threads);
|
OMPI_DECLSPEC int mca_pml_base_bsend_init(bool enable_mpi_threads);
|
||||||
OMPI_DECLSPEC int mca_pml_base_bsend_fini(void);
|
OMPI_DECLSPEC int mca_pml_base_bsend_fini(void);
|
||||||
|
@ -402,7 +402,7 @@ static int mca_pml_base_modex_subscribe(orte_process_name_t* name)
|
|||||||
}
|
}
|
||||||
OPAL_UNLOCK(&mca_pml_base_modex_lock);
|
OPAL_UNLOCK(&mca_pml_base_modex_lock);
|
||||||
|
|
||||||
/* otherwise - subscribe to get this jobid's ptl contact info */
|
/* otherwise - subscribe to get this jobid's contact info */
|
||||||
if (ORTE_SUCCESS != (rc = orte_ns.get_jobid(&jobid, name))) {
|
if (ORTE_SUCCESS != (rc = orte_ns.get_jobid(&jobid, name))) {
|
||||||
ORTE_ERROR_LOG(rc);
|
ORTE_ERROR_LOG(rc);
|
||||||
return rc;
|
return rc;
|
||||||
|
@ -25,7 +25,6 @@
|
|||||||
#include "ompi/constants.h"
|
#include "ompi/constants.h"
|
||||||
#include "ompi/mca/pml/pml.h"
|
#include "ompi/mca/pml/pml.h"
|
||||||
#include "ompi/mca/pml/base/base.h"
|
#include "ompi/mca/pml/base/base.h"
|
||||||
#include "ompi/mca/ptl/base/base.h"
|
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* The following file was created by configure. It contains extern
|
* The following file was created by configure. It contains extern
|
||||||
@ -89,7 +88,4 @@ int mca_pml_base_open(void)
|
|||||||
|
|
||||||
mca_base_param_lookup_string(
|
mca_base_param_lookup_string(
|
||||||
mca_base_param_register_string("pml",NULL,NULL,NULL,"ob1"), &mca_pml_base_pml);
|
mca_base_param_register_string("pml",NULL,NULL,NULL,"ob1"), &mca_pml_base_pml);
|
||||||
|
|
||||||
/* All done, now let's start the PTLs */
|
|
||||||
return mca_ptl_base_open();
|
|
||||||
}
|
}
|
||||||
|
@ -23,7 +23,6 @@
|
|||||||
|
|
||||||
#include "opal/threads/mutex.h"
|
#include "opal/threads/mutex.h"
|
||||||
#include "opal/threads/condition.h"
|
#include "opal/threads/condition.h"
|
||||||
#include "ompi/mca/ptl/ptl.h"
|
|
||||||
#include "opal/class/opal_list.h"
|
#include "opal/class/opal_list.h"
|
||||||
#include "ompi/communicator/communicator.h"
|
#include "ompi/communicator/communicator.h"
|
||||||
#include "ompi/proc/proc.h"
|
#include "ompi/proc/proc.h"
|
||||||
|
@ -254,7 +254,7 @@ do { \
|
|||||||
do { \
|
do { \
|
||||||
/* local variables */ \
|
/* local variables */ \
|
||||||
mca_pml_dr_recv_request_t *specific_recv, *wild_recv; \
|
mca_pml_dr_recv_request_t *specific_recv, *wild_recv; \
|
||||||
mca_ptl_sequence_t wild_recv_seq, specific_recv_seq; \
|
mca_pml_sequence_t wild_recv_seq, specific_recv_seq; \
|
||||||
int frag_tag, wild_recv_tag, specific_recv_tag; \
|
int frag_tag, wild_recv_tag, specific_recv_tag; \
|
||||||
\
|
\
|
||||||
/* initialization */ \
|
/* initialization */ \
|
||||||
|
@ -23,7 +23,6 @@
|
|||||||
|
|
||||||
#include "opal/threads/mutex.h"
|
#include "opal/threads/mutex.h"
|
||||||
#include "opal/threads/condition.h"
|
#include "opal/threads/condition.h"
|
||||||
#include "ompi/mca/ptl/ptl.h"
|
|
||||||
#include "opal/class/opal_list.h"
|
#include "opal/class/opal_list.h"
|
||||||
#include "ompi/proc/proc.h"
|
#include "ompi/proc/proc.h"
|
||||||
#if defined(c_plusplus) || defined(__cplusplus)
|
#if defined(c_plusplus) || defined(__cplusplus)
|
||||||
|
@ -222,7 +222,7 @@ do { \
|
|||||||
do { \
|
do { \
|
||||||
/* local variables */ \
|
/* local variables */ \
|
||||||
mca_pml_ob1_recv_request_t *specific_recv, *wild_recv; \
|
mca_pml_ob1_recv_request_t *specific_recv, *wild_recv; \
|
||||||
mca_ptl_sequence_t wild_recv_seq, specific_recv_seq; \
|
mca_pml_sequence_t wild_recv_seq, specific_recv_seq; \
|
||||||
int frag_tag, wild_recv_tag, specific_recv_tag; \
|
int frag_tag, wild_recv_tag, specific_recv_tag; \
|
||||||
\
|
\
|
||||||
/* initialization */ \
|
/* initialization */ \
|
||||||
|
@ -72,8 +72,7 @@ extern "C" {
|
|||||||
* PML component types
|
* PML component types
|
||||||
*/
|
*/
|
||||||
|
|
||||||
struct mca_ptl_base_modulet;
|
typedef uint64_t mca_pml_sequence_t;
|
||||||
struct mca_ptl_addr_t;
|
|
||||||
|
|
||||||
struct mca_pml_proc_t {
|
struct mca_pml_proc_t {
|
||||||
opal_list_item_t super;
|
opal_list_item_t super;
|
||||||
@ -177,7 +176,7 @@ typedef int (*mca_pml_base_module_enable_fn_t)(
|
|||||||
|
|
||||||
/**
|
/**
|
||||||
* For non-threaded case, provides MCA the opportunity to
|
* For non-threaded case, provides MCA the opportunity to
|
||||||
* progress outstanding requests on all ptls.
|
* progress outstanding requests on all btls.
|
||||||
*
|
*
|
||||||
* @return OMPI_SUCCESS or failure status.
|
* @return OMPI_SUCCESS or failure status.
|
||||||
*/
|
*/
|
||||||
|
@ -56,8 +56,6 @@
|
|||||||
#include "ompi/mca/bml/base/base.h"
|
#include "ompi/mca/bml/base/base.h"
|
||||||
#include "ompi/mca/rcache/rcache.h"
|
#include "ompi/mca/rcache/rcache.h"
|
||||||
#include "ompi/mca/rcache/base/base.h"
|
#include "ompi/mca/rcache/base/base.h"
|
||||||
#include "ompi/mca/ptl/ptl.h"
|
|
||||||
#include "ompi/mca/ptl/base/base.h"
|
|
||||||
#include "ompi/mca/btl/btl.h"
|
#include "ompi/mca/btl/btl.h"
|
||||||
#include "ompi/mca/btl/base/base.h"
|
#include "ompi/mca/btl/base/base.h"
|
||||||
#include "ompi/mca/topo/topo.h"
|
#include "ompi/mca/topo/topo.h"
|
||||||
@ -248,11 +246,6 @@ void ompi_info::open_components()
|
|||||||
ompi_osc_base_open();
|
ompi_osc_base_open();
|
||||||
component_map["osc"] = &ompi_osc_base_open_components;
|
component_map["osc"] = &ompi_osc_base_open_components;
|
||||||
|
|
||||||
/* mca_ptl_base_open() should not be called directly. This call is performed
|
|
||||||
* in the PML base open.
|
|
||||||
*/
|
|
||||||
component_map["ptl"] = &mca_ptl_base_components_opened;
|
|
||||||
|
|
||||||
mca_btl_base_open();
|
mca_btl_base_open();
|
||||||
component_map["btl"] = &mca_btl_base_components_opened;
|
component_map["btl"] = &mca_btl_base_components_opened;
|
||||||
|
|
||||||
|
@ -180,7 +180,6 @@ int main(int argc, char *argv[])
|
|||||||
ompi_info::mca_types.push_back("pml");
|
ompi_info::mca_types.push_back("pml");
|
||||||
ompi_info::mca_types.push_back("bml");
|
ompi_info::mca_types.push_back("bml");
|
||||||
ompi_info::mca_types.push_back("rcache");
|
ompi_info::mca_types.push_back("rcache");
|
||||||
ompi_info::mca_types.push_back("ptl");
|
|
||||||
ompi_info::mca_types.push_back("btl");
|
ompi_info::mca_types.push_back("btl");
|
||||||
ompi_info::mca_types.push_back("topo");
|
ompi_info::mca_types.push_back("topo");
|
||||||
ompi_info::mca_types.push_back("osc");
|
ompi_info::mca_types.push_back("osc");
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user