| 1031 | self.server_close() |
| 1032 | |
| 1033 | class Server(threading.Thread): |
| 1034 | |
| 1035 | def __init__(self, rcvr, hdlr, port, verify): |
| 1036 | super(Server, self).__init__() |
| 1037 | self.rcvr = rcvr |
| 1038 | self.hdlr = hdlr |
| 1039 | self.port = port |
| 1040 | self.verify = verify |
| 1041 | self.ready = threading.Event() |
| 1042 | |
| 1043 | def run(self): |
| 1044 | server = self.rcvr(port=self.port, handler=self.hdlr, |
| 1045 | ready=self.ready, |
| 1046 | verify=self.verify) |
| 1047 | if self.port == 0: |
| 1048 | self.port = server.server_address[1] |
| 1049 | self.ready.set() |
| 1050 | global _listener |
| 1051 | with logging._lock: |
| 1052 | _listener = server |
| 1053 | server.serve_until_stopped() |
| 1054 | |
| 1055 | return Server(ConfigSocketReceiver, ConfigStreamHandler, port, verify) |
| 1056 |
no outgoing calls
no test coverage detected