#include "postgres.h"
#include "replication/slot.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, bool need_lock)

void	pgstat_reset_replslot (const char *name)

void	pgstat_report_replslot (ReplicationSlot slot, const PgStat_StatReplSlotEntry repSlotStat)

void	pgstat_report_replslotsync (ReplicationSlot *slot)

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

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

References Assert, fb(), 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 176 of file pgstat_replslot.c.

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

References fb(), 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 141 of file pgstat_replslot.c.

{
    PgStat_EntryRef *entry_ref;
    PgStatShared_ReplSlot *shstatent;
 
    Assert(LWLockHeldByMeInMode(ReplicationSlotAllocationLock, LW_EXCLUSIVE));
 
    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 Assert, fb(), InvalidOid, LW_EXCLUSIVE, LWLockHeldByMeInMode(), pgstat_get_entry_ref_locked(), PGSTAT_KIND_REPLSLOT, pgstat_unlock_entry(), ReplicationSlotIndex(), and PgStat_EntryRef::shared_stats.

Referenced by ReplicationSlotCreate().

◆ pgstat_drop_replslot()

void pgstat_drop_replslot ( ReplicationSlot * slot )

Definition at line 186 of file pgstat_replslot.c.

{
    Assert(LWLockHeldByMeInMode(ReplicationSlotAllocationLock, LW_EXCLUSIVE));
 
    if (!pgstat_drop_entry(PGSTAT_KIND_REPLSLOT, InvalidOid,
                           ReplicationSlotIndex(slot)))
        pgstat_request_entry_refs_gc();
}

References Assert, fb(), 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 200 of file pgstat_replslot.c.

{
    int         idx;
    PgStat_StatReplSlotEntry *slotentry = NULL;
 
    LWLockAcquire(ReplicationSlotControlLock, LW_SHARED);
 
    idx = get_replslot_index(NameStr(slotname), false);
 
    if (idx != -1)
        slotentry = (PgStat_StatReplSlotEntry *) pgstat_fetch_entry(PGSTAT_KIND_REPLSLOT,
                                                                    InvalidOid, idx);
 
    LWLockRelease(ReplicationSlotControlLock);
 
    return slotentry;
}

References fb(), 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 232 of file pgstat_replslot.c.

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

References get_replslot_index(), idx(), InvalidOid, 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 248 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 219 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->objid, name))
        elog(ERROR, "could not find name for replication slot index %" PRIu64,
             key->objid);
}

References elog, ERROR, fb(), name, and ReplicationSlotName().

◆ pgstat_report_replslot()

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

Definition at line 77 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(mem_exceeded_count);
    REPLSLOT_ACC(total_txns);
    REPLSLOT_ACC(total_bytes);
#undef REPLSLOT_ACC
 
    pgstat_unlock_entry(entry_ref);
}

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

Referenced by UpdateDecodingStats().

◆ pgstat_report_replslotsync()

void pgstat_report_replslotsync ( ReplicationSlot * slot )

Definition at line 111 of file pgstat_replslot.c.

{
    PgStat_EntryRef *entry_ref;
    PgStatShared_ReplSlot *shstatent;
    PgStat_StatReplSlotEntry *statent;
 
    /* Slot sync stats are valid only for synced logical slots on standby. */
    Assert(slot->data.synced);
    Assert(RecoveryInProgress());
 
    entry_ref = pgstat_get_entry_ref_locked(PGSTAT_KIND_REPLSLOT, InvalidOid,
                                            ReplicationSlotIndex(slot), false);
    Assert(entry_ref != NULL);
 
    shstatent = (PgStatShared_ReplSlot *) entry_ref->shared_stats;
    statent = &shstatent->stats;
 
    statent->slotsync_skip_count += 1;
    statent->slotsync_last_skip = GetCurrentTimestamp();
 
    pgstat_unlock_entry(entry_ref);
}

References Assert, ReplicationSlot::data, fb(), GetCurrentTimestamp(), InvalidOid, pgstat_get_entry_ref_locked(), PGSTAT_KIND_REPLSLOT, pgstat_unlock_entry(), RecoveryInProgress(), ReplicationSlotIndex(), PgStat_EntryRef::shared_stats, and ReplicationSlotPersistentData::synced.

Referenced by update_slotsync_skip_stats().

◆ pgstat_reset_replslot()

void pgstat_reset_replslot ( const char * name )

Definition at line 42 of file pgstat_replslot.c.

{
    ReplicationSlot *slot;
 
    Assert(name != NULL);
 
    LWLockAcquire(ReplicationSlotControlLock, LW_SHARED);
 
    /* Check if the slot exists with the given name. */
    slot = SearchNamedReplicationSlot(name, false);
    if (!slot)
        ereport(ERROR,
                (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
                 errmsg("replication slot \"%s\" does not exist",
                        name)));
 
    /*
     * Reset stats if it is a logical slot. Nothing to do for physical slots
     * as we collect stats only for logical slots.
     */
    if (SlotIsLogical(slot))
        pgstat_reset(PGSTAT_KIND_REPLSLOT, InvalidOid,
                     ReplicationSlotIndex(slot));
 
    LWLockRelease(ReplicationSlotControlLock);
}

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

Referenced by pg_stat_reset_replication_slot().

Macros

Functions