(self)
| 1030 | self.verify = verify |
| 1031 | |
| 1032 | def serve_until_stopped(self): |
| 1033 | import select |
| 1034 | abort = 0 |
| 1035 | while not abort: |
| 1036 | rd, wr, ex = select.select([self.socket.fileno()], |
| 1037 | [], [], |
| 1038 | self.timeout) |
| 1039 | if rd: |
| 1040 | self.handle_request() |
| 1041 | with logging._lock: |
| 1042 | abort = self.abort |
| 1043 | self.server_close() |
| 1044 | |
| 1045 | class Server(threading.Thread): |
| 1046 |
no test coverage detected