1
1

Merge pull request #1963 from rhc54/topic/pmixfix

Fix shared memory rendezvous
Этот коммит содержится в:
rhc54 2016-08-13 09:59:14 -07:00 коммит произвёл GitHub
родитель ddde154d28 08a0644df5
Коммит d12e50b2d6
2 изменённых файлов: 4 добавлений и 4 удалений

Просмотреть файл

@ -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 */