From a13cb5262f0eea22aa51147b087b26e91930a9c4 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 18 四月 2024 16:31:51 +0800
Subject: [PATCH] 共享内存/zeromq通信测试
---
test_communication.py | 13 +++++++------
1 files changed, 7 insertions(+), 6 deletions(-)
diff --git a/test_communication.py b/test_communication.py
index d96a4d6..3296c7b 100644
--- a/test_communication.py
+++ b/test_communication.py
@@ -1,3 +1,4 @@
+import logging
import multiprocessing
import threading
import time
@@ -23,8 +24,8 @@
use_time = (time.time() - msg['time']) * 1000
decoded_data, decoded_use_time = L2SharedMemoryDataUtil.get_data(shared_memory)
print(f"鑾峰彇鍒伴�愮瑪濮旀墭鏁版嵁: 閫氫俊鑰楁椂锛歿use_time}ms 瑙ｇ爜鑰楁椂:{decoded_use_time}s")
- except:
- pass
+ except Exception as e:
+ logging.exception(e)
finally:
socket.send_string("SUCCESS")
@@ -37,8 +38,8 @@
use_time = (time.time() - msg['time']) * 1000
decoded_data, decoded_use_time = L2SharedMemoryDataUtil.get_data(shared_memory)
print(f"鑾峰彇鍒伴�愮瑪鎴愪氦鏁版嵁: 閫氫俊鑰楁椂锛歿use_time}ms 瑙ｇ爜鑰楁椂:{decoded_use_time}s")
- except:
- pass
+ except Exception as e:
+ logging.exception(e)
finally:
socket.send_string("SUCCESS")
@@ -105,8 +106,8 @@
delegate_data_shared_memory=delegate_data_array,
deal_data_shared_memory=deal_data_array)
if constant.is_windows():
- param.delegate_ipc_addr = f"tcp://*:{10000 + i}"
- param.deal_ipc_addr = f"tcp://*:{11000 + i}"
+ param.delegate_ipc_addr = f"tcp://127.0.0.1:{15000 + i}"
+ param.deal_ipc_addr = f"tcp://127.0.0.1:{16000 + i}"
params.append(param)
strategy = L2Strategy(params)
dataCollector = L2DataCollector(params)
--
Gitblit v1.8.0