<entry><type>timestamp with time zone</></entry>
<entry>Time when the <structfield>state</> was last changed</entry>
</row>
+ <row>
+ <entry><structfield>wait_event_type</></entry>
+ <entry><type>text</></entry>
+ <entry>The type of event for which the backend is waiting, if any;
+ otherwise NULL. Possible values are:
+ <itemizedlist>
+ <listitem>
+ <para>
+ <literal>LWLockNamed</>: The backend is waiting for a specific named
+ lightweight lock. Each such lock protects a particular data
+ structure in shared memory. <literal>wait_event</> will contain
+ the name of the lightweight lock.
+ </para>
+ </listitem>
+ <listitem>
+ <para>
+ <literal>LWLockTranche</>: The backend is waiting for one of a
+ group of related lightweight locks. All locks in the group perform
+ a similar function; <literal>wait_event</> will identify the general
+ purpose of locks in that group.
+ </para>
+ </listitem>
+ <listitem>
+ <para>
+ <literal>Lock</>: The backend is waiting for a heavyweight lock.
+ Heayweight locks, also known as lock manager locks or simply locks,
+ primarily protect SQL-visible objects such as tables. However,
+ they are also used to ensure mutual exclusion for certain internal
+ operations such as relation extension. <literal>wait_event</> will
+ identify the type of lock awaited.
+ </para>
+ </listitem>
+ <listitem>
+ <para>
+ <literal>BufferPin</>: The server process is waiting to access to
+ a data buffer during a period when no other process can be
+ examining that buffer. Buffer pin waits can be protracted if
+ another process holds an open cursor which last read data from the
+ buffer in question.
+ </para>
+ </listitem>
+ </itemizedlist>
+ </entry>
+ </row>
<row>
- <entry><structfield>waiting</></entry>
- <entry><type>boolean</></entry>
- <entry>True if this backend is currently waiting on a lock</entry>
+ <entry><structfield>wait_event</></entry>
+ <entry><type>text</></entry>
+ <entry>Wait event name if backend is currently waiting, otherwise NULL.
+ See <xref linkend="wait-event-table"> for details.
+ </entry>
</row>
<row>
<entry><structfield>state</></entry>
<note>
<para>
- The <structfield>waiting</> and <structfield>state</> columns are
+ The <structfield>wait_event</> and <structfield>state</> columns are
independent. If a backend is in the <literal>active</> state,
- it may or may not be <literal>waiting</>. If the state is
- <literal>active</> and <structfield>waiting</> is true, it means
- that a query is being executed, but is being blocked by a lock
- somewhere in the system.
+ it may or may not be <literal>waiting</> on some event. If the state
+ is <literal>active</> and <structfield>wait_event</> is non-null, it
+ means that a query is being executed, but is being blocked somewhere
+ in the system.
</para>
</note>
+ <table id="wait-event-table" xreflabel="wait_event">
+ <title><structname>wait_event</structname> Description</title>
+
+ <tgroup cols="3">
+ <thead>
+ <row>
+ <entry>Wait Event Type</entry>
+ <entry>Wait Event Name</entry>
+ <entry>Description</entry>
+ </row>
+ </thead>
+
+ <tbody>
+ <row>
+ <entry morerows="40"><literal>LWLockNamed</></entry>
+ <entry><literal>ShmemIndexLock</></entry>
+ <entry>Waiting to find or allocate space in shared memory.</entry>
+ </row>
+ <row>
+ <entry><literal>OidGenLock</></entry>
+ <entry>Waiting to allocate or assign an OID.</entry>
+ </row>
+ <row>
+ <entry><literal>XidGenLock</></entry>
+ <entry>Waiting to allocate or assign a transaction id.</entry>
+ </row>
+ <row>
+ <entry><literal>ProcArrayLock</></entry>
+ <entry>Waiting to get a snapshot or clearing a transaction id at
+ transaction end.</entry>
+ </row>
+ <row>
+ <entry><literal>SInvalReadLock</></entry>
+ <entry>Waiting to retrieve or remove messages from shared invalidation
+ queue.</entry>
+ </row>
+ <row>
+ <entry><literal>SInvalWriteLock</></entry>
+ <entry>Waiting to add a message in shared invalidation queue.</entry>
+ </row>
+ <row>
+ <entry><literal>WALBufMappingLock</></entry>
+ <entry>Waiting to replace a page in WAL buffers.</entry>
+ </row>
+ <row>
+ <entry><literal>WALWriteLock</></entry>
+ <entry>Waiting for WAL buffers to be written to disk.</entry>
+ </row>
+ <row>
+ <entry><literal>ControlFileLock</></entry>
+ <entry>Waiting to read or update the control file or creation of a
+ new WAL file.</entry>
+ </row>
+ <row>
+ <entry><literal>CheckpointLock</></entry>
+ <entry>Waiting to perform checkpoint.</entry>
+ </row>
+ <row>
+ <entry><literal>CLogControlLock</></entry>
+ <entry>Waiting to read or update transaction status.</entry>
+ </row>
+ <row>
+ <entry><literal>SubtransControlLock</></entry>
+ <entry>Waiting to read or update sub-transaction information.</entry>
+ </row>
+ <row>
+ <entry><literal>MultiXactGenLock</></entry>
+ <entry>Waiting to read or update shared multixact state.</entry>
+ </row>
+ <row>
+ <entry><literal>MultiXactOffsetControlLock</></entry>
+ <entry>Waiting to read or update multixact offset mappings.</entry>
+ </row>
+ <row>
+ <entry><literal>MultiXactMemberControlLock</></entry>
+ <entry>Waiting to read or update multixact member mappings.</entry>
+ </row>
+ <row>
+ <entry><literal>RelCacheInitLock</></entry>
+ <entry>Waiting to read or write relation cache initialization
+ file.</entry>
+ </row>
+ <row>
+ <entry><literal>CheckpointerCommLock</></entry>
+ <entry>Waiting to manage fsync requests.</entry>
+ </row>
+ <row>
+ <entry><literal>TwoPhaseStateLock</></entry>
+ <entry>Waiting to read or update the state of prepared transactions.</entry>
+ </row>
+ <row>
+ <entry><literal>TablespaceCreateLock</></entry>
+ <entry>Waiting to create or drop the tablespace.</entry>
+ </row>
+ <row>
+ <entry><literal>BtreeVacuumLock</></entry>
+ <entry>Waiting to read or update vacuum-related information for a
+ Btree index.</entry>
+ </row>
+ <row>
+ <entry><literal>AddinShmemInitLock</></entry>
+ <entry>Waiting to manage space allocation in shared memory.</entry>
+ </row>
+ <row>
+ <entry><literal>AutovacuumLock</></entry>
+ <entry>Autovacuum worker or launcher waiting to update or
+ read the current state of autovacuum workers.</entry>
+ </row>
+ <row>
+ <entry><literal>AutovacuumScheduleLock</></entry>
+ <entry>Waiting to ensure that the table it has selected for a vacuum
+ still needs vacuuming.
+ </entry>
+ </row>
+ <row>
+ <entry><literal>SyncScanLock</></entry>
+ <entry>Waiting to get the start location of a scan on a table for
+ synchronized scans.</entry>
+ </row>
+ <row>
+ <entry><literal>RelationMappingLock</></entry>
+ <entry>Waiting to update the relation map file used to store catalog
+ to filenode mapping.
+ </entry>
+ </row>
+ <row>
+ <entry><literal>AsyncCtlLock</></entry>
+ <entry>Waiting to read or update shared notification state.</entry>
+ </row>
+ <row>
+ <entry><literal>AsyncQueueLock</></entry>
+ <entry>Waiting to read or update notification messages.</entry>
+ </row>
+ <row>
+ <entry><literal>SerializableXactHashLock</></entry>
+ <entry>Waiting to retrieve or store information about serializable
+ transactions.</entry>
+ </row>
+ <row>
+ <entry><literal>SerializableFinishedListLock</></entry>
+ <entry>Waiting to access the list of finished serializable
+ transactions.</entry>
+ </row>
+ <row>
+ <entry><literal>SerializablePredicateLockListLock</></entry>
+ <entry>Waiting to perform an operation on a list of locks held by
+ serializable transactions.</entry>
+ </row>
+ <row>
+ <entry><literal>OldSerXidLock</></entry>
+ <entry>Waiting to read or record conflicting serializable
+ transactions.</entry>
+ </row>
+ <row>
+ <entry><literal>SyncRepLock</></entry>
+ <entry>Waiting to read or update information about synchronous
+ replicas.</entry>
+ </row>
+ <row>
+ <entry><literal>BackgroundWorkerLock</></entry>
+ <entry>Waiting to read or update background worker state.</entry>
+ </row>
+ <row>
+ <entry><literal>DynamicSharedMemoryControlLock</></entry>
+ <entry>Waiting to read or update dynamic shared memory state.</entry>
+ </row>
+ <row>
+ <entry><literal>AutoFileLock</></entry>
+ <entry>Waiting to update the <filename>postgresql.auto.conf</> file.</entry>
+ </row>
+ <row>
+ <entry><literal>ReplicationSlotAllocationLock</></entry>
+ <entry>Waiting to allocate or free a replication slot.</entry>
+ </row>
+ <row>
+ <entry><literal>ReplicationSlotControlLock</></entry>
+ <entry>Waiting to read or update replication slot state.</entry>
+ </row>
+ <row>
+ <entry><literal>CommitTsControlLock</></entry>
+ <entry>Waiting to read or update transaction commit timestamps.</entry>
+ </row>
+ <row>
+ <entry><literal>CommitTsLock</></entry>
+ <entry>Waiting to read or update the last value set for the
+ transaction timestamp.</entry>
+ </row>
+ <row>
+ <entry><literal>ReplicationOriginLock</></entry>
+ <entry>Waiting to setup, drop or use replication origin.</entry>
+ </row>
+ <row>
+ <entry><literal>MultiXactTruncationLock</></entry>
+ <entry>Waiting to read or truncate multixact information.</entry>
+ </row>
+ <row>
+ <entry morerows="15"><literal>LWLockTranche</></entry>
+ <entry><literal>clog</></entry>
+ <entry>Waiting for I/O on a clog (transcation status) buffer.</entry>
+ </row>
+ <row>
+ <entry><literal>commit_timestamp</></entry>
+ <entry>Waiting for I/O on commit timestamp buffer.</entry>
+ </row>
+ <row>
+ <entry><literal>subtrans</></entry>
+ <entry>Waiting for I/O a subtransaction buffer.</entry>
+ </row>
+ <row>
+ <entry><literal>multixact_offset</></entry>
+ <entry>Waiting for I/O on a multixact offset buffer.</entry>
+ </row>
+ <row>
+ <entry><literal>multixact_member</></entry>
+ <entry>Waiting for I/O on a multixact_member buffer.</entry>
+ </row>
+ <row>
+ <entry><literal>async</></entry>
+ <entry>Waiting for I/O on an async (notify) buffer.</entry>
+ </row>
+ <row>
+ <entry><literal>oldserxid</></entry>
+ <entry>Waiting to I/O on an oldserxid buffer.</entry>
+ </row>
+ <row>
+ <entry><literal>wal_insert</></entry>
+ <entry>Waiting to insert WAL into a memory buffer.</entry>
+ </row>
+ <row>
+ <entry><literal>buffer_content</></entry>
+ <entry>Waiting to read or write a data page in memory.</entry>
+ </row>
+ <row>
+ <entry><literal>buffer_io</></entry>
+ <entry>Waiting for I/O on a data page.</entry>
+ </row>
+ <row>
+ <entry><literal>replication_origin</></entry>
+ <entry>Waiting to read or update the replication progress.</entry>
+ </row>
+ <row>
+ <entry><literal>replication_slot_io</></entry>
+ <entry>Waiting for I/O on a replication slot.</entry>
+ </row>
+ <row>
+ <entry><literal>proc</></entry>
+ <entry>Waiting to read or update the fast-path lock information.</entry>
+ </row>
+ <row>
+ <entry><literal>buffer_mapping</></entry>
+ <entry>Waiting to associate a data block with a buffer in the buffer
+ pool.</entry>
+ </row>
+ <row>
+ <entry><literal>lock_manager</></entry>
+ <entry>Waiting to add or examine locks for backends, or waiting to
+ join or exit a locking group (used by parallel query).</entry>
+ </row>
+ <row>
+ <entry><literal>predicate_lock_manager</></entry>
+ <entry>Waiting to add or examine predicate lock information.</entry>
+ </row>
+ <row>
+ <entry morerows="9"><literal>Lock</></entry>
+ <entry><literal>relation</></entry>
+ <entry>Waiting to acquire a lock on a relation.</entry>
+ </row>
+ <row>
+ <entry><literal>extend</></entry>
+ <entry>Waiting to extend a relation.</entry>
+ </row>
+ <row>
+ <entry><literal>page</></entry>
+ <entry>Waiting to acquire a lock on page of a relation.</entry>
+ </row>
+ <row>
+ <entry><literal>tuple</></entry>
+ <entry>Waiting to acquire a lock on a tuple.</entry>
+ </row>
+ <row>
+ <entry><literal>transactionid</></entry>
+ <entry>Waiting for a transaction to finish.</entry>
+ </row>
+ <row>
+ <entry><literal>virtualxid</></entry>
+ <entry>Waiting to acquire a virtual xid lock.</entry>
+ </row>
+ <row>
+ <entry><literal>speculative token</></entry>
+ <entry>Waiting to acquire a speculative insertion lock.</entry>
+ </row>
+ <row>
+ <entry><literal>object</></entry>
+ <entry>Waiting to acquire a lock on a non-relation database object.</entry>
+ </row>
+ <row>
+ <entry><literal>userlock</></entry>
+ <entry>Waiting to acquire a userlock.</entry>
+ </row>
+ <row>
+ <entry><literal>advisory</></entry>
+ <entry>Waiting to acquire an advisory user lock.</entry>
+ </row>
+ <row>
+ <entry><literal>BufferPin</></entry>
+ <entry><literal>BufferPin</></entry>
+ <entry>Waiting to acquire a pin on a buffer.</entry>
+ </row>
+ </tbody>
+ </tgroup>
+ </table>
+
+ <note>
+ <para>
+ For tranches registered by extensions, the name is specified by extension
+ and this will be displayed as <structfield>wait_event</>. It is quite
+ possible that user has registered the tranche in one of the backends (by
+ having allocation in dynamic shared memory) in which case other backends
+ won't have that information, so we display <literal>extension</> for such
+ cases.
+ </para>
+ </note>
+
+ <para>
+ Here is an example of how wait events can be viewed
+
+<programlisting>
+SELECT pid, wait_event_type, wait_event FROM pg_stat_activity WHERE wait_event is NOT NULL;
+ pid | wait_event_type | wait_event
+------+-----------------+---------------
+ 2540 | Lock | relation
+ 6644 | LWLockNamed | ProcArrayLock
+(2 rows)
+</programlisting>
+ </para>
+
<table id="pg-stat-replication-view" xreflabel="pg_stat_replication">
<title><structname>pg_stat_replication</structname> View</title>
<tgroup cols="3">
<entry>OID of the user logged into this backend</entry>
</row>
+ <row>
+ <entry><literal><function>pg_stat_get_backend_wait_event_type(integer)</function></literal></entry>
+ <entry><type>text</type></entry>
+ <entry>Wait event type name if backend is currently waiting, otherwise NULL.
+ See <xref linkend="wait-event-table"> for details.
+ </entry>
+ </row>
+
<row>
- <entry><literal><function>pg_stat_get_backend_waiting(integer)</function></literal></entry>
- <entry><type>boolean</type></entry>
- <entry>True if this backend is currently waiting on a lock</entry>
+ <entry><literal><function>pg_stat_get_backend_wait_event(integer)</function></literal></entry>
+ <entry><type>text</type></entry>
+ <entry>Wait event name if backend is currently waiting, otherwise NULL.
+ See <xref linkend="wait-event-table"> for details.
+ </entry>
</row>
<row>
*/
LWLockReleaseAll();
+ /* Clear wait information and command progress indicator */
+ pgstat_report_wait_end();
+ pgstat_progress_end_command();
+
/* Clean up buffer I/O and buffer context locks, too */
AbortBufferIO();
UnlockBuffers();
- /* Clear command progress indicator */
- pgstat_progress_end_command();
-
/* Reset WAL record construction state */
XLogResetInsertion();
*/
LWLockReleaseAll();
+ pgstat_report_wait_end();
+ pgstat_progress_end_command();
AbortBufferIO();
UnlockBuffers();
- pgstat_progress_end_command();
/* Reset WAL record construction state */
XLogResetInsertion();
*/
XactReadOnly = s->prevXactReadOnly;
+ /* Report wait end here, when there is no further possibility of wait */
+ pgstat_report_wait_end();
+
RESUME_INTERRUPTS();
}
#include "miscadmin.h"
#include "nodes/makefuncs.h"
#include "pg_getopt.h"
+#include "pgstat.h"
#include "postmaster/bgwriter.h"
#include "postmaster/startup.h"
#include "postmaster/walwriter.h"
ShutdownAuxiliaryProcess(int code, Datum arg)
{
LWLockReleaseAll();
+ pgstat_report_wait_end();
}
/* ----------------------------------------------------------------
S.xact_start,
S.query_start,
S.state_change,
- S.waiting,
+ S.wait_event_type,
+ S.wait_event,
S.state,
S.backend_xid,
s.backend_xmin,
* It's not clear we need it elsewhere, but shouldn't hurt.
*/
smgrcloseall();
+
+ /* Report wait end here, when there is no further possibility of wait */
+ pgstat_report_wait_end();
}
/* We can now handle ereport(ERROR) */
* files.
*/
LWLockReleaseAll();
+ pgstat_report_wait_end();
AbortBufferIO();
UnlockBuffers();
/* buffer pins are released here: */
#include "postmaster/autovacuum.h"
#include "postmaster/fork_process.h"
#include "postmaster/postmaster.h"
-#include "storage/proc.h"
#include "storage/backendid.h"
#include "storage/dsm.h"
#include "storage/fd.h"
#include "storage/ipc.h"
#include "storage/latch.h"
+#include "storage/lmgr.h"
#include "storage/pg_shmem.h"
#include "storage/procsignal.h"
#include "storage/sinvaladt.h"
#else
beentry->st_ssl = false;
#endif
- beentry->st_waiting = false;
beentry->st_state = STATE_UNDEFINED;
beentry->st_appname[0] = '\0';
beentry->st_activity[0] = '\0';
{
if (beentry->st_state != STATE_DISABLED)
{
+ volatile PGPROC *proc = MyProc;
+
/*
* track_activities is disabled, but we last reported a
* non-disabled state. As our final update, change the state and
beentry->st_state_start_timestamp = 0;
beentry->st_activity[0] = '\0';
beentry->st_activity_start_timestamp = 0;
- /* st_xact_start_timestamp and st_waiting are also disabled */
+ /* st_xact_start_timestamp and wait_event_info are also disabled */
beentry->st_xact_start_timestamp = 0;
- beentry->st_waiting = false;
+ proc->wait_event_info = 0;
pgstat_increment_changecount_after(beentry);
}
return;
pgstat_increment_changecount_after(beentry);
}
-/* ----------
- * pgstat_report_waiting() -
- *
- * Called from lock manager to report beginning or end of a lock wait.
- *
- * NB: this *must* be able to survive being called before MyBEEntry has been
- * initialized.
- * ----------
- */
-void
-pgstat_report_waiting(bool waiting)
-{
- volatile PgBackendStatus *beentry = MyBEEntry;
-
- if (!pgstat_track_activities || !beentry)
- return;
-
- /*
- * Since this is a single-byte field in a struct that only this process
- * may modify, there seems no need to bother with the st_changecount
- * protocol. The update must appear atomic in any case.
- */
- beentry->st_waiting = waiting;
-}
-
-
/* ----------
* pgstat_read_current_status() -
*
localBackendStatusTable = localtable;
}
+/* ----------
+ * pgstat_get_wait_event_type() -
+ *
+ * Return a string representing the current wait event type, backend is
+ * waiting on.
+ */
+const char *
+pgstat_get_wait_event_type(uint32 wait_event_info)
+{
+ uint8 classId;
+ const char *event_type;
+
+ /* report process as not waiting. */
+ if (wait_event_info == 0)
+ return NULL;
+
+ wait_event_info = wait_event_info >> 24;
+ classId = wait_event_info & 0XFF;
+
+ switch (classId)
+ {
+ case WAIT_LWLOCK_NAMED:
+ event_type = "LWLockNamed";
+ break;
+ case WAIT_LWLOCK_TRANCHE:
+ event_type = "LWLockTranche";
+ break;
+ case WAIT_LOCK:
+ event_type = "Lock";
+ break;
+ case WAIT_BUFFER_PIN:
+ event_type = "BufferPin";
+ break;
+ default:
+ event_type = "???";
+ break;
+ }
+
+ return event_type;
+}
+
+/* ----------
+ * pgstat_get_wait_event() -
+ *
+ * Return a string representing the current wait event, backend is
+ * waiting on.
+ */
+const char *
+pgstat_get_wait_event(uint32 wait_event_info)
+{
+ uint8 classId;
+ uint16 eventId;
+ const char *event_name;
+
+ /* report process as not waiting. */
+ if (wait_event_info == 0)
+ return NULL;
+
+ eventId = wait_event_info & ((1 << 24) - 1);
+ wait_event_info = wait_event_info >> 24;
+ classId = wait_event_info & 0XFF;
+
+ switch (classId)
+ {
+ case WAIT_LWLOCK_NAMED:
+ case WAIT_LWLOCK_TRANCHE:
+ event_name = GetLWLockIdentifier(classId, eventId);
+ break;
+ case WAIT_LOCK:
+ event_name = GetLockNameFromTagType(eventId);
+ break;
+ case WAIT_BUFFER_PIN:
+ event_name = "BufferPin";
+ break;
+ default:
+ event_name = "unknown wait event";
+ break;
+ }
+
+ return event_name;
+}
/* ----------
* pgstat_get_backend_current_activity() -
#include "access/xlog.h"
#include "libpq/pqsignal.h"
#include "miscadmin.h"
+#include "pgstat.h"
#include "postmaster/walwriter.h"
#include "storage/bufmgr.h"
#include "storage/fd.h"
* about in walwriter, but we do have LWLocks, and perhaps buffers?
*/
LWLockReleaseAll();
+ pgstat_report_wait_end();
AbortBufferIO();
UnlockBuffers();
/* buffer pins are released here: */
#include "libpq/pqformat.h"
#include "miscadmin.h"
#include "nodes/replnodes.h"
+#include "pgstat.h"
#include "replication/basebackup.h"
#include "replication/decode.h"
#include "replication/logical.h"
WalSndErrorCleanup(void)
{
LWLockReleaseAll();
+ pgstat_report_wait_end();
if (sendFile >= 0)
{
UnlockBufHdr(bufHdr);
LockBuffer(buffer, BUFFER_LOCK_UNLOCK);
+ /* Report the wait */
+ pgstat_report_wait_start(WAIT_BUFFER_PIN, 0);
+
/* Wait to be signaled by UnpinBuffer() */
if (InHotStandby)
{
else
ProcWaitForSignal();
+ pgstat_report_wait_end();
+
/*
* Remove flag marking us as waiter. Normally this will not be set
* anymore, but ProcWaitForSignal() can return for other signals as
break;
}
}
+
+/*
+ * GetLockNameFromTagType
+ *
+ * Given locktag type, return the corresponding lock name.
+ */
+const char *
+GetLockNameFromTagType(uint16 locktag_type)
+{
+ const char *locktypename;
+ char tnbuf[32];
+
+ if (locktag_type <= LOCKTAG_LAST_TYPE)
+ locktypename = LockTagTypeNames[locktag_type];
+ else
+ {
+ snprintf(tnbuf, sizeof(tnbuf), "unknown %d",
+ (int) locktag_type);
+ locktypename = tnbuf;
+ }
+
+ return locktypename;
+}
set_ps_display(new_status, false);
new_status[len] = '\0'; /* truncate off " waiting" */
}
- pgstat_report_waiting(true);
+ pgstat_report_wait_start(WAIT_LOCK, locallock->tag.lock.locktag_type);
awaitedLock = locallock;
awaitedOwner = owner;
/* In this path, awaitedLock remains set until LockErrorCleanup */
/* Report change to non-waiting status */
- pgstat_report_waiting(false);
+ pgstat_report_wait_end();
if (update_process_title)
{
set_ps_display(new_status, false);
awaitedLock = NULL;
/* Report change to non-waiting status */
- pgstat_report_waiting(false);
+ pgstat_report_wait_end();
if (update_process_title)
{
set_ps_display(new_status, false);
#include "postgres.h"
#include "miscadmin.h"
+#include "pgstat.h"
#include "pg_trace.h"
#include "postmaster/postmaster.h"
#include "replication/slot.h"
static void InitializeLWLocks(void);
static void RegisterLWLockTranches(void);
+static inline void LWLockReportWaitStart(LWLock *lock);
+static inline void LWLockReportWaitEnd();
+
#ifdef LWLOCK_STATS
typedef struct lwlock_stats_key
{
{
LWLockTranchesAllocated = 32;
LWLockTrancheArray = (LWLockTranche **)
- MemoryContextAlloc(TopMemoryContext,
+ MemoryContextAllocZero(TopMemoryContext,
LWLockTranchesAllocated * sizeof(LWLockTranche *));
Assert(LWLockTranchesAllocated >= LWTRANCHE_FIRST_USER_DEFINED);
}
if (tranche_id >= LWLockTranchesAllocated)
{
int i = LWLockTranchesAllocated;
+ int j = LWLockTranchesAllocated;
while (i <= tranche_id)
i *= 2;
repalloc(LWLockTrancheArray,
i * sizeof(LWLockTranche *));
LWLockTranchesAllocated = i;
+ while (j < LWLockTranchesAllocated)
+ LWLockTrancheArray[j++] = NULL;
}
LWLockTrancheArray[tranche_id] = tranche;
dlist_init(&lock->waiters);
}
+/*
+ * Report start of wait event for light-weight locks.
+ *
+ * This function will be used by all the light-weight lock calls which
+ * needs to wait to acquire the lock. This function distinguishes wait
+ * event based on tranche and lock id.
+ */
+static inline void
+LWLockReportWaitStart(LWLock *lock)
+{
+ int lockId = T_ID(lock);
+
+ if (lock->tranche == 0)
+ pgstat_report_wait_start(WAIT_LWLOCK_NAMED, (uint16) lockId);
+ else
+ pgstat_report_wait_start(WAIT_LWLOCK_TRANCHE, lock->tranche);
+}
+
+/*
+ * Report end of wait event for light-weight locks.
+ */
+static inline void
+LWLockReportWaitEnd()
+{
+ pgstat_report_wait_end();
+}
+
+/*
+ * Return an identifier for an LWLock based on the wait class and event.
+ */
+const char *
+GetLWLockIdentifier(uint8 classId, uint16 eventId)
+{
+ if (classId == WAIT_LWLOCK_NAMED)
+ return MainLWLockNames[eventId];
+
+ Assert(classId == WAIT_LWLOCK_TRANCHE);
+
+ /*
+ * It is quite possible that user has registered tranche in one of the
+ * backends (e.g. by allocation lwlocks in dynamic shared memory) but not
+ * all of them, so we can't assume the tranche is registered here.
+ * extension for such cases.
+ */
+ if (eventId >= LWLockTranchesAllocated ||
+ LWLockTrancheArray[eventId]->name == NULL)
+ return "extension";
+
+ return LWLockTrancheArray[eventId]->name;
+}
+
/*
* Internal function that tries to atomically acquire the lwlock in the passed
* in mode.
lwstats->block_count++;
#endif
+ LWLockReportWaitStart(lock);
TRACE_POSTGRESQL_LWLOCK_WAIT_START(T_NAME(lock), T_ID(lock), mode);
for (;;)
#endif
TRACE_POSTGRESQL_LWLOCK_WAIT_DONE(T_NAME(lock), T_ID(lock), mode);
+ LWLockReportWaitEnd();
LOG_LWDEBUG("LWLockAcquire", lock, "awakened");
#ifdef LWLOCK_STATS
lwstats->block_count++;
#endif
+
+ LWLockReportWaitStart(lock);
TRACE_POSTGRESQL_LWLOCK_WAIT_START(T_NAME(lock), T_ID(lock), mode);
for (;;)
}
#endif
TRACE_POSTGRESQL_LWLOCK_WAIT_DONE(T_NAME(lock), T_ID(lock), mode);
+ LWLockReportWaitEnd();
LOG_LWDEBUG("LWLockAcquireOrWait", lock, "awakened");
}
lwstats->block_count++;
#endif
+ LWLockReportWaitStart(lock);
TRACE_POSTGRESQL_LWLOCK_WAIT_START(T_NAME(lock), T_ID(lock),
LW_EXCLUSIVE);
TRACE_POSTGRESQL_LWLOCK_WAIT_DONE(T_NAME(lock), T_ID(lock),
LW_EXCLUSIVE);
+ LWLockReportWaitEnd();
LOG_LWDEBUG("LWLockWaitForVar", lock, "awakened");
Assert(MyProc->lockGroupLeader == NULL);
Assert(dlist_is_empty(&MyProc->lockGroupMembers));
+ /* Initialize wait event information. */
+ MyProc->wait_event_info = 0;
+
/*
* Acquire ownership of the PGPROC's latch, so that we can use WaitLatch
* on it. That allows us to repoint the process latch, which so far
/* This must match enum LockTagType! */
-static const char *const LockTagTypeNames[] = {
+const char *const LockTagTypeNames[] = {
"relation",
"extend",
"page",
#include "libpq/ip.h"
#include "miscadmin.h"
#include "pgstat.h"
+#include "storage/proc.h"
+#include "storage/procarray.h"
#include "utils/acl.h"
#include "utils/builtins.h"
#include "utils/inet.h"
extern Datum pg_stat_get_backend_dbid(PG_FUNCTION_ARGS);
extern Datum pg_stat_get_backend_userid(PG_FUNCTION_ARGS);
extern Datum pg_stat_get_backend_activity(PG_FUNCTION_ARGS);
-extern Datum pg_stat_get_backend_waiting(PG_FUNCTION_ARGS);
+extern Datum pg_stat_get_backend_wait_event_type(PG_FUNCTION_ARGS);
+extern Datum pg_stat_get_backend_wait_event(PG_FUNCTION_ARGS);
extern Datum pg_stat_get_backend_activity_start(PG_FUNCTION_ARGS);
extern Datum pg_stat_get_backend_xact_start(PG_FUNCTION_ARGS);
extern Datum pg_stat_get_backend_start(PG_FUNCTION_ARGS);
Datum
pg_stat_get_activity(PG_FUNCTION_ARGS)
{
-#define PG_STAT_GET_ACTIVITY_COLS 22
+#define PG_STAT_GET_ACTIVITY_COLS 23
int num_backends = pgstat_fetch_stat_numbackends();
int curr_backend;
int pid = PG_ARGISNULL(0) ? -1 : PG_GETARG_INT32(0);
bool nulls[PG_STAT_GET_ACTIVITY_COLS];
LocalPgBackendStatus *local_beentry;
PgBackendStatus *beentry;
+ PGPROC *proc;
+ const char *wait_event_type;
+ const char *wait_event;
MemSet(values, 0, sizeof(values));
MemSet(nulls, 0, sizeof(nulls));
nulls[3] = true;
if (TransactionIdIsValid(local_beentry->backend_xid))
- values[14] = TransactionIdGetDatum(local_beentry->backend_xid);
+ values[15] = TransactionIdGetDatum(local_beentry->backend_xid);
else
- nulls[14] = true;
+ nulls[15] = true;
if (TransactionIdIsValid(local_beentry->backend_xmin))
- values[15] = TransactionIdGetDatum(local_beentry->backend_xmin);
+ values[16] = TransactionIdGetDatum(local_beentry->backend_xmin);
else
- nulls[15] = true;
+ nulls[16] = true;
if (beentry->st_ssl)
{
- values[16] = BoolGetDatum(true); /* ssl */
- values[17] = CStringGetTextDatum(beentry->st_sslstatus->ssl_version);
- values[18] = CStringGetTextDatum(beentry->st_sslstatus->ssl_cipher);
- values[19] = Int32GetDatum(beentry->st_sslstatus->ssl_bits);
- values[20] = BoolGetDatum(beentry->st_sslstatus->ssl_compression);
- values[21] = CStringGetTextDatum(beentry->st_sslstatus->ssl_clientdn);
+ values[17] = BoolGetDatum(true); /* ssl */
+ values[18] = CStringGetTextDatum(beentry->st_sslstatus->ssl_version);
+ values[19] = CStringGetTextDatum(beentry->st_sslstatus->ssl_cipher);
+ values[20] = Int32GetDatum(beentry->st_sslstatus->ssl_bits);
+ values[21] = BoolGetDatum(beentry->st_sslstatus->ssl_compression);
+ values[22] = CStringGetTextDatum(beentry->st_sslstatus->ssl_clientdn);
}
else
{
- values[16] = BoolGetDatum(false); /* ssl */
- nulls[17] = nulls[18] = nulls[19] = nulls[20] = nulls[21] = true;
+ values[17] = BoolGetDatum(false); /* ssl */
+ nulls[18] = nulls[19] = nulls[20] = nulls[21] = nulls[22] = true;
}
/* Values only available to role member */
}
values[5] = CStringGetTextDatum(beentry->st_activity);
- values[6] = BoolGetDatum(beentry->st_waiting);
- if (beentry->st_xact_start_timestamp != 0)
- values[7] = TimestampTzGetDatum(beentry->st_xact_start_timestamp);
+ proc = BackendPidGetProc(beentry->st_procpid);
+ wait_event_type = pgstat_get_wait_event_type(proc->wait_event_info);
+ if (wait_event_type)
+ values[6] = CStringGetTextDatum(wait_event_type);
+ else
+ nulls[6] = true;
+
+ wait_event = pgstat_get_wait_event(proc->wait_event_info);
+ if (wait_event)
+ values[7] = CStringGetTextDatum(wait_event);
else
nulls[7] = true;
- if (beentry->st_activity_start_timestamp != 0)
- values[8] = TimestampTzGetDatum(beentry->st_activity_start_timestamp);
+ if (beentry->st_xact_start_timestamp != 0)
+ values[8] = TimestampTzGetDatum(beentry->st_xact_start_timestamp);
else
nulls[8] = true;
- if (beentry->st_proc_start_timestamp != 0)
- values[9] = TimestampTzGetDatum(beentry->st_proc_start_timestamp);
+ if (beentry->st_activity_start_timestamp != 0)
+ values[9] = TimestampTzGetDatum(beentry->st_activity_start_timestamp);
else
nulls[9] = true;
- if (beentry->st_state_start_timestamp != 0)
- values[10] = TimestampTzGetDatum(beentry->st_state_start_timestamp);
+ if (beentry->st_proc_start_timestamp != 0)
+ values[10] = TimestampTzGetDatum(beentry->st_proc_start_timestamp);
else
nulls[10] = true;
+ if (beentry->st_state_start_timestamp != 0)
+ values[11] = TimestampTzGetDatum(beentry->st_state_start_timestamp);
+ else
+ nulls[11] = true;
+
/* A zeroed client addr means we don't know */
memset(&zero_clientaddr, 0, sizeof(zero_clientaddr));
if (memcmp(&(beentry->st_clientaddr), &zero_clientaddr,
sizeof(zero_clientaddr)) == 0)
{
- nulls[11] = true;
nulls[12] = true;
nulls[13] = true;
+ nulls[14] = true;
}
else
{
if (ret == 0)
{
clean_ipv6_addr(beentry->st_clientaddr.addr.ss_family, remote_host);
- values[11] = DirectFunctionCall1(inet_in,
+ values[12] = DirectFunctionCall1(inet_in,
CStringGetDatum(remote_host));
if (beentry->st_clienthostname &&
beentry->st_clienthostname[0])
- values[12] = CStringGetTextDatum(beentry->st_clienthostname);
+ values[13] = CStringGetTextDatum(beentry->st_clienthostname);
else
- nulls[12] = true;
- values[13] = Int32GetDatum(atoi(remote_port));
+ nulls[13] = true;
+ values[14] = Int32GetDatum(atoi(remote_port));
}
else
{
- nulls[11] = true;
nulls[12] = true;
nulls[13] = true;
+ nulls[14] = true;
}
}
else if (beentry->st_clientaddr.addr.ss_family == AF_UNIX)
* connections we have no permissions to view, or with
* errors.
*/
- nulls[11] = true;
nulls[12] = true;
- values[13] = DatumGetInt32(-1);
+ nulls[13] = true;
+ values[14] = DatumGetInt32(-1);
}
else
{
/* Unknown address type, should never happen */
- nulls[11] = true;
nulls[12] = true;
nulls[13] = true;
+ nulls[14] = true;
}
}
}
nulls[11] = true;
nulls[12] = true;
nulls[13] = true;
+ nulls[14] = true;
}
tuplestore_putvalues(tupstore, tupdesc, values, nulls);
PG_RETURN_TEXT_P(cstring_to_text(activity));
}
-
Datum
-pg_stat_get_backend_waiting(PG_FUNCTION_ARGS)
+pg_stat_get_backend_wait_event_type(PG_FUNCTION_ARGS)
{
int32 beid = PG_GETARG_INT32(0);
- bool result;
PgBackendStatus *beentry;
+ PGPROC *proc;
+ const char *wait_event_type;
if ((beentry = pgstat_fetch_stat_beentry(beid)) == NULL)
- PG_RETURN_NULL();
+ wait_event_type = "<backend information not available>";
+ else if (!has_privs_of_role(GetUserId(), beentry->st_userid))
+ wait_event_type = "<insufficient privilege>";
+ else
+ {
+ proc = BackendPidGetProc(beentry->st_procpid);
+ wait_event_type = pgstat_get_wait_event_type(proc->wait_event_info);
+ }
- if (!has_privs_of_role(GetUserId(), beentry->st_userid))
+ if (!wait_event_type)
PG_RETURN_NULL();
- result = beentry->st_waiting;
+ PG_RETURN_TEXT_P(cstring_to_text(wait_event_type));
+}
+
+Datum
+pg_stat_get_backend_wait_event(PG_FUNCTION_ARGS)
+{
+ int32 beid = PG_GETARG_INT32(0);
+ PgBackendStatus *beentry;
+ PGPROC *proc;
+ const char *wait_event;
+
+ if ((beentry = pgstat_fetch_stat_beentry(beid)) == NULL)
+ wait_event = "<backend information not available>";
+ else if (!has_privs_of_role(GetUserId(), beentry->st_userid))
+ wait_event = "<insufficient privilege>";
+ else
+ {
+ proc = BackendPidGetProc(beentry->st_procpid);
+ wait_event = pgstat_get_wait_event(proc->wait_event_info);
+ }
+
+ if (!wait_event)
+ PG_RETURN_NULL();
- PG_RETURN_BOOL(result);
+ PG_RETURN_TEXT_P(cstring_to_text(wait_event));
}
*/
/* yyyymmddN */
-#define CATALOG_VERSION_NO 201603091
+#define CATALOG_VERSION_NO 201603101
#endif
DESCR("statistics: number of auto analyzes for a table");
DATA(insert OID = 1936 ( pg_stat_get_backend_idset PGNSP PGUID 12 1 100 0 0 f f f f t t s r 0 0 23 "" _null_ _null_ _null_ _null_ _null_ pg_stat_get_backend_idset _null_ _null_ _null_ ));
DESCR("statistics: currently active backend IDs");
-DATA(insert OID = 2022 ( pg_stat_get_activity PGNSP PGUID 12 1 100 0 0 f f f f f t s r 1 0 2249 "23" "{23,26,23,26,25,25,25,16,1184,1184,1184,1184,869,25,23,28,28,16,25,25,23,16,25}" "{i,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o}" "{pid,datid,pid,usesysid,application_name,state,query,waiting,xact_start,query_start,backend_start,state_change,client_addr,client_hostname,client_port,backend_xid,backend_xmin,ssl,sslversion,sslcipher,sslbits,sslcompression,sslclientdn}" _null_ _null_ pg_stat_get_activity _null_ _null_ _null_ ));
+DATA(insert OID = 2022 ( pg_stat_get_activity PGNSP PGUID 12 1 100 0 0 f f f f f t s r 1 0 2249 "23" "{23,26,23,26,25,25,25,25,25,1184,1184,1184,1184,869,25,23,28,28,16,25,25,23,16,25}" "{i,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o}" "{pid,datid,pid,usesysid,application_name,state,query,wait_event_type,wait_event,xact_start,query_start,backend_start,state_change,client_addr,client_hostname,client_port,backend_xid,backend_xmin,ssl,sslversion,sslcipher,sslbits,sslcompression,sslclientdn}" _null_ _null_ pg_stat_get_activity _null_ _null_ _null_ ));
DESCR("statistics: information about currently active backends");
DATA(insert OID = 3318 ( pg_stat_get_progress_info PGNSP PGUID 12 1 100 0 0 f f f f f t s r 1 0 2249 "25" "{25,23,26,26,20,20,20,20,20,20,20,20,20,20}" "{i,o,o,o,o,o,o,o,o,o,o,o,o,o}" "{cmdtype,pid,datid,relid,param1,param2,param3,param4,param5,param6,param7,param8,param9,param10}" _null_ _null_ pg_stat_get_progress_info _null_ _null_ _null_ ));
DESCR("statistics: information about progress of backends running maintenance command");
DESCR("statistics: user ID of backend");
DATA(insert OID = 1940 ( pg_stat_get_backend_activity PGNSP PGUID 12 1 0 0 0 f f f f t f s r 1 0 25 "23" _null_ _null_ _null_ _null_ _null_ pg_stat_get_backend_activity _null_ _null_ _null_ ));
DESCR("statistics: current query of backend");
-DATA(insert OID = 2853 ( pg_stat_get_backend_waiting PGNSP PGUID 12 1 0 0 0 f f f f t f s r 1 0 16 "23" _null_ _null_ _null_ _null_ _null_ pg_stat_get_backend_waiting _null_ _null_ _null_ ));
-DESCR("statistics: is backend currently waiting for a lock");
+DATA(insert OID = 2788 ( pg_stat_get_backend_wait_event_type PGNSP PGUID 12 1 0 0 0 f f f f t f s r 1 0 25 "23" _null_ _null_ _null_ _null_ _null_ pg_stat_get_backend_wait_event_type _null_ _null_ _null_ ));
+DESCR("statistics: wait event type on which backend is currently waiting");
+DATA(insert OID = 2853 ( pg_stat_get_backend_wait_event PGNSP PGUID 12 1 0 0 0 f f f f t f s r 1 0 25 "23" _null_ _null_ _null_ _null_ _null_ pg_stat_get_backend_wait_event _null_ _null_ _null_ ));
+DESCR("statistics: wait event on which backend is currently waiting");
DATA(insert OID = 2094 ( pg_stat_get_backend_activity_start PGNSP PGUID 12 1 0 0 0 f f f f t f s r 1 0 1184 "23" _null_ _null_ _null_ _null_ _null_ pg_stat_get_backend_activity_start _null_ _null_ _null_ ));
DESCR("statistics: start time for current query of backend");
DATA(insert OID = 2857 ( pg_stat_get_backend_xact_start PGNSP PGUID 12 1 0 0 0 f f f f t f s r 1 0 1184 "23" _null_ _null_ _null_ _null_ _null_ pg_stat_get_backend_xact_start _null_ _null_ _null_ ));
#include "portability/instr_time.h"
#include "postmaster/pgarch.h"
#include "storage/barrier.h"
+#include "storage/proc.h"
#include "utils/hsearch.h"
#include "utils/relcache.h"
STATE_DISABLED
} BackendState;
+
+/* ----------
+ * Wait Classes
+ * ----------
+ */
+typedef enum WaitClass
+{
+ WAIT_UNDEFINED,
+ WAIT_LWLOCK_NAMED,
+ WAIT_LWLOCK_TRANCHE,
+ WAIT_LOCK,
+ WAIT_BUFFER_PIN
+} WaitClass;
+
+
/* ----------
* Command type for progress reporting purposes
* ----------
bool st_ssl;
PgBackendSSLStatus *st_sslstatus;
- /* Is backend currently waiting on an lmgr lock? */
- bool st_waiting;
-
/* current state */
BackendState st_state;
extern void pgstat_report_tempfile(size_t filesize);
extern void pgstat_report_appname(const char *appname);
extern void pgstat_report_xact_timestamp(TimestampTz tstamp);
-extern void pgstat_report_waiting(bool waiting);
+extern const char *pgstat_get_wait_event(uint32 wait_event_info);
+extern const char *pgstat_get_wait_event_type(uint32 wait_event_info);
extern const char *pgstat_get_backend_current_activity(int pid, bool checkUser);
extern const char *pgstat_get_crashed_backend_activity(int pid, char *buffer,
int buflen);
extern void pgstat_initstats(Relation rel);
+/* ----------
+ * pgstat_report_wait_start() -
+ *
+ * Called from places where server process needs to wait. This is called
+ * to report wait event information. The wait information is stored
+ * as 4-bytes where first byte repersents the wait event class (type of
+ * wait, for different types of wait, refer WaitClass) and the next
+ * 3-bytes repersent the actual wait event. Currently 2-bytes are used
+ * for wait event which is sufficient for current usage, 1-byte is
+ * reserved for future usage.
+ *
+ * NB: this *must* be able to survive being called before MyProc has been
+ * initialized.
+ * ----------
+ */
+static inline void
+pgstat_report_wait_start(uint8 classId, uint16 eventId)
+{
+ volatile PGPROC *proc = MyProc;
+ uint32 wait_event_val;
+
+ if (!pgstat_track_activities || !proc)
+ return;
+
+ wait_event_val = classId;
+ wait_event_val <<= 24;
+ wait_event_val |= eventId;
+
+ /*
+ * Since this is a four-byte field which is always read and written as
+ * four-bytes, updates are atomic.
+ */
+ proc->wait_event_info = wait_event_val;
+}
+
+/* ----------
+ * pgstat_report_wait_end() -
+ *
+ * Called to report end of a wait.
+ *
+ * NB: this *must* be able to survive being called before MyProc has been
+ * initialized.
+ * ----------
+ */
+static inline void
+pgstat_report_wait_end(void)
+{
+ volatile PGPROC *proc = MyProc;
+
+ if (!pgstat_track_activities || !proc)
+ return;
+
+ /*
+ * Since this is a four-byte field which is always read and written as
+ * four-bytes, updates are atomic.
+ */
+ proc->wait_event_info = 0;
+}
+
/* nontransactional event counts are simple enough to inline */
#define pgstat_count_heap_scan(rel) \
/* Describe a locktag for error messages */
extern void DescribeLockTag(StringInfo buf, const LOCKTAG *tag);
+extern const char *GetLockNameFromTagType(uint16 locktag_type);
+
#endif /* LMGR_H */
#define LOCKTAG_LAST_TYPE LOCKTAG_ADVISORY
+extern const char *const LockTagTypeNames[];
+
/*
* The LOCKTAG struct is defined with malice aforethought to fit into 16
* bytes with no padding. Note that this would need adjustment if we were
extern void CreateLWLocks(void);
extern void InitLWLockAccess(void);
+extern const char *GetLWLockIdentifier(uint8 classId, uint16 eventId);
+
/*
* Extensions (or core code) can obtain an LWLocks by calling
* RequestNamedLWLockTranche() during postmaster startup. Subsequently,
*/
TransactionId procArrayGroupMemberXid;
+ uint32 wait_event_info; /* proc's wait information */
+
/* Per-backend LWLock. Protects fields below (but not group fields). */
LWLock backendLock;
s.xact_start,
s.query_start,
s.state_change,
- s.waiting,
+ s.wait_event_type,
+ s.wait_event,
s.state,
s.backend_xid,
s.backend_xmin,
s.query
FROM pg_database d,
- pg_stat_get_activity(NULL::integer) s(datid, pid, usesysid, application_name, state, query, waiting, xact_start, query_start, backend_start, state_change, client_addr, client_hostname, client_port, backend_xid, backend_xmin, ssl, sslversion, sslcipher, sslbits, sslcompression, sslclientdn),
+ pg_stat_get_activity(NULL::integer) s(datid, pid, usesysid, application_name, state, query, wait_event_type, wait_event, xact_start, query_start, backend_start, state_change, client_addr, client_hostname, client_port, backend_xid, backend_xmin, ssl, sslversion, sslcipher, sslbits, sslcompression, sslclientdn),
pg_authid u
WHERE ((s.datid = d.oid) AND (s.usesysid = u.oid));
pg_stat_all_indexes| SELECT c.oid AS relid,
w.replay_location,
w.sync_priority,
w.sync_state
- FROM pg_stat_get_activity(NULL::integer) s(datid, pid, usesysid, application_name, state, query, waiting, xact_start, query_start, backend_start, state_change, client_addr, client_hostname, client_port, backend_xid, backend_xmin, ssl, sslversion, sslcipher, sslbits, sslcompression, sslclientdn),
+ FROM pg_stat_get_activity(NULL::integer) s(datid, pid, usesysid, application_name, state, query, wait_event_type, wait_event, xact_start, query_start, backend_start, state_change, client_addr, client_hostname, client_port, backend_xid, backend_xmin, ssl, sslversion, sslcipher, sslbits, sslcompression, sslclientdn),
pg_authid u,
pg_stat_get_wal_senders() w(pid, state, sent_location, write_location, flush_location, replay_location, sync_priority, sync_state)
WHERE ((s.usesysid = u.oid) AND (s.pid = w.pid));
s.sslbits AS bits,
s.sslcompression AS compression,
s.sslclientdn AS clientdn
- FROM pg_stat_get_activity(NULL::integer) s(datid, pid, usesysid, application_name, state, query, waiting, xact_start, query_start, backend_start, state_change, client_addr, client_hostname, client_port, backend_xid, backend_xmin, ssl, sslversion, sslcipher, sslbits, sslcompression, sslclientdn);
+ FROM pg_stat_get_activity(NULL::integer) s(datid, pid, usesysid, application_name, state, query, wait_event_type, wait_event, xact_start, query_start, backend_start, state_change, client_addr, client_hostname, client_port, backend_xid, backend_xmin, ssl, sslversion, sslcipher, sslbits, sslcompression, sslclientdn);
pg_stat_sys_indexes| SELECT pg_stat_all_indexes.relid,
pg_stat_all_indexes.indexrelid,
pg_stat_all_indexes.schemaname,
projects / postgresql / commitdiff