diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/backend/postmaster/autovacuum.c | 23 |
1 files changed, 20 insertions, 3 deletions
diff --git a/src/backend/postmaster/autovacuum.c b/src/backend/postmaster/autovacuum.c index 4f3bd711494..f0e2a173401 100644 --- a/src/backend/postmaster/autovacuum.c +++ b/src/backend/postmaster/autovacuum.c @@ -177,6 +177,7 @@ typedef struct autovac_table int at_freeze_table_age; int at_vacuum_cost_delay; int at_vacuum_cost_limit; + bool at_dobalance; bool at_wraparound; char *at_relname; char *at_nspname; @@ -207,6 +208,7 @@ typedef struct WorkerInfoData Oid wi_tableoid; PGPROC *wi_proc; TimestampTz wi_launchtime; + bool wi_dobalance; int wi_cost_delay; int wi_cost_limit; int wi_cost_limit_base; @@ -1680,6 +1682,7 @@ FreeWorkerInfo(int code, Datum arg) MyWorkerInfo->wi_tableoid = InvalidOid; MyWorkerInfo->wi_proc = NULL; MyWorkerInfo->wi_launchtime = 0; + MyWorkerInfo->wi_dobalance = false; MyWorkerInfo->wi_cost_delay = 0; MyWorkerInfo->wi_cost_limit = 0; MyWorkerInfo->wi_cost_limit_base = 0; @@ -1739,7 +1742,7 @@ autovac_balance_cost(void) if (vac_cost_limit <= 0 || vac_cost_delay <= 0) return; - /* caculate the total base cost limit of active workers */ + /* calculate the total base cost limit of participating active workers */ cost_total = 0.0; worker = (WorkerInfo) SHMQueueNext(&AutoVacuumShmem->av_runningWorkers, &AutoVacuumShmem->av_runningWorkers, @@ -1747,6 +1750,7 @@ autovac_balance_cost(void) while (worker) { if (worker->wi_proc != NULL && + worker->wi_dobalance && worker->wi_cost_limit_base > 0 && worker->wi_cost_delay > 0) cost_total += (double) worker->wi_cost_limit_base / worker->wi_cost_delay; @@ -1755,6 +1759,7 @@ autovac_balance_cost(void) &worker->wi_links, offsetof(WorkerInfoData, wi_links)); } + /* there are no cost limits -- nothing to do */ if (cost_total <= 0) return; @@ -1770,6 +1775,7 @@ autovac_balance_cost(void) while (worker) { if (worker->wi_proc != NULL && + worker->wi_dobalance && worker->wi_cost_limit_base > 0 && worker->wi_cost_delay > 0) { int limit = (int) @@ -1784,12 +1790,14 @@ autovac_balance_cost(void) worker->wi_cost_limit = Max(Min(limit, worker->wi_cost_limit_base), 1); + } - elog(DEBUG2, "autovac_balance_cost(pid=%u db=%u, rel=%u, cost_limit=%d, cost_limit_base=%d, cost_delay=%d)", + if (worker->wi_proc != NULL) + elog(DEBUG2, "autovac_balance_cost(pid=%u db=%u, rel=%u, dobalance=%s cost_limit=%d, cost_limit_base=%d, cost_delay=%d)", worker->wi_proc->pid, worker->wi_dboid, worker->wi_tableoid, + worker->wi_dobalance ? "yes" : "no", worker->wi_cost_limit, worker->wi_cost_limit_base, worker->wi_cost_delay); - } worker = (WorkerInfo) SHMQueueNext(&AutoVacuumShmem->av_runningWorkers, &worker->wi_links, @@ -2259,6 +2267,7 @@ do_autovacuum(void) LWLockAcquire(AutovacuumLock, LW_EXCLUSIVE); /* advertise my cost delay parameters for the balancing algorithm */ + MyWorkerInfo->wi_dobalance = tab->at_dobalance; MyWorkerInfo->wi_cost_delay = tab->at_vacuum_cost_delay; MyWorkerInfo->wi_cost_limit = tab->at_vacuum_cost_limit; MyWorkerInfo->wi_cost_limit_base = tab->at_vacuum_cost_limit; @@ -2539,6 +2548,14 @@ table_recheck_autovac(Oid relid, HTAB *table_toast_map, tab->at_relname = NULL; tab->at_nspname = NULL; tab->at_datname = NULL; + + /* + * If any of the cost delay parameters has been set individually for + * this table, disable the balancing algorithm. + */ + tab->at_dobalance = + !(avopts && (avopts->vacuum_cost_limit > 0 || + avopts->vacuum_cost_delay > 0)); } heap_freetuple(classTup); |