@@ -49,6 +49,10 @@ def test_ptrack_vacuum(self):
49
49
node .safe_psql ('postgres' , 'vacuum t_heap' )
50
50
node .safe_psql ('postgres' , 'checkpoint' )
51
51
52
+ # Make full backup to clean every ptrack
53
+ self .backup_node (
54
+ backup_dir , 'node' , node , options = ['-j10' , '--stream' ])
55
+
52
56
for i in idx_ptrack :
53
57
# get fork size and calculate it in pages
54
58
idx_ptrack [i ]['old_size' ] = self .get_fork_size (node , i )
@@ -57,11 +61,6 @@ def test_ptrack_vacuum(self):
57
61
# calculate md5sums for every page of this fork
58
62
idx_ptrack [i ]['old_pages' ] = self .get_md5_per_page_for_fork (
59
63
idx_ptrack [i ]['path' ], idx_ptrack [i ]['old_size' ])
60
-
61
- # Make full backup to clean every ptrack
62
- self .backup_node (
63
- backup_dir , 'node' , node , options = ['-j10' , '--stream' ])
64
- for i in idx_ptrack :
65
64
idx_ptrack [i ]['ptrack' ] = self .get_ptrack_bits_per_page_for_fork (
66
65
node , idx_ptrack [i ]['path' ], [idx_ptrack [i ]['old_size' ]])
67
66
self .check_ptrack_clean (idx_ptrack [i ], idx_ptrack [i ]['old_size' ])
@@ -158,11 +157,6 @@ def test_ptrack_vacuum_replica(self):
158
157
'--master-db=postgres' ,
159
158
'--master-port={0}' .format (master .port )])
160
159
161
- for i in idx_ptrack :
162
- idx_ptrack [i ]['ptrack' ] = self .get_ptrack_bits_per_page_for_fork (
163
- replica , idx_ptrack [i ]['path' ], [idx_ptrack [i ]['old_size' ]])
164
- self .check_ptrack_clean (idx_ptrack [i ], idx_ptrack [i ]['old_size' ])
165
-
166
160
for i in idx_ptrack :
167
161
# get fork size and calculate it in pages
168
162
idx_ptrack [i ]['old_size' ] = self .get_fork_size (replica , i )
@@ -171,6 +165,9 @@ def test_ptrack_vacuum_replica(self):
171
165
# calculate md5sums for every page of this fork
172
166
idx_ptrack [i ]['old_pages' ] = self .get_md5_per_page_for_fork (
173
167
idx_ptrack [i ]['path' ], idx_ptrack [i ]['old_size' ])
168
+ idx_ptrack [i ]['ptrack' ] = self .get_ptrack_bits_per_page_for_fork (
169
+ replica , idx_ptrack [i ]['path' ], [idx_ptrack [i ]['old_size' ]])
170
+ self .check_ptrack_clean (idx_ptrack [i ], idx_ptrack [i ]['old_size' ])
174
171
175
172
# Delete some rows, vacuum it and make checkpoint
176
173
master .safe_psql ('postgres' , 'delete from t_heap where id%2 = 1' )
0 commit comments