OpenMPI
0.1.1
|
#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 |
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.
ORTE_SUCCESS | Receive successfully started |
ORTE_ERROR | An 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().
ORTE_SUCCESS | Receive succesffully cancelled. |
References orte_rml, and orte_rml_module_t::recv_cancel.