From 23cecbb7d4ddf4149cd6b106bfaad415db45bcc3 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 18 三月 2024 14:53:58 +0800
Subject: [PATCH] L2日志修改
---
main.py | 11 ++++-------
1 files changed, 4 insertions(+), 7 deletions(-)
diff --git a/main.py b/main.py
index bcc1459..f73fdc2 100644
--- a/main.py
+++ b/main.py
@@ -29,7 +29,7 @@
queue_l1_w_strategy_r_: multiprocessing.Queue,
queue_strategy_w_trade_r_: multiprocessing.Queue,
queue_strategy_w_trade_r_for_read_: multiprocessing.Queue, order_queues_, transaction_queues_,
- market_queue_, queue_l1_trade_r_strategy_w_, queue_l1_trade_w_strategy_r_, order_ipc_hosts_):
+ market_queue_, queue_l1_trade_r_strategy_w_, queue_l1_trade_w_strategy_r_):
logger_system.info("绛栫暐杩涚▼ID锛歿}", os.getpid())
log.close_print()
# 鍒濆鍖栧弬鏁�
@@ -53,7 +53,7 @@
huaxin_trade_server.run(queue_strategy_r_trade_w_, queue_l1_w_strategy_r_, queue_strategy_w_trade_r_,
queue_strategy_w_trade_r_for_read_, order_queues_,
transaction_queues_, market_queue_,
- queue_l1_trade_w_strategy_r_, order_ipc_hosts_)
+ queue_l1_trade_w_strategy_r_)
# 涓绘湇鍔�
@@ -131,14 +131,11 @@
# 鍒涘缓L2閫氫俊闃熷垪
order_queues = []
transaction_queues = []
- order_ipc_hosts = []
market_queue = multiprocessing.Queue()
for i in range(constant.HUAXIN_L2_MAX_CODES_COUNT):
order_queues.append(multiprocessing.Queue())
for i in range(constant.HUAXIN_L2_MAX_CODES_COUNT):
transaction_queues.append(multiprocessing.Queue())
- for i in range(constant.HUAXIN_L2_MAX_CODES_COUNT):
- order_ipc_hosts.append(f"ipc://l2order{i}.ipc")
# 姝ゅ灏哃2鐨勮繘绋嬩笌绛栫暐杩涚▼鍚堝苟
# L2
@@ -148,14 +145,14 @@
# l2Process.start()
# 灏哃2鐨勮繘绋嬫敼涓鸿繘绋嬫墽琛�
threading.Thread(target=huaxin_client.l2_client.run, args=(
- queue_other_w_l2_r, order_queues, transaction_queues, market_queue, order_ipc_hosts,
+ queue_other_w_l2_r, order_queues, transaction_queues, market_queue,
huaxin_trade_server.my_l2_data_callbacks), daemon=True).start()
# 涓昏繘绋�
createTradeServer(pss_strategy, queue_strategy_r_trade_w, queue_l1_w_strategy_r, queue_strategy_w_trade_r,
queue_strategy_w_trade_r_for_read,
order_queues, transaction_queues, market_queue, queue_l1_trade_r_strategy_w,
- queue_l1_trade_w_strategy_r, order_ipc_hosts)
+ queue_l1_trade_w_strategy_r)
# 灏唗radeServer浣滀负涓昏繘绋�
l1Process.join()
--
Gitblit v1.8.0