54 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
55 errmsg(
"replication slot \"%s\" does not exist",
87 statent = &shstatent->
stats;
90 #define
REPLSLOT_ACC(fld) statent->fld += repSlotStat->fld
124 memset(&shstatent->
stats, 0,
sizeof(shstatent->
stats));
185 elog(
ERROR,
"could not find name for replication slot index %u",
Datum idx(PG_FUNCTION_ARGS)
elog(ERROR, "%s: %s", p2, msg)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
Assert(fmt[strlen(fmt) - 1] !='\n')
void pgstat_reset(PgStat_Kind kind, Oid dboid, Oid objoid)
void * pgstat_fetch_entry(PgStat_Kind kind, Oid dboid, Oid objoid)
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)
void pgstat_acquire_replslot(ReplicationSlot *slot)
static int get_replslot_index(const char *name)
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)
PgStat_StatReplSlotEntry * pgstat_fetch_replslot(NameData slotname)
#define REPLSLOT_ACC(fld)
PgStat_EntryRef * pgstat_get_entry_ref(PgStat_Kind kind, Oid dboid, Oid objoid, bool create, bool *created_entry)
void pgstat_unlock_entry(PgStat_EntryRef *entry_ref)
bool pgstat_drop_entry(PgStat_Kind kind, Oid dboid, Oid objoid)
PgStat_EntryRef * pgstat_get_entry_ref_locked(PgStat_Kind kind, Oid dboid, Oid objoid, bool nowait)
ReplicationSlot * SearchNamedReplicationSlot(const char *name, bool need_lock)
int ReplicationSlotIndex(ReplicationSlot *slot)
bool ReplicationSlotName(int index, Name name)
#define SlotIsPhysical(slot)
PgStat_StatReplSlotEntry stats
PgStatShared_Common * shared_stats