1
1

* add a debugging hack for Tim so to delay successive rsh/ssh calls so

that the xauth doesn't get whacked

This commit was SVN r3374.
Этот коммит содержится в:
Brian Barrett 2004-10-27 15:29:03 +00:00
родитель 855d7bebaa
Коммит 0210b6e8dd
3 изменённых файлов: 14 добавлений и 0 удалений

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

@ -64,6 +64,7 @@ extern "C" {
int ignore_stderr;
char* rsh_agent;
int constraints;
unsigned int delay_time;
};
typedef struct mca_pcm_rsh_module_t mca_pcm_rsh_module_t;

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

@ -54,6 +54,7 @@ static int mca_pcm_rsh_param_fast;
static int mca_pcm_rsh_param_ignore_stderr;
static int mca_pcm_rsh_param_priority;
static int mca_pcm_rsh_param_agent;
static int mca_pcm_rsh_param_delay_time;
int
@ -73,6 +74,9 @@ mca_pcm_rsh_component_open(void)
mca_pcm_rsh_param_priority =
mca_base_param_register_int("pcm", "rsh", "priority", NULL, 1);
mca_pcm_rsh_param_delay_time =
mca_base_param_register_int("pcm", "rsh", "delay", NULL, 0);
return OMPI_SUCCESS;
}
@ -107,6 +111,8 @@ mca_pcm_rsh_init(int *priority,
&(me->ignore_stderr));
mca_base_param_lookup_string(mca_pcm_rsh_param_agent,
&(me->rsh_agent));
mca_base_param_lookup_int(mca_pcm_rsh_param_delay_time,
&(me->delay_time));
ret = mca_llm_base_select("rsh", &(me->llm), have_threads);

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

@ -84,6 +84,7 @@ mca_pcm_rsh_spawn_procs(struct mca_pcm_base_module_1_0_0_t* me_super,
int global_start_vpid = 0;
int num_procs = 0;
int tmp_count;
unsigned int sleep_time;
OBJ_CONSTRUCT(&launch, ompi_list_t);
OBJ_CONSTRUCT(&done, ompi_list_t);
@ -162,6 +163,12 @@ mca_pcm_rsh_spawn_procs(struct mca_pcm_base_module_1_0_0_t* me_super,
/* copy the list over to the done part */
ompi_list_join(&done, ompi_list_get_end(&done), &launch);
/* delay before the next start */
sleep_time = me->delay_time;
while (sleep_time > 0) {
sleep_time = sleep(sleep_time);
}
}
/* put the list back where we found it... */