Function InitializeGpParallelDSMEntry

src/backend/executor/execParallel.c:1614–1670

}

bool
InitializeGpParallelDSMEntry(PlanState *planstate, ParallelContext *pctx)
{
	if (planstate == NULL)
		return false;

	switch (nodeTag(planstate))
	{
		case T_MotionState:
			/*
			 * If we walk to MotionStateNode with Recv Motion Type, we should return directly.
			 * So that we can only Initialize Parallel Entry for current Slice.
			 */
			if (((MotionState *) planstate)->mstype == MOTIONSTATE_RECV)
				return false;
			break;
		case T_SeqScanState:
			if (planstate->plan->parallel_aware)
				ExecSeqScanInitializeDSM((SeqScanState *) planstate,
										 pctx);
			break;
		case T_IndexScanState:
			if (planstate->plan->parallel_aware)
				ExecIndexScanInitializeDSM((IndexScanState *) planstate,
										   pctx);
			break;
		case T_IndexOnlyScanState:
			if (planstate->plan->parallel_aware)
				ExecIndexOnlyScanInitializeDSM((IndexOnlyScanState *) planstate,
											  pctx);
			break;
		case T_BitmapHeapScanState:
			if (planstate->plan->parallel_aware)
				ExecBitmapHeapInitializeDSM((BitmapHeapScanState *) planstate,
											pctx);
			break;
		case T_AppendState:
			if (planstate->plan->parallel_aware)
				ExecAppendInitializeDSM((AppendState *) planstate,
										pctx);
			break;
		case T_HashJoinState:
			if (planstate->plan->parallel_aware)
				ExecHashJoinInitializeDSM((HashJoinState *) planstate, pctx);
			break;
		case T_HashState:
			ExecHashInitializeDSM((HashState *) planstate, pctx);
			break;
		case T_SortState:
			ExecSortInitializeDSM((SortState *) planstate, pctx);
			break;
		default:
			break;
	}

	return planstate_tree_walker(planstate, InitializeGpParallelDSMEntry, pctx);
}