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