118 prune_xid = ((
PageHeader) page)->pd_prune_xid;
148 &limited_xmin, &limited_ts))
169 minfree =
Max(minfree, BLCKSZ / 10);
190 limited_xmin, limited_ts,
191 true, &ignore, NULL);
248 prstate.
rel = relation;
266 if (prstate.
marked[offnum])
362 if (report_stats && ndeleted > prstate.
ndead)
567 if (offnum < FirstOffsetNumber || offnum > maxoff)
571 if (prstate->
marked[offnum])
589 chainitems[nchain++] = offnum;
619 chainitems[nchain++] = offnum;
624 tupdead = recent_dead =
false;
665 elog(
ERROR,
"unexpected HeapTupleSatisfiesVacuum result");
682 else if (!recent_dead)
718 for (
i = 1; (
i < nchain) && (chainitems[
i - 1] != latestdead);
i++)
781 prstate->
marked[offnum] =
true;
783 prstate->
marked[rdoffnum] =
true;
794 prstate->
marked[offnum] =
true;
805 prstate->
marked[offnum] =
true;
830 for (i = 0; i < nredirected; i++)
841 for (i = 0; i < ndead; i++)
851 for (i = 0; i < nunused; i++)
919 root_offsets[offnum - 1] = offnum;
961 root_offsets[nextoffnum - 1] = offnum;
#define HeapTupleHeaderGetUpdateXid(tup)
void HeapTupleHeaderAdvanceLatestRemovedXid(HeapTupleHeader tuple, TransactionId *latestRemovedXid)
#define BUFFER_LOCK_UNLOCK
int heap_page_prune(Relation relation, Buffer buffer, GlobalVisState *vistest, TransactionId old_snap_xmin, TimestampTz old_snap_ts, bool report_stats, TransactionId *latestRemovedXid, OffsetNumber *off_loc)
static int heap_prune_chain(Buffer buffer, OffsetNumber rootoffnum, PruneState *prstate)
#define ItemIdIsRedirected(itemId)
#define TransactionIdEquals(id1, id2)
void pgstat_update_heap_dead_tuples(Relation rel, int delta)
void MarkBufferDirtyHint(Buffer buffer, bool buffer_std)
void MarkBufferDirty(Buffer buffer)
HeapTupleHeaderData * HeapTupleHeader
static bool OldSnapshotThresholdActive(void)
#define ItemIdGetRedirect(itemId)
#define END_CRIT_SECTION()
#define ItemIdIsUsed(itemId)
#define MaxHeapTuplesPerPage
static void heap_prune_record_dead(PruneState *prstate, OffsetNumber offnum)
#define START_CRIT_SECTION()
#define MemSet(start, val, len)
#define HeapTupleHeaderIndicatesMovedPartitions(tup)
OffsetNumber nowdead[MaxHeapTuplesPerPage]
bool TransactionIdLimitedForOldSnapshots(TransactionId recentXmin, Relation relation, TransactionId *limit_xid, TimestampTz *limit_ts)
bool RecoveryInProgress(void)
#define ItemIdIsDead(itemId)
bool marked[MaxHeapTuplesPerPage+1]
#define PageGetMaxOffsetNumber(page)
TransactionId new_prune_xid
bool GlobalVisTestIsRemovableXid(GlobalVisState *state, TransactionId xid)
void SetOldSnapshotThresholdTimestamp(TimestampTz ts, TransactionId xlimit)
#define HeapTupleHeaderIsHeapOnly(tup)
GlobalVisState * GlobalVisTestFor(Relation rel)
#define ItemIdGetLength(itemId)
bool ConditionalLockBufferForCleanup(Buffer buffer)
Size PageGetHeapFreeSpace(Page page)
static void heap_prune_record_prunable(PruneState *prstate, TransactionId xid)
TransactionId latestRemovedXid
#define ItemIdSetRedirect(itemId, link)
#define FirstOffsetNumber
void SnapshotTooOldMagicForTest(void)
#define InvalidTransactionId
#define BufferGetPage(buffer)
void heap_get_root_tuples(Page page, OffsetNumber *root_offsets)
HTSV_Result HeapTupleSatisfiesVacuumHorizon(HeapTuple htup, Buffer buffer, TransactionId *dead_after)
#define PageClearFull(page)
bool TransactionIdPrecedes(TransactionId id1, TransactionId id2)
#define RelationGetTargetPageFreeSpace(relation, defaultff)
#define HeapTupleHeaderIsHotUpdated(tup)
#define PageGetItemId(page, offsetNumber)
void LockBuffer(Buffer buffer, int mode)
TransactionId old_snap_xmin
static HTSV_Result heap_prune_satisfies_vacuum(PruneState *prstate, HeapTuple tup, Buffer buffer)
#define InvalidOffsetNumber
void heap_page_prune_execute(Buffer buffer, OffsetNumber *redirected, int nredirected, OffsetNumber *nowdead, int ndead, OffsetNumber *nowunused, int nunused)
PageHeaderData * PageHeader
#define Assert(condition)
static void heap_prune_record_redirect(PruneState *prstate, OffsetNumber offnum, OffsetNumber rdoffnum)
#define ItemIdIsNormal(itemId)
#define HeapTupleHeaderGetXmin(tup)
#define OffsetNumberNext(offsetNumber)
OffsetNumber nowunused[MaxHeapTuplesPerPage]
XLogRecPtr log_heap_clean(Relation reln, Buffer buffer, OffsetNumber *redirected, int nredirected, OffsetNumber *nowdead, int ndead, OffsetNumber *nowunused, int nunused, TransactionId latestRemovedXid)
#define ItemPointerGetOffsetNumber(pointer)
#define RelationNeedsWAL(relation)
OffsetNumber redirected[MaxHeapTuplesPerPage *2]
BlockNumber BufferGetBlockNumber(Buffer buffer)
void PageRepairFragmentation(Page page)
int old_snapshot_threshold
#define OffsetNumberIsValid(offsetNumber)
#define ItemIdSetDead(itemId)
void heap_page_prune_opt(Relation relation, Buffer buffer)
#define ItemPointerGetBlockNumber(pointer)
#define HEAP_DEFAULT_FILLFACTOR
#define TransactionIdIsValid(xid)
#define ItemIdSetUnused(itemId)
TransactionId GlobalVisTestNonRemovableHorizon(GlobalVisState *state)
#define TransactionIdIsNormal(xid)
#define PageSetLSN(page, lsn)
#define RelationGetRelid(relation)
#define PageGetItem(page, itemId)
#define ItemPointerSet(pointer, blockNumber, offNum)
static void heap_prune_record_unused(PruneState *prstate, OffsetNumber offnum)