@@ -11,7 +11,7 @@ class LockingTest(ProbackupTest, unittest.TestCase):
11
11
12
12
# @unittest.skip("skip")
13
13
# @unittest.expectedFailure
14
- def test_locking_simple (self ):
14
+ def test_locking_simple_1 (self ):
15
15
""""""
16
16
fname = self .id ().split ('.' )[3 ]
17
17
node = self .make_simple_node (
@@ -36,8 +36,6 @@ def test_locking_simple(self):
36
36
if gdb .continue_execution_until_break (20 ) != 'breakpoint-hit' :
37
37
self .AssertTrue (False , 'Failed to hit breakpoint' )
38
38
39
- gdb ._execute ('signal SIGKILL' )
40
-
41
39
self .validate_pb (backup_dir )
42
40
43
41
self .assertEqual (
@@ -46,5 +44,35 @@ def test_locking_simple(self):
46
44
self .assertEqual (
47
45
'ERROR' , self .show_pb (backup_dir , 'node' )[1 ]['status' ])
48
46
47
+ # Clean after yourself
48
+ self .del_test_dir (module_name , fname )
49
+
50
+ def test_locking_simple_2 (self ):
51
+ """"""
52
+ fname = self .id ().split ('.' )[3 ]
53
+ node = self .make_simple_node (
54
+ base_dir = os .path .join (module_name , fname , 'node' ),
55
+ initdb_params = ['--data-checksums' ],
56
+ pg_options = {'wal_level' : 'replica' })
57
+
58
+ backup_dir = os .path .join (self .tmp_path , module_name , fname , 'backup' )
59
+ self .init_pb (backup_dir )
60
+ self .add_instance (backup_dir , 'node' , node )
61
+ self .set_archiving (backup_dir , 'node' , node )
62
+ node .slow_start ()
63
+
64
+ self .backup_node (backup_dir , 'node' , node )
65
+
66
+ gdb = self .backup_node (
67
+ backup_dir , 'node' , node , gdb = True )
68
+
69
+ gdb .set_breakpoint ('copy_file' )
70
+ gdb .run_until_break ()
71
+
72
+ if gdb .continue_execution_until_break (20 ) != 'breakpoint-hit' :
73
+ self .AssertTrue (False , 'Failed to hit breakpoint' )
74
+
75
+ self .validate_pb (backup_dir )
76
+
49
77
# Clean after yourself
50
78
self .del_test_dir (module_name , fname )
0 commit comments