780c93ee57
We recognize that this means other users of OPAL will need to "wrap" the opal_process_name_t if they desire to abstract it in some fashion. This is regrettable, and we are looking at possible alternatives that might mitigate that requirement. Meantime, however, we have to put the needs of the OMPI community first, and are taking this step to restore hetero and SPARC support.
85 строки
2.7 KiB
C
85 строки
2.7 KiB
C
/*
|
|
* Copyright (c) 2004-2010 The Trustees of Indiana University and Indiana
|
|
* University Research and Technology
|
|
* Corporation. All rights reserved.
|
|
* Copyright (c) 2004-2006 The University of Tennessee and The University
|
|
* of Tennessee Research Foundation. All rights
|
|
* reserved.
|
|
* Copyright (c) 2004-2005 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 (c) 2007 Cisco Systems, Inc. All rights reserved.
|
|
* Copyright (c) 2012 Los Alamos National Security, LLC.
|
|
* All rights reserved.
|
|
* Copyright (c) 2014 Research Organization for Information Science
|
|
* and Technology (RIST). All rights reserved.
|
|
* $COPYRIGHT$
|
|
*
|
|
* Additional copyrights may follow
|
|
*
|
|
* $HEADER$
|
|
*/
|
|
|
|
#include "orte_config.h"
|
|
|
|
#include "rml_oob.h"
|
|
|
|
#include "opal/class/opal_list.h"
|
|
|
|
struct orte_rml_oob_exception_t {
|
|
opal_list_item_t super;
|
|
orte_rml_exception_callback_t cbfunc;
|
|
};
|
|
typedef struct orte_rml_oob_exception_t orte_rml_oob_exception_t;
|
|
static OBJ_CLASS_INSTANCE(orte_rml_oob_exception_t, opal_list_item_t,
|
|
NULL, NULL);
|
|
|
|
|
|
void
|
|
orte_rml_oob_exception_callback(orte_process_name_t *peer,
|
|
orte_rml_exception_t exception)
|
|
{
|
|
opal_list_item_t *item;
|
|
|
|
for (item = opal_list_get_first(&orte_rml_oob_module.exceptions) ;
|
|
item != opal_list_get_end(&orte_rml_oob_module.exceptions) ;
|
|
item = opal_list_get_next(item)) {
|
|
orte_rml_oob_exception_t *ex = (orte_rml_oob_exception_t*) item;
|
|
ex->cbfunc(peer, exception);
|
|
}
|
|
}
|
|
|
|
|
|
int
|
|
orte_rml_oob_add_exception(orte_rml_exception_callback_t cbfunc)
|
|
{
|
|
orte_rml_oob_exception_t *ex = OBJ_NEW(orte_rml_oob_exception_t);
|
|
|
|
if (NULL == ex) return ORTE_ERROR;
|
|
|
|
ex->cbfunc = cbfunc;
|
|
opal_list_append(&orte_rml_oob_module.exceptions, &ex->super);
|
|
|
|
return ORTE_SUCCESS;
|
|
}
|
|
|
|
|
|
int
|
|
orte_rml_oob_del_exception(orte_rml_exception_callback_t cbfunc)
|
|
{
|
|
opal_list_item_t *item;
|
|
|
|
for (item = opal_list_get_first(&orte_rml_oob_module.exceptions) ;
|
|
item != opal_list_get_end(&orte_rml_oob_module.exceptions) ;
|
|
item = opal_list_get_next(item)) {
|
|
orte_rml_oob_exception_t *ex = (orte_rml_oob_exception_t*) item;
|
|
|
|
if (cbfunc == ex->cbfunc) {
|
|
opal_list_remove_item(&orte_rml_oob_module.exceptions, item);
|
|
return ORTE_SUCCESS;
|
|
}
|
|
}
|
|
return ORTE_ERR_NOT_FOUND;
|
|
}
|