(self)
| 118 | self.daemon = kwargs.get("daemon", False) |
| 119 | |
| 120 | def serve(self): |
| 121 | self.serverTransport.listen() |
| 122 | while True: |
| 123 | try: |
| 124 | client = self.serverTransport.accept() |
| 125 | if not client: |
| 126 | continue |
| 127 | t = threading.Thread(target=self.handle, args=(client,)) |
| 128 | t.daemon = self.daemon |
| 129 | t.start() |
| 130 | except KeyboardInterrupt: |
| 131 | raise |
| 132 | except Exception as x: |
| 133 | logger.exception(x) |
| 134 | |
| 135 | def handle(self, client): |
| 136 | itrans = self.inputTransportFactory.getTransport(client) |