Add ProcArrayGroupUpdate wait event.

Discussion: http://postgr.es/m/CA+TgmobgWHcXDcChX2+BqJDk2dkPVF85ZrJFhUyHHQmw8diTpA@mail.gmail.com

diff --git a/doc/src/sgml/monitoring.sgml b/doc/src/sgml/monitoring.sgml
index 9856968997e84f2f7d8caf421e87e227b9670599..b16325d39004a064b46b4078ee212e65eb50cb84 100644 (file)
--- a/doc/src/sgml/monitoring.sgml
+++ b/doc/src/sgml/monitoring.sgml
@@ -1232,7 +1232,7 @@ postgres   27093  0.0  0.0  30096  2752 ?        Ss   11:34   0:00 postgres: ser
          Waiting in an extension.
         
         
-         1">IPC
+         2">IPC
          BgWorkerShutdown
          Waiting for background worker to shut down.
         
@@ -1272,6 +1272,9 @@ postgres   27093  0.0  0.0  30096  2752 ?        Ss   11:34   0:00 postgres: ser
          ParallelBitmapPopulate
          Waiting for the leader to populate the TidBitmap.
         
+        
+         ProcArrayGroupUpdate
+         Waiting for group leader to clear transaction id at transaction end.
         
          SafeSnapshot
          Waiting for a snapshot for a READ ONLY DEFERRABLE transaction.

diff --git a/src/backend/postmaster/pgstat.c b/src/backend/postmaster/pgstat.c
index 56a8bf2d17f7582554128b4cfe1df9ddf955887b..3fb57f060c95cbbb24a72dd85c1e6026de96458e 100644 (file)
--- a/src/backend/postmaster/pgstat.c
+++ b/src/backend/postmaster/pgstat.c
@@ -3560,6 +3560,9 @@ pgstat_get_wait_ipc(WaitEventIPC w)
        case WAIT_EVENT_PARALLEL_BITMAP_SCAN:
            event_name = "ParallelBitmapScan";
            break;
+       case WAIT_EVENT_PROCARRAY_GROUP_UPDATE:
+           event_name = "ProcArrayGroupUpdate";
+           break;
        case WAIT_EVENT_SAFE_SNAPSHOT:
            event_name = "SafeSnapshot";
            break;

diff --git a/src/backend/storage/ipc/procarray.c b/src/backend/storage/ipc/procarray.c
index fb39bdc2f598f2af15ebbca8d8f77348472f7702..ebf6a9292391a860e766992fb13189ae758c1363 100644 (file)
--- a/src/backend/storage/ipc/procarray.c
+++ b/src/backend/storage/ipc/procarray.c
@@ -53,6 +53,7 @@
 #include "access/xlog.h"
 #include "catalog/catalog.h"
 #include "miscadmin.h"
+#include "pgstat.h"
 #include "storage/proc.h"
 #include "storage/procarray.h"
 #include "storage/spin.h"
@@ -513,6 +514,7 @@ ProcArrayGroupClearXid(PGPROC *proc, TransactionId latestXid)
        int         extraWaits = 0;
 
        /* Sleep until the leader clears our XID. */
+       pgstat_report_wait_start(WAIT_EVENT_PROCARRAY_GROUP_UPDATE);
        for (;;)
        {
            /* acts as a read barrier */
@@ -521,6 +523,7 @@ ProcArrayGroupClearXid(PGPROC *proc, TransactionId latestXid)
                break;
            extraWaits++;
        }
+       pgstat_report_wait_end();
 
        Assert(pg_atomic_read_u32(&proc->procArrayGroupNext) == INVALID_PGPROCNO);
 

diff --git a/src/include/pgstat.h b/src/include/pgstat.h
index e29397f25b83202b7e1a037d6b9371e913512fa3..5e029c0f4ef490a0a8d693de25d39571d4700474 100644 (file)
--- a/src/include/pgstat.h
+++ b/src/include/pgstat.h
@@ -808,6 +808,7 @@ typedef enum
    WAIT_EVENT_MQ_SEND,
    WAIT_EVENT_PARALLEL_FINISH,
    WAIT_EVENT_PARALLEL_BITMAP_SCAN,
+   WAIT_EVENT_PROCARRAY_GROUP_UPDATE,
    WAIT_EVENT_SAFE_SNAPSHOT,
    WAIT_EVENT_SYNC_REP,
    WAIT_EVENT_LOGICAL_SYNC_DATA,