PostgreSQL Source Code
git master
|
Go to the source code of this file.
Macros | |
#define | SUB_ACC(fld) shsubent->stats.fld += localent->fld |
Functions | |
void | pgstat_report_subscription_error (Oid subid, bool is_apply_error) |
void | pgstat_report_subscription_conflict (Oid subid, ConflictType type) |
void | pgstat_create_subscription (Oid subid) |
void | pgstat_drop_subscription (Oid subid) |
PgStat_StatSubEntry * | pgstat_fetch_stat_subscription (Oid subid) |
bool | pgstat_subscription_flush_cb (PgStat_EntryRef *entry_ref, bool nowait) |
void | pgstat_subscription_reset_timestamp_cb (PgStatShared_Common *header, TimestampTz ts) |
#define SUB_ACC | ( | fld | ) | shsubent->stats.fld += localent->fld |
void pgstat_create_subscription | ( | Oid | subid | ) |
Definition at line 61 of file pgstat_subscription.c.
References InvalidOid, pgstat_create_transactional(), pgstat_get_entry_ref(), PGSTAT_KIND_SUBSCRIPTION, and pgstat_reset_entry().
Referenced by CreateSubscription().
void pgstat_drop_subscription | ( | Oid | subid | ) |
Definition at line 79 of file pgstat_subscription.c.
References InvalidOid, pgstat_drop_transactional(), and PGSTAT_KIND_SUBSCRIPTION.
Referenced by DropSubscription().
PgStat_StatSubEntry* pgstat_fetch_stat_subscription | ( | Oid | subid | ) |
Definition at line 90 of file pgstat_subscription.c.
References InvalidOid, pgstat_fetch_entry(), and PGSTAT_KIND_SUBSCRIPTION.
Referenced by pg_stat_get_subscription_stats().
void pgstat_report_subscription_conflict | ( | Oid | subid, |
ConflictType | type | ||
) |
Definition at line 46 of file pgstat_subscription.c.
References PgStat_BackendSubEntry::conflict_count, InvalidOid, PgStat_EntryRef::pending, PGSTAT_KIND_SUBSCRIPTION, pgstat_prep_pending_entry(), and type.
Referenced by ReportApplyConflict().
void pgstat_report_subscription_error | ( | Oid | subid, |
bool | is_apply_error | ||
) |
Definition at line 27 of file pgstat_subscription.c.
References PgStat_BackendSubEntry::apply_error_count, InvalidOid, PgStat_EntryRef::pending, PGSTAT_KIND_SUBSCRIPTION, pgstat_prep_pending_entry(), and PgStat_BackendSubEntry::sync_error_count.
Referenced by DisableSubscriptionAndExit(), start_apply(), and start_table_sync().
bool pgstat_subscription_flush_cb | ( | PgStat_EntryRef * | entry_ref, |
bool | nowait | ||
) |
Definition at line 103 of file pgstat_subscription.c.
References CONFLICT_NUM_TYPES, i, PgStat_EntryRef::pending, pgstat_lock_entry(), pgstat_unlock_entry(), PgStat_EntryRef::shared_stats, and SUB_ACC.
void pgstat_subscription_reset_timestamp_cb | ( | PgStatShared_Common * | header, |
TimestampTz | ts | ||
) |
Definition at line 128 of file pgstat_subscription.c.