8f119d9063
Fix for memory corruption in the restarted process stack. This stemed from the brute force method we were previously using. This commit fixes this by using a lighter weight solution focused in the r2 BML instead of above the PML. This is a more efficient and flexible solution, and it solves the original problem. In the process I pulled out the ft_event function in the tcp BTL and r2 BML into a set of *_ft.[c|h] files just to keep any updates to these code paths as isolated as possible to make merging easier on everyone. This commit was SVN r14371. The following SVN revision numbers were found above: r2 --> open-mpi/ompi@58fdc18855 The following Trac tickets were found above: Ticket 977 --> https://svn.open-mpi.org/trac/ompi/ticket/977
216 строки
10 KiB
C
216 строки
10 KiB
C
/*
|
|
* Copyright (c) 2004-2007 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.
|
|
* 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$
|
|
*
|
|
* Additional copyrights may follow
|
|
*
|
|
* $HEADER$
|
|
*/
|
|
#ifndef OMPI_CRCP_BASE_H
|
|
#define OMPI_CRCP_BASE_H
|
|
|
|
#include "ompi_config.h"
|
|
|
|
#include "ompi/constants.h"
|
|
#include "orte/mca/rml/rml.h"
|
|
#include "orte/dss/dss.h"
|
|
|
|
#include "ompi/mca/crcp/crcp.h"
|
|
|
|
/*
|
|
* Global functions for MCA overall CRCP
|
|
*/
|
|
|
|
#if defined(c_plusplus) || defined(__cplusplus)
|
|
extern "C" {
|
|
#endif
|
|
|
|
/**
|
|
* Initialize the CRCP MCA framework
|
|
*
|
|
* @retval OMPI_SUCCESS Upon success
|
|
* @retval OMPI_ERROR Upon failures
|
|
*
|
|
* This function is invoked during ompi_init();
|
|
*/
|
|
OMPI_DECLSPEC int ompi_crcp_base_open(void);
|
|
|
|
/**
|
|
* Select an available component.
|
|
*
|
|
* @retval OMPI_SUCCESS Upon Success
|
|
* @retval OMPI_NOT_FOUND If no component can be selected
|
|
* @retval OMPI_ERROR Upon other failure
|
|
*
|
|
*/
|
|
OMPI_DECLSPEC int ompi_crcp_base_select(void);
|
|
|
|
/**
|
|
* Finalize the CRCP MCA framework
|
|
*
|
|
* @retval OMPI_SUCCESS Upon success
|
|
* @retval OMPI_ERROR Upon failures
|
|
*
|
|
* This function is invoked during ompi_finalize();
|
|
*/
|
|
OMPI_DECLSPEC int ompi_crcp_base_close(void);
|
|
|
|
/**
|
|
* 'None' component functions
|
|
* These are to be used when no component is selected.
|
|
* They just return success, and empty strings as necessary.
|
|
*/
|
|
int ompi_crcp_base_none_open(void);
|
|
int ompi_crcp_base_none_close(void);
|
|
|
|
int ompi_crcp_base_module_init(void);
|
|
int ompi_crcp_base_module_finalize(void);
|
|
|
|
/* PML Interface */
|
|
ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_enable( bool enable, ompi_crcp_base_pml_state_t* );
|
|
|
|
ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_add_comm( struct ompi_communicator_t* comm, ompi_crcp_base_pml_state_t* );
|
|
ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_del_comm( struct ompi_communicator_t* comm, ompi_crcp_base_pml_state_t* );
|
|
|
|
ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_add_procs( struct ompi_proc_t **procs, size_t nprocs, ompi_crcp_base_pml_state_t* );
|
|
ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_del_procs( struct ompi_proc_t **procs, size_t nprocs, ompi_crcp_base_pml_state_t* );
|
|
|
|
ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_progress(ompi_crcp_base_pml_state_t*);
|
|
|
|
ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_iprobe(int dst, int tag, struct ompi_communicator_t* comm, int *matched, ompi_status_public_t* status, ompi_crcp_base_pml_state_t* );
|
|
|
|
ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_probe( int dst, int tag, struct ompi_communicator_t* comm, ompi_status_public_t* status, ompi_crcp_base_pml_state_t* );
|
|
|
|
ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_isend_init( void *buf, size_t count, ompi_datatype_t *datatype, int dst, int tag,
|
|
mca_pml_base_send_mode_t mode, struct ompi_communicator_t* comm, struct ompi_request_t **request, ompi_crcp_base_pml_state_t* );
|
|
|
|
ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_isend( void *buf, size_t count, ompi_datatype_t *datatype, int dst, int tag,
|
|
mca_pml_base_send_mode_t mode, struct ompi_communicator_t* comm, struct ompi_request_t **request, ompi_crcp_base_pml_state_t* );
|
|
|
|
ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_send( void *buf, size_t count, ompi_datatype_t *datatype, int dst, int tag,
|
|
mca_pml_base_send_mode_t mode, struct ompi_communicator_t* comm, ompi_crcp_base_pml_state_t* );
|
|
|
|
ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_irecv_init( void *buf, size_t count, ompi_datatype_t *datatype, int src, int tag,
|
|
struct ompi_communicator_t* comm, struct ompi_request_t **request, ompi_crcp_base_pml_state_t*);
|
|
|
|
ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_irecv( void *buf, size_t count, ompi_datatype_t *datatype, int src, int tag,
|
|
struct ompi_communicator_t* comm, struct ompi_request_t **request, ompi_crcp_base_pml_state_t* );
|
|
|
|
ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_recv( void *buf, size_t count, ompi_datatype_t *datatype, int src, int tag,
|
|
struct ompi_communicator_t* comm, ompi_status_public_t* status, ompi_crcp_base_pml_state_t*);
|
|
|
|
ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_dump( struct ompi_communicator_t* comm, int verbose, ompi_crcp_base_pml_state_t* );
|
|
|
|
ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_start( size_t count, ompi_request_t** requests, ompi_crcp_base_pml_state_t* );
|
|
|
|
ompi_crcp_base_pml_state_t* ompi_crcp_base_none_pml_ft_event(int state, ompi_crcp_base_pml_state_t*);
|
|
|
|
/* Request Interface */
|
|
int ompi_crcp_base_none_request_complete( struct ompi_request_t *request );
|
|
|
|
/* BTL Interface */
|
|
ompi_crcp_base_btl_state_t*
|
|
ompi_crcp_base_none_btl_add_procs( struct mca_btl_base_module_t* btl,
|
|
size_t nprocs,
|
|
struct ompi_proc_t** procs,
|
|
struct mca_btl_base_endpoint_t** endpoints,
|
|
struct ompi_bitmap_t* reachable,
|
|
ompi_crcp_base_btl_state_t* );
|
|
|
|
ompi_crcp_base_btl_state_t*
|
|
ompi_crcp_base_none_btl_del_procs( struct mca_btl_base_module_t* btl,
|
|
size_t nprocs,
|
|
struct ompi_proc_t** procs,
|
|
struct mca_btl_base_endpoint_t**,
|
|
ompi_crcp_base_btl_state_t*);
|
|
|
|
ompi_crcp_base_btl_state_t*
|
|
ompi_crcp_base_none_btl_register( struct mca_btl_base_module_t* btl,
|
|
mca_btl_base_tag_t tag,
|
|
mca_btl_base_module_recv_cb_fn_t cbfunc,
|
|
void* cbdata,
|
|
ompi_crcp_base_btl_state_t*);
|
|
|
|
ompi_crcp_base_btl_state_t*
|
|
ompi_crcp_base_none_btl_finalize( struct mca_btl_base_module_t* btl,
|
|
ompi_crcp_base_btl_state_t*);
|
|
|
|
ompi_crcp_base_btl_state_t*
|
|
ompi_crcp_base_none_btl_alloc( struct mca_btl_base_module_t* btl,
|
|
size_t size,
|
|
ompi_crcp_base_btl_state_t*);
|
|
|
|
ompi_crcp_base_btl_state_t*
|
|
ompi_crcp_base_none_btl_free( struct mca_btl_base_module_t* btl,
|
|
mca_btl_base_descriptor_t* descriptor,
|
|
ompi_crcp_base_btl_state_t*);
|
|
|
|
ompi_crcp_base_btl_state_t*
|
|
ompi_crcp_base_none_btl_prepare_src( struct mca_btl_base_module_t* btl,
|
|
struct mca_btl_base_endpoint_t* endpoint,
|
|
mca_mpool_base_registration_t* registration,
|
|
struct ompi_convertor_t* convertor,
|
|
size_t reserve,
|
|
size_t* size,
|
|
ompi_crcp_base_btl_state_t*);
|
|
|
|
ompi_crcp_base_btl_state_t*
|
|
ompi_crcp_base_none_btl_prepare_dst( struct mca_btl_base_module_t* btl,
|
|
struct mca_btl_base_endpoint_t* endpoint,
|
|
mca_mpool_base_registration_t* registration,
|
|
struct ompi_convertor_t* convertor,
|
|
size_t reserve,
|
|
size_t* size,
|
|
ompi_crcp_base_btl_state_t*);
|
|
|
|
ompi_crcp_base_btl_state_t*
|
|
ompi_crcp_base_none_btl_send( struct mca_btl_base_module_t* btl,
|
|
struct mca_btl_base_endpoint_t* endpoint,
|
|
struct mca_btl_base_descriptor_t* descriptor,
|
|
mca_btl_base_tag_t tag,
|
|
ompi_crcp_base_btl_state_t*);
|
|
|
|
ompi_crcp_base_btl_state_t*
|
|
ompi_crcp_base_none_btl_put( struct mca_btl_base_module_t* btl,
|
|
struct mca_btl_base_endpoint_t* endpoint,
|
|
struct mca_btl_base_descriptor_t* descriptor,
|
|
ompi_crcp_base_btl_state_t*);
|
|
|
|
ompi_crcp_base_btl_state_t*
|
|
ompi_crcp_base_none_btl_get( struct mca_btl_base_module_t* btl,
|
|
struct mca_btl_base_endpoint_t* endpoint,
|
|
struct mca_btl_base_descriptor_t* descriptor,
|
|
ompi_crcp_base_btl_state_t*);
|
|
|
|
ompi_crcp_base_btl_state_t*
|
|
ompi_crcp_base_none_btl_dump( struct mca_btl_base_module_t* btl,
|
|
struct mca_btl_base_endpoint_t* endpoint,
|
|
int verbose,
|
|
ompi_crcp_base_btl_state_t*);
|
|
|
|
ompi_crcp_base_btl_state_t*
|
|
ompi_crcp_base_none_btl_ft_event(int state,
|
|
ompi_crcp_base_btl_state_t*);
|
|
|
|
/* Utility Functions */
|
|
|
|
OMPI_DECLSPEC extern int ompi_crcp_base_output;
|
|
OMPI_DECLSPEC extern opal_list_t ompi_crcp_base_components_available;
|
|
OMPI_DECLSPEC extern ompi_crcp_base_component_t ompi_crcp_base_selected_component;
|
|
OMPI_DECLSPEC extern ompi_crcp_base_module_t ompi_crcp;
|
|
|
|
#if defined(c_plusplus) || defined(__cplusplus)
|
|
}
|
|
#endif
|
|
|
|
#endif /* OMPI_CRCP_BASE_H */
|