pgstat_subscription.c File Reference

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

Include dependency graph for pgstat_subscription.c:

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)

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 61 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 79 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 90 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_conflict()

void pgstat_report_subscription_conflict	(	Oid	subid,
		ConflictType	type
	)

Definition at line 46 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;
    pending->conflict_count[type]++;
}

References PgStat_BackendSubEntry::conflict_count, InvalidOid, PgStat_EntryRef::pending, PGSTAT_KIND_SUBSCRIPTION, pgstat_prep_pending_entry(), and type.

Referenced by ReportApplyConflict().

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 103 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);
    for (int i = 0; i < CONFLICT_NUM_TYPES; i++)
        SUB_ACC(conflict_count[i]);
#undef SUB_ACC
 
    pgstat_unlock_entry(entry_ref);
    return true;
}

References CONFLICT_NUM_TYPES, i, 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 128 of file pgstat_subscription.c.

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