(self)
| 72 | super().__init__(*args, **kwargs) |
| 73 | |
| 74 | def handle(self): |
| 75 | try: |
| 76 | while True: |
| 77 | data = self.rfile.readline() |
| 78 | logging.debug('%s -> inst: %s', self.client_address[0], data) |
| 79 | data = str(data, self.ENCODING) |
| 80 | out = self.instrument.handle(data) |
| 81 | out = bytes(out + self.TERMINATION, self.ENCODING) |
| 82 | self.wfile.write(out) |
| 83 | logging.debug('%s <- inst: %s', self.client_address[0], out) |
| 84 | except socket.error as e: |
| 85 | if e.errno == 32: # Broken pipe |
| 86 | logging.info('Client disconnected') |
| 87 | finally: |
| 88 | self.finish() |
| 89 | |
| 90 | return TCPHandler |
| 91 |
no test coverage detected