test: add asan case
This commit is contained in:
parent
b93e2afa57
commit
991795ca6e
|
@ -617,8 +617,8 @@
|
||||||
,,y,system-test,./pytest.sh python3 ./test.py -f 1-insert/delete_childtable.py
|
,,y,system-test,./pytest.sh python3 ./test.py -f 1-insert/delete_childtable.py
|
||||||
,,y,system-test,./pytest.sh python3 ./test.py -f 1-insert/delete_normaltable.py
|
,,y,system-test,./pytest.sh python3 ./test.py -f 1-insert/delete_normaltable.py
|
||||||
,,y,system-test,./pytest.sh python3 ./test.py -f 1-insert/keep_expired.py
|
,,y,system-test,./pytest.sh python3 ./test.py -f 1-insert/keep_expired.py
|
||||||
,,,system-test,python3 ./test.py -f 1-insert/drop.py
|
,,y,system-test,./pytest.sh python3 ./test.py -f 1-insert/drop.py
|
||||||
,,,system-test,python3 ./test.py -f 1-insert/drop.py -N 3 -M 3 -i False -n 3
|
,,y,system-test,./pytest.sh python3 ./test.py -f 1-insert/drop.py -N 3 -M 3 -i False -n 3
|
||||||
,,y,system-test,./pytest.sh python3 ./test.py -f 2-query/join2.py
|
,,y,system-test,./pytest.sh python3 ./test.py -f 2-query/join2.py
|
||||||
,,y,system-test,./pytest.sh python3 ./test.py -f 2-query/union1.py
|
,,y,system-test,./pytest.sh python3 ./test.py -f 2-query/union1.py
|
||||||
,,y,system-test,./pytest.sh python3 ./test.py -f 2-query/concat2.py
|
,,y,system-test,./pytest.sh python3 ./test.py -f 2-query/concat2.py
|
||||||
|
|
|
@ -311,6 +311,12 @@ class TDDnode:
|
||||||
if platform.system().lower() == 'windows':
|
if platform.system().lower() == 'windows':
|
||||||
cmd = "mintty -h never %s -c %s" % (
|
cmd = "mintty -h never %s -c %s" % (
|
||||||
binPath, self.cfgDir)
|
binPath, self.cfgDir)
|
||||||
|
else:
|
||||||
|
if self.asan:
|
||||||
|
asanDir = "%s/sim/asan/dnode%d.asan" % (
|
||||||
|
self.path, self.index)
|
||||||
|
cmd = "nohup %s -c %s > /dev/null 2> %s & " % (
|
||||||
|
binPath, self.cfgDir, asanDir)
|
||||||
else:
|
else:
|
||||||
cmd = "nohup %s -c %s > /dev/null 2>&1 & " % (
|
cmd = "nohup %s -c %s > /dev/null 2>&1 & " % (
|
||||||
binPath, self.cfgDir)
|
binPath, self.cfgDir)
|
||||||
|
@ -748,7 +754,7 @@ class TDDnodes:
|
||||||
tdLog.exit("index:%d should on a scale of [1, 10]" % (index))
|
tdLog.exit("index:%d should on a scale of [1, 10]" % (index))
|
||||||
|
|
||||||
def StopAllSigint(self):
|
def StopAllSigint(self):
|
||||||
tdLog.info("stop all dnodes sigint")
|
tdLog.info("stop all dnodes sigint, asan:%d" % self.asan)
|
||||||
if self.asan:
|
if self.asan:
|
||||||
tdLog.info("execute script: %s" % self.stopDnodesSigintPath)
|
tdLog.info("execute script: %s" % self.stopDnodesSigintPath)
|
||||||
os.system(self.stopDnodesSigintPath)
|
os.system(self.stopDnodesSigintPath)
|
||||||
|
@ -756,7 +762,7 @@ class TDDnodes:
|
||||||
return
|
return
|
||||||
|
|
||||||
def stopAll(self):
|
def stopAll(self):
|
||||||
tdLog.info("stop all dnodes")
|
tdLog.info("stop all dnodes, asan:%d" % self.asan)
|
||||||
if self.asan:
|
if self.asan:
|
||||||
tdLog.info("execute script: %s" % self.stopDnodesPath)
|
tdLog.info("execute script: %s" % self.stopDnodesPath)
|
||||||
os.system(self.stopDnodesPath)
|
os.system(self.stopDnodesPath)
|
||||||
|
|
|
@ -464,6 +464,7 @@ if __name__ == "__main__":
|
||||||
tdDnodes.init(deployPath, masterIp)
|
tdDnodes.init(deployPath, masterIp)
|
||||||
tdDnodes.setTestCluster(testCluster)
|
tdDnodes.setTestCluster(testCluster)
|
||||||
tdDnodes.setValgrind(valgrind)
|
tdDnodes.setValgrind(valgrind)
|
||||||
|
tdDnodes.setAsan(asan)
|
||||||
tdDnodes.stopAll()
|
tdDnodes.stopAll()
|
||||||
for dnode in tdDnodes.dnodes:
|
for dnode in tdDnodes.dnodes:
|
||||||
tdDnodes.deploy(dnode.index,{})
|
tdDnodes.deploy(dnode.index,{})
|
||||||
|
|
Loading…
Reference in New Issue