execAsync.c File Reference

#include "postgres.h"
#include "executor/execAsync.h"
#include "executor/executor.h"
#include "executor/nodeAppend.h"
#include "executor/nodeForeignscan.h"

Include dependency graph for execAsync.c:

Go to the source code of this file.

Functions
void	ExecAsyncRequest (AsyncRequest *areq)
void	ExecAsyncConfigureWait (AsyncRequest *areq)
void	ExecAsyncNotify (AsyncRequest *areq)
void	ExecAsyncResponse (AsyncRequest *areq)
void	ExecAsyncRequestDone (AsyncRequest *areq, TupleTableSlot *result)
void	ExecAsyncRequestPending (AsyncRequest *areq)

Function Documentation

ExecAsyncConfigureWait()

void ExecAsyncConfigureWait

(

AsyncRequest *

areq

)

Definition at line 62 of file execAsync.c.

{
    /* must provide our own instrumentation support */
    if (areq->requestee->instrument)
        InstrStartNode(areq->requestee->instrument);
 
    switch (nodeTag(areq->requestee))
    {
        case T_ForeignScanState:
            ExecAsyncForeignScanConfigureWait(areq);
            break;
        default:
            /* If the node doesn't support async, caller messed up. */
            elog(ERROR, "unrecognized node type: %d",
                 (int) nodeTag(areq->requestee));
    }
 
    /* must provide our own instrumentation support */
    if (areq->requestee->instrument)
        InstrStopNode(areq->requestee->instrument, 0.0);
}

References elog, ERROR, ExecAsyncForeignScanConfigureWait(), InstrStartNode(), InstrStopNode(), PlanState::instrument, nodeTag, and AsyncRequest::requestee.

Referenced by ExecAppendAsyncEventWait().

ExecAsyncNotify()

void ExecAsyncNotify

(

AsyncRequest *

areq

)

Definition at line 88 of file execAsync.c.

{
    /* must provide our own instrumentation support */
    if (areq->requestee->instrument)
        InstrStartNode(areq->requestee->instrument);
 
    switch (nodeTag(areq->requestee))
    {
        case T_ForeignScanState:
            ExecAsyncForeignScanNotify(areq);
            break;
        default:
            /* If the node doesn't support async, caller messed up. */
            elog(ERROR, "unrecognized node type: %d",
                 (int) nodeTag(areq->requestee));
    }
 
    ExecAsyncResponse(areq);
 
    /* must provide our own instrumentation support */
    if (areq->requestee->instrument)
        InstrStopNode(areq->requestee->instrument,
                      TupIsNull(areq->result) ? 0.0 : 1.0);
}

References elog, ERROR, ExecAsyncForeignScanNotify(), ExecAsyncResponse(), InstrStartNode(), InstrStopNode(), PlanState::instrument, nodeTag, AsyncRequest::requestee, AsyncRequest::result, and TupIsNull.

Referenced by ExecAppendAsyncEventWait().

ExecAsyncRequest()

void ExecAsyncRequest

(

AsyncRequest *

areq

)

Definition at line 26 of file execAsync.c.

{
    if (areq->requestee->chgParam != NULL)  /* something changed? */
        ExecReScan(areq->requestee);    /* let ReScan handle this */
 
    /* must provide our own instrumentation support */
    if (areq->requestee->instrument)
        InstrStartNode(areq->requestee->instrument);
 
    switch (nodeTag(areq->requestee))
    {
        case T_ForeignScanState:
            ExecAsyncForeignScanRequest(areq);
            break;
        default:
            /* If the node doesn't support async, caller messed up. */
            elog(ERROR, "unrecognized node type: %d",
                 (int) nodeTag(areq->requestee));
    }
 
    ExecAsyncResponse(areq);
 
    /* must provide our own instrumentation support */
    if (areq->requestee->instrument)
        InstrStopNode(areq->requestee->instrument,
                      TupIsNull(areq->result) ? 0.0 : 1.0);
}

References PlanState::chgParam, elog, ERROR, ExecAsyncForeignScanRequest(), ExecAsyncResponse(), ExecReScan(), InstrStartNode(), InstrStopNode(), PlanState::instrument, nodeTag, AsyncRequest::requestee, AsyncRequest::result, and TupIsNull.

Referenced by ExecAppendAsyncBegin(), and ExecAppendAsyncRequest().

ExecAsyncRequestDone()

void ExecAsyncRequestDone	(	AsyncRequest *	areq,
		TupleTableSlot *	result
	)

Definition at line 137 of file execAsync.c.

{
    areq->request_complete = true;
    areq->result = result;
}

References AsyncRequest::request_complete, and AsyncRequest::result.

Referenced by process_pending_request(), and produce_tuple_asynchronously().

ExecAsyncRequestPending()

void ExecAsyncRequestPending

(

AsyncRequest *

areq

)

Definition at line 149 of file execAsync.c.

{
    areq->callback_pending = true;
    areq->request_complete = false;
    areq->result = NULL;
}

References AsyncRequest::callback_pending, AsyncRequest::request_complete, and AsyncRequest::result.

Referenced by produce_tuple_asynchronously().

ExecAsyncResponse()

void ExecAsyncResponse

(

AsyncRequest *

areq

)

Definition at line 117 of file execAsync.c.

{
    switch (nodeTag(areq->requestor))
    {
        case T_AppendState:
            ExecAsyncAppendResponse(areq);
            break;
        default:
            /* If the node doesn't support async, caller messed up. */
            elog(ERROR, "unrecognized node type: %d",
                 (int) nodeTag(areq->requestor));
    }
}

References elog, ERROR, ExecAsyncAppendResponse(), nodeTag, and AsyncRequest::requestor.

Referenced by complete_pending_request(), ExecAsyncNotify(), ExecAsyncRequest(), and process_pending_request().