@@ -1412,48 +1412,52 @@ calc_file_checksum(pgFile *file)
14121412 return true;
14131413}
14141414
1415- /* Validate given page
1416- * return value:
1415+ /*
1416+ * Validate given page.
1417+ *
1418+ * Returns value:
14171419 * 0 - if the page is not found
14181420 * 1 - if the page is found and valid
14191421 * -1 - if the page is found but invalid
14201422 */
14211423#define PAGE_IS_NOT_FOUND 0
14221424#define PAGE_IS_FOUND_AND_VALID 1
1423- #define PAGE_IS_FOUND_AND__NOT_VALID -1
1425+ #define PAGE_IS_FOUND_AND_NOT_VALID -1
14241426static int
14251427validate_one_page (Page page , pgFile * file ,
14261428 BlockNumber blknum , XLogRecPtr stop_lsn ,
14271429 uint32 checksum_version )
14281430{
14291431 PageHeader phdr ;
1430- XLogRecPtr lsn ;
1431- bool page_header_is_sane = false;
1432- bool checksum_is_ok = false;
1432+ XLogRecPtr lsn ;
1433+ bool page_header_is_sane = false;
1434+ bool checksum_is_ok = false;
14331435
14341436 /* new level of paranoia */
14351437 if (page == NULL )
14361438 {
1437- elog (LOG , "File %s, block %u, page is NULL" ,
1438- file -> path , blknum );
1439- return PAGE_IS_NOT_FOUND ;
1439+ elog (LOG , "File \"%s\", block %u, page is NULL" , file -> path , blknum );
1440+ return PAGE_IS_NOT_FOUND ;
14401441 }
14411442
1443+ phdr = (PageHeader ) page ;
1444+
14421445 if (PageIsNew (page ))
14431446 {
1444- int i ;
1447+ int i ;
1448+
14451449 /* Check if the page is zeroed. */
14461450 for (i = 0 ; i < BLCKSZ && page [i ] == 0 ; i ++ );
14471451
14481452 if (i == BLCKSZ )
14491453 {
1450- elog (LOG , "File: %s blknum %u, page is New. empty zeroed page" ,
1454+ elog (LOG , "File: %s blknum %u, page is New, empty zeroed page" ,
14511455 file -> path , blknum );
14521456 return PAGE_IS_FOUND_AND_VALID ;
14531457 }
14541458 else
14551459 {
1456- elog (WARNING , "File: %s, block %u, page is New, but not zeroed" ,
1460+ elog (WARNING , "File: %s blknum %u, page is New, but not zeroed" ,
14571461 file -> path , blknum );
14581462 }
14591463
@@ -1462,8 +1466,6 @@ validate_one_page(Page page, pgFile *file,
14621466 }
14631467 else
14641468 {
1465- phdr = (PageHeader ) page ;
1466-
14671469 if (PageGetPageSize (phdr ) == BLCKSZ &&
14681470 PageGetPageLayoutVersion (phdr ) == PG_PAGE_LAYOUT_VERSION &&
14691471 (phdr -> pd_flags & ~PD_VALID_FLAG_BITS ) == 0 &&
@@ -1478,7 +1480,7 @@ validate_one_page(Page page, pgFile *file,
14781480 if (page_header_is_sane )
14791481 {
14801482 /* Verify checksum */
1481- if (checksum_version )
1483+ if (checksum_version )
14821484 {
14831485 /*
14841486 * If checksum is wrong, sleep a bit and then try again
@@ -1495,8 +1497,7 @@ validate_one_page(Page page, pgFile *file,
14951497 file -> path , blknum );
14961498 }
14971499 }
1498-
1499- if (!checksum_version )
1500+ else
15001501 {
15011502 /* Get lsn from page header. Ensure that page is from our time */
15021503 lsn = PageXLogRecPtrGet (phdr -> pd_lsn );
@@ -1525,7 +1526,7 @@ validate_one_page(Page page, pgFile *file,
15251526 }
15261527 }
15271528
1528- return PAGE_IS_FOUND_AND__NOT_VALID ;
1529+ return PAGE_IS_FOUND_AND_NOT_VALID ;
15291530}
15301531
15311532/* Valiate pages of datafile in backup one by one */
@@ -1610,13 +1611,13 @@ check_file_pages(pgFile *file, XLogRecPtr stop_lsn, uint32 checksum_version)
16101611 file -> path , uncompressed_size );
16111612
16121613 if (validate_one_page (page .data , file , blknum ,
1613- stop_lsn , checksum_version ) == PAGE_IS_FOUND_AND__NOT_VALID )
1614+ stop_lsn , checksum_version ) == PAGE_IS_FOUND_AND_NOT_VALID )
16141615 is_valid = false;
16151616 }
16161617 else
16171618 {
16181619 if (validate_one_page (compressed_page .data , file , blknum ,
1619- stop_lsn , checksum_version ) == PAGE_IS_FOUND_AND__NOT_VALID )
1620+ stop_lsn , checksum_version ) == PAGE_IS_FOUND_AND_NOT_VALID )
16201621 is_valid = false;
16211622 }
16221623 }
0 commit comments