xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

test: support for windows

This commit is contained in:
chenhaoran 2023-12-19 17:33:50 +08:00
parent 0dbbdd1d83
commit d819bb4bc1
1 changed files with 32 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
tests/system-test/7-tmq/tmq_offset.py
View File

@ -5,7 +5,7 @@ import time
import socket
import os
import threading
import platform
from util.log import *
from util.sql import *
from util.cases import *
@ -21,7 +21,25 @@ class TDTestCase:
tdSql.init(conn.cursor())
def run(self):
tdSql.prepare()
if platform.system().lower() == 'windows':
buildPath = tdCom.getBuildPath()
cmdStr1 = ' mintty -h never %s/build/bin/taosBenchmark -i 50 -B 1 -t 1000 -n 100000 -y '%(buildPath)
tdLog.info(cmdStr1)
os.system(cmdStr1)
time.sleep(15)
cmdStr2 = ' mintty -h never %s/build/bin/tmq_offset_test '%(buildPath)
tdLog.info(cmdStr2)
os.system(cmdStr2)
time.sleep(20)
# tdLog.info("ps -a | grep taos | awk \'{print $2}\' | xargs kill -9")
os.system('ps -a | grep taosBenchmark | awk \'{print $2}\' | xargs kill -9')
result = os.system('ps -a | grep tmq_offset_test | awk \'{print $2}\' | xargs kill -9')
if result != 0:
tdLog.exit("tmq_offset_test error!")
else:
buildPath = tdCom.getBuildPath()
cmdStr1 = '%s/build/bin/taosBenchmark -i 50 -B 1 -t 1000 -n 100000 -y &'%(buildPath)
tdLog.info(cmdStr1)
@ -31,7 +49,6 @@ class TDTestCase:
cmdStr2 = '%s/build/bin/tmq_offset_test &'%(buildPath)
tdLog.info(cmdStr2)
os.system(cmdStr2)
time.sleep(20)
os.system("kill -9 `pgrep taosBenchmark`")