116#define SUB_ACC(fld) shsubent->stats.fld += localent->fld
#define CONFLICT_NUM_TYPES
PgStat_EntryRef * pgstat_prep_pending_entry(PgStat_Kind kind, Oid dboid, uint64 objid, bool *created_entry)
void * pgstat_fetch_entry(PgStat_Kind kind, Oid dboid, uint64 objid)
#define PGSTAT_KIND_SUBSCRIPTION
PgStat_EntryRef * pgstat_get_entry_ref(PgStat_Kind kind, Oid dboid, uint64 objid, bool create, bool *created_entry)
void pgstat_reset_entry(PgStat_Kind kind, Oid dboid, uint64 objid, TimestampTz ts)
void pgstat_unlock_entry(PgStat_EntryRef *entry_ref)
bool pgstat_lock_entry(PgStat_EntryRef *entry_ref, bool nowait)
void pgstat_drop_subscription(Oid subid)
void pgstat_create_subscription(Oid subid)
void pgstat_report_subscription_conflict(Oid subid, ConflictType type)
void pgstat_report_subscription_error(Oid subid, bool is_apply_error)
bool pgstat_subscription_flush_cb(PgStat_EntryRef *entry_ref, bool nowait)
PgStat_StatSubEntry * pgstat_fetch_stat_subscription(Oid subid)
void pgstat_subscription_reset_timestamp_cb(PgStatShared_Common *header, TimestampTz ts)
void pgstat_drop_transactional(PgStat_Kind kind, Oid dboid, uint64 objid)
void pgstat_create_transactional(PgStat_Kind kind, Oid dboid, uint64 objid)
PgStat_Counter apply_error_count
PgStat_Counter sync_error_count
PgStat_Counter conflict_count[CONFLICT_NUM_TYPES]
PgStatShared_Common * shared_stats