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 120 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_get_entry_ref_locked(PGSTAT_KIND_INJECTION, InvalidOid,
                                             PGSTAT_INJ_IDX(name), false);
     shstatent = (PgStatShared_InjectionPoint *) entry_ref->shared_stats;
  
     /* initialize shared memory data */
     memset(&shstatent->stats, 0, sizeof(shstatent->stats));
     pgstat_unlock_entry(entry_ref);
 }

References inj_stats_enabled, inj_stats_loaded, InvalidOid, name, pgstat_get_entry_ref_locked(), PGSTAT_INJ_IDX, PGSTAT_KIND_INJECTION, pgstat_unlock_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 142 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 108 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 128 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 160 of file injection_stats.c.

 {
     PgStat_EntryRef *entry_ref;
     PgStatShared_InjectionPoint *shstatent;
     PgStat_StatInjEntry *statent;
  
     /* leave if disabled */
     if (!inj_stats_loaded || !inj_stats_enabled)
         return;
  
     entry_ref = pgstat_get_entry_ref_locked(PGSTAT_KIND_INJECTION, InvalidOid,
                                             PGSTAT_INJ_IDX(name), false);
  
     shstatent = (PgStatShared_InjectionPoint *) entry_ref->shared_stats;
     statent = &shstatent->stats;
  
     /* Update the injection point statistics */
     statent->numcalls++;
  
     pgstat_unlock_entry(entry_ref);
 }

References inj_stats_enabled, inj_stats_loaded, InvalidOid, name, PgStat_StatInjEntry::numcalls, pgstat_get_entry_ref_locked(), PGSTAT_INJ_IDX, PGSTAT_KIND_INJECTION, pgstat_unlock_entry(), PgStat_EntryRef::shared_stats, and PgStatShared_InjectionPoint::stats.

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 140 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);
  
     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);
 }

References PgStatShared_InjectionPointFixed::changecount, inj_fixed_loaded, inj_stats_enabled, 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_cached(), injection_points_detach(), injection_points_load(), and injection_points_run().

Variable Documentation

◆ inj_stats_enabled

bool inj_stats_enabled

extern

Definition at line 113 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