From eac800bcda85ede392d6cc730a383e527794d91f Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 29 八月 2023 23:52:24 +0800
Subject: [PATCH] 修改L2数据传输方式
---
huaxin_client/l2_data_manager.py | 13 +++++++++----
1 files changed, 9 insertions(+), 4 deletions(-)
diff --git a/huaxin_client/l2_data_manager.py b/huaxin_client/l2_data_manager.py
index 7b34dd2..469bcfd 100644
--- a/huaxin_client/l2_data_manager.py
+++ b/huaxin_client/l2_data_manager.py
@@ -166,7 +166,7 @@
tmep_order_detail_queue_dict[code] = queue.Queue()
tag = l2_data_transaction_protocol.get_mmap_tag_name_for_l2_order(code)
with contextlib.closing(
- mmap.mmap(-1, 1000 * 100, tagname=tag,
+ mmap.mmap(-1, 1000 * 100, tag,
access=mmap.ACCESS_WRITE)) as _mmap:
while True:
# print("order task")
@@ -306,6 +306,11 @@
t = threading.Thread(target=lambda: __test(pipe_strage), daemon=True)
t.start()
-
-if __name__ == "__main__":
- upload_data("000798", "trading_order_canceled", 30997688, new_sk=True)
+def test():
+ # upload_data("000798", "trading_order_canceled", 30997688, new_sk=True)
+ code = "000333"
+ tag = l2_data_transaction_protocol.get_mmap_tag_name_for_l2_order(code)
+ with contextlib.closing(
+ mmap.mmap(-1, 1000 * 100, tag,
+ access=mmap.ACCESS_WRITE)) as _mmap:
+ pass
\ No newline at end of file
--
Gitblit v1.8.0