(self)
| 291 | self.stop = Event() |
| 292 | |
| 293 | def run(self): |
| 294 | self.started = True |
| 295 | |
| 296 | while not self.stop.is_set(): |
| 297 | chunk = os.read(self.readfd, 1024) |
| 298 | |
| 299 | with self.buffer_lock: |
| 300 | self.buffer.write(chunk) |
| 301 | if self.echo: |
| 302 | sys.stdout.write(decode(chunk)) |
| 303 | |
| 304 | os.close(self.readfd) |
| 305 | os.close(self.writefd) |
| 306 | |
| 307 | def reset_buffer(self): |
| 308 | with self.buffer_lock: |