NotificationsYou must be signed in to change notification settings
Fork6
Star31

Commit92ebe50

committed

Fix autovacuum for shared relations

The table-skipping logic in autovacuum would fail to consider thatmultiple workers could be processing the same shared catalog indifferent databases. This normally wouldn't be a problem: firstlybecause autovacuum workers not for wraparound would simply ignore tablesin which they cannot acquire lock, and secondly because most of the timethese tables are small enough that even if multiple for-wraparoundworkers are stuck in the same catalog, they would be over prettyquickly. But in cases where the catalogs are severely bloated it couldbecome a problem.Backpatch all the way back, because the problem has been there since thebeginning.Reported by Ondřej SvětlíkDiscussion:https://www.postgresql.org/message-id/572B63B1.3030603%40flexibee.eu https://www.postgresql.org/message-id/572A1072.5080308%40flexibee.eu

1 parentcd5a652 commit92ebe50Copy full SHA for 92ebe50

File tree

1 file changed

+10

-2

lines changed

src/backend/postmaster
- autovacuum.c

1 file changed

+10

-2

lines changed

`‎src/backend/postmaster/autovacuum.c`

Lines changed: 10 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -195,6 +195,7 @@ typedef struct autovac_table`
`195`	`195`	`intat_vacuum_cost_limit;`
`196`	`196`	`boolat_dobalance;`
`197`	`197`	`boolat_wraparound;`
	`198`	`+boolat_sharedrel;`
`198`	`199`	`char*at_relname;`
`199`	`200`	`char*at_nspname;`
`200`	`201`	`char*at_datname;`
`@@ -208,6 +209,7 @@ typedef struct autovac_table`
`208`	`209`	`* wi_linksentry into free list or running list`
`209`	`210`	`* wi_dboidOID of the database this worker is supposed to work on`
`210`	`211`	`* wi_tableoidOID of the table currently being vacuumed, if any`
	`212`	`+ * wi_sharedrelflag indicating whether table is marked relisshared`
`211`	`213`	`* wi_procpointer to PGPROC of the running worker, NULL if not started`
`212`	`214`	`* wi_launchtime Time at which this worker was launched`
`213`	`215`	`* wi_cost_*Vacuum cost-based delay parameters current in this worker`
`@@ -225,6 +227,7 @@ typedef struct WorkerInfoData`
`225`	`227`	`PGPROC*wi_proc;`
`226`	`228`	`TimestampTzwi_launchtime;`
`227`	`229`	`boolwi_dobalance;`
	`230`	`+boolwi_sharedrel;`
`228`	`231`	`intwi_cost_delay;`
`229`	`232`	`intwi_cost_limit;`
`230`	`233`	`intwi_cost_limit_base;`
`@@ -746,6 +749,7 @@ AutoVacLauncherMain(int argc, char *argv[])`
`746`	`749`	`worker=AutoVacuumShmem->av_startingWorker;`
`747`	`750`	`worker->wi_dboid=InvalidOid;`
`748`	`751`	`worker->wi_tableoid=InvalidOid;`
	`752`	`+worker->wi_sharedrel= false;`
`749`	`753`	`worker->wi_proc=NULL;`
`750`	`754`	`worker->wi_launchtime=0;`
`751`	`755`	`dlist_push_head(&AutoVacuumShmem->av_freeWorkers,`
`@@ -1739,6 +1743,7 @@ FreeWorkerInfo(int code, Datum arg)`
`1739`	`1743`	`dlist_delete(&MyWorkerInfo->wi_links);`
`1740`	`1744`	`MyWorkerInfo->wi_dboid=InvalidOid;`
`1741`	`1745`	`MyWorkerInfo->wi_tableoid=InvalidOid;`
	`1746`	`+MyWorkerInfo->wi_sharedrel= false;`
`1742`	`1747`	`MyWorkerInfo->wi_proc=NULL;`
`1743`	`1748`	`MyWorkerInfo->wi_launchtime=0;`
`1744`	`1749`	`MyWorkerInfo->wi_dobalance= false;`
`@@ -2272,8 +2277,8 @@ do_autovacuum(void)`
`2272`	`2277`	`if (worker==MyWorkerInfo)`
`2273`	`2278`	`continue;`
`2274`	`2279`
`2275`		`-/* ignore workers in other databases */`
`2276`		`-if (worker->wi_dboid!=MyDatabaseId)`
	`2280`	`+/* ignore workers in other databases(unless table is shared)*/`
	`2281`	`+if (!worker->wi_sharedrel&&worker->wi_dboid!=MyDatabaseId)`
`2277`	`2282`	`continue;`
`2278`	`2283`
`2279`	`2284`	`if (worker->wi_tableoid==relid)`
`@@ -2314,6 +2319,7 @@ do_autovacuum(void)`
`2314`	`2319`	`* the lock so that other workers don't vacuum it concurrently.`
`2315`	`2320`	`*/`
`2316`	`2321`	`MyWorkerInfo->wi_tableoid=relid;`
	`2322`	`+MyWorkerInfo->wi_sharedrel=tab->at_sharedrel;`
`2317`	`2323`	`LWLockRelease(AutovacuumScheduleLock);`
`2318`	`2324`
`2319`	`2325`	`/*`
`@@ -2425,6 +2431,7 @@ do_autovacuum(void)`
`2425`	`2431`	`*/`
`2426`	`2432`	`LWLockAcquire(AutovacuumLock,LW_EXCLUSIVE);`
`2427`	`2433`	`MyWorkerInfo->wi_tableoid=InvalidOid;`
	`2434`	`+MyWorkerInfo->wi_sharedrel= false;`
`2428`	`2435`	`LWLockRelease(AutovacuumLock);`
`2429`	`2436`
`2430`	`2437`	`/* restore vacuum cost GUCs for the next iteration */`
`@@ -2625,6 +2632,7 @@ table_recheck_autovac(Oid relid, HTAB *table_toast_map,`
`2625`	`2632`
`2626`	`2633`	`tab=palloc(sizeof(autovac_table));`
`2627`	`2634`	`tab->at_relid=relid;`
	`2635`	`+tab->at_sharedrel=classForm->relisshared;`
`2628`	`2636`	`tab->at_dovacuum=dovacuum;`
`2629`	`2637`	`tab->at_doanalyze=doanalyze;`
`2630`	`2638`	`tab->at_freeze_min_age=freeze_min_age;`

0 commit comments

Comments

(0)

Movatterモバイル変換

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commit92ebe50

File tree

1 file changed

1 file changed

`‎src/backend/postmaster/autovacuum.c`

0 commit comments