ports/openmpi
ports/openmpi
1
1
Форкнуть 0
Код Релизы Активность

* Don't use ptys for stdin. When a pty has close() called on it, it

Просмотр исходного кода 
discards all of the data in the pty that hasn't been read.  This was
  leading to data being discarded when files were redirected into
  mpirun and read by rank 0 of the job.  This was very "not good".

  The decision to not use ptys for stdin was made based on what Tim said
  that LA-MPI was doing.

  This needs to go to the v1.0 branch...  Tim should probably review...

This commit was SVN r8892.
Этот коммит содержится в:
Brian Barrett 2006-02-03 20:43:20 +00:00
родитель 6a633829cb
Коммит ddda56eb0d
1 изменённых файлов: 19 добавлений и 57 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

50
orte/mca/iof/base/iof_base_setup.c
Просмотреть файл

@ -77,8 +77,6 @@ orte_iof_base_setup_prefork(orte_iof_base_io_conf_t *opts)
if (opts->usepty) {
ret = openpty(&(opts->p_stdout[0]), &(opts->p_stdout[1]),
NULL, NULL, NULL);
ret = openpty(&(opts->p_stdin[0]), &(opts->p_stdin[1]),
NULL, NULL, NULL);
} else {
ret = -1;
}
@ -98,11 +96,11 @@ orte_iof_base_setup_prefork(orte_iof_base_io_conf_t *opts)
ORTE_ERROR_LOG(ORTE_ERR_OUT_OF_RESOURCE);
return ORTE_ERR_OUT_OF_RESOURCE;
}
}
if (pipe(opts->p_stdin) < 0) {
ORTE_ERROR_LOG(ORTE_ERR_OUT_OF_RESOURCE);
return ORTE_ERR_OUT_OF_RESOURCE;
}
}
if (pipe(opts->p_stderr) < 0) {
ORTE_ERROR_LOG(ORTE_ERR_OUT_OF_RESOURCE);
return ORTE_ERR_OUT_OF_RESOURCE;
@ -120,45 +118,12 @@ orte_iof_base_setup_child(orte_iof_base_io_conf_t *opts)
if (!opts->usepty) {
close(opts->p_stdout[0]);
close(opts->p_stdin[1]);
}
close(opts->p_stdin[1]);
close(opts->p_stderr[0]);
if (opts->usepty) {
if (opts->connect_stdin) {
#ifndef __WINDOWS__
/* disable new-line translation */
struct termios term_attrs;
if (tcgetattr(opts->p_stdin[0], &term_attrs) < 0) {
return ORTE_ERROR;
}
term_attrs.c_iflag &= ~ (ICRNL | INLCR | ISTRIP | INPCK | IXON);
term_attrs.c_oflag &= ~ (
#ifdef OCRNL
/* OS X 10.3 does not have this
value defined */
OCRNL |
#endif
ONLCR);
if (tcsetattr(opts->p_stdin[0], TCSANOW, &term_attrs) == -1) {
return ORTE_ERROR;
}
#endif
/* and connect the pty to stdin */
ret = dup2(opts->p_stdin[0], fileno(stdin));
if (ret < 0) return ORTE_ERROR;
} else {
int fd;
/* connect input to /dev/null */
fd = open("/dev/null", O_RDONLY);
if(fd > fileno(stdin)) {
dup2(fd, fileno(stdin));
close(fd);
}
}
#ifndef __WINDOWS__
{
/* disable echo */
struct termios term_attrs;
if (tcgetattr(opts->p_stdout[1], &term_attrs) < 0) {
@ -177,7 +142,6 @@ orte_iof_base_setup_child(orte_iof_base_io_conf_t *opts)
if (tcsetattr(opts->p_stdout[1], TCSANOW, &term_attrs) == -1) {
return ORTE_ERROR;
}
}
#endif
ret = dup2(opts->p_stdout[1], fileno(stdout));
if (ret < 0) return ORTE_ERROR;
@ -188,11 +152,12 @@ orte_iof_base_setup_child(orte_iof_base_io_conf_t *opts)
if (ret < 0) return ORTE_ERROR;
close(opts->p_stdout[1]);
}
}
if (opts->connect_stdin) {
if(opts->p_stdin[0] != fileno(stdin)) {
ret = dup2(opts->p_stdin[1], fileno(stdin));
ret = dup2(opts->p_stdin[0], fileno(stdin));
if (ret < 0) return ORTE_ERROR;
close(opts->p_stdin[1]);
close(opts->p_stdin[0]);
}
} else {
int fd;
@ -205,7 +170,6 @@ orte_iof_base_setup_child(orte_iof_base_io_conf_t *opts)
close(fd);
}
}
}
if(opts->p_stderr[1] != fileno(stderr)) {
ret = dup2(opts->p_stderr[1], fileno(stderr));
if (ret < 0) return ORTE_ERROR;
@ -224,8 +188,8 @@ orte_iof_base_setup_parent(const orte_process_name_t* name,
if (! opts->usepty) {
close(opts->p_stdout[1]);
close(opts->p_stdin[0]);
}
close(opts->p_stdin[0]);
close(opts->p_stderr[1]);
/* connect stdin endpoint */
@ -238,10 +202,8 @@ orte_iof_base_setup_parent(const orte_process_name_t* name,
return ret;
}
} else {
if (! opts->usepty) {
close(opts->p_stdin[0]);
}
}
/* connect read end to IOF */
ret = orte_iof.iof_publish(name, ORTE_IOF_SOURCE,