modify checkdnodes error
This commit is contained in:
parent
b1c08fac47
commit
8c53e28da9
|
@ -68,6 +68,8 @@ class TDTestCase(TBase):
|
||||||
tdSql.checkData(0, 0, leader_status)
|
tdSql.checkData(0, 0, leader_status)
|
||||||
|
|
||||||
sc.dnodeStop(3)
|
sc.dnodeStop(3)
|
||||||
|
while 1:
|
||||||
|
if clusterComCheck.checkDnodes(4): break
|
||||||
while 1:
|
while 1:
|
||||||
leader_status = clusterComCheck.check_vgroups_status_with_offline(vgroup_numbers=self.vgroupNum, db_replica=self.replicaVar)
|
leader_status = clusterComCheck.check_vgroups_status_with_offline(vgroup_numbers=self.vgroupNum, db_replica=self.replicaVar)
|
||||||
if leader_status >= 0: break
|
if leader_status >= 0: break
|
||||||
|
@ -76,6 +78,8 @@ class TDTestCase(TBase):
|
||||||
tdSql.checkData(0, 0, leader_status)
|
tdSql.checkData(0, 0, leader_status)
|
||||||
|
|
||||||
sc.dnodeStop(2)
|
sc.dnodeStop(2)
|
||||||
|
while 1:
|
||||||
|
if clusterComCheck.checkDnodes(3): break
|
||||||
while 1:
|
while 1:
|
||||||
leader_status = clusterComCheck.check_vgroups_status_with_offline(vgroup_numbers=self.vgroupNum, db_replica=self.replicaVar)
|
leader_status = clusterComCheck.check_vgroups_status_with_offline(vgroup_numbers=self.vgroupNum, db_replica=self.replicaVar)
|
||||||
if leader_status >= 0: break
|
if leader_status >= 0: break
|
||||||
|
|
|
@ -44,7 +44,7 @@ class ClusterComCheck:
|
||||||
tdSql.query("select * from information_schema.ins_dnodes")
|
tdSql.query("select * from information_schema.ins_dnodes")
|
||||||
# tdLog.debug(tdSql.res)
|
# tdLog.debug(tdSql.res)
|
||||||
status=0
|
status=0
|
||||||
for i in range(dnodeNumbers):
|
for i in range(len(tdSql.res)):
|
||||||
if tdSql.res[i][4] == "ready":
|
if tdSql.res[i][4] == "ready":
|
||||||
status+=1
|
status+=1
|
||||||
# tdLog.info(status)
|
# tdLog.info(status)
|
||||||
|
|
Loading…
Reference in New Issue