test: add asan case
This commit is contained in:
parent
4cd660b3b1
commit
ecff9423bf
|
@ -687,9 +687,9 @@
|
||||||
,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqError.py
|
,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqError.py
|
||||||
,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/schema.py
|
,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/schema.py
|
||||||
,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/stbFilter.py
|
,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/stbFilter.py
|
||||||
,,,system-test,python3 ./test.py -f 7-tmq/tmqCheckData.py
|
,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqCheckData.py
|
||||||
,,,system-test,python3 ./test.py -f 7-tmq/tmqCheckData1.py
|
,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqCheckData1.py
|
||||||
,,,system-test,python3 ./test.py -f 7-tmq/tmqConsumerGroup.py
|
,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqConsumerGroup.py
|
||||||
,,,system-test,python3 ./test.py -f 7-tmq/tmqShow.py
|
,,,system-test,python3 ./test.py -f 7-tmq/tmqShow.py
|
||||||
,,,system-test,python3 ./test.py -f 7-tmq/tmqAlterSchema.py
|
,,,system-test,python3 ./test.py -f 7-tmq/tmqAlterSchema.py
|
||||||
,,,system-test,python3 ./test.py -f 7-tmq/tmqConsFromTsdb.py
|
,,,system-test,python3 ./test.py -f 7-tmq/tmqConsFromTsdb.py
|
||||||
|
|
|
@ -128,12 +128,12 @@ class TMQCom:
|
||||||
os.system(shellCmd)
|
os.system(shellCmd)
|
||||||
|
|
||||||
def stopTmqSimProcess(self, processorName):
|
def stopTmqSimProcess(self, processorName):
|
||||||
psCmd = "ps -ef|grep -w %s|grep -v grep | awk '{print $2}'"%(processorName)
|
psCmd = "unset LD_PRELOAD; ps -ef|grep -w %s|grep -v grep | awk '{print $2}'"%(processorName)
|
||||||
processID = subprocess.check_output(psCmd, shell=True).decode("utf-8")
|
processID = subprocess.check_output(psCmd, shell=True).decode("utf-8")
|
||||||
onlyKillOnceWindows = 0
|
onlyKillOnceWindows = 0
|
||||||
while(processID):
|
while(processID):
|
||||||
if not platform.system().lower() == 'windows' or (onlyKillOnceWindows == 0 and platform.system().lower() == 'windows'):
|
if not platform.system().lower() == 'windows' or (onlyKillOnceWindows == 0 and platform.system().lower() == 'windows'):
|
||||||
killCmd = "kill -INT %s > /dev/null 2>&1" % processID
|
killCmd = "unset LD_PRELOAD; kill -INT %s > /dev/null 2>&1" % processID
|
||||||
os.system(killCmd)
|
os.system(killCmd)
|
||||||
onlyKillOnceWindows = 1
|
onlyKillOnceWindows = 1
|
||||||
time.sleep(0.2)
|
time.sleep(0.2)
|
||||||
|
|
Loading…
Reference in New Issue