From 59159700fa6300d663140bc44f570ebc90e1998d Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 18 三月 2024 14:36:05 +0800
Subject: [PATCH] L2日志修改
---
huaxin_client/l2_data_manager.py | 16 ++++++++++++----
1 files changed, 12 insertions(+), 4 deletions(-)
diff --git a/huaxin_client/l2_data_manager.py b/huaxin_client/l2_data_manager.py
index 793d5e0..0e26cd3 100644
--- a/huaxin_client/l2_data_manager.py
+++ b/huaxin_client/l2_data_manager.py
@@ -37,7 +37,8 @@
class L2DataUploadManager:
def __init__(self, order_queue_distribute_manager: CodeQueueDistributeManager,
transaction_queue_distribute_manager: CodeQueueDistributeManager,
- market_data_queue: multiprocessing.Queue, order_ipc_hosts, data_callback_distribute_manager:CodeDataCallbackDistributeManager):
+ market_data_queue: multiprocessing.Queue, order_ipc_hosts,
+ data_callback_distribute_manager: CodeDataCallbackDistributeManager):
self.order_queue_distribute_manager = order_queue_distribute_manager
self.transaction_queue_distribute_manager = transaction_queue_distribute_manager
@@ -141,7 +142,6 @@
if not self.data_callback_distribute_manager.get_distributed_callback(code):
self.data_callback_distribute_manager.distribute_callback(code)
-
if code not in self.temp_order_queue_dict:
self.temp_order_queue_dict[code] = collections.deque()
if code not in self.temp_transaction_queue_dict:
@@ -204,7 +204,14 @@
# 涓婁紶鏁版嵁
# self.__upload_l2_data(code, upload_queue, temp_list)
# self.__upload_l2_order_data(code, temp_list)
- self.data_callback_distribute_manager.get_distributed_callback(code).OnL2Order(code, temp_list, time.time())
+ __start_time = time.time()
+ self.data_callback_distribute_manager.get_distributed_callback(code).OnL2Order(code, temp_list,
+ time.time())
+ use_time = time.time() - __start_time
+ if use_time > 0.01:
+ # 璁板綍10ms浠ヤ笂鐨勬暟鎹�
+ huaxin_l2_log.info(logger_local_huaxin_l2_error, f"鑰楁椂:{use_time}s 缁撴潫鏁版嵁锛歿temp_list[-1]}")
+
temp_list = []
else:
@@ -235,7 +242,8 @@
if temp_list:
# 涓婁紶鏁版嵁
# self.__upload_l2_data(code, upload_queue, temp_list)
- self.data_callback_distribute_manager.get_distributed_callback(code).OnL2Transaction(code, temp_list)
+ self.data_callback_distribute_manager.get_distributed_callback(code).OnL2Transaction(code,
+ temp_list)
temp_list = []
else:
if code not in self.temp_transaction_queue_dict:
--
Gitblit v1.8.0