From eac800bcda85ede392d6cc730a383e527794d91f Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 29 八月 2023 23:52:24 +0800
Subject: [PATCH] 修改L2数据传输方式
---
test/test_mmap.py | 11 +++++++++--
1 files changed, 9 insertions(+), 2 deletions(-)
diff --git a/test/test_mmap.py b/test/test_mmap.py
index 9fd5419..5d71e0a 100644
--- a/test/test_mmap.py
+++ b/test/test_mmap.py
@@ -3,9 +3,12 @@
import multiprocessing
import time
+from huaxin_client import l2_data_manager
+
def run_process_1(pipe):
- with contextlib.closing(mmap.mmap(-1, 1000 * 100, tagname='l2-000333', access=mmap.ACCESS_WRITE)) as m:
+ tag = 'l2-000333'
+ with contextlib.closing(mmap.mmap(-1, 1000 * 100, tagname=tag, access=mmap.ACCESS_WRITE)) as m:
for i in range(1, 10001):
start = time.time()
m.seek(0)
@@ -24,8 +27,12 @@
print(len(s), s)
time.sleep(1)
-
if __name__ == '__main__':
+ l2_data_manager.test()
+ pass
+
+
+if __name__ == '__main__1':
p1, p2 = multiprocessing.Pipe()
serverProcess = multiprocessing.Process(target=run_process_1, args=(p1,))
jueJinProcess = multiprocessing.Process(target=run_process_2, args=(p2,))
--
Gitblit v1.8.0