nodeBitmapHeapscan.h File Reference

#include "access/parallel.h"
#include "nodes/execnodes.h"

Include dependency graph for nodeBitmapHeapscan.h:

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

Go to the source code of this file.

Functions
BitmapHeapScanState *	ExecInitBitmapHeapScan (BitmapHeapScan *node, EState *estate, int eflags)
void	ExecEndBitmapHeapScan (BitmapHeapScanState *node)
void	ExecReScanBitmapHeapScan (BitmapHeapScanState *node)
void	ExecBitmapHeapEstimate (BitmapHeapScanState *node, ParallelContext *pcxt)
void	ExecBitmapHeapInitializeDSM (BitmapHeapScanState *node, ParallelContext *pcxt)
void	ExecBitmapHeapReInitializeDSM (BitmapHeapScanState *node, ParallelContext *pcxt)
void	ExecBitmapHeapInitializeWorker (BitmapHeapScanState *node, ParallelWorkerContext *pwcxt)
void	ExecBitmapHeapInstrumentEstimate (BitmapHeapScanState *node, ParallelContext *pcxt)
void	ExecBitmapHeapInstrumentInitDSM (BitmapHeapScanState *node, ParallelContext *pcxt)
void	ExecBitmapHeapInstrumentInitWorker (BitmapHeapScanState *node, ParallelWorkerContext *pwcxt)
void	ExecBitmapHeapRetrieveInstrumentation (BitmapHeapScanState *node)

Function Documentation

ExecBitmapHeapEstimate()

void ExecBitmapHeapEstimate ( BitmapHeapScanState *  node, ParallelContext *  pcxt  )

extern

Definition at line 510 of file nodeBitmapHeapscan.c.

{
    shm_toc_estimate_chunk(&pcxt->estimator,
                           MAXALIGN(sizeof(ParallelBitmapHeapState)));
    shm_toc_estimate_keys(&pcxt->estimator, 1);
}

References ParallelContext::estimator, MAXALIGN, shm_toc_estimate_chunk, and shm_toc_estimate_keys.

Referenced by ExecParallelEstimate().

ExecBitmapHeapInitializeDSM()

void ExecBitmapHeapInitializeDSM ( BitmapHeapScanState *  node, ParallelContext *  pcxt  )

extern

Definition at line 525 of file nodeBitmapHeapscan.c.

{
    ParallelBitmapHeapState *pstate;
    dsa_area   *dsa = node->ss.ps.state->es_query_dsa;
 
    /* If there's no DSA, there are no workers; initialize nothing. */
    if (dsa == NULL)
        return;
 
    pstate = (ParallelBitmapHeapState *)
        shm_toc_allocate(pcxt->toc,
                         MAXALIGN(sizeof(ParallelBitmapHeapState)));
 
    pstate->tbmiterator = 0;
 
    /* Initialize the mutex */
    SpinLockInit(&pstate->mutex);
    pstate->state = BM_INITIAL;
 
    ConditionVariableInit(&pstate->cv);
 
    shm_toc_insert(pcxt->toc, node->ss.ps.plan->plan_node_id, pstate);
    node->pstate = pstate;
}

References BM_INITIAL, ConditionVariableInit(), ParallelBitmapHeapState::cv, EState::es_query_dsa, fb(), MAXALIGN, ParallelBitmapHeapState::mutex, PlanState::plan, Plan::plan_node_id, ScanState::ps, BitmapHeapScanState::pstate, shm_toc_allocate(), shm_toc_insert(), SpinLockInit(), BitmapHeapScanState::ss, ParallelBitmapHeapState::state, PlanState::state, ParallelBitmapHeapState::tbmiterator, and ParallelContext::toc.

Referenced by ExecParallelInitializeDSM().

ExecBitmapHeapInitializeWorker()

void ExecBitmapHeapInitializeWorker ( BitmapHeapScanState *  node, ParallelWorkerContext *  pwcxt  )

extern

Definition at line 583 of file nodeBitmapHeapscan.c.

{
    Assert(node->ss.ps.state->es_query_dsa != NULL);
 
    node->pstate = (ParallelBitmapHeapState *)
        shm_toc_lookup(pwcxt->toc, node->ss.ps.plan->plan_node_id, false);
}

References Assert, EState::es_query_dsa, fb(), PlanState::plan, Plan::plan_node_id, ScanState::ps, BitmapHeapScanState::pstate, shm_toc_lookup(), BitmapHeapScanState::ss, and PlanState::state.

Referenced by ExecParallelInitializeWorker().

ExecBitmapHeapInstrumentEstimate()

void ExecBitmapHeapInstrumentEstimate ( BitmapHeapScanState *  node, ParallelContext *  pcxt  )

extern

Definition at line 597 of file nodeBitmapHeapscan.c.

{
    Size        size;
 
    if (!node->ss.ps.instrument || pcxt->nworkers == 0)
        return;
 
    size = add_size(offsetof(SharedBitmapHeapInstrumentation, sinstrument),
                    mul_size(pcxt->nworkers, sizeof(BitmapHeapScanInstrumentation)));
    shm_toc_estimate_chunk(&pcxt->estimator, size);
    shm_toc_estimate_keys(&pcxt->estimator, 1);
}

References add_size(), ParallelContext::estimator, fb(), PlanState::instrument, mul_size(), ParallelContext::nworkers, ScanState::ps, shm_toc_estimate_chunk, shm_toc_estimate_keys, and BitmapHeapScanState::ss.

Referenced by ExecParallelEstimate().

ExecBitmapHeapInstrumentInitDSM()

void ExecBitmapHeapInstrumentInitDSM ( BitmapHeapScanState *  node, ParallelContext *  pcxt  )

extern

Definition at line 615 of file nodeBitmapHeapscan.c.

{
    Size        size;
 
    if (!node->ss.ps.instrument || pcxt->nworkers == 0)
        return;
 
    size = add_size(offsetof(SharedBitmapHeapInstrumentation, sinstrument),
                    mul_size(pcxt->nworkers, sizeof(BitmapHeapScanInstrumentation)));
    node->sinstrument =
        (SharedBitmapHeapInstrumentation *) shm_toc_allocate(pcxt->toc, size);
 
    /* Each per-worker area must start out as zeroes */
    memset(node->sinstrument, 0, size);
    node->sinstrument->num_workers = pcxt->nworkers;
    shm_toc_insert(pcxt->toc,
                   node->ss.ps.plan->plan_node_id +
                   PARALLEL_KEY_SCAN_INSTRUMENT_OFFSET,
                   node->sinstrument);
}

References add_size(), fb(), PlanState::instrument, mul_size(), SharedBitmapHeapInstrumentation::num_workers, ParallelContext::nworkers, PARALLEL_KEY_SCAN_INSTRUMENT_OFFSET, PlanState::plan, Plan::plan_node_id, ScanState::ps, shm_toc_allocate(), shm_toc_insert(), BitmapHeapScanState::sinstrument, BitmapHeapScanState::ss, and ParallelContext::toc.

Referenced by ExecParallelInitializeDSM().

ExecBitmapHeapInstrumentInitWorker()

void ExecBitmapHeapInstrumentInitWorker ( BitmapHeapScanState *  node, ParallelWorkerContext *  pwcxt  )

extern

Definition at line 641 of file nodeBitmapHeapscan.c.

{
    if (!node->ss.ps.instrument)
        return;
 
    node->sinstrument = (SharedBitmapHeapInstrumentation *)
        shm_toc_lookup(pwcxt->toc,
                       node->ss.ps.plan->plan_node_id +
                       PARALLEL_KEY_SCAN_INSTRUMENT_OFFSET,
                       false);
}

References fb(), PlanState::instrument, PARALLEL_KEY_SCAN_INSTRUMENT_OFFSET, PlanState::plan, Plan::plan_node_id, ScanState::ps, shm_toc_lookup(), BitmapHeapScanState::sinstrument, and BitmapHeapScanState::ss.

Referenced by ExecParallelInitializeWorker().

ExecBitmapHeapReInitializeDSM()

void ExecBitmapHeapReInitializeDSM ( BitmapHeapScanState *  node, ParallelContext *  pcxt  )

extern

Definition at line 558 of file nodeBitmapHeapscan.c.

{
    ParallelBitmapHeapState *pstate = node->pstate;
    dsa_area   *dsa = node->ss.ps.state->es_query_dsa;
 
    /* If there's no DSA, there are no workers; do nothing. */
    if (dsa == NULL)
        return;
 
    pstate->state = BM_INITIAL;
 
    if (DsaPointerIsValid(pstate->tbmiterator))
        tbm_free_shared_area(dsa, pstate->tbmiterator);
 
    pstate->tbmiterator = InvalidDsaPointer;
}

References BM_INITIAL, DsaPointerIsValid, EState::es_query_dsa, fb(), InvalidDsaPointer, ScanState::ps, BitmapHeapScanState::pstate, BitmapHeapScanState::ss, ParallelBitmapHeapState::state, PlanState::state, tbm_free_shared_area(), and ParallelBitmapHeapState::tbmiterator.

Referenced by ExecParallelReInitializeDSM().

ExecBitmapHeapRetrieveInstrumentation()

void ExecBitmapHeapRetrieveInstrumentation ( BitmapHeapScanState *  node )

extern

Definition at line 661 of file nodeBitmapHeapscan.c.

{
    SharedBitmapHeapInstrumentation *sinstrument = node->sinstrument;
    Size        size;
 
    if (sinstrument == NULL)
        return;
 
    size = offsetof(SharedBitmapHeapInstrumentation, sinstrument)
        + sinstrument->num_workers * sizeof(BitmapHeapScanInstrumentation);
 
    node->sinstrument = palloc(size);
    memcpy(node->sinstrument, sinstrument, size);
}

References fb(), memcpy(), SharedBitmapHeapInstrumentation::num_workers, palloc(), and BitmapHeapScanState::sinstrument.

Referenced by ExecParallelRetrieveInstrumentation().

ExecEndBitmapHeapScan()

void ExecEndBitmapHeapScan ( BitmapHeapScanState *  node )

extern

Definition at line 315 of file nodeBitmapHeapscan.c.

{
    TableScanDesc scanDesc;
 
    /*
     * When ending a parallel worker, copy the statistics gathered by the
     * worker back into shared memory so that it can be picked up by the main
     * process to report in EXPLAIN ANALYZE.
     */
    if (node->sinstrument != NULL && IsParallelWorker())
    {
        BitmapHeapScanInstrumentation *si;
 
        Assert(ParallelWorkerNumber < node->sinstrument->num_workers);
        si = &node->sinstrument->sinstrument[ParallelWorkerNumber];
 
        /*
         * Here we accumulate the stats rather than performing memcpy on
         * node->stats into si.  When a Gather/GatherMerge node finishes it
         * will perform planner shutdown on the workers.  On rescan it will
         * spin up new workers which will have a new BitmapHeapScanState and
         * zeroed stats.
         */
        si->exact_pages += node->stats.exact_pages;
        si->lossy_pages += node->stats.lossy_pages;
 
        /* collect I/O instrumentation for this process */
        if (node->ss.ss_currentScanDesc &&
            node->ss.ss_currentScanDesc->rs_instrument)
        {
            AccumulateIOStats(&si->stats.io,
                              &node->ss.ss_currentScanDesc->rs_instrument->io);
        }
    }
 
    /*
     * extract information from the node
     */
    scanDesc = node->ss.ss_currentScanDesc;
 
    /*
     * close down subplans
     */
    ExecEndNode(outerPlanState(node));
 
    if (scanDesc)
    {
        /*
         * End iteration on iterators saved in scan descriptor if they have
         * not already been cleaned up.
         */
        if (!tbm_exhausted(&scanDesc->st.rs_tbmiterator))
            tbm_end_iterate(&scanDesc->st.rs_tbmiterator);
 
        /*
         * close table scan
         */
        table_endscan(scanDesc);
    }
 
    /*
     * release bitmaps and buffers if any
     */
    if (node->tbm)
        tbm_free(node->tbm);
}

References AccumulateIOStats(), Assert, BitmapHeapScanInstrumentation::exact_pages, ExecEndNode(), fb(), TableScanInstrumentation::io, IsParallelWorker, BitmapHeapScanInstrumentation::lossy_pages, outerPlanState, ParallelWorkerNumber, TableScanDescData::rs_instrument, SharedBitmapHeapInstrumentation::sinstrument, BitmapHeapScanState::sinstrument, BitmapHeapScanState::ss, ScanState::ss_currentScanDesc, BitmapHeapScanState::stats, table_endscan(), BitmapHeapScanState::tbm, tbm_end_iterate(), tbm_exhausted(), and tbm_free().

Referenced by ExecEndNode().

ExecInitBitmapHeapScan()

BitmapHeapScanState * ExecInitBitmapHeapScan ( BitmapHeapScan *  node, EState *  estate, int  eflags  )

extern

Definition at line 389 of file nodeBitmapHeapscan.c.

{
    BitmapHeapScanState *scanstate;
    Relation    currentRelation;
 
    /* check for unsupported flags */
    Assert(!(eflags & (EXEC_FLAG_BACKWARD | EXEC_FLAG_MARK)));
 
    /*
     * Assert caller didn't ask for an unsafe snapshot --- see comments at
     * head of file.
     */
    Assert(IsMVCCSnapshot(estate->es_snapshot));
 
    /*
     * create state structure
     */
    scanstate = makeNode(BitmapHeapScanState);
    scanstate->ss.ps.plan = (Plan *) node;
    scanstate->ss.ps.state = estate;
    scanstate->ss.ps.ExecProcNode = ExecBitmapHeapScan;
 
    scanstate->tbm = NULL;
 
    /* Zero the statistics counters */
    memset(&scanstate->stats, 0, sizeof(BitmapHeapScanInstrumentation));
 
    scanstate->initialized = false;
    scanstate->pstate = NULL;
    scanstate->recheck = true;
 
    /*
     * Miscellaneous initialization
     *
     * create expression context for node
     */
    ExecAssignExprContext(estate, &scanstate->ss.ps);
 
    /*
     * open the scan relation
     */
    currentRelation = ExecOpenScanRelation(estate, node->scan.scanrelid, eflags);
 
    /*
     * initialize child nodes
     */
    outerPlanState(scanstate) = ExecInitNode(outerPlan(node), estate, eflags);
 
    /*
     * get the scan type from the relation descriptor.
     */
    ExecInitScanTupleSlot(estate, &scanstate->ss,
                          RelationGetDescr(currentRelation),
                          table_slot_callbacks(currentRelation),
                          TTS_FLAG_OBEYS_NOT_NULL_CONSTRAINTS);
 
    /*
     * Initialize result type and projection.
     */
    ExecInitResultTypeTL(&scanstate->ss.ps);
    ExecAssignScanProjectionInfo(&scanstate->ss);
 
    /*
     * initialize child expressions
     */
    scanstate->ss.ps.qual =
        ExecInitQual(node->scan.plan.qual, (PlanState *) scanstate);
    scanstate->bitmapqualorig =
        ExecInitQual(node->bitmapqualorig, (PlanState *) scanstate);
 
    scanstate->ss.ss_currentRelation = currentRelation;
 
    /*
     * all done.
     */
    return scanstate;
}

References Assert, BitmapHeapScan::bitmapqualorig, EState::es_snapshot, EXEC_FLAG_BACKWARD, EXEC_FLAG_MARK, ExecAssignExprContext(), ExecAssignScanProjectionInfo(), ExecBitmapHeapScan(), ExecInitNode(), ExecInitQual(), ExecInitResultTypeTL(), ExecInitScanTupleSlot(), ExecOpenScanRelation(), fb(), IsMVCCSnapshot, makeNode, outerPlan, outerPlanState, RelationGetDescr, BitmapHeapScan::scan, Scan::scanrelid, table_slot_callbacks(), and TTS_FLAG_OBEYS_NOT_NULL_CONSTRAINTS.

Referenced by ExecInitNode().

ExecReScanBitmapHeapScan()

void ExecReScanBitmapHeapScan ( BitmapHeapScanState *  node )

extern

Definition at line 274 of file nodeBitmapHeapscan.c.

{
    PlanState  *outerPlan = outerPlanState(node);
 
    TableScanDesc scan = node->ss.ss_currentScanDesc;
 
    if (scan)
    {
        /*
         * End iteration on iterators saved in scan descriptor if they have
         * not already been cleaned up.
         */
        if (!tbm_exhausted(&scan->st.rs_tbmiterator))
            tbm_end_iterate(&scan->st.rs_tbmiterator);
 
        /* rescan to release any page pin */
        table_rescan(node->ss.ss_currentScanDesc, NULL);
    }
 
    /* release bitmaps and buffers if any */
    if (node->tbm)
        tbm_free(node->tbm);
    node->tbm = NULL;
    node->initialized = false;
    node->recheck = true;
 
    ExecScanReScan(&node->ss);
 
    /*
     * if chgParam of subnode is not null then plan will be re-scanned by
     * first ExecProcNode.
     */
    if (outerPlan->chgParam == NULL)
        ExecReScan(outerPlan);
}

References ExecReScan(), ExecScanReScan(), fb(), BitmapHeapScanState::initialized, outerPlan, outerPlanState, BitmapHeapScanState::recheck, TableScanDescData::rs_tbmiterator, BitmapHeapScanState::ss, ScanState::ss_currentScanDesc, TableScanDescData::st, table_rescan(), BitmapHeapScanState::tbm, tbm_end_iterate(), tbm_exhausted(), and tbm_free().

Referenced by ExecReScan().