(self, connection)
| 714 | self.session(self.sock.accept()) |
| 715 | |
| 716 | def session(self, connection): |
| 717 | sock, (host, port) = connection |
| 718 | while 1: |
| 719 | try: |
| 720 | call = recvrecord(sock) |
| 721 | except EOFError: |
| 722 | break |
| 723 | except socket.error: |
| 724 | print('socket error:', sys.exc_info()[0]) |
| 725 | break |
| 726 | reply = self.handle(call) |
| 727 | if reply is not None: |
| 728 | sendrecord(sock, reply) |
| 729 | |
| 730 | def forkingloop(self): |
| 731 | # Like loop but uses forksession() |
no test coverage detected