(addr)
| 15 | sock.close() |
| 16 | |
| 17 | def echo_server(addr): |
| 18 | print('Echo server running at', addr) |
| 19 | pool = ThreadPoolExecutor(128) |
| 20 | sock = socket(AF_INET, SOCK_STREAM) |
| 21 | sock.bind(addr) |
| 22 | sock.listen(5) |
| 23 | while True: |
| 24 | client_sock, client_addr = sock.accept() |
| 25 | pool.submit(echo_client, client_sock, client_addr) |
| 26 | |
| 27 | echo_server(('',15000)) |
no test coverage detected