| 1804 | |
| 1805 | |
| 1806 | class TestThreadedClient(SocketThread): |
| 1807 | |
| 1808 | def __init__(self, test, sock, prog, timeout): |
| 1809 | threading.Thread.__init__(self, None, None, 'test-client') |
| 1810 | self.daemon = True |
| 1811 | |
| 1812 | self._timeout = timeout |
| 1813 | self._sock = sock |
| 1814 | self._active = True |
| 1815 | self._prog = prog |
| 1816 | self._test = test |
| 1817 | |
| 1818 | def run(self): |
| 1819 | try: |
| 1820 | self._prog(TestSocketWrapper(self._sock)) |
| 1821 | except (KeyboardInterrupt, SystemExit): |
| 1822 | raise |
| 1823 | except BaseException as ex: |
| 1824 | self._test._abort_socket_test(ex) |
| 1825 | |
| 1826 | |
| 1827 | class TestThreadedServer(SocketThread): |