Fix shared memory rendezvous
Этот коммит содержится в:
родитель
ddde154d28
Коммит
08a0644df5
@ -314,12 +314,12 @@ static int rte_init(void)
|
||||
}
|
||||
/* retrieve the local peers */
|
||||
OPAL_MODEX_RECV_VALUE(ret, OPAL_PMIX_LOCAL_PEERS,
|
||||
&wildcard_rank, &val, OPAL_STRING);
|
||||
ORTE_PROC_MY_NAME, &val, OPAL_STRING);
|
||||
if (OPAL_SUCCESS == ret && NULL != val) {
|
||||
peers = opal_argv_split(val, ',');
|
||||
free(val);
|
||||
/* and their cpusets, if available */
|
||||
OPAL_MODEX_RECV_VALUE_OPTIONAL(ret, OPAL_PMIX_LOCAL_CPUSETS, &wildcard_rank, &val, OPAL_STRING);
|
||||
OPAL_MODEX_RECV_VALUE_OPTIONAL(ret, OPAL_PMIX_LOCAL_CPUSETS, ORTE_PROC_MY_NAME, &val, OPAL_STRING);
|
||||
if (OPAL_SUCCESS == ret && NULL != val) {
|
||||
cpusets = opal_argv_split(val, ':');
|
||||
free(val);
|
||||
|
@ -340,14 +340,14 @@ int orte_pmix_server_register_nspace(orte_job_t *jdata)
|
||||
kv = OBJ_NEW(opal_value_t);
|
||||
kv->key = strdup(OPAL_PMIX_LOCAL_PEERS);
|
||||
kv->type = OPAL_STRING;
|
||||
kv->data.string = peerlist;
|
||||
kv->data.string = strdup(peerlist);
|
||||
opal_list_append(pmap, &kv->super);
|
||||
|
||||
/* pass the list of cpusets */
|
||||
kv = OBJ_NEW(opal_value_t);
|
||||
kv->key = strdup(OPAL_PMIX_LOCAL_CPUSETS);
|
||||
kv->type = OPAL_STRING;
|
||||
kv->data.string = cpulist;
|
||||
kv->data.string = strdup(cpulist);
|
||||
opal_list_append(pmap, &kv->super);
|
||||
|
||||
/* appnum */
|
||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user