From 23cecbb7d4ddf4149cd6b106bfaad415db45bcc3 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 18 三月 2024 14:53:58 +0800
Subject: [PATCH] L2日志修改
---
l2/l2_data_listen_manager.py | 5 +----
1 files changed, 1 insertions(+), 4 deletions(-)
diff --git a/l2/l2_data_listen_manager.py b/l2/l2_data_listen_manager.py
index f35f63d..6727eb9 100644
--- a/l2/l2_data_listen_manager.py
+++ b/l2/l2_data_listen_manager.py
@@ -134,7 +134,7 @@
threading.Thread(target=lambda: self.__create_ipc_server(host), daemon=True).start()
# 鎺ユ敹L2鏁版嵁
- def receive_l2_data(self, order_queues, transaction_queues, market_queue, order_ipc_hosts):
+ def receive_l2_data(self, order_queues, transaction_queues, market_queue):
# TODO 鏆傛椂涓嶉�氳繃闃熷垪鎺ユ敹鏁版嵁
# for q in order_queues:
# t1 = threading.Thread(target=lambda: self.__recive_l2_orders(q), daemon=True)
@@ -144,9 +144,6 @@
t2.start()
t3 = threading.Thread(target=lambda: self.__recive_l2_markets(market_queue), daemon=True)
t3.start()
- # 鎺ユ敹璁㈠崟hosts
- if not constant.is_windows():
- self.__create_ipc_server_hosts(order_ipc_hosts)
def get_active_count(self, type_):
expire_time = time.time() - 5
--
Gitblit v1.8.0