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

* remove dead code

Просмотр исходного кода 
This commit was SVN r3728.
Этот коммит содержится в:
Brian Barrett 2004-12-07 15:16:06 +00:00
родитель 0853d49593
Коммит 88c94f7439
1 изменённых файлов: 0 добавлений и 75 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

75
src/mca/pcm/bproc/src/pcm_bproc_monitor.c
Просмотреть файл

@ -63,78 +63,3 @@ mca_pcm_bproc_monitor_cb(pid_t pid, int status, void *data)
mca_pcm_base_kill_unregister((mca_pcm_base_module_t*)me, jobid, lower, upper);
}
void
mca_pcm_bproc_stdin_handler(int sd, short flags, void *user)
{
}
void
mca_pcm_bproc_stdout_handler(int sd, short flags, void *user)
{
char buf[1024];
ssize_t ret;
size_t len;
while (1) {
ret = read(sd, buf, sizeof(buf));
if (ret < 0 && errno == EAGAIN) break;
if (ret < 0 && errno == EINTR) continue;
if (ret < 0) {
perror("bproc stdout");
/* BWB - what do I do now? */
break;
}
if (ret == 0) {
printf("bproc stdout: returned 0\n");
break;
}
len = (size_t) ret;
while (len > 0) {
ret = write(1, buf, len);
if (ret < 0 && errno != EINTR) {
perror("bproc stdout");
break;
}
len -= (size_t) ret;
}
}
}
void
mca_pcm_bproc_stderr_handler(int sd, short flags, void *user)
{
char buf[1024];
ssize_t ret;
size_t len;
while (1) {
ret = read(sd, buf, sizeof(buf));
if (ret < 0 && errno == EAGAIN) break;
if (ret < 0 && errno == EINTR) continue;
if (ret < 0) {
perror("bproc stdout");
/* BWB - what do I do now? */
break;
}
if (ret == 0) {
printf("bproc stdout: returned 0\n");
break;
}
len = (size_t) ret;
while (len > 0) {
ret = write(2, buf, len);
if (ret < 0 && errno != EINTR) {
perror("bproc stdout");
break;
}
len -= (size_t) ret;
}
}
}