@@ -11,7 +11,7 @@ class LockingTest(ProbackupTest, unittest.TestCase):
1111
1212 # @unittest.skip("skip")
1313 # @unittest.expectedFailure
14- def test_locking_simple (self ):
14+ def test_locking_simple_1 (self ):
1515 """"""
1616 fname = self .id ().split ('.' )[3 ]
1717 node = self .make_simple_node (
@@ -36,8 +36,6 @@ def test_locking_simple(self):
3636 if gdb .continue_execution_until_break (20 ) != 'breakpoint-hit' :
3737 self .AssertTrue (False , 'Failed to hit breakpoint' )
3838
39- gdb ._execute ('signal SIGKILL' )
40-
4139 self .validate_pb (backup_dir )
4240
4341 self .assertEqual (
@@ -46,5 +44,35 @@ def test_locking_simple(self):
4644 self .assertEqual (
4745 'ERROR' , self .show_pb (backup_dir , 'node' )[1 ]['status' ])
4846
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+
4977 # Clean after yourself
5078 self .del_test_dir (module_name , fname )
0 commit comments