Only connect the first time thru the Torque launch, remove stale code
cmr:v1.7.3:reviewer=jsquyres This commit was SVN r29227.
Этот коммит содержится в:
родитель
63da76ad5f
Коммит
23c8848157
@ -295,11 +295,12 @@ static void launch_daemons(int fd, short args, void *cbdata)
|
|||||||
if (NULL != param) free(param);
|
if (NULL != param) free(param);
|
||||||
}
|
}
|
||||||
|
|
||||||
rc = plm_tm_connect();
|
if (!connected) {
|
||||||
if (ORTE_SUCCESS != rc) {
|
if (ORTE_SUCCESS != plm_tm_connect()) {
|
||||||
goto cleanup;
|
goto cleanup;
|
||||||
|
}
|
||||||
|
connected = true;
|
||||||
}
|
}
|
||||||
connected = true;
|
|
||||||
|
|
||||||
/* Figure out the basenames for the libdir and bindir. There is a
|
/* Figure out the basenames for the libdir and bindir. There is a
|
||||||
lengthy comment about this in plm_rsh_module.c explaining all
|
lengthy comment about this in plm_rsh_module.c explaining all
|
||||||
@ -543,6 +544,7 @@ static int plm_tm_connect(void)
|
|||||||
int ret;
|
int ret;
|
||||||
struct tm_roots tm_root;
|
struct tm_roots tm_root;
|
||||||
int count;
|
int count;
|
||||||
|
struct timespec tp = {0, 100};
|
||||||
|
|
||||||
/* try a couple times to connect - might get busy signals every
|
/* try a couple times to connect - might get busy signals every
|
||||||
now and then */
|
now and then */
|
||||||
@ -552,29 +554,14 @@ static int plm_tm_connect(void)
|
|||||||
return ORTE_SUCCESS;
|
return ORTE_SUCCESS;
|
||||||
}
|
}
|
||||||
|
|
||||||
#if ORTE_ENABLE_PROGRESS_THREADS
|
/* provide a very short quiet period so we
|
||||||
{
|
* don't hammer the cpu while we wait
|
||||||
/* provide a very short quiet period so we
|
*/
|
||||||
* don't hammer the cpu while we wait
|
nanosleep(&tp, NULL);
|
||||||
*/
|
|
||||||
struct timespec tp = {0, 100};
|
|
||||||
nanosleep(&tp, NULL);
|
|
||||||
#if HAVE_SCHED_YIELD
|
#if HAVE_SCHED_YIELD
|
||||||
sched_yield();
|
sched_yield();
|
||||||
#endif
|
|
||||||
}
|
|
||||||
#else
|
|
||||||
{
|
|
||||||
int progress;
|
|
||||||
for (progress = 0 ; progress < 10 ; ++progress) {
|
|
||||||
opal_progress();
|
|
||||||
#if HAVE_SCHED_YIELD
|
|
||||||
sched_yield();
|
|
||||||
#endif
|
|
||||||
}
|
|
||||||
}
|
|
||||||
#endif
|
#endif
|
||||||
}
|
}
|
||||||
|
|
||||||
return ORTE_ERR_RESOURCE_BUSY;
|
return ORTE_ERR_RESOURCE_BUSY;
|
||||||
}
|
}
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user