| 4 | from eventhandler import EventHandler, event_loop |
| 5 | |
| 6 | class TCPServer(EventHandler): |
| 7 | def __init__(self, address, client_handler, handler_list): |
| 8 | self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) |
| 9 | self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, True) |
| 10 | self.sock.bind(address) |
| 11 | self.sock.listen(1) |
| 12 | self.client_handler = client_handler |
| 13 | self.handler_list = handler_list |
| 14 | |
| 15 | def fileno(self): |
| 16 | return self.sock.fileno() |
| 17 | |
| 18 | def wants_to_receive(self): |
| 19 | return True |
| 20 | |
| 21 | def handle_receive(self): |
| 22 | client, addr = self.sock.accept() |
| 23 | # Add the client to the event loop's handler list |
| 24 | self.handler_list.append(self.client_handler(client, self.handler_list)) |
| 25 | |
| 26 | class TCPClient(EventHandler): |
| 27 | def __init__(self, sock, handler_list): |
no outgoing calls
no test coverage detected