test: test ci
This commit is contained in:
parent
2978b33e01
commit
2a5e665f3b
|
@ -37,17 +37,17 @@ class TDSimClient:
|
||||||
"charset": "UTF-8",
|
"charset": "UTF-8",
|
||||||
"asyncLog": "0",
|
"asyncLog": "0",
|
||||||
"rpcDebugFlag": "135",
|
"rpcDebugFlag": "135",
|
||||||
"tmrDebugFlag": "135",
|
"tmrDebugFlag": "131",
|
||||||
"dDebugFlag":"135",
|
"dDebugFlag":"131",
|
||||||
"cDebugFlag": "135",
|
"cDebugFlag": "131",
|
||||||
"uDebugFlag": "135",
|
"uDebugFlag": "131",
|
||||||
"jniDebugFlag": "135",
|
"jniDebugFlag": "131",
|
||||||
"qDebugFlag": "135",
|
"qDebugFlag": "135",
|
||||||
"supportVnodes": "1024",
|
"supportVnodes": "1024",
|
||||||
"enableQueryHb": "1",
|
"enableQueryHb": "1",
|
||||||
"telemetryReporting": "0",
|
"telemetryReporting": "0",
|
||||||
"tqDebugflag": "135",
|
"tqDebugflag": "135",
|
||||||
"wDebugflag":"135",
|
"stDebugflag":"135",
|
||||||
}
|
}
|
||||||
|
|
||||||
def getLogDir(self):
|
def getLogDir(self):
|
||||||
|
@ -130,21 +130,21 @@ class TDDnode:
|
||||||
"maxShellConns": "30000",
|
"maxShellConns": "30000",
|
||||||
"locale": "en_US.UTF-8",
|
"locale": "en_US.UTF-8",
|
||||||
"charset": "UTF-8",
|
"charset": "UTF-8",
|
||||||
"asyncLog": "135",
|
"asyncLog": "0",
|
||||||
"mDebugFlag": "135",
|
"mDebugFlag": "135",
|
||||||
"dDebugFlag": "135",
|
"dDebugFlag": "131",
|
||||||
"vDebugFlag": "135",
|
"vDebugFlag": "131",
|
||||||
"tqDebugFlag": "135",
|
"tqDebugFlag": "135",
|
||||||
"cDebugFlag": "135",
|
"cDebugFlag": "131",
|
||||||
"stDebugFlag": "135",
|
"stDebugFlag": "135",
|
||||||
"smaDebugFlag": "135",
|
"smaDebugFlag": "131",
|
||||||
"jniDebugFlag": "135",
|
"jniDebugFlag": "131",
|
||||||
"qDebugFlag": "135",
|
"qDebugFlag": "131",
|
||||||
"rpcDebugFlag": "135",
|
"rpcDebugFlag": "135",
|
||||||
"tmrDebugFlag": "135",
|
"tmrDebugFlag": "131",
|
||||||
"uDebugFlag": "135",
|
"uDebugFlag": "131",
|
||||||
"sDebugFlag": "135",
|
"sDebugFlag": "131",
|
||||||
"wDebugFlag": "135",
|
"wDebugFlag": "131",
|
||||||
"numOfLogLines": "100000000",
|
"numOfLogLines": "100000000",
|
||||||
"statusInterval": "1",
|
"statusInterval": "1",
|
||||||
"enableQueryHb": "1",
|
"enableQueryHb": "1",
|
||||||
|
|
|
@ -177,21 +177,15 @@ class TDTestCase:
|
||||||
if stopRole == "mnode":
|
if stopRole == "mnode":
|
||||||
for i in range(mnodeNums):
|
for i in range(mnodeNums):
|
||||||
tdDnodes[i].stoptaosd()
|
tdDnodes[i].stoptaosd()
|
||||||
# sleep(10)
|
|
||||||
tdDnodes[i].starttaosd()
|
tdDnodes[i].starttaosd()
|
||||||
# sleep(10)
|
|
||||||
elif stopRole == "vnode":
|
elif stopRole == "vnode":
|
||||||
for i in range(vnodeNumbers):
|
for i in range(vnodeNumbers):
|
||||||
tdDnodes[i+mnodeNums].stoptaosd()
|
tdDnodes[i+mnodeNums].stoptaosd()
|
||||||
# sleep(10)
|
|
||||||
tdDnodes[i+mnodeNums].starttaosd()
|
tdDnodes[i+mnodeNums].starttaosd()
|
||||||
# sleep(10)
|
|
||||||
elif stopRole == "dnode":
|
elif stopRole == "dnode":
|
||||||
for i in range(dnodeNumbers):
|
for i in range(dnodeNumbers):
|
||||||
tdDnodes[i].stoptaosd()
|
tdDnodes[i].stoptaosd()
|
||||||
# sleep(10)
|
|
||||||
tdDnodes[i].starttaosd()
|
tdDnodes[i].starttaosd()
|
||||||
# sleep(10)
|
|
||||||
|
|
||||||
# dnodeNumbers don't include database of schema
|
# dnodeNumbers don't include database of schema
|
||||||
if clusterComCheck.checkDnodes(dnodeNumbers):
|
if clusterComCheck.checkDnodes(dnodeNumbers):
|
||||||
|
@ -219,7 +213,7 @@ class TDTestCase:
|
||||||
tdSql.checkRows(rowsPerStb)
|
tdSql.checkRows(rowsPerStb)
|
||||||
def run(self):
|
def run(self):
|
||||||
# print(self.master_dnode.cfgDict)
|
# print(self.master_dnode.cfgDict)
|
||||||
self.fiveDnodeThreeMnode(dnodeNumbers=6,mnodeNums=3,restartNumbers=2,stopRole='dnode')
|
self.fiveDnodeThreeMnode(dnodeNumbers=6,mnodeNums=3,restartNumbers=1,stopRole='dnode')
|
||||||
|
|
||||||
def stop(self):
|
def stop(self):
|
||||||
tdSql.close()
|
tdSql.close()
|
||||||
|
|
|
@ -227,7 +227,7 @@ class TDTestCase:
|
||||||
|
|
||||||
def run(self):
|
def run(self):
|
||||||
# print(self.master_dnode.cfgDict)
|
# print(self.master_dnode.cfgDict)
|
||||||
self.fiveDnodeThreeMnode(dnodeNumbers=6,mnodeNums=3,restartNumbers=2,stopRole='dnode')
|
self.fiveDnodeThreeMnode(dnodeNumbers=6,mnodeNums=3,restartNumbers=1,stopRole='dnode')
|
||||||
|
|
||||||
def stop(self):
|
def stop(self):
|
||||||
tdSql.close()
|
tdSql.close()
|
||||||
|
|
|
@ -168,7 +168,7 @@ class TDTestCase:
|
||||||
|
|
||||||
def run(self):
|
def run(self):
|
||||||
# print(self.master_dnode.cfgDict)
|
# print(self.master_dnode.cfgDict)
|
||||||
self.fiveDnodeThreeMnode(dnodeNumbers=5,mnodeNums=3,restartNumbers=2,stopRole='dnode')
|
self.fiveDnodeThreeMnode(dnodeNumbers=5,mnodeNums=3,restartNumbers=1,stopRole='dnode')
|
||||||
|
|
||||||
def stop(self):
|
def stop(self):
|
||||||
tdSql.close()
|
tdSql.close()
|
||||||
|
|
|
@ -170,7 +170,7 @@ class TDTestCase:
|
||||||
|
|
||||||
def run(self):
|
def run(self):
|
||||||
# print(self.master_dnode.cfgDict)
|
# print(self.master_dnode.cfgDict)
|
||||||
self.fiveDnodeThreeMnode(dnodeNumbers=6,mnodeNums=3,restartNumbers=4,stopRole='mnode')
|
self.fiveDnodeThreeMnode(dnodeNumbers=6,mnodeNums=3,restartNumbers=2,stopRole='mnode')
|
||||||
|
|
||||||
def stop(self):
|
def stop(self):
|
||||||
tdSql.close()
|
tdSql.close()
|
||||||
|
|
|
@ -93,7 +93,7 @@ class TDTestCase:
|
||||||
# seperate vnode and mnode in different dnodes.
|
# seperate vnode and mnode in different dnodes.
|
||||||
# create database and stable
|
# create database and stable
|
||||||
stopcount =0
|
stopcount =0
|
||||||
while stopcount <= 2:
|
while stopcount <= 1:
|
||||||
tdLog.info(" restart loop: %d"%stopcount )
|
tdLog.info(" restart loop: %d"%stopcount )
|
||||||
for i in range(dnodenumbers):
|
for i in range(dnodenumbers):
|
||||||
tdDnodes[i].stoptaosd()
|
tdDnodes[i].stoptaosd()
|
||||||
|
|
Loading…
Reference in New Issue