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

fix multi-thread cases.

This commit is contained in:
Shuduo Sang 2020-06-05 13:53:30 +08:00
parent ab47133213
commit 34a14a87fe
2 changed files with 12 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tests/pytest/random-test/random-test-multi-threading-3.py
View File

@ -179,15 +179,16 @@ class Test (threading.Thread):
tdDnodes.forcestop(1) tdDnodes.forcestop(1)
tdDnodes.deploy(1) tdDnodes.deploy(1)
tdDnodes.start(1)
tdSql.prepare()
last_tb = "" last_tb = ""
last_stb = "" last_stb = ""
written = 0 written = 0
tdDnodes.start(1)
tdSql.prepare()
def delete_datafiles(self): def delete_datafiles(self):
tdLog.info("delete_data_files") tdLog.info("delete_data_files")
global last_tb global last_tb
global last_stb
global written global written
dnodesDir = tdDnodes.getDnodesRootDir() dnodesDir = tdDnodes.getDnodesRootDir()
@ -195,10 +196,11 @@ class Test (threading.Thread):
deleteCmd = 'rm -rf %s' % dataDir deleteCmd = 'rm -rf %s' % dataDir
os.system(deleteCmd) os.system(deleteCmd)
last_tb = ""
written = 0
tdDnodes.start(1) tdDnodes.start(1)
tdSql.prepare() tdSql.prepare()
last_tb = ""
last_stb = ""
written = 0
def run(self): def run(self):
dataOp = { dataOp = {

10
tests/pytest/random-test/random-test-multi-threading.py
View File

@ -181,15 +181,16 @@ class Test (threading.Thread):
tdDnodes.forcestop(1) tdDnodes.forcestop(1)
tdDnodes.deploy(1) tdDnodes.deploy(1)
tdDnodes.start(1)
tdSql.prepare()
last_tb = "" last_tb = ""
last_stb = "" last_stb = ""
written = 0 written = 0
tdDnodes.start(1)
tdSql.prepare()
def delete_datafiles(self): def delete_datafiles(self):
tdLog.info("delete_data_files") tdLog.info("delete_data_files")
global last_tb global last_tb
global last_stb
global written global written
dnodesDir = tdDnodes.getDnodesRootDir() dnodesDir = tdDnodes.getDnodesRootDir()
@ -197,11 +198,12 @@ class Test (threading.Thread):
deleteCmd = 'rm -rf %s' % dataDir deleteCmd = 'rm -rf %s' % dataDir
os.system(deleteCmd) os.system(deleteCmd)
last_tb = ""
written = 0
tdDnodes.start(1) tdDnodes.start(1)
tdLog.sleep(10) tdLog.sleep(10)
tdSql.prepare() tdSql.prepare()
last_tb = ""
last_stb = ""
written = 0
def run(self): def run(self):
dataOp = { dataOp = {