101 #define SUB_ACC(fld) shsubent->stats.fld += localent->fld
void * pgstat_fetch_entry(PgStat_Kind kind, Oid dboid, Oid objoid)
PgStat_EntryRef * pgstat_prep_pending_entry(PgStat_Kind kind, Oid dboid, Oid objoid, bool *created_entry)
@ PGSTAT_KIND_SUBSCRIPTION
void pgstat_reset_entry(PgStat_Kind kind, Oid dboid, Oid objoid, TimestampTz ts)
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_lock_entry(PgStat_EntryRef *entry_ref, bool nowait)
void pgstat_drop_subscription(Oid subid)
void pgstat_create_subscription(Oid subid)
PgStat_StatSubEntry * pgstat_fetch_stat_subscription(Oid subid)
void pgstat_report_subscription_error(Oid subid, bool is_apply_error)
bool pgstat_subscription_flush_cb(PgStat_EntryRef *entry_ref, bool nowait)
void pgstat_subscription_reset_timestamp_cb(PgStatShared_Common *header, TimestampTz ts)
void pgstat_create_transactional(PgStat_Kind kind, Oid dboid, Oid objoid)
void pgstat_drop_transactional(PgStat_Kind kind, Oid dboid, Oid objoid)
PgStat_Counter apply_error_count
PgStat_Counter sync_error_count
PgStatShared_Common * shared_stats