56#include "utils/fmgroids.h"
68#define PARALLEL_VACUUM_DELAY_REPORT_INTERVAL_NS (NS_PER_S)
146 "vacuum_buffer_usage_limit",
164 bool skip_locked =
false;
168 bool disable_page_skipping =
false;
169 bool process_main =
true;
170 bool process_toast =
true;
172 bool skip_database_stats =
false;
173 bool only_database_stats =
false;
199 if (strcmp(opt->
defname,
"verbose") == 0)
201 else if (strcmp(opt->
defname,
"skip_locked") == 0)
203 else if (strcmp(opt->
defname,
"buffer_usage_limit") == 0)
207 char *vac_buffer_size;
220 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
221 errmsg(
"BUFFER_USAGE_LIMIT option must be 0 or between %d kB and %d kB",
223 hintmsg ?
errhint(
"%s",
_(hintmsg)) : 0));
230 (
errcode(ERRCODE_SYNTAX_ERROR),
235 else if (strcmp(opt->
defname,
"analyze") == 0)
237 else if (strcmp(opt->
defname,
"freeze") == 0)
239 else if (strcmp(opt->
defname,
"full") == 0)
241 else if (strcmp(opt->
defname,
"disable_page_skipping") == 0)
243 else if (strcmp(opt->
defname,
"index_cleanup") == 0)
259 else if (strcmp(opt->
defname,
"process_main") == 0)
261 else if (strcmp(opt->
defname,
"process_toast") == 0)
263 else if (strcmp(opt->
defname,
"truncate") == 0)
265 else if (strcmp(opt->
defname,
"parallel") == 0)
267 if (opt->
arg == NULL)
270 (
errcode(ERRCODE_SYNTAX_ERROR),
271 errmsg(
"parallel option requires a value between 0 and %d",
282 (
errcode(ERRCODE_SYNTAX_ERROR),
283 errmsg(
"parallel workers for vacuum must be between 0 and %d",
297 else if (strcmp(opt->
defname,
"skip_database_stats") == 0)
299 else if (strcmp(opt->
defname,
"only_database_stats") == 0)
303 (
errcode(ERRCODE_SYNTAX_ERROR),
329 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
330 errmsg(
"VACUUM FULL cannot be performed in parallel")));
340 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
341 errmsg(
"BUFFER_USAGE_LIMIT cannot be specified for VACUUM FULL")));
348 foreach(lc, vacstmt->
rels)
354 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
355 errmsg(
"ANALYZE option must be specified when a column list is provided")));
366 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
367 errmsg(
"VACUUM option DISABLE_PAGE_SKIPPING cannot be used with FULL")));
373 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
374 errmsg(
"PROCESS_TOAST required with VACUUM FULL")));
382 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
383 errmsg(
"ONLY_DATABASE_STATS cannot be specified with a list of tables")));
391 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
392 errmsg(
"ONLY_DATABASE_STATS cannot be specified with other VACUUM options")));
466 vacuum(vacstmt->
rels, ¶ms, bstrategy, vac_context, isTopLevel);
498 static bool in_vacuum =
false;
500 const char *stmttype;
501 volatile bool in_outer_xact,
519 in_outer_xact =
false;
531 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
532 errmsg(
"%s cannot be executed from VACUUM or ANALYZE",
544 else if (relations !=
NIL)
549 foreach(lc, relations)
580 use_own_xacts =
true;
585 use_own_xacts =
true;
586 else if (in_outer_xact)
587 use_own_xacts =
false;
589 use_own_xacts =
true;
591 use_own_xacts =
false;
630 foreach(
cur, relations)
654 vrel->
va_cols, in_outer_xact, bstrategy);
735 !reltuple->relisshared) ||
744 (
errmsg(
"permission denied to vacuum \"%s\", skipping it",
757 (
errmsg(
"permission denied to analyze \"%s\", skipping it",
776 bool rel_lock =
true;
813 if (relation == NULL)
834 (
errcode(ERRCODE_LOCK_NOT_AVAILABLE),
835 errmsg(
"skipping vacuum of \"%s\" --- lock not available",
840 errmsg(
"skipping vacuum of \"%s\" --- relation no longer exists",
855 (
errcode(ERRCODE_LOCK_NOT_AVAILABLE),
856 errmsg(
"skipping analyze of \"%s\" --- lock not available",
861 errmsg(
"skipping analyze of \"%s\" --- relation no longer exists",
894 vacrels =
lappend(vacrels, vrel);
906 bool include_children;
907 bool is_partitioned_table;
935 (
errcode(ERRCODE_LOCK_NOT_AVAILABLE),
936 errmsg(
"skipping vacuum of \"%s\" --- lock not available",
940 (
errcode(ERRCODE_LOCK_NOT_AVAILABLE),
941 errmsg(
"skipping analyze of \"%s\" --- lock not available",
952 elog(
ERROR,
"cache lookup failed for relation %u", relid);
974 is_partitioned_table = (classForm->relkind == RELKIND_PARTITIONED_TABLE);
977 (
errmsg(
"VACUUM ONLY of partitioned table \"%s\" has no effect",
992 if (include_children)
997 foreach(part_lc, part_oids)
1001 if (part_oid == relid)
1054 Oid relid = classForm->oid;
1061 if (classForm->relkind != RELKIND_RELATION &&
1062 classForm->relkind != RELKIND_MATVIEW &&
1063 classForm->relkind != RELKIND_PARTITIONED_TABLE)
1105 multixact_freeze_min_age,
1107 multixact_freeze_table_age,
1108 effective_multixact_freeze_max_age;
1111 aggressiveXIDCutoff;
1114 aggressiveMXIDCutoff;
1163 safeOldestMxact = nextMXID - effective_multixact_freeze_max_age;
1168 (
errmsg(
"cutoff for removing and freezing tuples is far in the past"),
1169 errhint(
"Close open transactions soon to avoid wraparound problems.\n"
1170 "You might also need to commit or roll back old prepared transactions, or drop stale replication slots.")));
1173 (
errmsg(
"cutoff for freezing multixacts is far in the past"),
1174 errhint(
"Close open transactions soon to avoid wraparound problems.\n"
1175 "You might also need to commit or roll back old prepared transactions, or drop stale replication slots.")));
1183 if (freeze_min_age < 0)
1186 Assert(freeze_min_age >= 0);
1202 if (multixact_freeze_min_age < 0)
1204 multixact_freeze_min_age =
Min(multixact_freeze_min_age,
1205 effective_multixact_freeze_max_age / 2);
1206 Assert(multixact_freeze_min_age >= 0);
1225 if (freeze_table_age < 0)
1228 Assert(freeze_table_age >= 0);
1229 aggressiveXIDCutoff = nextXID - freeze_table_age;
1233 aggressiveXIDCutoff))
1244 if (multixact_freeze_table_age < 0)
1246 multixact_freeze_table_age =
1247 Min(multixact_freeze_table_age,
1248 effective_multixact_freeze_max_age * 0.95);
1249 Assert(multixact_freeze_table_age >= 0);
1250 aggressiveMXIDCutoff = nextMXID - multixact_freeze_table_age;
1254 aggressiveMXIDCutoff))
1275 int skip_index_vacuum;
1334 double scanned_tuples)
1337 double old_rel_tuples = relation->
rd_rel->reltuples;
1339 double unscanned_pages;
1340 double total_tuples;
1343 if (scanned_pages >= total_pages)
1344 return scanned_tuples;
1360 if (old_rel_pages == total_pages &&
1361 scanned_pages < (
double) total_pages * 0.02)
1362 return old_rel_tuples;
1363 if (scanned_pages <= 1)
1364 return old_rel_tuples;
1370 if (old_rel_tuples < 0 || old_rel_pages == 0)
1371 return floor((scanned_tuples / scanned_pages) * total_pages + 0.5);
1379 old_density = old_rel_tuples / old_rel_pages;
1380 unscanned_pages = (double) total_pages - (
double) scanned_pages;
1381 total_tuples = old_density * unscanned_pages + scanned_tuples;
1382 return floor(total_tuples + 0.5);
1432 bool *frozenxid_updated,
bool *minmulti_updated,
1439 void *inplace_state;
1455 NULL, 1,
key, &ctup, &inplace_state);
1457 elog(
ERROR,
"pg_class entry for relid %u vanished during vacuuming",
1464 if (pgcform->relpages != (
int32) num_pages)
1466 pgcform->relpages = (
int32) num_pages;
1469 if (pgcform->reltuples != (
float4) num_tuples)
1471 pgcform->reltuples = (
float4) num_tuples;
1474 if (pgcform->relallvisible != (
int32) num_all_visible_pages)
1476 pgcform->relallvisible = (
int32) num_all_visible_pages;
1487 if (pgcform->relhasindex && !hasindex)
1489 pgcform->relhasindex =
false;
1494 if (pgcform->relhasrules && relation->
rd_rules == NULL)
1496 pgcform->relhasrules =
false;
1499 if (pgcform->relhastriggers && relation->
trigdesc == NULL)
1501 pgcform->relhastriggers =
false;
1516 oldfrozenxid = pgcform->relfrozenxid;
1518 if (frozenxid_updated)
1519 *frozenxid_updated =
false;
1522 bool update =
false;
1527 futurexid = update =
true;
1531 pgcform->relfrozenxid = frozenxid;
1533 if (frozenxid_updated)
1534 *frozenxid_updated =
true;
1539 oldminmulti = pgcform->relminmxid;
1541 if (minmulti_updated)
1542 *minmulti_updated =
false;
1545 bool update =
false;
1550 futuremxid = update =
true;
1554 pgcform->relminmxid = minmulti;
1556 if (minmulti_updated)
1557 *minmulti_updated =
true;
1572 errmsg_internal(
"overwrote invalid relfrozenxid value %u with new value %u for table \"%s\"",
1573 oldfrozenxid, frozenxid,
1578 errmsg_internal(
"overwrote invalid relminmxid value %u with new value %u for table \"%s\"",
1579 oldminmulti, minmulti,
1617 void *inplace_state;
1671 if (classForm->relkind != RELKIND_RELATION &&
1672 classForm->relkind != RELKIND_MATVIEW &&
1673 classForm->relkind != RELKIND_TOASTVALUE)
1708 newFrozenXid = relfrozenxid;
1722 newMinMulti = relminmxid;
1747 Anum_pg_database_oid,
1752 NULL, 1,
key, &tuple, &inplace_state);
1764 if (dbform->datfrozenxid != newFrozenXid &&
1768 dbform->datfrozenxid = newFrozenXid;
1772 newFrozenXid = dbform->datfrozenxid;
1775 if (dbform->datminmxid != newMinMulti &&
1779 dbform->datminmxid = newMinMulti;
1783 newMinMulti = dbform->datminmxid;
1800 lastSaneFrozenXid, lastSaneMinMulti);
1831 Oid oldestxid_datoid;
1832 Oid minmulti_datoid;
1834 bool frozenAlreadyWrapped =
false;
1883 "skipping invalid database \"%s\" while computing relfrozenxid",
1902 frozenAlreadyWrapped =
true;
1906 oldestxid_datoid = dbform->oid;
1912 minmulti_datoid = dbform->oid;
1926 if (frozenAlreadyWrapped)
1929 (
errmsg(
"some databases have not been vacuumed in over 2 billion transactions"),
1930 errdetail(
"You might have already suffered transaction-wraparound data loss.")));
2000 int save_sec_context;
2103 if (rel->
rd_rel->relkind != RELKIND_RELATION &&
2104 rel->
rd_rel->relkind != RELKIND_MATVIEW &&
2105 rel->
rd_rel->relkind != RELKIND_TOASTVALUE &&
2106 rel->
rd_rel->relkind != RELKIND_PARTITIONED_TABLE)
2109 (
errmsg(
"skipping \"%s\" --- cannot vacuum non-tables or special system tables",
2137 if (rel->
rd_rel->relkind == RELKIND_PARTITIONED_TABLE)
2170 vacuum_index_cleanup =
2179 Assert(vacuum_index_cleanup ==
2216 toast_relid = rel->
rd_rel->reltoastrelid;
2293 memcpy(&toast_vacuum_params, params,
sizeof(
VacuumParams));
2297 vacuum_rel(toast_relid, NULL, &toast_vacuum_params, bstrategy);
2344 foreach(indexoidscan, indexoidlist)
2351 (*Irel)[
i++] = indrel;
2478 last_report_time = delay_end;
2482 else if (is_analyze)
2602 (
errmsg(
"scanned index \"%s\" to remove %lld row versions",
2604 (
long long) dead_items_info->
num_items)));
2621 (
errmsg(
"index \"%s\" now contains %.0f row versions in %u pages",
2625 errdetail(
"%.0f index row versions were removed.\n"
2626 "%u index pages were newly deleted.\n"
2627 "%u index pages are currently deleted, of which %u are currently reusable.",
bool object_ownercheck(Oid classid, Oid objectid, Oid roleid)
AclResult pg_class_aclcheck(Oid table_oid, Oid roleid, AclMode mode)
static uint32 pg_atomic_sub_fetch_u32(volatile pg_atomic_uint32 *ptr, int32 sub_)
static uint32 pg_atomic_add_fetch_u32(volatile pg_atomic_uint32 *ptr, int32 add_)
static uint32 pg_atomic_read_u32(volatile pg_atomic_uint32 *ptr)
void VacuumUpdateCosts(void)
int autovacuum_multixact_freeze_max_age
int autovacuum_freeze_max_age
void AutoVacuumUpdateCostLimit(void)
void pgstat_progress_parallel_incr_param(int index, int64 incr)
void pgstat_progress_incr_param(int index, int64 incr)
#define MAX_PARALLEL_WORKER_LIMIT
#define Assert(condition)
TransactionId MultiXactId
#define OidIsValid(objectId)
void TruncateCLOG(TransactionId oldestXact, Oid oldestxid_datoid)
void cluster_rel(Relation OldHeap, Oid indexOid, ClusterParams *params)
void analyze_rel(Oid relid, RangeVar *relation, VacuumParams *params, List *va_cols, bool in_outer_xact, BufferAccessStrategy bstrategy)
void AdvanceOldestCommitTsXid(TransactionId oldestXact)
void TruncateCommitTs(TransactionId oldestXact)
bool database_is_invalid_form(Form_pg_database datform)
int32 defGetInt32(DefElem *def)
char * defGetString(DefElem *def)
bool defGetBoolean(DefElem *def)
int errmsg_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,...)
BufferAccessStrategy GetAccessStrategyWithSize(BufferAccessStrategyType btype, int ring_size_kb)
void systable_endscan(SysScanDesc sysscan)
void systable_inplace_update_cancel(void *state)
void systable_inplace_update_begin(Relation relation, Oid indexId, bool indexOK, Snapshot snapshot, int nkeys, const ScanKeyData *key, HeapTuple *oldtupcopy, void **state)
void systable_inplace_update_finish(void *state, HeapTuple tuple)
HeapTuple systable_getnext(SysScanDesc sysscan)
SysScanDesc systable_beginscan(Relation heapRelation, Oid indexId, bool indexOK, Snapshot snapshot, int nkeys, ScanKey key)
volatile sig_atomic_t InterruptPending
int VacuumBufferUsageLimit
void ProcessConfigFile(GucContext context)
bool parse_int(const char *value, int *result, int flags, const char **hintmsg)
int NewGUCNestLevel(void)
void RestrictSearchPath(void)
void AtEOXact_GUC(bool isCommit, int nestLevel)
#define GUC_check_errdetail
HeapTuple heap_getnext(TableScanDesc sscan, ScanDirection direction)
void heap_freetuple(HeapTuple htup)
#define HeapTupleIsValid(tuple)
static void * GETSTRUCT(const HeapTupleData *tuple)
#define IsParallelWorker()
IndexBulkDeleteResult * index_vacuum_cleanup(IndexVacuumInfo *info, IndexBulkDeleteResult *istat)
IndexBulkDeleteResult * index_bulk_delete(IndexVacuumInfo *info, IndexBulkDeleteResult *istat, IndexBulkDeleteCallback callback, void *callback_state)
void index_close(Relation relation, LOCKMODE lockmode)
Relation index_open(Oid relationId, LOCKMODE lockmode)
#define INSTR_TIME_SET_CURRENT(t)
#define INSTR_TIME_GET_NANOSEC(t)
#define INSTR_TIME_SET_ZERO(t)
#define INSTR_TIME_ACCUM_DIFF(x, y, z)
volatile sig_atomic_t ConfigReloadPending
List * lappend(List *list, void *datum)
List * list_concat(List *list1, const List *list2)
void list_free(List *list)
bool ConditionalLockRelationOid(Oid relid, LOCKMODE lockmode)
void UnlockRelationOid(Oid relid, LOCKMODE lockmode)
void LockRelationIdForSession(LockRelId *relid, LOCKMODE lockmode)
void UnlockRelationIdForSession(LockRelId *relid, LOCKMODE lockmode)
void LockDatabaseFrozenIds(LOCKMODE lockmode)
#define AccessExclusiveLock
#define ShareUpdateExclusiveLock
bool LWLockAcquire(LWLock *lock, LWLockMode mode)
void LWLockRelease(LWLock *lock)
VacuumRelation * makeVacuumRelation(RangeVar *relation, Oid oid, List *va_cols)
void pfree(void *pointer)
void MemoryContextDelete(MemoryContext context)
MemoryContext PortalContext
#define AllocSetContextCreate
#define ALLOCSET_DEFAULT_SIZES
#define AmAutoVacuumWorkerProcess()
#define MIN_BAS_VAC_RING_SIZE_KB
#define MAX_BAS_VAC_RING_SIZE_KB
#define SECURITY_RESTRICTED_OPERATION
#define CHECK_FOR_INTERRUPTS()
void GetUserIdAndSecContext(Oid *userid, int *sec_context)
void SetUserIdAndSecContext(Oid userid, int sec_context)
bool MultiXactIdPrecedes(MultiXactId multi1, MultiXactId multi2)
bool MultiXactIdPrecedesOrEquals(MultiXactId multi1, MultiXactId multi2)
void SetMultiXactIdLimit(MultiXactId oldest_datminmxid, Oid oldest_datoid, bool is_startup)
MultiXactId GetOldestMultiXactId(void)
int MultiXactMemberFreezeThreshold(void)
MultiXactId ReadNextMultiXactId(void)
void TruncateMultiXact(MultiXactId newOldestMulti, Oid newOldestMultiDB)
#define MultiXactIdIsValid(multi)
Oid RangeVarGetRelidExtended(const RangeVar *relation, LOCKMODE lockmode, uint32 flags, RangeVarGetRelidCallback callback, void *callback_arg)
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
int parser_errposition(ParseState *pstate, int location)
#define ERRCODE_DATA_CORRUPTED
FormData_pg_class * Form_pg_class
TransactionId datfrozenxid
FormData_pg_database * Form_pg_database
List * find_all_inheritors(Oid parentrelId, LOCKMODE lockmode, List **numparents)
#define lfirst_node(type, lc)
static int list_length(const List *l)
static rewind_source * source
#define ERRCODE_UNDEFINED_TABLE
#define PostmasterIsAlive()
int pg_strcasecmp(const char *s1, const char *s2)
static Datum ObjectIdGetDatum(Oid X)
#define PROC_VACUUM_FOR_WRAPAROUND
TransactionId GetOldestNonRemovableTransactionId(Relation rel)
#define PROGRESS_VACUUM_DELAY_TIME
#define PROGRESS_ANALYZE_DELAY_TIME
static long analyze(struct nfa *nfa)
#define RelationGetRelid(relation)
#define RelationGetRelationName(relation)
#define RELATION_IS_OTHER_TEMP(relation)
@ STDRD_OPTION_VACUUM_INDEX_CLEANUP_AUTO
@ STDRD_OPTION_VACUUM_INDEX_CLEANUP_OFF
@ STDRD_OPTION_VACUUM_INDEX_CLEANUP_ON
List * RelationGetIndexList(Relation relation)
void ScanKeyInit(ScanKey entry, AttrNumber attributeNumber, StrategyNumber strategy, RegProcedure procedure, Datum argument)
void pg_usleep(long microsec)
Snapshot GetTransactionSnapshot(void)
void PushActiveSnapshot(Snapshot snapshot)
bool ActiveSnapshotSet(void)
void PopActiveSnapshot(void)
void relation_close(Relation relation, LOCKMODE lockmode)
Relation try_relation_open(Oid relationId, LOCKMODE lockmode)
#define BTEqualStrategyNumber
BlockNumber pages_deleted
BlockNumber pages_newly_deleted
TransactionId FreezeLimit
TransactionId relfrozenxid
MultiXactId MultiXactCutoff
int multixact_freeze_min_age
int multixact_freeze_table_age
VacOptValue index_cleanup
double max_eager_freeze_failure_rate
void ReleaseSysCache(HeapTuple tuple)
HeapTuple SearchSysCache1(int cacheId, Datum key1)
void table_close(Relation relation, LOCKMODE lockmode)
Relation table_open(Oid relationId, LOCKMODE lockmode)
TableScanDesc table_beginscan_catalog(Relation relation, int nkeys, struct ScanKeyData *key)
static void table_endscan(TableScanDesc scan)
static void table_relation_vacuum(Relation rel, struct VacuumParams *params, BufferAccessStrategy bstrategy)
bool TidStoreIsMember(TidStore *ts, ItemPointer tid)
bool TransactionIdPrecedes(TransactionId id1, TransactionId id2)
bool TransactionIdPrecedesOrEquals(TransactionId id1, TransactionId id2)
static TransactionId ReadNextTransactionId(void)
#define FirstNormalTransactionId
#define TransactionIdIsValid(xid)
#define TransactionIdIsNormal(xid)
static bool vac_tid_reaped(ItemPointer itemptr, void *state)
void ExecVacuum(ParseState *pstate, VacuumStmt *vacstmt, bool isTopLevel)
pg_atomic_uint32 * VacuumActiveNWorkers
static void vac_truncate_clog(TransactionId frozenXID, MultiXactId minMulti, TransactionId lastSaneFrozenXid, MultiXactId lastSaneMinMulti)
int vacuum_freeze_min_age
double vacuum_max_eager_freeze_failure_rate
bool track_cost_delay_timing
static List * expand_vacuum_rel(VacuumRelation *vrel, MemoryContext vac_context, int options)
static double compute_parallel_delay(void)
static VacOptValue get_vacoptval_from_boolean(DefElem *def)
void vac_open_indexes(Relation relation, LOCKMODE lockmode, int *nindexes, Relation **Irel)
void vacuum(List *relations, VacuumParams *params, BufferAccessStrategy bstrategy, MemoryContext vac_context, bool isTopLevel)
#define PARALLEL_VACUUM_DELAY_REPORT_INTERVAL_NS
bool check_vacuum_buffer_usage_limit(int *newval, void **extra, GucSource source)
int VacuumCostBalanceLocal
static List * get_all_vacuum_rels(MemoryContext vac_context, int options)
void vac_update_relstats(Relation relation, BlockNumber num_pages, double num_tuples, BlockNumber num_all_visible_pages, bool hasindex, TransactionId frozenxid, MultiXactId minmulti, bool *frozenxid_updated, bool *minmulti_updated, bool in_outer_xact)
int vacuum_multixact_freeze_table_age
int vacuum_freeze_table_age
IndexBulkDeleteResult * vac_cleanup_one_index(IndexVacuumInfo *ivinfo, IndexBulkDeleteResult *istat)
int vacuum_multixact_failsafe_age
int vacuum_multixact_freeze_min_age
Relation vacuum_open_relation(Oid relid, RangeVar *relation, bits32 options, bool verbose, LOCKMODE lmode)
static bool vacuum_rel(Oid relid, RangeVar *relation, VacuumParams *params, BufferAccessStrategy bstrategy)
int64 parallel_vacuum_worker_delay_ns
void vac_close_indexes(int nindexes, Relation *Irel, LOCKMODE lockmode)
void vac_update_datfrozenxid(void)
void vacuum_delay_point(bool is_analyze)
bool vacuum_get_cutoffs(Relation rel, const VacuumParams *params, struct VacuumCutoffs *cutoffs)
bool vacuum_xid_failsafe_check(const struct VacuumCutoffs *cutoffs)
pg_atomic_uint32 * VacuumSharedCostBalance
bool VacuumFailsafeActive
double vac_estimate_reltuples(Relation relation, BlockNumber total_pages, BlockNumber scanned_pages, double scanned_tuples)
bool vacuum_is_permitted_for_relation(Oid relid, Form_pg_class reltuple, bits32 options)
IndexBulkDeleteResult * vac_bulkdel_one_index(IndexVacuumInfo *ivinfo, IndexBulkDeleteResult *istat, TidStore *dead_items, VacDeadItemsInfo *dead_items_info)
#define VACOPT_SKIP_LOCKED
#define VACOPT_SKIP_DATABASE_STATS
@ VACOPTVALUE_UNSPECIFIED
#define VACOPT_PROCESS_TOAST
#define VACOPT_DISABLE_PAGE_SKIPPING
#define VACOPT_ONLY_DATABASE_STATS
#define VACOPT_PROCESS_MAIN
void SetTransactionIdLimit(TransactionId oldest_datfrozenxid, Oid oldest_datoid)
bool ForceTransactionIdLimitUpdate(void)
static void pgstat_report_wait_start(uint32 wait_event_info)
static void pgstat_report_wait_end(void)
bool IsInTransactionBlock(bool isTopLevel)
void CommandCounterIncrement(void)
void PreventInTransactionBlock(bool isTopLevel, const char *stmtType)
void StartTransactionCommand(void)
void CommitTransactionCommand(void)