Commit0d498a4

committed

add another test for referee

1 parentca2876a commit0d498a4Copy full SHA for 0d498a4

File tree

+56

-1

lines changed

+56

-1

lines changed

Lines changed: 27 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -81,3 +81,30 @@ class SkewTime(FailureInjector):`
`81`	`81`	`def__init__(self,node):`
`82`	`82`	`self.node=node`
`83`	`83`	`super().__init__()`
	`84`	`+`
	`85`	`+classStopNode(FailureInjector):`
	`86`	`+`
	`87`	`+def__init__(self,node):`
	`88`	`+self.node=node`
	`89`	`+super().__init__()`
	`90`	`+`
	`91`	`+# XXX: Is it really a good idea to call cli.stop inside method called start?`
	`92`	`+defstart(self):`
	`93`	`+self.docker_api.stop(self.node)`
	`94`	`+`
	`95`	`+defstop(self):`
	`96`	`+return`
	`97`	`+`
	`98`	`+`
	`99`	`+classStartNode(FailureInjector):`
	`100`	`+`
	`101`	`+def__init__(self,node):`
	`102`	`+self.node=node`
	`103`	`+super().__init__()`
	`104`	`+`
	`105`	`+# XXX: Is it really a good idea to call cli.stop inside method called start?`
	`106`	`+defstart(self):`
	`107`	`+return`
	`108`	`+`
	`109`	`+defstop(self):`
	`110`	`+self.docker_api.start(self.node)`

Lines changed: 29 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -14,7 +14,7 @@`
`14`	`14`	`fromlib.test_helperimport*`
`15`	`15`
`16`	`16`
`17`		`-classMajorTest(unittest.TestCase,TestHelper):`
	`17`	`+classRefereeTest(unittest.TestCase,TestHelper):`
`18`	`18`
`19`	`19`	`@classmethod`
`20`	`20`	`defsetUpClass(cls):`
`@@ -108,6 +108,34 @@ def test_double_failure_referee(self):`
`108`	`108`	`self.assertIsolation(aggs)`
`109`	`109`
`110`	`110`
	`111`	`+deftest_winner_restart(self):`
	`112`	`+print('### test_winner_restart ###')`
	`113`	`+`
	`114`	`+aggs_failure,aggs=self.performFailure(StopNode('node1'))`
	`115`	`+`
	`116`	`+self.assertNoCommits(aggs_failure[:1])`
	`117`	`+self.assertCommits(aggs_failure[1:])`
	`118`	`+self.assertIsolation(aggs_failure)`
	`119`	`+`
	`120`	`+self.assertNoCommits(aggs[:1])`
	`121`	`+self.assertCommits(aggs[1:])`
	`122`	`+self.assertIsolation(aggs)`
	`123`	`+`
	`124`	`+aggs_failure,aggs=self.performFailure(RestartNode('node2'))`
	`125`	`+`
	`126`	`+self.assertNoCommits(aggs_failure)`
	`127`	`+self.assertIsolation(aggs_failure)`
	`128`	`+`
	`129`	`+self.assertNoCommits(aggs[:1])`
	`130`	`+self.assertCommits(aggs[1:])`
	`131`	`+self.assertIsolation(aggs)`
	`132`	`+`
	`133`	`+# need to start node1 to perform consequent tests`
	`134`	`+docker_api=docker.Client()`
	`135`	`+docker_api.start('node1')`
	`136`	`+time.sleep(20)`
	`137`	`+`
	`138`	`+`
`111`	`139`	`if__name__=='__main__':`
`112`	`140`	`unittest.main()`
`113`	`141`

Comments

(0)