| | |
|---|
| | | |
|---|
| | | |
|---|
| | | 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()}") |
|---|
| | |
|---|
| | | 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() |
|---|
