injection_stats_fixed.c File Reference

#include "postgres.h"
#include "fmgr.h"
#include "access/htup_details.h"
#include "common/hashfn.h"
#include "funcapi.h"
#include "injection_stats.h"
#include "pgstat.h"
#include "utils/builtins.h"
#include "utils/pgstat_internal.h"

Include dependency graph for injection_stats_fixed.c:

Go to the source code of this file.

Data Structures
struct	PgStat_StatInjFixedEntry
struct	PgStatShared_InjectionPointFixed

Macros
#define	PGSTAT_KIND_INJECTION_FIXED   26
#define	FIXED_COMP(fld)   stat_snap->fld -= reset.fld;

Typedefs
typedef struct PgStat_StatInjFixedEntry	PgStat_StatInjFixedEntry
typedef struct PgStatShared_InjectionPointFixed	PgStatShared_InjectionPointFixed

Functions
static void	injection_stats_fixed_init_shmem_cb (void *stats)
static void	injection_stats_fixed_reset_all_cb (TimestampTz ts)
static void	injection_stats_fixed_snapshot_cb (void)
void	pgstat_register_inj_fixed (void)
void	pgstat_report_inj_fixed (uint32 numattach, uint32 numdetach, uint32 numrun, uint32 numcached, uint32 numloaded)
	PG_FUNCTION_INFO_V1 (injection_points_stats_fixed)
Datum	injection_points_stats_fixed (PG_FUNCTION_ARGS)

Variables
static const PgStat_KindInfo	injection_stats_fixed
static bool	inj_fixed_loaded = false

Macro Definition Documentation

FIXED_COMP

#define FIXED_COMP

(

fld

)

stat_snap->fld -= reset.fld;

PGSTAT_KIND_INJECTION_FIXED

#define PGSTAT_KIND_INJECTION_FIXED   26

Definition at line 68 of file injection_stats_fixed.c.

Typedef Documentation

PgStat_StatInjFixedEntry

typedef struct PgStat_StatInjFixedEntry PgStat_StatInjFixedEntry

PgStatShared_InjectionPointFixed

typedef struct PgStatShared_InjectionPointFixed PgStatShared_InjectionPointFixed

Function Documentation

injection_points_stats_fixed()

Datum injection_points_stats_fixed

(

PG_FUNCTION_ARGS

)

Definition at line 174 of file injection_stats_fixed.c.

{
    TupleDesc   tupdesc;
    Datum       values[5] = {0};
    bool        nulls[5] = {0};
    PgStat_StatInjFixedEntry *stats;
 
    if (!inj_fixed_loaded || !inj_stats_enabled)
        PG_RETURN_NULL();
 
    pgstat_snapshot_fixed(PGSTAT_KIND_INJECTION_FIXED);
    stats = pgstat_get_custom_snapshot_data(PGSTAT_KIND_INJECTION_FIXED);
 
    /* Initialise attributes information in the tuple descriptor */
    tupdesc = CreateTemplateTupleDesc(5);
    TupleDescInitEntry(tupdesc, (AttrNumber) 1, "numattach",
                       INT8OID, -1, 0);
    TupleDescInitEntry(tupdesc, (AttrNumber) 2, "numdetach",
                       INT8OID, -1, 0);
    TupleDescInitEntry(tupdesc, (AttrNumber) 3, "numrun",
                       INT8OID, -1, 0);
    TupleDescInitEntry(tupdesc, (AttrNumber) 4, "numcached",
                       INT8OID, -1, 0);
    TupleDescInitEntry(tupdesc, (AttrNumber) 5, "numloaded",
                       INT8OID, -1, 0);
    BlessTupleDesc(tupdesc);
 
    values[0] = Int64GetDatum(stats->numattach);
    values[1] = Int64GetDatum(stats->numdetach);
    values[2] = Int64GetDatum(stats->numrun);
    values[3] = Int64GetDatum(stats->numcached);
    values[4] = Int64GetDatum(stats->numloaded);
    nulls[0] = false;
    nulls[1] = false;
    nulls[2] = false;
    nulls[3] = false;
    nulls[4] = false;
 
    /* Returns the record as Datum */
    PG_RETURN_DATUM(HeapTupleGetDatum(heap_form_tuple(tupdesc, values, nulls)));
}

References BlessTupleDesc(), CreateTemplateTupleDesc(), heap_form_tuple(), HeapTupleGetDatum(), inj_fixed_loaded, inj_stats_enabled, Int64GetDatum(), PgStat_StatInjFixedEntry::numattach, PgStat_StatInjFixedEntry::numcached, PgStat_StatInjFixedEntry::numdetach, PgStat_StatInjFixedEntry::numloaded, PgStat_StatInjFixedEntry::numrun, PG_RETURN_DATUM, PG_RETURN_NULL, pgstat_get_custom_snapshot_data(), PGSTAT_KIND_INJECTION_FIXED, pgstat_snapshot_fixed(), TupleDescInitEntry(), and values.

injection_stats_fixed_init_shmem_cb()

static void injection_stats_fixed_init_shmem_cb ( void *  stats )

static

Definition at line 74 of file injection_stats_fixed.c.

{
    PgStatShared_InjectionPointFixed *stats_shmem =
        (PgStatShared_InjectionPointFixed *) stats;
 
    LWLockInitialize(&stats_shmem->lock, LWTRANCHE_PGSTATS_DATA);
}

References PgStatShared_InjectionPointFixed::lock, and LWLockInitialize().

injection_stats_fixed_reset_all_cb()

static void injection_stats_fixed_reset_all_cb ( TimestampTz  ts )

static

Definition at line 83 of file injection_stats_fixed.c.

{
    PgStatShared_InjectionPointFixed *stats_shmem =
        pgstat_get_custom_shmem_data(PGSTAT_KIND_INJECTION_FIXED);
 
    LWLockAcquire(&stats_shmem->lock, LW_EXCLUSIVE);
    pgstat_copy_changecounted_stats(&stats_shmem->reset_offset,
                                    &stats_shmem->stats,
                                    sizeof(stats_shmem->stats),
                                    &stats_shmem->changecount);
    stats_shmem->stats.stat_reset_timestamp = ts;
    LWLockRelease(&stats_shmem->lock);
}

References PgStatShared_InjectionPointFixed::changecount, PgStatShared_InjectionPointFixed::lock, LW_EXCLUSIVE, LWLockAcquire(), LWLockRelease(), pgstat_copy_changecounted_stats(), pgstat_get_custom_shmem_data(), PGSTAT_KIND_INJECTION_FIXED, PgStatShared_InjectionPointFixed::reset_offset, PgStat_StatInjFixedEntry::stat_reset_timestamp, and PgStatShared_InjectionPointFixed::stats.

injection_stats_fixed_snapshot_cb()

static void injection_stats_fixed_snapshot_cb ( void  )

static

Definition at line 98 of file injection_stats_fixed.c.

{
    PgStatShared_InjectionPointFixed *stats_shmem =
        pgstat_get_custom_shmem_data(PGSTAT_KIND_INJECTION_FIXED);
    PgStat_StatInjFixedEntry *stat_snap =
        pgstat_get_custom_snapshot_data(PGSTAT_KIND_INJECTION_FIXED);
    PgStat_StatInjFixedEntry *reset_offset = &stats_shmem->reset_offset;
    PgStat_StatInjFixedEntry reset;
 
    pgstat_copy_changecounted_stats(stat_snap,
                                    &stats_shmem->stats,
                                    sizeof(stats_shmem->stats),
                                    &stats_shmem->changecount);
 
    LWLockAcquire(&stats_shmem->lock, LW_SHARED);
    memcpy(&reset, reset_offset, sizeof(stats_shmem->stats));
    LWLockRelease(&stats_shmem->lock);
 
    /* compensate by reset offsets */
#define FIXED_COMP(fld) stat_snap->fld -= reset.fld;
    FIXED_COMP(numattach);
    FIXED_COMP(numdetach);
    FIXED_COMP(numrun);
    FIXED_COMP(numcached);
    FIXED_COMP(numloaded);
#undef FIXED_COMP
}

References PgStatShared_InjectionPointFixed::changecount, FIXED_COMP, PgStatShared_InjectionPointFixed::lock, LW_SHARED, LWLockAcquire(), LWLockRelease(), pgstat_copy_changecounted_stats(), pgstat_get_custom_shmem_data(), pgstat_get_custom_snapshot_data(), PGSTAT_KIND_INJECTION_FIXED, reset(), PgStatShared_InjectionPointFixed::reset_offset, and PgStatShared_InjectionPointFixed::stats.

PG_FUNCTION_INFO_V1()

PG_FUNCTION_INFO_V1

(

injection_points_stats_fixed

)

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_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_fixed_loaded

bool inj_fixed_loaded = false

static

Definition at line 71 of file injection_stats_fixed.c.

Referenced by injection_points_stats_fixed(), pgstat_register_inj_fixed(), and pgstat_report_inj_fixed().

injection_stats_fixed

const PgStat_KindInfo injection_stats_fixed

static

Initial value:

= {
    .name = "injection_points_fixed",
    .fixed_amount = true,
    .write_to_file = true,
 
    .shared_size = sizeof(PgStat_StatInjFixedEntry),
    .shared_data_off = offsetof(PgStatShared_InjectionPointFixed, stats),
    .shared_data_len = sizeof(((PgStatShared_InjectionPointFixed *) 0)->stats),
 
    .init_shmem_cb = injection_stats_fixed_init_shmem_cb,
    .reset_all_cb = injection_stats_fixed_reset_all_cb,
    .snapshot_cb = injection_stats_fixed_snapshot_cb,
}

Definition at line 51 of file injection_stats_fixed.c.

Referenced by pgstat_register_inj_fixed().