(self)
| 95 | return True |
| 96 | |
| 97 | def _run(self): |
| 98 | self.logger.info("Thread started") |
| 99 | while not self._do_stop: |
| 100 | try: |
| 101 | self._receive() |
| 102 | except ua.utils.SocketClosedException: |
| 103 | self.logger.info("Socket has closed connection") |
| 104 | self._connection.close() |
| 105 | break |
| 106 | except UaError: |
| 107 | self.logger.exception("Protocol Error") |
| 108 | self._cancel_all_callbacks() |
| 109 | self.logger.info("Thread ended") |
| 110 | |
| 111 | def _receive(self): |
| 112 | msg = self._connection.receive_from_socket(self._socket) |
nothing calls this directly
no test coverage detected