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 52 : pgstat_report_archiver(const char *xlog, bool failed) 29 : { 30 52 : PgStatShared_Archiver *stats_shmem = &pgStatLocal.shmem->archiver; 31 52 : TimestampTz now = GetCurrentTimestamp(); 32 : 33 52 : pgstat_begin_changecount_write(&stats_shmem->changecount); 34 : 35 52 : if (failed) 36 : { 37 2 : ++stats_shmem->stats.failed_count; 38 2 : memcpy(&stats_shmem->stats.last_failed_wal, xlog, 39 : sizeof(stats_shmem->stats.last_failed_wal)); 40 2 : stats_shmem->stats.last_failed_timestamp = now; 41 : } 42 : else 43 : { 44 50 : ++stats_shmem->stats.archived_count; 45 50 : memcpy(&stats_shmem->stats.last_archived_wal, xlog, 46 : sizeof(stats_shmem->stats.last_archived_wal)); 47 50 : stats_shmem->stats.last_archived_timestamp = now; 48 : } 49 : 50 52 : pgstat_end_changecount_write(&stats_shmem->changecount); 51 52 : } 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 44 : pgstat_fetch_stat_archiver(void) 59 : { 60 44 : pgstat_snapshot_fixed(PGSTAT_KIND_ARCHIVER); 61 : 62 44 : return &pgStatLocal.snapshot.archiver; 63 : } 64 : 65 : void 66 888 : pgstat_archiver_reset_all_cb(TimestampTz ts) 67 : { 68 888 : PgStatShared_Archiver *stats_shmem = &pgStatLocal.shmem->archiver; 69 : 70 : /* see explanation above PgStatShared_Archiver for the reset protocol */ 71 888 : LWLockAcquire(&stats_shmem->lock, LW_EXCLUSIVE); 72 888 : pgstat_copy_changecounted_stats(&stats_shmem->reset_offset, 73 888 : &stats_shmem->stats, 74 : sizeof(stats_shmem->stats), 75 : &stats_shmem->changecount); 76 888 : stats_shmem->stats.stat_reset_timestamp = ts; 77 888 : LWLockRelease(&stats_shmem->lock); 78 888 : } 79 : 80 : void 81 2010 : pgstat_archiver_snapshot_cb(void) 82 : { 83 2010 : PgStatShared_Archiver *stats_shmem = &pgStatLocal.shmem->archiver; 84 2010 : PgStat_ArchiverStats *stat_snap = &pgStatLocal.snapshot.archiver; 85 2010 : PgStat_ArchiverStats *reset_offset = &stats_shmem->reset_offset; 86 : PgStat_ArchiverStats reset; 87 : 88 2010 : pgstat_copy_changecounted_stats(stat_snap, 89 2010 : &stats_shmem->stats, 90 : sizeof(stats_shmem->stats), 91 : &stats_shmem->changecount); 92 : 93 2010 : LWLockAcquire(&stats_shmem->lock, LW_SHARED); 94 2010 : memcpy(&reset, reset_offset, sizeof(stats_shmem->stats)); 95 2010 : LWLockRelease(&stats_shmem->lock); 96 : 97 : /* compensate by reset offsets */ 98 2010 : if (stat_snap->archived_count == reset.archived_count) 99 : { 100 1974 : stat_snap->last_archived_wal[0] = 0; 101 1974 : stat_snap->last_archived_timestamp = 0; 102 : } 103 2010 : stat_snap->archived_count -= reset.archived_count; 104 : 105 2010 : if (stat_snap->failed_count == reset.failed_count) 106 : { 107 1994 : stat_snap->last_failed_wal[0] = 0; 108 1994 : stat_snap->last_failed_timestamp = 0; 109 : } 110 2010 : stat_snap->failed_count -= reset.failed_count; 111 2010 : }