From 9f06233d02d036624bbdcf92ba81b2a6aaa970da Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 30 八月 2023 00:26:24 +0800
Subject: [PATCH] 取消测试
---
huaxin_client/l2_data_manager.py | 11 ++++++-----
1 files changed, 6 insertions(+), 5 deletions(-)
diff --git a/huaxin_client/l2_data_manager.py b/huaxin_client/l2_data_manager.py
index 469bcfd..cf959e7 100644
--- a/huaxin_client/l2_data_manager.py
+++ b/huaxin_client/l2_data_manager.py
@@ -165,9 +165,10 @@
if code not in tmep_order_detail_queue_dict:
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, tag,
- access=mmap.ACCESS_WRITE)) as _mmap:
+ # with contextlib.closing(
+ # mmap.mmap(-1, 1000 * 100, tag,
+ # access=mmap.ACCESS_WRITE)) as _mmap:
+ if True:
while True:
# print("order task")
try:
@@ -181,8 +182,8 @@
udatas.append(temp)
if udatas:
start_time = time.time()
- # upload_data(code, "l2_order", udatas)
- l2_data_transaction_protocol.send_l2_order_detail(pipe, _mmap, code, udatas)
+ upload_data(code, "l2_order", udatas)
+ # l2_data_transaction_protocol.send_l2_order_detail(pipe, _mmap, code, udatas)
use_time = int((time.time() - start_time) * 1000)
if use_time > 20:
logger_local_huaxin_l2_upload.info(f"{code}-涓婁紶浠ｇ爜鑰楁椂锛歿use_time}ms")
--
Gitblit v1.8.0