| 50 | conn.close() |
| 51 | |
| 52 | def start_server(self, server_ip, server_port): |
| 53 | ip_port = (server_ip, server_port) |
| 54 | s = socket.socket() |
| 55 | s.bind(ip_port) |
| 56 | |
| 57 | # dump ip/port info to file |
| 58 | with open('server.txt', 'w') as f: |
| 59 | f.write('{} {}\n'.format(server_ip, server_port)) |
| 60 | |
| 61 | s.listen() |
| 62 | self.send('server listening on {}, waiting for job connection...'.format(server_ip)) |
| 63 | while(True): |
| 64 | conn, addr = s.accept() |
| 65 | threading.Thread(target=self.worker_thread, args=(conn, addr)).start() |
| 66 | |
| 67 | class MsgClient(object): |
| 68 | def __init__(self, server_ip, server_port): |