@@ -17,9 +17,8 @@ def test_locking_simple(self):
17
17
node = self .make_simple_node (
18
18
base_dir = os .path .join (module_name , fname , 'node' ),
19
19
initdb_params = ['--data-checksums' ],
20
- pg_options = {
21
- 'wal_level' : 'replica' }
22
- )
20
+ pg_options = {'wal_level' : 'replica' })
21
+
23
22
backup_dir = os .path .join (self .tmp_path , module_name , fname , 'backup' )
24
23
self .init_pb (backup_dir )
25
24
self .add_instance (backup_dir , 'node' , node )
@@ -28,5 +27,22 @@ def test_locking_simple(self):
28
27
29
28
self .backup_node (backup_dir , 'node' , node )
30
29
30
+ gdb = self .backup_node (
31
+ backup_dir , 'node' , node , gdb = True )
32
+
33
+ gdb .set_breakpoint ('copy_file' )
34
+ gdb .run_until_break ()
35
+
36
+ if gdb .continue_execution_until_break (20 ) != 'breakpoint-hit' :
37
+ self .AssertTrue (False , 'Failed to hit breakpoint' )
38
+
39
+ gdb ._execute ('signal SIGKILL' )
40
+
41
+ self .assertEqual (
42
+ 'OK' , self .show_pb (backup_dir , 'node' )[0 ]['status' ])
43
+
44
+ self .assertEqual (
45
+ 'ERROR' , self .show_pb (backup_dir , 'node' )[1 ]['status' ])
46
+
31
47
# Clean after yourself
32
48
self .del_test_dir (module_name , fname )
0 commit comments