| | |
| | | sk.connect((addr, port)) |
| | | try: |
| | | sk.sendall(socket_util.load_header(json.dumps(fdata).encode('utf-8'))) |
| | | result, header = socket_util.recv_data(sk) |
| | | if result: |
| | | result = json.loads(result) |
| | | if result["code"] != 0: |
| | | raise Exception(result["msg"]) |
| | | # result, header = socket_util.recv_data(sk) |
| | | # if result: |
| | | # result = json.loads(result) |
| | | # if result["code"] != 0: |
| | | # raise Exception(result["msg"]) |
| | | sk.sendall(socket_util.load_header(json.dumps({"type": 40, "data": []}).encode('utf-8'))) |
| | | result, header = socket_util.recv_data(sk) |
| | | # result, header = socket_util.recv_data(sk) |
| | | finally: |
| | | sk.close() |