35 #include "catalog/pg_opfamily_d.h"
53 #define InvalidBtreeLevel ((uint32) InvalidBlockNumber)
54 #define BTreeTupleGetNKeyAtts(itup, rel) \
55 Min(IndexRelationGetNumberOfKeyAttributes(rel), BTreeTupleGetNAtts(itup, rel))
152 bool heapallindexed,
bool rootdescend,
157 bool heapkeyspace,
bool readonly,
bool heapallindexed,
158 bool rootdescend,
bool checkunique);
192 bool tupleIsAlive,
void *checkstate);
233 bool heapallindexed =
false;
234 bool checkunique =
false;
259 bool heapallindexed =
false;
260 bool rootdescend =
false;
261 bool checkunique =
false;
280 bool rootdescend,
bool checkunique)
287 int save_sec_context;
324 save_sec_context = -1;
350 errmsg(
"could not open parent table of index \"%s\"",
363 (
errcode(ERRCODE_INDEX_CORRUPTED),
364 errmsg(
"index \"%s\" lacks a main relation fork",
369 if (allequalimage && !heapkeyspace)
371 (
errcode(ERRCODE_INDEX_CORRUPTED),
372 errmsg(
"index \"%s\" metapage has equalimage field set on unsupported nbtree version",
376 bool has_interval_ops =
false;
380 has_interval_ops =
true;
382 (
errcode(ERRCODE_INDEX_CORRUPTED),
383 errmsg(
"index \"%s\" metapage incorrectly indicates that deduplication is safe",
386 ?
errhint(
"This is known of \"interval\" indexes last built on a version predating 2023-11.")
392 heapallindexed, rootdescend, checkunique);
422 if (rel->
rd_rel->relkind != RELKIND_INDEX ||
423 rel->
rd_rel->relam != BTREE_AM_OID)
425 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
426 errmsg(
"only B-Tree indexes are supported as targets for verification"),
427 errdetail(
"Relation \"%s\" is not a B-Tree index.",
432 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
433 errmsg(
"cannot access temporary tables of other sessions"),
434 errdetail(
"Index \"%s\" is associated with temporary relation.",
439 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
440 errmsg(
"cannot check index \"%s\"",
456 if (rel->
rd_rel->relpersistence != RELPERSISTENCE_UNLOGGED ||
461 (
errcode(ERRCODE_READ_ONLY_SQL_TRANSACTION),
462 errmsg(
"cannot verify unlogged index \"%s\" during recovery, skipping",
493 bool readonly,
bool heapallindexed,
bool rootdescend,
504 elog(
DEBUG1,
"verifying consistency of tree structure for index \"%s\"",
507 elog(
DEBUG1,
"verifying consistency of tree structure for index \"%s\" with cross-level checks",
521 state->heaprel = heaprel;
522 state->heapkeyspace = heapkeyspace;
523 state->readonly = readonly;
524 state->heapallindexed = heapallindexed;
525 state->rootdescend = rootdescend;
526 state->checkunique = checkunique;
529 if (
state->heapallindexed)
544 (int64)
state->rel->rd_rel->reltuples);
549 state->heaptuplespresent = 0;
558 if (!
state->readonly)
580 errmsg(
"index \"%s\" cannot be verified using transaction snapshot",
590 if (
state->checkunique)
593 if (
state->indexinfo->ii_Unique)
596 state->snapshot = snapshot;
603 if (
state->rootdescend && !
state->heapkeyspace)
605 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
606 errmsg(
"cannot verify that tuples from index \"%s\" can each be found by an independent index search",
608 errhint(
"Only B-Tree version 4 indexes support rootdescend verification.")));
633 errdetail_internal(
"Fast root block %u (level %u) differs from true root block %u (level %u).",
656 (
errcode(ERRCODE_INDEX_CORRUPTED),
657 errmsg(
"index \"%s\" has no valid pages on level below %u or first level",
660 previouslevel = current.
level;
666 if (
state->heapallindexed)
709 elog(
DEBUG1,
"verifying that tuples from index \"%s\" are present in \"%s\"",
773 " (true root level)" : level.
level == 0 ?
" (leaf level)" :
"");
776 state->previncompletesplit =
false;
784 state->targetblock = current;
805 (
errcode(ERRCODE_INDEX_CORRUPTED),
806 errmsg(
"downlink or sibling link points to deleted block in index \"%s\"",
809 current, leftcurrent, opaque->
btpo_prev)));
813 (
errcode(ERRCODE_INDEX_CORRUPTED),
814 errmsg(
"block %u fell off the end of index \"%s\"",
836 (
errcode(ERRCODE_INDEX_CORRUPTED),
837 errmsg(
"block %u is not leftmost in index \"%s\"",
842 (
errcode(ERRCODE_INDEX_CORRUPTED),
843 errmsg(
"block %u is not true root in index \"%s\"",
903 (
errcode(ERRCODE_INDEX_CORRUPTED),
904 errmsg(
"leftmost down link for level points to block in index \"%s\" whose level is not one level down",
906 errdetail_internal(
"Block pointed to=%u expected level=%u level in pointed to block=%u.",
915 if (current == leftcurrent || current == opaque->
btpo_prev)
917 (
errcode(ERRCODE_INDEX_CORRUPTED),
918 errmsg(
"circular link chain found in block %u of index \"%s\"",
921 leftcurrent = current;
928 state->lowkey = NULL;
963 while (current !=
P_NONE);
969 state->lowkey = NULL;
975 return nextleveldown;
987 tid,
state->snapshot, slot);
1018 itid =
psprintf(
"tid=(%u,%u)", block, offset);
1020 if (nblock != block || noffset != offset)
1021 nitid =
psprintf(
" tid=(%u,%u)", nblock, noffset);
1024 pposting =
psprintf(
" posting %u", posting);
1027 pnposting =
psprintf(
" posting %u", nposting);
1030 (
errcode(ERRCODE_INDEX_CORRUPTED),
1031 errmsg(
"index uniqueness is violated for index \"%s\"",
1033 errdetail(
"Index %s%s and%s%s (point to heap %s and %s) page lsn=%X/%X.",
1034 itid, pposting, nitid, pnposting, htid, nhtid,
1046 bool has_visible_entry =
false;
1061 has_visible_entry =
true;
1065 *lVis_tid, *lVis_block,
1066 *lVis_offset, *lVis_i,
1081 *lVis_offset = offset;
1082 *lVis_block = targetblock;
1097 has_visible_entry =
true;
1101 *lVis_tid, *lVis_block,
1102 *lVis_offset, *lVis_i,
1108 *lVis_offset = offset;
1109 *lVis_block = targetblock;
1114 *lVis_block != targetblock)
1119 posting =
psprintf(
" posting %u", *lVis_i);
1122 errmsg(
"index uniqueness can not be checked for index tid=(%u,%u) in index \"%s\"",
1123 targetblock, offset,
1125 errdetail(
"It doesn't have visible heap tids and key is equal to the tid=(%u,%u)%s (points to heap tid=(%u,%u)).",
1126 *lVis_block, *lVis_offset, posting,
1129 errhint(
"VACUUM the table and repeat the check.")));
1145 reached_from =
start;
1146 bool all_half_dead =
true;
1154 while (reached !=
P_NONE && all_half_dead)
1168 reached != reached_from &&
1169 reached_opaque->
btpo_next == reached_from;
1177 errmsg_internal(
"harmless interrupted page deletion detected in index \"%s\"",
1180 reached, reached_from,
1183 reached_from = reached;
1190 return all_half_dead;
1236 if (!
state->readonly)
1266 if (newtargetblock != leftcurrent)
1270 state->checkstrategy);
1276 btpo_prev_from_target = opaque->
btpo_prev;
1298 if (btpo_prev_from_target == leftcurrent)
1302 (
errcode(ERRCODE_INTERNAL_ERROR),
1303 errmsg_internal(
"harmless concurrent page split detected in index \"%s\"",
1306 leftcurrent, newtargetblock,
1307 state->targetblock)));
1318 state->targetblock = newtargetblock;
1322 (
errcode(ERRCODE_INDEX_CORRUPTED),
1323 errmsg(
"left link/right link pair in index \"%s\" not in agreement",
1326 state->targetblock, leftcurrent,
1327 btpo_prev_from_target)));
1385 elog(
DEBUG2,
"verifying %u items on %s block %u", max,
1386 P_ISLEAF(topaque) ?
"leaf" :
"internal",
state->targetblock);
1405 (
errcode(ERRCODE_INDEX_CORRUPTED),
1406 errmsg(
"wrong number of high key index tuple attributes in index \"%s\"",
1411 P_ISLEAF(topaque) ?
"heap" :
"index",
1429 bool lowersizelimit;
1435 state->target, offset);
1447 (
errcode(ERRCODE_INDEX_CORRUPTED),
1448 errmsg(
"index tuple size does not equal lp_len in index \"%s\"",
1451 state->targetblock, offset,
1454 errhint(
"This could be a torn page problem.")));
1471 (
errcode(ERRCODE_INDEX_CORRUPTED),
1472 errmsg(
"wrong number of index tuple attributes in index \"%s\"",
1477 P_ISLEAF(topaque) ?
"heap" :
"index",
1521 (
errcode(ERRCODE_INDEX_CORRUPTED),
1522 errmsg(
"could not find tuple using search from root page in index \"%s\"",
1547 char *itid =
psprintf(
"(%u,%u)",
state->targetblock, offset);
1550 (
errcode(ERRCODE_INDEX_CORRUPTED),
1551 errmsg_internal(
"posting list contains misplaced TID in index \"%s\"",
1604 (
errcode(ERRCODE_INDEX_CORRUPTED),
1605 errmsg(
"index row size %zu exceeds maximum for index \"%s\"",
1609 P_ISLEAF(topaque) ?
"heap" :
"index",
1631 if (norm != logtuple)
1711 (
errcode(ERRCODE_INDEX_CORRUPTED),
1712 errmsg(
"high key invariant violated for index \"%s\"",
1716 P_ISLEAF(topaque) ?
"heap" :
"index",
1757 (
errcode(ERRCODE_INDEX_CORRUPTED),
1758 errmsg(
"item order invariant violated for index \"%s\"",
1761 "higher index tid=%s (points to %s tid=%s) "
1764 P_ISLEAF(topaque) ?
"heap" :
"index",
1767 P_ISLEAF(topaque) ?
"heap" :
"index",
1776 if (
state->checkunique &&
state->indexinfo->ii_Unique &&
1779 &lVis_i, &lVis_tid, &lVis_offset,
1782 if (
state->checkunique &&
state->indexinfo->ii_Unique &&
1849 if (!
state->readonly)
1864 (
errcode(ERRCODE_INDEX_CORRUPTED),
1865 errmsg(
"cross page item order invariant violated for index \"%s\"",
1868 state->targetblock, offset,
1877 if (
state->checkunique &&
state->indexinfo->ii_Unique &&
1880 elog(
DEBUG2,
"check cross page unique condition");
1906 &lVis_i, &lVis_tid, &lVis_offset,
2016 errmsg_internal(
"level %u sibling page in block %u of index \"%s\" was found deleted or half dead",
2018 errdetail_internal(
"Deleted page found when building scankey from right sibling.")));
2148 P_ISLEAF(opaque) ?
"leaf" :
"internal", targetnext,
2247 bool rightsplit =
state->previncompletesplit;
2256 state->target, target_downlinkoffnum);
2293 state->previncompletesplit =
false;
2300 (
errcode(ERRCODE_INDEX_CORRUPTED),
2301 errmsg(
"can't traverse from downlink %u to downlink %u of index \"%s\"",
2302 state->prevrightlink, downlink,
2306 if (blkno == downlink && loaded_child)
2307 page = loaded_child;
2317 (
errcode(ERRCODE_INDEX_CORRUPTED),
2318 errmsg(
"the first child of leftmost target page is not leftmost of its level in index \"%s\"",
2321 state->targetblock, blkno,
2328 (
errcode(ERRCODE_INDEX_CORRUPTED),
2329 errmsg(
"block found while following rightlinks from child of index \"%s\" has invalid level",
2331 errdetail_internal(
"Block pointed to=%u expected level=%u level in pointed to block=%u.",
2332 blkno, target_level - 1, opaque->
btpo_level)));
2335 if ((!first && blkno ==
state->prevrightlink) || blkno == opaque->
btpo_prev)
2337 (
errcode(ERRCODE_INDEX_CORRUPTED),
2338 errmsg(
"circular link chain found in block %u of index \"%s\"",
2341 if (blkno != downlink && !
P_IGNORE(opaque))
2385 if (blkno == downlink)
2388 pivotkey_offset = target_downlinkoffnum;
2403 (
errcode(ERRCODE_INDEX_CORRUPTED),
2404 errmsg(
"child high key is greater than rightmost pivot key on target level in index \"%s\"",
2407 state->targetblock, blkno,
2412 state->target, pivotkey_offset);
2433 (
errcode(ERRCODE_INDEX_CORRUPTED),
2434 errmsg(
"can't find left sibling high key in index \"%s\"",
2437 state->targetblock, blkno,
2439 itup =
state->lowkey;
2445 (
errcode(ERRCODE_INDEX_CORRUPTED),
2446 errmsg(
"mismatch between parent key and child high key in index \"%s\"",
2449 state->targetblock, blkno,
2455 if (blkno == downlink)
2458 state->previncompletesplit = rightsplit;
2466 if (page != loaded_child)
2499 state->target, downlinkoffnum);
2585 (
errcode(ERRCODE_INDEX_CORRUPTED),
2586 errmsg(
"downlink to deleted page found in index \"%s\"",
2589 state->targetblock, childblock,
2593 offset <= maxoffset;
2626 (
errcode(ERRCODE_INDEX_CORRUPTED),
2627 errmsg(
"down-link lower bound invariant violated for index \"%s\"",
2630 state->targetblock, childblock, offset,
2697 errmsg_internal(
"harmless interrupted page split detected in index \"%s\"",
2718 (
errcode(ERRCODE_INDEX_CORRUPTED),
2719 errmsg(
"leaf index block lacks downlink in index \"%s\"",
2726 elog(
DEBUG1,
"checking for interrupted multi-level deletion due to missing downlink in index \"%s\"",
2746 (
errcode(ERRCODE_INDEX_CORRUPTED),
2747 errmsg_internal(
"downlink points to block in index \"%s\" whose level is not one level down",
2749 errdetail_internal(
"Top parent/under check block=%u block pointed to=%u expected level=%u level in pointed to block=%u.",
2784 (
errcode(ERRCODE_INDEX_CORRUPTED),
2785 errmsg_internal(
"downlink to deleted leaf page found in index \"%s\"",
2787 errdetail_internal(
"Top parent/target block=%u leaf block=%u top parent/under check lsn=%X/%X.",
2810 (
errcode(ERRCODE_INDEX_CORRUPTED),
2811 errmsg(
"internal index block lacks downlink in index \"%s\"",
2875 bool *isnull,
bool tupleIsAlive,
void *checkstate)
2893 errmsg(
"heap tuple (%u,%u) from table \"%s\" lacks matching index tuple within index \"%s\"",
2899 ?
errhint(
"Retrying verification using the function bt_index_parent_check() might provide a more specific error.")
2902 state->heaptuplespresent++;
2948 bool formnewtup =
false;
2959 for (
i = 0;
i < tupleDescriptor->
natts;
i++)
2966 need_free[
i] =
false;
2970 if (att->attbyval || att->attlen != -1 || isnull[
i])
2980 (
errcode(ERRCODE_INDEX_CORRUPTED),
2981 errmsg(
"external varlena datum in tuple that references heap row (%u,%u) in index \"%s\"",
2987 (att->attstorage == TYPSTORAGE_EXTENDED ||
2988 att->attstorage == TYPSTORAGE_MAIN))
3001 need_free[
i] =
true;
3019 need_free[
i] =
true;
3048 for (
i = 0;
i < tupleDescriptor->
natts;
i++)
3131 insertstate.
itup = itup;
3136 insertstate.
buf = lbuf;
3214 if (!
key->heapkeyspace)
3245 if (
key->keysz == uppnkeyatts)
3246 return key->scantid == NULL && rheaptid != NULL;
3248 return key->keysz < uppnkeyatts;
3298 if (!
key->heapkeyspace)
3339 if (!
key->heapkeyspace)
3360 if (
key->keysz == uppnkeyatts)
3361 return key->scantid == NULL && childheaptid != NULL;
3363 return key->keysz < uppnkeyatts;
3398 state->checkstrategy);
3415 (
errcode(ERRCODE_INDEX_CORRUPTED),
3416 errmsg(
"invalid meta page found at block %u in index \"%s\"",
3427 (
errcode(ERRCODE_INDEX_CORRUPTED),
3428 errmsg(
"index \"%s\" meta page is corrupt",
3434 (
errcode(ERRCODE_INDEX_CORRUPTED),
3435 errmsg(
"version mismatch in index \"%s\": file version %d, "
3436 "current version %d, minimum supported version %d",
3456 (
errcode(ERRCODE_INDEX_CORRUPTED),
3457 errmsg_internal(
"invalid leaf page level %u for block %u in index \"%s\"",
3463 (
errcode(ERRCODE_INDEX_CORRUPTED),
3464 errmsg_internal(
"invalid internal page level 0 for block %u in index \"%s\"",
3491 (
errcode(ERRCODE_INDEX_CORRUPTED),
3492 errmsg(
"Number of items on block %u of index \"%s\" exceeds MaxIndexTuplesPerPage (%u)",
3498 (
errcode(ERRCODE_INDEX_CORRUPTED),
3499 errmsg(
"internal block %u in index \"%s\" lacks high key and/or at least one downlink",
3504 (
errcode(ERRCODE_INDEX_CORRUPTED),
3505 errmsg(
"non-rightmost leaf block %u in index \"%s\" lacks high key item",
3517 (
errcode(ERRCODE_INDEX_CORRUPTED),
3518 errmsg(
"internal page block %u in index \"%s\" is half-dead",
3520 errhint(
"This can be caused by an interrupted VACUUM in version 9.3 or older, before upgrade. Please REINDEX it.")));
3528 (
errcode(ERRCODE_INDEX_CORRUPTED),
3529 errmsg_internal(
"internal page block %u in index \"%s\" has garbage items",
3534 (
errcode(ERRCODE_INDEX_CORRUPTED),
3535 errmsg_internal(
"full transaction id page flag appears in non-deleted block %u in index \"%s\"",
3540 (
errcode(ERRCODE_INDEX_CORRUPTED),
3594 (
errcode(ERRCODE_INDEX_CORRUPTED),
3595 errmsg(
"line pointer points past end of tuple space in index \"%s\"",
3610 (
errcode(ERRCODE_INDEX_CORRUPTED),
3611 errmsg(
"invalid line pointer storage in index \"%s\"",
3639 (
errcode(ERRCODE_INDEX_CORRUPTED),
3640 errmsg_internal(
"block %u or its right sibling block or child block in index \"%s\" has unexpected pivot tuple",
3646 (
errcode(ERRCODE_INDEX_CORRUPTED),
3647 errmsg_internal(
"block %u or its right sibling block or child block in index \"%s\" has unexpected non-pivot tuple",
3654 (
errcode(ERRCODE_INDEX_CORRUPTED),
3655 errmsg(
"block %u or its right sibling block or child block in index \"%s\" contains non-pivot tuple that lacks a heap TID",
3686 return &itup->
t_tid;
#define InvalidBlockNumber
static bool BlockNumberIsValid(BlockNumber blockNumber)
void bloom_free(bloom_filter *filter)
bloom_filter * bloom_create(int64 total_elems, int bloom_work_mem, uint64 seed)
double bloom_prop_bits_set(bloom_filter *filter)
bool bloom_lacks_element(bloom_filter *filter, unsigned char *elem, size_t len)
void bloom_add_element(bloom_filter *filter, unsigned char *elem, size_t len)
static Datum values[MAXATTR]
void UnlockReleaseBuffer(Buffer buffer)
void LockBuffer(Buffer buffer, int mode)
Buffer ReadBufferExtended(Relation reln, ForkNumber forkNum, BlockNumber blockNum, ReadBufferMode mode, BufferAccessStrategy strategy)
#define RelationGetNumberOfBlocks(reln)
static Page BufferGetPage(Buffer buffer)
static bool BufferIsValid(Buffer bufnum)
static Item PageGetItem(Page page, ItemId itemId)
static ItemId PageGetItemId(Page page, OffsetNumber offsetNumber)
static XLogRecPtr PageGetLSN(Page page)
static OffsetNumber PageGetMaxOffsetNumber(Page page)
#define Assert(condition)
#define OidIsValid(objectId)
int errmsg_internal(const char *fmt,...)
int errdetail_internal(const char *fmt,...)
int errdetail(const char *fmt,...)
int errhint(const char *fmt,...)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
void ExecDropSingleTupleTableSlot(TupleTableSlot *slot)
#define PG_DETOAST_DATUM(datum)
#define PG_GETARG_BOOL(n)
BufferAccessStrategy GetAccessStrategy(BufferAccessStrategyType btype)
int NewGUCNestLevel(void)
void RestrictSearchPath(void)
void AtEOXact_GUC(bool isCommit, int nestLevel)
#define TOAST_INDEX_TARGET
#define HeapTupleHeaderGetXmin(tup)
Oid IndexGetRelation(Oid indexId, bool missing_ok)
IndexInfo * BuildIndexInfo(Relation index)
void index_close(Relation relation, LOCKMODE lockmode)
Relation index_open(Oid relationId, LOCKMODE lockmode)
IndexTuple index_form_tuple(TupleDesc tupleDescriptor, const Datum *values, const bool *isnull)
#define ItemIdGetLength(itemId)
#define ItemIdGetOffset(itemId)
#define ItemIdIsDead(itemId)
#define ItemIdIsUsed(itemId)
#define ItemIdIsRedirected(itemId)
#define ItemIdGetFlags(itemId)
int32 ItemPointerCompare(ItemPointer arg1, ItemPointer arg2)
static OffsetNumber ItemPointerGetOffsetNumber(const ItemPointerData *pointer)
static OffsetNumber ItemPointerGetOffsetNumberNoCheck(const ItemPointerData *pointer)
static BlockNumber ItemPointerGetBlockNumber(const ItemPointerData *pointer)
static BlockNumber ItemPointerGetBlockNumberNoCheck(const ItemPointerData *pointer)
static void ItemPointerCopy(const ItemPointerData *fromPointer, ItemPointerData *toPointer)
static bool ItemPointerIsValid(const ItemPointerData *pointer)
#define IndexTupleHasVarwidths(itup)
IndexTupleData * IndexTuple
#define IndexTupleSize(itup)
static Datum index_getattr(IndexTuple tup, int attnum, TupleDesc tupleDesc, bool *isnull)
#define MaxIndexTuplesPerPage
void MemoryContextReset(MemoryContext context)
void pfree(void *pointer)
void * palloc0(Size size)
MemoryContext CurrentMemoryContext
void * MemoryContextAlloc(MemoryContext context, Size size)
void MemoryContextDelete(MemoryContext context)
#define AllocSetContextCreate
#define ALLOCSET_DEFAULT_SIZES
#define SECURITY_RESTRICTED_OPERATION
#define CHECK_FOR_INTERRUPTS()
void GetUserIdAndSecContext(Oid *userid, int *sec_context)
void SetUserIdAndSecContext(Oid userid, int sec_context)
IndexTuple _bt_form_posting(IndexTuple base, ItemPointer htids, int nhtids)
void _bt_relbuf(Relation rel, Buffer buf)
void _bt_checkpage(Relation rel, Buffer buf)
void _bt_metaversion(Relation rel, bool *heapkeyspace, bool *allequalimage)
#define P_HAS_FULLXID(opaque)
#define P_ISHALFDEAD(opaque)
static uint16 BTreeTupleGetNPosting(IndexTuple posting)
static bool BTreeTupleIsPivot(IndexTuple itup)
#define BTREE_MIN_VERSION
#define P_HAS_GARBAGE(opaque)
#define BTMaxItemSizeNoHeapTid(page)
#define BTPageGetOpaque(page)
#define P_ISDELETED(opaque)
static BlockNumber BTreeTupleGetTopParent(IndexTuple leafhikey)
#define MaxTIDsPerBTreePage
#define P_FIRSTDATAKEY(opaque)
#define P_RIGHTMOST(opaque)
#define BTMaxItemSize(page)
#define P_INCOMPLETE_SPLIT(opaque)
static ItemPointer BTreeTupleGetPostingN(IndexTuple posting, int n)
static BlockNumber BTreeTupleGetDownLink(IndexTuple pivot)
static ItemPointer BTreeTupleGetMaxHeapTID(IndexTuple itup)
static bool BTreeTupleIsPosting(IndexTuple itup)
static ItemPointer BTreeTupleGetHeapTID(IndexTuple itup)
#define BTreeTupleGetNAtts(itup, rel)
BTStack _bt_search(Relation rel, Relation heaprel, BTScanInsert key, Buffer *bufP, int access)
OffsetNumber _bt_binsrch_insert(Relation rel, BTInsertState insertstate)
int32 _bt_compare(Relation rel, BTScanInsert key, Page page, OffsetNumber offnum)
void _bt_freestack(BTStack stack)
BTScanInsert _bt_mkscankey(Relation rel, IndexTuple itup)
bool _bt_check_natts(Relation rel, bool heapkeyspace, Page page, OffsetNumber offnum)
bool _bt_allequalimage(Relation rel, bool debugmessage)
#define InvalidOffsetNumber
#define OffsetNumberIsValid(offsetNumber)
#define OffsetNumberNext(offsetNumber)
FormData_pg_attribute * Form_pg_attribute
#define ERRCODE_DATA_CORRUPTED
uint64 pg_prng_uint64(pg_prng_state *state)
pg_prng_state pg_global_prng_state
#define ERRCODE_T_R_SERIALIZATION_FAILURE
#define ERRCODE_UNDEFINED_TABLE
static Datum PointerGetDatum(const void *X)
static Pointer DatumGetPointer(Datum X)
char * psprintf(const char *fmt,...)
MemoryContextSwitchTo(old_ctx)
static int cmp(const chr *x, const chr *y, size_t len)
static SMgrRelation RelationGetSmgr(Relation rel)
#define RelationGetDescr(relation)
#define RelationGetRelationName(relation)
#define RELATION_IS_OTHER_TEMP(relation)
#define IndexRelationGetNumberOfKeyAttributes(relation)
bool smgrexists(SMgrRelation reln, ForkNumber forknum)
Snapshot GetTransactionSnapshot(void)
void UnregisterSnapshot(Snapshot snapshot)
Snapshot RegisterSnapshot(Snapshot snapshot)
BufferAccessStrategy checkstrategy
BlockNumber prevrightlink
MemoryContext targetcontext
uint16 * ii_ExclusionStrats
struct HeapTupleData * rd_indextuple
void table_close(Relation relation, LOCKMODE lockmode)
Relation table_open(Oid relationId, LOCKMODE lockmode)
TupleTableSlot * table_slot_create(Relation relation, List **reglist)
static TableScanDesc table_beginscan_strat(Relation rel, Snapshot snapshot, int nkeys, struct ScanKeyData *key, bool allow_strat, bool allow_sync)
static double table_index_build_scan(Relation table_rel, Relation index_rel, struct IndexInfo *index_info, bool allow_sync, bool progress, IndexBuildCallback callback, void *callback_state, TableScanDesc scan)
static bool table_tuple_fetch_row_version(Relation rel, ItemPointer tid, Snapshot snapshot, TupleTableSlot *slot)
bool TransactionIdPrecedes(TransactionId id1, TransactionId id2)
#define TransactionIdIsValid(xid)
#define TupleDescAttr(tupdesc, i)
#define SET_VARSIZE_SHORT(PTR, len)
#define VARATT_CAN_MAKE_SHORT(PTR)
#define VARATT_IS_COMPRESSED(PTR)
#define VARATT_CONVERTED_SHORT_SIZE(PTR)
#define VARATT_IS_EXTERNAL(PTR)
static bool offset_is_negative_infinity(BTPageOpaque opaque, OffsetNumber offset)
static bool bt_leftmost_ignoring_half_dead(BtreeCheckState *state, BlockNumber start, BTPageOpaque start_opaque)
static bool invariant_l_offset(BtreeCheckState *state, BTScanInsert key, OffsetNumber upperbound)
static ItemPointer BTreeTupleGetPointsToTID(IndexTuple itup)
struct BtreeCheckState BtreeCheckState
static IndexTuple bt_posting_plain_tuple(IndexTuple itup, int n)
static void bt_target_page_check(BtreeCheckState *state)
static void bt_check_every_level(Relation rel, Relation heaprel, bool heapkeyspace, bool readonly, bool heapallindexed, bool rootdescend, bool checkunique)
static void bt_entry_unique_check(BtreeCheckState *state, IndexTuple itup, BlockNumber targetblock, OffsetNumber offset, int *lVis_i, ItemPointer *lVis_tid, OffsetNumber *lVis_offset, BlockNumber *lVis_block)
static bool bt_pivot_tuple_identical(bool heapkeyspace, IndexTuple itup1, IndexTuple itup2)
static void bt_report_duplicate(BtreeCheckState *state, ItemPointer tid, BlockNumber block, OffsetNumber offset, int posting, ItemPointer nexttid, BlockNumber nblock, OffsetNumber noffset, int nposting)
static void bt_index_check_internal(Oid indrelid, bool parentcheck, bool heapallindexed, bool rootdescend, bool checkunique)
static bool invariant_leq_offset(BtreeCheckState *state, BTScanInsert key, OffsetNumber upperbound)
Datum bt_index_parent_check(PG_FUNCTION_ARGS)
static void bt_child_highkey_check(BtreeCheckState *state, OffsetNumber target_downlinkoffnum, Page loaded_child, uint32 target_level)
static bool heap_entry_is_visible(BtreeCheckState *state, ItemPointer tid)
static BTScanInsert bt_mkscankey_pivotsearch(Relation rel, IndexTuple itup)
Datum bt_index_check(PG_FUNCTION_ARGS)
static BtreeLevel bt_check_level_from_leftmost(BtreeCheckState *state, BtreeLevel level)
static void bt_downlink_missing_check(BtreeCheckState *state, bool rightsplit, BlockNumber blkno, Page page)
PG_FUNCTION_INFO_V1(bt_index_check)
static ItemId PageGetItemIdCareful(BtreeCheckState *state, BlockNumber block, Page page, OffsetNumber offset)
static void bt_tuple_present_callback(Relation index, ItemPointer tid, Datum *values, bool *isnull, bool tupleIsAlive, void *checkstate)
static bool btree_index_mainfork_expected(Relation rel)
static bool bt_rootdescend(BtreeCheckState *state, IndexTuple itup)
static BTScanInsert bt_right_page_check_scankey(BtreeCheckState *state, OffsetNumber *rightfirstoffset)
static bool invariant_g_offset(BtreeCheckState *state, BTScanInsert key, OffsetNumber lowerbound)
#define InvalidBtreeLevel
static Page palloc_btree_page(BtreeCheckState *state, BlockNumber blocknum)
static IndexTuple bt_normalize_tuple(BtreeCheckState *state, IndexTuple itup)
static void bt_recheck_sibling_links(BtreeCheckState *state, BlockNumber btpo_prev_from_target, BlockNumber leftcurrent)
static ItemPointer BTreeTupleGetHeapTIDCareful(BtreeCheckState *state, IndexTuple itup, bool nonpivot)
#define BTreeTupleGetNKeyAtts(itup, rel)
static void bt_child_check(BtreeCheckState *state, BTScanInsert targetkey, OffsetNumber downlinkoffnum)
static void btree_index_checkable(Relation rel)
static bool invariant_l_nontarget_offset(BtreeCheckState *state, BTScanInsert key, BlockNumber nontargetblock, Page nontarget, OffsetNumber upperbound)
struct BtreeLevel BtreeLevel
#define IsolationUsesXactSnapshot()
bool RecoveryInProgress(void)
#define LSN_FORMAT_ARGS(lsn)