137 stack_in, page_access);
178 stack_in = new_stack;
247 Assert(!forupdate || heaprel != NULL);
266 cmpval =
key->nextkey ? 0 : 1;
311 elog(
ERROR,
"fell off the end of index \"%s\"",
384 cmpval =
key->nextkey ? 0 : 1;
394 if (result >= cmpval)
469 low = insertstate->
low;
507 if (result >= cmpval)
532 (
errcode(ERRCODE_INDEX_CORRUPTED),
533 errmsg_internal(
"table tid from new index tuple (%u,%u) cannot find insert offset between offsets %u and %u of block %u in index \"%s\"",
554 insertstate->
low = low;
612 mid = low + ((high - low) / 2);
696 ncmpkey =
Min(ntupatts,
key->keysz);
699 scankey =
key->scankeys;
700 for (
int i = 1;
i <= ncmpkey;
i++)
758 if (
key->keysz > ntupatts)
767 if (
key->scantid == NULL)
802 if (
key->heapkeyspace && !
key->pivotsearch &&
803 key->keysz == ntupatts && heapTid == NULL)
1002 if (chosen == NULL && impliesNN != NULL &&
1008 chosen = ¬nullkeys[keysCount];
1029 startKeys[keysCount++] = chosen;
1038 strat_total = strat;
1050 cur->sk_attno != curattr + 1)
1056 curattr =
cur->sk_attno;
1068 switch (
cur->sk_strategy)
1126 for (
i = 0;
i < keysCount;
i++)
1151 memcpy(inskey.scankeys +
i, subkey,
sizeof(
ScanKeyData));
1167 if (
i == keysCount - 1)
1169 bool used_all_subkeys =
false;
1176 if (subkey->
sk_attno != keysCount + 1)
1183 memcpy(inskey.scankeys + keysCount, subkey,
1188 used_all_subkeys =
true;
1192 if (!used_all_subkeys)
1194 switch (strat_total)
1248 elog(
ERROR,
"missing support function %d(%u,%u) for attribute %d of index \"%s\"",
1276 switch (strat_total)
1350 elog(
ERROR,
"unrecognized strat_total: %d", (
int) strat_total);
1356 inskey.anynullkeys =
false;
1357 inskey.nextkey = nextkey;
1358 inskey.pivotsearch =
false;
1359 inskey.scantid = NULL;
1360 inskey.keysz = keysCount;
1543 bool requiredMatchedByPrecheck;
1563 continuescan =
true;
1629 &requiredMatchedByPrecheck,
false);
1634 requiredMatchedByPrecheck =
false;
1642 offnum =
Max(offnum, minoff);
1644 while (offnum <= maxoff)
1663 &continuescan, requiredMatchedByPrecheck);
1670 Assert(!requiredMatchedByPrecheck ||
1672 &continuescan,
false));
1730 _bt_checkkeys(scan, itup, truncatt, dir, &continuescan,
false);
1746 offnum =
Min(offnum, maxoff);
1748 while (offnum >= minoff)
1774 tuple_alive =
false;
1782 &continuescan, requiredMatchedByPrecheck);
1789 Assert(!requiredMatchedByPrecheck ||
1791 &continuescan,
false));
1792 if (passes_quals && tuple_alive)
1899 memcpy(base, itup, itupsz);
2112 blkno = opaque->btpo_next;
2333 elog(
ERROR,
"fell off the end of index \"%s\"",
2356 elog(
ERROR,
"could not find left sibling of block %u in index \"%s\"",
2412 elog(
ERROR,
"fell off the end of index \"%s\"",
2424 (
errcode(ERRCODE_INDEX_CORRUPTED),
2503 elog(
ERROR,
"invalid scan direction: %d", (
int) dir);
#define InvalidBlockNumber
void IncrBufferRefCount(Buffer buffer)
BlockNumber BufferGetBlockNumber(Buffer buffer)
void ReleaseBuffer(Buffer buffer)
XLogRecPtr BufferGetLSNAtomic(Buffer buffer)
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 OffsetNumber PageGetMaxOffsetNumber(Page page)
#define RegProcedureIsValid(p)
#define INVERT_COMPARE_RESULT(var)
static void PGresult * res
elog(ERROR, "%s: %s", p2, msg)
int errmsg_internal(const char *fmt,...)
int errcode(int sqlerrcode)
#define ereport(elevel,...)
Datum FunctionCall2Coll(FmgrInfo *flinfo, Oid collation, Datum arg1, Datum arg2)
FmgrInfo * index_getprocinfo(Relation irel, AttrNumber attnum, uint16 procnum)
if(TABLE==NULL||TABLE_index==NULL)
#define ItemIdIsDead(itemId)
int32 ItemPointerCompare(ItemPointer arg1, ItemPointer arg2)
static OffsetNumber ItemPointerGetOffsetNumber(const ItemPointerData *pointer)
static BlockNumber ItemPointerGetBlockNumber(const ItemPointerData *pointer)
IndexTupleData * IndexTuple
#define IndexTupleSize(itup)
static Datum index_getattr(IndexTuple tup, int attnum, TupleDesc tupleDesc, bool *isnull)
Assert(fmt[strlen(fmt) - 1] !='\n')
Oid get_opfamily_proc(Oid opfamily, Oid lefttype, Oid righttype, int16 procnum)
#define CHECK_FOR_INTERRUPTS()
void _bt_finish_split(Relation rel, Relation heaprel, Buffer lbuf, BTStack stack)
Buffer _bt_relandgetbuf(Relation rel, Buffer obuf, BlockNumber blkno, int access)
void _bt_relbuf(Relation rel, Buffer buf)
Buffer _bt_gettrueroot(Relation rel)
void _bt_metaversion(Relation rel, bool *heapkeyspace, bool *allequalimage)
Buffer _bt_getbuf(Relation rel, BlockNumber blkno, int access)
void _bt_unlockbuf(Relation rel, Buffer buf)
void _bt_lockbuf(Relation rel, Buffer buf, int access)
Buffer _bt_getroot(Relation rel, Relation heaprel, int access)
void _bt_parallel_release(IndexScanDesc scan, BlockNumber scan_page)
void _bt_parallel_done(IndexScanDesc scan)
bool _bt_parallel_seize(IndexScanDesc scan, BlockNumber *pageno)
#define BTScanPosIsPinned(scanpos)
static uint16 BTreeTupleGetNPosting(IndexTuple posting)
static bool BTreeTupleIsPivot(IndexTuple itup)
#define P_LEFTMOST(opaque)
#define BTPageGetOpaque(page)
#define P_ISDELETED(opaque)
#define MaxTIDsPerBTreePage
#define BTScanPosIsValid(scanpos)
#define P_FIRSTDATAKEY(opaque)
static uint32 BTreeTupleGetPostingOffset(IndexTuple posting)
#define P_RIGHTMOST(opaque)
#define SK_BT_NULLS_FIRST
#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)
#define BTScanPosInvalidate(scanpos)
#define BTScanPosUnpinIfPinned(scanpos)
static ItemPointer BTreeTupleGetHeapTID(IndexTuple itup)
#define BTreeTupleGetNAtts(itup, rel)
BTScanOpaqueData * BTScanOpaque
Buffer _bt_get_endpoint(Relation rel, uint32 level, bool rightmost)
static bool _bt_readnextpage(IndexScanDesc scan, BlockNumber blkno, ScanDirection dir)
Buffer _bt_moveright(Relation rel, Relation heaprel, BTScanInsert key, Buffer buf, bool forupdate, BTStack stack, int access)
static int _bt_binsrch_posting(BTScanInsert key, Page page, OffsetNumber offnum)
bool _bt_first(IndexScanDesc scan, ScanDirection dir)
static void _bt_saveitem(BTScanOpaque so, int itemIndex, OffsetNumber offnum, IndexTuple itup)
static bool _bt_readpage(IndexScanDesc scan, ScanDirection dir, OffsetNumber offnum)
static bool _bt_parallel_readpage(IndexScanDesc scan, BlockNumber blkno, ScanDirection dir)
static int _bt_setuppostingitems(BTScanOpaque so, int itemIndex, OffsetNumber offnum, ItemPointer heapTid, IndexTuple itup)
static Buffer _bt_walk_left(Relation rel, Buffer buf)
static void _bt_drop_lock_and_maybe_pin(IndexScanDesc scan, BTScanPos sp)
static OffsetNumber _bt_binsrch(Relation rel, BTScanInsert key, Buffer buf)
static bool _bt_endpoint(IndexScanDesc scan, ScanDirection dir)
static bool _bt_steppage(IndexScanDesc scan, ScanDirection dir)
static void _bt_savepostingitem(BTScanOpaque so, int itemIndex, OffsetNumber offnum, ItemPointer heapTid, int tupleOffset)
BTStack _bt_search(Relation rel, Relation heaprel, BTScanInsert key, Buffer *bufP, int access)
OffsetNumber _bt_binsrch_insert(Relation rel, BTInsertState insertstate)
bool _bt_next(IndexScanDesc scan, ScanDirection dir)
int32 _bt_compare(Relation rel, BTScanInsert key, Page page, OffsetNumber offnum)
static void _bt_initialize_more_data(BTScanOpaque so, ScanDirection dir)
bool _bt_checkkeys(IndexScanDesc scan, IndexTuple tuple, int tupnatts, ScanDirection dir, bool *continuescan, bool requiredMatchedByPrecheck)
void _bt_freestack(BTStack stack)
void _bt_killitems(IndexScanDesc scan)
bool _bt_check_natts(Relation rel, bool heapkeyspace, Page page, OffsetNumber offnum)
void _bt_preprocess_keys(IndexScanDesc scan)
#define InvalidOffsetNumber
#define OffsetNumberNext(offsetNumber)
#define OffsetNumberPrev(offsetNumber)
#define pgstat_count_index_scan(rel)
static Pointer DatumGetPointer(Datum X)
static int32 DatumGetInt32(Datum X)
void PredicateLockPage(Relation relation, BlockNumber blkno, Snapshot snapshot)
void PredicateLockRelation(Relation relation, Snapshot snapshot)
#define RelationGetDescr(relation)
#define RelationGetRelationName(relation)
#define RelationNeedsWAL(relation)
#define IndexRelationGetNumberOfAttributes(relation)
#define IndexRelationGetNumberOfKeyAttributes(relation)
void ScanKeyEntryInitialize(ScanKey entry, int flags, AttrNumber attributeNumber, StrategyNumber strategy, Oid subtype, Oid collation, RegProcedure procedure, Datum argument)
void ScanKeyEntryInitializeWithInfo(ScanKey entry, int flags, AttrNumber attributeNumber, StrategyNumber strategy, Oid subtype, Oid collation, FmgrInfo *finfo, Datum argument)
#define ScanDirectionIsForward(direction)
#define ScanDirectionIsBackward(direction)
#define IsMVCCSnapshot(snapshot)
#define BTGreaterStrategyNumber
#define BTLessStrategyNumber
#define BTEqualStrategyNumber
#define BTLessEqualStrategyNumber
#define BTGreaterEqualStrategyNumber
BTScanPosItem items[MaxTIDsPerBTreePage]
LocationIndex tupleOffset
struct BTStackData * bts_parent
struct ParallelIndexScanDescData * parallel_scan
bool ignore_killed_tuples
ItemPointerData xs_heaptid
struct SnapshotData * xs_snapshot
StrategyNumber sk_strategy
#define IsolationIsSerializable()