30 #ifndef ORTE_MCA_RML_RML_H_
31 #define ORTE_MCA_RML_RML_H_
33 #include "orte_config.h"
42 #include "opal/mca/crs/base/base.h"
168 orte_rml_exception_t exception);
229 typedef char* (*orte_rml_module_get_contact_info_fn_t)(void);
272 const struct timeval* tv);
633 #define ORTE_RML_BASE_VERSION_2_0_0 \
634 MCA_BASE_VERSION_2_0_0, \
RML module interface.
Definition: rml.h:577
RML component interface.
Definition: rml.h:89
orte_rml_module_finalize_fn_t finalize
Shutdown the communication system and clean up resources.
Definition: rml.h:581
orte_rml_module_set_contact_info_fn_t set_contact_info
Set contact information for remote process.
Definition: rml.h:586
orte_rml_module_send_nb_fn_t send_nb
Send blocking buffer message.
Definition: rml.h:594
Common type for all MCA components.
Definition: mca.h:250
ORTE_DECLSPEC orte_rml_module_t orte_rml
Interface for RML communication.
Definition: rml_base_components.c:37
orte_rml_module_recv_buffer_fn_t recv_buffer
Receive non-blocking iovec message.
Definition: rml.h:605
int(* orte_rml_module_ft_event_fn_t)(int state)
Handle fault tolerance updates.
Definition: rml.h:558
struct orte_rml_module_t *(* orte_rml_component_init_fn_t)(int *priority)
RML component initialization.
Definition: rml.h:79
int(* orte_rml_module_set_contact_info_fn_t)(const char *contact_info)
Update the RML with a remote process's contact info.
Definition: rml.h:252
int(* orte_rml_module_ping_fn_t)(const char *contact_info, const struct timeval *tv)
"Ping" another process to determine availability
Definition: rml.h:271
orte_rml_module_exception_fn_t add_exception_handler
Add callback for communication exception.
Definition: rml.h:612
int(* orte_rml_module_enable_comm_fn_t)(void)
Enable communication using the RML module.
Definition: rml.h:193
Top-level interface for all MCA components.
int(* orte_rml_module_send_nb_fn_t)(struct orte_process_name_t *peer, struct iovec *msg, int count, orte_rml_tag_t tag, int flags, orte_rml_callback_fn_t cbfunc, void *cbdata)
Send an iovec non-blocking message.
Definition: rml.h:351
void(* orte_rml_callback_fn_t)(int status, struct orte_process_name_t *peer, struct iovec *msg, int count, orte_rml_tag_t tag, void *cbdata)
Funtion prototype for callback from non-blocking iovec send and receive.
Definition: rml.h:123
orte_rml_module_ft_event_fn_t ft_event
Fault tolerance handler.
Definition: rml.h:617
int(* orte_rml_module_send_buffer_fn_t)(struct orte_process_name_t *peer, struct opal_buffer_t *buffer, orte_rml_tag_t tag, int flags)
Send a buffer blocking message.
Definition: rml.h:321
int(* orte_rml_module_send_fn_t)(struct orte_process_name_t *peer, struct iovec *msg, int count, int tag, int flags)
Send an iovec blocking message.
Definition: rml.h:295
int(* orte_rml_module_recv_buffer_nb_fn_t)(struct orte_process_name_t *peer, orte_rml_tag_t tag, int flags, orte_rml_buffer_callback_fn_t cbfunc, void *cbdata)
Receive a buffer non-blocking message.
Definition: rml.h:509
int(* orte_rml_module_purge_fn_t)(struct orte_process_name_t *peer)
Purge the RML/OOB of contact info and pending messages to/from a specified process.
Definition: rml.h:565
orte_rml_module_purge_fn_t purge
Purge information.
Definition: rml.h:620
int(* orte_rml_module_exception_fn_t)(orte_rml_exception_callback_t cbfunc)
Register or deregister an exception callback function.
Definition: rml.h:545
Definition: ompi_uio.h:29
orte_rml_module_recv_fn_t recv
Receive blocking iovec message.
Definition: rml.h:601
orte_rml_module_exception_fn_t del_exception_handler
Delete callback for communication exception.
Definition: rml.h:614
Meta data for MCA v2.0.0 components.
Definition: mca.h:309
orte_rml_module_recv_buffer_nb_fn_t recv_buffer_nb
Receive non-blocking buffer message.
Definition: rml.h:607
uint32_t orte_rml_tag_t
Message matching tag.
Definition: rml_types.h:220
int(* orte_rml_module_recv_nb_fn_t)(struct orte_process_name_t *peer, struct iovec *msg, int count, orte_rml_tag_t tag, int flags, orte_rml_callback_fn_t cbfunc, void *cbdata)
Receive an iovec non-blocking message.
Definition: rml.h:475
int(* orte_rml_module_finalize_fn_t)(void)
Finalize the RML module.
Definition: rml.h:210
orte_rml_module_recv_nb_fn_t recv_nb
Receive blocking buffer message.
Definition: rml.h:603
orte_rml_module_send_fn_t send
Send blocking iovec message.
Definition: rml.h:592
int(* orte_rml_module_recv_fn_t)(struct orte_process_name_t *peer, struct iovec *msg, int count, orte_rml_tag_t tag, int flags)
Receive an iovec blocking message.
Definition: rml.h:414
int(* orte_rml_module_send_buffer_nb_fn_t)(struct orte_process_name_t *peer, struct opal_buffer_t *buffer, orte_rml_tag_t tag, int flags, orte_rml_buffer_callback_fn_t cbfunc, void *cbdata)
Send an buffer non-blocking message.
Definition: rml.h:383
void(* orte_rml_buffer_callback_fn_t)(int status, struct orte_process_name_t *peer, struct opal_buffer_t *buffer, orte_rml_tag_t tag, void *cbdata)
Funtion prototype for callback from non-blocking buffer send and receive.
Definition: rml.h:149
Structure for holding a buffer to be used with the RML or OOB subsystems.
Definition: dss_types.h:159
int(* orte_rml_module_recv_buffer_fn_t)(struct orte_process_name_t *peer, struct opal_buffer_t *buf, orte_rml_tag_t tag, int flags)
Receive a buffer blocking message.
Definition: rml.h:442
orte_rml_module_ping_fn_t ping
Ping process for connectivity check.
Definition: rml.h:589
orte_rml_module_get_contact_info_fn_t get_contact_info
Get contact information for local process.
Definition: rml.h:584
Checkpoint and Restart Service (CRS) Interface.
orte_rml_module_send_buffer_fn_t send_buffer
Send non-blocking iovec message.
Definition: rml.h:596
void(* orte_rml_exception_callback_t)(const orte_process_name_t *peer, orte_rml_exception_t exception)
Function prototype for exception callback.
Definition: rml.h:167
orte_rml_module_send_buffer_nb_fn_t send_buffer_nb
Send non-blocking buffer message.
Definition: rml.h:598
orte_rml_module_recv_cancel_fn_t recv_cancel
Cancel posted non-blocking receive.
Definition: rml.h:609
orte_rml_module_enable_comm_fn_t enable_comm
Enable communication once a process name has been assigned.
Definition: rml.h:579
Contains the typedefs for the use of the rml.
int(* orte_rml_module_recv_cancel_fn_t)(orte_process_name_t *peer, orte_rml_tag_t tag)
Cancel a posted non-blocking receive.
Definition: rml.h:530
char *(* orte_rml_module_get_contact_info_fn_t)(void)
Get a "contact info" string for the local process.
Definition: rml.h:229