Function SendStopMessage

src/backend/cdb/motion/cdbmotion.c:341–351

}

void
SendStopMessage(MotionLayerState *mlStates,
				ChunkTransportState *transportStates,
				int16 motNodeID)
{
	MotionNodeEntry *pEntry = getMotionNodeEntry(mlStates, motNodeID);

	pEntry->stopped = true;
	if (transportStates != NULL && CurrentMotionIPCLayer->SendStopMessage != NULL)
		CurrentMotionIPCLayer->SendStopMessage(transportStates, motNodeID);
}

void
CheckAndSendRecordCache(MotionLayerState *mlStates,