@@ -983,10 +983,6 @@ restore_data_file_new(parray *parent_chain, pgFile *dest_file, FILE *out, const
983
983
984
984
pgBackup * backup = (pgBackup * ) parray_get (parent_chain , i );
985
985
986
- /* check for interrupt */
987
- if (interrupted || thread_interrupted )
988
- elog (ERROR , "Interrupted during restore" );
989
-
990
986
/* lookup file in intermediate backup */
991
987
res_file = parray_bsearch (backup -> files , dest_file , pgFileCompareRelPathWithExternal );
992
988
tmp_file = (res_file ) ? * res_file : NULL ;
@@ -1050,6 +1046,10 @@ restore_data_file_internal(FILE *in, FILE *out, pgFile *file, uint32 backup_vers
1050
1046
DataPage page ;
1051
1047
int32 uncompressed_size = 0 ;
1052
1048
1049
+ /* check for interrupt */
1050
+ if (interrupted || thread_interrupted )
1051
+ elog (ERROR , "Interrupted during data file restore" );
1052
+
1053
1053
/* read BackupPageHeader */
1054
1054
read_len = fread (& header , 1 , sizeof (header ), in );
1055
1055
@@ -1207,6 +1207,10 @@ restore_non_data_file_internal(FILE *in, FILE *out, pgFile *file,
1207
1207
{
1208
1208
read_len = 0 ;
1209
1209
1210
+ /* check for interrupt */
1211
+ if (interrupted || thread_interrupted )
1212
+ elog (ERROR , "Interrupted during non-data file restore" );
1213
+
1210
1214
if ((read_len = fio_fread (in , buf , sizeof (buf ))) != sizeof (buf ))
1211
1215
break ;
1212
1216
0 commit comments