PostgreSQL Source Code  git master
pgstat.h File Reference
#include "datatype/timestamp.h"
#include "libpq/pqcomm.h"
#include "miscadmin.h"
#include "port/atomics.h"
#include "portability/instr_time.h"
#include "postmaster/pgarch.h"
#include "storage/proc.h"
#include "utils/hsearch.h"
#include "utils/relcache.h"
Include dependency graph for pgstat.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures

struct  PgStat_TableCounts
 
struct  PgStat_TableStatus
 
struct  PgStat_TableXactStatus
 
struct  PgStat_MsgHdr
 
struct  PgStat_MsgDummy
 
struct  PgStat_MsgInquiry
 
struct  PgStat_TableEntry
 
struct  PgStat_MsgTabstat
 
struct  PgStat_MsgTabpurge
 
struct  PgStat_MsgDropdb
 
struct  PgStat_MsgResetcounter
 
struct  PgStat_MsgResetsharedcounter
 
struct  PgStat_MsgResetsinglecounter
 
struct  PgStat_MsgAutovacStart
 
struct  PgStat_MsgVacuum
 
struct  PgStat_MsgAnalyze
 
struct  PgStat_MsgArchiver
 
struct  PgStat_MsgBgWriter
 
struct  PgStat_MsgRecoveryConflict
 
struct  PgStat_MsgTempFile
 
struct  PgStat_FunctionCounts
 
struct  PgStat_BackendFunctionEntry
 
struct  PgStat_FunctionEntry
 
struct  PgStat_MsgFuncstat
 
struct  PgStat_MsgFuncpurge
 
struct  PgStat_MsgDeadlock
 
struct  PgStat_MsgChecksumFailure
 
union  PgStat_Msg
 
struct  PgStat_StatDBEntry
 
struct  PgStat_StatTabEntry
 
struct  PgStat_StatFuncEntry
 
struct  PgStat_ArchiverStats
 
struct  PgStat_GlobalStats
 
struct  PgBackendSSLStatus
 
struct  PgBackendGSSStatus
 
struct  PgBackendStatus
 
struct  LocalPgBackendStatus
 
struct  PgStat_FunctionCallUsage
 

Macros

#define PGSTAT_STAT_PERMANENT_DIRECTORY   "pg_stat"
 
#define PGSTAT_STAT_PERMANENT_FILENAME   "pg_stat/global.stat"
 
#define PGSTAT_STAT_PERMANENT_TMPFILE   "pg_stat/global.tmp"
 
#define PG_STAT_TMP_DIR   "pg_stat_tmp"
 
#define PGSTAT_MAX_MSG_SIZE   1000
 
#define PGSTAT_MSG_PAYLOAD   (PGSTAT_MAX_MSG_SIZE - sizeof(PgStat_MsgHdr))
 
#define PGSTAT_NUM_TABENTRIES
 
#define PGSTAT_NUM_TABPURGE
 
#define PGSTAT_NUM_FUNCENTRIES
 
#define PGSTAT_NUM_FUNCPURGE
 
#define PGSTAT_FILE_FORMAT_ID   0x01A5BC9D
 
#define PG_WAIT_LWLOCK   0x01000000U
 
#define PG_WAIT_LOCK   0x03000000U
 
#define PG_WAIT_BUFFER_PIN   0x04000000U
 
#define PG_WAIT_ACTIVITY   0x05000000U
 
#define PG_WAIT_CLIENT   0x06000000U
 
#define PG_WAIT_EXTENSION   0x07000000U
 
#define PG_WAIT_IPC   0x08000000U
 
#define PG_WAIT_TIMEOUT   0x09000000U
 
#define PG_WAIT_IO   0x0A000000U
 
#define PGSTAT_NUM_PROGRESS_PARAM   20
 
#define PGSTAT_BEGIN_WRITE_ACTIVITY(beentry)
 
#define PGSTAT_END_WRITE_ACTIVITY(beentry)
 
#define pgstat_begin_read_activity(beentry, before_changecount)
 
#define pgstat_end_read_activity(beentry, after_changecount)
 
#define pgstat_read_activity_complete(before_changecount, after_changecount)
 
#define pgstat_count_heap_scan(rel)
 
#define pgstat_count_heap_getnext(rel)
 
#define pgstat_count_heap_fetch(rel)
 
#define pgstat_count_index_scan(rel)
 
#define pgstat_count_index_tuples(rel, n)
 
#define pgstat_count_buffer_read(rel)
 
#define pgstat_count_buffer_hit(rel)
 
#define pgstat_count_buffer_read_time(n)   (pgStatBlockReadTime += (n))
 
#define pgstat_count_buffer_write_time(n)   (pgStatBlockWriteTime += (n))
 

Typedefs

typedef enum TrackFunctionsLevel TrackFunctionsLevel
 
typedef enum StatMsgType StatMsgType
 
typedef int64 PgStat_Counter
 
typedef struct PgStat_TableCounts PgStat_TableCounts
 
typedef enum PgStat_Shared_Reset_Target PgStat_Shared_Reset_Target
 
typedef enum PgStat_Single_Reset_Type PgStat_Single_Reset_Type
 
typedef struct PgStat_TableStatus PgStat_TableStatus
 
typedef struct PgStat_TableXactStatus PgStat_TableXactStatus
 
typedef struct PgStat_MsgHdr PgStat_MsgHdr
 
typedef struct PgStat_MsgDummy PgStat_MsgDummy
 
typedef struct PgStat_MsgInquiry PgStat_MsgInquiry
 
typedef struct PgStat_TableEntry PgStat_TableEntry
 
typedef struct PgStat_MsgTabstat PgStat_MsgTabstat
 
typedef struct PgStat_MsgTabpurge PgStat_MsgTabpurge
 
typedef struct PgStat_MsgDropdb PgStat_MsgDropdb
 
typedef struct PgStat_MsgResetcounter PgStat_MsgResetcounter
 
typedef struct PgStat_MsgResetsharedcounter PgStat_MsgResetsharedcounter
 
typedef struct PgStat_MsgResetsinglecounter PgStat_MsgResetsinglecounter
 
typedef struct PgStat_MsgAutovacStart PgStat_MsgAutovacStart
 
typedef struct PgStat_MsgVacuum PgStat_MsgVacuum
 
typedef struct PgStat_MsgAnalyze PgStat_MsgAnalyze
 
typedef struct PgStat_MsgArchiver PgStat_MsgArchiver
 
typedef struct PgStat_MsgBgWriter PgStat_MsgBgWriter
 
typedef struct PgStat_MsgRecoveryConflict PgStat_MsgRecoveryConflict
 
typedef struct PgStat_MsgTempFile PgStat_MsgTempFile
 
typedef struct PgStat_FunctionCounts PgStat_FunctionCounts
 
typedef struct PgStat_BackendFunctionEntry PgStat_BackendFunctionEntry
 
typedef struct PgStat_FunctionEntry PgStat_FunctionEntry
 
typedef struct PgStat_MsgFuncstat PgStat_MsgFuncstat
 
typedef struct PgStat_MsgFuncpurge PgStat_MsgFuncpurge
 
typedef struct PgStat_MsgDeadlock PgStat_MsgDeadlock
 
typedef struct PgStat_MsgChecksumFailure PgStat_MsgChecksumFailure
 
typedef union PgStat_Msg PgStat_Msg
 
typedef struct PgStat_StatDBEntry PgStat_StatDBEntry
 
typedef struct PgStat_StatTabEntry PgStat_StatTabEntry
 
typedef struct PgStat_StatFuncEntry PgStat_StatFuncEntry
 
typedef struct PgStat_ArchiverStats PgStat_ArchiverStats
 
typedef struct PgStat_GlobalStats PgStat_GlobalStats
 
typedef enum BackendState BackendState
 
typedef enum ProgressCommandType ProgressCommandType
 
typedef struct PgBackendSSLStatus PgBackendSSLStatus
 
typedef struct PgBackendGSSStatus PgBackendGSSStatus
 
typedef struct PgBackendStatus PgBackendStatus
 
typedef struct LocalPgBackendStatus LocalPgBackendStatus
 
typedef struct PgStat_FunctionCallUsage PgStat_FunctionCallUsage
 

Enumerations

enum  TrackFunctionsLevel { TRACK_FUNC_OFF, TRACK_FUNC_PL, TRACK_FUNC_ALL }
 
enum  StatMsgType {
  PGSTAT_MTYPE_DUMMY, PGSTAT_MTYPE_INQUIRY, PGSTAT_MTYPE_TABSTAT, PGSTAT_MTYPE_TABPURGE,
  PGSTAT_MTYPE_DROPDB, PGSTAT_MTYPE_RESETCOUNTER, PGSTAT_MTYPE_RESETSHAREDCOUNTER, PGSTAT_MTYPE_RESETSINGLECOUNTER,
  PGSTAT_MTYPE_AUTOVAC_START, PGSTAT_MTYPE_VACUUM, PGSTAT_MTYPE_ANALYZE, PGSTAT_MTYPE_ARCHIVER,
  PGSTAT_MTYPE_BGWRITER, PGSTAT_MTYPE_FUNCSTAT, PGSTAT_MTYPE_FUNCPURGE, PGSTAT_MTYPE_RECOVERYCONFLICT,
  PGSTAT_MTYPE_TEMPFILE, PGSTAT_MTYPE_DEADLOCK, PGSTAT_MTYPE_CHECKSUMFAILURE
}
 
enum  PgStat_Shared_Reset_Target { RESET_ARCHIVER, RESET_BGWRITER }
 
enum  PgStat_Single_Reset_Type { RESET_TABLE, RESET_FUNCTION }
 
enum  BackendState {
  STATE_UNDEFINED, STATE_IDLE, STATE_RUNNING, STATE_IDLEINTRANSACTION,
  STATE_FASTPATH, STATE_IDLEINTRANSACTION_ABORTED, STATE_DISABLED
}
 
enum  WaitEventActivity {
  WAIT_EVENT_ARCHIVER_MAIN = PG_WAIT_ACTIVITY, WAIT_EVENT_AUTOVACUUM_MAIN, WAIT_EVENT_BGWRITER_HIBERNATE, WAIT_EVENT_BGWRITER_MAIN,
  WAIT_EVENT_CHECKPOINTER_MAIN, WAIT_EVENT_LOGICAL_APPLY_MAIN, WAIT_EVENT_LOGICAL_LAUNCHER_MAIN, WAIT_EVENT_PGSTAT_MAIN,
  WAIT_EVENT_RECOVERY_WAL_STREAM, WAIT_EVENT_SYSLOGGER_MAIN, WAIT_EVENT_WAL_RECEIVER_MAIN, WAIT_EVENT_WAL_SENDER_MAIN,
  WAIT_EVENT_WAL_WRITER_MAIN
}
 
enum  WaitEventClient {
  WAIT_EVENT_CLIENT_READ = PG_WAIT_CLIENT, WAIT_EVENT_CLIENT_WRITE, WAIT_EVENT_GSS_OPEN_SERVER, WAIT_EVENT_LIBPQWALRECEIVER_CONNECT,
  WAIT_EVENT_LIBPQWALRECEIVER_RECEIVE, WAIT_EVENT_SSL_OPEN_SERVER, WAIT_EVENT_WAL_RECEIVER_WAIT_START, WAIT_EVENT_WAL_SENDER_WAIT_WAL,
  WAIT_EVENT_WAL_SENDER_WRITE_DATA
}
 
enum  WaitEventIPC {
  WAIT_EVENT_BACKUP_WAIT_WAL_ARCHIVE = PG_WAIT_IPC, WAIT_EVENT_BGWORKER_SHUTDOWN, WAIT_EVENT_BGWORKER_STARTUP, WAIT_EVENT_BTREE_PAGE,
  WAIT_EVENT_CLOG_GROUP_UPDATE, WAIT_EVENT_CHECKPOINT_DONE, WAIT_EVENT_CHECKPOINT_START, WAIT_EVENT_EXECUTE_GATHER,
  WAIT_EVENT_HASH_BATCH_ALLOCATING, WAIT_EVENT_HASH_BATCH_ELECTING, WAIT_EVENT_HASH_BATCH_LOADING, WAIT_EVENT_HASH_BUILD_ALLOCATING,
  WAIT_EVENT_HASH_BUILD_ELECTING, WAIT_EVENT_HASH_BUILD_HASHING_INNER, WAIT_EVENT_HASH_BUILD_HASHING_OUTER, WAIT_EVENT_HASH_GROW_BATCHES_ALLOCATING,
  WAIT_EVENT_HASH_GROW_BATCHES_DECIDING, WAIT_EVENT_HASH_GROW_BATCHES_ELECTING, WAIT_EVENT_HASH_GROW_BATCHES_FINISHING, WAIT_EVENT_HASH_GROW_BATCHES_REPARTITIONING,
  WAIT_EVENT_HASH_GROW_BUCKETS_ALLOCATING, WAIT_EVENT_HASH_GROW_BUCKETS_ELECTING, WAIT_EVENT_HASH_GROW_BUCKETS_REINSERTING, WAIT_EVENT_LOGICAL_SYNC_DATA,
  WAIT_EVENT_LOGICAL_SYNC_STATE_CHANGE, WAIT_EVENT_MQ_INTERNAL, WAIT_EVENT_MQ_PUT_MESSAGE, WAIT_EVENT_MQ_RECEIVE,
  WAIT_EVENT_MQ_SEND, WAIT_EVENT_PARALLEL_BITMAP_SCAN, WAIT_EVENT_PARALLEL_CREATE_INDEX_SCAN, WAIT_EVENT_PARALLEL_FINISH,
  WAIT_EVENT_PROCARRAY_GROUP_UPDATE, WAIT_EVENT_PROMOTE, WAIT_EVENT_RECOVERY_PAUSE, WAIT_EVENT_REPLICATION_ORIGIN_DROP,
  WAIT_EVENT_REPLICATION_SLOT_DROP, WAIT_EVENT_SAFE_SNAPSHOT, WAIT_EVENT_SYNC_REP
}
 
enum  WaitEventTimeout {
  WAIT_EVENT_BASE_BACKUP_THROTTLE = PG_WAIT_TIMEOUT, WAIT_EVENT_PG_SLEEP, WAIT_EVENT_RECOVERY_APPLY_DELAY, WAIT_EVENT_RECOVERY_RETRIEVE_RETRY_INTERVAL,
  WAIT_EVENT_VACUUM_DELAY
}
 
enum  WaitEventIO {
  WAIT_EVENT_BUFFILE_READ = PG_WAIT_IO, WAIT_EVENT_BUFFILE_WRITE, WAIT_EVENT_CONTROL_FILE_READ, WAIT_EVENT_CONTROL_FILE_SYNC,
  WAIT_EVENT_CONTROL_FILE_SYNC_UPDATE, WAIT_EVENT_CONTROL_FILE_WRITE, WAIT_EVENT_CONTROL_FILE_WRITE_UPDATE, WAIT_EVENT_COPY_FILE_READ,
  WAIT_EVENT_COPY_FILE_WRITE, WAIT_EVENT_DATA_FILE_EXTEND, WAIT_EVENT_DATA_FILE_FLUSH, WAIT_EVENT_DATA_FILE_IMMEDIATE_SYNC,
  WAIT_EVENT_DATA_FILE_PREFETCH, WAIT_EVENT_DATA_FILE_READ, WAIT_EVENT_DATA_FILE_SYNC, WAIT_EVENT_DATA_FILE_TRUNCATE,
  WAIT_EVENT_DATA_FILE_WRITE, WAIT_EVENT_DSM_FILL_ZERO_WRITE, WAIT_EVENT_LOCK_FILE_ADDTODATADIR_READ, WAIT_EVENT_LOCK_FILE_ADDTODATADIR_SYNC,
  WAIT_EVENT_LOCK_FILE_ADDTODATADIR_WRITE, WAIT_EVENT_LOCK_FILE_CREATE_READ, WAIT_EVENT_LOCK_FILE_CREATE_SYNC, WAIT_EVENT_LOCK_FILE_CREATE_WRITE,
  WAIT_EVENT_LOCK_FILE_RECHECKDATADIR_READ, WAIT_EVENT_LOGICAL_REWRITE_CHECKPOINT_SYNC, WAIT_EVENT_LOGICAL_REWRITE_MAPPING_SYNC, WAIT_EVENT_LOGICAL_REWRITE_MAPPING_WRITE,
  WAIT_EVENT_LOGICAL_REWRITE_SYNC, WAIT_EVENT_LOGICAL_REWRITE_TRUNCATE, WAIT_EVENT_LOGICAL_REWRITE_WRITE, WAIT_EVENT_PROC_SIGNAL_BARRIER,
  WAIT_EVENT_RELATION_MAP_READ, WAIT_EVENT_RELATION_MAP_SYNC, WAIT_EVENT_RELATION_MAP_WRITE, WAIT_EVENT_REORDER_BUFFER_READ,
  WAIT_EVENT_REORDER_BUFFER_WRITE, WAIT_EVENT_REORDER_LOGICAL_MAPPING_READ, WAIT_EVENT_REPLICATION_SLOT_READ, WAIT_EVENT_REPLICATION_SLOT_RESTORE_SYNC,
  WAIT_EVENT_REPLICATION_SLOT_SYNC, WAIT_EVENT_REPLICATION_SLOT_WRITE, WAIT_EVENT_SLRU_FLUSH_SYNC, WAIT_EVENT_SLRU_READ,
  WAIT_EVENT_SLRU_SYNC, WAIT_EVENT_SLRU_WRITE, WAIT_EVENT_SNAPBUILD_READ, WAIT_EVENT_SNAPBUILD_SYNC,
  WAIT_EVENT_SNAPBUILD_WRITE, WAIT_EVENT_TIMELINE_HISTORY_FILE_SYNC, WAIT_EVENT_TIMELINE_HISTORY_FILE_WRITE, WAIT_EVENT_TIMELINE_HISTORY_READ,
  WAIT_EVENT_TIMELINE_HISTORY_SYNC, WAIT_EVENT_TIMELINE_HISTORY_WRITE, WAIT_EVENT_TWOPHASE_FILE_READ, WAIT_EVENT_TWOPHASE_FILE_SYNC,
  WAIT_EVENT_TWOPHASE_FILE_WRITE, WAIT_EVENT_WALSENDER_TIMELINE_HISTORY_READ, WAIT_EVENT_WAL_BOOTSTRAP_SYNC, WAIT_EVENT_WAL_BOOTSTRAP_WRITE,
  WAIT_EVENT_WAL_COPY_READ, WAIT_EVENT_WAL_COPY_SYNC, WAIT_EVENT_WAL_COPY_WRITE, WAIT_EVENT_WAL_INIT_SYNC,
  WAIT_EVENT_WAL_INIT_WRITE, WAIT_EVENT_WAL_READ, WAIT_EVENT_WAL_SYNC, WAIT_EVENT_WAL_SYNC_METHOD_ASSIGN,
  WAIT_EVENT_WAL_WRITE
}
 
enum  ProgressCommandType {
  PROGRESS_COMMAND_INVALID, PROGRESS_COMMAND_VACUUM, PROGRESS_COMMAND_ANALYZE, PROGRESS_COMMAND_CLUSTER,
  PROGRESS_COMMAND_CREATE_INDEX, PROGRESS_COMMAND_BASEBACKUP
}
 

Functions

Size BackendStatusShmemSize (void)
 
void CreateSharedBackendStatus (void)
 
void pgstat_init (void)
 
int pgstat_start (void)
 
void pgstat_reset_all (void)
 
void allow_immediate_pgstat_restart (void)
 
void pgstat_ping (void)
 
void pgstat_report_stat (bool force)
 
void pgstat_vacuum_stat (void)
 
void pgstat_drop_database (Oid databaseid)
 
void pgstat_clear_snapshot (void)
 
void pgstat_reset_counters (void)
 
void pgstat_reset_shared_counters (const char *)
 
void pgstat_reset_single_counter (Oid objectid, PgStat_Single_Reset_Type type)
 
void pgstat_report_autovac (Oid dboid)
 
void pgstat_report_vacuum (Oid tableoid, bool shared, PgStat_Counter livetuples, PgStat_Counter deadtuples)
 
void pgstat_report_analyze (Relation rel, PgStat_Counter livetuples, PgStat_Counter deadtuples, bool resetcounter)
 
void pgstat_report_recovery_conflict (int reason)
 
void pgstat_report_deadlock (void)
 
void pgstat_report_checksum_failures_in_db (Oid dboid, int failurecount)
 
void pgstat_report_checksum_failure (void)
 
void pgstat_initialize (void)
 
void pgstat_bestart (void)
 
void pgstat_report_activity (BackendState state, const char *cmd_str)
 
void pgstat_report_tempfile (size_t filesize)
 
void pgstat_report_appname (const char *appname)
 
void pgstat_report_xact_timestamp (TimestampTz tstamp)
 
const char * pgstat_get_wait_event (uint32 wait_event_info)
 
const char * pgstat_get_wait_event_type (uint32 wait_event_info)
 
const char * pgstat_get_backend_current_activity (int pid, bool checkUser)
 
const char * pgstat_get_crashed_backend_activity (int pid, char *buffer, int buflen)
 
void pgstat_progress_start_command (ProgressCommandType cmdtype, Oid relid)
 
void pgstat_progress_update_param (int index, int64 val)
 
void pgstat_progress_update_multi_param (int nparam, const int *index, const int64 *val)
 
void pgstat_progress_end_command (void)
 
PgStat_TableStatusfind_tabstat_entry (Oid rel_id)
 
PgStat_BackendFunctionEntryfind_funcstat_entry (Oid func_id)
 
void pgstat_initstats (Relation rel)
 
char * pgstat_clip_activity (const char *raw_activity)
 
static void pgstat_report_wait_start (uint32 wait_event_info)
 
static void pgstat_report_wait_end (void)
 
void pgstat_count_heap_insert (Relation rel, PgStat_Counter n)
 
void pgstat_count_heap_update (Relation rel, bool hot)
 
void pgstat_count_heap_delete (Relation rel)
 
void pgstat_count_truncate (Relation rel)
 
void pgstat_update_heap_dead_tuples (Relation rel, int delta)
 
void pgstat_init_function_usage (struct FunctionCallInfoBaseData *fcinfo, PgStat_FunctionCallUsage *fcu)
 
void pgstat_end_function_usage (PgStat_FunctionCallUsage *fcu, bool finalize)
 
void AtEOXact_PgStat (bool isCommit, bool parallel)
 
void AtEOSubXact_PgStat (bool isCommit, int nestDepth)
 
void AtPrepare_PgStat (void)
 
void PostPrepare_PgStat (void)
 
void pgstat_twophase_postcommit (TransactionId xid, uint16 info, void *recdata, uint32 len)
 
void pgstat_twophase_postabort (TransactionId xid, uint16 info, void *recdata, uint32 len)
 
void pgstat_send_archiver (const char *xlog, bool failed)
 
void pgstat_send_bgwriter (void)
 
PgStat_StatDBEntrypgstat_fetch_stat_dbentry (Oid dbid)
 
PgStat_StatTabEntrypgstat_fetch_stat_tabentry (Oid relid)
 
PgBackendStatuspgstat_fetch_stat_beentry (int beid)
 
LocalPgBackendStatuspgstat_fetch_stat_local_beentry (int beid)
 
PgStat_StatFuncEntrypgstat_fetch_stat_funcentry (Oid funcid)
 
int pgstat_fetch_stat_numbackends (void)
 
PgStat_ArchiverStatspgstat_fetch_stat_archiver (void)
 
PgStat_GlobalStatspgstat_fetch_global (void)
 

Variables

PGDLLIMPORT bool pgstat_track_activities
 
PGDLLIMPORT bool pgstat_track_counts
 
PGDLLIMPORT int pgstat_track_functions
 
PGDLLIMPORT int pgstat_track_activity_query_size
 
char * pgstat_stat_directory
 
char * pgstat_stat_tmpname
 
char * pgstat_stat_filename
 
PgStat_MsgBgWriter BgWriterStats
 
PgStat_Counter pgStatBlockReadTime
 
PgStat_Counter pgStatBlockWriteTime
 

Macro Definition Documentation

◆ PG_STAT_TMP_DIR

#define PG_STAT_TMP_DIR   "pg_stat_tmp"

Definition at line 34 of file pgstat.h.

◆ PG_WAIT_ACTIVITY

#define PG_WAIT_ACTIVITY   0x05000000U

Definition at line 740 of file pgstat.h.

Referenced by pgstat_get_wait_event(), and pgstat_get_wait_event_type().

◆ PG_WAIT_BUFFER_PIN

#define PG_WAIT_BUFFER_PIN   0x04000000U

◆ PG_WAIT_CLIENT

#define PG_WAIT_CLIENT   0x06000000U

Definition at line 741 of file pgstat.h.

Referenced by pgstat_get_wait_event(), and pgstat_get_wait_event_type().

◆ PG_WAIT_EXTENSION

◆ PG_WAIT_IO

#define PG_WAIT_IO   0x0A000000U

Definition at line 745 of file pgstat.h.

Referenced by pgstat_get_wait_event(), and pgstat_get_wait_event_type().

◆ PG_WAIT_IPC

#define PG_WAIT_IPC   0x08000000U

Definition at line 743 of file pgstat.h.

Referenced by pgstat_get_wait_event(), and pgstat_get_wait_event_type().

◆ PG_WAIT_LOCK

#define PG_WAIT_LOCK   0x03000000U

◆ PG_WAIT_LWLOCK

#define PG_WAIT_LWLOCK   0x01000000U

◆ PG_WAIT_TIMEOUT

#define PG_WAIT_TIMEOUT   0x09000000U

Definition at line 744 of file pgstat.h.

Referenced by pgstat_get_wait_event(), and pgstat_get_wait_event_type().

◆ pgstat_begin_read_activity

#define pgstat_begin_read_activity (   beentry,
  before_changecount 
)
Value:
do { \
(before_changecount) = (beentry)->st_changecount; \
pg_read_barrier(); \
} while (0)

Definition at line 1134 of file pgstat.h.

Referenced by pgstat_get_backend_current_activity(), and pgstat_read_current_status().

◆ PGSTAT_BEGIN_WRITE_ACTIVITY

#define PGSTAT_BEGIN_WRITE_ACTIVITY (   beentry)

◆ pgstat_count_buffer_hit

#define pgstat_count_buffer_hit (   rel)
Value:
do { \
if ((rel)->pgstat_info != NULL) \
(rel)->pgstat_info->t_counts.t_blocks_hit++; \
} while (0)

Definition at line 1376 of file pgstat.h.

Referenced by ReadBufferExtended().

◆ pgstat_count_buffer_read

#define pgstat_count_buffer_read (   rel)
Value:
do { \
if ((rel)->pgstat_info != NULL) \
(rel)->pgstat_info->t_counts.t_blocks_fetched++; \
} while (0)

Definition at line 1371 of file pgstat.h.

Referenced by ReadBufferExtended().

◆ pgstat_count_buffer_read_time

#define pgstat_count_buffer_read_time (   n)    (pgStatBlockReadTime += (n))

Definition at line 1381 of file pgstat.h.

Referenced by ReadBuffer_common().

◆ pgstat_count_buffer_write_time

#define pgstat_count_buffer_write_time (   n)    (pgStatBlockWriteTime += (n))

Definition at line 1383 of file pgstat.h.

Referenced by FlushBuffer().

◆ pgstat_count_heap_fetch

#define pgstat_count_heap_fetch (   rel)
Value:
do { \
if ((rel)->pgstat_info != NULL) \
(rel)->pgstat_info->t_counts.t_tuples_fetched++; \
} while (0)

Definition at line 1356 of file pgstat.h.

Referenced by heapam_scan_bitmap_next_tuple(), and index_fetch_heap().

◆ pgstat_count_heap_getnext

#define pgstat_count_heap_getnext (   rel)
Value:
do { \
if ((rel)->pgstat_info != NULL) \
(rel)->pgstat_info->t_counts.t_tuples_returned++; \
} while (0)

Definition at line 1351 of file pgstat.h.

Referenced by heap_getnext(), heap_getnextslot(), and heapam_scan_sample_next_tuple().

◆ pgstat_count_heap_scan

#define pgstat_count_heap_scan (   rel)
Value:
do { \
if ((rel)->pgstat_info != NULL) \
(rel)->pgstat_info->t_counts.t_numscans++; \
} while (0)

Definition at line 1346 of file pgstat.h.

Referenced by initscan().

◆ pgstat_count_index_scan

#define pgstat_count_index_scan (   rel)
Value:
do { \
if ((rel)->pgstat_info != NULL) \
(rel)->pgstat_info->t_counts.t_numscans++; \
} while (0)

Definition at line 1361 of file pgstat.h.

Referenced by _bt_first(), _hash_first(), bringetbitmap(), gistgetbitmap(), and gistgettuple().

◆ pgstat_count_index_tuples

#define pgstat_count_index_tuples (   rel,
 
)
Value:
do { \
if ((rel)->pgstat_info != NULL) \
(rel)->pgstat_info->t_counts.t_tuples_returned += (n); \
} while (0)

Definition at line 1366 of file pgstat.h.

Referenced by index_getbitmap(), and index_getnext_tid().

◆ pgstat_end_read_activity

#define pgstat_end_read_activity (   beentry,
  after_changecount 
)
Value:
do { \
pg_read_barrier(); \
(after_changecount) = (beentry)->st_changecount; \
} while (0)

Definition at line 1140 of file pgstat.h.

Referenced by pgstat_get_backend_current_activity(), and pgstat_read_current_status().

◆ PGSTAT_END_WRITE_ACTIVITY

#define PGSTAT_END_WRITE_ACTIVITY (   beentry)
Value:
do { \
pg_write_barrier(); \
(beentry)->st_changecount++; \
Assert(((beentry)->st_changecount & 1) == 0); \
END_CRIT_SECTION(); \
} while (0)

Definition at line 1126 of file pgstat.h.

Referenced by pgstat_beshutdown_hook(), pgstat_bestart(), pgstat_progress_end_command(), pgstat_progress_start_command(), pgstat_progress_update_multi_param(), pgstat_progress_update_param(), pgstat_report_activity(), pgstat_report_appname(), and pgstat_report_xact_timestamp().

◆ PGSTAT_FILE_FORMAT_ID

#define PGSTAT_FILE_FORMAT_ID   0x01A5BC9D

◆ PGSTAT_MAX_MSG_SIZE

#define PGSTAT_MAX_MSG_SIZE   1000

Definition at line 207 of file pgstat.h.

Referenced by pgstat_init().

◆ PGSTAT_MSG_PAYLOAD

#define PGSTAT_MSG_PAYLOAD   (PGSTAT_MAX_MSG_SIZE - sizeof(PgStat_MsgHdr))

Definition at line 208 of file pgstat.h.

◆ PGSTAT_NUM_FUNCENTRIES

#define PGSTAT_NUM_FUNCENTRIES
Value:
((PGSTAT_MSG_PAYLOAD - sizeof(Oid) - sizeof(int)) \
unsigned int Oid
Definition: postgres_ext.h:31
#define PGSTAT_MSG_PAYLOAD
Definition: pgstat.h:208

Definition at line 494 of file pgstat.h.

Referenced by pgstat_send_funcstats().

◆ PGSTAT_NUM_FUNCPURGE

#define PGSTAT_NUM_FUNCPURGE
Value:
((PGSTAT_MSG_PAYLOAD - sizeof(Oid) - sizeof(int)) \
/ sizeof(Oid))
unsigned int Oid
Definition: postgres_ext.h:31
#define PGSTAT_MSG_PAYLOAD
Definition: pgstat.h:208

Definition at line 511 of file pgstat.h.

Referenced by pgstat_vacuum_stat().

◆ PGSTAT_NUM_PROGRESS_PARAM

#define PGSTAT_NUM_PROGRESS_PARAM   20

◆ PGSTAT_NUM_TABENTRIES

#define PGSTAT_NUM_TABENTRIES
Value:
((PGSTAT_MSG_PAYLOAD - sizeof(Oid) - 3 * sizeof(int) - 2 * sizeof(PgStat_Counter)) \
/ sizeof(PgStat_TableEntry))
int64 PgStat_Counter
Definition: pgstat.h:75
unsigned int Oid
Definition: postgres_ext.h:31
struct PgStat_TableEntry PgStat_TableEntry
#define PGSTAT_MSG_PAYLOAD
Definition: pgstat.h:208

Definition at line 264 of file pgstat.h.

Referenced by pgstat_report_stat().

◆ PGSTAT_NUM_TABPURGE

#define PGSTAT_NUM_TABPURGE
Value:
((PGSTAT_MSG_PAYLOAD - sizeof(Oid) - sizeof(int)) \
/ sizeof(Oid))
unsigned int Oid
Definition: postgres_ext.h:31
#define PGSTAT_MSG_PAYLOAD
Definition: pgstat.h:208

Definition at line 286 of file pgstat.h.

Referenced by pgstat_vacuum_stat().

◆ pgstat_read_activity_complete

#define pgstat_read_activity_complete (   before_changecount,
  after_changecount 
)
Value:
((before_changecount) == (after_changecount) && \
((before_changecount) & 1) == 0)

Definition at line 1146 of file pgstat.h.

Referenced by pgstat_get_backend_current_activity(), and pgstat_read_current_status().

◆ PGSTAT_STAT_PERMANENT_DIRECTORY

#define PGSTAT_STAT_PERMANENT_DIRECTORY   "pg_stat"

Definition at line 29 of file pgstat.h.

Referenced by get_dbstat_filename(), and pgstat_reset_all().

◆ PGSTAT_STAT_PERMANENT_FILENAME

#define PGSTAT_STAT_PERMANENT_FILENAME   "pg_stat/global.stat"

◆ PGSTAT_STAT_PERMANENT_TMPFILE

#define PGSTAT_STAT_PERMANENT_TMPFILE   "pg_stat/global.tmp"

Definition at line 31 of file pgstat.h.

Referenced by pgstat_write_statsfiles().

Typedef Documentation

◆ BackendState

typedef enum BackendState BackendState

◆ LocalPgBackendStatus

◆ PgBackendGSSStatus

◆ PgBackendSSLStatus

◆ PgBackendStatus

◆ PgStat_ArchiverStats

◆ PgStat_BackendFunctionEntry

◆ PgStat_Counter

typedef int64 PgStat_Counter

Definition at line 75 of file pgstat.h.

◆ PgStat_FunctionCallUsage

◆ PgStat_FunctionCounts

◆ PgStat_FunctionEntry

◆ PgStat_GlobalStats

◆ PgStat_Msg

typedef union PgStat_Msg PgStat_Msg

◆ PgStat_MsgAnalyze

◆ PgStat_MsgArchiver

◆ PgStat_MsgAutovacStart

◆ PgStat_MsgBgWriter

◆ PgStat_MsgChecksumFailure

◆ PgStat_MsgDeadlock

◆ PgStat_MsgDropdb

◆ PgStat_MsgDummy

◆ PgStat_MsgFuncpurge

◆ PgStat_MsgFuncstat

◆ PgStat_MsgHdr

typedef struct PgStat_MsgHdr PgStat_MsgHdr

◆ PgStat_MsgInquiry

◆ PgStat_MsgRecoveryConflict

◆ PgStat_MsgResetcounter

◆ PgStat_MsgResetsharedcounter

◆ PgStat_MsgResetsinglecounter

◆ PgStat_MsgTabpurge

◆ PgStat_MsgTabstat

◆ PgStat_MsgTempFile

◆ PgStat_MsgVacuum

◆ PgStat_Shared_Reset_Target

◆ PgStat_Single_Reset_Type

◆ PgStat_StatDBEntry

◆ PgStat_StatFuncEntry

◆ PgStat_StatTabEntry

◆ PgStat_TableCounts

◆ PgStat_TableEntry

◆ PgStat_TableStatus

◆ PgStat_TableXactStatus

◆ ProgressCommandType

◆ StatMsgType

typedef enum StatMsgType StatMsgType

◆ TrackFunctionsLevel

Enumeration Type Documentation

◆ BackendState

Enumerator
STATE_UNDEFINED 
STATE_IDLE 
STATE_RUNNING 
STATE_IDLEINTRANSACTION 
STATE_FASTPATH 
STATE_IDLEINTRANSACTION_ABORTED 
STATE_DISABLED 

Definition at line 721 of file pgstat.h.

◆ PgStat_Shared_Reset_Target

Enumerator
RESET_ARCHIVER 
RESET_BGWRITER 

Definition at line 120 of file pgstat.h.

121 {
PgStat_Shared_Reset_Target
Definition: pgstat.h:120

◆ PgStat_Single_Reset_Type

Enumerator
RESET_TABLE 
RESET_FUNCTION 

Definition at line 127 of file pgstat.h.

128 {
129  RESET_TABLE,
PgStat_Single_Reset_Type
Definition: pgstat.h:127

◆ ProgressCommandType

Enumerator
PROGRESS_COMMAND_INVALID 
PROGRESS_COMMAND_VACUUM 
PROGRESS_COMMAND_ANALYZE 
PROGRESS_COMMAND_CLUSTER 
PROGRESS_COMMAND_CREATE_INDEX 
PROGRESS_COMMAND_BASEBACKUP 

Definition at line 941 of file pgstat.h.

◆ StatMsgType

Enumerator
PGSTAT_MTYPE_DUMMY 
PGSTAT_MTYPE_INQUIRY 
PGSTAT_MTYPE_TABSTAT 
PGSTAT_MTYPE_TABPURGE 
PGSTAT_MTYPE_DROPDB 
PGSTAT_MTYPE_RESETCOUNTER 
PGSTAT_MTYPE_RESETSHAREDCOUNTER 
PGSTAT_MTYPE_RESETSINGLECOUNTER 
PGSTAT_MTYPE_AUTOVAC_START 
PGSTAT_MTYPE_VACUUM 
PGSTAT_MTYPE_ANALYZE 
PGSTAT_MTYPE_ARCHIVER 
PGSTAT_MTYPE_BGWRITER 
PGSTAT_MTYPE_FUNCSTAT 
PGSTAT_MTYPE_FUNCPURGE 
PGSTAT_MTYPE_RECOVERYCONFLICT 
PGSTAT_MTYPE_TEMPFILE 
PGSTAT_MTYPE_DEADLOCK 
PGSTAT_MTYPE_CHECKSUMFAILURE 

Definition at line 48 of file pgstat.h.

49 {
69 } StatMsgType;
StatMsgType
Definition: pgstat.h:48

◆ TrackFunctionsLevel

Enumerator
TRACK_FUNC_OFF 
TRACK_FUNC_PL 
TRACK_FUNC_ALL 

Definition at line 37 of file pgstat.h.

◆ WaitEventActivity

Enumerator
WAIT_EVENT_ARCHIVER_MAIN 
WAIT_EVENT_AUTOVACUUM_MAIN 
WAIT_EVENT_BGWRITER_HIBERNATE 
WAIT_EVENT_BGWRITER_MAIN 
WAIT_EVENT_CHECKPOINTER_MAIN 
WAIT_EVENT_LOGICAL_APPLY_MAIN 
WAIT_EVENT_LOGICAL_LAUNCHER_MAIN 
WAIT_EVENT_PGSTAT_MAIN 
WAIT_EVENT_RECOVERY_WAL_STREAM 
WAIT_EVENT_SYSLOGGER_MAIN 
WAIT_EVENT_WAL_RECEIVER_MAIN 
WAIT_EVENT_WAL_SENDER_MAIN 
WAIT_EVENT_WAL_WRITER_MAIN 

Definition at line 755 of file pgstat.h.

◆ WaitEventClient

Enumerator
WAIT_EVENT_CLIENT_READ 
WAIT_EVENT_CLIENT_WRITE 
WAIT_EVENT_GSS_OPEN_SERVER 
WAIT_EVENT_LIBPQWALRECEIVER_CONNECT 
WAIT_EVENT_LIBPQWALRECEIVER_RECEIVE 
WAIT_EVENT_SSL_OPEN_SERVER 
WAIT_EVENT_WAL_RECEIVER_WAIT_START 
WAIT_EVENT_WAL_SENDER_WAIT_WAL 
WAIT_EVENT_WAL_SENDER_WRITE_DATA 

Definition at line 780 of file pgstat.h.

◆ WaitEventIO

Enumerator
WAIT_EVENT_BUFFILE_READ 
WAIT_EVENT_BUFFILE_WRITE 
WAIT_EVENT_CONTROL_FILE_READ 
WAIT_EVENT_CONTROL_FILE_SYNC 
WAIT_EVENT_CONTROL_FILE_SYNC_UPDATE 
WAIT_EVENT_CONTROL_FILE_WRITE 
WAIT_EVENT_CONTROL_FILE_WRITE_UPDATE 
WAIT_EVENT_COPY_FILE_READ 
WAIT_EVENT_COPY_FILE_WRITE 
WAIT_EVENT_DATA_FILE_EXTEND 
WAIT_EVENT_DATA_FILE_FLUSH 
WAIT_EVENT_DATA_FILE_IMMEDIATE_SYNC 
WAIT_EVENT_DATA_FILE_PREFETCH 
WAIT_EVENT_DATA_FILE_READ 
WAIT_EVENT_DATA_FILE_SYNC 
WAIT_EVENT_DATA_FILE_TRUNCATE 
WAIT_EVENT_DATA_FILE_WRITE 
WAIT_EVENT_DSM_FILL_ZERO_WRITE 
WAIT_EVENT_LOCK_FILE_ADDTODATADIR_READ 
WAIT_EVENT_LOCK_FILE_ADDTODATADIR_SYNC 
WAIT_EVENT_LOCK_FILE_ADDTODATADIR_WRITE 
WAIT_EVENT_LOCK_FILE_CREATE_READ 
WAIT_EVENT_LOCK_FILE_CREATE_SYNC 
WAIT_EVENT_LOCK_FILE_CREATE_WRITE 
WAIT_EVENT_LOCK_FILE_RECHECKDATADIR_READ 
WAIT_EVENT_LOGICAL_REWRITE_CHECKPOINT_SYNC 
WAIT_EVENT_LOGICAL_REWRITE_MAPPING_SYNC 
WAIT_EVENT_LOGICAL_REWRITE_MAPPING_WRITE 
WAIT_EVENT_LOGICAL_REWRITE_SYNC 
WAIT_EVENT_LOGICAL_REWRITE_TRUNCATE 
WAIT_EVENT_LOGICAL_REWRITE_WRITE 
WAIT_EVENT_PROC_SIGNAL_BARRIER 
WAIT_EVENT_RELATION_MAP_READ 
WAIT_EVENT_RELATION_MAP_SYNC 
WAIT_EVENT_RELATION_MAP_WRITE 
WAIT_EVENT_REORDER_BUFFER_READ 
WAIT_EVENT_REORDER_BUFFER_WRITE 
WAIT_EVENT_REORDER_LOGICAL_MAPPING_READ 
WAIT_EVENT_REPLICATION_SLOT_READ 
WAIT_EVENT_REPLICATION_SLOT_RESTORE_SYNC 
WAIT_EVENT_REPLICATION_SLOT_SYNC 
WAIT_EVENT_REPLICATION_SLOT_WRITE 
WAIT_EVENT_SLRU_FLUSH_SYNC 
WAIT_EVENT_SLRU_READ 
WAIT_EVENT_SLRU_SYNC 
WAIT_EVENT_SLRU_WRITE 
WAIT_EVENT_SNAPBUILD_READ 
WAIT_EVENT_SNAPBUILD_SYNC 
WAIT_EVENT_SNAPBUILD_WRITE 
WAIT_EVENT_TIMELINE_HISTORY_FILE_SYNC 
WAIT_EVENT_TIMELINE_HISTORY_FILE_WRITE 
WAIT_EVENT_TIMELINE_HISTORY_READ 
WAIT_EVENT_TIMELINE_HISTORY_SYNC 
WAIT_EVENT_TIMELINE_HISTORY_WRITE 
WAIT_EVENT_TWOPHASE_FILE_READ 
WAIT_EVENT_TWOPHASE_FILE_SYNC 
WAIT_EVENT_TWOPHASE_FILE_WRITE 
WAIT_EVENT_WALSENDER_TIMELINE_HISTORY_READ 
WAIT_EVENT_WAL_BOOTSTRAP_SYNC 
WAIT_EVENT_WAL_BOOTSTRAP_WRITE 
WAIT_EVENT_WAL_COPY_READ 
WAIT_EVENT_WAL_COPY_SYNC 
WAIT_EVENT_WAL_COPY_WRITE 
WAIT_EVENT_WAL_INIT_SYNC 
WAIT_EVENT_WAL_INIT_WRITE 
WAIT_EVENT_WAL_READ 
WAIT_EVENT_WAL_SYNC 
WAIT_EVENT_WAL_SYNC_METHOD_ASSIGN 
WAIT_EVENT_WAL_WRITE 

Definition at line 864 of file pgstat.h.

865 {
935 } WaitEventIO;
#define PG_WAIT_IO
Definition: pgstat.h:745
WaitEventIO
Definition: pgstat.h:864

◆ WaitEventIPC

Enumerator
WAIT_EVENT_BACKUP_WAIT_WAL_ARCHIVE 
WAIT_EVENT_BGWORKER_SHUTDOWN 
WAIT_EVENT_BGWORKER_STARTUP 
WAIT_EVENT_BTREE_PAGE 
WAIT_EVENT_CLOG_GROUP_UPDATE 
WAIT_EVENT_CHECKPOINT_DONE 
WAIT_EVENT_CHECKPOINT_START 
WAIT_EVENT_EXECUTE_GATHER 
WAIT_EVENT_HASH_BATCH_ALLOCATING 
WAIT_EVENT_HASH_BATCH_ELECTING 
WAIT_EVENT_HASH_BATCH_LOADING 
WAIT_EVENT_HASH_BUILD_ALLOCATING 
WAIT_EVENT_HASH_BUILD_ELECTING 
WAIT_EVENT_HASH_BUILD_HASHING_INNER 
WAIT_EVENT_HASH_BUILD_HASHING_OUTER 
WAIT_EVENT_HASH_GROW_BATCHES_ALLOCATING 
WAIT_EVENT_HASH_GROW_BATCHES_DECIDING 
WAIT_EVENT_HASH_GROW_BATCHES_ELECTING 
WAIT_EVENT_HASH_GROW_BATCHES_FINISHING 
WAIT_EVENT_HASH_GROW_BATCHES_REPARTITIONING 
WAIT_EVENT_HASH_GROW_BUCKETS_ALLOCATING 
WAIT_EVENT_HASH_GROW_BUCKETS_ELECTING 
WAIT_EVENT_HASH_GROW_BUCKETS_REINSERTING 
WAIT_EVENT_LOGICAL_SYNC_DATA 
WAIT_EVENT_LOGICAL_SYNC_STATE_CHANGE 
WAIT_EVENT_MQ_INTERNAL 
WAIT_EVENT_MQ_PUT_MESSAGE 
WAIT_EVENT_MQ_RECEIVE 
WAIT_EVENT_MQ_SEND 
WAIT_EVENT_PARALLEL_BITMAP_SCAN 
WAIT_EVENT_PARALLEL_CREATE_INDEX_SCAN 
WAIT_EVENT_PARALLEL_FINISH 
WAIT_EVENT_PROCARRAY_GROUP_UPDATE 
WAIT_EVENT_PROMOTE 
WAIT_EVENT_RECOVERY_PAUSE 
WAIT_EVENT_REPLICATION_ORIGIN_DROP 
WAIT_EVENT_REPLICATION_SLOT_DROP 
WAIT_EVENT_SAFE_SNAPSHOT 
WAIT_EVENT_SYNC_REP 

Definition at line 800 of file pgstat.h.

801 {
841 } WaitEventIPC;
WaitEventIPC
Definition: pgstat.h:800
#define PG_WAIT_IPC
Definition: pgstat.h:743

◆ WaitEventTimeout

Enumerator
WAIT_EVENT_BASE_BACKUP_THROTTLE 
WAIT_EVENT_PG_SLEEP 
WAIT_EVENT_RECOVERY_APPLY_DELAY 
WAIT_EVENT_RECOVERY_RETRIEVE_RETRY_INTERVAL 
WAIT_EVENT_VACUUM_DELAY 

Definition at line 849 of file pgstat.h.

Function Documentation

◆ allow_immediate_pgstat_restart()

void allow_immediate_pgstat_restart ( void  )

Definition at line 787 of file pgstat.c.

References last_pgstat_start_time.

Referenced by HandleChildCrash().

788 {
790 }
static time_t last_pgstat_start_time
Definition: pgstat.c:152

◆ AtEOSubXact_PgStat()

void AtEOSubXact_PgStat ( bool  isCommit,
int  nestDepth 
)

Definition at line 2177 of file pgstat.c.

References Assert, PgStat_SubXactStatus::first, get_tabstat_stack_level(), PgStat_TableXactStatus::nest_level, PgStat_SubXactStatus::nest_level, PgStat_TableXactStatus::next, PgStat_TableXactStatus::parent, pfree(), pgstat_truncate_restore_counters(), pgstat_truncate_save_counters(), pgStatXactStack, PgStat_SubXactStatus::prev, PgStat_TableStatus::t_counts, PgStat_TableCounts::t_delta_dead_tuples, PgStat_TableCounts::t_tuples_deleted, PgStat_TableCounts::t_tuples_inserted, PgStat_TableCounts::t_tuples_updated, PgStat_TableStatus::trans, trans, PgStat_TableXactStatus::truncated, PgStat_TableXactStatus::tuples_deleted, PgStat_TableXactStatus::tuples_inserted, PgStat_TableXactStatus::tuples_updated, and PgStat_TableXactStatus::upper.

Referenced by AbortSubTransaction(), and CommitSubTransaction().

2178 {
2179  PgStat_SubXactStatus *xact_state;
2180 
2181  /*
2182  * Transfer transactional insert/update counts into the next higher
2183  * subtransaction state.
2184  */
2185  xact_state = pgStatXactStack;
2186  if (xact_state != NULL &&
2187  xact_state->nest_level >= nestDepth)
2188  {
2190  PgStat_TableXactStatus *next_trans;
2191 
2192  /* delink xact_state from stack immediately to simplify reuse case */
2193  pgStatXactStack = xact_state->prev;
2194 
2195  for (trans = xact_state->first; trans != NULL; trans = next_trans)
2196  {
2197  PgStat_TableStatus *tabstat;
2198 
2199  next_trans = trans->next;
2200  Assert(trans->nest_level == nestDepth);
2201  tabstat = trans->parent;
2202  Assert(tabstat->trans == trans);
2203  if (isCommit)
2204  {
2205  if (trans->upper && trans->upper->nest_level == nestDepth - 1)
2206  {
2207  if (trans->truncated)
2208  {
2209  /* propagate the truncate status one level up */
2211  /* replace upper xact stats with ours */
2212  trans->upper->tuples_inserted = trans->tuples_inserted;
2213  trans->upper->tuples_updated = trans->tuples_updated;
2214  trans->upper->tuples_deleted = trans->tuples_deleted;
2215  }
2216  else
2217  {
2218  trans->upper->tuples_inserted += trans->tuples_inserted;
2219  trans->upper->tuples_updated += trans->tuples_updated;
2220  trans->upper->tuples_deleted += trans->tuples_deleted;
2221  }
2222  tabstat->trans = trans->upper;
2223  pfree(trans);
2224  }
2225  else
2226  {
2227  /*
2228  * When there isn't an immediate parent state, we can just
2229  * reuse the record instead of going through a
2230  * palloc/pfree pushup (this works since it's all in
2231  * TopTransactionContext anyway). We have to re-link it
2232  * into the parent level, though, and that might mean
2233  * pushing a new entry into the pgStatXactStack.
2234  */
2235  PgStat_SubXactStatus *upper_xact_state;
2236 
2237  upper_xact_state = get_tabstat_stack_level(nestDepth - 1);
2238  trans->next = upper_xact_state->first;
2239  upper_xact_state->first = trans;
2240  trans->nest_level = nestDepth - 1;
2241  }
2242  }
2243  else
2244  {
2245  /*
2246  * On abort, update top-level tabstat counts, then forget the
2247  * subtransaction
2248  */
2249 
2250  /* first restore values obliterated by truncate */
2252  /* count attempted actions regardless of commit/abort */
2253  tabstat->t_counts.t_tuples_inserted += trans->tuples_inserted;
2254  tabstat->t_counts.t_tuples_updated += trans->tuples_updated;
2255  tabstat->t_counts.t_tuples_deleted += trans->tuples_deleted;
2256  /* inserted tuples are dead, deleted tuples are unaffected */
2257  tabstat->t_counts.t_delta_dead_tuples +=
2258  trans->tuples_inserted + trans->tuples_updated;
2259  tabstat->trans = trans->upper;
2260  pfree(trans);
2261  }
2262  }
2263  pfree(xact_state);
2264  }
2265 }
PgStat_Counter tuples_updated
Definition: pgstat.h:169
struct PgStat_TableXactStatus * next
Definition: pgstat.h:180
PgStat_TableCounts t_counts
Definition: pgstat.h:159
static PgStat_SubXactStatus * get_tabstat_stack_level(int nest_level)
Definition: pgstat.c:1895
void pfree(void *pointer)
Definition: mcxt.c:1056
PgStat_Counter t_tuples_updated
Definition: pgstat.h:106
static void pgstat_truncate_restore_counters(PgStat_TableXactStatus *trans)
Definition: pgstat.c:2031
PgStat_Counter tuples_inserted
Definition: pgstat.h:168
PgStat_Counter t_delta_dead_tuples
Definition: pgstat.h:112
struct PgStat_TableXactStatus * upper
Definition: pgstat.h:177
PgStat_Counter t_tuples_deleted
Definition: pgstat.h:107
PgStat_Counter tuples_deleted
Definition: pgstat.h:170
struct PgStat_SubXactStatus * prev
Definition: pgstat.c:214
#define Assert(condition)
Definition: c.h:738
static PgStat_SubXactStatus * pgStatXactStack
Definition: pgstat.c:218
struct PgStat_TableXactStatus * trans
Definition: pgstat.h:158
static zic_t trans[TZ_MAX_LEAPS]
Definition: zic.c:396
PgStat_TableXactStatus * first
Definition: pgstat.c:215
static void pgstat_truncate_save_counters(PgStat_TableXactStatus *trans)
Definition: pgstat.c:2016
PgStat_Counter t_tuples_inserted
Definition: pgstat.h:105
PgStat_TableStatus * parent
Definition: pgstat.h:178

◆ AtEOXact_PgStat()

void AtEOXact_PgStat ( bool  isCommit,
bool  parallel 
)

Definition at line 2090 of file pgstat.c.

References Assert, PgStat_SubXactStatus::first, PgStat_TableXactStatus::nest_level, PgStat_SubXactStatus::nest_level, PgStat_TableXactStatus::next, PgStat_TableXactStatus::parent, pgstat_clear_snapshot(), pgstat_truncate_restore_counters(), pgStatXactCommit, pgStatXactRollback, pgStatXactStack, PgStat_SubXactStatus::prev, PgStat_TableCounts::t_changed_tuples, PgStat_TableStatus::t_counts, PgStat_TableCounts::t_delta_dead_tuples, PgStat_TableCounts::t_delta_live_tuples, PgStat_TableCounts::t_truncated, PgStat_TableCounts::t_tuples_deleted, PgStat_TableCounts::t_tuples_inserted, PgStat_TableCounts::t_tuples_updated, PgStat_TableStatus::trans, trans, PgStat_TableXactStatus::truncated, PgStat_TableXactStatus::tuples_deleted, PgStat_TableXactStatus::tuples_inserted, PgStat_TableXactStatus::tuples_updated, and PgStat_TableXactStatus::upper.

Referenced by AbortTransaction(), CommitTransaction(), and FinishPreparedTransaction().

2091 {
2092  PgStat_SubXactStatus *xact_state;
2093 
2094  /* Don't count parallel worker transaction stats */
2095  if (!parallel)
2096  {
2097  /*
2098  * Count transaction commit or abort. (We use counters, not just
2099  * bools, in case the reporting message isn't sent right away.)
2100  */
2101  if (isCommit)
2102  pgStatXactCommit++;
2103  else
2105  }
2106 
2107  /*
2108  * Transfer transactional insert/update counts into the base tabstat
2109  * entries. We don't bother to free any of the transactional state, since
2110  * it's all in TopTransactionContext and will go away anyway.
2111  */
2112  xact_state = pgStatXactStack;
2113  if (xact_state != NULL)
2114  {
2116 
2117  Assert(xact_state->nest_level == 1);
2118  Assert(xact_state->prev == NULL);
2119  for (trans = xact_state->first; trans != NULL; trans = trans->next)
2120  {
2121  PgStat_TableStatus *tabstat;
2122 
2123  Assert(trans->nest_level == 1);
2124  Assert(trans->upper == NULL);
2125  tabstat = trans->parent;
2126  Assert(tabstat->trans == trans);
2127  /* restore pre-truncate stats (if any) in case of aborted xact */
2128  if (!isCommit)
2130  /* count attempted actions regardless of commit/abort */
2131  tabstat->t_counts.t_tuples_inserted += trans->tuples_inserted;
2132  tabstat->t_counts.t_tuples_updated += trans->tuples_updated;
2133  tabstat->t_counts.t_tuples_deleted += trans->tuples_deleted;
2134  if (isCommit)
2135  {
2136  tabstat->t_counts.t_truncated = trans->truncated;
2137  if (trans->truncated)
2138  {
2139  /* forget live/dead stats seen by backend thus far */
2140  tabstat->t_counts.t_delta_live_tuples = 0;
2141  tabstat->t_counts.t_delta_dead_tuples = 0;
2142  }
2143  /* insert adds a live tuple, delete removes one */
2144  tabstat->t_counts.t_delta_live_tuples +=
2145  trans->tuples_inserted - trans->tuples_deleted;
2146  /* update and delete each create a dead tuple */
2147  tabstat->t_counts.t_delta_dead_tuples +=
2148  trans->tuples_updated + trans->tuples_deleted;
2149  /* insert, update, delete each count as one change event */
2150  tabstat->t_counts.t_changed_tuples +=
2151  trans->tuples_inserted + trans->tuples_updated +
2152  trans->tuples_deleted;
2153  }
2154  else
2155  {
2156  /* inserted tuples are dead, deleted tuples are unaffected */
2157  tabstat->t_counts.t_delta_dead_tuples +=
2158  trans->tuples_inserted + trans->tuples_updated;
2159  /* an aborted xact generates no changed_tuple events */
2160  }
2161  tabstat->trans = NULL;
2162  }
2163  }
2164  pgStatXactStack = NULL;
2165 
2166  /* Make sure any stats snapshot is thrown away */
2168 }
PgStat_Counter t_delta_live_tuples
Definition: pgstat.h:111
PgStat_Counter tuples_updated
Definition: pgstat.h:169
static int pgStatXactCommit
Definition: pgstat.c:220
struct PgStat_TableXactStatus * next
Definition: pgstat.h:180
PgStat_TableCounts t_counts
Definition: pgstat.h:159
PgStat_Counter t_tuples_updated
Definition: pgstat.h:106
static void pgstat_truncate_restore_counters(PgStat_TableXactStatus *trans)
Definition: pgstat.c:2031
static int pgStatXactRollback
Definition: pgstat.c:221
PgStat_Counter tuples_inserted
Definition: pgstat.h:168
PgStat_Counter t_delta_dead_tuples
Definition: pgstat.h:112
struct PgStat_TableXactStatus * upper
Definition: pgstat.h:177
PgStat_Counter t_tuples_deleted
Definition: pgstat.h:107
PgStat_Counter tuples_deleted
Definition: pgstat.h:170
struct PgStat_SubXactStatus * prev
Definition: pgstat.c:214
PgStat_Counter t_changed_tuples
Definition: pgstat.h:113
#define Assert(condition)
Definition: c.h:738
void pgstat_clear_snapshot(void)
Definition: pgstat.c:5677
static PgStat_SubXactStatus * pgStatXactStack
Definition: pgstat.c:218
struct PgStat_TableXactStatus * trans
Definition: pgstat.h:158
static zic_t trans[TZ_MAX_LEAPS]
Definition: zic.c:396
PgStat_TableXactStatus * first
Definition: pgstat.c:215
PgStat_Counter t_tuples_inserted
Definition: pgstat.h:105
PgStat_TableStatus * parent
Definition: pgstat.h:178

◆ AtPrepare_PgStat()

void AtPrepare_PgStat ( void  )

Definition at line 2276 of file pgstat.c.

References Assert, PgStat_TableXactStatus::deleted_pre_trunc, TwoPhasePgStatRecord::deleted_pre_trunc, PgStat_SubXactStatus::first, PgStat_TableXactStatus::inserted_pre_trunc, TwoPhasePgStatRecord::inserted_pre_trunc, PgStat_TableXactStatus::nest_level, PgStat_SubXactStatus::nest_level, PgStat_TableXactStatus::next, PgStat_TableXactStatus::parent, pgStatXactStack, PgStat_SubXactStatus::prev, RegisterTwoPhaseRecord(), PgStat_TableStatus::t_id, TwoPhasePgStatRecord::t_id, PgStat_TableStatus::t_shared, TwoPhasePgStatRecord::t_shared, TwoPhasePgStatRecord::t_truncated, PgStat_TableStatus::trans, trans, PgStat_TableXactStatus::truncated, PgStat_TableXactStatus::tuples_deleted, TwoPhasePgStatRecord::tuples_deleted, PgStat_TableXactStatus::tuples_inserted, TwoPhasePgStatRecord::tuples_inserted, PgStat_TableXactStatus::tuples_updated, TwoPhasePgStatRecord::tuples_updated, TWOPHASE_RM_PGSTAT_ID, PgStat_TableXactStatus::updated_pre_trunc, TwoPhasePgStatRecord::updated_pre_trunc, and PgStat_TableXactStatus::upper.

Referenced by PrepareTransaction().

2277 {
2278  PgStat_SubXactStatus *xact_state;
2279 
2280  xact_state = pgStatXactStack;
2281  if (xact_state != NULL)
2282  {
2284 
2285  Assert(xact_state->nest_level == 1);
2286  Assert(xact_state->prev == NULL);
2287  for (trans = xact_state->first; trans != NULL; trans = trans->next)
2288  {
2289  PgStat_TableStatus *tabstat;
2290  TwoPhasePgStatRecord record;
2291 
2292  Assert(trans->nest_level == 1);
2293  Assert(trans->upper == NULL);
2294  tabstat = trans->parent;
2295  Assert(tabstat->trans == trans);
2296 
2297  record.tuples_inserted = trans->tuples_inserted;
2298  record.tuples_updated = trans->tuples_updated;
2299  record.tuples_deleted = trans->tuples_deleted;
2300  record.inserted_pre_trunc = trans->inserted_pre_trunc;
2301  record.updated_pre_trunc = trans->updated_pre_trunc;
2302  record.deleted_pre_trunc = trans->deleted_pre_trunc;
2303  record.t_id = tabstat->t_id;
2304  record.t_shared = tabstat->t_shared;
2305  record.t_truncated = trans->truncated;
2306 
2308  &record, sizeof(TwoPhasePgStatRecord));
2309  }
2310  }
2311 }
PgStat_Counter tuples_updated
Definition: pgstat.h:169
struct PgStat_TableXactStatus * next
Definition: pgstat.h:180
PgStat_Counter deleted_pre_trunc
Definition: pgstat.h:174
PgStat_Counter deleted_pre_trunc
Definition: pgstat.c:233
void RegisterTwoPhaseRecord(TwoPhaseRmgrId rmid, uint16 info, const void *data, uint32 len)
Definition: twophase.c:1187
PgStat_Counter tuples_inserted
Definition: pgstat.h:168
PgStat_Counter updated_pre_trunc
Definition: pgstat.c:232
PgStat_Counter inserted_pre_trunc
Definition: pgstat.c:231
struct PgStat_TableXactStatus * upper
Definition: pgstat.h:177
PgStat_Counter tuples_updated
Definition: pgstat.c:229
PgStat_Counter tuples_deleted
Definition: pgstat.h:170
struct PgStat_SubXactStatus * prev
Definition: pgstat.c:214
#define Assert(condition)
Definition: c.h:738
PgStat_Counter inserted_pre_trunc
Definition: pgstat.h:172
PgStat_Counter tuples_inserted
Definition: pgstat.c:228
static PgStat_SubXactStatus * pgStatXactStack
Definition: pgstat.c:218
struct PgStat_TableXactStatus * trans
Definition: pgstat.h:158
PgStat_Counter tuples_deleted
Definition: pgstat.c:230
#define TWOPHASE_RM_PGSTAT_ID
Definition: twophase_rmgr.h:26
PgStat_Counter updated_pre_trunc
Definition: pgstat.h:173
static zic_t trans[TZ_MAX_LEAPS]
Definition: zic.c:396
PgStat_TableXactStatus * first
Definition: pgstat.c:215
PgStat_TableStatus * parent
Definition: pgstat.h:178

◆ BackendStatusShmemSize()

Size BackendStatusShmemSize ( void  )

Definition at line 2648 of file pgstat.c.

References add_size(), mul_size(), NAMEDATALEN, NumBackendStatSlots, and pgstat_track_activity_query_size.

Referenced by CreateSharedMemoryAndSemaphores().

2649 {
2650  Size size;
2651 
2652  /* BackendStatusArray: */
2653  size = mul_size(sizeof(PgBackendStatus), NumBackendStatSlots);
2654  /* BackendAppnameBuffer: */
2655  size = add_size(size,
2657  /* BackendClientHostnameBuffer: */
2658  size = add_size(size,
2660  /* BackendActivityBuffer: */
2661  size = add_size(size,
2663 #ifdef USE_SSL
2664  /* BackendSslStatusBuffer: */
2665  size = add_size(size,
2667 #endif
2668  return size;
2669 }
#define NumBackendStatSlots
Definition: pgstat.c:117
#define NAMEDATALEN
int pgstat_track_activity_query_size
Definition: pgstat.c:127
Size mul_size(Size s1, Size s2)
Definition: shmem.c:515
Size add_size(Size s1, Size s2)
Definition: shmem.c:498
size_t Size
Definition: c.h:466

◆ CreateSharedBackendStatus()

void CreateSharedBackendStatus ( void  )

Definition at line 2676 of file pgstat.c.

References BackendActivityBuffer, BackendActivityBufferSize, BackendAppnameBuffer, BackendClientHostnameBuffer, i, MemSet, mul_size(), NAMEDATALEN, NumBackendStatSlots, pgstat_track_activity_query_size, ShmemInitStruct(), PgBackendStatus::st_activity_raw, PgBackendStatus::st_appname, PgBackendStatus::st_clienthostname, PgBackendStatus::st_gssstatus, and PgBackendStatus::st_sslstatus.

Referenced by CreateSharedMemoryAndSemaphores().

2677 {
2678  Size size;
2679  bool found;
2680  int i;
2681  char *buffer;
2682 
2683  /* Create or attach to the shared array */
2684  size = mul_size(sizeof(PgBackendStatus), NumBackendStatSlots);
2686  ShmemInitStruct("Backend Status Array", size, &found);
2687 
2688  if (!found)
2689  {
2690  /*
2691  * We're the first - initialize.
2692  */
2693  MemSet(BackendStatusArray, 0, size);
2694  }
2695 
2696  /* Create or attach to the shared appname buffer */
2698  BackendAppnameBuffer = (char *)
2699  ShmemInitStruct("Backend Application Name Buffer", size, &found);
2700 
2701  if (!found)
2702  {
2703  MemSet(BackendAppnameBuffer, 0, size);
2704 
2705  /* Initialize st_appname pointers. */
2706  buffer = BackendAppnameBuffer;
2707  for (i = 0; i < NumBackendStatSlots; i++)
2708  {
2709  BackendStatusArray[i].st_appname = buffer;
2710  buffer += NAMEDATALEN;
2711  }
2712  }
2713 
2714  /* Create or attach to the shared client hostname buffer */
2716  BackendClientHostnameBuffer = (char *)
2717  ShmemInitStruct("Backend Client Host Name Buffer", size, &found);
2718 
2719  if (!found)
2720  {
2722 
2723  /* Initialize st_clienthostname pointers. */
2724  buffer = BackendClientHostnameBuffer;
2725  for (i = 0; i < NumBackendStatSlots; i++)
2726  {
2728  buffer += NAMEDATALEN;
2729  }
2730  }
2731 
2732  /* Create or attach to the shared activity buffer */
2735  BackendActivityBuffer = (char *)
2736  ShmemInitStruct("Backend Activity Buffer",
2738  &found);
2739 
2740  if (!found)
2741  {
2743 
2744  /* Initialize st_activity pointers. */
2745  buffer = BackendActivityBuffer;
2746  for (i = 0; i < NumBackendStatSlots; i++)
2747  {
2750  }
2751  }
2752 
2753 #ifdef USE_SSL
2754  /* Create or attach to the shared SSL status buffer */
2756  BackendSslStatusBuffer = (PgBackendSSLStatus *)
2757  ShmemInitStruct("Backend SSL Status Buffer", size, &found);
2758 
2759  if (!found)
2760  {
2761  PgBackendSSLStatus *ptr;
2762 
2763  MemSet(BackendSslStatusBuffer, 0, size);
2764 
2765  /* Initialize st_sslstatus pointers. */
2766  ptr = BackendSslStatusBuffer;
2767  for (i = 0; i < NumBackendStatSlots; i++)
2768  {
2770  ptr++;
2771  }
2772  }
2773 #endif
2774 
2775 #ifdef ENABLE_GSS
2776  /* Create or attach to the shared GSSAPI status buffer */
2778  BackendGssStatusBuffer = (PgBackendGSSStatus *)
2779  ShmemInitStruct("Backend GSS Status Buffer", size, &found);
2780 
2781  if (!found)
2782  {
2783  PgBackendGSSStatus *ptr;
2784 
2785  MemSet(BackendGssStatusBuffer, 0, size);
2786 
2787  /* Initialize st_gssstatus pointers. */
2788  ptr = BackendGssStatusBuffer;
2789  for (i = 0; i < NumBackendStatSlots; i++)
2790  {
2792  ptr++;
2793  }
2794  }
2795 #endif
2796 }
static PgBackendStatus * BackendStatusArray
Definition: pgstat.c:2630
static char * BackendActivityBuffer
Definition: pgstat.c:2634
static Size BackendActivityBufferSize
Definition: pgstat.c:2635
#define MemSet(start, val, len)
Definition: c.h:971
#define NumBackendStatSlots
Definition: pgstat.c:117
char * st_clienthostname
Definition: pgstat.h:1051
#define NAMEDATALEN
static char * BackendAppnameBuffer
Definition: pgstat.c:2632
void * ShmemInitStruct(const char *name, Size size, bool *foundPtr)
Definition: shmem.c:392
char * st_activity_raw
Definition: pgstat.h:1074
int pgstat_track_activity_query_size
Definition: pgstat.c:127
char * st_appname
Definition: pgstat.h:1065
Size mul_size(Size s1, Size s2)
Definition: shmem.c:515
size_t Size
Definition: c.h:466
int i
PgBackendSSLStatus * st_sslstatus
Definition: pgstat.h:1055
PgBackendGSSStatus * st_gssstatus
Definition: pgstat.h:1059
static char * BackendClientHostnameBuffer
Definition: pgstat.c:2633

◆ find_funcstat_entry()

PgStat_BackendFunctionEntry* find_funcstat_entry ( Oid  func_id)

Definition at line 1670 of file pgstat.c.

References HASH_FIND, and hash_search().

Referenced by pg_stat_get_xact_function_calls(), pg_stat_get_xact_function_self_time(), and pg_stat_get_xact_function_total_time().

1671 {
1672  if (pgStatFunctions == NULL)
1673  return NULL;
1674 
1676  (void *) &func_id,
1677  HASH_FIND, NULL);
1678 }
void * hash_search(HTAB *hashp, const void *keyPtr, HASHACTION action, bool *foundPtr)
Definition: dynahash.c:907
static HTAB * pgStatFunctions
Definition: pgstat.c:196

◆ find_tabstat_entry()

PgStat_TableStatus* find_tabstat_entry ( Oid  rel_id)

Definition at line 1875 of file pgstat.c.

References HASH_FIND, hash_search(), and TabStatHashEntry::tsa_entry.

Referenced by pg_stat_get_xact_blocks_fetched(), pg_stat_get_xact_blocks_hit(), pg_stat_get_xact_numscans(), pg_stat_get_xact_tuples_deleted(), pg_stat_get_xact_tuples_fetched(), pg_stat_get_xact_tuples_hot_updated(), pg_stat_get_xact_tuples_inserted(), pg_stat_get_xact_tuples_returned(), and pg_stat_get_xact_tuples_updated().

1876 {
1877  TabStatHashEntry *hash_entry;
1878 
1879  /* If hashtable doesn't exist, there are no entries at all */
1880  if (!pgStatTabHash)
1881  return NULL;
1882 
1883  hash_entry = hash_search(pgStatTabHash, &rel_id, HASH_FIND, NULL);
1884  if (!hash_entry)
1885  return NULL;
1886 
1887  /* Note that this step could also return NULL, but that's correct */
1888  return hash_entry->tsa_entry;
1889 }
void * hash_search(HTAB *hashp, const void *keyPtr, HASHACTION action, bool *foundPtr)
Definition: dynahash.c:907
static HTAB * pgStatTabHash
Definition: pgstat.c:190
PgStat_TableStatus * tsa_entry
Definition: pgstat.c:184

◆ pgstat_bestart()

void pgstat_bestart ( void  )

Definition at line 2853 of file pgstat.c.

References application_name, Assert, B_BACKEND, B_BG_WORKER, B_WAL_SENDER, be_gssapi_get_auth(), be_gssapi_get_enc(), be_gssapi_get_princ(), be_tls_get_cipher(), be_tls_get_cipher_bits(), be_tls_get_compression(), be_tls_get_peer_issuer_name(), be_tls_get_peer_serial(), be_tls_get_peer_subject_name(), be_tls_get_version(), GetSessionUserId(), Port::gss, PgBackendGSSStatus::gss_auth, PgBackendGSSStatus::gss_enc, PgBackendGSSStatus::gss_princ, InvalidOid, MemSet, MyBackendType, MyBEEntry, MyDatabaseId, MyProcPid, MyProcPort, MyStartTimestamp, NAMEDATALEN, PGSTAT_BEGIN_WRITE_ACTIVITY, PGSTAT_END_WRITE_ACTIVITY, pgstat_report_appname(), pgstat_track_activity_query_size, PROGRESS_COMMAND_INVALID, Port::raddr, Port::remote_hostname, PgBackendSSLStatus::ssl_bits, PgBackendSSLStatus::ssl_cipher, PgBackendSSLStatus::ssl_client_dn, PgBackendSSLStatus::ssl_client_serial, PgBackendSSLStatus::ssl_compression, PgBackendSSLStatus::ssl_issuer_dn, PgBackendSSLStatus::ssl_version, PgBackendStatus::st_activity_raw, PgBackendStatus::st_activity_start_timestamp, PgBackendStatus::st_appname, PgBackendStatus::st_backendType, PgBackendStatus::st_changecount, PgBackendStatus::st_clientaddr, PgBackendStatus::st_clienthostname, PgBackendStatus::st_databaseid, PgBackendStatus::st_gss, PgBackendStatus::st_gssstatus, PgBackendStatus::st_proc_start_timestamp, PgBackendStatus::st_procpid, PgBackendStatus::st_progress_command, PgBackendStatus::st_progress_command_target, PgBackendStatus::st_ssl, PgBackendStatus::st_sslstatus, PgBackendStatus::st_state, PgBackendStatus::st_state_start_timestamp, PgBackendStatus::st_userid, PgBackendStatus::st_xact_start_timestamp, STATE_UNDEFINED, strlcpy(), and unvolatize.

Referenced by AuxiliaryProcessMain(), and InitPostgres().

2854 {
2855  volatile PgBackendStatus *vbeentry = MyBEEntry;
2856  PgBackendStatus lbeentry;
2857 #ifdef USE_SSL
2858  PgBackendSSLStatus lsslstatus;
2859 #endif
2860 #ifdef ENABLE_GSS
2861  PgBackendGSSStatus lgssstatus;
2862 #endif
2863 
2864  /* pgstats state must be initialized from pgstat_initialize() */
2865  Assert(vbeentry != NULL);
2866 
2867  /*
2868  * To minimize the time spent modifying the PgBackendStatus entry, and
2869  * avoid risk of errors inside the critical section, we first copy the
2870  * shared-memory struct to a local variable, then modify the data in the
2871  * local variable, then copy the local variable back to shared memory.
2872  * Only the last step has to be inside the critical section.
2873  *
2874  * Most of the data we copy from shared memory is just going to be
2875  * overwritten, but the struct's not so large that it's worth the
2876  * maintenance hassle to copy only the needful fields.
2877  */
2878  memcpy(&lbeentry,
2879  unvolatize(PgBackendStatus *, vbeentry),
2880  sizeof(PgBackendStatus));
2881 
2882  /* These structs can just start from zeroes each time, though */
2883 #ifdef USE_SSL
2884  memset(&lsslstatus, 0, sizeof(lsslstatus));
2885 #endif
2886 #ifdef ENABLE_GSS
2887  memset(&lgssstatus, 0, sizeof(lgssstatus));
2888 #endif
2889 
2890  /*
2891  * Now fill in all the fields of lbeentry, except for strings that are
2892  * out-of-line data. Those have to be handled separately, below.
2893  */
2894  lbeentry.st_procpid = MyProcPid;
2895  lbeentry.st_backendType = MyBackendType;
2897  lbeentry.st_activity_start_timestamp = 0;
2898  lbeentry.st_state_start_timestamp = 0;
2899  lbeentry.st_xact_start_timestamp = 0;
2900  lbeentry.st_databaseid = MyDatabaseId;
2901 
2902  /* We have userid for client-backends, wal-sender and bgworker processes */
2903  if (lbeentry.st_backendType == B_BACKEND
2904  || lbeentry.st_backendType == B_WAL_SENDER
2905  || lbeentry.st_backendType == B_BG_WORKER)
2906  lbeentry.st_userid = GetSessionUserId();
2907  else
2908  lbeentry.st_userid = InvalidOid;
2909 
2910  /*
2911  * We may not have a MyProcPort (eg, if this is the autovacuum process).
2912  * If so, use all-zeroes client address, which is dealt with specially in
2913  * pg_stat_get_backend_client_addr and pg_stat_get_backend_client_port.
2914  */
2915  if (MyProcPort)
2916  memcpy(&lbeentry.st_clientaddr, &MyProcPort->raddr,
2917  sizeof(lbeentry.st_clientaddr));
2918  else
2919  MemSet(&lbeentry.st_clientaddr, 0, sizeof(lbeentry.st_clientaddr));
2920 
2921 #ifdef USE_SSL
2922  if (MyProcPort && MyProcPort->ssl != NULL)
2923  {
2924  lbeentry.st_ssl = true;
2932  }
2933  else
2934  {
2935  lbeentry.st_ssl = false;
2936  }
2937 #else
2938  lbeentry.st_ssl = false;
2939 #endif
2940 
2941 #ifdef ENABLE_GSS
2942  if (MyProcPort && MyProcPort->gss != NULL)
2943  {
2944  lbeentry.st_gss = true;
2945  lgssstatus.gss_auth = be_gssapi_get_auth(MyProcPort);
2946  lgssstatus.gss_enc = be_gssapi_get_enc(MyProcPort);
2947 
2948  if (lgssstatus.gss_auth)
2950  }
2951  else
2952  {
2953  lbeentry.st_gss = false;
2954  }
2955 #else
2956  lbeentry.st_gss = false;
2957 #endif
2958 
2959  lbeentry.st_state = STATE_UNDEFINED;
2962 
2963  /*
2964  * we don't zero st_progress_param here to save cycles; nobody should
2965  * examine it until st_progress_command has been set to something other
2966  * than PROGRESS_COMMAND_INVALID
2967  */
2968 
2969  /*
2970  * We're ready to enter the critical section that fills the shared-memory
2971  * status entry. We follow the protocol of bumping st_changecount before
2972  * and after; and make sure it's even afterwards. We use a volatile
2973  * pointer here to ensure the compiler doesn't try to get cute.
2974  */
2975  PGSTAT_BEGIN_WRITE_ACTIVITY(vbeentry);
2976 
2977  /* make sure we'll memcpy the same st_changecount back */
2978  lbeentry.st_changecount = vbeentry->st_changecount;
2979 
2980  memcpy(unvolatize(PgBackendStatus *, vbeentry),
2981  &lbeentry,
2982  sizeof(PgBackendStatus));
2983 
2984  /*
2985  * We can write the out-of-line strings and structs using the pointers
2986  * that are in lbeentry; this saves some de-volatilizing messiness.
2987  */
2988  lbeentry.st_appname[0] = '\0';
2991  NAMEDATALEN);
2992  else
2993  lbeentry.st_clienthostname[0] = '\0';
2994  lbeentry.st_activity_raw[0] = '\0';
2995  /* Also make sure the last byte in each string area is always 0 */
2996  lbeentry.st_appname[NAMEDATALEN - 1] = '\0';
2997  lbeentry.st_clienthostname[NAMEDATALEN - 1] = '\0';
2999 
3000 #ifdef USE_SSL
3001  memcpy(lbeentry.st_sslstatus, &lsslstatus, sizeof(PgBackendSSLStatus));
3002 #endif
3003 #ifdef ENABLE_GSS
3004  memcpy(lbeentry.st_gssstatus, &lgssstatus, sizeof(PgBackendGSSStatus));
3005 #endif
3006 
3007  PGSTAT_END_WRITE_ACTIVITY(vbeentry);
3008 
3009  /* Update app name to current GUC setting */
3010  if (application_name)
3012 }
char ssl_issuer_dn[NAMEDATALEN]
Definition: pgstat.h:982
char gss_princ[NAMEDATALEN]
Definition: pgstat.h:996
bool ssl_compression
Definition: pgstat.h:971
char ssl_cipher[NAMEDATALEN]
Definition: pgstat.h:973
Oid st_progress_command_target
Definition: pgstat.h:1086
int MyProcPid
Definition: globals.c:40
struct Port * MyProcPort
Definition: globals.c:43
const char * be_gssapi_get_princ(Port *port)
BackendType MyBackendType
Definition: miscinit.c:60
TimestampTz st_activity_start_timestamp
Definition: pgstat.h:1044
char ssl_client_dn[NAMEDATALEN]
Definition: pgstat.h:974
char ssl_version[NAMEDATALEN]
Definition: pgstat.h:972
SockAddr st_clientaddr
Definition: pgstat.h:1050
#define MemSet(start, val, len)
Definition: c.h:971
ProgressCommandType st_progress_command
Definition: pgstat.h:1085
char ssl_client_serial[NAMEDATALEN]
Definition: pgstat.h:980
BackendState st_state
Definition: pgstat.h:1062
char * st_clienthostname
Definition: pgstat.h:1051
Oid GetSessionUserId(void)
Definition: miscinit.c:473
Oid st_databaseid
Definition: pgstat.h:1048
#define NAMEDATALEN
char * remote_hostname
Definition: libpq-be.h:128
SockAddr raddr
Definition: libpq-be.h:126
bool be_tls_get_compression(Port *port)
static PgBackendStatus * MyBEEntry
Definition: pgstat.c:2631
#define PGSTAT_END_WRITE_ACTIVITY(beentry)
Definition: pgstat.h:1126
char * st_activity_raw
Definition: pgstat.h:1074
int pgstat_track_activity_query_size
Definition: pgstat.c:127
TimestampTz st_state_start_timestamp
Definition: pgstat.h:1045
char * st_appname
Definition: pgstat.h:1065
bool be_gssapi_get_enc(Port *port)
TimestampTz MyStartTimestamp
Definition: globals.c:42
int be_tls_get_cipher_bits(Port *port)
Oid MyDatabaseId
Definition: globals.c:85
BackendType st_backendType
Definition: pgstat.h:1039
void pgstat_report_appname(const char *appname)
Definition: pgstat.c:3235
#define InvalidOid
Definition: postgres_ext.h:36
size_t strlcpy(char *dst, const char *src, size_t siz)
Definition: strlcpy.c:45
#define Assert(condition)
Definition: c.h:738
const char * be_tls_get_version(Port *port)
void be_tls_get_peer_issuer_name(Port *port, char *ptr, size_t len)
char * application_name
Definition: guc.c:566
void be_tls_get_peer_subject_name(Port *port, char *ptr, size_t len)
void * gss
Definition: libpq-be.h:184
#define unvolatize(underlying_type, expr)
Definition: c.h:1208
void be_tls_get_peer_serial(Port *port, char *ptr, size_t len)
TimestampTz st_xact_start_timestamp
Definition: pgstat.h:1043
int st_changecount
Definition: pgstat.h:1033
const char * be_tls_get_cipher(Port *port)
TimestampTz st_proc_start_timestamp
Definition: pgstat.h:1042
PgBackendSSLStatus * st_sslstatus
Definition: pgstat.h:1055
#define PGSTAT_BEGIN_WRITE_ACTIVITY(beentry)
Definition: pgstat.h:1119
PgBackendGSSStatus * st_gssstatus
Definition: pgstat.h:1059
bool be_gssapi_get_auth(Port *port)

◆ pgstat_clear_snapshot()

void pgstat_clear_snapshot ( void  )

Definition at line 5677 of file pgstat.c.

References localNumBackends, and MemoryContextDelete().

Referenced by AtEOXact_PgStat(), autovac_refresh_stats(), AutoVacLauncherMain(), pg_stat_clear_snapshot(), and PostPrepare_PgStat().

5678 {
5679  /* Release memory, if any was allocated */
5680  if (pgStatLocalContext)
5682 
5683  /* Reset variables */
5684  pgStatLocalContext = NULL;
5685  pgStatDBHash = NULL;
5686  localBackendStatusTable = NULL;
5687  localNumBackends = 0;
5688 }
void MemoryContextDelete(MemoryContext context)
Definition: mcxt.c:211
static LocalPgBackendStatus * localBackendStatusTable
Definition: pgstat.c:246
static HTAB * pgStatDBHash
Definition: pgstat.c:243
static int localNumBackends
Definition: pgstat.c:249
static MemoryContext pgStatLocalContext
Definition: pgstat.c:242

◆ pgstat_clip_activity()

char* pgstat_clip_activity ( const char *  raw_activity)

Definition at line 6440 of file pgstat.c.

References cliplen(), pg_mbcliplen(), pgstat_track_activity_query_size, and pnstrdup().

Referenced by pg_stat_get_activity(), pg_stat_get_backend_activity(), and pgstat_get_backend_current_activity().

6441 {
6442  char *activity;
6443  int rawlen;
6444  int cliplen;
6445 
6446  /*
6447  * Some callers, like pgstat_get_backend_current_activity(), do not
6448  * guarantee that the buffer isn't concurrently modified. We try to take
6449  * care that the buffer is always terminated by a NUL byte regardless, but
6450  * let's still be paranoid about the string's length. In those cases the
6451  * underlying buffer is guaranteed to be pgstat_track_activity_query_size
6452  * large.
6453  */
6454  activity = pnstrdup(raw_activity, pgstat_track_activity_query_size - 1);
6455 
6456  /* now double-guaranteed to be NUL terminated */
6457  rawlen = strlen(activity);
6458 
6459  /*
6460  * All supported server-encodings make it possible to determine the length
6461  * of a multi-byte character from its first byte (this is not the case for
6462  * client encodings, see GB18030). As st_activity is always stored using
6463  * server encoding, this allows us to perform multi-byte aware truncation,
6464  * even if the string earlier was truncated in the middle of a multi-byte
6465  * character.
6466  */
6467  cliplen = pg_mbcliplen(activity, rawlen,
6469 
6470  activity[cliplen] = '\0';
6471 
6472  return activity;
6473 }
char * pnstrdup(const char *in, Size len)
Definition: mcxt.c:1197
int pg_mbcliplen(const char *mbstr, int len, int limit)
Definition: mbutils.c:967
int pgstat_track_activity_query_size
Definition: pgstat.c:127
static int cliplen(const char *str, int len, int limit)
Definition: mbutils.c:1034

◆ pgstat_count_heap_delete()

void pgstat_count_heap_delete ( Relation  rel)

Definition at line 1990 of file pgstat.c.

References add_tabstat_xact_level(), GetCurrentTransactionNestLevel(), PgStat_TableXactStatus::nest_level, RelationData::pgstat_info, PgStat_TableStatus::trans, and PgStat_TableXactStatus::tuples_deleted.

Referenced by heap_abort_speculative(), and heap_delete().

1991 {
1992  PgStat_TableStatus *pgstat_info = rel->pgstat_info;
1993 
1994  if (pgstat_info != NULL)
1995  {
1996  /* We have to log the effect at the proper transactional level */
1997  int nest_level = GetCurrentTransactionNestLevel();
1998 
1999  if (pgstat_info->trans == NULL ||
2000  pgstat_info->trans->nest_level != nest_level)
2001  add_tabstat_xact_level(pgstat_info, nest_level);
2002 
2003  pgstat_info->trans->tuples_deleted++;
2004  }
2005 }
PgStat_Counter tuples_deleted
Definition: pgstat.h:170
int GetCurrentTransactionNestLevel(void)
Definition: xact.c:841
struct PgStat_TableStatus * pgstat_info
Definition: rel.h:216
static void add_tabstat_xact_level(PgStat_TableStatus *pgstat_info, int nest_level)
Definition: pgstat.c:1917
struct PgStat_TableXactStatus * trans
Definition: pgstat.h:158

◆ pgstat_count_heap_insert()

void pgstat_count_heap_insert ( Relation  rel,
PgStat_Counter  n 
)

Definition at line 1944 of file pgstat.c.

References add_tabstat_xact_level(), GetCurrentTransactionNestLevel(), PgStat_TableXactStatus::nest_level, RelationData::pgstat_info, PgStat_TableStatus::trans, and PgStat_TableXactStatus::tuples_inserted.

Referenced by ExecRefreshMatView(), heap_insert(), and heap_multi_insert().

1945 {
1946  PgStat_TableStatus *pgstat_info = rel->pgstat_info;
1947 
1948  if (pgstat_info != NULL)
1949  {
1950  /* We have to log the effect at the proper transactional level */
1951  int nest_level = GetCurrentTransactionNestLevel();
1952 
1953  if (pgstat_info->trans == NULL ||
1954  pgstat_info->trans->nest_level != nest_level)
1955  add_tabstat_xact_level(pgstat_info, nest_level);
1956 
1957  pgstat_info->trans->tuples_inserted += n;
1958  }
1959 }
PgStat_Counter tuples_inserted
Definition: pgstat.h:168
int GetCurrentTransactionNestLevel(void)
Definition: xact.c:841
struct PgStat_TableStatus * pgstat_info
Definition: rel.h:216
static void add_tabstat_xact_level(PgStat_TableStatus *pgstat_info, int nest_level)
Definition: pgstat.c:1917
struct PgStat_TableXactStatus * trans
Definition: pgstat.h:158

◆ pgstat_count_heap_update()

void pgstat_count_heap_update ( Relation  rel,
bool  hot 
)

Definition at line 1965 of file pgstat.c.

References add_tabstat_xact_level(), GetCurrentTransactionNestLevel(), PgStat_TableXactStatus::nest_level, RelationData::pgstat_info, PgStat_TableStatus::t_counts, PgStat_TableCounts::t_tuples_hot_updated, PgStat_TableStatus::trans, and PgStat_TableXactStatus::tuples_updated.

Referenced by heap_update().

1966 {
1967  PgStat_TableStatus *pgstat_info = rel->pgstat_info;
1968 
1969  if (pgstat_info != NULL)
1970  {
1971  /* We have to log the effect at the proper transactional level */
1972  int nest_level = GetCurrentTransactionNestLevel();
1973 
1974  if (pgstat_info->trans == NULL ||
1975  pgstat_info->trans->nest_level != nest_level)
1976  add_tabstat_xact_level(pgstat_info, nest_level);
1977 
1978  pgstat_info->trans->tuples_updated++;
1979 
1980  /* t_tuples_hot_updated is nontransactional, so just advance it */
1981  if (hot)
1982  pgstat_info->t_counts.t_tuples_hot_updated++;
1983  }
1984 }
PgStat_Counter tuples_updated
Definition: pgstat.h:169
PgStat_Counter t_tuples_hot_updated
Definition: pgstat.h:108
PgStat_TableCounts t_counts
Definition: pgstat.h:159
int GetCurrentTransactionNestLevel(void)
Definition: xact.c:841
struct PgStat_TableStatus * pgstat_info
Definition: rel.h:216
static void add_tabstat_xact_level(PgStat_TableStatus *pgstat_info, int nest_level)
Definition: pgstat.c:1917
struct PgStat_TableXactStatus * trans
Definition: pgstat.h:158

◆ pgstat_count_truncate()

void pgstat_count_truncate ( Relation  rel)

Definition at line 2045 of file pgstat.c.

References add_tabstat_xact_level(), GetCurrentTransactionNestLevel(), PgStat_TableXactStatus::nest_level, RelationData::pgstat_info, pgstat_truncate_save_counters(), PgStat_TableStatus::trans, PgStat_TableXactStatus::tuples_deleted, PgStat_TableXactStatus::tuples_inserted, and PgStat_TableXactStatus::tuples_updated.

Referenced by ExecRefreshMatView(), and ExecuteTruncateGuts().

2046 {
2047  PgStat_TableStatus *pgstat_info = rel->pgstat_info;
2048 
2049  if (pgstat_info != NULL)
2050  {
2051  /* We have to log the effect at the proper transactional level */
2052  int nest_level = GetCurrentTransactionNestLevel();
2053 
2054  if (pgstat_info->trans == NULL ||
2055  pgstat_info->trans->nest_level != nest_level)
2056  add_tabstat_xact_level(pgstat_info, nest_level);
2057 
2058  pgstat_truncate_save_counters(pgstat_info->trans);
2059  pgstat_info->trans->tuples_inserted = 0;
2060  pgstat_info->trans->tuples_updated = 0;
2061  pgstat_info->trans->tuples_deleted = 0;
2062  }
2063 }
PgStat_Counter tuples_updated
Definition: pgstat.h:169
PgStat_Counter tuples_inserted
Definition: pgstat.h:168
PgStat_Counter tuples_deleted
Definition: pgstat.h:170
int GetCurrentTransactionNestLevel(void)
Definition: xact.c:841
struct PgStat_TableStatus * pgstat_info
Definition: rel.h:216
static void add_tabstat_xact_level(PgStat_TableStatus *pgstat_info, int nest_level)
Definition: pgstat.c:1917
struct PgStat_TableXactStatus * trans
Definition: pgstat.h:158
static void pgstat_truncate_save_counters(PgStat_TableXactStatus *trans)
Definition: pgstat.c:2016

◆ pgstat_drop_database()

void pgstat_drop_database ( Oid  databaseid)

Definition at line 1251 of file pgstat.c.

References PgStat_MsgTabpurge::m_databaseid, PgStat_MsgDropdb::m_databaseid, PgStat_MsgTabpurge::m_hdr, PgStat_MsgDropdb::m_hdr, PgStat_MsgTabpurge::m_nentries, PgStat_MsgTabpurge::m_tableid, MyDatabaseId, offsetof, PGINVALID_SOCKET, PGSTAT_MTYPE_DROPDB, PGSTAT_MTYPE_TABPURGE, pgstat_send(), pgstat_setheader(), and pgStatSock.

Referenced by dropdb(), and pgstat_vacuum_stat().

1252 {
1253  PgStat_MsgDropdb msg;
1254 
1256  return;
1257 
1259  msg.m_databaseid = databaseid;
1260  pgstat_send(&msg, sizeof(msg));
1261 }
static void pgstat_send(void *msg, int len)
Definition: pgstat.c:4252
NON_EXEC_STATIC pgsocket pgStatSock
Definition: pgstat.c:148
Oid m_databaseid
Definition: pgstat.h:307
PgStat_MsgHdr m_hdr
Definition: pgstat.h:306
#define PGINVALID_SOCKET
Definition: port.h:33
static void pgstat_setheader(PgStat_MsgHdr *hdr, StatMsgType mtype)
Definition: pgstat.c:4239

◆ pgstat_end_function_usage()

void pgstat_end_function_usage ( PgStat_FunctionCallUsage fcu,
bool  finalize 
)

Definition at line 1690 of file pgstat.c.

References PgStat_FunctionCounts::f_numcalls, PgStat_FunctionCounts::f_self_time, PgStat_FunctionCallUsage::f_start, PgStat_FunctionCounts::f_total_time, PgStat_FunctionCallUsage::fs, have_function_stats, INSTR_TIME_ADD, INSTR_TIME_SET_CURRENT, INSTR_TIME_SUBTRACT, PgStat_FunctionCallUsage::save_f_total_time, PgStat_FunctionCallUsage::save_total, and total_func_time.

Referenced by call_pltcl_start_proc(), EventTriggerInvoke(), ExecCallTriggerFunc(), ExecEvalFuncExprFusage(), ExecEvalFuncExprStrictFusage(), ExecMakeFunctionResultSet(), ExecMakeTableFunctionResult(), ExecuteCallStmt(), and fmgr_security_definer().

1691 {
1692  PgStat_FunctionCounts *fs = fcu->fs;
1693  instr_time f_total;
1694  instr_time f_others;
1695  instr_time f_self;
1696 
1697  /* stats not wanted? */
1698  if (fs == NULL)
1699  return;
1700 
1701  /* total elapsed time in this function call */
1702  INSTR_TIME_SET_CURRENT(f_total);
1703  INSTR_TIME_SUBTRACT(f_total, fcu->f_start);
1704 
1705  /* self usage: elapsed minus anything already charged to other calls */
1706  f_others = total_func_time;
1707  INSTR_TIME_SUBTRACT(f_others, fcu->save_total);
1708  f_self = f_total;
1709  INSTR_TIME_SUBTRACT(f_self, f_others);
1710 
1711  /* update backend-wide total time */
1713 
1714  /*
1715  * Compute the new f_total_time as the total elapsed time added to the
1716  * pre-call value of f_total_time. This is necessary to avoid
1717  * double-counting any time taken by recursive calls of myself. (We do
1718  * not need any similar kluge for self time, since that already excludes
1719  * any recursive calls.)
1720  */
1721  INSTR_TIME_ADD(f_total, fcu->save_f_total_time);
1722 
1723  /* update counters in function stats table */
1724  if (finalize)
1725  fs->f_numcalls++;
1726  fs->f_total_time = f_total;
1727  INSTR_TIME_ADD(fs->f_self_time, f_self);
1728 
1729  /* indicate that we have something to send */
1730  have_function_stats = true;
1731 }
instr_time f_self_time
Definition: pgstat.h:464
instr_time save_total
Definition: pgstat.h:1190
struct timeval instr_time
Definition: instr_time.h:150
instr_time f_total_time
Definition: pgstat.h:463
PgStat_FunctionCounts * fs
Definition: pgstat.h:1186
PgStat_Counter f_numcalls
Definition: pgstat.h:462
#define INSTR_TIME_SUBTRACT(x, y)
Definition: instr_time.h:170
#define INSTR_TIME_ADD(x, y)
Definition: instr_time.h:158
static instr_time total_func_time
Definition: pgstat.c:271
static bool have_function_stats
Definition: pgstat.c:202
#define INSTR_TIME_SET_CURRENT(t)
Definition: instr_time.h:156
instr_time save_f_total_time
Definition: pgstat.h:1188

◆ pgstat_fetch_global()

◆ pgstat_fetch_stat_archiver()

PgStat_ArchiverStats* pgstat_fetch_stat_archiver ( void  )

Definition at line 2600 of file pgstat.c.

References archiverStats, and backend_read_statsfile().

Referenced by pg_stat_get_archiver().

2601 {
2603 
2604  return &archiverStats;
2605 }
static void backend_read_statsfile(void)
Definition: pgstat.c:5523
static PgStat_ArchiverStats archiverStats
Definition: pgstat.c:256

◆ pgstat_fetch_stat_beentry()

◆ pgstat_fetch_stat_dbentry()

PgStat_StatDBEntry* pgstat_fetch_stat_dbentry ( Oid  dbid)

Definition at line 2428 of file pgstat.c.

References backend_read_statsfile(), HASH_FIND, and hash_search().

Referenced by do_autovacuum(), do_start_worker(), pg_stat_get_db_blk_read_time(), pg_stat_get_db_blk_write_time(), pg_stat_get_db_blocks_fetched(), pg_stat_get_db_blocks_hit(), pg_stat_get_db_checksum_failures(), pg_stat_get_db_checksum_last_failure(), pg_stat_get_db_conflict_all(), pg_stat_get_db_conflict_bufferpin(), pg_stat_get_db_conflict_lock(), pg_stat_get_db_conflict_snapshot(), pg_stat_get_db_conflict_startup_deadlock(), pg_stat_get_db_conflict_tablespace(), pg_stat_get_db_deadlocks(), pg_stat_get_db_stat_reset_time(), pg_stat_get_db_temp_bytes(), pg_stat_get_db_temp_files(), pg_stat_get_db_tuples_deleted(), pg_stat_get_db_tuples_fetched(), pg_stat_get_db_tuples_inserted(), pg_stat_get_db_tuples_returned(), pg_stat_get_db_tuples_updated(), pg_stat_get_db_xact_commit(), pg_stat_get_db_xact_rollback(), pgstat_fetch_stat_funcentry(), rebuild_database_list(), and table_recheck_autovac().

2429 {
2430  /*
2431  * If not done for this transaction, read the statistics collector stats
2432  * file into some hash tables.
2433  */
2435 
2436  /*
2437  * Lookup the requested database; return NULL if not found
2438  */
2440  (void *) &dbid,
2441  HASH_FIND, NULL);
2442 }
void * hash_search(HTAB *hashp, const void *keyPtr, HASHACTION action, bool *foundPtr)
Definition: dynahash.c:907
static void backend_read_statsfile(void)
Definition: pgstat.c:5523
static HTAB * pgStatDBHash
Definition: pgstat.c:243

◆ pgstat_fetch_stat_funcentry()

PgStat_StatFuncEntry* pgstat_fetch_stat_funcentry ( Oid  funcid)

Definition at line 2511 of file pgstat.c.

References backend_read_statsfile(), PgStat_StatDBEntry::functions, HASH_FIND, hash_search(), MyDatabaseId, and pgstat_fetch_stat_dbentry().

Referenced by pg_stat_get_function_calls(), pg_stat_get_function_self_time(), and pg_stat_get_function_total_time().

2512 {
2513  PgStat_StatDBEntry *dbentry;
2514  PgStat_StatFuncEntry *funcentry = NULL;
2515 
2516  /* load the stats file if needed */
2518 
2519  /* Lookup our database, then find the requested function. */
2521  if (dbentry != NULL && dbentry->functions != NULL)
2522  {
2523  funcentry = (PgStat_StatFuncEntry *) hash_search(dbentry->functions,
2524  (void *) &func_id,
2525  HASH_FIND, NULL);
2526  }
2527 
2528  return funcentry;
2529 }
HTAB * functions
Definition: pgstat.h:625
PgStat_StatDBEntry * pgstat_fetch_stat_dbentry(Oid dbid)
Definition: pgstat.c:2428
void * hash_search(HTAB *hashp, const void *keyPtr, HASHACTION action, bool *foundPtr)
Definition: dynahash.c:907
static void backend_read_statsfile(void)
Definition: pgstat.c:5523
Oid MyDatabaseId
Definition: globals.c:85

◆ pgstat_fetch_stat_local_beentry()

LocalPgBackendStatus* pgstat_fetch_stat_local_beentry ( int  beid)

Definition at line 2565 of file pgstat.c.

References localNumBackends, and pgstat_read_current_status().

Referenced by pg_stat_get_activity(), and pg_stat_get_progress_info().

2566 {
2568 
2569  if (beid < 1 || beid > localNumBackends)
2570  return NULL;
2571 
2572  return &localBackendStatusTable[beid - 1];
2573 }
static void pgstat_read_current_status(void)
Definition: pgstat.c:3291
static LocalPgBackendStatus * localBackendStatusTable
Definition: pgstat.c:246
static int localNumBackends
Definition: pgstat.c:249

◆ pgstat_fetch_stat_numbackends()

int pgstat_fetch_stat_numbackends ( void  )

Definition at line 2584 of file pgstat.c.

References localNumBackends, and pgstat_read_current_status().

Referenced by pg_stat_get_activity(), pg_stat_get_backend_idset(), pg_stat_get_db_numbackends(), and pg_stat_get_progress_info().

2585 {
2587 
2588  return localNumBackends;
2589 }
static void pgstat_read_current_status(void)
Definition: pgstat.c:3291
static int localNumBackends
Definition: pgstat.c:249

◆ pgstat_fetch_stat_tabentry()

PgStat_StatTabEntry* pgstat_fetch_stat_tabentry ( Oid  relid)

Definition at line 2455 of file pgstat.c.

References backend_read_statsfile(), HASH_FIND, hash_search(), InvalidOid, MyDatabaseId, and PgStat_StatDBEntry::tables.

Referenced by index_concurrently_swap(), pg_stat_get_analyze_count(), pg_stat_get_autoanalyze_count(), pg_stat_get_autovacuum_count(), pg_stat_get_blocks_fetched(), pg_stat_get_blocks_hit(), pg_stat_get_dead_tuples(), pg_stat_get_ins_since_vacuum(), pg_stat_get_last_analyze_time(), pg_stat_get_last_autoanalyze_time(), pg_stat_get_last_autovacuum_time(), pg_stat_get_last_vacuum_time(), pg_stat_get_live_tuples(), pg_stat_get_mod_since_analyze(), pg_stat_get_numscans(), pg_stat_get_tuples_deleted(), pg_stat_get_tuples_fetched(), pg_stat_get_tuples_hot_updated(), pg_stat_get_tuples_inserted(), pg_stat_get_tuples_returned(), pg_stat_get_tuples_updated(), and pg_stat_get_vacuum_count().

2456 {
2457  Oid dbid;
2458  PgStat_StatDBEntry *dbentry;
2459  PgStat_StatTabEntry *tabentry;
2460 
2461  /*
2462  * If not done for this transaction, read the statistics collector stats
2463  * file into some hash tables.
2464  */
2466 
2467  /*
2468  * Lookup our database, then look in its table hash table.
2469  */
2470  dbid = MyDatabaseId;
2472  (void *) &dbid,
2473  HASH_FIND, NULL);
2474  if (dbentry != NULL && dbentry->tables != NULL)
2475  {
2476  tabentry = (PgStat_StatTabEntry *) hash_search(dbentry->tables,
2477  (void *) &relid,
2478  HASH_FIND, NULL);
2479  if (tabentry)
2480  return tabentry;
2481  }
2482 
2483  /*
2484  * If we didn't find it, maybe it's a shared table.
2485  */
2486  dbid = InvalidOid;
2488  (void *) &dbid,
2489  HASH_FIND, NULL);
2490  if (dbentry != NULL && dbentry->tables != NULL)
2491  {
2492  tabentry = (PgStat_StatTabEntry *) hash_search(dbentry->tables,
2493  (void *) &relid,
2494  HASH_FIND, NULL);
2495  if (tabentry)
2496  return tabentry;
2497  }
2498 
2499  return NULL;
2500 }
void * hash_search(HTAB *hashp, const void *keyPtr, HASHACTION action, bool *foundPtr)
Definition: dynahash.c:907
unsigned int Oid
Definition: postgres_ext.h:31
static void backend_read_statsfile(void)
Definition: pgstat.c:5523
Oid MyDatabaseId
Definition: globals.c:85
#define InvalidOid
Definition: postgres_ext.h:36
static HTAB * pgStatDBHash
Definition: pgstat.c:243

◆ pgstat_get_backend_current_activity()

const char* pgstat_get_backend_current_activity ( int  pid,
bool  checkUser 
)

Definition at line 4090 of file pgstat.c.

References BackendStatusArray, CHECK_FOR_INTERRUPTS, GetUserId(), i, MaxBackends, pgstat_begin_read_activity, pgstat_clip_activity(), pgstat_end_read_activity, pgstat_read_activity_complete, PgBackendStatus::st_activity_raw, PgBackendStatus::st_procpid, PgBackendStatus::st_userid, and superuser().

Referenced by DeadLockReport().

4091 {
4092  PgBackendStatus *beentry;
4093  int i;
4094 
4095  beentry = BackendStatusArray;
4096  for (i = 1; i <= MaxBackends; i++)
4097  {
4098  /*
4099  * Although we expect the target backend's entry to be stable, that
4100  * doesn't imply that anyone else's is. To avoid identifying the
4101  * wrong backend, while we check for a match to the desired PID we
4102  * must follow the protocol of retrying if st_changecount changes
4103  * while we examine the entry, or if it's odd. (This might be
4104  * unnecessary, since fetching or storing an int is almost certainly
4105  * atomic, but let's play it safe.) We use a volatile pointer here to
4106  * ensure the compiler doesn't try to get cute.
4107  */
4108  volatile PgBackendStatus *vbeentry = beentry;
4109  bool found;
4110 
4111  for (;;)
4112  {
4113  int before_changecount;
4114  int after_changecount;
4115 
4116  pgstat_begin_read_activity(vbeentry, before_changecount);
4117 
4118  found = (vbeentry->st_procpid == pid);
4119 
4120  pgstat_end_read_activity(vbeentry, after_changecount);
4121 
4122  if (pgstat_read_activity_complete(before_changecount,
4123  after_changecount))
4124  break;
4125 
4126  /* Make sure we can break out of loop if stuck... */
4128  }
4129 
4130  if (found)
4131  {
4132  /* Now it is safe to use the non-volatile pointer */
4133  if (checkUser && !superuser() && beentry->st_userid != GetUserId())
4134  return "<insufficient privilege>";
4135  else if (*(beentry->st_activity_raw) == '\0')
4136  return "<command string not enabled>";
4137  else
4138  {
4139  /* this'll leak a bit of memory, but that seems acceptable */
4140  return pgstat_clip_activity(beentry->st_activity_raw);
4141  }
4142  }
4143 
4144  beentry++;
4145  }
4146 
4147  /* If we get here, caller is in error ... */
4148  return "<backend information not available>";
4149 }
static PgBackendStatus * BackendStatusArray
Definition: pgstat.c:2630
Oid GetUserId(void)
Definition: miscinit.c:439
bool superuser(void)
Definition: superuser.c:46
int MaxBackends
Definition: globals.c:135
char * st_activity_raw
Definition: pgstat.h:1074
#define pgstat_end_read_activity(beentry, after_changecount)
Definition: pgstat.h:1140
#define pgstat_begin_read_activity(beentry, before_changecount)
Definition: pgstat.h:1134
char * pgstat_clip_activity(const char *raw_activity)
Definition: pgstat.c:6440
int i
#define CHECK_FOR_INTERRUPTS()
Definition: miscadmin.h:99
#define pgstat_read_activity_complete(before_changecount, after_changecount)
Definition: pgstat.h:1146

◆ pgstat_get_crashed_backend_activity()

const char* pgstat_get_crashed_backend_activity ( int  pid,
char *  buffer,
int  buflen 
)

Definition at line 4168 of file pgstat.c.

References ascii_safe_strlcpy(), BackendActivityBuffer, BackendActivityBufferSize, BackendStatusArray, i, MaxBackends, Min, pgstat_track_activity_query_size, PgBackendStatus::st_activity_raw, and PgBackendStatus::st_procpid.

Referenced by LogChildExit().

4169 {
4170  volatile PgBackendStatus *beentry;
4171  int i;
4172 
4173  beentry = BackendStatusArray;
4174 
4175  /*
4176  * We probably shouldn't get here before shared memory has been set up,
4177  * but be safe.
4178  */
4179  if (beentry == NULL || BackendActivityBuffer == NULL)
4180  return NULL;
4181 
4182  for (i = 1; i <= MaxBackends; i++)
4183  {
4184  if (beentry->st_procpid == pid)
4185  {
4186  /* Read pointer just once, so it can't change after validation */
4187  const char *activity = beentry->st_activity_raw;
4188  const char *activity_last;
4189 
4190  /*
4191  * We mustn't access activity string before we verify that it
4192  * falls within the BackendActivityBuffer. To make sure that the
4193  * entire string including its ending is contained within the
4194  * buffer, subtract one activity length from the buffer size.
4195  */
4198 
4199  if (activity < BackendActivityBuffer ||
4200  activity > activity_last)
4201  return NULL;
4202 
4203  /* If no string available, no point in a report */
4204  if (activity[0] == '\0')
4205  return NULL;
4206 
4207  /*
4208  * Copy only ASCII-safe characters so we don't run into encoding
4209  * problems when reporting the message; and be sure not to run off
4210  * the end of memory. As only ASCII characters are reported, it
4211  * doesn't seem necessary to perform multibyte aware clipping.
4212  */
4213  ascii_safe_strlcpy(buffer, activity,
4214  Min(buflen, pgstat_track_activity_query_size));
4215 
4216  return buffer;
4217  }
4218 
4219  beentry++;
4220  }
4221 
4222  /* PID not found */
4223  return NULL;
4224 }
static PgBackendStatus * BackendStatusArray
Definition: pgstat.c:2630
static char * BackendActivityBuffer
Definition: pgstat.c:2634
#define Min(x, y)
Definition: c.h:920
static Size BackendActivityBufferSize
Definition: pgstat.c:2635
void ascii_safe_strlcpy(char *dest, const char *src, size_t destsiz)
Definition: ascii.c:173
int MaxBackends
Definition: globals.c:135
char * st_activity_raw
Definition: pgstat.h:1074
int pgstat_track_activity_query_size
Definition: pgstat.c:127
int i

◆ pgstat_get_wait_event()

const char* pgstat_get_wait_event ( uint32  wait_event_info)

Definition at line 3498 of file pgstat.c.

References GetLockNameFromTagType(), GetLWLockIdentifier(), PG_WAIT_ACTIVITY, PG_WAIT_BUFFER_PIN, PG_WAIT_CLIENT, PG_WAIT_EXTENSION, PG_WAIT_IO, PG_WAIT_IPC, PG_WAIT_LOCK, PG_WAIT_LWLOCK, PG_WAIT_TIMEOUT, pgstat_get_wait_activity(), pgstat_get_wait_client(), pgstat_get_wait_io(), pgstat_get_wait_ipc(), and pgstat_get_wait_timeout().

Referenced by pg_stat_get_activity(), and pg_stat_get_backend_wait_event().

3499 {
3500  uint32 classId;
3501  uint16 eventId;
3502  const char *event_name;
3503 
3504  /* report process as not waiting. */
3505  if (wait_event_info == 0)
3506  return NULL;
3507 
3508  classId = wait_event_info & 0xFF000000;
3509  eventId = wait_event_info & 0x0000FFFF;
3510 
3511  switch (classId)
3512  {
3513  case PG_WAIT_LWLOCK:
3514  event_name = GetLWLockIdentifier(classId, eventId);
3515  break;
3516  case PG_WAIT_LOCK:
3517  event_name = GetLockNameFromTagType(eventId);
3518  break;
3519  case PG_WAIT_BUFFER_PIN:
3520  event_name = "BufferPin";
3521  break;
3522  case PG_WAIT_ACTIVITY:
3523  {
3524  WaitEventActivity w = (WaitEventActivity) wait_event_info;
3525 
3526  event_name = pgstat_get_wait_activity(w);
3527  break;
3528  }
3529  case PG_WAIT_CLIENT:
3530  {
3531  WaitEventClient w = (WaitEventClient) wait_event_info;
3532 
3533  event_name = pgstat_get_wait_client(w);
3534  break;
3535  }
3536  case PG_WAIT_EXTENSION:
3537  event_name = "Extension";
3538  break;
3539  case PG_WAIT_IPC:
3540  {
3541  WaitEventIPC w = (WaitEventIPC) wait_event_info;
3542 
3543  event_name = pgstat_get_wait_ipc(w);
3544  break;
3545  }
3546  case PG_WAIT_TIMEOUT:
3547  {
3548  WaitEventTimeout w = (WaitEventTimeout) wait_event_info;
3549 
3550  event_name = pgstat_get_wait_timeout(w);
3551  break;
3552  }
3553  case PG_WAIT_IO:
3554  {
3555  WaitEventIO w = (WaitEventIO) wait_event_info;
3556 
3557  event_name = pgstat_get_wait_io(w);
3558  break;
3559  }
3560  default:
3561  event_name = "unknown wait event";
3562  break;
3563  }
3564 
3565  return event_name;
3566 }
#define PG_WAIT_LOCK
Definition: pgstat.h:738
WaitEventIPC
Definition: pgstat.h:800
static const char * pgstat_get_wait_timeout(WaitEventTimeout w)
Definition: pgstat.c:3815
static const char * pgstat_get_wait_ipc(WaitEventIPC w)
Definition: pgstat.c:3679
#define PG_WAIT_ACTIVITY
Definition: pgstat.h:740
#define PG_WAIT_IO
Definition: pgstat.h:745
static const char * pgstat_get_wait_activity(WaitEventActivity w)
Definition: pgstat.c:3575
unsigned short uint16
Definition: c.h:366
#define PG_WAIT_CLIENT
Definition: pgstat.h:741
WaitEventClient
Definition: pgstat.h:780
static const char * pgstat_get_wait_client(WaitEventClient w)
Definition: pgstat.c:3633
unsigned int uint32
Definition: c.h:367
WaitEventTimeout
Definition: pgstat.h:849
#define PG_WAIT_EXTENSION
Definition: pgstat.h:742
#define PG_WAIT_BUFFER_PIN
Definition: pgstat.h:739
const char * GetLockNameFromTagType(uint16 locktag_type)
Definition: lmgr.c:1170
WaitEventIO
Definition: pgstat.h:864
#define PG_WAIT_TIMEOUT
Definition: pgstat.h:744
#define PG_WAIT_IPC
Definition: pgstat.h:743
const char * GetLWLockIdentifier(uint32 classId, uint16 eventId)
Definition: lwlock.c:715
static const char * pgstat_get_wait_io(WaitEventIO w)
Definition: pgstat.c:3849
#define PG_WAIT_LWLOCK
Definition: pgstat.h:737
WaitEventActivity
Definition: pgstat.h:755

◆ pgstat_get_wait_event_type()

const char* pgstat_get_wait_event_type ( uint32  wait_event_info)

Definition at line 3443 of file pgstat.c.

References PG_WAIT_ACTIVITY, PG_WAIT_BUFFER_PIN, PG_WAIT_CLIENT, PG_WAIT_EXTENSION, PG_WAIT_IO, PG_WAIT_IPC, PG_WAIT_LOCK, PG_WAIT_LWLOCK, and PG_WAIT_TIMEOUT.

Referenced by pg_stat_get_activity(), and pg_stat_get_backend_wait_event_type().

3444 {
3445  uint32 classId;
3446  const char *event_type;
3447 
3448  /* report process as not waiting. */
3449  if (wait_event_info == 0)
3450  return NULL;
3451 
3452  classId = wait_event_info & 0xFF000000;
3453 
3454  switch (classId)
3455  {
3456  case PG_WAIT_LWLOCK:
3457  event_type = "LWLock";
3458  break;
3459  case PG_WAIT_LOCK:
3460  event_type = "Lock";
3461  break;
3462  case PG_WAIT_BUFFER_PIN:
3463  event_type = "BufferPin";
3464  break;
3465  case PG_WAIT_ACTIVITY:
3466  event_type = "Activity";
3467  break;
3468  case PG_WAIT_CLIENT:
3469  event_type = "Client";
3470  break;
3471  case PG_WAIT_EXTENSION:
3472  event_type = "Extension";
3473  break;
3474  case PG_WAIT_IPC:
3475  event_type = "IPC";
3476  break;
3477  case PG_WAIT_TIMEOUT:
3478  event_type = "Timeout";
3479  break;
3480  case PG_WAIT_IO:
3481  event_type = "IO";
3482  break;
3483  default:
3484  event_type = "???";
3485  break;
3486  }
3487 
3488  return event_type;
3489 }
#define PG_WAIT_LOCK
Definition: pgstat.h:738
#define PG_WAIT_ACTIVITY
Definition: pgstat.h:740
#define PG_WAIT_IO
Definition: pgstat.h:745
#define PG_WAIT_CLIENT
Definition: pgstat.h:741
unsigned int uint32
Definition: c.h:367
#define PG_WAIT_EXTENSION
Definition: pgstat.h:742
#define PG_WAIT_BUFFER_PIN
Definition: pgstat.h:739
#define PG_WAIT_TIMEOUT
Definition: pgstat.h:744
#define PG_WAIT_IPC
Definition: pgstat.h:743
#define PG_WAIT_LWLOCK
Definition: pgstat.h:737

◆ pgstat_init()

void pgstat_init ( void  )

Definition at line 349 of file pgstat.c.

References addrinfo::ai_next, AI_PASSIVE, bind, closesocket, connect, EINTR, elog, ereport, errcode(), errcode_for_socket_access(), errmsg(), gai_strerror, LOG, pg_freeaddrinfo_all(), pg_getaddrinfo_all(), pg_set_noblock(), PGC_INTERNAL, PGC_S_OVERRIDE, PGINVALID_SOCKET, PGSTAT_MAX_MSG_SIZE, PGSTAT_MIN_RCVBUF, pgStatAddr, pgStatSock, recv, ReserveExternalFD(), select, send, SetConfigOption(), socket, StaticAssertStmt, and TESTBYTEVAL.

Referenced by PostmasterMain().

350 {
351  ACCEPT_TYPE_ARG3 alen;
352  struct addrinfo *addrs = NULL,
353  *addr,
354  hints;
355  int ret;
356  fd_set rset;
357  struct timeval tv;
358  char test_byte;
359  int sel_res;
360  int tries = 0;
361 
362 #define TESTBYTEVAL ((char) 199)
363 
364  /*
365  * This static assertion verifies that we didn't mess up the calculations
366  * involved in selecting maximum payload sizes for our UDP messages.
367  * Because the only consequence of overrunning PGSTAT_MAX_MSG_SIZE would
368  * be silent performance loss from fragmentation, it seems worth having a
369  * compile-time cross-check that we didn't.
370  */
372  "maximum stats message size exceeds PGSTAT_MAX_MSG_SIZE");
373 
374  /*
375  * Create the UDP socket for sending and receiving statistic messages
376  */
377  hints.ai_flags = AI_PASSIVE;
378  hints.ai_family = AF_UNSPEC;
379  hints.ai_socktype = SOCK_DGRAM;
380  hints.ai_protocol = 0;
381  hints.ai_addrlen = 0;
382  hints.ai_addr = NULL;
383  hints.ai_canonname = NULL;
384  hints.ai_next = NULL;
385  ret = pg_getaddrinfo_all("localhost", NULL, &hints, &addrs);
386  if (ret || !addrs)
387  {
388  ereport(LOG,
389  (errmsg("could not resolve \"localhost\": %s",
390  gai_strerror(ret))));
391  goto startup_failed;
392  }
393 
394  /*
395  * On some platforms, pg_getaddrinfo_all() may return multiple addresses
396  * only one of which will actually work (eg, both IPv6 and IPv4 addresses
397  * when kernel will reject IPv6). Worse, the failure may occur at the
398  * bind() or perhaps even connect() stage. So we must loop through the
399  * results till we find a working combination. We will generate LOG
400  * messages, but no error, for bogus combinations.
401  */
402  for (addr = addrs; addr; addr = addr->ai_next)
403  {
404 #ifdef HAVE_UNIX_SOCKETS
405  /* Ignore AF_UNIX sockets, if any are returned. */
406  if (addr->ai_family == AF_UNIX)
407  continue;
408 #endif
409 
410  if (++tries > 1)
411  ereport(LOG,
412  (errmsg("trying another address for the statistics collector")));
413 
414  /*
415  * Create the socket.
416  */
417  if ((pgStatSock = socket(addr->ai_family, SOCK_DGRAM, 0)) == PGINVALID_SOCKET)
418  {
419  ereport(LOG,
421  errmsg("could not create socket for statistics collector: %m")));
422  continue;
423  }
424 
425  /*
426  * Bind it to a kernel assigned port on localhost and get the assigned
427  * port via getsockname().
428  */
429  if (bind(pgStatSock, addr->ai_addr, addr->ai_addrlen) < 0)
430  {
431  ereport(LOG,
433  errmsg("could not bind socket for statistics collector: %m")));
436  continue;
437  }
438 
439  alen = sizeof(pgStatAddr);
440  if (getsockname(pgStatSock, (struct sockaddr *) &pgStatAddr, &alen) < 0)
441  {
442  ereport(LOG,
444  errmsg("could not get address of socket for statistics collector: %m")));
447  continue;
448  }
449 
450  /*
451  * Connect the socket to its own address. This saves a few cycles by
452  * not having to respecify the target address on every send. This also
453  * provides a kernel-level check that only packets from this same
454  * address will be received.
455  */
456  if (connect(pgStatSock, (struct sockaddr *) &pgStatAddr, alen) < 0)
457  {
458  ereport(LOG,
460  errmsg("could not connect socket for statistics collector: %m")));
463  continue;
464  }
465 
466  /*
467  * Try to send and receive a one-byte test message on the socket. This
468  * is to catch situations where the socket can be created but will not
469  * actually pass data (for instance, because kernel packet filtering
470  * rules prevent it).
471  */
472  test_byte = TESTBYTEVAL;
473 
474 retry1:
475  if (send(pgStatSock, &test_byte, 1, 0) != 1)
476  {
477  if (errno == EINTR)
478  goto retry1; /* if interrupted, just retry */
479  ereport(LOG,
481  errmsg("could not send test message on socket for statistics collector: %m")));
484  continue;
485  }
486 
487  /*
488  * There could possibly be a little delay before the message can be
489  * received. We arbitrarily allow up to half a second before deciding
490  * it's broken.
491  */
492  for (;;) /* need a loop to handle EINTR */
493  {
494  FD_ZERO(&rset);
495  FD_SET(pgStatSock, &rset);
496 
497  tv.tv_sec = 0;
498  tv.tv_usec = 500000;
499  sel_res = select(pgStatSock + 1, &rset, NULL, NULL, &tv);
500  if (sel_res >= 0 || errno != EINTR)
501  break;
502  }
503  if (sel_res < 0)
504  {
505  ereport(LOG,
507  errmsg("select() failed in statistics collector: %m")));
510  continue;
511  }
512  if (sel_res == 0 || !FD_ISSET(pgStatSock, &rset))
513  {
514  /*
515  * This is the case we actually think is likely, so take pains to
516  * give a specific message for it.
517  *
518  * errno will not be set meaningfully here, so don't use it.
519  */
520  ereport(LOG,
521  (errcode(ERRCODE_CONNECTION_FAILURE),
522  errmsg("test message did not get through on socket for statistics collector")));
525  continue;
526  }
527 
528  test_byte++; /* just make sure variable is changed */
529 
530 retry2:
531  if (recv(pgStatSock, &test_byte, 1, 0) != 1)
532  {
533  if (errno == EINTR)
534  goto retry2; /* if interrupted, just retry */
535  ereport(LOG,
537  errmsg("could not receive test message on socket for statistics collector: %m")));
540  continue;
541  }
542 
543  if (test_byte != TESTBYTEVAL) /* strictly paranoia ... */
544  {
545  ereport(LOG,
546  (errcode(ERRCODE_INTERNAL_ERROR),
547  errmsg("incorrect test message transmission on socket for statistics collector")));
550  continue;
551  }
552 
553  /* If we get here, we have a working socket */
554  break;
555  }
556 
557  /* Did we find a working address? */
558  if (!addr || pgStatSock == PGINVALID_SOCKET)
559  goto startup_failed;
560 
561  /*
562  * Set the socket to non-blocking IO. This ensures that if the collector
563  * falls behind, statistics messages will be discarded; backends won't
564  * block waiting to send messages to the collector.
565  */
567  {
568  ereport(LOG,
570  errmsg("could not set statistics collector socket to nonblocking mode: %m")));
571  goto startup_failed;
572  }
573 
574  /*
575  * Try to ensure that the socket's receive buffer is at least
576  * PGSTAT_MIN_RCVBUF bytes, so that it won't easily overflow and lose
577  * data. Use of UDP protocol means that we are willing to lose data under
578  * heavy load, but we don't want it to happen just because of ridiculously
579  * small default buffer sizes (such as 8KB on older Windows versions).
580  */
581  {
582  int old_rcvbuf;
583  int new_rcvbuf;
584  ACCEPT_TYPE_ARG3 rcvbufsize = sizeof(old_rcvbuf);
585 
586  if (getsockopt(pgStatSock, SOL_SOCKET, SO_RCVBUF,
587  (char *) &old_rcvbuf, &rcvbufsize) < 0)
588  {
589  elog(LOG, "getsockopt(SO_RCVBUF) failed: %m");
590  /* if we can't get existing size, always try to set it */
591  old_rcvbuf = 0;
592  }
593 
594  new_rcvbuf = PGSTAT_MIN_RCVBUF;
595  if (old_rcvbuf < new_rcvbuf)
596  {
597  if (setsockopt(pgStatSock, SOL_SOCKET, SO_RCVBUF,
598  (char *) &new_rcvbuf, sizeof(new_rcvbuf)) < 0)
599  elog(LOG, "setsockopt(SO_RCVBUF) failed: %m");
600  }
601  }
602 
603  pg_freeaddrinfo_all(hints.ai_family, addrs);
604 
605  /* Now that we have a long-lived socket, tell fd.c about it. */
607 
608  return;
609 
610 startup_failed:
611  ereport(LOG,
612  (errmsg("disabling statistics collector for lack of working socket")));
613 
614  if (addrs)
615  pg_freeaddrinfo_all(hints.ai_family, addrs);
616 
620 
621  /*
622  * Adjust GUC variables to suppress useless activity, and for debugging
623  * purposes (seeing track_counts off is a clue that we failed here). We
624  * use PGC_S_OVERRIDE because there is no point in trying to turn it back
625  * on from postgresql.conf without a restart.
626  */
627  SetConfigOption("track_counts", "off", PGC_INTERNAL, PGC_S_OVERRIDE);
628 }
void pg_freeaddrinfo_all(int hint_ai_family, struct addrinfo *ai)
Definition: ip.c:88
NON_EXEC_STATIC pgsocket pgStatSock
Definition: pgstat.c:148
#define closesocket
Definition: port.h:312
int errcode(int sqlerrcode)
Definition: elog.c:610
#define connect(s, name, namelen)
Definition: win32_port.h:435
#define LOG
Definition: elog.h:26
#define bind(s, addr, addrlen)
Definition: win32_port.h:432
#define recv(s, buf, len, flags)
Definition: win32_port.h:437
#define gai_strerror
Definition: getaddrinfo.h:146
int pg_getaddrinfo_all(const char *hostname, const char *servname, const struct addrinfo *hintp, struct addrinfo **result)
Definition: ip.c:57
#define StaticAssertStmt(condition, errmessage)
Definition: c.h:852
#define PGSTAT_MIN_RCVBUF
Definition: pgstat.c:96
#define TESTBYTEVAL
void ReserveExternalFD(void)
Definition: fd.c:1080
void SetConfigOption(const char *name, const char *value, GucContext context, GucSource source)
Definition: guc.c:7658
#define AI_PASSIVE
Definition: getaddrinfo.h:62
#define select(n, r, w, e, timeout)
Definition: win32_port.h:436
int errcode_for_socket_access(void)
Definition: elog.c:704
#define socket(af, type, protocol)
Definition: win32_port.h:431
#define PGSTAT_MAX_MSG_SIZE
Definition: pgstat.h:207
#define PGINVALID_SOCKET
Definition: port.h:33
#define ereport(elevel,...)
Definition: elog.h:144
static struct sockaddr_storage pgStatAddr
Definition: pgstat.c:150
bool pg_set_noblock(pgsocket sock)
Definition: noblock.c:25
struct addrinfo * ai_next
Definition: getaddrinfo.h:107
int errmsg(const char *fmt,...)
Definition: elog.c:824
#define elog(elevel,...)
Definition: elog.h:214
#define EINTR
Definition: win32_port.h:323
#define send(s, buf, len, flags)
Definition: win32_port.h:438

◆ pgstat_init_function_usage()

void pgstat_init_function_usage ( struct FunctionCallInfoBaseData fcinfo,
PgStat_FunctionCallUsage fcu 
)

◆ pgstat_initialize()

void pgstat_initialize ( void  )

Definition at line 2811 of file pgstat.c.

References Assert, InvalidBackendId, MaxBackends, MyAuxProcType, MyBackendId, NotAnAuxProcess, on_shmem_exit(), and pgstat_beshutdown_hook().

Referenced by AuxiliaryProcessMain(), and InitPostgres().

2812 {
2813  /* Initialize MyBEEntry */
2815  {
2818  }
2819  else
2820  {
2821  /* Must be an auxiliary process */
2823 
2824  /*
2825  * Assign the MyBEEntry for an auxiliary process. Since it doesn't
2826  * have a BackendId, the slot is statically allocated based on the
2827  * auxiliary process type (MyAuxProcType). Backends use slots indexed
2828  * in the range from 1 to MaxBackends (inclusive), so we use
2829  * MaxBackends + AuxBackendType + 1 as the index of the slot for an
2830  * auxiliary process.
2831  */
2833  }
2834 
2835  /* Set up a process-exit hook to clean up */
2837 }
static PgBackendStatus * BackendStatusArray
Definition: pgstat.c:2630
BackendId MyBackendId
Definition: globals.c:81
int MaxBackends
Definition: globals.c:135
static PgBackendStatus * MyBEEntry
Definition: pgstat.c:2631
void on_shmem_exit(pg_on_exit_callback function, Datum arg)
Definition: ipc.c:361
static void pgstat_beshutdown_hook(int code, Datum arg)
Definition: pgstat.c:3024
#define InvalidBackendId
Definition: backendid.h:23
AuxProcType MyAuxProcType
Definition: bootstrap.c:72
#define Assert(condition)
Definition: c.h:738

◆ pgstat_initstats()

void pgstat_initstats ( Relation  rel)

Definition at line 1747 of file pgstat.c.

References get_tabstat_entry(), PGINVALID_SOCKET, RelationData::pgstat_info, pgstat_track_counts, pgStatSock, RelationData::rd_id, RelationData::rd_rel, and PgStat_TableStatus::t_id.

Referenced by relation_open(), and try_relation_open().

1748 {
1749  Oid rel_id = rel->rd_id;
1750  char relkind = rel->rd_rel->relkind;
1751 
1752  /* We only count stats for things that have storage */
1753  if (!(relkind == RELKIND_RELATION ||
1754  relkind == RELKIND_MATVIEW ||
1755  relkind == RELKIND_INDEX ||
1756  relkind == RELKIND_TOASTVALUE ||
1757  relkind == RELKIND_SEQUENCE))
1758  {
1759  rel->pgstat_info = NULL;
1760  return;
1761  }
1762 
1764  {
1765  /* We're not counting at all */
1766  rel->pgstat_info = NULL;
1767  return;
1768  }
1769 
1770  /*
1771  * If we already set up this relation in the current transaction, nothing
1772  * to do.
1773  */
1774  if (rel->pgstat_info != NULL &&
1775  rel->pgstat_info->t_id == rel_id)
1776  return;
1777 
1778  /* Else find or make the PgStat_TableStatus entry, and update link */
1779  rel->pgstat_info = get_tabstat_entry(rel_id, rel->rd_rel->relisshared);
1780 }
NON_EXEC_STATIC pgsocket pgStatSock
Definition: pgstat.c:148
Form_pg_class rd_rel
Definition: rel.h:89
unsigned int Oid
Definition: postgres_ext.h:31
bool pgstat_track_counts
Definition: pgstat.c:125
Oid rd_id
Definition: rel.h:91
static PgStat_TableStatus * get_tabstat_entry(Oid rel_id, bool isshared)
Definition: pgstat.c:1786
#define PGINVALID_SOCKET
Definition: port.h:33
struct PgStat_TableStatus * pgstat_info
Definition: rel.h:216

◆ pgstat_ping()

void pgstat_ping ( void  )

Definition at line 1583 of file pgstat.c.

References PgStat_MsgDummy::m_hdr, PGINVALID_SOCKET, PGSTAT_MTYPE_DUMMY, pgstat_send(), pgstat_setheader(), and pgStatSock.

1584 {
1585  PgStat_MsgDummy msg;
1586 
1588  return;
1589 
1591  pgstat_send(&msg, sizeof(msg));
1592 }
static void pgstat_send(void *msg, int len)
Definition: pgstat.c:4252
NON_EXEC_STATIC pgsocket pgStatSock
Definition: pgstat.c:148
#define PGINVALID_SOCKET
Definition: port.h:33
PgStat_MsgHdr m_hdr
Definition: pgstat.h:217
static void pgstat_setheader(PgStat_MsgHdr *hdr, StatMsgType mtype)
Definition: pgstat.c:4239

◆ pgstat_progress_end_command()

void pgstat_progress_end_command ( void  )

Definition at line 3212 of file pgstat.c.

References InvalidOid, MyBEEntry, PGSTAT_BEGIN_WRITE_ACTIVITY, PGSTAT_END_WRITE_ACTIVITY, pgstat_track_activities, PROGRESS_COMMAND_INVALID, PgBackendStatus::st_progress_command, and PgBackendStatus::st_progress_command_target.

Referenced by AbortSubTransaction(), AbortTransaction(), analyze_rel(), cluster_rel(), DefineIndex(), heap_vacuum_rel(), perform_base_backup(), reindex_index(), and ReindexRelationConcurrently().

3213 {
3214  volatile PgBackendStatus *beentry = MyBEEntry;
3215 
3216  if (!beentry || !pgstat_track_activities)
3217  return;
3218 
3220  return;
3221 
3222  PGSTAT_BEGIN_WRITE_ACTIVITY(beentry);
3225  PGSTAT_END_WRITE_ACTIVITY(beentry);
3226 }
Oid st_progress_command_target
Definition: pgstat.h:1086
ProgressCommandType st_progress_command
Definition: pgstat.h:1085
static PgBackendStatus * MyBEEntry
Definition: pgstat.c:2631
#define PGSTAT_END_WRITE_ACTIVITY(beentry)
Definition: pgstat.h:1126
#define InvalidOid
Definition: postgres_ext.h:36
bool pgstat_track_activities
Definition: pgstat.c:124
#define PGSTAT_BEGIN_WRITE_ACTIVITY(beentry)
Definition: pgstat.h:1119

◆ pgstat_progress_start_command()

void pgstat_progress_start_command ( ProgressCommandType  cmdtype,
Oid  relid 
)

Definition at line 3140 of file pgstat.c.

References MemSet, MyBEEntry, PGSTAT_BEGIN_WRITE_ACTIVITY, PGSTAT_END_WRITE_ACTIVITY, pgstat_track_activities, PgBackendStatus::st_progress_command, PgBackendStatus::st_progress_command_target, and PgBackendStatus::st_progress_param.

Referenced by analyze_rel(), cluster_rel(), DefineIndex(), heap_vacuum_rel(), perform_base_backup(), reindex_index(), and ReindexRelationConcurrently().

3141 {
3142  volatile PgBackendStatus *beentry = MyBEEntry;
3143 
3144  if (!beentry || !pgstat_track_activities)
3145  return;
3146 
3147  PGSTAT_BEGIN_WRITE_ACTIVITY(beentry);
3148  beentry->st_progress_command = cmdtype;
3149  beentry->st_progress_command_target = relid;
3150  MemSet(&beentry->st_progress_param, 0, sizeof(beentry->st_progress_param));
3151  PGSTAT_END_WRITE_ACTIVITY(beentry);
3152 }
Oid st_progress_command_target
Definition: pgstat.h:1086
#define MemSet(start, val, len)
Definition: c.h:971
ProgressCommandType st_progress_command
Definition: pgstat.h:1085
static PgBackendStatus * MyBEEntry
Definition: pgstat.c:2631
#define PGSTAT_END_WRITE_ACTIVITY(beentry)
Definition: pgstat.h:1126
int64 st_progress_param[PGSTAT_NUM_PROGRESS_PARAM]
Definition: pgstat.h:1087
bool pgstat_track_activities
Definition: pgstat.c:124
#define PGSTAT_BEGIN_WRITE_ACTIVITY(beentry)
Definition: pgstat.h:1119

◆ pgstat_progress_update_multi_param()

void pgstat_progress_update_multi_param ( int  nparam,
const int *  index,
const int64 *  val 
)

Definition at line 3183 of file pgstat.c.

References Assert, i, MyBEEntry, PGSTAT_BEGIN_WRITE_ACTIVITY, PGSTAT_END_WRITE_ACTIVITY, PGSTAT_NUM_PROGRESS_PARAM, pgstat_track_activities, and PgBackendStatus::st_progress_param.

Referenced by _bt_spools_heapscan(), BuildRelationExtStatistics(), heapam_relation_copy_for_cluster(), index_build(), lazy_scan_heap(), perform_base_backup(), update_basebackup_progress(), validate_index(), and WaitForLockersMultiple().

3185 {
3186  volatile PgBackendStatus *beentry = MyBEEntry;
3187  int i;
3188 
3189  if (!beentry || !pgstat_track_activities || nparam == 0)
3190  return;
3191 
3192  PGSTAT_BEGIN_WRITE_ACTIVITY(beentry);
3193 
3194  for (i = 0; i < nparam; ++i)
3195  {
3196  Assert(index[i] >= 0 && index[i] < PGSTAT_NUM_PROGRESS_PARAM);
3197 
3198  beentry->st_progress_param[index[i]] = val[i];
3199  }
3200 
3201  PGSTAT_END_WRITE_ACTIVITY(beentry);
3202 }
Definition: type.h:89
#define PGSTAT_NUM_PROGRESS_PARAM
Definition: pgstat.h:951
static PgBackendStatus * MyBEEntry
Definition: pgstat.c:2631
#define PGSTAT_END_WRITE_ACTIVITY(beentry)
Definition: pgstat.h:1126
#define Assert(condition)
Definition: c.h:738
int64 st_progress_param[PGSTAT_NUM_PROGRESS_PARAM]
Definition: pgstat.h:1087
bool pgstat_track_activities
Definition: pgstat.c:124
int i
#define PGSTAT_BEGIN_WRITE_ACTIVITY(beentry)
Definition: pgstat.h:1119
long val
Definition: informix.c:664

◆ pgstat_progress_update_param()

void pgstat_progress_update_param ( int  index,
int64  val 
)

Definition at line 3161 of file pgstat.c.

References Assert, MyBEEntry, PGSTAT_BEGIN_WRITE_ACTIVITY, PGSTAT_END_WRITE_ACTIVITY, PGSTAT_NUM_PROGRESS_PARAM, pgstat_track_activities, PgBackendStatus::st_progress_param, and val.

Referenced by _bt_leafbuild(), _bt_load(), _bt_spools_heapscan(), _h_indexbuild(), acquire_inherited_sample_rows(), acquire_sample_rows(), btvacuumscan(), BuildRelationExtStatistics(), cluster_rel(), DefineIndex(), do_analyze_rel(), do_pg_start_backup(), finish_heap_swap(), hashbuild(), heap_vacuum_rel(), heapam_index_build_range_scan(), heapam_index_validate_scan(), heapam_relation_copy_for_cluster(), lazy_cleanup_all_indexes(), lazy_record_dead_tuple(), lazy_scan_heap(), lazy_truncate_heap(), lazy_vacuum_all_indexes(), lazy_vacuum_heap(), lazy_vacuum_page(), perform_base_backup(), reindex_index(), reindex_relation(), ReindexRelationConcurrently(), validate_index(), WaitForLockersMultiple(), and WaitForOlderSnapshots().

3162 {
3163  volatile PgBackendStatus *beentry = MyBEEntry;
3164 
3166 
3167  if (!beentry || !pgstat_track_activities)
3168  return;
3169 
3170  PGSTAT_BEGIN_WRITE_ACTIVITY(beentry);
3171  beentry->st_progress_param[index] = val;
3172  PGSTAT_END_WRITE_ACTIVITY(beentry);
3173 }
Definition: type.h:89
#define PGSTAT_NUM_PROGRESS_PARAM
Definition: pgstat.h:951
static PgBackendStatus * MyBEEntry
Definition: pgstat.c:2631
#define PGSTAT_END_WRITE_ACTIVITY(beentry)
Definition: pgstat.h:1126
#define Assert(condition)
Definition: c.h:738
int64 st_progress_param[PGSTAT_NUM_PROGRESS_PARAM]
Definition: pgstat.h:1087
bool pgstat_track_activities
Definition: pgstat.c:124
#define PGSTAT_BEGIN_WRITE_ACTIVITY(beentry)
Definition: pgstat.h:1119
long val
Definition: informix.c:664

◆ pgstat_report_activity()

void pgstat_report_activity ( BackendState  state,
const char *  cmd_str 
)

Definition at line 3062 of file pgstat.c.

References GetCurrentStatementStartTimestamp(), GetCurrentTimestamp(), Min, MyBEEntry, MyProc, PGSTAT_BEGIN_WRITE_ACTIVITY, PGSTAT_END_WRITE_ACTIVITY, pgstat_track_activities, pgstat_track_activity_query_size, PgBackendStatus::st_activity_raw, PgBackendStatus::st_activity_start_timestamp, PgBackendStatus::st_state, PgBackendStatus::st_state_start_timestamp, PgBackendStatus::st_xact_start_timestamp, STATE_DISABLED, and PGPROC::wait_event_info.

Referenced by _bt_parallel_build_main(), apply_handle_begin(), apply_handle_commit(), autovac_report_activity(), autovac_report_workitem(), exec_bind_message(), exec_execute_message(), exec_parse_message(), exec_replication_command(), exec_simple_query(), initialize_worker_spi(), LogicalRepApplyLoop(), parallel_vacuum_main(), ParallelQueryMain(), and PostgresMain().

3063 {
3064  volatile PgBackendStatus *beentry = MyBEEntry;
3065  TimestampTz start_timestamp;
3066  TimestampTz current_timestamp;
3067  int len = 0;
3068 
3069  TRACE_POSTGRESQL_STATEMENT_STATUS(cmd_str);
3070 
3071  if (!beentry)
3072  return;
3073 
3075  {
3076  if (beentry->st_state != STATE_DISABLED)
3077  {
3078  volatile PGPROC *proc = MyProc;
3079 
3080  /*
3081  * track_activities is disabled, but we last reported a
3082  * non-disabled state. As our final update, change the state and
3083  * clear fields we will not be updating anymore.
3084  */
3085  PGSTAT_BEGIN_WRITE_ACTIVITY(beentry);
3086  beentry->st_state = STATE_DISABLED;
3087  beentry->st_state_start_timestamp = 0;
3088  beentry->st_activity_raw[0] = '\0';
3089  beentry->st_activity_start_timestamp = 0;
3090  /* st_xact_start_timestamp and wait_event_info are also disabled */
3091  beentry->st_xact_start_timestamp = 0;
3092  proc->wait_event_info = 0;
3093  PGSTAT_END_WRITE_ACTIVITY(beentry);
3094  }
3095  return;
3096  }
3097 
3098  /*
3099  * To minimize the time spent modifying the entry, and avoid risk of
3100  * errors inside the critical section, fetch all the needed data first.
3101  */
3102  start_timestamp = GetCurrentStatementStartTimestamp();
3103  if (cmd_str != NULL)
3104  {
3105  /*
3106  * Compute length of to-be-stored string unaware of multi-byte
3107  * characters. For speed reasons that'll get corrected on read, rather
3108  * than computed every write.
3109  */
3110  len = Min(strlen(cmd_str), pgstat_track_activity_query_size - 1);
3111  }
3112  current_timestamp = GetCurrentTimestamp();
3113 
3114  /*
3115  * Now update the status entry
3116  */
3117  PGSTAT_BEGIN_WRITE_ACTIVITY(beentry);
3118 
3119  beentry->st_state = state;
3120  beentry->st_state_start_timestamp = current_timestamp;
3121 
3122  if (cmd_str != NULL)
3123  {
3124  memcpy((char *) beentry->st_activity_raw, cmd_str, len);
3125  beentry->st_activity_raw[len] = '\0';
3126  beentry->st_activity_start_timestamp = start_timestamp;
3127  }
3128 
3129  PGSTAT_END_WRITE_ACTIVITY(beentry);
3130 }
uint32 wait_event_info
Definition: proc.h:176
TimestampTz st_activity_start_timestamp
Definition: pgstat.h:1044
TimestampTz GetCurrentTimestamp(void)
Definition: timestamp.c:1583
PGPROC * MyProc
Definition: proc.c:67
int64 TimestampTz
Definition: timestamp.h:39
#define Min(x, y)
Definition: c.h:920
BackendState st_state
Definition: pgstat.h:1062
static PgBackendStatus * MyBEEntry
Definition: pgstat.c:2631
#define PGSTAT_END_WRITE_ACTIVITY(beentry)
Definition: pgstat.h:1126
char * st_activity_raw
Definition: pgstat.h:1074
int pgstat_track_activity_query_size
Definition: pgstat.c:127
TimestampTz st_state_start_timestamp
Definition: pgstat.h:1045
Definition: regguts.h:298
TimestampTz st_xact_start_timestamp
Definition: pgstat.h:1043
bool pgstat_track_activities
Definition: pgstat.c:124
Definition: proc.h:95
#define PGSTAT_BEGIN_WRITE_ACTIVITY(beentry)
Definition: pgstat.h:1119
TimestampTz GetCurrentStatementStartTimestamp(void)
Definition: xact.c:791

◆ pgstat_report_analyze()

void pgstat_report_analyze ( Relation  rel,
PgStat_Counter  livetuples,
PgStat_Counter  deadtuples,
bool  resetcounter 
)

Definition at line 1434 of file pgstat.c.

References GetCurrentTimestamp(), InvalidOid, IsAutoVacuumWorkerProcess(), PgStat_MsgAnalyze::m_analyzetime, PgStat_MsgAnalyze::m_autovacuum, PgStat_MsgAnalyze::m_databaseid, PgStat_MsgAnalyze::m_dead_tuples, PgStat_MsgAnalyze::m_hdr, PgStat_MsgAnalyze::m_live_tuples, PgStat_MsgAnalyze::m_resetcounter, PgStat_MsgAnalyze::m_tableoid, Max, MyDatabaseId, PGINVALID_SOCKET, RelationData::pgstat_info, PGSTAT_MTYPE_ANALYZE, pgstat_send(), pgstat_setheader(), pgstat_track_counts, pgStatSock, RelationData::rd_rel, RelationGetRelid, PgStat_TableStatus::t_counts, PgStat_TableCounts::t_delta_dead_tuples, PgStat_TableStatus::trans, trans, PgStat_TableXactStatus::tuples_deleted, PgStat_TableXactStatus::tuples_inserted, PgStat_TableXactStatus::tuples_updated, and PgStat_TableXactStatus::upper.

Referenced by do_analyze_rel().

1437 {
1438  PgStat_MsgAnalyze msg;
1439 
1441  return;
1442 
1443  /*
1444  * Unlike VACUUM, ANALYZE might be running inside a transaction that has
1445  * already inserted and/or deleted rows in the target table. ANALYZE will
1446  * have counted such rows as live or dead respectively. Because we will
1447  * report our counts of such rows at transaction end, we should subtract
1448  * off these counts from what we send to the collector now, else they'll
1449  * be double-counted after commit. (This approach also ensures that the
1450  * collector ends up with the right numbers if we abort instead of
1451  * committing.)
1452  */
1453  if (rel->pgstat_info != NULL)
1454  {
1456 
1457  for (trans = rel->pgstat_info->trans; trans; trans = trans->upper)
1458  {
1459  livetuples -= trans->tuples_inserted - trans->tuples_deleted;
1460  deadtuples -= trans->tuples_updated + trans->tuples_deleted;
1461  }
1462  /* count stuff inserted by already-aborted subxacts, too */
1463  deadtuples -= rel->pgstat_info->t_counts.t_delta_dead_tuples;
1464  /* Since ANALYZE's counts are estimates, we could have underflowed */
1465  livetuples = Max(livetuples, 0);
1466  deadtuples = Max(deadtuples, 0);
1467  }
1468 
1470  msg.m_databaseid = rel->rd_rel->relisshared ? InvalidOid : MyDatabaseId;
1471  msg.m_tableoid = RelationGetRelid(rel);
1473  msg.m_resetcounter = resetcounter;
1475  msg.m_live_tuples = livetuples;
1476  msg.m_dead_tuples = deadtuples;
1477  pgstat_send(&msg, sizeof(msg));
1478 }
static void pgstat_send(void *msg, int len)
Definition: pgstat.c:4252
PgStat_Counter tuples_updated
Definition: pgstat.h:169
NON_EXEC_STATIC pgsocket pgStatSock
Definition: pgstat.c:148
TimestampTz GetCurrentTimestamp(void)
Definition: timestamp.c:1583
TimestampTz m_analyzetime
Definition: pgstat.h:388
PgStat_TableCounts t_counts
Definition: pgstat.h:159
Form_pg_class rd_rel
Definition: rel.h:89
bool m_resetcounter
Definition: pgstat.h:387
bool pgstat_track_counts
Definition: pgstat.c:125
PgStat_Counter tuples_inserted
Definition: pgstat.h:168
PgStat_Counter t_delta_dead_tuples
Definition: pgstat.h:112
bool IsAutoVacuumWorkerProcess(void)
Definition: autovacuum.c:3302
struct PgStat_TableXactStatus * upper
Definition: pgstat.h:177
PgStat_Counter m_live_tuples
Definition: pgstat.h:389
bool m_autovacuum
Definition: pgstat.h:386
PgStat_Counter tuples_deleted
Definition: pgstat.h:170
#define PGINVALID_SOCKET
Definition: port.h:33
Oid MyDatabaseId
Definition: globals.c:85
#define InvalidOid
Definition: postgres_ext.h:36
#define Max(x, y)
Definition: c.h:914
static void pgstat_setheader(PgStat_MsgHdr *hdr, StatMsgType mtype)
Definition: pgstat.c:4239
struct PgStat_TableStatus * pgstat_info
Definition: rel.h:216
struct PgStat_TableXactStatus * trans
Definition: pgstat.h:158
PgStat_MsgHdr m_hdr
Definition: pgstat.h:383
static zic_t trans[TZ_MAX_LEAPS]
Definition: zic.c:396
PgStat_Counter m_dead_tuples
Definition: pgstat.h:390
#define RelationGetRelid(relation)
Definition: rel.h:436

◆ pgstat_report_appname()

void pgstat_report_appname ( const char *  appname)

Definition at line 3235 of file pgstat.c.

References MyBEEntry, NAMEDATALEN, pg_mbcliplen(), PGSTAT_BEGIN_WRITE_ACTIVITY, PGSTAT_END_WRITE_ACTIVITY, and PgBackendStatus::st_appname.

Referenced by assign_application_name(), and pgstat_bestart().

3236 {
3237  volatile PgBackendStatus *beentry = MyBEEntry;
3238  int len;
3239 
3240  if (!beentry)
3241  return;
3242 
3243  /* This should be unnecessary if GUC did its job, but be safe */
3244  len = pg_mbcliplen(appname, strlen(appname), NAMEDATALEN - 1);
3245 
3246  /*
3247  * Update my status entry, following the protocol of bumping
3248  * st_changecount before and after. We use a volatile pointer here to
3249  * ensure the compiler doesn't try to get cute.
3250  */
3251  PGSTAT_BEGIN_WRITE_ACTIVITY(beentry);
3252 
3253  memcpy((char *) beentry->st_appname, appname, len);
3254  beentry->st_appname[len] = '\0';
3255 
3256  PGSTAT_END_WRITE_ACTIVITY(beentry);
3257 }
#define NAMEDATALEN
int pg_mbcliplen(const char *mbstr, int len, int limit)
Definition: mbutils.c:967
static PgBackendStatus * MyBEEntry
Definition: pgstat.c:2631
#define PGSTAT_END_WRITE_ACTIVITY(beentry)
Definition: pgstat.h:1126
char * st_appname
Definition: pgstat.h:1065
#define PGSTAT_BEGIN_WRITE_ACTIVITY(beentry)
Definition: pgstat.h:1119

◆ pgstat_report_autovac()

void pgstat_report_autovac ( Oid  dboid)

Definition at line 1384 of file pgstat.c.

References GetCurrentTimestamp(), PgStat_MsgAutovacStart::m_databaseid, PgStat_MsgAutovacStart::m_hdr, PgStat_MsgAutovacStart::m_start_time, PGINVALID_SOCKET, PGSTAT_MTYPE_AUTOVAC_START, pgstat_send(), pgstat_setheader(), and pgStatSock.

Referenced by AutoVacWorkerMain().

1385 {
1387 
1389  return;
1390 
1392  msg.m_databaseid = dboid;
1394 
1395  pgstat_send(&msg, sizeof(msg));
1396 }
static void pgstat_send(void *msg, int len)
Definition: pgstat.c:4252
NON_EXEC_STATIC pgsocket pgStatSock
Definition: pgstat.c:148
TimestampTz GetCurrentTimestamp(void)
Definition: timestamp.c:1583
PgStat_MsgHdr m_hdr
Definition: pgstat.h:353
#define PGINVALID_SOCKET
Definition: port.h:33
static void pgstat_setheader(PgStat_MsgHdr *hdr, StatMsgType mtype)
Definition: pgstat.c:4239
TimestampTz m_start_time
Definition: pgstat.h:355

◆ pgstat_report_checksum_failure()

void pgstat_report_checksum_failure ( void  )

Definition at line 1550 of file pgstat.c.

References MyDatabaseId, and pgstat_report_checksum_failures_in_db().

Referenced by PageIsVerified().

1551 {
1553 }
void pgstat_report_checksum_failures_in_db(Oid dboid, int failurecount)
Definition: pgstat.c:1528
Oid MyDatabaseId
Definition: globals.c:85

◆ pgstat_report_checksum_failures_in_db()

void pgstat_report_checksum_failures_in_db ( Oid  dboid,
int  failurecount 
)

Definition at line 1528 of file pgstat.c.

References GetCurrentTimestamp(), PgStat_MsgChecksumFailure::m_databaseid, PgStat_MsgChecksumFailure::m_failure_time, PgStat_MsgChecksumFailure::m_failurecount, PgStat_MsgChecksumFailure::m_hdr, PGINVALID_SOCKET, PGSTAT_MTYPE_CHECKSUMFAILURE, pgstat_send(), pgstat_setheader(), pgstat_track_counts, and pgStatSock.

Referenced by pgstat_report_checksum_failure(), and sendFile().

1529 {
1531 
1533  return;
1534 
1536  msg.m_databaseid = dboid;
1537  msg.m_failurecount = failurecount;
1539 
1540  pgstat_send(&msg, sizeof(msg));
1541 }
static void pgstat_send(void *msg, int len)
Definition: pgstat.c:4252
NON_EXEC_STATIC pgsocket pgStatSock
Definition: pgstat.c:148
TimestampTz GetCurrentTimestamp(void)
Definition: timestamp.c:1583
PgStat_MsgHdr m_hdr
Definition: pgstat.h:541
bool pgstat_track_counts
Definition: pgstat.c:125
TimestampTz m_failure_time
Definition: pgstat.h:544
#define PGINVALID_SOCKET
Definition: port.h:33
static void pgstat_setheader(PgStat_MsgHdr *hdr, StatMsgType mtype)
Definition: pgstat.c:4239

◆ pgstat_report_deadlock()

void pgstat_report_deadlock ( void  )

Definition at line 1507 of file pgstat.c.

References PgStat_MsgDeadlock::m_databaseid, PgStat_MsgDeadlock::m_hdr, MyDatabaseId, PGINVALID_SOCKET, PGSTAT_MTYPE_DEADLOCK, pgstat_send(), pgstat_setheader(), pgstat_track_counts, and pgStatSock.

Referenced by DeadLockReport().

1508 {
1509  PgStat_MsgDeadlock msg;
1510 
1512  return;
1513 
1515  msg.m_databaseid = MyDatabaseId;
1516  pgstat_send(&msg, sizeof(msg));
1517 }
static void pgstat_send(void *msg, int len)
Definition: pgstat.c:4252
NON_EXEC_STATIC pgsocket pgStatSock
Definition: pgstat.c:148
bool pgstat_track_counts
Definition: pgstat.c:125
PgStat_MsgHdr m_hdr
Definition: pgstat.h:530
#define PGINVALID_SOCKET
Definition: port.h:33
Oid MyDatabaseId
Definition: globals.c:85
static void pgstat_setheader(PgStat_MsgHdr *hdr, StatMsgType mtype)
Definition: pgstat.c:4239

◆ pgstat_report_recovery_conflict()

void pgstat_report_recovery_conflict ( int  reason)

Definition at line 1487 of file pgstat.c.

References PgStat_MsgRecoveryConflict::m_databaseid, PgStat_MsgRecoveryConflict::m_hdr, PgStat_MsgRecoveryConflict::m_reason, MyDatabaseId, PGINVALID_SOCKET, PGSTAT_MTYPE_RECOVERYCONFLICT, pgstat_send(), pgstat_setheader(), pgstat_track_counts, and pgStatSock.

Referenced by ProcessInterrupts().

1488 {
1490 
1492  return;
1493 
1495  msg.m_databaseid = MyDatabaseId;
1496  msg.m_reason = reason;
1497  pgstat_send(&msg, sizeof(msg));
1498 }
static void pgstat_send(void *msg, int len)
Definition: pgstat.c:4252
NON_EXEC_STATIC pgsocket pgStatSock
Definition: pgstat.c:148
bool pgstat_track_counts
Definition: pgstat.c:125
PgStat_MsgHdr m_hdr
Definition: pgstat.h:432
#define PGINVALID_SOCKET
Definition: port.h:33
Oid MyDatabaseId
Definition: globals.c:85
static void pgstat_setheader(PgStat_MsgHdr *hdr, StatMsgType mtype)
Definition: pgstat.c:4239

◆ pgstat_report_stat()

void pgstat_report_stat ( bool  force)

Definition at line 809 of file pgstat.c.

References Assert, GetCurrentTransactionStopTimestamp(), hash_destroy(), have_function_stats, i, InvalidOid, PgStat_MsgTabstat::m_databaseid, PgStat_MsgTabstat::m_entry, PgStat_MsgTabstat::m_nentries, MemSet, MyDatabaseId, now(), PGSTAT_NUM_TABENTRIES, pgstat_send_funcstats(), pgstat_send_tabstat(), PGSTAT_STAT_INTERVAL, pgStatXactCommit, pgStatXactRollback, PgStat_TableStatus::t_counts, PgStat_TableEntry::t_counts, PgStat_TableStatus::t_id, PgStat_TableEntry::t_id, PgStat_TableStatus::t_shared, TimestampDifferenceExceeds(), PgStat_TableStatus::trans, TabStatusArray::tsa_entries, TabStatusArray::tsa_next, and TabStatusArray::tsa_used.

Referenced by apply_handle_commit(), initialize_worker_spi(), LogicalRepSyncTableStart(), pg_attribute_noreturn(), pgstat_beshutdown_hook(), PostgresMain(), and process_syncing_tables_for_apply().

810 {
811  /* we assume this inits to all zeroes: */
812  static const PgStat_TableCounts all_zeroes;
813  static TimestampTz last_report = 0;
814 
816  PgStat_MsgTabstat regular_msg;
817  PgStat_MsgTabstat shared_msg;
818  TabStatusArray *tsa;
819  int i;
820 
821  /* Don't expend a clock check if nothing to do */
822  if ((pgStatTabList == NULL || pgStatTabList->tsa_used == 0) &&
823  pgStatXactCommit == 0 && pgStatXactRollback == 0 &&
825  return;
826 
827  /*
828  * Don't send a message unless it's been at least PGSTAT_STAT_INTERVAL
829  * msec since we last sent one, or the caller wants to force stats out.
830  */
832  if (!force &&
834  return;
835  last_report = now;
836 
837  /*
838  * Destroy pgStatTabHash before we start invalidating PgStat_TableEntry
839  * entries it points to. (Should we fail partway through the loop below,
840  * it's okay to have removed the hashtable already --- the only
841  * consequence is we'd get multiple entries for the same table in the
842  * pgStatTabList, and that's safe.)
843  */
844  if (pgStatTabHash)
846  pgStatTabHash = NULL;
847 
848  /*
849  * Scan through the TabStatusArray struct(s) to find tables that actually
850  * have counts, and build messages to send. We have to separate shared
851  * relations from regular ones because the databaseid field in the message
852  * header has to depend on that.
853  */
854  regular_msg.m_databaseid = MyDatabaseId;
855  shared_msg.m_databaseid = InvalidOid;
856  regular_msg.m_nentries = 0;
857  shared_msg.m_nentries = 0;
858 
859  for (tsa = pgStatTabList; tsa != NULL; tsa = tsa->tsa_next)
860  {
861  for (i = 0; i < tsa->tsa_used; i++)
862  {
863  PgStat_TableStatus *entry = &tsa->tsa_entries[i];
864  PgStat_MsgTabstat *this_msg;
865  PgStat_TableEntry *this_ent;
866 
867  /* Shouldn't have any pending transaction-dependent counts */
868  Assert(entry->trans == NULL);
869 
870  /*
871  * Ignore entries that didn't accumulate any actual counts, such
872  * as indexes that were opened by the planner but not used.
873  */
874  if (memcmp(&entry->t_counts, &all_zeroes,
875  sizeof(PgStat_TableCounts)) == 0)
876  continue;
877 
878  /*
879  * OK, insert data into the appropriate message, and send if full.
880  */
881  this_msg = entry->t_shared ? &shared_msg : &regular_msg;
882  this_ent = &this_msg->m_entry[this_msg->m_nentries];
883  this_ent->t_id = entry->t_id;
884  memcpy(&this_ent->t_counts, &entry->t_counts,
885  sizeof(PgStat_TableCounts));
886  if (++this_msg->m_nentries >= PGSTAT_NUM_TABENTRIES)
887  {
888  pgstat_send_tabstat(this_msg);
889  this_msg->m_nentries = 0;
890  }
891  }
892  /* zero out PgStat_TableStatus structs after use */
893  MemSet(tsa->tsa_entries, 0,
894  tsa->tsa_used * sizeof(PgStat_TableStatus));
895  tsa->tsa_used = 0;
896  }
897 
898  /*
899  * Send partial messages. Make sure that any pending xact commit/abort
900  * gets counted, even if there are no table stats to send.
901  */
902  if (regular_msg.m_nentries > 0 ||
904  pgstat_send_tabstat(&regular_msg);
905  if (shared_msg.m_nentries > 0)
906  pgstat_send_tabstat(&shared_msg);
907 
908  /* Now, send function statistics */
910 }
void hash_destroy(HTAB *hashp)
Definition: dynahash.c:815
int tsa_used
Definition: pgstat.c:172
static int pgStatXactCommit
Definition: pgstat.c:220
int64 TimestampTz
Definition: timestamp.h:39
#define MemSet(start, val, len)
Definition: c.h:971
struct TabStatusArray * tsa_next
Definition: pgstat.c:171
PgStat_TableCounts t_counts
Definition: pgstat.h:159
bool TimestampDifferenceExceeds(TimestampTz start_time, TimestampTz stop_time, int msec)
Definition: timestamp.c:1682
static void pgstat_send_tabstat(PgStat_MsgTabstat *tsmsg)
Definition: pgstat.c:916
static HTAB * pgStatTabHash
Definition: pgstat.c:190
static int pgStatXactRollback
Definition: pgstat.c:221
#define PGSTAT_STAT_INTERVAL
Definition: pgstat.c:76
PgStat_TableStatus tsa_entries[TABSTAT_QUANTUM]
Definition: pgstat.c:173
#define PGSTAT_NUM_TABENTRIES
Definition: pgstat.h:264
Oid MyDatabaseId
Definition: globals.c:85
static TabStatusArray * pgStatTabList
Definition: pgstat.c:176
#define InvalidOid
Definition: postgres_ext.h:36
static bool have_function_stats
Definition: pgstat.c:202
TimestampTz GetCurrentTransactionStopTimestamp(void)
Definition: xact.c:803
#define Assert(condition)
Definition: c.h:738
PgStat_TableCounts t_counts
Definition: pgstat.h:256
struct PgStat_TableXactStatus * trans
Definition: pgstat.h:158
PgStat_TableEntry m_entry[PGSTAT_NUM_TABENTRIES]
Definition: pgstat.h:277
int i
static void pgstat_send_funcstats(void)
Definition: pgstat.c:960
Datum now(PG_FUNCTION_ARGS)
Definition: timestamp.c:1547

◆ pgstat_report_tempfile()

void pgstat_report_tempfile ( size_t  filesize)

Definition at line 1562 of file pgstat.c.

References PgStat_MsgTempFile::m_databaseid, PgStat_MsgTempFile::m_filesize, PgStat_MsgTempFile::m_hdr, MyDatabaseId, PGINVALID_SOCKET, PGSTAT_MTYPE_TEMPFILE, pgstat_send(), pgstat_setheader(), pgstat_track_counts, and pgStatSock.

Referenced by ReportTemporaryFileUsage().

1563 {
1564  PgStat_MsgTempFile msg;
1565 
1567  return;
1568 
1570  msg.m_databaseid = MyDatabaseId;
1571  msg.m_filesize = filesize;
1572  pgstat_send(&msg, sizeof(msg));
1573 }
static void pgstat_send(void *msg, int len)
Definition: pgstat.c:4252
NON_EXEC_STATIC pgsocket pgStatSock
Definition: pgstat.c:148
PgStat_MsgHdr m_hdr
Definition: pgstat.h:444
size_t m_filesize
Definition: pgstat.h:447
bool pgstat_track_counts
Definition: pgstat.c:125
#define PGINVALID_SOCKET
Definition: port.h:33
Oid MyDatabaseId
Definition: globals.c:85
static void pgstat_setheader(PgStat_MsgHdr *hdr, StatMsgType mtype)
Definition: pgstat.c:4239

◆ pgstat_report_vacuum()

void pgstat_report_vacuum ( Oid  tableoid,
bool  shared,
PgStat_Counter  livetuples,
PgStat_Counter  deadtuples 
)

Definition at line 1406 of file pgstat.c.

References GetCurrentTimestamp(), InvalidOid, IsAutoVacuumWorkerProcess(), PgStat_MsgVacuum::m_autovacuum, PgStat_MsgVacuum::m_databaseid, PgStat_MsgVacuum::m_dead_tuples, PgStat_MsgVacuum::m_hdr, PgStat_MsgVacuum::m_live_tuples, PgStat_MsgVacuum::m_tableoid, PgStat_MsgVacuum::m_vacuumtime, MyDatabaseId, PGINVALID_SOCKET, PGSTAT_MTYPE_VACUUM, pgstat_send(), pgstat_setheader(), pgstat_track_counts, and pgStatSock.

Referenced by heap_vacuum_rel().

1408 {
1409  PgStat_MsgVacuum msg;
1410 
1412  return;
1413 
1415  msg.m_databaseid = shared ? InvalidOid : MyDatabaseId;
1416  msg.m_tableoid = tableoid;
1419  msg.m_live_tuples = livetuples;
1420  msg.m_dead_tuples = deadtuples;
1421  pgstat_send(&msg, sizeof(msg));
1422 }
static void pgstat_send(void *msg, int len)
Definition: pgstat.c:4252
PgStat_Counter m_dead_tuples
Definition: pgstat.h:372
TimestampTz m_vacuumtime
Definition: pgstat.h:370
NON_EXEC_STATIC pgsocket pgStatSock
Definition: pgstat.c:148
PgStat_Counter m_live_tuples
Definition: pgstat.h:371
TimestampTz GetCurrentTimestamp(void)
Definition: timestamp.c:1583
Oid m_databaseid
Definition: pgstat.h:367
bool m_autovacuum
Definition: pgstat.h:369
bool pgstat_track_counts
Definition: pgstat.c:125
bool IsAutoVacuumWorkerProcess(void)
Definition: autovacuum.c:3302
#define PGINVALID_SOCKET
Definition: port.h:33
Oid MyDatabaseId
Definition: globals.c:85
#define InvalidOid
Definition: postgres_ext.h:36
static void pgstat_setheader(PgStat_MsgHdr *hdr, StatMsgType mtype)
Definition: pgstat.c:4239
PgStat_MsgHdr m_hdr
Definition: pgstat.h:366

◆ pgstat_report_wait_end()

static void pgstat_report_wait_end ( void  )
inlinestatic

Definition at line 1330 of file pgstat.h.

References MyProc, pgstat_track_activities, and PGPROC::wait_event_info.

Referenced by AbortSubTransaction(), AbortTransaction(), AddToDataDirLockFile(), ApplyLogicalMappingFile(), assign_xlog_sync_method(), AutoVacLauncherMain(), BackgroundWriterMain(), BootStrapXLOG(), CheckpointerMain(), CheckPointLogicalRewriteHeap(), copy_file(), CreateLockFile(), do_pg_stop_backup(), dsm_impl_mmap(), dsm_impl_op(), FilePrefetch(), FileRead(), FileSync(), FileTruncate(), FileWrite(), FileWriteback(), heap_xlog_logical_rewrite(), issue_xlog_fsync(), load_relmap_file(), LWLockReportWaitEnd(), ProcArrayGroupClearXid(), ReadControlFile(), ReadTwoPhaseFile(), RecheckDataDirLockFile(), recoveryPausesHere(), RecreateTwoPhaseFile(), ReorderBufferSerializeChange(), RestoreSlotFromDisk(), SaveSlotToPath(), SendTimeLineHistory(), ShutdownAuxiliaryProcess(), SimpleLruFlush(), SlruPhysicalReadPage(), SlruPhysicalWritePage(), SnapBuildRestore(), SnapBuildSerialize(), StandbyParamErrorPauseRecovery(), TransactionGroupUpdateXidStatus(), update_controlfile(), vacuum_delay_point(), WaitEventSetWait(), WALRead(), WalSndErrorCleanup(), WalWriterMain(), write_relmap_file(), WriteControlFile(), writeTimeLineHistory(), writeTimeLineHistoryFile(), XLogFileCopy(), XLogFileInit(), XLogPageRead(), and XLogWrite().

1331 {
1332  volatile PGPROC *proc = MyProc;
1333 
1334  if (!pgstat_track_activities || !proc)
1335  return;
1336 
1337  /*
1338  * Since this is a four-byte field which is always read and written as
1339  * four-bytes, updates are atomic.
1340  */
1341  proc->wait_event_info = 0;
1342 }
uint32 wait_event_info
Definition: proc.h:176
PGPROC * MyProc
Definition: proc.c:67
PGDLLIMPORT bool pgstat_track_activities
Definition: pgstat.c:124
Definition: proc.h:95

◆ pgstat_report_wait_start()

static void pgstat_report_wait_start ( uint32  wait_event_info)
inlinestatic

Definition at line 1306 of file pgstat.h.

References MyProc, pgstat_track_activities, and PGPROC::wait_event_info.

Referenced by AddToDataDirLockFile(), ApplyLogicalMappingFile(), assign_xlog_sync_method(), BootStrapXLOG(), CheckPointLogicalRewriteHeap(), copy_file(), CreateLockFile(), do_pg_stop_backup(), dsm_impl_mmap(), dsm_impl_op(), FilePrefetch(), FileRead(), FileSync(), FileTruncate(), FileWrite(), FileWriteback(), heap_xlog_logical_rewrite(), issue_xlog_fsync(), load_relmap_file(), LWLockReportWaitStart(), ProcArrayGroupClearXid(), ReadControlFile(), ReadTwoPhaseFile(), RecheckDataDirLockFile(), recoveryPausesHere(), RecreateTwoPhaseFile(), ReorderBufferSerializeChange(), RestoreSlotFromDisk(), SaveSlotToPath(), SendTimeLineHistory(), SimpleLruFlush(), SlruPhysicalReadPage(), SlruPhysicalWritePage(), SnapBuildRestore(), SnapBuildSerialize(), StandbyParamErrorPauseRecovery(), TransactionGroupUpdateXidStatus(), update_controlfile(), vacuum_delay_point(), WaitEventSetWait(), WALRead(), write_relmap_file(), WriteControlFile(), writeTimeLineHistory(), writeTimeLineHistoryFile(), XLogFileCopy(), XLogFileInit(), XLogPageRead(), and XLogWrite().

1307 {
1308  volatile PGPROC *proc = MyProc;
1309 
1310  if (!pgstat_track_activities || !proc)
1311  return;
1312 
1313  /*
1314  * Since this is a four-byte field which is always read and written as
1315  * four-bytes, updates are atomic.
1316  */
1317  proc->wait_event_info = wait_event_info;
1318 }
uint32 wait_event_info
Definition: proc.h:176
PGPROC * MyProc
Definition: proc.c:67
PGDLLIMPORT bool pgstat_track_activities
Definition: pgstat.c:124
Definition: proc.h:95

◆ pgstat_report_xact_timestamp()

void pgstat_report_xact_timestamp ( TimestampTz  tstamp)

Definition at line 3264 of file pgstat.c.

References MyBEEntry, PGSTAT_BEGIN_WRITE_ACTIVITY, PGSTAT_END_WRITE_ACTIVITY, pgstat_track_activities, and PgBackendStatus::st_xact_start_timestamp.

Referenced by AbortTransaction(), CommitTransaction(), PrepareTransaction(), and StartTransaction().

3265 {
3266  volatile PgBackendStatus *beentry = MyBEEntry;
3267 
3268  if (!pgstat_track_activities || !beentry)
3269  return;
3270 
3271  /*
3272  * Update my status entry, following the protocol of bumping
3273  * st_changecount before and after. We use a volatile pointer here to
3274  * ensure the compiler doesn't try to get cute.
3275  */
3276  PGSTAT_BEGIN_WRITE_ACTIVITY(beentry);
3277 
3278  beentry->st_xact_start_timestamp = tstamp;
3279 
3280  PGSTAT_END_WRITE_ACTIVITY(beentry);
3281 }
static PgBackendStatus * MyBEEntry
Definition: pgstat.c:2631
#define PGSTAT_END_WRITE_ACTIVITY(beentry)
Definition: pgstat.h:1126
TimestampTz st_xact_start_timestamp
Definition: pgstat.h:1043
bool pgstat_track_activities
Definition: pgstat.c:124
#define PGSTAT_BEGIN_WRITE_ACTIVITY(beentry)
Definition: pgstat.h:1119

◆ pgstat_reset_all()

void pgstat_reset_all ( void  )

Definition at line 682 of file pgstat.c.

References Assert, av, lengthof, pgstat_reset_remove_files(), pgstat_stat_directory, and PGSTAT_STAT_PERMANENT_DIRECTORY.

Referenced by StartupXLOG().

683 {
686 }
#define PGSTAT_STAT_PERMANENT_DIRECTORY
Definition: pgstat.h:29
char * pgstat_stat_directory
Definition: pgstat.c:133
static void pgstat_reset_remove_files(const char *directory)
Definition: pgstat.c:634

◆ pgstat_reset_counters()

void pgstat_reset_counters ( void  )

Definition at line 1307 of file pgstat.c.

References PgStat_MsgResetcounter::m_databaseid, PgStat_MsgResetcounter::m_hdr, MyDatabaseId, PGINVALID_SOCKET, PGSTAT_MTYPE_RESETCOUNTER, pgstat_send(), pgstat_setheader(), and pgStatSock.

Referenced by pg_stat_reset().

1308 {
1310 
1312  return;
1313 
1315  msg.m_databaseid = MyDatabaseId;
1316  pgstat_send(&msg, sizeof(msg));
1317 }
static void pgstat_send(void *msg, int len)
Definition: pgstat.c:4252
NON_EXEC_STATIC pgsocket pgStatSock
Definition: pgstat.c:148
PgStat_MsgHdr m_hdr
Definition: pgstat.h:318
#define PGINVALID_SOCKET
Definition: port.h:33
Oid MyDatabaseId
Definition: globals.c:85
static void pgstat_setheader(PgStat_MsgHdr *hdr, StatMsgType mtype)
Definition: pgstat.c:4239

◆ pgstat_reset_shared_counters()

void pgstat_reset_shared_counters ( const char *  )

Definition at line 1329 of file pgstat.c.

References ereport, errcode(), errhint(), errmsg(), ERROR, PgStat_MsgResetsharedcounter::m_hdr, PgStat_MsgResetsharedcounter::m_resettarget, PGINVALID_SOCKET, PGSTAT_MTYPE_RESETSHAREDCOUNTER, pgstat_send(), pgstat_setheader(), pgStatSock, RESET_ARCHIVER, and RESET_BGWRITER.

Referenced by pg_stat_reset_shared().

1330 {
1332 
1334  return;
1335 
1336  if (strcmp(target, "archiver") == 0)
1338  else if (strcmp(target, "bgwriter") == 0)
1340  else
1341  ereport(ERROR,
1342  (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1343  errmsg("unrecognized reset target: \"%s\"", target),
1344  errhint("Target must be \"archiver\" or \"bgwriter\".")));
1345 
1347  pgstat_send(&msg, sizeof(msg));
1348 }
static void pgstat_send(void *msg, int len)
Definition: pgstat.c:4252
int errhint(const char *fmt,...)
Definition: elog.c:1071
NON_EXEC_STATIC pgsocket pgStatSock
Definition: pgstat.c:148
int errcode(int sqlerrcode)
Definition: elog.c:610
#define ERROR
Definition: elog.h:43
#define PGINVALID_SOCKET
Definition: port.h:33
PgStat_Shared_Reset_Target m_resettarget
Definition: pgstat.h:330
#define ereport(elevel,...)
Definition: elog.h:144
static void pgstat_setheader(PgStat_MsgHdr *hdr, StatMsgType mtype)
Definition: pgstat.c:4239
int errmsg(const char *fmt,...)
Definition: elog.c:824

◆ pgstat_reset_single_counter()

void pgstat_reset_single_counter ( Oid  objectid,
PgStat_Single_Reset_Type  type 
)