#include "postgres.h"
#include "utils/pgstat_internal.h"

Include dependency graph for pgstat_subscription.c:

Macros
#define	SUB_ACC(fld) shsubent->stats.fld += localent->fld

Functions
void	pgstat_report_subscription_error (Oid subid, bool is_apply_error)

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)

Macro Definition Documentation

◆ SUB_ACC

#define SUB_ACC ( fld ) shsubent->stats.fld += localent->fld

Function Documentation

◆ pgstat_create_subscription()

void pgstat_create_subscription ( Oid subid )

Definition at line 46 of file pgstat_subscription.c.

 {
     /* Ensures that stats are dropped if transaction rolls back */
     pgstat_create_transactional(PGSTAT_KIND_SUBSCRIPTION,
                                 InvalidOid, subid);
  
     /* Create and initialize the subscription stats entry */
     pgstat_get_entry_ref(PGSTAT_KIND_SUBSCRIPTION, InvalidOid, subid,
                          true, NULL);
     pgstat_reset_entry(PGSTAT_KIND_SUBSCRIPTION, InvalidOid, subid, 0);
 }

References InvalidOid, pgstat_create_transactional(), pgstat_get_entry_ref(), PGSTAT_KIND_SUBSCRIPTION, and pgstat_reset_entry().

Referenced by CreateSubscription().

◆ pgstat_drop_subscription()

void pgstat_drop_subscription ( Oid subid )

Definition at line 64 of file pgstat_subscription.c.

 {
     pgstat_drop_transactional(PGSTAT_KIND_SUBSCRIPTION,
                               InvalidOid, subid);
 }

References InvalidOid, pgstat_drop_transactional(), and PGSTAT_KIND_SUBSCRIPTION.

Referenced by DropSubscription().

◆ pgstat_fetch_stat_subscription()

PgStat_StatSubEntry* pgstat_fetch_stat_subscription ( Oid subid )

Definition at line 75 of file pgstat_subscription.c.

 {
     return (PgStat_StatSubEntry *)
         pgstat_fetch_entry(PGSTAT_KIND_SUBSCRIPTION, InvalidOid, subid);
 }

References InvalidOid, pgstat_fetch_entry(), and PGSTAT_KIND_SUBSCRIPTION.

Referenced by pg_stat_get_subscription_stats().

◆ pgstat_report_subscription_error()

void pgstat_report_subscription_error	(	Oid	subid,
		bool	is_apply_error
	)

Definition at line 27 of file pgstat_subscription.c.

 {
     PgStat_EntryRef *entry_ref;
     PgStat_BackendSubEntry *pending;
  
     entry_ref = pgstat_prep_pending_entry(PGSTAT_KIND_SUBSCRIPTION,
                                           InvalidOid, subid, NULL);
     pending = entry_ref->pending;
  
     if (is_apply_error)
         pending->apply_error_count++;
     else
         pending->sync_error_count++;
 }

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().

◆ pgstat_subscription_flush_cb()

bool pgstat_subscription_flush_cb	(	PgStat_EntryRef *	entry_ref,
		bool	nowait
	)

Definition at line 88 of file pgstat_subscription.c.

 {
     PgStat_BackendSubEntry *localent;
     PgStatShared_Subscription *shsubent;
  
     localent = (PgStat_BackendSubEntry *) entry_ref->pending;
     shsubent = (PgStatShared_Subscription *) entry_ref->shared_stats;
  
     /* localent always has non-zero content */
  
     if (!pgstat_lock_entry(entry_ref, nowait))
         return false;
  
 #define SUB_ACC(fld) shsubent->stats.fld += localent->fld
     SUB_ACC(apply_error_count);
     SUB_ACC(sync_error_count);
 #undef SUB_ACC
  
     pgstat_unlock_entry(entry_ref);
     return true;
 }

References PgStat_EntryRef::pending, pgstat_lock_entry(), pgstat_unlock_entry(), PgStat_EntryRef::shared_stats, and SUB_ACC.

◆ pgstat_subscription_reset_timestamp_cb()

void pgstat_subscription_reset_timestamp_cb	(	PgStatShared_Common *	header,
		TimestampTz	ts
	)

Definition at line 111 of file pgstat_subscription.c.

 {
     ((PgStatShared_Subscription *) header)->stats.stat_reset_timestamp = ts;
 }

Macros

Functions