| 1796 | |
| 1797 | |
| 1798 | class TestThreadedClient(SocketThread): |
| 1799 | |
| 1800 | def __init__(self, test, sock, prog, timeout): |
| 1801 | threading.Thread.__init__(self, None, None, 'test-client') |
| 1802 | self.daemon = True |
| 1803 | |
| 1804 | self._timeout = timeout |
| 1805 | self._sock = sock |
| 1806 | self._active = True |
| 1807 | self._prog = prog |
| 1808 | self._test = test |
| 1809 | |
| 1810 | def run(self): |
| 1811 | try: |
| 1812 | self._prog(TestSocketWrapper(self._sock)) |
| 1813 | except (KeyboardInterrupt, SystemExit): |
| 1814 | raise |
| 1815 | except BaseException as ex: |
| 1816 | self._test._abort_socket_test(ex) |
| 1817 | |
| 1818 | |
| 1819 | class TestThreadedServer(SocketThread): |
no outgoing calls
searching dependent graphs…