54 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
55 errmsg(
"replication slot \"%s\" does not exist",
83 statent = &shstatent->
stats;
92 #define REPLSLOT_ACC(fld) statent->fld += repSlotStat->fld
126 memset(&shstatent->
stats, 0,
sizeof(shstatent->
stats));
145 statent = &shstatent->
stats;
154 memset(statent, 0,
sizeof(*statent));
Datum idx(PG_FUNCTION_ARGS)
#define AssertArg(condition)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
Assert(fmt[strlen(fmt) - 1] !='\n')
int namestrcmp(Name name, const char *str)
void namestrcpy(Name name, const char *str)
static void header(const char *fmt,...) pg_attribute_printf(1
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 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)
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)
#define SlotIsPhysical(slot)
PgStat_StatReplSlotEntry stats
PgStatShared_Common * shared_stats
ReplicationSlotPersistentData data