X-Git-Url: http://git.tuebingen.mpg.de/?a=blobdiff_plain;f=interactive.c;h=729a0dd5bd4b5d68423d044411ba27b7a9bcc992;hb=bb899fb1a0c279a2890ff30d11bf7aec50fb92ed;hp=3af90a6814d79e248178a3e47ae04cd066a8efad;hpb=e854df2fe2cfb3ae90a439828fc13cc0fc470aa9;p=paraslash.git diff --git a/interactive.c b/interactive.c index 3af90a68..729a0dd5 100644 --- a/interactive.c +++ b/interactive.c @@ -377,7 +377,7 @@ static void i9e_pre_select(struct sched *s, __a_unused void *context) return; } if (ret > 0) - para_fd_set(i9ep->ici->fds[1], &s->wfds, &s->max_fileno); + sched_monitor_writefd(i9ep->ici->fds[1], s); } /* * fd[0] might have been reset to blocking mode if our job was moved to @@ -388,7 +388,7 @@ static void i9e_pre_select(struct sched *s, __a_unused void *context) if (ret < 0) PARA_WARNING_LOG("set to nonblock failed: (fd0 %d, %s)\n", i9ep->ici->fds[0], para_strerror(-ret)); - para_fd_set(i9ep->ici->fds[0], &s->rfds, &s->max_fileno); + sched_monitor_readfd(i9ep->ici->fds[0], s); } static void update_winsize(void)