TLA  Line data    Source code

       1                 : /* -------------------------------------------------------------------------
       2                 :  *
       3                 :  * pgstat_archiver.c
       4                 :  *    Implementation of archiver statistics.
       5                 :  *
       6                 :  * This file contains the implementation of archiver statistics. It is kept
       7                 :  * separate from pgstat.c to enforce the line between the statistics access /
       8                 :  * storage implementation and the details about individual types of
       9                 :  * statistics.
      10                 :  *
      11                 :  * Copyright (c) 2001-2023, PostgreSQL Global Development Group
      12                 :  *
      13                 :  * IDENTIFICATION
      14                 :  *    src/backend/utils/activity/pgstat_archiver.c
      15                 :  * -------------------------------------------------------------------------
      16                 :  */
      17                 : 
      18                 : #include "postgres.h"
      19                 : 
      20                 : #include "utils/pgstat_internal.h"
      21                 : #include "utils/timestamp.h"
      22                 : 
      23                 : 
      24                 : /*
      25                 :  * Report archiver statistics
      26                 :  */
      27                 : void
      28 CBC          25 : pgstat_report_archiver(const char *xlog, bool failed)
      29                 : {
      30              25 :     PgStatShared_Archiver *stats_shmem = &pgStatLocal.shmem->archiver;
      31              25 :     TimestampTz now = GetCurrentTimestamp();
      32                 : 
      33              25 :     pgstat_begin_changecount_write(&stats_shmem->changecount);
      34                 : 
      35              25 :     if (failed)
      36                 :     {
      37               1 :         ++stats_shmem->stats.failed_count;
      38               1 :         memcpy(&stats_shmem->stats.last_failed_wal, xlog,
      39                 :                sizeof(stats_shmem->stats.last_failed_wal));
      40               1 :         stats_shmem->stats.last_failed_timestamp = now;
      41                 :     }
      42                 :     else
      43                 :     {
      44              24 :         ++stats_shmem->stats.archived_count;
      45              24 :         memcpy(&stats_shmem->stats.last_archived_wal, xlog,
      46                 :                sizeof(stats_shmem->stats.last_archived_wal));
      47              24 :         stats_shmem->stats.last_archived_timestamp = now;
      48                 :     }
      49                 : 
      50              25 :     pgstat_end_changecount_write(&stats_shmem->changecount);
      51              25 : }
      52                 : 
      53                 : /*
      54                 :  * Support function for the SQL-callable pgstat* functions. Returns
      55                 :  * a pointer to the archiver statistics struct.
      56                 :  */
      57                 : PgStat_ArchiverStats *
      58              22 : pgstat_fetch_stat_archiver(void)
      59                 : {
      60              22 :     pgstat_snapshot_fixed(PGSTAT_KIND_ARCHIVER);
      61                 : 
      62              22 :     return &pgStatLocal.snapshot.archiver;
      63                 : }
      64                 : 
      65                 : void
      66             441 : pgstat_archiver_reset_all_cb(TimestampTz ts)
      67                 : {
      68             441 :     PgStatShared_Archiver *stats_shmem = &pgStatLocal.shmem->archiver;
      69                 : 
      70                 :     /* see explanation above PgStatShared_Archiver for the reset protocol */
      71             441 :     LWLockAcquire(&stats_shmem->lock, LW_EXCLUSIVE);
      72             441 :     pgstat_copy_changecounted_stats(&stats_shmem->reset_offset,
      73             441 :                                     &stats_shmem->stats,
      74                 :                                     sizeof(stats_shmem->stats),
      75                 :                                     &stats_shmem->changecount);
      76             441 :     stats_shmem->stats.stat_reset_timestamp = ts;
      77             441 :     LWLockRelease(&stats_shmem->lock);
      78             441 : }
      79                 : 
      80                 : void
      81            1014 : pgstat_archiver_snapshot_cb(void)
      82                 : {
      83            1014 :     PgStatShared_Archiver *stats_shmem = &pgStatLocal.shmem->archiver;
      84            1014 :     PgStat_ArchiverStats *stat_snap = &pgStatLocal.snapshot.archiver;
      85            1014 :     PgStat_ArchiverStats *reset_offset = &stats_shmem->reset_offset;
      86                 :     PgStat_ArchiverStats reset;
      87                 : 
      88            1014 :     pgstat_copy_changecounted_stats(stat_snap,
      89            1014 :                                     &stats_shmem->stats,
      90                 :                                     sizeof(stats_shmem->stats),
      91                 :                                     &stats_shmem->changecount);
      92                 : 
      93            1014 :     LWLockAcquire(&stats_shmem->lock, LW_SHARED);
      94            1014 :     memcpy(&reset, reset_offset, sizeof(stats_shmem->stats));
      95            1014 :     LWLockRelease(&stats_shmem->lock);
      96                 : 
      97                 :     /* compensate by reset offsets */
      98            1014 :     if (stat_snap->archived_count == reset.archived_count)
      99                 :     {
     100             995 :         stat_snap->last_archived_wal[0] = 0;
     101             995 :         stat_snap->last_archived_timestamp = 0;
     102                 :     }
     103            1014 :     stat_snap->archived_count -= reset.archived_count;
     104                 : 
     105            1014 :     if (stat_snap->failed_count == reset.failed_count)
     106                 :     {
     107            1006 :         stat_snap->last_failed_wal[0] = 0;
     108            1006 :         stat_snap->last_failed_timestamp = 0;
     109                 :     }
     110            1014 :     stat_snap->failed_count -= reset.failed_count;
     111            1014 : }