(self)
| 1053 | self.ready = threading.Event() |
| 1054 | |
| 1055 | def run(self): |
| 1056 | server = self.rcvr(port=self.port, handler=self.hdlr, |
| 1057 | ready=self.ready, |
| 1058 | verify=self.verify) |
| 1059 | if self.port == 0: |
| 1060 | self.port = server.server_address[1] |
| 1061 | self.ready.set() |
| 1062 | global _listener |
| 1063 | with logging._lock: |
| 1064 | _listener = server |
| 1065 | server.serve_until_stopped() |
| 1066 | |
| 1067 | return Server(ConfigSocketReceiver, ConfigStreamHandler, port, verify) |
| 1068 |
no test coverage detected