Commitd4116a7

committed

Add ProcArrayGroupUpdate wait event.

1 parentdbb2a93 commitd4116a7Copy full SHA for d4116a7

File tree

+11

-1

lines changed

+11

-1

lines changed

Lines changed: 4 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -1232,7 +1232,7 @@ postgres 27093 0.0 0.0 30096 2752 ? Ss 11:34 0:00 postgres: ser`
`1232`	`1232`	`<entry>Waiting in an extension.</entry>`
`1233`	`1233`	`</row>`
`1234`	`1234`	`<row>`
`1235`		`- <entry morerows="11"><literal>IPC</></entry>`
	`1235`	`+ <entry morerows="12"><literal>IPC</></entry>`
`1236`	`1236`	`<entry><literal>BgWorkerShutdown</></entry>`
`1237`	`1237`	`<entry>Waiting for background worker to shut down.</entry>`
`1238`	`1238`	`</row>`
`@@ -1272,6 +1272,9 @@ postgres 27093 0.0 0.0 30096 2752 ? Ss 11:34 0:00 postgres: ser`
`1272`	`1272`	`<entry><literal>ParallelBitmapPopulate</></entry>`
`1273`	`1273`	`<entry>Waiting for the leader to populate the TidBitmap.</entry>`
`1274`	`1274`	`</row>`
	`1275`	`+ <row>`
	`1276`	`+ <entry><literal>ProcArrayGroupUpdate</></entry>`
	`1277`	`+ <entry>Waiting for group leader to clear transaction id at transaction end.</entry>`
`1275`	`1278`	`<row>`
`1276`	`1279`	`<entry><literal>SafeSnapshot</></entry>`
`1277`	`1280`	`<entry>Waiting for a snapshot for a <literal>READ ONLY DEFERRABLE</> transaction.</entry>`

Lines changed: 3 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -3560,6 +3560,9 @@ pgstat_get_wait_ipc(WaitEventIPC w)`
`3560`	`3560`	`caseWAIT_EVENT_PARALLEL_BITMAP_SCAN:`
`3561`	`3561`	`event_name="ParallelBitmapScan";`
`3562`	`3562`	`break;`
	`3563`	`+caseWAIT_EVENT_PROCARRAY_GROUP_UPDATE:`
	`3564`	`+event_name="ProcArrayGroupUpdate";`
	`3565`	`+break;`
`3563`	`3566`	`caseWAIT_EVENT_SAFE_SNAPSHOT:`
`3564`	`3567`	`event_name="SafeSnapshot";`
`3565`	`3568`	`break;`

Lines changed: 3 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -53,6 +53,7 @@`
`53`	`53`	`#include"access/xlog.h"`
`54`	`54`	`#include"catalog/catalog.h"`
`55`	`55`	`#include"miscadmin.h"`
	`56`	`+#include"pgstat.h"`
`56`	`57`	`#include"storage/proc.h"`
`57`	`58`	`#include"storage/procarray.h"`
`58`	`59`	`#include"storage/spin.h"`
`@@ -513,6 +514,7 @@ ProcArrayGroupClearXid(PGPROC *proc, TransactionId latestXid)`
`513`	`514`	`intextraWaits=0;`
`514`	`515`
`515`	`516`	`/* Sleep until the leader clears our XID. */`
	`517`	`+pgstat_report_wait_start(WAIT_EVENT_PROCARRAY_GROUP_UPDATE);`
`516`	`518`	`for (;;)`
`517`	`519`	`{`
`518`	`520`	`/* acts as a read barrier */`
`@@ -521,6 +523,7 @@ ProcArrayGroupClearXid(PGPROC *proc, TransactionId latestXid)`
`521`	`523`	`break;`
`522`	`524`	`extraWaits++;`
`523`	`525`	`}`
	`526`	`+pgstat_report_wait_end();`
`524`	`527`
`525`	`528`	`Assert(pg_atomic_read_u32(&proc->procArrayGroupNext)==INVALID_PGPROCNO);`
`526`	`529`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -808,6 +808,7 @@ typedef enum`
`808`	`808`	`WAIT_EVENT_MQ_SEND,`
`809`	`809`	`WAIT_EVENT_PARALLEL_FINISH,`
`810`	`810`	`WAIT_EVENT_PARALLEL_BITMAP_SCAN,`
	`811`	`+WAIT_EVENT_PROCARRAY_GROUP_UPDATE,`
`811`	`812`	`WAIT_EVENT_SAFE_SNAPSHOT,`
`812`	`813`	`WAIT_EVENT_SYNC_REP,`
`813`	`814`	`WAIT_EVENT_LOGICAL_SYNC_DATA,`

Comments

(0)