db/pg_probackup
db/pg_probackup
1
0
Fork 0
mirror of https://github.com/postgrespro/pg_probackup.git synced 2024-12-13 11:53:59 +02:00
Code Issues Releases Activity

Retry remote pull using ptrack

Browse Source
This commit is contained in:
Konstantin Knizhnik 2019-02-18 11:44:14 +03:00
parent 6f42781d58
commit 7e60de38db
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/data.c
View File

@ -593,6 +593,8 @@ backup_data_file(backup_files_arg* arguments,
int rc = fio_send_pages(in, out, file, int rc = fio_send_pages(in, out, file,
backup_mode == BACKUP_MODE_DIFF_DELTA && file->exists_in_prev ? prev_backup_start_lsn : InvalidXLogRecPtr, backup_mode == BACKUP_MODE_DIFF_DELTA && file->exists_in_prev ? prev_backup_start_lsn : InvalidXLogRecPtr,
&n_blocks_skipped, calg, clevel); &n_blocks_skipped, calg, clevel);
if (rc == PAGE_CHECKSUM_MISMATCH && is_ptrack_support)
goto RetryUsingPtrack;
if (rc < 0) if (rc < 0)
elog(ERROR, "Failed to read file %s: %s", elog(ERROR, "Failed to read file %s: %s",
file->path, rc == PAGE_CHECKSUM_MISMATCH ? "data file checksum mismatch" : strerror(-rc)); file->path, rc == PAGE_CHECKSUM_MISMATCH ? "data file checksum mismatch" : strerror(-rc));
@ -600,6 +602,7 @@ backup_data_file(backup_files_arg* arguments,
} }
else else
{ {
RetryUsingPtrack:
for (blknum = 0; blknum < nblocks; blknum++) for (blknum = 0; blknum < nblocks; blknum++)
{ {
page_state = prepare_page(arguments, file, prev_backup_start_lsn, page_state = prepare_page(arguments, file, prev_backup_start_lsn,