From bb2c58fb407a3783b3704b33df6a154207ae4199 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 13 三月 2024 14:39:05 +0800
Subject: [PATCH] 更改L2数据接收方式
---
main.py | 8 ++++----
1 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/main.py b/main.py
index 4b727ef..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_)
# 涓绘湇鍔�
@@ -143,14 +143,14 @@
# 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