1.1 --- a/parallel.py Wed Sep 28 16:00:06 2005 +0000
1.2 +++ b/parallel.py Wed Sep 28 16:15:15 2005 +0000
1.3 @@ -196,16 +196,16 @@
1.4 for fd, status in fds:
1.5 channel = self.readables[fd]
1.6
1.7 - # Record readable channels.
1.8 -
1.9 - if status & select.POLLIN:
1.10 - readables.append(channel)
1.11 -
1.12 # Remove ended/error channels.
1.13
1.14 if status & (select.POLLHUP | select.POLLNVAL | select.POLLERR):
1.15 self.remove(channel)
1.16
1.17 + # Record readable channels.
1.18 +
1.19 + elif status & select.POLLIN:
1.20 + readables.append(channel)
1.21 +
1.22 return readables
1.23
1.24 def remove(self, channel):