++++++++++++++++ bug修复

Administrator

2023-08-17 314e8d81d3379be11e3aae018f66a41299c4114d

++++++++++++++++
bug修复

 huaxin_api/l2_client.py

@@ -539,7 +539,7 @@


def run(pipe_trade, pipe_strategy):
    logger_system.info("L2进程ID：", os.getpid())
    logger_system.info("L2进程ID：{}", os.getpid())
    log.close_print()
    if pipe_trade is not None:
        t1 = threading.Thread(target=lambda: __receive_from_pipe_trade(pipe_trade), daemon=True)

 huaxin_api/trade_client.py

@@ -976,7 +976,7 @@


def run(pipe_l2=None, pipe_strategy=None):
    logger_system.info("交易进程ID：", os.getpid())
    logger_system.info("交易进程ID：{}", os.getpid())
    __init_trade_data_server()
    global l2pipe
    l2pipe = pipe_l2

 main.py

@@ -24,7 +24,7 @@


def createTradeServer(pipe_server, pipe_trade, pipe_l1, pipe_l2):
    logger_system.info("策略进程ID：", os.getpid())
    logger_system.info("策略进程ID：{}", os.getpid())
    log.close_print()
    # 初始化参数
    global_data_loader.init()
@@ -78,7 +78,7 @@
    # 托管环境下不创建
    # serverProcess = multiprocessing.Process(target=createServer, args=(pss_server,))
    # serverProcess.start()
    logger_system.info("主进程ID：", os.getpid())
    logger_system.info("主进程ID：{}", os.getpid())

    tradeServerProcess = multiprocessing.Process(target=createTradeServer,
                                                 args=(pss_strategy, pst_strategy, pl1t_strategy, psl2_strategy))