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

Administrator

2023-08-15 e4d50361d0be2c86ddf9da7584963f54e72a86a8

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

 huaxin_api/l2_client.py

@@ -11,6 +11,7 @@
import lev2mdapi
from huaxin_api.command_manager import L2ActionCallback
from huaxin_api.mylog import logger_l2_orderdetail, logger_l2_transaction, logger_l2_subscript
from log_module import log

Front_Address = "tcp://10.0.1.101:6900"
Multicast_Address = "udp://224.224.2.19:7889"
@@ -536,6 +537,7 @@


def run(pipe_trade, pipe_strategy):
    log.close_print()
    if pipe_trade is not None:
        t1 = threading.Thread(target=lambda: __receive_from_pipe_trade(pipe_trade), daemon=True)
        t1.start()

 log_module/log.py

@@ -1,6 +1,7 @@
"""
日志
"""
import os
import sys
from loguru import logger
import constant
@@ -289,3 +290,8 @@
hx_logger_trade_callback = __mylogger.get_logger("hx_trade_callback")
hx_logger_trade_debug = __mylogger.get_logger("hx_trade_debug")
hx_logger_trade_loop = __mylogger.get_logger("hx_trade_loop")


def close_print():
    os.close(1)
    os.open('/dev/null', os.O_WRONLY)

 main.py

@@ -3,11 +3,14 @@
"""

import multiprocessing
import os
import sys

from db import redis_manager_delegate as redis_manager
import huaxin_api.trade_client
import huaxin_api.l2_client
import huaxin_api.l1_client
from log_module import log

from server import *

@@ -20,6 +23,7 @@


def createTradeServer(pipe_server, pipe_trade, pipe_l1, pipe_l2):
    log.close_print()
    # 初始化参数
    global_data_loader.init()

@@ -55,6 +59,7 @@


if __name__ == '__main__':
    log.close_print()
    # 策略与server间的通信
    pss_server, pss_strategy = multiprocessing.Pipe()
    # 策略与交易间的通信