Function EstimateGpParallelDSMEntrySize

src/backend/executor/execParallel.c:1503–1560

}

bool
EstimateGpParallelDSMEntrySize(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)
				ExecSeqScanEstimate((SeqScanState *) planstate,
									pctx);
			break;
		case T_IndexScanState:
			if (planstate->plan->parallel_aware)
				ExecIndexScanEstimate((IndexScanState *) planstate,
									  pctx);
			break;
		case T_IndexOnlyScanState:
			if (planstate->plan->parallel_aware)
				ExecIndexOnlyScanEstimate((IndexOnlyScanState *) planstate,
										  pctx);
			break;
		case T_BitmapHeapScanState:
			if (planstate->plan->parallel_aware)
				ExecBitmapHeapEstimate((BitmapHeapScanState *) planstate,
									   pctx);
			break;
		case T_AppendState:
			if (planstate->plan->parallel_aware)
				ExecAppendEstimate((AppendState*) planstate, pctx);
			break;
		case T_HashJoinState:
			if (planstate->plan->parallel_aware)
				ExecHashJoinEstimate((HashJoinState *) planstate,
									 pctx);
			break;
		case T_HashState:
			ExecHashEstimate((HashState *) planstate, pctx);
			break;
		case T_SortState:
			ExecSortEstimate((SortState *) planstate, pctx);
			break;
		default:
			break;

	}

	return planstate_tree_walker(planstate, EstimateGpParallelDSMEntrySize, pctx);
}