| 29 | itchat.send(msg, toUserName='filehelper') |
| 30 | |
| 31 | def worker_thread(self, conn, addr): |
| 32 | conn.settimeout(args.timeout) |
| 33 | if conn is not None: |
| 34 | self.send('job connected! [{}]'.format(addr)) |
| 35 | else: |
| 36 | self.send('none connection!') |
| 37 | return -1 |
| 38 | |
| 39 | while(True): |
| 40 | try: |
| 41 | recv_data = conn.recv(1024) |
| 42 | except socket.timeout as e: |
| 43 | print('no msg...') |
| 44 | else: |
| 45 | msg_len = len(recv_data) |
| 46 | if msg_len == 0: |
| 47 | self.send('connection break, waiting for other connections..') |
| 48 | break |
| 49 | self.send(str(recv_data, encoding = 'utf-8')) |
| 50 | conn.close() |
| 51 | |
| 52 | def start_server(self, server_ip, server_port): |
| 53 | ip_port = (server_ip, server_port) |