Коммит
36457cbce6
@ -413,7 +413,8 @@ static int rank_by(orte_job_t *jdata,
|
|||||||
return ORTE_ERROR;
|
return ORTE_ERROR;
|
||||||
}
|
}
|
||||||
/* ignore procs not on this object */
|
/* ignore procs not on this object */
|
||||||
if (!hwloc_bitmap_intersects(obj->cpuset, locale->cpuset)) {
|
if (NULL == locale ||
|
||||||
|
!hwloc_bitmap_intersects(obj->cpuset, locale->cpuset)) {
|
||||||
opal_output_verbose(5, orte_rmaps_base_framework.framework_output,
|
opal_output_verbose(5, orte_rmaps_base_framework.framework_output,
|
||||||
"mca:rmaps:rank_by: proc at position %d is not on object %d",
|
"mca:rmaps:rank_by: proc at position %d is not on object %d",
|
||||||
j, i);
|
j, i);
|
||||||
|
@ -663,24 +663,32 @@ void orte_daemon_recv(int status, orte_process_name_t* sender,
|
|||||||
ORTE_ERROR_LOG(ret);
|
ORTE_ERROR_LOG(ret);
|
||||||
free(cmpdata);
|
free(cmpdata);
|
||||||
OBJ_DESTRUCT(&data);
|
OBJ_DESTRUCT(&data);
|
||||||
|
OBJ_RELEASE(answer);
|
||||||
|
goto CLEANUP;
|
||||||
}
|
}
|
||||||
/* pack the compressed length */
|
/* pack the compressed length */
|
||||||
if (ORTE_SUCCESS != (ret = opal_dss.pack(answer, &cmplen, 1, OPAL_SIZE))) {
|
if (ORTE_SUCCESS != (ret = opal_dss.pack(answer, &cmplen, 1, OPAL_SIZE))) {
|
||||||
ORTE_ERROR_LOG(ret);
|
ORTE_ERROR_LOG(ret);
|
||||||
free(cmpdata);
|
free(cmpdata);
|
||||||
OBJ_DESTRUCT(&data);
|
OBJ_DESTRUCT(&data);
|
||||||
|
OBJ_RELEASE(answer);
|
||||||
|
goto CLEANUP;
|
||||||
}
|
}
|
||||||
/* pack the uncompressed length */
|
/* pack the uncompressed length */
|
||||||
if (ORTE_SUCCESS != (ret = opal_dss.pack(answer, &data.bytes_used, 1, OPAL_SIZE))) {
|
if (ORTE_SUCCESS != (ret = opal_dss.pack(answer, &data.bytes_used, 1, OPAL_SIZE))) {
|
||||||
ORTE_ERROR_LOG(ret);
|
ORTE_ERROR_LOG(ret);
|
||||||
free(cmpdata);
|
free(cmpdata);
|
||||||
OBJ_DESTRUCT(&data);
|
OBJ_DESTRUCT(&data);
|
||||||
|
OBJ_RELEASE(answer);
|
||||||
|
goto CLEANUP;
|
||||||
}
|
}
|
||||||
/* pack the compressed info */
|
/* pack the compressed info */
|
||||||
if (ORTE_SUCCESS != (ret = opal_dss.pack(answer, cmpdata, cmplen, OPAL_UINT8))) {
|
if (ORTE_SUCCESS != (ret = opal_dss.pack(answer, cmpdata, cmplen, OPAL_UINT8))) {
|
||||||
ORTE_ERROR_LOG(ret);
|
ORTE_ERROR_LOG(ret);
|
||||||
free(cmpdata);
|
free(cmpdata);
|
||||||
OBJ_DESTRUCT(&data);
|
OBJ_DESTRUCT(&data);
|
||||||
|
OBJ_RELEASE(answer);
|
||||||
|
goto CLEANUP;
|
||||||
}
|
}
|
||||||
OBJ_DESTRUCT(&data);
|
OBJ_DESTRUCT(&data);
|
||||||
free(cmpdata);
|
free(cmpdata);
|
||||||
@ -691,6 +699,8 @@ void orte_daemon_recv(int status, orte_process_name_t* sender,
|
|||||||
ORTE_ERROR_LOG(ret);
|
ORTE_ERROR_LOG(ret);
|
||||||
OBJ_DESTRUCT(&data);
|
OBJ_DESTRUCT(&data);
|
||||||
free(cmpdata);
|
free(cmpdata);
|
||||||
|
OBJ_RELEASE(answer);
|
||||||
|
goto CLEANUP;
|
||||||
}
|
}
|
||||||
/* transfer the payload across */
|
/* transfer the payload across */
|
||||||
opal_dss.copy_payload(answer, &data);
|
opal_dss.copy_payload(answer, &data);
|
||||||
|
@ -1285,10 +1285,12 @@ int orte_util_nidmap_generate_ppn(orte_job_t *jdata, char **ppn)
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
OPAL_LIST_DESTRUCT(&prk[n]); // releases all the actives objects
|
OPAL_LIST_DESTRUCT(&prk[n]); // releases all the actives objects
|
||||||
|
if (NULL != ptmp) {
|
||||||
opal_argv_append_nosize(&cache, ptmp);
|
opal_argv_append_nosize(&cache, ptmp);
|
||||||
free(ptmp);
|
free(ptmp);
|
||||||
ptmp = NULL;
|
ptmp = NULL;
|
||||||
}
|
}
|
||||||
|
}
|
||||||
free(prk);
|
free(prk);
|
||||||
free(cnt);
|
free(cnt);
|
||||||
free(actives);
|
free(actives);
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user