#include "postgres.h"
#include "replication/slot.h"
#include "utils/builtins.h"
#include "utils/pgstat_internal.h"

Include dependency graph for pgstat_replslot.c:

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

Functions
static int	get_replslot_index (const char *name)

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 )

static

Definition at line 212 of file pgstat_replslot.c.

 {
     ReplicationSlot *slot;
  
     Assert(name != NULL);
  
     slot = SearchNamedReplicationSlot(name, true);
  
     if (!slot)
         return -1;
  
     return ReplicationSlotIndex(slot);
 }

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 144 of file pgstat_replslot.c.

 {
     pgstat_get_entry_ref(PGSTAT_KIND_REPLSLOT, InvalidOid,
                          ReplicationSlotIndex(slot), true, NULL);
 }

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.

 {
     PgStat_EntryRef *entry_ref;
     PgStatShared_ReplSlot *shstatent;
  
     entry_ref = pgstat_get_entry_ref_locked(PGSTAT_KIND_REPLSLOT, InvalidOid,
                                             ReplicationSlotIndex(slot), false);
     shstatent = (PgStatShared_ReplSlot *) entry_ref->shared_stats;
  
     /*
      * NB: need to accept that there might be stats from an older slot, e.g.
      * if we previously crashed after dropping a slot.
      */
     memset(&shstatent->stats, 0, sizeof(shstatent->stats));
  
     pgstat_unlock_entry(entry_ref);
 }

References InvalidOid, 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 154 of file pgstat_replslot.c.

 {
     pgstat_drop_entry(PGSTAT_KIND_REPLSLOT, InvalidOid,
                       ReplicationSlotIndex(slot));
 }

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

Referenced by InvalidatePossiblyObsoleteSlot(), and ReplicationSlotDropPtr().

◆ pgstat_fetch_replslot()

PgStat_StatReplSlotEntry* pgstat_fetch_replslot ( NameData slotname )

Definition at line 165 of file pgstat_replslot.c.

 {
     int         idx = get_replslot_index(NameStr(slotname));
  
     if (idx == -1)
         return NULL;
  
     return (PgStat_StatReplSlotEntry *)
         pgstat_fetch_entry(PGSTAT_KIND_REPLSLOT, InvalidOid, idx);
 }

References get_replslot_index(), idx(), InvalidOid, 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 190 of file pgstat_replslot.c.

 {
     int         idx = get_replslot_index(NameStr(*name));
  
     /* slot might have been deleted */
     if (idx == -1)
         return false;
  
     key->kind = PGSTAT_KIND_REPLSLOT;
     key->dboid = InvalidOid;
     key->objoid = idx;
  
     return true;
 }

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 206 of file pgstat_replslot.c.

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

◆ 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 177 of file pgstat_replslot.c.

 {
     /*
      * This is only called late during shutdown. The set of existing slots
      * isn't allowed to change at this point, we can assume that a slot exists
      * at the offset.
      */
     if (!ReplicationSlotName(key->objoid, name))
         elog(ERROR, "could not find name for replication slot index %u",
              key->objoid);
 }

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.

 {
     PgStat_EntryRef *entry_ref;
     PgStatShared_ReplSlot *shstatent;
     PgStat_StatReplSlotEntry *statent;
  
     entry_ref = pgstat_get_entry_ref_locked(PGSTAT_KIND_REPLSLOT, InvalidOid,
                                             ReplicationSlotIndex(slot), false);
     shstatent = (PgStatShared_ReplSlot *) entry_ref->shared_stats;
     statent = &shstatent->stats;
  
     /* Update the replication slot statistics */
 #define REPLSLOT_ACC(fld) statent->fld += repSlotStat->fld
     REPLSLOT_ACC(spill_txns);
     REPLSLOT_ACC(spill_count);
     REPLSLOT_ACC(spill_bytes);
     REPLSLOT_ACC(stream_txns);
     REPLSLOT_ACC(stream_count);
     REPLSLOT_ACC(stream_bytes);
     REPLSLOT_ACC(total_txns);
     REPLSLOT_ACC(total_bytes);
 #undef REPLSLOT_ACC
  
     pgstat_unlock_entry(entry_ref);
 }

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 43 of file pgstat_replslot.c.

 {
     ReplicationSlot *slot;
  
     Assert(name != NULL);
  
     /* Check if the slot exits with the given name. */
     slot = SearchNamedReplicationSlot(name, true);
  
     if (!slot)
         ereport(ERROR,
                 (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
                  errmsg("replication slot \"%s\" does not exist",
                         name)));
  
     /*
      * Nothing to do for physical slots as we collect stats only for logical
      * slots.
      */
     if (SlotIsPhysical(slot))
         return;
  
     /* reset this one entry */
     pgstat_reset(PGSTAT_KIND_REPLSLOT, InvalidOid,
                  ReplicationSlotIndex(slot));
 }

References Assert(), ereport, errcode(), errmsg(), ERROR, InvalidOid, name, PGSTAT_KIND_REPLSLOT, pgstat_reset(), ReplicationSlotIndex(), SearchNamedReplicationSlot(), and SlotIsPhysical.

Referenced by pg_stat_reset_replication_slot().

Macros

Functions