|
OpenMPI
0.1.1
|
#include "orte_config.h"#include "opal/mca/mca.h"#include "opal/mca/base/mca_base_param.h"#include "opal/dss/dss.h"#include "opal/threads/threads.h"#include "orte/constants.h"#include "orte/types.h"#include "orte/util/proc_info.h"#include "orte/util/error_strings.h"#include "orte/mca/errmgr/errmgr.h"#include "orte/mca/ess/ess.h"#include "orte/mca/rml/rml.h"#include "orte/mca/rml/rml_types.h"#include "orte/mca/routed/routed.h"#include "orte/mca/ras/base/base.h"#include "orte/util/name_fns.h"#include "orte/runtime/orte_globals.h"#include "orte/runtime/orte_quit.h"#include "orte/mca/plm/plm_types.h"#include "orte/mca/plm/plm.h"#include "orte/mca/plm/base/plm_private.h"#include "orte/mca/plm/base/base.h"Functions | |
| static void | process_msg (int fd, short event, void *data) |
| int | orte_plm_base_comm_start (void) |
| int | orte_plm_base_comm_stop (void) |
| void | orte_plm_base_recv (int status, orte_process_name_t *sender, opal_buffer_t *buffer, orte_rml_tag_t tag, void *cbdata) |
| void | orte_plm_base_receive_process_msg (int fd, short event, void *data) |
Variables | |
| static bool | recv_issued =false |
| static opal_mutex_t | lock |
| static opal_condition_t | cond |
| static opal_list_t | recvs |
| static opal_event_t | ready |
| static int | ready_fd [2] |
| static bool | processing |