From 122def357140a4a504710a57fe2bc1a8020aa7b1 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 27 二月 2024 17:57:39 +0800
Subject: [PATCH] 新版L2数据传输协议测试
---
main.py | 11 +++++++----
1 files changed, 7 insertions(+), 4 deletions(-)
diff --git a/main.py b/main.py
index 5c66386..5c0aeca 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_):
+ market_queue_, queue_l1_trade_r_strategy_w_, queue_l1_trade_w_strategy_r_, order_ipc_hosts_):
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_)
+ queue_l1_trade_w_strategy_r_, order_ipc_hosts_)
# 涓绘湇鍔�
@@ -131,23 +131,26 @@
# 鍒涘缓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")
# L2
l2Process = multiprocessing.Process(
target=huaxin_client.l2_client.run,
- args=(queue_other_w_l2_r, order_queues, transaction_queues, market_queue))
+ args=(queue_other_w_l2_r, order_queues, transaction_queues, market_queue, order_ipc_hosts))
l2Process.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)
+ queue_l1_trade_w_strategy_r, order_ipc_hosts)
# 灏唗radeServer浣滀负涓昏繘绋�
l1Process.join()
--
Gitblit v1.8.0