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-2022, 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  */
167 
168  /*
169  * Tuple insertion/deletion counts for an open transaction can't be
170  * propagated into PgStat_TableStatus counters until we know if it is
171  * going to commit or abort. Hence, we keep these counts in per-subxact
172  * structs that live in TopTransactionContext. This data structure is
173  * designed on the assumption that subxacts won't usually modify very many
174  * tables.
175  */
176  PgStat_TableXactStatus *first; /* head of list for this subxact */
178 
179 
180 /*
181  * Metadata for a specific kind of statistics.
182  */
183 typedef struct PgStat_KindInfo
184 {
185  /*
186  * Do a fixed number of stats objects exist for this kind of stats (e.g.
187  * bgwriter stats) or not (e.g. tables).
188  */
189  bool fixed_amount:1;
190 
191  /*
192  * Can stats of this kind be accessed from another database? Determines
193  * whether a stats object gets included in stats snapshots.
194  */
196 
197  /*
198  * For variable-numbered stats: Identified on-disk using a name, rather
199  * than PgStat_HashKey. Probably only needed for replication slot stats.
200  */
202 
203  /*
204  * The size of an entry in the shared stats hash table (pointed to by
205  * PgStatShared_HashEntry->body).
206  */
208 
209  /*
210  * The offset/size of statistics inside the shared stats entry. Used when
211  * [de-]serializing statistics to / from disk respectively. Separate from
212  * shared_size because [de-]serialization may not include in-memory state
213  * like lwlocks.
214  */
217 
218  /*
219  * The size of the pending data for this kind. E.g. how large
220  * PgStat_EntryRef->pending is. Used for allocations.
221  *
222  * 0 signals that an entry of this kind should never have a pending entry.
223  */
225 
226  /*
227  * For variable-numbered stats: flush pending stats. Required if pending
228  * data is used.
229  */
230  bool (*flush_pending_cb) (PgStat_EntryRef *sr, bool nowait);
231 
232  /*
233  * For variable-numbered stats: delete pending stats. Optional.
234  */
236 
237  /*
238  * For variable-numbered stats: reset the reset timestamp. Optional.
239  */
241 
242  /*
243  * For variable-numbered stats with named_on_disk. Optional.
244  */
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 *found);
583 extern bool pgstat_lock_entry(PgStat_EntryRef *entry_ref, bool nowait);
584 extern void pgstat_unlock_entry(PgStat_EntryRef *entry_ref);
585 extern bool pgstat_drop_entry(PgStat_Kind kind, Oid dboid, Oid objoid);
586 extern void pgstat_drop_all_entries(void);
588  bool nowait);
589 extern void pgstat_reset_entry(PgStat_Kind kind, Oid dboid, Oid objoid, TimestampTz ts);
591 extern void pgstat_reset_matching_entries(bool (*do_reset) (PgStatShared_HashEntry *, Datum),
592  Datum match_data,
593  TimestampTz ts);
594 
595 extern void pgstat_request_entry_refs_gc(void);
597  PgStatShared_HashEntry *shhashent);
598 
599 
600 /*
601  * Functions in pgstat_slru.c
602  */
603 
604 extern bool pgstat_slru_flush(bool nowait);
605 extern void pgstat_slru_reset_all_cb(TimestampTz ts);
606 extern void pgstat_slru_snapshot_cb(void);
607 
608 
609 /*
610  * Functions in pgstat_wal.c
611  */
612 
613 extern bool pgstat_flush_wal(bool nowait);
614 extern void pgstat_init_wal(void);
615 extern bool pgstat_have_pending_wal(void);
616 
617 extern void pgstat_wal_reset_all_cb(TimestampTz ts);
618 extern void pgstat_wal_snapshot_cb(void);
619 
620 
621 /*
622  * Functions in pgstat_subscription.c
623  */
624 
625 extern bool pgstat_subscription_flush_cb(PgStat_EntryRef *entry_ref, bool nowait);
627 
628 /*
629  * Functions in pgstat_xact.c
630  */
631 
632 extern PgStat_SubXactStatus *pgstat_get_xact_stack_level(int nest_level);
633 extern void pgstat_drop_transactional(PgStat_Kind kind, Oid dboid, Oid objoid);
634 extern void pgstat_create_transactional(PgStat_Kind kind, Oid dboid, Oid objoid);
635 
636 
637 /*
638  * Variables in pgstat.c
639  */
640 
642 
643 
644 /*
645  * Variables in pgstat_slru.c
646  */
647 
648 extern PGDLLIMPORT bool have_slrustats;
649 
650 
651 /*
652  * Implementation of inline functions declared above.
653  */
654 
655 /*
656  * Helpers for changecount manipulation. See comments around struct
657  * PgBackendStatus for details.
658  */
659 
660 static inline void
662 {
663  Assert((*cc & 1) == 0);
664 
666  (*cc)++;
668 }
669 
670 static inline void
672 {
673  Assert((*cc & 1) == 1);
674 
676 
677  (*cc)++;
678 
680 }
681 
682 static inline uint32
684 {
685  uint32 before_cc = *cc;
686 
688 
689  pg_read_barrier();
690 
691  return before_cc;
692 }
693 
694 /*
695  * Returns true if the read succeeded, false if it needs to be repeated.
696  */
697 static inline bool
699 {
700  uint32 after_cc;
701 
702  pg_read_barrier();
703 
704  after_cc = *cc;
705 
706  /* was a write in progress when we started? */
707  if (before_cc & 1)
708  return false;
709 
710  /* did writes start and complete while we read? */
711  return before_cc == after_cc;
712 }
713 
714 
715 /*
716  * helper function for PgStat_KindInfo->snapshot_cb
717  * PgStat_KindInfo->reset_all_cb callbacks.
718  *
719  * Copies out the specified memory area following change-count protocol.
720  */
721 static inline void
722 pgstat_copy_changecounted_stats(void *dst, void *src, size_t len,
723  uint32 *cc)
724 {
725  uint32 cc_before;
726 
727  do
728  {
729  cc_before = pgstat_begin_changecount_read(cc);
730 
731  memcpy(dst, src, len);
732  }
733  while (!pgstat_end_changecount_read(cc, cc_before));
734 }
735 
736 /* helpers for dshash / simplehash hashtables */
737 static inline int
738 pgstat_cmp_hash_key(const void *a, const void *b, size_t size, void *arg)
739 {
740  AssertArg(size == sizeof(PgStat_HashKey) && arg == NULL);
741  return memcmp(a, b, sizeof(PgStat_HashKey));
742 }
743 
744 static inline uint32
745 pgstat_hash_hash_key(const void *d, size_t size, void *arg)
746 {
747  const PgStat_HashKey *key = (PgStat_HashKey *) d;
748  uint32 hash;
749 
750  AssertArg(size == sizeof(PgStat_HashKey) && arg == NULL);
751 
752  hash = murmurhash32(key->kind);
753  hash = hash_combine(hash, murmurhash32(key->dboid));
754  hash = hash_combine(hash, murmurhash32(key->objoid));
755 
756  return hash;
757 }
758 
759 /*
760  * The length of the data portion of a shared memory stats entry (i.e. without
761  * transient data such as refcounts, lwlocks, ...).
762  */
763 static inline size_t
765 {
767 }
768 
769 /*
770  * Returns a pointer to the data portion of a shared memory stats entry.
771  */
772 static inline void *
774 {
775  size_t off = pgstat_get_kind_info(kind)->shared_data_off;
776 
777  Assert(off != 0 && off < PG_UINT32_MAX);
778 
779  return ((char *) (entry)) + off;
780 }
781 
782 #endif /* PGSTAT_INTERNAL_H */
#define pg_read_barrier()
Definition: atomics.h:158
#define pg_write_barrier()
Definition: atomics.h:159
unsigned int uint32
Definition: c.h:441
#define PGDLLIMPORT
Definition: c.h:1331
#define PG_UINT32_MAX
Definition: c.h:525
unsigned char bool
Definition: c.h:391
#define AssertArg(condition)
Definition: c.h:806
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:561
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:212
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:205
void pgstat_reset_entries_of_kind(PgStat_Kind kind, TimestampTz ts)
Definition: pgstat_shmem.c:969
struct PgStatShared_Wal PgStatShared_Wal
void pgstat_request_entry_refs_gc(void)
Definition: pgstat_shmem.c:608
void pgstat_snapshot_fixed(PgStat_Kind kind)
Definition: pgstat.c:899
struct PgStat_EntryRef PgStat_EntryRef
const PgStat_KindInfo * pgstat_get_kind_info(PgStat_Kind kind)
Definition: pgstat.c:1211
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
void pgstat_replslot_to_serialized_name_cb(const PgStatShared_Common *tmp, NameData *name)
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:1104
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:366
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
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:388
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:913
static uint32 pgstat_begin_changecount_read(uint32 *cc)
void pgstat_update_dbstats(TimestampTz ts)
PgStat_EntryRef * pgstat_get_entry_ref(PgStat_Kind kind, Oid dboid, Oid objoid, bool create, bool *found)
Definition: pgstat_shmem.c:393
void pgstat_replslot_reset_timestamp_cb(PgStatShared_Common *header, TimestampTz ts)
bool pgstat_slru_flush(bool nowait)
Definition: pgstat_slru.c:158
void pgstat_reset_matching_entries(bool(*do_reset)(PgStatShared_HashEntry *, Datum), Datum match_data, TimestampTz ts)
Definition: pgstat_shmem.c:933
void pgstat_slru_reset_all_cb(TimestampTz ts)
Definition: pgstat_slru.c:198
PgStat_EntryRef * pgstat_prep_pending_entry(PgStat_Kind kind, Oid dboid, Oid objoid, bool *created_entry)
Definition: pgstat.c:1053
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:875
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:1091
void pgstat_bgwriter_snapshot_cb(void)
struct PgStatShared_Checkpointer PgStatShared_Checkpointer
void pgstat_unlock_entry(PgStat_EntryRef *entry_ref)
Definition: pgstat_shmem.c:583
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:243
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:838
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:592
void pgstat_relation_delete_pending_cb(PgStat_EntryRef *entry_ref)
uintptr_t Datum
Definition: postgres.h:411
unsigned int Oid
Definition: postgres_ext.h:31
static unsigned hash(unsigned *uv, int n)
Definition: rege_dfa.c:715
Definition: lwlock.h:32
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 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:355
Definition: c.h:676