| 65 | threading.Thread(target=self.worker_thread, args=(conn, addr)).start() |
| 66 | |
| 67 | class MsgClient(object): |
| 68 | def __init__(self, server_ip, server_port): |
| 69 | self._init_client(server_ip, server_port) |
| 70 | self.send('I\'m client!\n') |
| 71 | |
| 72 | def send(self, msg, echo=True): |
| 73 | self.s.send(bytes(msg, encoding = 'utf-8')) |
| 74 | if echo: |
| 75 | print(msg) |
| 76 | |
| 77 | def _init_client(self, server_ip, server_port): |
| 78 | ip_port = (server_ip, server_port) |
| 79 | self.s = socket.socket() |
| 80 | self.s.connect(ip_port) |
| 81 | |
| 82 | def close(self): |
| 83 | self.s.close() |
| 84 | |
| 85 | def itchat_manager(): |
| 86 | def run_and_get(cmd, screen=False): |
no outgoing calls
no test coverage detected