| | |
|---|
| | | from log_module import log, async_log_util |
|---|
| | | from log_module.log import logger_local_huaxin_l2_subscript, logger_system, logger_local_huaxin_l2_transaction, \ |
|---|
| | | logger_local_huaxin_g_cancel, logger_l2_codes_subscript |
|---|
| | | from utils import tool |
|---|
| | | |
|---|
| | | Front_Address = "tcp://10.0.1.101:6900" |
|---|
| | | Multicast_Address = "udp://224.224.2.19:7889" |
|---|
| | |
|---|
| | | |
|---|
| | | def run(pipe_trade, _pipe_strategy, _l2_data_callback: l2_data_transform_protocol.L2DataCallBack)->None: |
|---|
| | | logger_system.info("L2进程ID：{}", os.getpid()) |
|---|
| | | logger_system.info(f"l2_client 线程ID:{tool.get_thread_id()}") |
|---|
| | | try: |
|---|
| | | log.close_print() |
|---|
| | | if pipe_trade is not None: |
|---|
