From b217ca6db84c273f0d1c24eed3fae6bec2431dbe Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 31 八月 2023 10:39:53 +0800
Subject: [PATCH] 添加系统日志
---
huaxin_client/l2_client.py | 43 +++++++++++++++++++++++--------------------
1 files changed, 23 insertions(+), 20 deletions(-)
diff --git a/huaxin_client/l2_client.py b/huaxin_client/l2_client.py
index e184b69..d06e344 100644
--- a/huaxin_client/l2_client.py
+++ b/huaxin_client/l2_client.py
@@ -575,27 +575,30 @@
def run(pipe_trade, _pipe_strategy, _l2_data_callback: l2_data_transform_protocol.L2DataCallBack)->None:
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)
- t1.start()
- if _pipe_strategy is not None:
- global pipe_strategy
- pipe_strategy = _pipe_strategy
- t1 = threading.Thread(target=__receive_from_pipe_strategy, args=(_pipe_strategy,), daemon=True)
- t1.start()
- __init_l2()
+ try:
+ log.close_print()
+ if pipe_trade is not None:
+ t1 = threading.Thread(target=lambda: __receive_from_pipe_trade(pipe_trade), daemon=True)
+ t1.start()
+ if _pipe_strategy is not None:
+ global pipe_strategy
+ pipe_strategy = _pipe_strategy
+ t1 = threading.Thread(target=__receive_from_pipe_strategy, args=(_pipe_strategy,), daemon=True)
+ t1.start()
+ __init_l2()
- global l2_data_callback
- l2_data_callback = _l2_data_callback
- l2_data_manager.run_upload_common(l2_data_callback)
- l2_data_manager.run_upload_trading_canceled(l2_data_callback)
- l2_data_manager.run_log()
- # l2_data_manager.run_test(l2_data_callback)
- global l2CommandManager
- l2CommandManager = command_manager.L2CommandManager()
- l2CommandManager.init(MyL2ActionCallback())
- logger_system.info("L2璁㈤槄鏈嶅姟鍚姩鎴愬姛")
+ global l2_data_callback
+ l2_data_callback = _l2_data_callback
+ l2_data_manager.run_upload_common(l2_data_callback)
+ l2_data_manager.run_upload_trading_canceled(l2_data_callback)
+ l2_data_manager.run_log()
+ # l2_data_manager.run_test(l2_data_callback)
+ global l2CommandManager
+ l2CommandManager = command_manager.L2CommandManager()
+ l2CommandManager.init(MyL2ActionCallback())
+ logger_system.info("L2璁㈤槄鏈嶅姟鍚姩鎴愬姛")
+ except Exception as e:
+ logger_system.exception(e)
while True:
time.sleep(2)
--
Gitblit v1.8.0