diff --git a/test/test_init.py b/test/test_init.py index d9442b1..d6f32d1 100644 --- a/test/test_init.py +++ b/test/test_init.py @@ -14,12 +14,8 @@ def test_death(servers, helpers): helpers.wait_for(servers[13301].check_status, ['localhost:13302', 'suspect']) helpers.wait_for(servers[13301].check_status, ['localhost:13302', 'dead']) - assert servers[13301].conn.eval('return membership.mark_left("localhost:13302")')[0] - helpers.wait_for(servers[13301].check_status, ['localhost:13302', 'left']) - servers[13302].start() helpers.wait_for(servers[13302].connect) - assert servers[13301].conn.eval("return membership.init('localhost', 13302)")[0] helpers.wait_for(servers[13301].check_status, ['localhost:13302', 'alive']) helpers.wait_for(servers[13302].check_status, ['localhost:13301', 'alive']) diff --git a/test/test_quit.py b/test/test_quit.py index caffac7..36c094c 100644 --- a/test/test_quit.py +++ b/test/test_quit.py @@ -19,3 +19,7 @@ def test_rejoin(servers, helpers): assert servers[13302].conn.eval('return membership.init("localhost", 13302)')[0] assert servers[13301].add_member('localhost:13302') helpers.wait_for(servers[13301].check_status, ['localhost:13302', 'alive']) + +def test_mark_left(servers, helpers): + assert servers[13301].conn.eval('return membership.mark_left("localhost:13302")')[0] + helpers.wait_for(servers[13301].check_status, ['localhost:13302', 'left'])