diff options
Diffstat (limited to 'src/backend/access/index/indexam.c')
-rw-r--r-- | src/backend/access/index/indexam.c | 62 |
1 files changed, 31 insertions, 31 deletions
diff --git a/src/backend/access/index/indexam.c b/src/backend/access/index/indexam.c index bb8379dc129..4ad30186d97 100644 --- a/src/backend/access/index/indexam.c +++ b/src/backend/access/index/indexam.c @@ -98,7 +98,7 @@ #define RELATION_CHECKS \ ( \ AssertMacro(RelationIsValid(indexRelation)), \ - AssertMacro(PointerIsValid(indexRelation->rd_amroutine)), \ + AssertMacro(PointerIsValid(indexRelation->rd_indam)), \ AssertMacro(!ReindexIsProcessingIndex(RelationGetRelid(indexRelation))) \ ) @@ -106,19 +106,19 @@ ( \ AssertMacro(IndexScanIsValid(scan)), \ AssertMacro(RelationIsValid(scan->indexRelation)), \ - AssertMacro(PointerIsValid(scan->indexRelation->rd_amroutine)) \ + AssertMacro(PointerIsValid(scan->indexRelation->rd_indam)) \ ) #define CHECK_REL_PROCEDURE(pname) \ do { \ - if (indexRelation->rd_amroutine->pname == NULL) \ + if (indexRelation->rd_indam->pname == NULL) \ elog(ERROR, "function %s is not defined for index %s", \ CppAsString(pname), RelationGetRelationName(indexRelation)); \ } while(0) #define CHECK_SCAN_PROCEDURE(pname) \ do { \ - if (scan->indexRelation->rd_amroutine->pname == NULL) \ + if (scan->indexRelation->rd_indam->pname == NULL) \ elog(ERROR, "function %s is not defined for index %s", \ CppAsString(pname), RelationGetRelationName(scan->indexRelation)); \ } while(0) @@ -203,14 +203,14 @@ index_insert(Relation indexRelation, RELATION_CHECKS; CHECK_REL_PROCEDURE(aminsert); - if (!(indexRelation->rd_amroutine->ampredlocks)) + if (!(indexRelation->rd_indam->ampredlocks)) CheckForSerializableConflictIn(indexRelation, (HeapTuple) NULL, InvalidBuffer); - return indexRelation->rd_amroutine->aminsert(indexRelation, values, isnull, - heap_t_ctid, heapRelation, - checkUnique, indexInfo); + return indexRelation->rd_indam->aminsert(indexRelation, values, isnull, + heap_t_ctid, heapRelation, + checkUnique, indexInfo); } /* @@ -275,7 +275,7 @@ index_beginscan_internal(Relation indexRelation, RELATION_CHECKS; CHECK_REL_PROCEDURE(ambeginscan); - if (!(indexRelation->rd_amroutine->ampredlocks)) + if (!(indexRelation->rd_indam->ampredlocks)) PredicateLockRelation(indexRelation, snapshot); /* @@ -286,8 +286,8 @@ index_beginscan_internal(Relation indexRelation, /* * Tell the AM to open a scan. */ - scan = indexRelation->rd_amroutine->ambeginscan(indexRelation, nkeys, - norderbys); + scan = indexRelation->rd_indam->ambeginscan(indexRelation, nkeys, + norderbys); /* Initialize information for parallel scan. */ scan->parallel_scan = pscan; scan->xs_temp_snap = temp_snap; @@ -329,8 +329,8 @@ index_rescan(IndexScanDesc scan, scan->kill_prior_tuple = false; /* for safety */ - scan->indexRelation->rd_amroutine->amrescan(scan, keys, nkeys, - orderbys, norderbys); + scan->indexRelation->rd_indam->amrescan(scan, keys, nkeys, + orderbys, norderbys); } /* ---------------- @@ -351,7 +351,7 @@ index_endscan(IndexScanDesc scan) } /* End the AM's scan */ - scan->indexRelation->rd_amroutine->amendscan(scan); + scan->indexRelation->rd_indam->amendscan(scan); /* Release index refcount acquired by index_beginscan */ RelationDecrementReferenceCount(scan->indexRelation); @@ -373,7 +373,7 @@ index_markpos(IndexScanDesc scan) SCAN_CHECKS; CHECK_SCAN_PROCEDURE(ammarkpos); - scan->indexRelation->rd_amroutine->ammarkpos(scan); + scan->indexRelation->rd_indam->ammarkpos(scan); } /* ---------------- @@ -404,7 +404,7 @@ index_restrpos(IndexScanDesc scan) scan->kill_prior_tuple = false; /* for safety */ - scan->indexRelation->rd_amroutine->amrestrpos(scan); + scan->indexRelation->rd_indam->amrestrpos(scan); } /* @@ -430,9 +430,9 @@ index_parallelscan_estimate(Relation indexRelation, Snapshot snapshot) * AM-specific data needed. (It's hard to believe that could work, but * it's easy enough to cater to it here.) */ - if (indexRelation->rd_amroutine->amestimateparallelscan != NULL) + if (indexRelation->rd_indam->amestimateparallelscan != NULL) nbytes = add_size(nbytes, - indexRelation->rd_amroutine->amestimateparallelscan()); + indexRelation->rd_indam->amestimateparallelscan()); return nbytes; } @@ -465,12 +465,12 @@ index_parallelscan_initialize(Relation heapRelation, Relation indexRelation, SerializeSnapshot(snapshot, target->ps_snapshot_data); /* aminitparallelscan is optional; assume no-op if not provided by AM */ - if (indexRelation->rd_amroutine->aminitparallelscan != NULL) + if (indexRelation->rd_indam->aminitparallelscan != NULL) { void *amtarget; amtarget = OffsetToPointer(target, offset); - indexRelation->rd_amroutine->aminitparallelscan(amtarget); + indexRelation->rd_indam->aminitparallelscan(amtarget); } } @@ -484,8 +484,8 @@ index_parallelrescan(IndexScanDesc scan) SCAN_CHECKS; /* amparallelrescan is optional; assume no-op if not provided by AM */ - if (scan->indexRelation->rd_amroutine->amparallelrescan != NULL) - scan->indexRelation->rd_amroutine->amparallelrescan(scan); + if (scan->indexRelation->rd_indam->amparallelrescan != NULL) + scan->indexRelation->rd_indam->amparallelrescan(scan); } /* @@ -539,7 +539,7 @@ index_getnext_tid(IndexScanDesc scan, ScanDirection direction) * scan->xs_recheck and possibly scan->xs_itup/scan->xs_hitup, though we * pay no attention to those fields here. */ - found = scan->indexRelation->rd_amroutine->amgettuple(scan, direction); + found = scan->indexRelation->rd_indam->amgettuple(scan, direction); /* Reset kill flag immediately for safety */ scan->kill_prior_tuple = false; @@ -724,7 +724,7 @@ index_getbitmap(IndexScanDesc scan, TIDBitmap *bitmap) /* * have the am's getbitmap proc do all the work. */ - ntids = scan->indexRelation->rd_amroutine->amgetbitmap(scan, bitmap); + ntids = scan->indexRelation->rd_indam->amgetbitmap(scan, bitmap); pgstat_count_index_tuples(scan->indexRelation, ntids); @@ -751,8 +751,8 @@ index_bulk_delete(IndexVacuumInfo *info, RELATION_CHECKS; CHECK_REL_PROCEDURE(ambulkdelete); - return indexRelation->rd_amroutine->ambulkdelete(info, stats, - callback, callback_state); + return indexRelation->rd_indam->ambulkdelete(info, stats, + callback, callback_state); } /* ---------------- @@ -770,7 +770,7 @@ index_vacuum_cleanup(IndexVacuumInfo *info, RELATION_CHECKS; CHECK_REL_PROCEDURE(amvacuumcleanup); - return indexRelation->rd_amroutine->amvacuumcleanup(info, stats); + return indexRelation->rd_indam->amvacuumcleanup(info, stats); } /* ---------------- @@ -786,10 +786,10 @@ index_can_return(Relation indexRelation, int attno) RELATION_CHECKS; /* amcanreturn is optional; assume false if not provided by AM */ - if (indexRelation->rd_amroutine->amcanreturn == NULL) + if (indexRelation->rd_indam->amcanreturn == NULL) return false; - return indexRelation->rd_amroutine->amcanreturn(indexRelation, attno); + return indexRelation->rd_indam->amcanreturn(indexRelation, attno); } /* ---------------- @@ -827,7 +827,7 @@ index_getprocid(Relation irel, int nproc; int procindex; - nproc = irel->rd_amroutine->amsupport; + nproc = irel->rd_indam->amsupport; Assert(procnum > 0 && procnum <= (uint16) nproc); @@ -861,7 +861,7 @@ index_getprocinfo(Relation irel, int nproc; int procindex; - nproc = irel->rd_amroutine->amsupport; + nproc = irel->rd_indam->amsupport; Assert(procnum > 0 && procnum <= (uint16) nproc); |