pgstat: rename some pgstat_send_* functions to pgstat_report_*.

Only the pgstat_send_* functions that are called from outside pgstat*.c are
renamed (the rest will go away). This is done separately from the - quite
large - shared memory statistics patch to make review easier.

Author: Andres Freund <andres@anarazel.de>
Reviewed-By: Kyotaro Horiguchi <horikyota.ntt@gmail.com>
Discussion: https://postgr.es/m/20220404041516.cctrvpadhuriawlq@alap3.anarazel.de
This commit is contained in:
Andres Freund 2022-04-06 14:08:57 -07:00
parent dbafe127bb
commit cc96373cf3
10 changed files with 23 additions and 23 deletions

View File

@ -241,7 +241,7 @@ BackgroundWriterMain(void)
can_hibernate = BgBufferSync(&wb_context); can_hibernate = BgBufferSync(&wb_context);
/* Report pending statistics to the cumulative stats system */ /* Report pending statistics to the cumulative stats system */
pgstat_send_bgwriter(); pgstat_report_bgwriter();
if (FirstCallSinceLastCheckpoint()) if (FirstCallSinceLastCheckpoint())
{ {

View File

@ -493,8 +493,8 @@ CheckpointerMain(void)
CheckArchiveTimeout(); CheckArchiveTimeout();
/* Report pending statistics to the cumulative stats system */ /* Report pending statistics to the cumulative stats system */
pgstat_send_checkpointer(); pgstat_report_checkpointer();
pgstat_send_wal(true); pgstat_report_wal(true);
/* /*
* If any checkpoint flags have been set, redo the loop to handle the * If any checkpoint flags have been set, redo the loop to handle the
@ -571,8 +571,8 @@ HandleCheckpointerInterrupts(void)
*/ */
PendingCheckpointerStats.m_requested_checkpoints++; PendingCheckpointerStats.m_requested_checkpoints++;
ShutdownXLOG(0, 0); ShutdownXLOG(0, 0);
pgstat_send_checkpointer(); pgstat_report_checkpointer();
pgstat_send_wal(true); pgstat_report_wal(true);
/* Normal exit from the checkpointer is here */ /* Normal exit from the checkpointer is here */
proc_exit(0); /* done */ proc_exit(0); /* done */
@ -715,7 +715,7 @@ CheckpointWriteDelay(int flags, double progress)
CheckArchiveTimeout(); CheckArchiveTimeout();
/* Report interim statistics to the cumulative stats system */ /* Report interim statistics to the cumulative stats system */
pgstat_send_checkpointer(); pgstat_report_checkpointer();
/* /*
* This sleep used to be connected to bgwriter_delay, typically 200ms. * This sleep used to be connected to bgwriter_delay, typically 200ms.

View File

@ -480,7 +480,7 @@ pgarch_ArchiverCopyLoop(void)
* Tell the cumulative stats system about the WAL file that we * Tell the cumulative stats system about the WAL file that we
* successfully archived * successfully archived
*/ */
pgstat_send_archiver(xlog, false); pgstat_report_archiver(xlog, false);
break; /* out of inner retry loop */ break; /* out of inner retry loop */
} }
@ -490,7 +490,7 @@ pgarch_ArchiverCopyLoop(void)
* Tell the cumulative stats system about the WAL file that we * Tell the cumulative stats system about the WAL file that we
* failed to archive * failed to archive
*/ */
pgstat_send_archiver(xlog, true); pgstat_report_archiver(xlog, true);
if (++failures >= NUM_ARCHIVE_RETRIES) if (++failures >= NUM_ARCHIVE_RETRIES)
{ {

View File

@ -793,7 +793,7 @@ pgstat_report_stat(bool disconnect)
pgstat_send_funcstats(); pgstat_send_funcstats();
/* Send WAL statistics */ /* Send WAL statistics */
pgstat_send_wal(true); pgstat_report_wal(true);
/* Finally send SLRU statistics */ /* Finally send SLRU statistics */
pgstat_send_slru(); pgstat_send_slru();

View File

@ -258,7 +258,7 @@ WalWriterMain(void)
left_till_hibernate--; left_till_hibernate--;
/* report pending statistics to the cumulative stats system */ /* report pending statistics to the cumulative stats system */
pgstat_send_wal(false); pgstat_report_wal(false);
/* /*
* Sleep until we are signaled or WalWriterDelay has elapsed. If we * Sleep until we are signaled or WalWriterDelay has elapsed. If we
@ -297,11 +297,11 @@ HandleWalWriterInterrupts(void)
/* /*
* Force reporting remaining WAL statistics at process exit. * Force reporting remaining WAL statistics at process exit.
* *
* Since pgstat_send_wal is invoked with 'force' is false in main loop * Since pgstat_report_wal is invoked with 'force' is false in main loop
* to avoid overloading the cumulative stats system, there may exist * to avoid overloading the cumulative stats system, there may exist
* unreported stats counters for the WAL writer. * unreported stats counters for the WAL writer.
*/ */
pgstat_send_wal(true); pgstat_report_wal(true);
proc_exit(0); proc_exit(0);
} }

View File

@ -25,7 +25,7 @@
* Report archiver statistics * Report archiver statistics
*/ */
void void
pgstat_send_archiver(const char *xlog, bool failed) pgstat_report_archiver(const char *xlog, bool failed)
{ {
PgStat_MsgArchiver msg; PgStat_MsgArchiver msg;

View File

@ -32,7 +32,7 @@ PgStat_MsgBgWriter PendingBgWriterStats;
* Report bgwriter statistics * Report bgwriter statistics
*/ */
void void
pgstat_send_bgwriter(void) pgstat_report_bgwriter(void)
{ {
/* We assume this initializes to zeroes */ /* We assume this initializes to zeroes */
static const PgStat_MsgBgWriter all_zeroes; static const PgStat_MsgBgWriter all_zeroes;

View File

@ -32,7 +32,7 @@ PgStat_MsgCheckpointer PendingCheckpointerStats;
* Report checkpointer statistics * Report checkpointer statistics
*/ */
void void
pgstat_send_checkpointer(void) pgstat_report_checkpointer(void)
{ {
/* We assume this initializes to zeroes */ /* We assume this initializes to zeroes */
static const PgStat_MsgCheckpointer all_zeroes; static const PgStat_MsgCheckpointer all_zeroes;

View File

@ -31,8 +31,8 @@ PgStat_MsgWal WalStats;
/* /*
* WAL usage counters saved from pgWALUsage at the previous call to * WAL usage counters saved from pgWALUsage at the previous call to
* pgstat_send_wal(). This is used to calculate how much WAL usage * pgstat_report_wal(). This is used to calculate how much WAL usage
* happens between pgstat_send_wal() calls, by subtracting * happens between pgstat_report_wal() calls, by subtracting
* the previous counters from the current ones. * the previous counters from the current ones.
*/ */
static WalUsage prevWalUsage; static WalUsage prevWalUsage;
@ -45,7 +45,7 @@ static WalUsage prevWalUsage;
* passed since last one was sent to reach PGSTAT_STAT_INTERVAL. * passed since last one was sent to reach PGSTAT_STAT_INTERVAL.
*/ */
void void
pgstat_send_wal(bool force) pgstat_report_wal(bool force)
{ {
static TimestampTz sendTime = 0; static TimestampTz sendTime = 0;
@ -133,7 +133,7 @@ void
pgstat_wal_initialize(void) pgstat_wal_initialize(void)
{ {
/* /*
* Initialize prevWalUsage with pgWalUsage so that pgstat_send_wal() can * Initialize prevWalUsage with pgWalUsage so that pgstat_report_wal() can
* calculate how much pgWalUsage counters are increased by subtracting * calculate how much pgWalUsage counters are increased by subtracting
* prevWalUsage from pgWalUsage. * prevWalUsage from pgWalUsage.
*/ */

View File

@ -997,21 +997,21 @@ extern PgStat_WalStats *pgstat_fetch_stat_wal(void);
* Functions in pgstat_archiver.c * Functions in pgstat_archiver.c
*/ */
extern void pgstat_send_archiver(const char *xlog, bool failed); extern void pgstat_report_archiver(const char *xlog, bool failed);
/* /*
* Functions in pgstat_bgwriter.c * Functions in pgstat_bgwriter.c
*/ */
extern void pgstat_send_bgwriter(void); extern void pgstat_report_bgwriter(void);
/* /*
* Functions in pgstat_checkpointer.c * Functions in pgstat_checkpointer.c
*/ */
extern void pgstat_send_checkpointer(void); extern void pgstat_report_checkpointer(void);
/* /*
@ -1165,7 +1165,7 @@ extern void PostPrepare_PgStat(void);
* Functions in pgstat_wal.c * Functions in pgstat_wal.c
*/ */
extern void pgstat_send_wal(bool force); extern void pgstat_report_wal(bool force);
/* /*