55 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
56 errmsg(
"replication slot \"%s\" does not exist",
87 statent = &shstatent->
stats;
90#define
REPLSLOT_ACC(fld) statent->fld += repSlotStat->fld
126 memset(&shstatent->
stats, 0,
sizeof(shstatent->
stats));
197 elog(
ERROR,
"could not find name for replication slot index %llu",
198 (
unsigned long long)
key->objid);
Datum idx(PG_FUNCTION_ARGS)
#define Assert(condition)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
bool LWLockAcquire(LWLock *lock, LWLockMode mode)
bool LWLockHeldByMeInMode(LWLock *lock, LWLockMode mode)
void LWLockRelease(LWLock *lock)
void pgstat_reset(PgStat_Kind kind, Oid dboid, uint64 objid)
void * pgstat_fetch_entry(PgStat_Kind kind, Oid dboid, uint64 objid)
#define PGSTAT_KIND_REPLSLOT
bool pgstat_replslot_from_serialized_name_cb(const NameData *name, PgStat_HashKey *key)
void pgstat_reset_replslot(const char *name)
void pgstat_create_replslot(ReplicationSlot *slot)
PgStat_StatReplSlotEntry * pgstat_fetch_replslot(NameData slotname)
void pgstat_acquire_replslot(ReplicationSlot *slot)
static int get_replslot_index(const char *name, bool need_lock)
void pgstat_report_replslot(ReplicationSlot *slot, const PgStat_StatReplSlotEntry *repSlotStat)
void pgstat_replslot_to_serialized_name_cb(const PgStat_HashKey *key, const PgStatShared_Common *header, NameData *name)
void pgstat_replslot_reset_timestamp_cb(PgStatShared_Common *header, TimestampTz ts)
void pgstat_drop_replslot(ReplicationSlot *slot)
#define REPLSLOT_ACC(fld)
void pgstat_request_entry_refs_gc(void)
PgStat_EntryRef * pgstat_get_entry_ref(PgStat_Kind kind, Oid dboid, uint64 objid, bool create, bool *created_entry)
bool pgstat_drop_entry(PgStat_Kind kind, Oid dboid, uint64 objid)
void pgstat_unlock_entry(PgStat_EntryRef *entry_ref)
PgStat_EntryRef * pgstat_get_entry_ref_locked(PgStat_Kind kind, Oid dboid, uint64 objid, bool nowait)
int ReplicationSlotIndex(ReplicationSlot *slot)
ReplicationSlot * SearchNamedReplicationSlot(const char *name, bool need_lock)
bool ReplicationSlotName(int index, Name name)
#define SlotIsLogical(slot)
PgStat_StatReplSlotEntry stats
PgStatShared_Common * shared_stats