#include "postgres.h"
#include "utils/pgstat_internal.h"

Include dependency graph for pgstat_lock.c:

Macros
#define	LOCKSTAT_ACC(fld) (lck_shstats->fld += PendingLockStats.stats[i].fld)

Functions
PgStat_Lock *	pgstat_fetch_stat_lock (void)

void	pgstat_lock_flush (bool nowait)

bool	pgstat_lock_flush_cb (bool nowait)

void	pgstat_lock_init_shmem_cb (void *stats)

void	pgstat_lock_reset_all_cb (TimestampTz ts)

void	pgstat_lock_snapshot_cb (void)

void	pgstat_count_lock_fastpath_exceeded (uint8 locktag_type)

void	pgstat_count_lock_waits (uint8 locktag_type, long msecs)

Variables
static PgStat_PendingLock	PendingLockStats

static bool	have_lockstats = false

Macro Definition Documentation

◆ LOCKSTAT_ACC

#define LOCKSTAT_ACC ( fld ) (lck_shstats->fld += PendingLockStats.stats[i].fld)

Function Documentation

◆ pgstat_count_lock_fastpath_exceeded()

void pgstat_count_lock_fastpath_exceeded ( uint8 locktag_type )

Definition at line 156 of file pgstat_lock.c.

{
    Assert(locktag_type <= LOCKTAG_LAST_TYPE);
    PendingLockStats.stats[locktag_type].fastpath_exceeded++;
    have_lockstats = true;
    pgstat_report_fixed = true;
}

References Assert, PgStat_LockEntry::fastpath_exceeded, have_lockstats, LOCKTAG_LAST_TYPE, PendingLockStats, pgstat_report_fixed, and PgStat_PendingLock::stats.

Referenced by LockAcquireExtended().

◆ pgstat_count_lock_waits()

void pgstat_count_lock_waits	(	uint8	locktag_type,
		long	msecs
	)

Definition at line 171 of file pgstat_lock.c.

{
    Assert(locktag_type <= LOCKTAG_LAST_TYPE);
    PendingLockStats.stats[locktag_type].waits++;
    PendingLockStats.stats[locktag_type].wait_time += (PgStat_Counter) msecs;
    have_lockstats = true;
    pgstat_report_fixed = true;
}

References Assert, fb(), have_lockstats, LOCKTAG_LAST_TYPE, PendingLockStats, pgstat_report_fixed, PgStat_PendingLock::stats, PgStat_LockEntry::wait_time, and PgStat_LockEntry::waits.

Referenced by ProcSleep().

◆ pgstat_fetch_stat_lock()

PgStat_Lock * pgstat_fetch_stat_lock ( void )

Definition at line 26 of file pgstat_lock.c.

{
    pgstat_snapshot_fixed(PGSTAT_KIND_LOCK);
 
    return &pgStatLocal.snapshot.lock;
}

References PgStat_Snapshot::lock, PGSTAT_KIND_LOCK, pgstat_snapshot_fixed(), pgStatLocal, and PgStat_LocalState::snapshot.

Referenced by pg_stat_get_lock().

◆ pgstat_lock_flush()

void pgstat_lock_flush ( bool nowait )

Definition at line 37 of file pgstat_lock.c.

{
    (void) pgstat_lock_flush_cb(nowait);
}

References fb(), and pgstat_lock_flush_cb().

◆ pgstat_lock_flush_cb()

bool pgstat_lock_flush_cb ( bool nowait )

Definition at line 51 of file pgstat_lock.c.

{
    LWLock     *lcktype_lock;
    PgStat_LockEntry *lck_shstats;
    bool        lock_not_acquired = false;
 
    if (!have_lockstats)
        return false;
 
    for (int i = 0; i <= LOCKTAG_LAST_TYPE; i++)
    {
        lcktype_lock = &pgStatLocal.shmem->lock.locks[i];
        lck_shstats =
            &pgStatLocal.shmem->lock.stats.stats[i];
 
        if (!nowait)
            LWLockAcquire(lcktype_lock, LW_EXCLUSIVE);
        else if (!LWLockConditionalAcquire(lcktype_lock, LW_EXCLUSIVE))
        {
            lock_not_acquired = true;
            continue;
        }
 
#define LOCKSTAT_ACC(fld) \
    (lck_shstats->fld += PendingLockStats.stats[i].fld)
        LOCKSTAT_ACC(waits);
        LOCKSTAT_ACC(wait_time);
        LOCKSTAT_ACC(fastpath_exceeded);
#undef LOCKSTAT_ACC
 
        LWLockRelease(lcktype_lock);
    }
 
    memset(&PendingLockStats, 0, sizeof(PendingLockStats));
 
    have_lockstats = false;
 
    return lock_not_acquired;
}

References fb(), have_lockstats, i, PgStat_ShmemControl::lock, PgStatShared_Lock::locks, LOCKSTAT_ACC, LOCKTAG_LAST_TYPE, LW_EXCLUSIVE, LWLockAcquire(), LWLockConditionalAcquire(), LWLockRelease(), PendingLockStats, pgStatLocal, PgStat_LocalState::shmem, PgStat_Lock::stats, and PgStatShared_Lock::stats.

Referenced by pgstat_lock_flush().

◆ pgstat_lock_init_shmem_cb()

void pgstat_lock_init_shmem_cb ( void * stats )

Definition at line 93 of file pgstat_lock.c.

{
    PgStatShared_Lock *stat_shmem = (PgStatShared_Lock *) stats;
 
    for (int i = 0; i <= LOCKTAG_LAST_TYPE; i++)
        LWLockInitialize(&stat_shmem->locks[i], LWTRANCHE_PGSTATS_DATA);
}

References fb(), i, LOCKTAG_LAST_TYPE, and LWLockInitialize().

◆ pgstat_lock_reset_all_cb()

void pgstat_lock_reset_all_cb ( TimestampTz ts )

Definition at line 102 of file pgstat_lock.c.

{
    for (int i = 0; i <= LOCKTAG_LAST_TYPE; i++)
    {
        LWLock     *lcktype_lock = &pgStatLocal.shmem->lock.locks[i];
        PgStat_LockEntry *lck_shstats = &pgStatLocal.shmem->lock.stats.stats[i];
 
        LWLockAcquire(lcktype_lock, LW_EXCLUSIVE);
 
        /*
         * Use the lock in the first lock type PgStat_LockEntry to protect the
         * reset timestamp as well.
         */
        if (i == 0)
            pgStatLocal.shmem->lock.stats.stat_reset_timestamp = ts;
 
        memset(lck_shstats, 0, sizeof(*lck_shstats));
        LWLockRelease(lcktype_lock);
    }
}

References fb(), i, PgStat_ShmemControl::lock, PgStatShared_Lock::locks, LOCKTAG_LAST_TYPE, LW_EXCLUSIVE, LWLockAcquire(), LWLockRelease(), pgStatLocal, PgStat_LocalState::shmem, PgStat_Lock::stat_reset_timestamp, PgStat_Lock::stats, and PgStatShared_Lock::stats.

◆ pgstat_lock_snapshot_cb()

void pgstat_lock_snapshot_cb ( void )

Definition at line 124 of file pgstat_lock.c.

{
    for (int i = 0; i <= LOCKTAG_LAST_TYPE; i++)
    {
        LWLock     *lcktype_lock = &pgStatLocal.shmem->lock.locks[i];
        PgStat_LockEntry *lck_shstats = &pgStatLocal.shmem->lock.stats.stats[i];
        PgStat_LockEntry *lck_snap = &pgStatLocal.snapshot.lock.stats[i];
 
        LWLockAcquire(lcktype_lock, LW_SHARED);
 
        /*
         * Use the lock in the first lock type PgStat_LockEntry to protect the
         * reset timestamp as well.
         */
        if (i == 0)
            pgStatLocal.snapshot.lock.stat_reset_timestamp =
                pgStatLocal.shmem->lock.stats.stat_reset_timestamp;
 
        /* using struct assignment due to better type safety */
        *lck_snap = *lck_shstats;
        LWLockRelease(lcktype_lock);
    }
}

References fb(), i, PgStat_ShmemControl::lock, PgStat_Snapshot::lock, PgStatShared_Lock::locks, LOCKTAG_LAST_TYPE, LW_SHARED, LWLockAcquire(), LWLockRelease(), pgStatLocal, PgStat_LocalState::shmem, PgStat_LocalState::snapshot, PgStat_Lock::stat_reset_timestamp, PgStat_Lock::stats, and PgStatShared_Lock::stats.

Variable Documentation

◆ have_lockstats

bool have_lockstats = false

static

Definition at line 23 of file pgstat_lock.c.

Referenced by pgstat_count_lock_fastpath_exceeded(), pgstat_count_lock_waits(), and pgstat_lock_flush_cb().

◆ PendingLockStats

PgStat_PendingLock PendingLockStats