From 23cecbb7d4ddf4149cd6b106bfaad415db45bcc3 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 18 三月 2024 14:53:58 +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 1649e59..50709d0 100644
--- a/huaxin_client/l2_client.py
+++ b/huaxin_client/l2_client.py
@@ -590,7 +590,7 @@
def run(queue_r: multiprocessing.Queue, order_queues: List[multiprocessing.Queue],
- transaction_queues: List[multiprocessing.Queue], market_queue: multiprocessing.Queue, order_ipc_hosts: list, data_callbacks:list) -> None:
+ transaction_queues: List[multiprocessing.Queue], market_queue: multiprocessing.Queue, data_callbacks:list) -> None:
logger_system.info("L2杩涚▼ID锛歿}", os.getpid())
logger_system.info(f"l2_client 绾跨▼ID:{tool.get_thread_id()}")
@@ -605,7 +605,7 @@
transaction_queue_distribute_manager = CodeQueueDistributeManager(transaction_queues)
data_callback_distribute_manager = CodeDataCallbackDistributeManager(data_callbacks)
l2_data_upload_manager = L2DataUploadManager(order_queue_distribute_manager,
- transaction_queue_distribute_manager, market_queue, order_ipc_hosts, data_callback_distribute_manager)
+ transaction_queue_distribute_manager, market_queue, data_callback_distribute_manager)
__init_l2(l2_data_upload_manager)
l2_data_manager.run_upload_common()
l2_data_manager.run_log()
--
Gitblit v1.8.0