* disconnect if an error occurs after we connected
This commit was SVN r6940.
Этот коммит содержится в:
родитель
e737bba753
Коммит
0a07341c40
@ -98,6 +98,7 @@ pls_tm_launch(orte_jobid_t jobid)
|
|||||||
int argc;
|
int argc;
|
||||||
int rc;
|
int rc;
|
||||||
int id;
|
int id;
|
||||||
|
bool connected = false;
|
||||||
|
|
||||||
/* query the list of nodes allocated to the job - don't need the entire
|
/* query the list of nodes allocated to the job - don't need the entire
|
||||||
* mapping - as the daemon/proxy is responsibe for determining the apps
|
* mapping - as the daemon/proxy is responsibe for determining the apps
|
||||||
@ -218,6 +219,7 @@ pls_tm_launch(orte_jobid_t jobid)
|
|||||||
if (ORTE_SUCCESS != rc) {
|
if (ORTE_SUCCESS != rc) {
|
||||||
goto cleanup;
|
goto cleanup;
|
||||||
}
|
}
|
||||||
|
connected = true;
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* Iterate through each of the nodes and spin
|
* Iterate through each of the nodes and spin
|
||||||
@ -307,9 +309,12 @@ pls_tm_launch(orte_jobid_t jobid)
|
|||||||
free(name);
|
free(name);
|
||||||
}
|
}
|
||||||
|
|
||||||
rc = pls_tm_disconnect();
|
|
||||||
|
|
||||||
cleanup:
|
cleanup:
|
||||||
|
if (connected) {
|
||||||
|
rc = pls_tm_disconnect();
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
while (NULL != (item = opal_list_remove_first(&nodes))) {
|
while (NULL != (item = opal_list_remove_first(&nodes))) {
|
||||||
OBJ_RELEASE(item);
|
OBJ_RELEASE(item);
|
||||||
}
|
}
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user