This graph shows which files directly or indirectly include this file:

Functions
void	pgstat_register_inj (void)

void	pgstat_create_inj (const char *name)

void	pgstat_drop_inj (const char *name)

void	pgstat_report_inj (const char *name)

void	pgstat_register_inj_fixed (void)

void	pgstat_report_inj_fixed (uint32 numattach, uint32 numdetach, uint32 numrun, uint32 numcached, uint32 numloaded)

Variables
bool	inj_stats_enabled

Function Documentation

◆ pgstat_create_inj()

void pgstat_create_inj ( const char * name )

Definition at line 125 of file injection_stats.c.

{
    PgStat_EntryRef *entry_ref;
    PgStatShared_InjectionPoint *shstatent;
 
    /* leave if disabled */
    if (!inj_stats_loaded || !inj_stats_enabled)
        return;
 
    entry_ref = pgstat_prep_pending_entry(PGSTAT_KIND_INJECTION, InvalidOid,
                                          PGSTAT_INJ_IDX(name), NULL);
 
    shstatent = (PgStatShared_InjectionPoint *) entry_ref->shared_stats;
 
    /* initialize shared memory data */
    memset(&shstatent->stats, 0, sizeof(shstatent->stats));
}

References inj_stats_enabled, inj_stats_loaded, InvalidOid, name, PGSTAT_INJ_IDX, PGSTAT_KIND_INJECTION, pgstat_prep_pending_entry(), PgStat_EntryRef::shared_stats, and PgStatShared_InjectionPoint::stats.

Referenced by injection_points_attach().

◆ pgstat_drop_inj()

void pgstat_drop_inj ( const char * name )

Definition at line 147 of file injection_stats.c.

{
    /* leave if disabled */
    if (!inj_stats_loaded || !inj_stats_enabled)
        return;
 
    if (!pgstat_drop_entry(PGSTAT_KIND_INJECTION, InvalidOid,
                           PGSTAT_INJ_IDX(name)))
        pgstat_request_entry_refs_gc();
}

References inj_stats_enabled, inj_stats_loaded, InvalidOid, name, pgstat_drop_entry(), PGSTAT_INJ_IDX, PGSTAT_KIND_INJECTION, and pgstat_request_entry_refs_gc().

Referenced by injection_points_cleanup(), and injection_points_detach().

◆ pgstat_register_inj()

void pgstat_register_inj ( void )

Definition at line 113 of file injection_stats.c.

{
    pgstat_register_kind(PGSTAT_KIND_INJECTION, &injection_stats);
 
    /* mark stats as loaded */
    inj_stats_loaded = true;
}

References inj_stats_loaded, injection_stats, PGSTAT_KIND_INJECTION, and pgstat_register_kind().

Referenced by _PG_init().

◆ pgstat_register_inj_fixed()

void pgstat_register_inj_fixed ( void )

Definition at line 130 of file injection_stats_fixed.c.

{
    pgstat_register_kind(PGSTAT_KIND_INJECTION_FIXED, &injection_stats_fixed);
 
    /* mark stats as loaded */
    inj_fixed_loaded = true;
}

References inj_fixed_loaded, injection_stats_fixed, PGSTAT_KIND_INJECTION_FIXED, and pgstat_register_kind().

Referenced by _PG_init().

◆ pgstat_report_inj()

void pgstat_report_inj ( const char * name )

Definition at line 165 of file injection_stats.c.

{
    PgStat_EntryRef *entry_ref;
    PgStat_StatInjEntry *pending;
 
    /* leave if disabled */
    if (!inj_stats_loaded || !inj_stats_enabled)
        return;
 
    entry_ref = pgstat_prep_pending_entry(PGSTAT_KIND_INJECTION, InvalidOid,
                                          PGSTAT_INJ_IDX(name), NULL);
 
    pending = (PgStat_StatInjEntry *) entry_ref->pending;
 
    /* Update the injection point pending statistics */
    pending->numcalls++;
}

References inj_stats_enabled, inj_stats_loaded, InvalidOid, name, PgStat_StatInjEntry::numcalls, PgStat_EntryRef::pending, PGSTAT_INJ_IDX, PGSTAT_KIND_INJECTION, and pgstat_prep_pending_entry().

Referenced by injection_error(), injection_notice(), and injection_wait().

◆ pgstat_report_inj_fixed()

void pgstat_report_inj_fixed	(	uint32	numattach,
		uint32	numdetach,
		uint32	numrun,
		uint32	numcached,
		uint32	numloaded
	)

Definition at line 142 of file injection_stats_fixed.c.

{
    PgStatShared_InjectionPointFixed *stats_shmem;
 
    /* leave if disabled */
    if (!inj_fixed_loaded || !inj_stats_enabled)
        return;
 
    stats_shmem = pgstat_get_custom_shmem_data(PGSTAT_KIND_INJECTION_FIXED);
 
    LWLockAcquire(&stats_shmem->lock, LW_EXCLUSIVE);
 
    pgstat_begin_changecount_write(&stats_shmem->changecount);
    stats_shmem->stats.numattach += numattach;
    stats_shmem->stats.numdetach += numdetach;
    stats_shmem->stats.numrun += numrun;
    stats_shmem->stats.numcached += numcached;
    stats_shmem->stats.numloaded += numloaded;
    pgstat_end_changecount_write(&stats_shmem->changecount);
 
    LWLockRelease(&stats_shmem->lock);
}

References PgStatShared_InjectionPointFixed::changecount, inj_fixed_loaded, inj_stats_enabled, PgStatShared_InjectionPointFixed::lock, LW_EXCLUSIVE, LWLockAcquire(), LWLockRelease(), PgStat_StatInjFixedEntry::numattach, PgStat_StatInjFixedEntry::numcached, PgStat_StatInjFixedEntry::numdetach, PgStat_StatInjFixedEntry::numloaded, PgStat_StatInjFixedEntry::numrun, pgstat_begin_changecount_write(), pgstat_end_changecount_write(), pgstat_get_custom_shmem_data(), PGSTAT_KIND_INJECTION_FIXED, and PgStatShared_InjectionPointFixed::stats.

Referenced by injection_points_attach(), injection_points_attach_func(), injection_points_cached(), injection_points_detach(), injection_points_load(), and injection_points_run().

Variable Documentation

◆ inj_stats_enabled

bool inj_stats_enabled

extern

Definition at line 117 of file injection_points.c.

Referenced by _PG_init(), injection_points_stats_fixed(), pgstat_create_inj(), pgstat_drop_inj(), pgstat_fetch_stat_injentry(), pgstat_report_inj(), and pgstat_report_inj_fixed().

Functions

Variables