OpenMPI  0.1.1
rml_base_receive.c File Reference
#include "orte_config.h"
#include "orte/constants.h"
#include "orte/types.h"
#include "opal/dss/dss.h"
#include "opal/util/output.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/runtime/orte_globals.h"
#include "orte/runtime/orte_wait.h"
#include "orte/util/name_fns.h"
#include "orte/mca/rml/rml.h"
#include "orte/mca/rml/base/base.h"
#include "orte/mca/rml/base/rml_contact.h"

Functions

static void orte_rml_base_recv (int status, orte_process_name_t *sender, opal_buffer_t *buffer, orte_rml_tag_t tag, void *cbdata)
 
int orte_rml_base_comm_start (void)
 Post receive to get updates regarding contact information. More...
 
int orte_rml_base_comm_stop (void)
 Stop receiving contact information updates. More...
 
static void process_message (int fd, short event, void *data)
 

Variables

static bool recv_issued =false
 

Function Documentation

int orte_rml_base_comm_start ( void  )

Post receive to get updates regarding contact information.

Post a non-blocking receive (likely during orte_init()) to receive updated contact information from the HNP when it becomes available. This should be called in any process that needs such updates, and the receive will continue to get update callbacks until orte_rml_base_comm_stop() is called.

Return values
ORTE_SUCCESSReceive successfully started
ORTE_ERRORAn unknown error occurred

References orte_rml, ORTE_RML_NON_PERSISTENT, and orte_rml_module_t::recv_buffer_nb.

int orte_rml_base_comm_stop ( void  )

Stop receiving contact information updates.

Shut down the receive posted during orte_rml_base_comm_start(), likely during orte_finalize().

Return values
ORTE_SUCCESSReceive succesffully cancelled.

References orte_rml, and orte_rml_module_t::recv_cancel.