(self)
| 416 | self.outbuf[0:1] = [] |
| 417 | |
| 418 | def fill(self): |
| 419 | self.rsock.setblocking(False) |
| 420 | try: |
| 421 | b = _nb_clean(os.read, self.rsock.fileno(), 32768) |
| 422 | except OSError, e: |
| 423 | raise Fatal('other end: %r' % e) |
| 424 | #log('<<< %r\n' % b) |
| 425 | if b == '': # EOF |
| 426 | self.ok = False |
| 427 | if b: |
| 428 | self.inbuf += b |
| 429 | |
| 430 | def handle(self): |
| 431 | self.fill() |