PostgreSQL Source Code git master
Functions
nodeLockRows.h File Reference
#include "nodes/execnodes.h"
Include dependency graph for nodeLockRows.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions

LockRowsState *  ExecInitLockRows (LockRows *node, EState *estate, int eflags)
 
void  ExecEndLockRows (LockRowsState *node)
 
void  ExecReScanLockRows (LockRowsState *node)
 

Function Documentation

◆ ExecEndLockRows()

void ExecEndLockRows ( LockRowsState *  node )

Definition at line 390 of file nodeLockRows.c.

391{
392 /* We may have shut down EPQ already, but no harm in another call */
395}
void EvalPlanQualEnd(EPQState *epqstate)
Definition: execMain.c:3169
void ExecEndNode(PlanState *node)
Definition: execProcnode.c:562
#define outerPlanState(node)
Definition: execnodes.h:1255
EPQState lr_epqstate
Definition: execnodes.h:2884

References EvalPlanQualEnd(), ExecEndNode(), LockRowsState::lr_epqstate, and outerPlanState.

Referenced by ExecEndNode().

◆ ExecInitLockRows()

LockRowsState * ExecInitLockRows ( LockRows *  node,
EState *  estate,
int  eflags 
)

Definition at line 291 of file nodeLockRows.c.

292{
293 LockRowsState *lrstate;
294 Plan *outerPlan = outerPlan(node);
295 List *epq_arowmarks;
296 ListCell *lc;
297
298 /* check for unsupported flags */
299 Assert(!(eflags & EXEC_FLAG_MARK));
300
301 /*
302 * create state structure
303 */
304 lrstate = makeNode(LockRowsState);
305 lrstate->ps.plan = (Plan *) node;
306 lrstate->ps.state = estate;
307 lrstate->ps.ExecProcNode = ExecLockRows;
308
309 /*
310 * Miscellaneous initialization
311 *
312 * LockRows nodes never call ExecQual or ExecProject, therefore no
313 * ExprContext is needed.
314 */
315
316 /*
317 * Initialize result type.
318 */
319 ExecInitResultTypeTL(&lrstate->ps);
320
321 /*
322 * then initialize outer plan
323 */
324 outerPlanState(lrstate) = ExecInitNode(outerPlan, estate, eflags);
325
326 /* node returns unmodified slots from the outer plan */
327 lrstate->ps.resultopsset = true;
329 &lrstate->ps.resultopsfixed);
330
331 /*
332 * LockRows nodes do no projections, so initialize projection info for
333 * this node appropriately
334 */
335 lrstate->ps.ps_ProjInfo = NULL;
336
337 /*
338 * Locate the ExecRowMark(s) that this node is responsible for, and
339 * construct ExecAuxRowMarks for them. (InitPlan should already have
340 * built the global list of ExecRowMarks.)
341 */
342 lrstate->lr_arowMarks = NIL;
343 epq_arowmarks = NIL;
344 foreach(lc, node->rowMarks)
345 {
347 ExecRowMark *erm;
348 ExecAuxRowMark *aerm;
349
350 /*
351 * Ignore "parent" rowmarks, because they are irrelevant at runtime.
352 * Also ignore the rowmarks belonging to child tables that have been
353 * pruned in ExecDoInitialPruning().
354 */
355 if (rc->isParent ||
356 !bms_is_member(rc->rti, estate->es_unpruned_relids))
357 continue;
358
359 /* find ExecRowMark and build ExecAuxRowMark */
360 erm = ExecFindRowMark(estate, rc->rti, false);
361 aerm = ExecBuildAuxRowMark(erm, outerPlan->targetlist);
362
363 /*
364 * Only locking rowmarks go into our own list. Non-locking marks are
365 * passed off to the EvalPlanQual machinery. This is because we don't
366 * want to bother fetching non-locked rows unless we actually have to
367 * do an EPQ recheck.
368 */
370 lrstate->lr_arowMarks = lappend(lrstate->lr_arowMarks, aerm);
371 else
372 epq_arowmarks = lappend(epq_arowmarks, aerm);
373 }
374
375 /* Now we have the info needed to set up EPQ state */
376 EvalPlanQualInit(&lrstate->lr_epqstate, estate,
377 outerPlan, epq_arowmarks, node->epqParam, NIL);
378
379 return lrstate;
380}
bool bms_is_member(int x, const Bitmapset *a)
Definition: bitmapset.c:510
ExecRowMark * ExecFindRowMark(EState *estate, Index rti, bool missing_ok)
Definition: execMain.c:2546
ExecAuxRowMark * ExecBuildAuxRowMark(ExecRowMark *erm, List *targetlist)
Definition: execMain.c:2569
void EvalPlanQualInit(EPQState *epqstate, EState *parentestate, Plan *subplan, List *auxrowmarks, int epqParam, List *resultRelations)
Definition: execMain.c:2708
PlanState * ExecInitNode(Plan *node, EState *estate, int eflags)
Definition: execProcnode.c:142
void ExecInitResultTypeTL(PlanState *planstate)
Definition: execTuples.c:1944
const TupleTableSlotOps * ExecGetResultSlotOps(PlanState *planstate, bool *isfixed)
Definition: execUtils.c:504
#define EXEC_FLAG_MARK
Definition: executor.h:70
Assert(PointerIsAligned(start, uint64))
List * lappend(List *list, void *datum)
Definition: list.c:339
static TupleTableSlot * ExecLockRows(PlanState *pstate)
Definition: nodeLockRows.c:38
#define makeNode(_type_)
Definition: nodes.h:161
#define lfirst_node(type, lc)
Definition: pg_list.h:176
#define NIL
Definition: pg_list.h:68
#define outerPlan(node)
Definition: plannodes.h:252
#define RowMarkRequiresRowShareLock(marktype)
Definition: plannodes.h:1537
Bitmapset * es_unpruned_relids
Definition: execnodes.h:673
RowMarkType markType
Definition: execnodes.h:802
Definition: pg_list.h:54
PlanState ps
Definition: execnodes.h:2882
List * lr_arowMarks
Definition: execnodes.h:2883
int epqParam
Definition: plannodes.h:1460
List * rowMarks
Definition: plannodes.h:1458
Index rti
Definition: plannodes.h:1583
bool isParent
Definition: plannodes.h:1597
const TupleTableSlotOps * resultops
Definition: execnodes.h:1236
bool resultopsset
Definition: execnodes.h:1244
Plan * plan
Definition: execnodes.h:1159
EState * state
Definition: execnodes.h:1161
ProjectionInfo * ps_ProjInfo
Definition: execnodes.h:1199
bool resultopsfixed
Definition: execnodes.h:1240
ExecProcNodeMtd ExecProcNode
Definition: execnodes.h:1165
Definition: plannodes.h:177
Definition: pg_list.h:46

References Assert(), bms_is_member(), LockRows::epqParam, EState::es_unpruned_relids, EvalPlanQualInit(), EXEC_FLAG_MARK, ExecBuildAuxRowMark(), ExecFindRowMark(), ExecGetResultSlotOps(), ExecInitNode(), ExecInitResultTypeTL(), ExecLockRows(), PlanState::ExecProcNode, PlanRowMark::isParent, lappend(), lfirst_node, LockRowsState::lr_arowMarks, LockRowsState::lr_epqstate, makeNode, ExecRowMark::markType, NIL, outerPlan, outerPlanState, PlanState::plan, LockRowsState::ps, PlanState::ps_ProjInfo, PlanState::resultops, PlanState::resultopsfixed, PlanState::resultopsset, RowMarkRequiresRowShareLock, LockRows::rowMarks, PlanRowMark::rti, and PlanState::state.

Referenced by ExecInitNode().

◆ ExecReScanLockRows()

void ExecReScanLockRows ( LockRowsState *  node )

Definition at line 399 of file nodeLockRows.c.

400{
402
403 /*
404 * if chgParam of subnode is not null then plan will be re-scanned by
405 * first ExecProcNode.
406 */
407 if (outerPlan->chgParam == NULL)
409}
void ExecReScan(PlanState *node)
Definition: execAmi.c:77

References ExecReScan(), outerPlan, and outerPlanState.

Referenced by ExecReScan().

AltStyle によって変換されたページ (->オリジナル) /