Create the mutex and the condition only once.
This commit was SVN r7430.
Этот коммит содержится в:
родитель
193120d434
Коммит
60f9edf17c
@ -336,6 +336,10 @@ int main(int argc, char *argv[])
|
||||
}
|
||||
}
|
||||
|
||||
/* setup the thread lock and condition variable */
|
||||
OBJ_CONSTRUCT(&orted_globals.mutex, opal_mutex_t);
|
||||
OBJ_CONSTRUCT(&orted_globals.condition, opal_condition_t);
|
||||
|
||||
/* check to see if I'm a bootproxy */
|
||||
if (orted_globals.bootproxy) { /* perform bootproxy-specific things */
|
||||
if (orted_globals.mpi_call_yield > 0) {
|
||||
@ -344,10 +348,6 @@ int main(int argc, char *argv[])
|
||||
opal_setenv(var, "1", true, &environ);
|
||||
}
|
||||
|
||||
/* setup the thread lock and condition variable */
|
||||
OBJ_CONSTRUCT(&orted_globals.mutex, opal_mutex_t);
|
||||
OBJ_CONSTRUCT(&orted_globals.condition, opal_condition_t);
|
||||
|
||||
/* Setup callback on jobid */
|
||||
ret = orte_rmgr_base_proc_stage_gate_subscribe(orted_globals.bootproxy, job_state_callback, NULL, ORTE_STAGE_GATE_TERMINATION);
|
||||
if(ORTE_SUCCESS != ret) {
|
||||
@ -375,10 +375,6 @@ int main(int argc, char *argv[])
|
||||
exit(ret);
|
||||
}
|
||||
|
||||
/* setup the thread lock and condition variable */
|
||||
OBJ_CONSTRUCT(&orted_globals.mutex, opal_mutex_t);
|
||||
OBJ_CONSTRUCT(&orted_globals.condition, opal_condition_t);
|
||||
|
||||
/*
|
||||
* Set my process status to "starting". Note that this must be done
|
||||
* after the rte init is completed.
|
||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user