1
1

add the error handler registration to OB1..

This commit was SVN r11234.
Этот коммит содержится в:
Galen Shipman 2006-08-16 20:56:22 +00:00
родитель 74e95bc65f
Коммит e809a442e7
2 изменённых файлов: 22 добавлений и 6 удалений

Просмотреть файл

@ -110,11 +110,6 @@ int mca_pml_dr_del_comm(ompi_communicator_t* comm)
void mca_pml_dr_error_handler(
struct mca_btl_base_module_t* btl,
int32_t flags) {
orte_errmgr.abort();
}
/* /*
* For each proc setup a datastructure that indicates the PTLs * For each proc setup a datastructure that indicates the PTLs
@ -250,3 +245,8 @@ int mca_pml_dr_dump(
void mca_pml_dr_error_handler(
struct mca_btl_base_module_t* btl,
int32_t flags) {
orte_errmgr.abort();
}

Просмотреть файл

@ -35,6 +35,7 @@
#include "pml_ob1_recvreq.h" #include "pml_ob1_recvreq.h"
#include "pml_ob1_rdmafrag.h" #include "pml_ob1_rdmafrag.h"
#include "ompi/mca/bml/base/base.h" #include "ompi/mca/bml/base/base.h"
#include "orte/mca/errmgr/errmgr.h"
mca_pml_ob1_t mca_pml_ob1 = { mca_pml_ob1_t mca_pml_ob1 = {
{ {
@ -59,6 +60,11 @@ mca_pml_ob1_t mca_pml_ob1 = {
} }
}; };
void mca_pml_ob1_error_handler(
struct mca_btl_base_module_t* btl,
int32_t flags);
int mca_pml_ob1_enable(bool enable) int mca_pml_ob1_enable(bool enable)
{ {
if( false == enable ) return OMPI_SUCCESS; if( false == enable ) return OMPI_SUCCESS;
@ -145,6 +151,9 @@ int mca_pml_ob1_add_procs(ompi_proc_t** procs, size_t nprocs)
mca_pml_ob1_recv_frag_callback, mca_pml_ob1_recv_frag_callback,
NULL); NULL);
/* register error handlers */
rc = mca_bml.bml_register_error(mca_pml_ob1_error_handler);
/* initialize free list of receive buffers */ /* initialize free list of receive buffers */
ompi_free_list_init( ompi_free_list_init(
&mca_pml_ob1.buffers, &mca_pml_ob1.buffers,
@ -346,3 +355,10 @@ void mca_pml_ob1_process_pending_rdma(void)
break; break;
} }
} }
void mca_pml_ob1_error_handler(
struct mca_btl_base_module_t* btl,
int32_t flags) {
orte_errmgr.abort();
}