NotificationsYou must be signed in to change notification settings
Fork6
Star31

Commit8e1fae1

Amit Kapila

committed

Move parallel vacuum code to vacuumparallel.c.

This commit moves parallel vacuum related code to a new filecommands/vacuumparallel.c so that any table AM supporting indexes canutilize parallel vacuum in order to call index AM callbacks (ambulkdeleteand amvacuumcleanup) with parallel workers.Another reason for this refactoring is that the parallel vacuum isn'tspecific to heap so it doesn't make sense to keep this code inheap/vacuumlazy.c.Author: Masahiko Sawada, based on suggestion from Andres FreundReviewed-by: Hou Zhijie, Amit Kapila, Haiying TangDiscussion:https://www.postgresql.org/message-id/20211030212101.ae3qcouatwmy7tbr%40alap3.anarazel.de

1 parente2e1bbd commit8e1fae1Copy full SHA for 8e1fae1

File tree

8 files changed

+1125

-983

lines changed

src
- backend
  - access
    - heap
      - vacuumlazy.c
    - transam
      - parallel.c
  - commands
- include
  - access
    - heapam.h
  - commands
    - vacuum.h
- tools/pgindent
  - typedefs.list

8 files changed

+1125

-983

lines changed

`‎src/backend/access/heap/vacuumlazy.c`

Lines changed: 28 additions & 974 deletions

Large diffs are not rendered by default.

`‎src/backend/access/transam/parallel.c`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -14,7 +14,6 @@`
`14`	`14`
`15`	`15`	`#include"postgres.h"`
`16`	`16`
`17`		`-#include"access/heapam.h"`
`18`	`17`	`#include"access/nbtree.h"`
`19`	`18`	`#include"access/parallel.h"`
`20`	`19`	`#include"access/session.h"`
`@@ -25,6 +24,7 @@`
`25`	`24`	`#include"catalog/pg_enum.h"`
`26`	`25`	`#include"catalog/storage.h"`
`27`	`26`	`#include"commands/async.h"`
	`27`	`+#include"commands/vacuum.h"`
`28`	`28`	`#include"executor/execParallel.h"`
`29`	`29`	`#include"libpq/libpq.h"`
`30`	`30`	`#include"libpq/pqformat.h"`

`‎src/backend/commands/Makefile`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -59,6 +59,7 @@ OBJS = \`
`59`	`59`	`typecmds.o\`
`60`	`60`	`user.o\`
`61`	`61`	`vacuum.o\`
	`62`	`+vacuumparallel.o\`
`62`	`63`	`variable.o\`
`63`	`64`	`view.o`
`64`	`65`

`‎src/backend/commands/vacuum.c`

Lines changed: 3 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -7,8 +7,9 @@`
`7`	`7`	`* commands, (b) code to compute various vacuum thresholds, and (c) index`
`8`	`8`	`* vacuum code.`
`9`	`9`	`*`
`10`		`- * VACUUM for heap AM is implemented in vacuumlazy.c, ANALYZE in analyze.c, and`
`11`		`- * VACUUM FULL is a variant of CLUSTER, handled in cluster.c.`
	`10`	`+ * VACUUM for heap AM is implemented in vacuumlazy.c, parallel vacuum in`
	`11`	`+ * vacuumparallel.c, ANALYZE in analyze.c, and VACUUM FULL is a variant of`
	`12`	`+ * CLUSTER, handled in cluster.c.`
`12`	`13`	`*`
`13`	`14`	`*`
`14`	`15`	`* Portions Copyright (c) 1996-2021, PostgreSQL Global Development Group`

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!

Commit8e1fae1

File tree

8 files changed

8 files changed

`‎src/backend/access/heap/vacuumlazy.c`

`‎src/backend/access/transam/parallel.c`

`‎src/backend/commands/Makefile`

`‎src/backend/commands/vacuum.c`

0 commit comments