From 1f55402be2f1e4bd015432a11640cfe72e44957c Mon Sep 17 00:00:00 2001 From: Melanie Plageman Date: Wed, 21 Feb 2024 20:28:27 -0500 Subject: [PATCH v6 3/6] Add LSNTimeStream to PgStat_WalStats Add a globally maintained instance of an LSNTimeStream to PgStat_WalStats and a utility function to insert new values. --- src/backend/utils/activity/pgstat_wal.c | 10 ++++++++++ src/include/pgstat.h | 4 ++++ 2 files changed, 14 insertions(+) diff --git a/src/backend/utils/activity/pgstat_wal.c b/src/backend/utils/activity/pgstat_wal.c index affab8437c8..c1c3da22b2f 100644 --- a/src/backend/utils/activity/pgstat_wal.c +++ b/src/backend/utils/activity/pgstat_wal.c @@ -515,3 +515,13 @@ stop: result = (double) (lsn - start.lsn) / lsns_elapsed * time_elapsed + start.time; return Max(result, 0); } + +void +pgstat_wal_update_lsntime_stream(TimestampTz time, XLogRecPtr lsn) +{ + PgStatShared_Wal *stats_shmem = &pgStatLocal.shmem->wal; + + LWLockAcquire(&stats_shmem->lock, LW_EXCLUSIVE); + lsntime_insert(&stats_shmem->stats.stream, time, lsn); + LWLockRelease(&stats_shmem->lock); +} diff --git a/src/include/pgstat.h b/src/include/pgstat.h index 825cdc8f73a..667f2b93cad 100644 --- a/src/include/pgstat.h +++ b/src/include/pgstat.h @@ -470,6 +470,7 @@ typedef struct PgStat_WalStats PgStat_Counter wal_sync; PgStat_Counter wal_write_time; PgStat_Counter wal_sync_time; + LSNTimeStream stream; TimestampTz stat_reset_timestamp; } PgStat_WalStats; @@ -752,6 +753,9 @@ extern void pgstat_execute_transactional_drops(int ndrops, struct xl_xact_stats_ extern void pgstat_report_wal(bool force); extern PgStat_WalStats *pgstat_fetch_stat_wal(void); +/* Helpers for maintaining the LSNTimeStream */ +extern void pgstat_wal_update_lsntime_stream(TimestampTz time, XLogRecPtr lsn); + /* * Variables in pgstat.c -- 2.34.1