git.postgresql.org Git - postgresql.git/commit

git projects / postgresql.git / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 14bdb3f) | patch
Display the leader apply worker's PID for parallel apply workers.
2023年1月18日 03:33:12 +0000 (09:03 +0530)
2023年1月18日 03:33:12 +0000 (09:03 +0530)
commit d540a02a724b9643205abce8c5644a0f0908f6e3
Display the leader apply worker's PID for parallel apply workers.

Add leader_pid to pg_stat_subscription. leader_pid is the process ID of
the leader apply worker if this process is a parallel apply worker. If
this field is NULL, it indicates that the process is a leader apply
worker or a synchronization worker. The new column makes it easier to
distinguish parallel apply workers from other kinds of workers and helps
to identify the leader for the parallel workers corresponding to a
particular subscription.

Additionally, update the leader_pid column in pg_stat_activity as well to
display the PID of the leader apply worker for parallel apply workers.

Author: Hou Zhijie
Reviewed-by: Peter Smith, Sawada Masahiko, Amit Kapila, Shveta Mallik
Discussion: https://postgr.es/m/CAA4eK1+wyN6zpaHUkCLorEWNx75MG0xhMwcFhvjqm2KURZEAGw@mail.gmail.com
doc/src/sgml/logical-replication.sgml diff | blob | blame | history
doc/src/sgml/monitoring.sgml diff | blob | blame | history
src/backend/catalog/system_views.sql diff | blob | blame | history
src/backend/replication/logical/applyparallelworker.c diff | blob | blame | history
src/backend/replication/logical/launcher.c diff | blob | blame | history
src/backend/utils/adt/pgstatfuncs.c diff | blob | blame | history
src/include/catalog/catversion.h diff | blob | blame | history
src/include/catalog/pg_proc.dat diff | blob | blame | history
src/include/replication/logicallauncher.h diff | blob | blame | history
src/include/replication/worker_internal.h diff | blob | blame | history
src/test/regress/expected/rules.out diff | blob | blame | history
This is the main PostgreSQL git repository.
RSS Atom

AltStyle によって変換されたページ (->オリジナル) /