From 4d321ae069fce2c0f6f7884bec8fa6c4ec534d1a Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 03 八月 2023 18:25:33 +0800
Subject: [PATCH] redis连接池归还
---
test/l2_trade_test.py | 11 ++++++-----
1 files changed, 6 insertions(+), 5 deletions(-)
diff --git a/test/l2_trade_test.py b/test/l2_trade_test.py
index a5936ce..668ff60 100644
--- a/test/l2_trade_test.py
+++ b/test/l2_trade_test.py
@@ -28,20 +28,21 @@
redis_l2 = redis_manager.RedisManager(1).getRedis()
keys = ["buy1_volumn_latest_info-{}", "m_big_money_begin-{}", "m_big_money_process_index-{}"]
for k in keys:
- RedisUtils.delete(redis_l2, k.format(code))
+ RedisUtils.delete(redis_l2, k.format(code), auto_free=False)
+ redis_l2.connection_pool.disconnect()
l2.l2_data_manager.TradePointManager.delete_buy_point(code)
big_money_num_manager.reset(code)
- redis_trade = redis_manager.RedisManager(2).getRedis()
- RedisUtils.delete( redis_trade, "trade-state-{}".format(code))
+ RedisUtils.delete( redis_manager.RedisManager(2).getRedis(), "trade-state-{}".format(code))
trade_data_manager.placeordercountmanager.clear_place_order_count(code)
redis_info = redis_manager.RedisManager(0).getRedis()
- keys = RedisUtils.keys(redis_info, "*{}*".format(code))
+ keys = RedisUtils.keys(redis_info, "*{}*".format(code), auto_free=False)
for k in keys:
if k.find("pre") is not None:
continue
if k.find("zyltgb") is not None:
continue
- RedisUtils.delete(redis_info, k)
+ RedisUtils.delete(redis_info, k, auto_free=False)
+ redis_info.connection_pool.disconnect()
BuyL2SafeCountManager().clear_data(code)
transaction_progress.TradeBuyQueue().set_traded_index(code, 0)
--
Gitblit v1.8.0