pgstat_xact.c File Reference

#include "postgres.h"
#include "access/transam.h"
#include "access/xact.h"
#include "pgstat.h"
#include "utils/memutils.h"
#include "utils/pgstat_internal.h"

Include dependency graph for pgstat_xact.c:

Go to the source code of this file.

Data Structures
struct	PgStat_PendingDroppedStatsItem

Typedefs
typedef struct PgStat_PendingDroppedStatsItem	PgStat_PendingDroppedStatsItem

Functions
static void	AtEOXact_PgStat_DroppedStats (PgStat_SubXactStatus *xact_state, bool isCommit)
static void	AtEOSubXact_PgStat_DroppedStats (PgStat_SubXactStatus *xact_state, bool isCommit, int nestDepth)
void	AtEOXact_PgStat (bool isCommit, bool parallel)
void	AtEOSubXact_PgStat (bool isCommit, int nestDepth)
void	AtPrepare_PgStat (void)
void	PostPrepare_PgStat (void)
PgStat_SubXactStatus *	pgstat_get_xact_stack_level (int nest_level)
int	pgstat_get_transactional_drops (bool isCommit, xl_xact_stats_item **items)
void	pgstat_execute_transactional_drops (int ndrops, struct xl_xact_stats_item *items, bool is_redo)
static void	create_drop_transactional_internal (PgStat_Kind kind, Oid dboid, Oid objoid, bool is_create)
void	pgstat_create_transactional (PgStat_Kind kind, Oid dboid, Oid objoid)
void	pgstat_drop_transactional (PgStat_Kind kind, Oid dboid, Oid objoid)

Variables
static PgStat_SubXactStatus *	pgStatXactStack = NULL

Typedef Documentation

PgStat_PendingDroppedStatsItem

typedef struct PgStat_PendingDroppedStatsItem PgStat_PendingDroppedStatsItem

Function Documentation

AtEOSubXact_PgStat()

void AtEOSubXact_PgStat	(	bool	isCommit,
		int	nestDepth
	)

Definition at line 117 of file pgstat_xact.c.

{
    PgStat_SubXactStatus *xact_state;
 
    /* merge the sub-transaction's transactional stats into the parent */
    xact_state = pgStatXactStack;
    if (xact_state != NULL &&
        xact_state->nest_level >= nestDepth)
    {
        /* delink xact_state from stack immediately to simplify reuse case */
        pgStatXactStack = xact_state->prev;
 
        AtEOSubXact_PgStat_Relations(xact_state, isCommit, nestDepth);
        AtEOSubXact_PgStat_DroppedStats(xact_state, isCommit, nestDepth);
 
        pfree(xact_state);
    }
}

References AtEOSubXact_PgStat_DroppedStats(), AtEOSubXact_PgStat_Relations(), PgStat_SubXactStatus::nest_level, pfree(), pgStatXactStack, and PgStat_SubXactStatus::prev.

Referenced by AbortSubTransaction(), and CommitSubTransaction().

AtEOSubXact_PgStat_DroppedStats()

static void AtEOSubXact_PgStat_DroppedStats ( PgStat_SubXactStatus *  xact_state, bool  isCommit, int  nestDepth  )

static

Definition at line 140 of file pgstat_xact.c.

{
    PgStat_SubXactStatus *parent_xact_state;
    dlist_mutable_iter iter;
    int         not_freed_count = 0;
 
    if (xact_state->pending_drops_count == 0)
        return;
 
    parent_xact_state = pgstat_get_xact_stack_level(nestDepth - 1);
 
    dlist_foreach_modify(iter, &xact_state->pending_drops)
    {
        PgStat_PendingDroppedStatsItem *pending =
        dlist_container(PgStat_PendingDroppedStatsItem, node, iter.cur);
        xl_xact_stats_item *it = &pending->item;
 
        dlist_delete(&pending->node);
        xact_state->pending_drops_count--;
 
        if (!isCommit && pending->is_create)
        {
            /*
             * Subtransaction creating a new stats object aborted. Drop the
             * stats object.
             */
            if (!pgstat_drop_entry(it->kind, it->dboid, it->objoid))
                not_freed_count++;
            pfree(pending);
        }
        else if (isCommit)
        {
            /*
             * Subtransaction dropping a stats object committed. Can't yet
             * remove the stats object, the surrounding transaction might
             * still abort. Pass it on to the parent.
             */
            dlist_push_tail(&parent_xact_state->pending_drops, &pending->node);
            parent_xact_state->pending_drops_count++;
        }
        else
        {
            pfree(pending);
        }
    }
 
    Assert(xact_state->pending_drops_count == 0);
    if (not_freed_count > 0)
        pgstat_request_entry_refs_gc();
}

References Assert(), dlist_mutable_iter::cur, xl_xact_stats_item::dboid, dlist_container, dlist_delete(), dlist_foreach_modify, dlist_push_tail(), PgStat_PendingDroppedStatsItem::is_create, PgStat_PendingDroppedStatsItem::item, xl_xact_stats_item::kind, PgStat_PendingDroppedStatsItem::node, xl_xact_stats_item::objoid, PgStat_SubXactStatus::pending_drops, PgStat_SubXactStatus::pending_drops_count, pfree(), pgstat_drop_entry(), pgstat_get_xact_stack_level(), and pgstat_request_entry_refs_gc().

Referenced by AtEOSubXact_PgStat().

AtEOXact_PgStat()

void AtEOXact_PgStat	(	bool	isCommit,
		bool	parallel
	)

Definition at line 41 of file pgstat_xact.c.

{
    PgStat_SubXactStatus *xact_state;
 
    AtEOXact_PgStat_Database(isCommit, parallel);
 
    /* handle transactional stats information */
    xact_state = pgStatXactStack;
    if (xact_state != NULL)
    {
        Assert(xact_state->nest_level == 1);
        Assert(xact_state->prev == NULL);
 
        AtEOXact_PgStat_Relations(xact_state, isCommit);
        AtEOXact_PgStat_DroppedStats(xact_state, isCommit);
    }
    pgStatXactStack = NULL;
 
    /* Make sure any stats snapshot is thrown away */
    pgstat_clear_snapshot();
}

References Assert(), AtEOXact_PgStat_Database(), AtEOXact_PgStat_DroppedStats(), AtEOXact_PgStat_Relations(), PgStat_SubXactStatus::nest_level, pgstat_clear_snapshot(), pgStatXactStack, and PgStat_SubXactStatus::prev.

Referenced by AbortTransaction(), CommitTransaction(), and FinishPreparedTransaction().

AtEOXact_PgStat_DroppedStats()

static void AtEOXact_PgStat_DroppedStats ( PgStat_SubXactStatus *  xact_state, bool  isCommit  )

static

Definition at line 68 of file pgstat_xact.c.

{
    dlist_mutable_iter iter;
    int         not_freed_count = 0;
 
    if (xact_state->pending_drops_count == 0)
    {
        Assert(dlist_is_empty(&xact_state->pending_drops));
        return;
    }
 
    dlist_foreach_modify(iter, &xact_state->pending_drops)
    {
        PgStat_PendingDroppedStatsItem *pending =
        dlist_container(PgStat_PendingDroppedStatsItem, node, iter.cur);
        xl_xact_stats_item *it = &pending->item;
 
        if (isCommit && !pending->is_create)
        {
            /*
             * Transaction that dropped an object committed. Drop the stats
             * too.
             */
            if (!pgstat_drop_entry(it->kind, it->dboid, it->objoid))
                not_freed_count++;
        }
        else if (!isCommit && pending->is_create)
        {
            /*
             * Transaction that created an object aborted. Drop the stats
             * associated with the object.
             */
            if (!pgstat_drop_entry(it->kind, it->dboid, it->objoid))
                not_freed_count++;
        }
 
        dlist_delete(&pending->node);
        xact_state->pending_drops_count--;
        pfree(pending);
    }
 
    if (not_freed_count > 0)
        pgstat_request_entry_refs_gc();
}

References Assert(), dlist_mutable_iter::cur, xl_xact_stats_item::dboid, dlist_container, dlist_delete(), dlist_foreach_modify, dlist_is_empty(), PgStat_PendingDroppedStatsItem::is_create, PgStat_PendingDroppedStatsItem::item, xl_xact_stats_item::kind, PgStat_PendingDroppedStatsItem::node, xl_xact_stats_item::objoid, PgStat_SubXactStatus::pending_drops, PgStat_SubXactStatus::pending_drops_count, pfree(), pgstat_drop_entry(), and pgstat_request_entry_refs_gc().

Referenced by AtEOXact_PgStat().

AtPrepare_PgStat()

void AtPrepare_PgStat

(

void

)

Definition at line 196 of file pgstat_xact.c.

{
    PgStat_SubXactStatus *xact_state;
 
    xact_state = pgStatXactStack;
    if (xact_state != NULL)
    {
        Assert(xact_state->nest_level == 1);
        Assert(xact_state->prev == NULL);
 
        AtPrepare_PgStat_Relations(xact_state);
    }
}

References Assert(), AtPrepare_PgStat_Relations(), PgStat_SubXactStatus::nest_level, pgStatXactStack, and PgStat_SubXactStatus::prev.

Referenced by PrepareTransaction().

create_drop_transactional_internal()

static void create_drop_transactional_internal ( PgStat_Kind  kind, Oid  dboid, Oid  objoid, bool  is_create  )

static

Definition at line 340 of file pgstat_xact.c.

{
    int         nest_level = GetCurrentTransactionNestLevel();
    PgStat_SubXactStatus *xact_state;
    PgStat_PendingDroppedStatsItem *drop = (PgStat_PendingDroppedStatsItem *)
    MemoryContextAlloc(TopTransactionContext, sizeof(PgStat_PendingDroppedStatsItem));
 
    xact_state = pgstat_get_xact_stack_level(nest_level);
 
    drop->is_create = is_create;
    drop->item.kind = kind;
    drop->item.dboid = dboid;
    drop->item.objoid = objoid;
 
    dlist_push_tail(&xact_state->pending_drops, &drop->node);
    xact_state->pending_drops_count++;
}

References xl_xact_stats_item::dboid, dlist_push_tail(), GetCurrentTransactionNestLevel(), PgStat_PendingDroppedStatsItem::is_create, PgStat_PendingDroppedStatsItem::item, xl_xact_stats_item::kind, MemoryContextAlloc(), PgStat_PendingDroppedStatsItem::node, xl_xact_stats_item::objoid, PgStat_SubXactStatus::pending_drops, PgStat_SubXactStatus::pending_drops_count, pgstat_get_xact_stack_level(), and TopTransactionContext.

Referenced by pgstat_create_transactional(), and pgstat_drop_transactional().

pgstat_create_transactional()

void pgstat_create_transactional	(	PgStat_Kind	kind,
		Oid	dboid,
		Oid	objoid
	)

Definition at line 366 of file pgstat_xact.c.

{
    if (pgstat_get_entry_ref(kind, dboid, objoid, false, NULL))
    {
        ereport(WARNING,
                errmsg("resetting existing stats for type %s, db=%u, oid=%u",
                       (pgstat_get_kind_info(kind))->name, dboid, objoid));
 
        pgstat_reset(kind, dboid, objoid);
    }
 
    create_drop_transactional_internal(kind, dboid, objoid, /* create */ true);
}

References create_drop_transactional_internal(), ereport, errmsg(), name, pgstat_get_entry_ref(), pgstat_get_kind_info(), pgstat_reset(), and WARNING.

Referenced by pgstat_create_function(), pgstat_create_relation(), and pgstat_create_subscription().

pgstat_drop_transactional()

void pgstat_drop_transactional	(	PgStat_Kind	kind,
		Oid	dboid,
		Oid	objoid
	)

Definition at line 388 of file pgstat_xact.c.

{
    create_drop_transactional_internal(kind, dboid, objoid, /* create */ false);
}

References create_drop_transactional_internal().

Referenced by pgstat_drop_database(), pgstat_drop_function(), pgstat_drop_relation(), and pgstat_drop_subscription().

pgstat_execute_transactional_drops()

void pgstat_execute_transactional_drops	(	int	ndrops,
		struct xl_xact_stats_item *	items,
		bool	is_redo
	)

Definition at line 320 of file pgstat_xact.c.

{
    int         not_freed_count = 0;
 
    if (ndrops == 0)
        return;
 
    for (int i = 0; i < ndrops; i++)
    {
        xl_xact_stats_item *it = &items[i];
 
        if (!pgstat_drop_entry(it->kind, it->dboid, it->objoid))
            not_freed_count++;
    }
 
    if (not_freed_count > 0)
        pgstat_request_entry_refs_gc();
}

References xl_xact_stats_item::dboid, i, xl_xact_stats_item::kind, xl_xact_stats_item::objoid, pgstat_drop_entry(), and pgstat_request_entry_refs_gc().

Referenced by FinishPreparedTransaction(), xact_redo_abort(), and xact_redo_commit().

pgstat_get_transactional_drops()

int pgstat_get_transactional_drops	(	bool	isCommit,
		xl_xact_stats_item **	items
	)

Definition at line 278 of file pgstat_xact.c.

{
    PgStat_SubXactStatus *xact_state = pgStatXactStack;
    int         nitems = 0;
    dlist_iter  iter;
 
    if (xact_state == NULL)
        return 0;
 
    /*
     * We expect to be called for subtransaction abort (which logs a WAL
     * record), but not for subtransaction commit (which doesn't).
     */
    Assert(!isCommit || xact_state->nest_level == 1);
    Assert(!isCommit || xact_state->prev == NULL);
 
    *items = palloc(xact_state->pending_drops_count
                    * sizeof(xl_xact_stats_item));
 
    dlist_foreach(iter, &xact_state->pending_drops)
    {
        PgStat_PendingDroppedStatsItem *pending =
        dlist_container(PgStat_PendingDroppedStatsItem, node, iter.cur);
 
        if (isCommit && pending->is_create)
            continue;
        if (!isCommit && !pending->is_create)
            continue;
 
        Assert(nitems < xact_state->pending_drops_count);
        (*items)[nitems++] = pending->item;
    }
 
    return nitems;
}

References Assert(), dlist_iter::cur, dlist_container, dlist_foreach, PgStat_PendingDroppedStatsItem::is_create, PgStat_PendingDroppedStatsItem::item, PgStat_SubXactStatus::nest_level, palloc(), PgStat_SubXactStatus::pending_drops, PgStat_SubXactStatus::pending_drops_count, pgStatXactStack, and PgStat_SubXactStatus::prev.

Referenced by RecordTransactionAbort(), RecordTransactionCommit(), and StartPrepare().

pgstat_get_xact_stack_level()

PgStat_SubXactStatus* pgstat_get_xact_stack_level

(

int

nest_level

)

Definition at line 243 of file pgstat_xact.c.

{
    PgStat_SubXactStatus *xact_state;
 
    xact_state = pgStatXactStack;
    if (xact_state == NULL || xact_state->nest_level != nest_level)
    {
        xact_state = (PgStat_SubXactStatus *)
            MemoryContextAlloc(TopTransactionContext,
                               sizeof(PgStat_SubXactStatus));
        dlist_init(&xact_state->pending_drops);
        xact_state->pending_drops_count = 0;
        xact_state->nest_level = nest_level;
        xact_state->prev = pgStatXactStack;
        xact_state->first = NULL;
        pgStatXactStack = xact_state;
    }
    return xact_state;
}

References dlist_init(), PgStat_SubXactStatus::first, MemoryContextAlloc(), PgStat_SubXactStatus::nest_level, PgStat_SubXactStatus::pending_drops, PgStat_SubXactStatus::pending_drops_count, pgStatXactStack, PgStat_SubXactStatus::prev, and TopTransactionContext.

Referenced by add_tabstat_xact_level(), AtEOSubXact_PgStat_DroppedStats(), AtEOSubXact_PgStat_Relations(), and create_drop_transactional_internal().

PostPrepare_PgStat()

void PostPrepare_PgStat

(

void

)

Definition at line 216 of file pgstat_xact.c.

{
    PgStat_SubXactStatus *xact_state;
 
    /*
     * We don't bother to free any of the transactional state, since it's all
     * in TopTransactionContext and will go away anyway.
     */
    xact_state = pgStatXactStack;
    if (xact_state != NULL)
    {
        Assert(xact_state->nest_level == 1);
        Assert(xact_state->prev == NULL);
 
        PostPrepare_PgStat_Relations(xact_state);
    }
    pgStatXactStack = NULL;
 
    /* Make sure any stats snapshot is thrown away */
    pgstat_clear_snapshot();
}

References Assert(), PgStat_SubXactStatus::nest_level, pgstat_clear_snapshot(), pgStatXactStack, PostPrepare_PgStat_Relations(), and PgStat_SubXactStatus::prev.

Referenced by PrepareTransaction().

Variable Documentation

pgStatXactStack

PgStat_SubXactStatus* pgStatXactStack = NULL

static

Definition at line 34 of file pgstat_xact.c.

Referenced by AtEOSubXact_PgStat(), AtEOXact_PgStat(), AtPrepare_PgStat(), pgstat_get_transactional_drops(), pgstat_get_xact_stack_level(), and PostPrepare_PgStat().