(self)
| 16 | self._done = False |
| 17 | |
| 18 | def start(self): |
| 19 | def process(self): |
| 20 | self._socket.listen(1) |
| 21 | self._process() |
| 22 | |
| 23 | try: |
| 24 | os.unlink(self._uds_path) |
| 25 | except OSError: |
| 26 | if os.path.exists(self._uds_path): |
| 27 | raise |
| 28 | self._socket = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) |
| 29 | self._socket.bind(self._uds_path) |
| 30 | self._thread = Thread(target=process, daemon=True, args=[self]) |
| 31 | self._thread.start() |
| 32 | |
| 33 | def stop(self): |
| 34 | self._done = True |