(self, state, *args, **kwargs)
| 729 | """ |
| 730 | |
| 731 | def __init__(self, state, *args, **kwargs): |
| 732 | super().__init__(state, *args, **kwargs) |
| 733 | self._opened = threading.Event() |
| 734 | self._cmd_mutex = threading.Lock() # serializes RunCommand callers |
| 735 | self._cv = threading.Condition() |
| 736 | self._buf = b'' |
| 737 | self._active_nonce = None # bytes |
| 738 | self._active_writer = None |
| 739 | self._exit_code = None |
| 740 | self._died = False |
| 741 | |
| 742 | def handshake_ok(self): |
| 743 | pass |