bug修复

Administrator

2025-03-11 b0547060aa83ba6cb17e60fe69589d2e34467887

bug修复

 l2/subscript/l2_subscript_manager.py

@@ -119,7 +119,7 @@
        """
        context = zmq.Context()
        socket = context.socket(zmq.REP)
        socket.bind(str(ipc_addr))
        socket.bind(ipc_addr)
        while True:
            data = socket.recv()
            try:

 main.py

@@ -84,8 +84,8 @@
    channel_list = []
    for i in range(constant.HUAXIN_L2_MAX_CODES_COUNT):
        # 创建委托/成交的共享数组和ZMQ通信通道
        delegate_ipc_addr = f"ipc://order_{i}.ipc",
        deal_ipc_addr = f"ipc://deal_{i}.ipc",
        delegate_ipc_addr = f"ipc://order_{i}.ipc"
        deal_ipc_addr = f"ipc://deal_{i}.ipc"
        delegate = [0, shared_memery_util.create_array(), delegate_ipc_addr]
        delegate[0] = shared_memery_util.get_number(delegate[1])
        deal = [0, shared_memery_util.create_array(), deal_ipc_addr]