1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
|
/*
* Copyright (c) 2011 Cisco Systems, Inc. All rights reserved.
* $COPYRIGHT$
*
* Additional copyrights may follow
*
* $HEADER$
*/
#include "ompi_config.h"
#include "ompi/constants.h"
#include <pmi.h>
#if WANT_CRAY_PMI2_EXT
#include <pmi2.h>
#endif
#include "orte/util/proc_info.h"
#include "orte/util/name_fns.h"
#include "pubsub_pmi.h"
static int pubsub_pmi_component_open(void);
static int pubsub_pmi_component_close(void);
static int pubsub_pmi_component_query(mca_base_module_t **module, int *priority);
static int my_priority = 100; /* must be above "orte" component */
static bool started_by_me=false;
ompi_pubsub_base_component_t mca_pubsub_pmi_component = {
{
OMPI_PUBSUB_BASE_VERSION_2_0_0,
"pmi", /* MCA component name */
OMPI_MAJOR_VERSION, /* MCA component major version */
OMPI_MINOR_VERSION, /* MCA component minor version */
OMPI_RELEASE_VERSION, /* MCA component release version */
pubsub_pmi_component_open, /* component open */
pubsub_pmi_component_close, /* component close */
pubsub_pmi_component_query /* component query */
},
{
/* This component is checkpoint ready */
MCA_BASE_METADATA_PARAM_CHECKPOINT
}
};
static int pubsub_pmi_component_open(void)
{
mca_base_component_t *c = &mca_pubsub_pmi_component.base_version;
mca_base_param_reg_int(c, "priority",
"Priority of the pubsub pmi component",
false, false, my_priority,
&my_priority);
return OMPI_SUCCESS;
}
static int pubsub_pmi_component_close(void)
{
#if WANT_CRAY_PMI2_EXT
if (started_by_me && PMI2_Initialized()) {
PMI2_Finalize();
}
#else
PMI_BOOL initialized;
/* if we weren't selected, cleanup */
if (started_by_me && PMI_SUCCESS == PMI_Initialized(&initialized) &&
PMI_TRUE == initialized) {
PMI_Finalize();
}
#endif
return OMPI_SUCCESS;
}
static bool pmi_startup(void)
{
#if WANT_CRAY_PMI2_EXT
int spawned, size, rank, appnum;
if (PMI2_Initialized()) {
/* already initialized */
return true;
}
/* if we can't startup PMI, we can't be used */
if (PMI_SUCCESS != PMI2_Init(&spawned, &size, &rank, &appnum)) {
return false;
}
/* flag that we started PMI */
started_by_me = true;
/* ignore the info - we'll pick it up elsewhere */
return true;
#else
PMI_BOOL initialized;
if (PMI_SUCCESS != PMI_Initialized(&initialized)) {
return false;
}
if (PMI_TRUE != initialized) {
if (PMI_SUCCESS != PMI_Init(&initialized)) {
return false;
}
/* flag that we started PMI */
started_by_me = true;
}
return true;
#endif
}
static int pubsub_pmi_component_query(mca_base_module_t **module, int *priority)
{
/* for now, only use PMI when direct launched */
if (NULL == orte_process_info.my_hnp_uri &&
pmi_startup()) {
/* if PMI is available, use it */
*priority = my_priority;
*module = (mca_base_module_t *)&ompi_pubsub_pmi_module;
return ORTE_SUCCESS;
}
/* we can't run */
*priority = -1;
*module = NULL;
return OMPI_ERROR;
}
|
