Commit 11a68e4b authored by Michael Paquier's avatar Michael Paquier

Tweak behavior of pg_stat_activity.leader_pid

The initial implementation of leader_pid in pg_stat_activity added by
b025f32e took the approach to strictly print what a PGPROC entry
includes.  In short, if a backend has been involved in parallel query at
least once, leader_pid would remain set as long as the backend is alive.
For a parallel group leader, this means that the field would always be
set after it participated at least once in parallel query, and after
more discussions this could be confusing if using for example a
connection pooler.

This commit changes the data printed so as leader_pid becomes always
NULL for a parallel group leader, showing up a non-NULL value only for
the parallel workers, and actually as long as a parallel query is
running as workers are shut down once the query has completed.

This does not change the definition of any catalog, so no catalog bump
is needed.  Per discussion with Justin Pryzby, Álvaro Herrera, Julien
Rouhaud and me.

Discussion: https://postgr.es/m/20200721035145.GB17300@paquier.xyz
Backpatch-through: 13
parent 15e44197
...@@ -687,12 +687,9 @@ postgres 27093 0.0 0.0 30096 2752 ? Ss 11:34 0:00 postgres: ser ...@@ -687,12 +687,9 @@ postgres 27093 0.0 0.0 30096 2752 ? Ss 11:34 0:00 postgres: ser
<structfield>leader_pid</structfield> <type>integer</type> <structfield>leader_pid</structfield> <type>integer</type>
</para> </para>
<para> <para>
Process ID of the parallel group leader if this process is or Process ID of the parallel group leader, if this process is a
has been involved in parallel query, or null. This field is set parallel query worker. <literal>NULL</literal> if this process is a
when a process wants to cooperate with parallel workers, and parallel group leader or does not participate in parallel query.
remains set as long as the process exists. For a parallel group leader,
this field is set to its own process ID. For a parallel worker,
this field is set to the process ID of the parallel group leader.
</para></entry> </para></entry>
</row> </row>
......
...@@ -735,7 +735,13 @@ pg_stat_get_activity(PG_FUNCTION_ARGS) ...@@ -735,7 +735,13 @@ pg_stat_get_activity(PG_FUNCTION_ARGS)
wait_event = pgstat_get_wait_event(raw_wait_event); wait_event = pgstat_get_wait_event(raw_wait_event);
leader = proc->lockGroupLeader; leader = proc->lockGroupLeader;
if (leader)
/*
* Show the leader only for active parallel workers. This
* leaves the field as NULL for the leader of a parallel
* group.
*/
if (leader && leader->pid != beentry->st_procpid)
{ {
values[29] = Int32GetDatum(leader->pid); values[29] = Int32GetDatum(leader->pid);
nulls[29] = false; nulls[29] = false;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment