共享内存测试

Administrator

2023-08-25 dbc2ec056e478704cc352586a22e9e07755b15f0

 trade/huaxin/trade_server.py

@@ -185,8 +185,9 @@
                            code = data["code"]
                            timestamp = data.get("time")
                            datas = data["data"]
                            now_timestamp = int(time.time() * 1000)
                            async_log_util.info(hx_logger_l2_orderdetail,
                                                f"{code}#耗时：{int(time.time() * 1000) - timestamp}#{datas}")
                                                f"{code}#耗时：{int(time.time() * 1000) - timestamp}-{now_timestamp}#{datas}")
                            l2_log.threadIds[code] = random.randint(0, 100000)
                            l2_data_manager_new.L2TradeDataProcessor.process_huaxin(code, datas)
                        finally:
@@ -380,11 +381,8 @@
                                    logger_l2_g_cancel.info(f"{code}-需要撤单：{msg}")
                                else:
                                    logger_l2_g_cancel.info(f"{code}-不需要撤单：{msg}")


                            except Exception as e:
                                logger_l2_g_cancel.error(f"{code}-撤单异常：{str(e)}")
                                logger_l2_g_cancel.exception(e)
                        finally:
                            sk.sendall(socket_util.load_header(json.dumps({"code": 0}).encode(encoding='utf-8')))