pgstat_database.c File Reference

#include "postgres.h"
#include "storage/standby.h"
#include "utils/pgstat_internal.h"
#include "utils/timestamp.h"

Include dependency graph for pgstat_database.c:

Go to the source code of this file.

Macros
#define	PGSTAT_ACCUM_DBCOUNT(item)    (sharedent)->stats.item += (pendingent)->item

Functions
static bool	pgstat_should_report_connstat (void)
void	pgstat_drop_database (Oid databaseid)
void	pgstat_report_autovac (Oid dboid)
void	pgstat_report_recovery_conflict (int reason)
void	pgstat_report_deadlock (void)
void	pgstat_prepare_report_checksum_failure (Oid dboid)
void	pgstat_report_checksum_failures_in_db (Oid dboid, int failurecount)
void	pgstat_report_tempfile (size_t filesize)
void	pgstat_report_connect (Oid dboid)
void	pgstat_report_disconnect (Oid dboid)
PgStat_StatDBEntry *	pgstat_fetch_stat_dbentry (Oid dboid)
void	AtEOXact_PgStat_Database (bool isCommit, bool parallel)
void	pgstat_update_parallel_workers_stats (PgStat_Counter workers_to_launch, PgStat_Counter workers_launched)
void	pgstat_update_dbstats (TimestampTz ts)
PgStat_StatDBEntry *	pgstat_prep_database_pending (Oid dboid)
void	pgstat_reset_database_timestamp (Oid dboid, TimestampTz ts)
bool	pgstat_database_flush_cb (PgStat_EntryRef *entry_ref, bool nowait)
void	pgstat_database_reset_timestamp_cb (PgStatShared_Common *header, TimestampTz ts)

Variables
PgStat_Counter	pgStatBlockReadTime = 0
PgStat_Counter	pgStatBlockWriteTime = 0
PgStat_Counter	pgStatActiveTime = 0
PgStat_Counter	pgStatTransactionIdleTime = 0
SessionEndType	pgStatSessionEndCause = DISCONNECT_NORMAL
static int	pgStatXactCommit = 0
static int	pgStatXactRollback = 0
static PgStat_Counter	pgLastSessionReportTime = 0

Macro Definition Documentation

PGSTAT_ACCUM_DBCOUNT

#define PGSTAT_ACCUM_DBCOUNT

(

item

)

(sharedent)->stats.item += (pendingent)->item

Function Documentation

AtEOXact_PgStat_Database()

void AtEOXact_PgStat_Database	(	bool	isCommit,
		bool	parallel
	)

Definition at line 295 of file pgstat_database.c.

{
    /* Don't count parallel worker transaction stats */
    if (!parallel)
    {
        /*
         * Count transaction commit or abort.  (We use counters, not just
         * bools, in case the reporting message isn't sent right away.)
         */
        if (isCommit)
            pgStatXactCommit++;
        else
            pgStatXactRollback++;
    }
}

References fb(), pgStatXactCommit, and pgStatXactRollback.

Referenced by AtEOXact_PgStat().

pgstat_database_flush_cb()

bool pgstat_database_flush_cb	(	PgStat_EntryRef *	entry_ref,
		bool	nowait
	)

Definition at line 438 of file pgstat_database.c.

{
    PgStatShared_Database *sharedent;
    PgStat_StatDBEntry *pendingent;
 
    pendingent = (PgStat_StatDBEntry *) entry_ref->pending;
    sharedent = (PgStatShared_Database *) entry_ref->shared_stats;
 
    if (!pgstat_lock_entry(entry_ref, nowait))
        return false;
 
#define PGSTAT_ACCUM_DBCOUNT(item)      \
    (sharedent)->stats.item += (pendingent)->item
 
    PGSTAT_ACCUM_DBCOUNT(xact_commit);
    PGSTAT_ACCUM_DBCOUNT(xact_rollback);
    PGSTAT_ACCUM_DBCOUNT(blocks_fetched);
    PGSTAT_ACCUM_DBCOUNT(blocks_hit);
 
    PGSTAT_ACCUM_DBCOUNT(tuples_returned);
    PGSTAT_ACCUM_DBCOUNT(tuples_fetched);
    PGSTAT_ACCUM_DBCOUNT(tuples_inserted);
    PGSTAT_ACCUM_DBCOUNT(tuples_updated);
    PGSTAT_ACCUM_DBCOUNT(tuples_deleted);
 
    /* last_autovac_time is reported immediately */
    Assert(pendingent->last_autovac_time == 0);
 
    PGSTAT_ACCUM_DBCOUNT(conflict_tablespace);
    PGSTAT_ACCUM_DBCOUNT(conflict_lock);
    PGSTAT_ACCUM_DBCOUNT(conflict_snapshot);
    PGSTAT_ACCUM_DBCOUNT(conflict_logicalslot);
    PGSTAT_ACCUM_DBCOUNT(conflict_bufferpin);
    PGSTAT_ACCUM_DBCOUNT(conflict_startup_deadlock);
 
    PGSTAT_ACCUM_DBCOUNT(temp_bytes);
    PGSTAT_ACCUM_DBCOUNT(temp_files);
    PGSTAT_ACCUM_DBCOUNT(deadlocks);
 
    /* checksum failures are reported immediately */
    Assert(pendingent->checksum_failures == 0);
    Assert(pendingent->last_checksum_failure == 0);
 
    PGSTAT_ACCUM_DBCOUNT(blk_read_time);
    PGSTAT_ACCUM_DBCOUNT(blk_write_time);
 
    PGSTAT_ACCUM_DBCOUNT(sessions);
    PGSTAT_ACCUM_DBCOUNT(session_time);
    PGSTAT_ACCUM_DBCOUNT(active_time);
    PGSTAT_ACCUM_DBCOUNT(idle_in_transaction_time);
    PGSTAT_ACCUM_DBCOUNT(sessions_abandoned);
    PGSTAT_ACCUM_DBCOUNT(sessions_fatal);
    PGSTAT_ACCUM_DBCOUNT(sessions_killed);
    PGSTAT_ACCUM_DBCOUNT(parallel_workers_to_launch);
    PGSTAT_ACCUM_DBCOUNT(parallel_workers_launched);
#undef PGSTAT_ACCUM_DBCOUNT
 
    pgstat_unlock_entry(entry_ref);
 
    memset(pendingent, 0, sizeof(*pendingent));
 
    return true;
}

References Assert, fb(), PgStat_EntryRef::pending, PGSTAT_ACCUM_DBCOUNT, pgstat_lock_entry(), pgstat_unlock_entry(), and PgStat_EntryRef::shared_stats.

pgstat_database_reset_timestamp_cb()

void pgstat_database_reset_timestamp_cb	(	PgStatShared_Common *	header,
		TimestampTz	ts
	)

Definition at line 503 of file pgstat_database.c.

{
    ((PgStatShared_Database *) header)->stats.stat_reset_timestamp = ts;
}

pgstat_drop_database()

void pgstat_drop_database

(

Oid

databaseid

)

Definition at line 44 of file pgstat_database.c.

{
    pgstat_drop_transactional(PGSTAT_KIND_DATABASE, databaseid, InvalidOid);
}

References fb(), InvalidOid, pgstat_drop_transactional(), and PGSTAT_KIND_DATABASE.

Referenced by dropdb().

pgstat_fetch_stat_dbentry()

PgStat_StatDBEntry * pgstat_fetch_stat_dbentry

(

Oid

dboid

)

Definition at line 288 of file pgstat_database.c.

{
    return (PgStat_StatDBEntry *)
        pgstat_fetch_entry(PGSTAT_KIND_DATABASE, dboid, InvalidOid);
}

References InvalidOid, pgstat_fetch_entry(), and PGSTAT_KIND_DATABASE.

Referenced by do_start_worker(), pg_stat_get_db_checksum_failures(), pg_stat_get_db_checksum_last_failure(), pg_stat_get_db_conflict_all(), pg_stat_get_db_stat_reset_time(), and rebuild_database_list().

pgstat_prep_database_pending()

PgStat_StatDBEntry * pgstat_prep_database_pending

(

Oid

dboid

)

Definition at line 396 of file pgstat_database.c.

{
    PgStat_EntryRef *entry_ref;
 
    /*
     * This should not report stats on database objects before having
     * connected to a database.
     */
    Assert(!OidIsValid(dboid) || OidIsValid(MyDatabaseId));
 
    entry_ref = pgstat_prep_pending_entry(PGSTAT_KIND_DATABASE, dboid, InvalidOid,
                                          NULL);
 
    return entry_ref->pending;
}

References Assert, fb(), InvalidOid, MyDatabaseId, OidIsValid, PgStat_EntryRef::pending, PGSTAT_KIND_DATABASE, and pgstat_prep_pending_entry().

Referenced by pgstat_relation_flush_cb(), pgstat_report_connect(), pgstat_report_deadlock(), pgstat_report_disconnect(), pgstat_report_recovery_conflict(), pgstat_report_tempfile(), pgstat_update_dbstats(), and pgstat_update_parallel_workers_stats().

pgstat_prepare_report_checksum_failure()

void pgstat_prepare_report_checksum_failure

(

Oid

dboid

)

Definition at line 155 of file pgstat_database.c.

{
    Assert(!CritSectionCount);
 
    /*
     * Just need to ensure this backend has an entry ref for the database.
     * That will allows us to report checksum failures without e.g. needing to
     * map in DSM segments.
     */
    pgstat_get_entry_ref(PGSTAT_KIND_DATABASE, dboid, InvalidOid,
                         true, NULL);
}

References Assert, CritSectionCount, fb(), InvalidOid, pgstat_get_entry_ref(), and PGSTAT_KIND_DATABASE.

Referenced by AsyncReadBuffers(), read_rel_block_ll(), RelationCopyStorage(), and sendFile().

pgstat_report_autovac()

void pgstat_report_autovac

(

Oid

dboid

)

Definition at line 55 of file pgstat_database.c.

{
    PgStat_EntryRef *entry_ref;
    PgStatShared_Database *dbentry;
 
    /* can't get here in single user mode */
    Assert(IsUnderPostmaster);
 
    /*
     * End-of-vacuum is reported instantly. Report the start the same way for
     * consistency. Vacuum doesn't run frequently and is a long-lasting
     * operation so it doesn't matter if we get blocked here a little.
     */
    entry_ref = pgstat_get_entry_ref_locked(PGSTAT_KIND_DATABASE,
                                            dboid, InvalidOid, false);
 
    dbentry = (PgStatShared_Database *) entry_ref->shared_stats;
    dbentry->stats.last_autovac_time = GetCurrentTimestamp();
 
    pgstat_unlock_entry(entry_ref);
}

References Assert, fb(), GetCurrentTimestamp(), InvalidOid, IsUnderPostmaster, pgstat_get_entry_ref_locked(), PGSTAT_KIND_DATABASE, pgstat_unlock_entry(), and PgStat_EntryRef::shared_stats.

Referenced by AutoVacWorkerMain().

pgstat_report_checksum_failures_in_db()

void pgstat_report_checksum_failures_in_db	(	Oid	dboid,
		int	failurecount
	)

Definition at line 176 of file pgstat_database.c.

{
    PgStat_EntryRef *entry_ref;
    PgStatShared_Database *sharedent;
 
    if (!pgstat_track_counts)
        return;
 
    /*
     * Update the shared stats directly - checksum failures should never be
     * common enough for that to be a problem. Note that we pass create=false
     * here, as we want to be sure to not require memory allocations, so this
     * can be called in critical sections.
     */
    entry_ref = pgstat_get_entry_ref(PGSTAT_KIND_DATABASE, dboid, InvalidOid,
                                     false, NULL);
 
    /*
     * Should always have been created by
     * pgstat_prepare_report_checksum_failure().
     *
     * When not using assertions, we don't want to crash should something have
     * gone wrong, so just return.
     */
    Assert(entry_ref);
    if (!entry_ref)
    {
        elog(WARNING, "could not report %d checksum failures for database %u",
             failurecount, dboid);
        return;
    }
 
    (void) pgstat_lock_entry(entry_ref, false);
 
    sharedent = (PgStatShared_Database *) entry_ref->shared_stats;
    sharedent->stats.checksum_failures += failurecount;
    sharedent->stats.last_checksum_failure = GetCurrentTimestamp();
 
    pgstat_unlock_entry(entry_ref);
}

References Assert, elog, fb(), GetCurrentTimestamp(), InvalidOid, pgstat_get_entry_ref(), PGSTAT_KIND_DATABASE, pgstat_lock_entry(), pgstat_track_counts, pgstat_unlock_entry(), PgStat_EntryRef::shared_stats, and WARNING.

Referenced by buffer_readv_complete(), RelationCopyStorage(), sendFile(), and shared_buffer_readv_complete_local().

pgstat_report_connect()

void pgstat_report_connect

(

Oid

dboid

)

Definition at line 237 of file pgstat_database.c.

{
    PgStat_StatDBEntry *dbentry;
 
    if (!pgstat_should_report_connstat())
        return;
 
    pgLastSessionReportTime = MyStartTimestamp;
 
    dbentry = pgstat_prep_database_pending(MyDatabaseId);
    dbentry->sessions++;
}

References fb(), MyDatabaseId, MyStartTimestamp, pgLastSessionReportTime, pgstat_prep_database_pending(), and pgstat_should_report_connstat().

Referenced by PostgresMain().

pgstat_report_deadlock()

void pgstat_report_deadlock

(

void

)

Definition at line 135 of file pgstat_database.c.

{
    PgStat_StatDBEntry *dbent;
 
    if (!pgstat_track_counts)
        return;
 
    dbent = pgstat_prep_database_pending(MyDatabaseId);
    dbent->deadlocks++;
}

References fb(), MyDatabaseId, pgstat_prep_database_pending(), and pgstat_track_counts.

Referenced by DeadLockReport().

pgstat_report_disconnect()

void pgstat_report_disconnect

(

Oid

dboid

)

Definition at line 254 of file pgstat_database.c.

{
    PgStat_StatDBEntry *dbentry;
 
    if (!pgstat_should_report_connstat())
        return;
 
    dbentry = pgstat_prep_database_pending(MyDatabaseId);
 
    switch (pgStatSessionEndCause)
    {
        case DISCONNECT_NOT_YET:
        case DISCONNECT_NORMAL:
            /* we don't collect these */
            break;
        case DISCONNECT_CLIENT_EOF:
            dbentry->sessions_abandoned++;
            break;
        case DISCONNECT_FATAL:
            dbentry->sessions_fatal++;
            break;
        case DISCONNECT_KILLED:
            dbentry->sessions_killed++;
            break;
    }
}

References DISCONNECT_CLIENT_EOF, DISCONNECT_FATAL, DISCONNECT_KILLED, DISCONNECT_NORMAL, DISCONNECT_NOT_YET, fb(), MyDatabaseId, pgstat_prep_database_pending(), pgstat_should_report_connstat(), and pgStatSessionEndCause.

Referenced by pgstat_shutdown_hook().

pgstat_report_recovery_conflict()

void pgstat_report_recovery_conflict

(

int

reason

)

Definition at line 81 of file pgstat_database.c.

{
    PgStat_StatDBEntry *dbentry;
 
    Assert(IsUnderPostmaster);
    if (!pgstat_track_counts)
        return;
 
    dbentry = pgstat_prep_database_pending(MyDatabaseId);
 
    switch ((RecoveryConflictReason) reason)
    {
        case RECOVERY_CONFLICT_DATABASE:
 
            /*
             * Since we drop the information about the database as soon as it
             * replicates, there is no point in counting these conflicts.
             */
            break;
        case RECOVERY_CONFLICT_TABLESPACE:
            dbentry->conflict_tablespace++;
            break;
        case RECOVERY_CONFLICT_LOCK:
            dbentry->conflict_lock++;
            break;
        case RECOVERY_CONFLICT_SNAPSHOT:
            dbentry->conflict_snapshot++;
            break;
        case RECOVERY_CONFLICT_BUFFERPIN:
            dbentry->conflict_bufferpin++;
            break;
        case RECOVERY_CONFLICT_LOGICALSLOT:
            dbentry->conflict_logicalslot++;
            break;
        case RECOVERY_CONFLICT_STARTUP_DEADLOCK:
            dbentry->conflict_startup_deadlock++;
            break;
        case RECOVERY_CONFLICT_BUFFERPIN_DEADLOCK:
 
            /*
             * The difference between RECOVERY_CONFLICT_STARTUP_DEADLOCK and
             * RECOVERY_CONFLICT_BUFFERPIN_DEADLOCK is merely whether a buffer
             * pin was part of the deadlock. We use the same counter for both
             * reasons.
             */
            dbentry->conflict_startup_deadlock++;
            break;
    }
}

References Assert, fb(), IsUnderPostmaster, MyDatabaseId, pgstat_prep_database_pending(), pgstat_track_counts, RECOVERY_CONFLICT_BUFFERPIN, RECOVERY_CONFLICT_BUFFERPIN_DEADLOCK, RECOVERY_CONFLICT_DATABASE, RECOVERY_CONFLICT_LOCK, RECOVERY_CONFLICT_LOGICALSLOT, RECOVERY_CONFLICT_SNAPSHOT, RECOVERY_CONFLICT_STARTUP_DEADLOCK, and RECOVERY_CONFLICT_TABLESPACE.

Referenced by report_recovery_conflict().

pgstat_report_tempfile()

void pgstat_report_tempfile

(

size_t

filesize

)

Definition at line 221 of file pgstat_database.c.

{
    PgStat_StatDBEntry *dbent;
 
    if (!pgstat_track_counts)
        return;
 
    dbent = pgstat_prep_database_pending(MyDatabaseId);
    dbent->temp_bytes += filesize;
    dbent->temp_files++;
}

References fb(), MyDatabaseId, pgstat_prep_database_pending(), and pgstat_track_counts.

Referenced by ReportTemporaryFileUsage().

pgstat_reset_database_timestamp()

void pgstat_reset_database_timestamp	(	Oid	dboid,
		TimestampTz	ts
	)

Definition at line 417 of file pgstat_database.c.

{
    PgStat_EntryRef *dbref;
    PgStatShared_Database *dbentry;
 
    dbref = pgstat_get_entry_ref_locked(PGSTAT_KIND_DATABASE, MyDatabaseId, InvalidOid,
                                        false);
 
    dbentry = (PgStatShared_Database *) dbref->shared_stats;
    dbentry->stats.stat_reset_timestamp = ts;
 
    pgstat_unlock_entry(dbref);
}

References fb(), InvalidOid, MyDatabaseId, pgstat_get_entry_ref_locked(), PGSTAT_KIND_DATABASE, and pgstat_unlock_entry().

Referenced by pgstat_reset().

pgstat_should_report_connstat()

static bool pgstat_should_report_connstat ( void  )

static

Definition at line 387 of file pgstat_database.c.

{
    return MyBackendType == B_BACKEND;
}

References B_BACKEND, and MyBackendType.

Referenced by pgstat_report_connect(), pgstat_report_disconnect(), and pgstat_update_dbstats().

pgstat_update_dbstats()

void pgstat_update_dbstats

(

TimestampTz

ts

)

Definition at line 333 of file pgstat_database.c.

{
    PgStat_StatDBEntry *dbentry;
 
    /*
     * If not connected to a database yet, don't attribute time to "shared
     * state" (InvalidOid is used to track stats for shared relations, etc.).
     */
    if (!OidIsValid(MyDatabaseId))
        return;
 
    dbentry = pgstat_prep_database_pending(MyDatabaseId);
 
    /*
     * Accumulate xact commit/rollback and I/O timings to stats entry of the
     * current database.
     */
    dbentry->xact_commit += pgStatXactCommit;
    dbentry->xact_rollback += pgStatXactRollback;
    dbentry->blk_read_time += pgStatBlockReadTime;
    dbentry->blk_write_time += pgStatBlockWriteTime;
 
    if (pgstat_should_report_connstat())
    {
        long        secs;
        int         usecs;
 
        /*
         * pgLastSessionReportTime is initialized to MyStartTimestamp by
         * pgstat_report_connect().
         */
        TimestampDifference(pgLastSessionReportTime, ts, &secs, &usecs);
        pgLastSessionReportTime = ts;
        dbentry->session_time += (PgStat_Counter) secs * 1000000 + usecs;
        dbentry->active_time += pgStatActiveTime;
        dbentry->idle_in_transaction_time += pgStatTransactionIdleTime;
    }
 
    pgStatXactCommit = 0;
    pgStatXactRollback = 0;
    pgStatBlockReadTime = 0;
    pgStatBlockWriteTime = 0;
    pgStatActiveTime = 0;
    pgStatTransactionIdleTime = 0;
}

References fb(), MyDatabaseId, OidIsValid, pgLastSessionReportTime, pgstat_prep_database_pending(), pgstat_should_report_connstat(), pgStatActiveTime, pgStatBlockReadTime, pgStatBlockWriteTime, pgStatTransactionIdleTime, pgStatXactCommit, pgStatXactRollback, and TimestampDifference().

Referenced by pgstat_report_stat().

pgstat_update_parallel_workers_stats()

void pgstat_update_parallel_workers_stats	(	PgStat_Counter	workers_to_launch,
		PgStat_Counter	workers_launched
	)

Definition at line 315 of file pgstat_database.c.

{
    PgStat_StatDBEntry *dbentry;
 
    if (!OidIsValid(MyDatabaseId))
        return;
 
    dbentry = pgstat_prep_database_pending(MyDatabaseId);
    dbentry->parallel_workers_to_launch += workers_to_launch;
    dbentry->parallel_workers_launched += workers_launched;
}

References fb(), MyDatabaseId, OidIsValid, and pgstat_prep_database_pending().

Referenced by standard_ExecutorEnd().

Variable Documentation

pgLastSessionReportTime

PgStat_Counter pgLastSessionReportTime = 0

static

Definition at line 37 of file pgstat_database.c.

Referenced by pgstat_report_connect(), and pgstat_update_dbstats().

pgStatActiveTime

PgStat_Counter pgStatActiveTime = 0

Definition at line 30 of file pgstat_database.c.

Referenced by pgstat_update_dbstats().

pgStatBlockReadTime

PgStat_Counter pgStatBlockReadTime = 0

Definition at line 28 of file pgstat_database.c.

Referenced by do_analyze_rel(), heap_vacuum_rel(), and pgstat_update_dbstats().

pgStatBlockWriteTime

PgStat_Counter pgStatBlockWriteTime = 0

Definition at line 29 of file pgstat_database.c.

Referenced by do_analyze_rel(), heap_vacuum_rel(), and pgstat_update_dbstats().

pgStatSessionEndCause

SessionEndType pgStatSessionEndCause = DISCONNECT_NORMAL

Definition at line 32 of file pgstat_database.c.

Referenced by die(), errfinish(), pgstat_report_disconnect(), and PostgresMain().

pgStatTransactionIdleTime

PgStat_Counter pgStatTransactionIdleTime = 0

Definition at line 31 of file pgstat_database.c.

Referenced by pgstat_update_dbstats().

pgStatXactCommit

int pgStatXactCommit = 0

static

Definition at line 35 of file pgstat_database.c.

Referenced by AtEOXact_PgStat_Database(), and pgstat_update_dbstats().

pgStatXactRollback

int pgStatXactRollback = 0

static

Definition at line 36 of file pgstat_database.c.

Referenced by AtEOXact_PgStat_Database(), and pgstat_update_dbstats().