| | |
|---|
| | | 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 |
|---|
| | | |
|---|
| | |
|---|
| | | 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, |
|---|
| | |
|---|
| | | # 主进程 |
|---|
| | | 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)) |
|---|
| | | |
|---|
| | | # 将tradeServer作为主进程 |
|---|
| | | l1Process.join() |
|---|
