Commita0b40e3

committed

in/out test for raftable

1 parentc616219 commita0b40e3Copy full SHA for a0b40e3

File tree

+29

-0

lines changed

+29

-0

lines changed

Lines changed: 29 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -44,6 +44,35 @@ def test_1_node_disconnect(self):`
`44`	`44`	`# check we didn't stuck in set op`
`45`	`45`	`self.assertTrue(agg['setkey']['running_latency']<3)`
`46`	`46`
	`47`	`+deftest_1_node_in_node_out(self):`
	`48`	`+print('### InOutTest ###')`
	`49`	`+`
	`50`	`+subprocess.check_call(['blockade','partition','node3'])`
	`51`	`+print('Node3 disconnected')`
	`52`	`+`
	`53`	`+print('Waiting 5s')`
	`54`	`+time.sleep(5)`
	`55`	`+`
	`56`	`+forclientinself.clients:`
	`57`	`+agg=client.history.aggregate()`
	`58`	`+print(agg)`
	`59`	`+# check we didn't stuck in set op`
	`60`	`+self.assertTrue(agg['setkey']['running_latency']<3)`
	`61`	`+`
	`62`	`+subprocess.check_call(['blockade','join'])`
	`63`	`+print('Node3 connected')`
	`64`	`+`
	`65`	`+print('Waiting 5s')`
	`66`	`+time.sleep(5)`
	`67`	`+`
	`68`	`+forclientinself.clients:`
	`69`	`+agg=client.history.aggregate()`
	`70`	`+print(agg)`
	`71`	`+# check we didn't stuck in set op`
	`72`	`+self.assertTrue(agg['setkey']['running_latency']<3)`
	`73`	`+`
	`74`	`+`
	`75`	`+`
`47`	`76`	`if__name__=='__main__':`
`48`	`77`	`unittest.main()`
`49`	`78`

Comments

(0)