From f5d3bd2bb47e7d1983158d281e2f059ac65a1bd6 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 21 五月 2024 00:14:08 +0800
Subject: [PATCH] 真实下单位修复/深证下单方式修改/9:25之前L2订阅首板开1代码
---
main.py | 7 ++++++-
1 files changed, 6 insertions(+), 1 deletions(-)
diff --git a/main.py b/main.py
index 0e032ac..80493ef 100644
--- a/main.py
+++ b/main.py
@@ -12,6 +12,7 @@
import huaxin_client.l2_client
import huaxin_client.l1_client
import huaxin_client.l1_client_for_trade
+from huaxin_client import l2_market_client
from log_module import log
from log_module.log import logger_l2_trade, logger_system, logger_local_huaxin_l1
@@ -135,6 +136,10 @@
args=(queue_l1_trade_w_strategy_r, queue_l1_trade_r_strategy_w,))
l1TradeProcess.start()
+ l2MarketProcess = multiprocessing.Process(target=l2_market_client.run,
+ args=(queue_l1_w_strategy_r,))
+ l2MarketProcess.start()
+
# 浜ゆ槗杩涚▼
tradeProcess = multiprocessing.Process(
target=huaxin_client.trade_client.run,
@@ -154,7 +159,7 @@
# 涓昏繘绋�
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, queue_l1_trade_r_strategy_w,
- queue_l1_trade_w_strategy_r,(order_ipc_addr, cancel_order_ipc_addr))
+ queue_l1_trade_w_strategy_r, (order_ipc_addr, cancel_order_ipc_addr))
# 灏唗radeServer浣滀负涓昏繘绋�
l1Process.join()
--
Gitblit v1.8.0