Merge branch 'td-18572' of https://github.com/taosdata/TDengine into td-18572
This commit is contained in:
charles
commit
ef7e9ccbbb
|
|
@ -0,0 +1,221 @@
|
|||
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())
|
||||
Loading…
Reference in New Issue