From bb2c58fb407a3783b3704b33df6a154207ae4199 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 13 三月 2024 14:39:05 +0800
Subject: [PATCH] 更改L2数据接收方式
---
huaxin_client/l2_client.py | 4 ++--
1 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/huaxin_client/l2_client.py b/huaxin_client/l2_client.py
index c4b2e4b..3cfe584 100644
--- a/huaxin_client/l2_client.py
+++ b/huaxin_client/l2_client.py
@@ -585,7 +585,7 @@
def run(queue_r: multiprocessing.Queue, order_queues: List[multiprocessing.Queue],
- transaction_queues: List[multiprocessing.Queue], market_queue: multiprocessing.Queue) -> None:
+ transaction_queues: List[multiprocessing.Queue], market_queue: multiprocessing.Queue, order_ipc_hosts: list) -> None:
# def test_add_codes():
# time.sleep(5)
# # if value:
@@ -633,7 +633,7 @@
order_queue_distribute_manager = CodeQueueDistributeManager(order_queues)
transaction_queue_distribute_manager = CodeQueueDistributeManager(transaction_queues)
l2_data_upload_manager = L2DataUploadManager(order_queue_distribute_manager,
- transaction_queue_distribute_manager, market_queue)
+ transaction_queue_distribute_manager, market_queue, order_ipc_hosts)
__init_l2(l2_data_upload_manager)
l2_data_manager.run_upload_common()
l2_data_manager.run_log()
--
Gitblit v1.8.0