PostgreSQL Source Code  git master
pgstat_internal.h
Go to the documentation of this file.
1 /* ----------
2  * pgstat_internal.h
3  *
4  * Definitions for the PostgreSQL cumulative statistics system that should
5  * only be needed by files implementing statistics support (rather than ones
6  * reporting / querying stats).
7  *
8  * Copyright (c) 2001-2023, PostgreSQL Global Development Group
9  *
10  * src/include/utils/pgstat_internal.h
11  * ----------
12  */
13 #ifndef PGSTAT_INTERNAL_H
14 #define PGSTAT_INTERNAL_H
15 
16 
17 #include "common/hashfn.h"
18 #include "lib/dshash.h"
19 #include "lib/ilist.h"
20 #include "pgstat.h"
21 #include "storage/lwlock.h"
22 #include "utils/dsa.h"
23 
24 
25 /*
26  * Types related to shared memory storage of statistics.
27  *
28  * Per-object statistics are stored in the "shared stats" hashtable. That
29  * table's entries (PgStatShared_HashEntry) contain a pointer to the actual stats
30  * data for the object (the size of the stats data varies depending on the
31  * kind of stats). The table is keyed by PgStat_HashKey.
32  *
33  * Once a backend has a reference to a shared stats entry, it increments the
34  * entry's refcount. Even after stats data is dropped (e.g., due to a DROP
35  * TABLE), the entry itself can only be deleted once all references have been
36  * released.
37  *
38  * These refcounts, in combination with a backend local hashtable
39  * (pgStatEntryRefHash, with entries pointing to PgStat_EntryRef) in front of
40  * the shared hash table, mean that most stats work can happen without
41  * touching the shared hash table, reducing contention.
42  *
43  * Once there are pending stats updates for a table PgStat_EntryRef->pending
44  * is allocated to contain a working space for as-of-yet-unapplied stats
45  * updates. Once the stats are flushed, PgStat_EntryRef->pending is freed.
46  *
47  * Each stat kind in the shared hash table has a fixed member
48  * PgStatShared_Common as the first element.
49  */
50 
51 /* struct for shared statistics hash entry key. */
52 typedef struct PgStat_HashKey
53 {
54  PgStat_Kind kind; /* statistics entry kind */
55  Oid dboid; /* database ID. InvalidOid for shared objects. */
56  Oid objoid; /* object ID, either table or function. */
58 
59 /*
60  * Shared statistics hash entry. Doesn't itself contain any stats, but points
61  * to them (with ->body). That allows the stats entries themselves to be of
62  * variable size.
63  */
64 typedef struct PgStatShared_HashEntry
65 {
66  PgStat_HashKey key; /* hash key */
67 
68  /*
69  * If dropped is set, backends need to release their references so that
70  * the memory for the entry can be freed. No new references may be made
71  * once marked as dropped.
72  */
73  bool dropped;
74 
75  /*
76  * Refcount managing lifetime of the entry itself (as opposed to the
77  * dshash entry pointing to it). The stats lifetime has to be separate
78  * from the hash table entry lifetime because we allow backends to point
79  * to a stats entry without holding a hash table lock (and some other
80  * reasons).
81  *
82  * As long as the entry is not dropped, 1 is added to the refcount
83  * representing that the entry should not be dropped. In addition each
84  * backend that has a reference to the entry needs to increment the
85  * refcount as long as it does.
86  *
87  * May only be incremented / decremented while holding at least a shared
88  * lock on the dshash partition containing the entry. It needs to be an
89  * atomic variable because multiple backends can increment the refcount
90  * with just a shared lock.
91  *
92  * When the refcount reaches 0 the entry needs to be freed.
93  */
95 
96  /*
97  * Pointer to shared stats. The stats entry always starts with
98  * PgStatShared_Common, embedded in a larger struct containing the
99  * PgStat_Kind specific stats fields.
100  */
103 
104 /*
105  * Common header struct for PgStatShm_Stat*Entry.
106  */
107 typedef struct PgStatShared_Common
108 {
109  uint32 magic; /* just a validity cross-check */
110  /* lock protecting stats contents (i.e. data following the header) */
113 
114 /*
115  * A backend local reference to a shared stats entry. As long as at least one
116  * such reference exists, the shared stats entry will not be released.
117  *
118  * If there are pending stats update to the shared stats, these are stored in
119  * ->pending.
120  */
121 typedef struct PgStat_EntryRef
122 {
123  /*
124  * Pointer to the PgStatShared_HashEntry entry in the shared stats
125  * hashtable.
126  */
128 
129  /*
130  * Pointer to the stats data (i.e. PgStatShared_HashEntry->body), resolved
131  * as a local pointer, to avoid repeated dsa_get_address() calls.
132  */
134 
135  /*
136  * Pending statistics data that will need to be flushed to shared memory
137  * stats eventually. Each stats kind utilizing pending data defines what
138  * format its pending data has and needs to provide a
139  * PgStat_KindInfo->flush_pending_cb callback to merge pending into shared
140  * stats.
141  */
142  void *pending;
143  dlist_node pending_node; /* membership in pgStatPending list */
145 
146 
147 /*
148  * Some stats changes are transactional. To maintain those, a stack of
149  * PgStat_SubXactStatus entries is maintained, which contain data pertaining
150  * to the current transaction and its active subtransactions.
151  */
152 typedef struct PgStat_SubXactStatus
153 {
154  int nest_level; /* subtransaction nest level */
155 
156  struct PgStat_SubXactStatus *prev; /* higher-level subxact if any */
157 
158  /*
159  * Statistics for transactionally dropped objects need to be
160  * transactionally dropped as well. Collect the stats dropped in the
161  * current (sub-)transaction and only execute the stats drop when we know
162  * if the transaction commits/aborts. To handle replicas and crashes,
163  * stats drops are included in commit / abort records.
164  */
166 
167  /*
168  * Tuple insertion/deletion counts for an open transaction can't be
169  * propagated into PgStat_TableStatus counters until we know if it is
170  * going to commit or abort. Hence, we keep these counts in per-subxact
171  * structs that live in TopTransactionContext. This data structure is
172  * designed on the assumption that subxacts won't usually modify very many
173  * tables.
174  */
175  PgStat_TableXactStatus *first; /* head of list for this subxact */
177 
178 
179 /*
180  * Metadata for a specific kind of statistics.
181  */
182 typedef struct PgStat_KindInfo
183 {
184  /*
185  * Do a fixed number of stats objects exist for this kind of stats (e.g.
186  * bgwriter stats) or not (e.g. tables).
187  */
188  bool fixed_amount:1;
189 
190  /*
191  * Can stats of this kind be accessed from another database? Determines
192  * whether a stats object gets included in stats snapshots.
193  */
195 
196  /*
197  * For variable-numbered stats: Identified on-disk using a name, rather
198  * than PgStat_HashKey. Probably only needed for replication slot stats.
199  */
201 
202  /*
203  * The size of an entry in the shared stats hash table (pointed to by
204  * PgStatShared_HashEntry->body).
205  */
207 
208  /*
209  * The offset/size of statistics inside the shared stats entry. Used when
210  * [de-]serializing statistics to / from disk respectively. Separate from
211  * shared_size because [de-]serialization may not include in-memory state
212  * like lwlocks.
213  */
216 
217  /*
218  * The size of the pending data for this kind. E.g. how large
219  * PgStat_EntryRef->pending is. Used for allocations.
220  *
221  * 0 signals that an entry of this kind should never have a pending entry.
222  */
224 
225  /*
226  * For variable-numbered stats: flush pending stats. Required if pending
227  * data is used.
228  */
229  bool (*flush_pending_cb) (PgStat_EntryRef *sr, bool nowait);
230 
231  /*
232  * For variable-numbered stats: delete pending stats. Optional.
233  */
235 
236  /*
237  * For variable-numbered stats: reset the reset timestamp. Optional.
238  */
240 
241  /*
242  * For variable-numbered stats with named_on_disk. Optional.
243  */
247 
248  /*
249  * For fixed-numbered statistics: Reset All.
250  */
251  void (*reset_all_cb) (TimestampTz ts);
252 
253  /*
254  * For fixed-numbered statistics: Build snapshot for entry
255  */
256  void (*snapshot_cb) (void);
257 
258  /* name of the kind of stats */
259  const char *const name;
261 
262 
263 /*
264  * List of SLRU names that we keep stats for. There is no central registry of
265  * SLRUs, so we use this fixed list instead. The "other" entry is used for
266  * all SLRUs without an explicit entry (e.g. SLRUs in extensions).
267  *
268  * This is only defined here so that SLRU_NUM_ELEMENTS is known for later type
269  * definitions.
270  */
271 static const char *const slru_names[] = {
272  "CommitTs",
273  "MultiXactMember",
274  "MultiXactOffset",
275  "Notify",
276  "Serial",
277  "Subtrans",
278  "Xact",
279  "other" /* has to be last */
280 };
281 
282 #define SLRU_NUM_ELEMENTS lengthof(slru_names)
283 
284 
285 /* ----------
286  * Types and definitions for different kinds of fixed-amount stats.
287  *
288  * Single-writer stats use the changecount mechanism to achieve low-overhead
289  * writes - they're obviously more performance critical than reads. Check the
290  * definition of struct PgBackendStatus for some explanation of the
291  * changecount mechanism.
292  *
293  * Because the obvious implementation of resetting single-writer stats isn't
294  * compatible with that (another backend needs to write), we don't scribble on
295  * shared stats while resetting. Instead, just record the current counter
296  * values in a copy of the stats data, which is protected by ->lock. See
297  * pgstat_fetch_stat_(archiver|bgwriter|checkpointer) for the reader side.
298  *
299  * The only exception to that is the stat_reset_timestamp in these structs,
300  * which is protected by ->lock, because it has to be written by another
301  * backend while resetting.
302  * ----------
303  */
304 
305 typedef struct PgStatShared_Archiver
306 {
307  /* lock protects ->reset_offset as well as stats->stat_reset_timestamp */
313 
314 typedef struct PgStatShared_BgWriter
315 {
316  /* lock protects ->reset_offset as well as stats->stat_reset_timestamp */
322 
324 {
325  /* lock protects ->reset_offset as well as stats->stat_reset_timestamp */
331 
332 typedef struct PgStatShared_SLRU
333 {
334  /* lock protects ->stats */
338 
339 typedef struct PgStatShared_Wal
340 {
341  /* lock protects ->stats */
345 
346 
347 
348 /* ----------
349  * Types and definitions for different kinds of variable-amount stats.
350  *
351  * Each struct has to start with PgStatShared_Common, containing information
352  * common across the different types of stats. Kind-specific data follows.
353  * ----------
354  */
355 
356 typedef struct PgStatShared_Database
357 {
361 
362 typedef struct PgStatShared_Relation
363 {
367 
368 typedef struct PgStatShared_Function
369 {
373 
375 {
379 
380 typedef struct PgStatShared_ReplSlot
381 {
385 
386 
387 /*
388  * Central shared memory entry for the cumulative stats system.
389  *
390  * Fixed amount stats, the dynamic shared memory hash table for
391  * non-fixed-amount stats, as well as remaining bits and pieces are all
392  * reached from here.
393  */
394 typedef struct PgStat_ShmemControl
395 {
397 
398  /*
399  * Stats for variable-numbered objects are kept in this shared hash table.
400  * See comment above PgStat_Kind for details.
401  */
402  dshash_table_handle hash_handle; /* shared dbstat hash */
403 
404  /* Has the stats system already been shut down? Just a debugging check. */
406 
407  /*
408  * Whenever statistics for dropped objects could not be freed - because
409  * backends still have references - the dropping backend calls
410  * pgstat_request_entry_refs_gc() incrementing this counter. Eventually
411  * that causes backends to run pgstat_gc_entry_refs(), allowing memory to
412  * be reclaimed.
413  */
415 
416  /*
417  * Stats data for fixed-numbered objects.
418  */
425 
426 
427 /*
428  * Cached statistics snapshot
429  */
430 typedef struct PgStat_Snapshot
431 {
433 
434  /* time at which snapshot was taken */
436 
438 
440 
442 
444 
446 
448 
449  /* to free snapshot in bulk */
451  struct pgstat_snapshot_hash *stats;
453 
454 
455 /*
456  * Collection of backend-local stats state.
457  */
458 typedef struct PgStat_LocalState
459 {
463 
464  /* the current statistics snapshot */
467 
468 
469 /*
470  * Inline functions defined further below.
471  */
472 
473 static inline void pgstat_begin_changecount_write(uint32 *cc);
474 static inline void pgstat_end_changecount_write(uint32 *cc);
475 static inline uint32 pgstat_begin_changecount_read(uint32 *cc);
476 static inline bool pgstat_end_changecount_read(uint32 *cc, uint32 cc_before);
477 
478 static inline void pgstat_copy_changecounted_stats(void *dst, void *src, size_t len,
479  uint32 *cc);
480 
481 static inline int pgstat_cmp_hash_key(const void *a, const void *b, size_t size, void *arg);
482 static inline uint32 pgstat_hash_hash_key(const void *d, size_t size, void *arg);
483 static inline size_t pgstat_get_entry_len(PgStat_Kind kind);
484 static inline void *pgstat_get_entry_data(PgStat_Kind kind, PgStatShared_Common *entry);
485 
486 
487 /*
488  * Functions in pgstat.c
489  */
490 
492 
493 #ifdef USE_ASSERT_CHECKING
494 extern void pgstat_assert_is_up(void);
495 #else
496 #define pgstat_assert_is_up() ((void)true)
497 #endif
498 
499 extern void pgstat_delete_pending_entry(PgStat_EntryRef *entry_ref);
500 extern PgStat_EntryRef *pgstat_prep_pending_entry(PgStat_Kind kind, Oid dboid, Oid objoid, bool *created_entry);
501 extern PgStat_EntryRef *pgstat_fetch_pending_entry(PgStat_Kind kind, Oid dboid, Oid objoid);
502 
503 extern void *pgstat_fetch_entry(PgStat_Kind kind, Oid dboid, Oid objoid);
504 extern void pgstat_snapshot_fixed(PgStat_Kind kind);
505 
506 
507 /*
508  * Functions in pgstat_archiver.c
509  */
510 
512 extern void pgstat_archiver_snapshot_cb(void);
513 
514 
515 /*
516  * Functions in pgstat_bgwriter.c
517  */
518 
520 extern void pgstat_bgwriter_snapshot_cb(void);
521 
522 
523 /*
524  * Functions in pgstat_checkpointer.c
525  */
526 
528 extern void pgstat_checkpointer_snapshot_cb(void);
529 
530 
531 /*
532  * Functions in pgstat_database.c
533  */
534 
535 extern void pgstat_report_disconnect(Oid dboid);
536 extern void pgstat_update_dbstats(TimestampTz ts);
537 extern void AtEOXact_PgStat_Database(bool isCommit, bool parallel);
538 
540 extern void pgstat_reset_database_timestamp(Oid dboid, TimestampTz ts);
541 extern bool pgstat_database_flush_cb(PgStat_EntryRef *entry_ref, bool nowait);
543 
544 
545 /*
546  * Functions in pgstat_function.c
547  */
548 
549 extern bool pgstat_function_flush_cb(PgStat_EntryRef *entry_ref, bool nowait);
550 
551 
552 /*
553  * Functions in pgstat_relation.c
554  */
555 
556 extern void AtEOXact_PgStat_Relations(PgStat_SubXactStatus *xact_state, bool isCommit);
557 extern void AtEOSubXact_PgStat_Relations(PgStat_SubXactStatus *xact_state, bool isCommit, int nestDepth);
558 extern void AtPrepare_PgStat_Relations(PgStat_SubXactStatus *xact_state);
559 extern void PostPrepare_PgStat_Relations(PgStat_SubXactStatus *xact_state);
560 
561 extern bool pgstat_relation_flush_cb(PgStat_EntryRef *entry_ref, bool nowait);
562 extern void pgstat_relation_delete_pending_cb(PgStat_EntryRef *entry_ref);
563 
564 
565 /*
566  * Functions in pgstat_replslot.c
567  */
568 
572 
573 
574 /*
575  * Functions in pgstat_shmem.c
576  */
577 
578 extern void pgstat_attach_shmem(void);
579 extern void pgstat_detach_shmem(void);
580 
581 extern PgStat_EntryRef *pgstat_get_entry_ref(PgStat_Kind kind, Oid dboid, Oid objoid,
582  bool create, bool *created_entry);
583 extern bool pgstat_lock_entry(PgStat_EntryRef *entry_ref, bool nowait);
584 extern bool pgstat_lock_entry_shared(PgStat_EntryRef *entry_ref, bool nowait);
585 extern void pgstat_unlock_entry(PgStat_EntryRef *entry_ref);
586 extern bool pgstat_drop_entry(PgStat_Kind kind, Oid dboid, Oid objoid);
587 extern void pgstat_drop_all_entries(void);
589  bool nowait);
590 extern void pgstat_reset_entry(PgStat_Kind kind, Oid dboid, Oid objoid, TimestampTz ts);
592 extern void pgstat_reset_matching_entries(bool (*do_reset) (PgStatShared_HashEntry *, Datum),
593  Datum match_data,
594  TimestampTz ts);
595 
596 extern void pgstat_request_entry_refs_gc(void);
598  PgStatShared_HashEntry *shhashent);
599 
600 
601 /*
602  * Functions in pgstat_slru.c
603  */
604 
605 extern bool pgstat_slru_flush(bool nowait);
606 extern void pgstat_slru_reset_all_cb(TimestampTz ts);
607 extern void pgstat_slru_snapshot_cb(void);
608 
609 
610 /*
611  * Functions in pgstat_wal.c
612  */
613 
614 extern bool pgstat_flush_wal(bool nowait);
615 extern void pgstat_init_wal(void);
616 extern bool pgstat_have_pending_wal(void);
617 
618 extern void pgstat_wal_reset_all_cb(TimestampTz ts);
619 extern void pgstat_wal_snapshot_cb(void);
620 
621 
622 /*
623  * Functions in pgstat_subscription.c
624  */
625 
626 extern bool pgstat_subscription_flush_cb(PgStat_EntryRef *entry_ref, bool nowait);
628 
629 
630 /*
631  * Functions in pgstat_xact.c
632  */
633 
634 extern PgStat_SubXactStatus *pgstat_get_xact_stack_level(int nest_level);
635 extern void pgstat_drop_transactional(PgStat_Kind kind, Oid dboid, Oid objoid);
636 extern void pgstat_create_transactional(PgStat_Kind kind, Oid dboid, Oid objoid);
637 
638 
639 /*
640  * Variables in pgstat.c
641  */
642 
644 
645 
646 /*
647  * Variables in pgstat_slru.c
648  */
649 
650 extern PGDLLIMPORT bool have_slrustats;
651 
652 
653 /*
654  * Implementation of inline functions declared above.
655  */
656 
657 /*
658  * Helpers for changecount manipulation. See comments around struct
659  * PgBackendStatus for details.
660  */
661 
662 static inline void
664 {
665  Assert((*cc & 1) == 0);
666 
668  (*cc)++;
670 }
671 
672 static inline void
674 {
675  Assert((*cc & 1) == 1);
676 
678 
679  (*cc)++;
680 
682 }
683 
684 static inline uint32
686 {
687  uint32 before_cc = *cc;
688 
690 
691  pg_read_barrier();
692 
693  return before_cc;
694 }
695 
696 /*
697  * Returns true if the read succeeded, false if it needs to be repeated.
698  */
699 static inline bool
701 {
702  uint32 after_cc;
703 
704  pg_read_barrier();
705 
706  after_cc = *cc;
707 
708  /* was a write in progress when we started? */
709  if (before_cc & 1)
710  return false;
711 
712  /* did writes start and complete while we read? */
713  return before_cc == after_cc;
714 }
715 
716 
717 /*
718  * helper function for PgStat_KindInfo->snapshot_cb
719  * PgStat_KindInfo->reset_all_cb callbacks.
720  *
721  * Copies out the specified memory area following change-count protocol.
722  */
723 static inline void
724 pgstat_copy_changecounted_stats(void *dst, void *src, size_t len,
725  uint32 *cc)
726 {
727  uint32 cc_before;
728 
729  do
730  {
731  cc_before = pgstat_begin_changecount_read(cc);
732 
733  memcpy(dst, src, len);
734  }
735  while (!pgstat_end_changecount_read(cc, cc_before));
736 }
737 
738 /* helpers for dshash / simplehash hashtables */
739 static inline int
740 pgstat_cmp_hash_key(const void *a, const void *b, size_t size, void *arg)
741 {
742  Assert(size == sizeof(PgStat_HashKey) && arg == NULL);
743  return memcmp(a, b, sizeof(PgStat_HashKey));
744 }
745 
746 static inline uint32
747 pgstat_hash_hash_key(const void *d, size_t size, void *arg)
748 {
749  const PgStat_HashKey *key = (PgStat_HashKey *) d;
750  uint32 hash;
751 
752  Assert(size == sizeof(PgStat_HashKey) && arg == NULL);
753 
754  hash = murmurhash32(key->kind);
755  hash = hash_combine(hash, murmurhash32(key->dboid));
756  hash = hash_combine(hash, murmurhash32(key->objoid));
757 
758  return hash;
759 }
760 
761 /*
762  * The length of the data portion of a shared memory stats entry (i.e. without
763  * transient data such as refcounts, lwlocks, ...).
764  */
765 static inline size_t
767 {
769 }
770 
771 /*
772  * Returns a pointer to the data portion of a shared memory stats entry.
773  */
774 static inline void *
776 {
777  size_t off = pgstat_get_kind_info(kind)->shared_data_off;
778 
779  Assert(off != 0 && off < PG_UINT32_MAX);
780 
781  return ((char *) (entry)) + off;
782 }
783 
784 #endif /* PGSTAT_INTERNAL_H */
#define pg_read_barrier()
Definition: atomics.h:153
#define pg_write_barrier()
Definition: atomics.h:154
unsigned int uint32
Definition: c.h:490
#define PGDLLIMPORT
Definition: c.h:1303
#define PG_UINT32_MAX
Definition: c.h:574
unsigned char bool
Definition: c.h:440
int64 TimestampTz
Definition: timestamp.h:39
uint64 dsa_pointer
Definition: dsa.h:62
dsa_pointer dshash_table_handle
Definition: dshash.h:24
const char * name
Definition: encode.c:571
static uint32 hash_combine(uint32 a, uint32 b)
Definition: hashfn.h:68
static uint32 murmurhash32(uint32 data)
Definition: hashfn.h:92
int b
Definition: isn.c:70
int a
Definition: isn.c:69
Assert(fmt[strlen(fmt) - 1] !='\n')
#define START_CRIT_SECTION()
Definition: miscadmin.h:148
#define CHECK_FOR_INTERRUPTS()
Definition: miscadmin.h:121
#define END_CRIT_SECTION()
Definition: miscadmin.h:150
void * arg
const void size_t len
static void header(const char *fmt,...) pg_attribute_printf(1
Definition: pg_regress.c:207
PgStat_Kind
Definition: pgstat.h:36
PgStat_FetchConsistency
Definition: pgstat.h:68
#define PGSTAT_NUM_KINDS
Definition: pgstat.h:57
bool pgstat_replslot_from_serialized_name_cb(const NameData *name, PgStat_HashKey *key)
void pgstat_slru_snapshot_cb(void)
Definition: pgstat_slru.c:203
void pgstat_reset_entries_of_kind(PgStat_Kind kind, TimestampTz ts)
Definition: pgstat_shmem.c:985
struct PgStatShared_Wal PgStatShared_Wal
void pgstat_request_entry_refs_gc(void)
Definition: pgstat_shmem.c:624
void pgstat_snapshot_fixed(PgStat_Kind kind)
Definition: pgstat.c:902
struct PgStat_EntryRef PgStat_EntryRef
const PgStat_KindInfo * pgstat_get_kind_info(PgStat_Kind kind)
Definition: pgstat.c:1221
PgStatShared_Common * pgstat_init_entry(PgStat_Kind kind, PgStatShared_HashEntry *shhashent)
Definition: pgstat_shmem.c:254
PGDLLIMPORT bool have_slrustats
Definition: pgstat_slru.c:35
static uint32 pgstat_hash_hash_key(const void *d, size_t size, void *arg)
struct PgStatShared_SLRU PgStatShared_SLRU
void pgstat_delete_pending_entry(PgStat_EntryRef *entry_ref)
Definition: pgstat.c:1114
bool pgstat_lock_entry_shared(PgStat_EntryRef *entry_ref, bool nowait)
Definition: pgstat_shmem.c:587
void pgstat_attach_shmem(void)
Definition: pgstat_shmem.c:213
static void pgstat_end_changecount_write(uint32 *cc)
static const char *const slru_names[]
static int pgstat_cmp_hash_key(const void *a, const void *b, size_t size, void *arg)
struct PgStat_KindInfo PgStat_KindInfo
void pgstat_database_reset_timestamp_cb(PgStatShared_Common *header, TimestampTz ts)
struct PgStatShared_Function PgStatShared_Function
void pgstat_checkpointer_snapshot_cb(void)
static void * pgstat_get_entry_data(PgStat_Kind kind, PgStatShared_Common *entry)
void pgstat_wal_reset_all_cb(TimestampTz ts)
Definition: pgstat_wal.c:152
struct PgStatShared_Subscription PgStatShared_Subscription
void AtPrepare_PgStat_Relations(PgStat_SubXactStatus *xact_state)
void AtEOXact_PgStat_Database(bool isCommit, bool parallel)
#define pgstat_assert_is_up()
bool pgstat_have_pending_wal(void)
Definition: pgstat_wal.c:144
void pgstat_create_transactional(PgStat_Kind kind, Oid dboid, Oid objoid)
Definition: pgstat_xact.c:358
PGDLLIMPORT PgStat_LocalState pgStatLocal
Definition: pgstat.c:195
void pgstat_archiver_reset_all_cb(TimestampTz ts)
void pgstat_bgwriter_reset_all_cb(TimestampTz ts)
struct PgStat_HashKey PgStat_HashKey
struct PgStatShared_Archiver PgStatShared_Archiver
void pgstat_replslot_to_serialized_name_cb(const PgStat_HashKey *key, const PgStatShared_Common *header, NameData *name)
bool pgstat_subscription_flush_cb(PgStat_EntryRef *entry_ref, bool nowait)
struct PgStatShared_HashEntry PgStatShared_HashEntry
struct PgStat_LocalState PgStat_LocalState
void * pgstat_fetch_entry(PgStat_Kind kind, Oid dboid, Oid objoid)
Definition: pgstat.c:779
void pgstat_drop_transactional(PgStat_Kind kind, Oid dboid, Oid objoid)
Definition: pgstat_xact.c:380
void pgstat_init_wal(void)
Definition: pgstat_wal.c:126
bool pgstat_relation_flush_cb(PgStat_EntryRef *entry_ref, bool nowait)
void pgstat_reset_entry(PgStat_Kind kind, Oid dboid, Oid objoid, TimestampTz ts)
Definition: pgstat_shmem.c:929
static uint32 pgstat_begin_changecount_read(uint32 *cc)
void pgstat_update_dbstats(TimestampTz ts)
void pgstat_replslot_reset_timestamp_cb(PgStatShared_Common *header, TimestampTz ts)
bool pgstat_slru_flush(bool nowait)
Definition: pgstat_slru.c:156
void pgstat_reset_matching_entries(bool(*do_reset)(PgStatShared_HashEntry *, Datum), Datum match_data, TimestampTz ts)
Definition: pgstat_shmem.c:949
void pgstat_slru_reset_all_cb(TimestampTz ts)
Definition: pgstat_slru.c:196
PgStat_EntryRef * pgstat_prep_pending_entry(PgStat_Kind kind, Oid dboid, Oid objoid, bool *created_entry)
Definition: pgstat.c:1063
struct PgStat_SubXactStatus PgStat_SubXactStatus
void AtEOXact_PgStat_Relations(PgStat_SubXactStatus *xact_state, bool isCommit)
struct PgStatShared_Relation PgStatShared_Relation
PgStat_StatDBEntry * pgstat_prep_database_pending(Oid dboid)
void pgstat_drop_all_entries(void)
Definition: pgstat_shmem.c:891
static bool pgstat_end_changecount_read(uint32 *cc, uint32 cc_before)
PgStat_EntryRef * pgstat_fetch_pending_entry(PgStat_Kind kind, Oid dboid, Oid objoid)
Definition: pgstat.c:1101
void pgstat_bgwriter_snapshot_cb(void)
PgStat_EntryRef * pgstat_get_entry_ref(PgStat_Kind kind, Oid dboid, Oid objoid, bool create, bool *created_entry)
Definition: pgstat_shmem.c:393
struct PgStatShared_Checkpointer PgStatShared_Checkpointer
void pgstat_unlock_entry(PgStat_EntryRef *entry_ref)
Definition: pgstat_shmem.c:599
bool pgstat_flush_wal(bool nowait)
Definition: pgstat_wal.c:68
void pgstat_checkpointer_reset_all_cb(TimestampTz ts)
void pgstat_reset_database_timestamp(Oid dboid, TimestampTz ts)
static void pgstat_begin_changecount_write(uint32 *cc)
PgStat_SubXactStatus * pgstat_get_xact_stack_level(int nest_level)
Definition: pgstat_xact.c:237
bool pgstat_function_flush_cb(PgStat_EntryRef *entry_ref, bool nowait)
bool pgstat_drop_entry(PgStat_Kind kind, Oid dboid, Oid objoid)
Definition: pgstat_shmem.c:854
void pgstat_report_disconnect(Oid dboid)
void PostPrepare_PgStat_Relations(PgStat_SubXactStatus *xact_state)
bool pgstat_database_flush_cb(PgStat_EntryRef *entry_ref, bool nowait)
struct PgStat_ShmemControl PgStat_ShmemControl
#define SLRU_NUM_ELEMENTS
struct PgStatShared_Database PgStatShared_Database
void pgstat_wal_snapshot_cb(void)
Definition: pgstat_wal.c:163
static void pgstat_copy_changecounted_stats(void *dst, void *src, size_t len, uint32 *cc)
struct PgStatShared_BgWriter PgStatShared_BgWriter
void AtEOSubXact_PgStat_Relations(PgStat_SubXactStatus *xact_state, bool isCommit, int nestDepth)
bool pgstat_lock_entry(PgStat_EntryRef *entry_ref, bool nowait)
Definition: pgstat_shmem.c:571
static size_t pgstat_get_entry_len(PgStat_Kind kind)
struct PgStatShared_Common PgStatShared_Common
void pgstat_subscription_reset_timestamp_cb(PgStatShared_Common *header, TimestampTz ts)
struct PgStatShared_ReplSlot PgStatShared_ReplSlot
void pgstat_archiver_snapshot_cb(void)
void pgstat_detach_shmem(void)
Definition: pgstat_shmem.c:233
struct PgStat_Snapshot PgStat_Snapshot
PgStat_EntryRef * pgstat_get_entry_ref_locked(PgStat_Kind kind, Oid dboid, Oid objoid, bool nowait)
Definition: pgstat_shmem.c:608
void pgstat_relation_delete_pending_cb(PgStat_EntryRef *entry_ref)
uintptr_t Datum
Definition: postgres.h:64
unsigned int Oid
Definition: postgres_ext.h:31
static unsigned hash(unsigned *uv, int n)
Definition: rege_dfa.c:715
Definition: lwlock.h:40
PgStat_ArchiverStats reset_offset
PgStat_ArchiverStats stats
PgStat_BgWriterStats reset_offset
PgStat_BgWriterStats stats
PgStat_CheckpointerStats reset_offset
PgStat_CheckpointerStats stats
PgStat_StatDBEntry stats
PgStatShared_Common header
PgStatShared_Common header
PgStat_StatFuncEntry stats
pg_atomic_uint32 refcount
PgStatShared_Common header
PgStat_StatTabEntry stats
PgStatShared_Common header
PgStat_StatReplSlotEntry stats
PgStat_SLRUStats stats[SLRU_NUM_ELEMENTS]
PgStat_StatSubEntry stats
PgStatShared_Common header
PgStat_WalStats stats
PgStatShared_Common * shared_stats
PgStatShared_HashEntry * shared_entry
dlist_node pending_node
PgStat_Kind kind
bool accessed_across_databases
void(* to_serialized_name)(const PgStat_HashKey *key, const PgStatShared_Common *header, NameData *name)
bool(* from_serialized_name)(const NameData *name, PgStat_HashKey *key)
bool(* flush_pending_cb)(PgStat_EntryRef *sr, bool nowait)
void(* reset_all_cb)(TimestampTz ts)
void(* reset_timestamp_cb)(PgStatShared_Common *header, TimestampTz ts)
const char *const name
void(* delete_pending_cb)(PgStat_EntryRef *sr)
void(* snapshot_cb)(void)
PgStat_Snapshot snapshot
dshash_table * shared_hash
PgStat_ShmemControl * shmem
dshash_table_handle hash_handle
PgStatShared_SLRU slru
pg_atomic_uint64 gc_request_count
PgStatShared_Wal wal
PgStatShared_Archiver archiver
PgStatShared_Checkpointer checkpointer
PgStatShared_BgWriter bgwriter
PgStat_CheckpointerStats checkpointer
TimestampTz snapshot_timestamp
MemoryContext context
PgStat_WalStats wal
bool fixed_valid[PGSTAT_NUM_KINDS]
PgStat_ArchiverStats archiver
PgStat_FetchConsistency mode
PgStat_SLRUStats slru[SLRU_NUM_ELEMENTS]
struct pgstat_snapshot_hash * stats
PgStat_BgWriterStats bgwriter
PgStat_TableXactStatus * first
struct PgStat_SubXactStatus * prev
Definition: dsa.c:367
Definition: c.h:725