(self)
| 95 | (self.connecting or self.accepting or (self.connected and self.downloadChunk > 0)) |
| 96 | |
| 97 | def handle_read(self): |
| 98 | self.lastTx = time.time() |
| 99 | newData = self.recv(self.downloadChunk) |
| 100 | self.receivedBytes += len(newData) |
| 101 | asyncore.update_received(len(newData)) |
| 102 | with self.readLock: |
| 103 | self.read_buf.extend(newData) |
| 104 | |
| 105 | def handle_write(self): |
| 106 | self.lastTx = time.time() |