From c50168a25481b3a94f1f65ec8cccf40c26c312b3 Mon Sep 17 00:00:00 2001 From: Charles Date: Wed, 15 Nov 2023 10:14:04 +0800 Subject: [PATCH] Delete tests/system-test/0-others/test_hot_refresh_configrations.py --- .../test_hot_refresh_configrations.py | 221 ------------------ 1 file changed, 221 deletions(-) delete mode 100644 tests/system-test/0-others/test_hot_refresh_configrations.py diff --git a/tests/system-test/0-others/test_hot_refresh_configrations.py b/tests/system-test/0-others/test_hot_refresh_configrations.py deleted file mode 100644 index ca721140a4..0000000000 --- a/tests/system-test/0-others/test_hot_refresh_configrations.py +++ /dev/null @@ -1,221 +0,0 @@ -import subprocess -import random -import time -import os - -from util.log import * -from util.sql import * -from util.cases import * -from util.dnodes import * -from util.common import * - - -class TDTestCase: - """This test case is used to veirfy hot refresh configurations - """ - def init(self, conn, logSql, replicaVar=1): - self.replicaVar = int(replicaVar) - tdLog.debug(f"start to excute {__file__}") - tdSql.init(conn.cursor()) - - self.configration_dic = { - "cli": [ - { - "name": "keepAliveIdle", - "values": [1, 100, 7200000], - "except_values": [0, 7200001] - }, - { - "name": "queryPolicy", - "values": [1, 2, 4], - "except_values": [0, 5] - }, - { - "name": "numOfLogLines", - "values": [1000, 2000, 2000000000], - "except_values": [999, 2000000001] - }, - { - "name": "logKeepDays", - "values": [-365000, 2000, 365000], - "except_values": [-365001, 365001] - } - ], - "svr": [ - { - "name": "keepAliveIdle", - "alias": "tsKeepAliveIdle", - "values": [1, 100, 7200000], - "except_values": [0, 7200001] - }, - { - "name": "mndSdbWriteDelta", - "alias": "tsMndSdbWriteDelta", - "values": [20, 1000, 10000], - "except_values": [19, 10001] - }, - { - "name": "enableWhiteList", - "alias": "tsEnableWhiteList", - "values": [0, 1], - "except_values": [-1, 2] - }, - { - "name": "audit", - "alias": "tsEnableAudit", - "values": [0, 1], - "except_values": [-1, 2] - }, - { - "name": "telemetryReporting", - "alias": "tsEnableTelem", - "values": [0, 1], - "except_values": [-1, 2] - }, - { - "name": "cacheLazyLoadThreshold", - "alias": "tsCacheLazyLoadThreshold", - "values": [0, 200, 100000], - "except_values": [-1, 100001] - }, - { - "name": "queryRspPolicy", - "alias": "tsQueryRspPolicy", - "values": [0, 1], - "except_values": [-1, 2] - }, - { - "name": "ttlFlushThreshold", - "alias": "tsTtlFlushThreshold", - "values": [-1, 200, 1000000], - "except_values": [-2, 1000001] - }, - { - "name": "timeseriesThreshold", - "alias": "tsTimeSeriesThreshold", - "values": [0, 200, 2000], - "except_values": [-2, 2001] - }, - { - "name": "minDiskFreeSize", - "alias": "tsMinDiskFreeSize", - "values": ["51200K", "100M", "1G"], - "except_values": ["1024K", "1.1G", "1T"] - }, - { - "name": "tmqMaxTopicNum", - "alias": "tmqMaxTopicNum", - "values": [1, 1000, 10000], - "except_values": [0, 10001] - }, - { - "name": "transPullupInterval", - "alias": "tsTransPullupInterval", - "values": [1, 1000, 10000], - "except_values": [0, 10001] - }, - { - "name": "mqRebalanceInterval", - "alias": "tsMqRebalanceInterval", - "values": [1, 1000, 10000], - "except_values": [0, 10001] - }, - { - "name": "checkpointInterval", - "alias": "tsStreamCheckpointInterval", - "values": [60, 1000, 1200], - "except_values": [59, 1201] - }, - { - "name": "trimVDbIntervalSec", - "alias": "tsTrimVDbIntervalSec", - "values": [1, 1000, 100000], - "except_values": [0, 100001] - }, - { - "name": "disableStream", - "alias": "tsDisableStream", - "values": [0, 1], - "except_values": [-1] - }, - { - "name": "maxStreamBackendCache", - "alias": "tsMaxStreamBackendCache", - "values": [16, 512, 1024], - "except_values": [15, 1025] - }, - { - "name": "numOfLogLines", - "alias": "tsNumOfLogLines", - "values": [1000, 50000, 2000000000], - "except_values": [999, 2000000001] - }, - { - "name": "logKeepDays", - "alias": "tsLogKeepDays", - "values": [-365000, 10, 365000], - "except_values": [-365001, 365001] - } - ] - } - - def get_param_value_with_gdb(self, config_name, process_name): - res = subprocess.Popen("gdb -q -nx -p `pidof {}` --batch -ex 'set height 0' -ex 'p {}'".format(process_name, config_name), shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE) - r_lines = res.stdout.read() - if r_lines: - for line in r_lines.decode().split("\n"): - if "$1 = " in line: - tdLog.debug("gdb result: {}".format(line)) - return line.split(" = ")[1] - - def cli_check(self, name, values, except_values=False): - if not except_values: - for v in values: - tdLog.debug("Set {} to {}".format(name, v)) - tdSql.execute(f'alter local "{name} {v}";') - else: - for v in values: - tdLog.debug("Set {} to {}".format(name, v)) - tdSql.error(f'alter local "{name} {v}";') - - def svr_check(self, name, alias, values, except_values=False): - p_list = ["dnode 1", "all dnodes"] - # check bool param value - if len(values) == 2 and [0, 1] == values and name != "queryRspPolicy": - is_bool = True - else: - is_bool = False - tdLog.debug(f"{name} is_bool: {is_bool}") - if not except_values: - for v in values: - dnode = random.choice(p_list) - tdSql.execute(f'alter {dnode} "{name} {v}";') - value = self.get_param_value_with_gdb(alias, "taosd") - tdLog.debug(f"value: {value}") - assert(value == str(bool(v)).lower() if is_bool else str(v)) - else: - for v in values: - dnode = random.choice(p_list) - tdSql.error(f'alter {dnode} "{name} {v}";') - - def run(self): - for key in self.configration_dic: - if "cli" == key: - for item in self.configration_dic[key]: - self.cli_check(item["name"], item["values"]) - if "except_values" in item: - self.cli_check(item["name"], item["except_values"], True) - elif "svr" == key: - for item in self.configration_dic[key]: - self.svr_check(item["name"], item["alias"], item["values"]) - if "except_values" in item: - self.svr_check(item["name"], item["alias"], item["except_values"], True) - else: - raise Exception(f"unknown key: {key}") - - def stop(self): - tdSql.close() - tdLog.success(f"{__file__} successfully executed") - -tdCases.addLinux(__file__, TDTestCase()) -tdCases.addWindows(__file__, TDTestCase())