| | |
| | | l2_log.threadIds[code] = random.randint(0, 100000) |
| | | l2_data_manager_new.L2TradeDataProcessor.process_huaxin(code, datas) |
| | | finally: |
| | | sk.sendall(json.dumps({"code": 0}).encode(encoding='utf-8')) |
| | | sk.sendall(socket_util.load_header(json.dumps({"code": 0}).encode(encoding='utf-8'))) |
| | | |
| | | elif data_json["type"] == "l2_trans": |
| | | try: |
| | |
| | | except Exception as e: |
| | | hx_logger_l2_transaction.exception(e) |
| | | finally: |
| | | sk.sendall(json.dumps({"code": 0}).encode(encoding='utf-8')) |
| | | sk.sendall(socket_util.load_header(json.dumps({"code": 0}).encode(encoding='utf-8'))) |
| | | elif data_json["type"] == "l2_market_data": |
| | | try: |
| | | data = data_json["data"] |