(self, session, **fds)
| 13 | """Captures stdout and stderr of the debugged process.""" |
| 14 | |
| 15 | def __init__(self, session, **fds): |
| 16 | self.session = session |
| 17 | self._lock = threading.Lock() |
| 18 | self._chunks = {} |
| 19 | self._worker_threads = [] |
| 20 | |
| 21 | for stream_name, fd in fds.items(): |
| 22 | log.info("Capturing {0} {1}", session.debuggee_id, stream_name) |
| 23 | self._capture(fd, stream_name) |
| 24 | |
| 25 | def __str__(self): |
| 26 | return f"CapturedOutput[{self.session.id}]" |