Location via proxy:   [ UP ]  
[Report a bug]   [Manage cookies]                
Skip to content

Commit aa0e465

Browse files
committed
tests for PGPRO-1014
1 parent de46a7f commit aa0e465

File tree

2 files changed

+26
-0
lines changed

2 files changed

+26
-0
lines changed

tests2/lib/failure_injector.py

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -63,6 +63,19 @@ def stop(self):
6363
self.docker_api.containers.get(self.node).start()
6464

6565

66+
class FreezeNode(FailureInjector):
67+
68+
def __init__(self, node):
69+
self.node = node
70+
super().__init__()
71+
72+
def start(self):
73+
self.docker_api.containers.get(self.node).pause()
74+
75+
def stop(self):
76+
self.docker_api.containers.get(self.node).unpause()
77+
78+
6679
class CrashRecoverNode(FailureInjector):
6780

6881
def __init__(self, node):

tests2/test_recovery.py

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -120,6 +120,19 @@ def test_node_crash(self):
120120
self.assertCommits(aggs)
121121
self.assertIsolation(aggs)
122122

123+
# def test_node_pause(self):
124+
# print('### test_node_pause ###')
125+
126+
# aggs_failure, aggs = self.performFailure(FreezeNode('node3'),
127+
# node_wait_for_commit=2, stop_load=True)
128+
129+
# self.assertCommits(aggs_failure[:2])
130+
# self.assertNoCommits(aggs_failure[2:])
131+
# self.assertIsolation(aggs_failure)
132+
133+
# self.assertCommits(aggs)
134+
# self.assertIsolation(aggs)
135+
123136
def test_node_bicrash(self):
124137
print('### test_node_bicrash ###')
125138

0 commit comments

Comments
 (0)