PostgreSQL Source Code  git master
Macros | Functions
pgstat_replslot.c File Reference
#include "postgres.h"
#include "replication/slot.h"
#include "utils/pgstat_internal.h"
Include dependency graph for pgstat_replslot.c:

Go to the source code of this file.

Macros

#define REPLSLOT_ACC(fld)   statent->fld += repSlotStat->fld
 

Functions

static int get_replslot_index (const char *name, bool need_lock)
 
void pgstat_reset_replslot (const char *name)
 
void pgstat_report_replslot (ReplicationSlot *slot, const PgStat_StatReplSlotEntry *repSlotStat)
 
void pgstat_create_replslot (ReplicationSlot *slot)
 
void pgstat_acquire_replslot (ReplicationSlot *slot)
 
void pgstat_drop_replslot (ReplicationSlot *slot)
 
PgStat_StatReplSlotEntry * pgstat_fetch_replslot (NameData slotname)
 
void pgstat_replslot_to_serialized_name_cb (const PgStat_HashKey *key, const PgStatShared_Common *header, NameData *name)
 
bool pgstat_replslot_from_serialized_name_cb (const NameData *name, PgStat_HashKey *key)
 
void pgstat_replslot_reset_timestamp_cb (PgStatShared_Common *header, TimestampTz ts)
 

Macro Definition Documentation

◆ REPLSLOT_ACC

#define REPLSLOT_ACC (   fld)    statent->fld += repSlotStat->fld

Function Documentation

◆ get_replslot_index()

static int get_replslot_index ( const char *  name,
bool  need_lock 
)
static

Definition at line 224 of file pgstat_replslot.c.

225 {
226  ReplicationSlot *slot;
227 
228  Assert(name != NULL);
229 
230  slot = SearchNamedReplicationSlot(name, need_lock);
231 
232  if (!slot)
233  return -1;
234 
235  return ReplicationSlotIndex(slot);
236 }
Assert
#define Assert(condition)
Definition: c.h:861
SearchNamedReplicationSlot
ReplicationSlot * SearchNamedReplicationSlot(const char *name, bool need_lock)
Definition: slot.c:464
ReplicationSlotIndex
int ReplicationSlotIndex(ReplicationSlot *slot)
Definition: slot.c:497
name
const char * name
Definition: wait_event_funcs.c:28

References Assert, name, ReplicationSlotIndex(), and SearchNamedReplicationSlot().

Referenced by pgstat_fetch_replslot(), and pgstat_replslot_from_serialized_name_cb().

◆ pgstat_acquire_replslot()

void pgstat_acquire_replslot ( ReplicationSlot *  slot)

Definition at line 146 of file pgstat_replslot.c.

147 {
148  pgstat_get_entry_ref(PGSTAT_KIND_REPLSLOT, InvalidOid,
149  ReplicationSlotIndex(slot), true, NULL);
150 }
PGSTAT_KIND_REPLSLOT
#define PGSTAT_KIND_REPLSLOT
Definition: pgstat.h:50
pgstat_get_entry_ref
PgStat_EntryRef * pgstat_get_entry_ref(PgStat_Kind kind, Oid dboid, uint64 objid, bool create, bool *created_entry)
Definition: pgstat_shmem.c:432
InvalidOid
#define InvalidOid
Definition: postgres_ext.h:36

References InvalidOid, pgstat_get_entry_ref(), PGSTAT_KIND_REPLSLOT, and ReplicationSlotIndex().

Referenced by ReplicationSlotAcquire().

◆ pgstat_create_replslot()

void pgstat_create_replslot ( ReplicationSlot *  slot)

Definition at line 111 of file pgstat_replslot.c.

112 {
113  PgStat_EntryRef *entry_ref;
114  PgStatShared_ReplSlot *shstatent;
115 
116  Assert(LWLockHeldByMeInMode(ReplicationSlotAllocationLock, LW_EXCLUSIVE));
117 
118  entry_ref = pgstat_get_entry_ref_locked(PGSTAT_KIND_REPLSLOT, InvalidOid,
119  ReplicationSlotIndex(slot), false);
120  shstatent = (PgStatShared_ReplSlot *) entry_ref->shared_stats;
121 
122  /*
123  * NB: need to accept that there might be stats from an older slot, e.g.
124  * if we previously crashed after dropping a slot.
125  */
126  memset(&shstatent->stats, 0, sizeof(shstatent->stats));
127 
128  pgstat_unlock_entry(entry_ref);
129 }
LWLockHeldByMeInMode
bool LWLockHeldByMeInMode(LWLock *lock, LWLockMode mode)
Definition: lwlock.c:1937
LW_EXCLUSIVE
@ LW_EXCLUSIVE
Definition: lwlock.h:114
pgstat_unlock_entry
void pgstat_unlock_entry(PgStat_EntryRef *entry_ref)
Definition: pgstat_shmem.c:638
pgstat_get_entry_ref_locked
PgStat_EntryRef * pgstat_get_entry_ref_locked(PgStat_Kind kind, Oid dboid, uint64 objid, bool nowait)
Definition: pgstat_shmem.c:647
PgStatShared_ReplSlot
Definition: pgstat_internal.h:426
PgStatShared_ReplSlot::stats
PgStat_StatReplSlotEntry stats
Definition: pgstat_internal.h:428
PgStat_EntryRef
Definition: pgstat_internal.h:123
PgStat_EntryRef::shared_stats
PgStatShared_Common * shared_stats
Definition: pgstat_internal.h:134

References Assert, InvalidOid, LW_EXCLUSIVE, LWLockHeldByMeInMode(), pgstat_get_entry_ref_locked(), PGSTAT_KIND_REPLSLOT, pgstat_unlock_entry(), ReplicationSlotIndex(), PgStat_EntryRef::shared_stats, and PgStatShared_ReplSlot::stats.

Referenced by ReplicationSlotCreate().

◆ pgstat_drop_replslot()

void pgstat_drop_replslot ( ReplicationSlot *  slot)

Definition at line 156 of file pgstat_replslot.c.

157 {
158  Assert(LWLockHeldByMeInMode(ReplicationSlotAllocationLock, LW_EXCLUSIVE));
159 
160  if (!pgstat_drop_entry(PGSTAT_KIND_REPLSLOT, InvalidOid,
161  ReplicationSlotIndex(slot)))
162  pgstat_request_entry_refs_gc();
163 }
pgstat_request_entry_refs_gc
void pgstat_request_entry_refs_gc(void)
Definition: pgstat_shmem.c:663
pgstat_drop_entry
bool pgstat_drop_entry(PgStat_Kind kind, Oid dboid, uint64 objid)
Definition: pgstat_shmem.c:909

References Assert, InvalidOid, LW_EXCLUSIVE, LWLockHeldByMeInMode(), pgstat_drop_entry(), PGSTAT_KIND_REPLSLOT, pgstat_request_entry_refs_gc(), and ReplicationSlotIndex().

Referenced by ReplicationSlotDropPtr().

◆ pgstat_fetch_replslot()

PgStat_StatReplSlotEntry* pgstat_fetch_replslot ( NameData  slotname)

Definition at line 170 of file pgstat_replslot.c.

171 {
172  int idx;
173  PgStat_StatReplSlotEntry *slotentry = NULL;
174 
175  LWLockAcquire(ReplicationSlotControlLock, LW_SHARED);
176 
177  idx = get_replslot_index(NameStr(slotname), false);
178 
179  if (idx != -1)
180  slotentry = (PgStat_StatReplSlotEntry *) pgstat_fetch_entry(PGSTAT_KIND_REPLSLOT,
181  InvalidOid, idx);
182 
183  LWLockRelease(ReplicationSlotControlLock);
184 
185  return slotentry;
186 }
idx
Datum idx(PG_FUNCTION_ARGS)
Definition: _int_op.c:259
NameStr
#define NameStr(name)
Definition: c.h:749
LWLockAcquire
bool LWLockAcquire(LWLock *lock, LWLockMode mode)
Definition: lwlock.c:1168
LWLockRelease
void LWLockRelease(LWLock *lock)
Definition: lwlock.c:1781
LW_SHARED
@ LW_SHARED
Definition: lwlock.h:115
pgstat_fetch_entry
void * pgstat_fetch_entry(PgStat_Kind kind, Oid dboid, uint64 objid)
Definition: pgstat.c:928
get_replslot_index
static int get_replslot_index(const char *name, bool need_lock)
Definition: pgstat_replslot.c:224
PgStat_StatReplSlotEntry
Definition: pgstat.h:402

References get_replslot_index(), idx(), InvalidOid, LW_SHARED, LWLockAcquire(), LWLockRelease(), NameStr, pgstat_fetch_entry(), and PGSTAT_KIND_REPLSLOT.

Referenced by pg_stat_get_replication_slot().

◆ pgstat_replslot_from_serialized_name_cb()

bool pgstat_replslot_from_serialized_name_cb ( const NameData *  name,
PgStat_HashKey *  key 
)

Definition at line 202 of file pgstat_replslot.c.

203 {
204  int idx = get_replslot_index(NameStr(*name), true);
205 
206  /* slot might have been deleted */
207  if (idx == -1)
208  return false;
209 
210  key->kind = PGSTAT_KIND_REPLSLOT;
211  key->dboid = InvalidOid;
212  key->objid = idx;
213 
214  return true;
215 }

References get_replslot_index(), idx(), InvalidOid, sort-test::key, name, NameStr, and PGSTAT_KIND_REPLSLOT.

◆ pgstat_replslot_reset_timestamp_cb()

void pgstat_replslot_reset_timestamp_cb ( PgStatShared_Common *  header,
TimestampTz  ts 
)

Definition at line 218 of file pgstat_replslot.c.

219 {
220  ((PgStatShared_ReplSlot *) header)->stats.stat_reset_timestamp = ts;
221 }

◆ pgstat_replslot_to_serialized_name_cb()

void pgstat_replslot_to_serialized_name_cb ( const PgStat_HashKey *  key,
const PgStatShared_Common *  header,
NameData *  name 
)

Definition at line 189 of file pgstat_replslot.c.

190 {
191  /*
192  * This is only called late during shutdown. The set of existing slots
193  * isn't allowed to change at this point, we can assume that a slot exists
194  * at the offset.
195  */
196  if (!ReplicationSlotName(key->objid, name))
197  elog(ERROR, "could not find name for replication slot index %llu",
198  (unsigned long long) key->objid);
199 }
ERROR
#define ERROR
Definition: elog.h:39
elog
#define elog(elevel,...)
Definition: elog.h:225
ReplicationSlotName
bool ReplicationSlotName(int index, Name name)
Definition: slot.c:513

References elog, ERROR, sort-test::key, name, and ReplicationSlotName().

◆ pgstat_report_replslot()

void pgstat_report_replslot ( ReplicationSlot *  slot,
const PgStat_StatReplSlotEntry *  repSlotStat 
)

Definition at line 78 of file pgstat_replslot.c.

79 {
80  PgStat_EntryRef *entry_ref;
81  PgStatShared_ReplSlot *shstatent;
82  PgStat_StatReplSlotEntry *statent;
83 
84  entry_ref = pgstat_get_entry_ref_locked(PGSTAT_KIND_REPLSLOT, InvalidOid,
85  ReplicationSlotIndex(slot), false);
86  shstatent = (PgStatShared_ReplSlot *) entry_ref->shared_stats;
87  statent = &shstatent->stats;
88 
89  /* Update the replication slot statistics */
90 #define REPLSLOT_ACC(fld) statent->fld += repSlotStat->fld
91  REPLSLOT_ACC(spill_txns);
92  REPLSLOT_ACC(spill_count);
93  REPLSLOT_ACC(spill_bytes);
94  REPLSLOT_ACC(stream_txns);
95  REPLSLOT_ACC(stream_count);
96  REPLSLOT_ACC(stream_bytes);
97  REPLSLOT_ACC(total_txns);
98  REPLSLOT_ACC(total_bytes);
99 #undef REPLSLOT_ACC
100 
101  pgstat_unlock_entry(entry_ref);
102 }
REPLSLOT_ACC
#define REPLSLOT_ACC(fld)

References InvalidOid, pgstat_get_entry_ref_locked(), PGSTAT_KIND_REPLSLOT, pgstat_unlock_entry(), ReplicationSlotIndex(), REPLSLOT_ACC, PgStat_EntryRef::shared_stats, and PgStatShared_ReplSlot::stats.

Referenced by UpdateDecodingStats().

◆ pgstat_reset_replslot()

void pgstat_reset_replslot ( const char *  name)

Definition at line 42 of file pgstat_replslot.c.

43 {
44  ReplicationSlot *slot;
45 
46  Assert(name != NULL);
47 
48  LWLockAcquire(ReplicationSlotControlLock, LW_SHARED);
49 
50  /* Check if the slot exits with the given name. */
51  slot = SearchNamedReplicationSlot(name, false);
52 
53  if (!slot)
54  ereport(ERROR,
55  (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
56  errmsg("replication slot \"%s\" does not exist",
57  name)));
58 
59  /*
60  * Reset stats if it is a logical slot. Nothing to do for physical slots
61  * as we collect stats only for logical slots.
62  */
63  if (SlotIsLogical(slot))
64  pgstat_reset(PGSTAT_KIND_REPLSLOT, InvalidOid,
65  ReplicationSlotIndex(slot));
66 
67  LWLockRelease(ReplicationSlotControlLock);
68 }
errcode
int errcode(int sqlerrcode)
Definition: elog.c:853
errmsg
int errmsg(const char *fmt,...)
Definition: elog.c:1070
ereport
#define ereport(elevel,...)
Definition: elog.h:149
pgstat_reset
void pgstat_reset(PgStat_Kind kind, Oid dboid, uint64 objid)
Definition: pgstat.c:848
SlotIsLogical
#define SlotIsLogical(slot)
Definition: slot.h:213

References Assert, ereport, errcode(), errmsg(), ERROR, InvalidOid, LW_SHARED, LWLockAcquire(), LWLockRelease(), name, PGSTAT_KIND_REPLSLOT, pgstat_reset(), ReplicationSlotIndex(), SearchNamedReplicationSlot(), and SlotIsLogical.

Referenced by pg_stat_reset_replication_slot().