Fill raw queue from exactly one recv() system call. Block if no data is immediately available. Set self.eof when connection is closed.
(self)
| 514 | return c |
| 515 | |
| 516 | def fill_rawq(self): |
| 517 | """Fill raw queue from exactly one recv() system call. |
| 518 | |
| 519 | Block if no data is immediately available. Set self.eof when |
| 520 | connection is closed. |
| 521 | |
| 522 | """ |
| 523 | if self.irawq >= len(self.rawq): |
| 524 | self.rawq = b'' |
| 525 | self.irawq = 0 |
| 526 | # The buffer size should be fairly small so as to avoid quadratic |
| 527 | # behavior in process_rawq() above |
| 528 | buf = self.sock.recv(50) |
| 529 | self.msg("recv %r", buf) |
| 530 | self.eof = (not buf) |
| 531 | self.rawq = self.rawq + buf |
| 532 | |
| 533 | def sock_avail(self): |
| 534 | """Test whether data is available on the socket.""" |
no test coverage detected