plugins/org.eclipse.qvtd.pivot.qvtschedule/emf-gen/org/eclipse/qvtd/pivot/qvtschedule/impl/NodeConnectionImpl.java - mmt/org.eclipse.qvtd - Git at Google

 /**
  * <copyright>
  *
  * Copyright (c) 2013, 2019 Willink Transformations and others.
  * All rights reserved. This program and the accompanying materials
  * are made available under the terms of the Eclipse Public License v2.0
  * which accompanies this distribution, and is available at
  * http://www.eclipse.org/legal/epl-v20.html
  *
  * Contributors:
  *   E.D.Willink - Initial API and implementation
  *
  * </copyright>
  */
 package org.eclipse.qvtd.pivot.qvtschedule.impl;

 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;

 import org.eclipse.emf.common.notify.Notification;
 import org.eclipse.emf.common.util.EList;
 import org.eclipse.emf.ecore.EClass;

 import org.eclipse.emf.ecore.InternalEObject;
 import org.eclipse.emf.ecore.impl.ENotificationImpl;
 import org.eclipse.emf.ecore.util.EObjectResolvingEList;
 import org.eclipse.jdt.annotation.NonNull;
 import org.eclipse.jdt.annotation.Nullable;
 import org.eclipse.ocl.pivot.CompleteClass;
 import org.eclipse.ocl.pivot.Type;
 import org.eclipse.ocl.pivot.ids.IdResolver;
 import org.eclipse.ocl.pivot.internal.ElementImpl;
 import org.eclipse.ocl.pivot.util.Visitor;
 import org.eclipse.qvtd.pivot.qvtschedule.ClassDatum;
 import org.eclipse.qvtd.pivot.qvtschedule.ConnectionEnd;
 import org.eclipse.qvtd.pivot.qvtschedule.ConnectionRole;
 import org.eclipse.qvtd.pivot.qvtschedule.MappingPartition;
 import org.eclipse.qvtd.pivot.qvtschedule.Node;
 import org.eclipse.qvtd.pivot.qvtschedule.NodeConnection;
 import org.eclipse.qvtd.pivot.qvtschedule.Partition;
 import org.eclipse.qvtd.pivot.qvtschedule.QVTschedulePackage;
 import org.eclipse.qvtd.pivot.qvtschedule.Region;
 import org.eclipse.qvtd.pivot.qvtschedule.Role;
 import org.eclipse.qvtd.pivot.qvtschedule.util.QVTscheduleVisitor;
 import org.eclipse.qvtd.pivot.qvtschedule.utilities.QVTscheduleConstants;
 import org.eclipse.qvtd.pivot.qvtschedule.utilities.QVTscheduleUtil;

 import com.google.common.collect.Iterables;
 import java.util.Collection;

 /**
  * <!-- begin-user-doc -->
  * An implementation of the model object '<em><b>Node Connection</b></em>'.
  * <!-- end-user-doc -->
  * <p>
  * The following features are implemented:
  * </p>
  * <ul>
  *   <li>{@link org.eclipse.qvtd.pivot.qvtschedule.impl.NodeConnectionImpl#getClassDatum <em>Class Datum</em>}</li>
  *   <li>{@link org.eclipse.qvtd.pivot.qvtschedule.impl.NodeConnectionImpl#getMandatoryTargetNodes <em>Mandatory Target Nodes</em>}</li>
  *   <li>{@link org.eclipse.qvtd.pivot.qvtschedule.impl.NodeConnectionImpl#getPassedTargetNodes <em>Passed Target Nodes</em>}</li>
  *   <li>{@link org.eclipse.qvtd.pivot.qvtschedule.impl.NodeConnectionImpl#getPreferredTargetNodes <em>Preferred Target Nodes</em>}</li>
  * </ul>
  *
  * @generated
  */
 public class NodeConnectionImpl extends ConnectionImpl implements NodeConnection
 {
 	/**
 	 * The number of structural features of the '<em>Node Connection</em>' class.
 	 * <!-- begin-user-doc -->
 	 * <!-- end-user-doc -->
 	 * @generated
 	 * @ordered
 	 */
 	public static final int NODE_CONNECTION_FEATURE_COUNT = ConnectionImpl.CONNECTION_FEATURE_COUNT + 4;

 	/**
 	 * The number of operations of the '<em>Node Connection</em>' class.
 	 * <!-- begin-user-doc -->
 	 * <!-- end-user-doc -->
 	 * @generated
 	 * @ordered
 	 */
 	public static final int NODE_CONNECTION_OPERATION_COUNT = ConnectionImpl.CONNECTION_OPERATION_COUNT + 0;

 	/**
 	 * NodeList duplicates changes to the lists-of-nodes to the 'redundant' node-to-role map.
 	 */
 	@SuppressWarnings("serial")
 	protected static class NodeList extends EObjectResolvingEList<@NonNull Node>
 	{
 		protected final @NonNull ConnectionRole connectionRole;
 		private final @NonNull Map<@NonNull Node, @NonNull ConnectionRole> targetEnd2role;

 		protected NodeList(@NonNull NodeConnectionImpl owner, int featureID, @NonNull ConnectionRole connectionRole) {
 			super(Node.class, owner, featureID);
 			this.connectionRole = connectionRole;
 			this.targetEnd2role = owner.targetEnd2role;
 		}

 		@Override
 		protected void didAdd(int index, @NonNull Node newObject) {
 			targetEnd2role.put(newObject, connectionRole);
 		}

 		@Override
 		protected void didRemove(int index, @NonNull Node oldObject) {
 			targetEnd2role.remove(oldObject);
 		}
 	}

 	/**
 	 * The cached value of the '{@link #getClassDatum() <em>Class Datum</em>}' reference.
 	 * <!-- begin-user-doc -->
 	 * <!-- end-user-doc -->
 	 * @see #getClassDatum()
 	 * @generated
 	 * @ordered
 	 */
 	protected ClassDatum classDatum;

 	/**
 	 * The cached value of the '{@link #getMandatoryTargetNodes() <em>Mandatory Target Nodes</em>}' reference list.
 	 * <!-- begin-user-doc -->
 	 * <!-- end-user-doc -->
 	 * @see #getMandatoryTargetNodes()
 	 * @generated
 	 * @ordered
 	 */
 	protected EList<Node> mandatoryTargetNodes;
 	/**
 	 * The cached value of the '{@link #getPassedTargetNodes() <em>Passed Target Nodes</em>}' reference list.
 	 * <!-- begin-user-doc -->
 	 * <!-- end-user-doc -->
 	 * @see #getPassedTargetNodes()
 	 * @generated
 	 * @ordered
 	 */
 	protected EList<Node> passedTargetNodes;
 	/**
 	 * The cached value of the '{@link #getPreferredTargetNodes() <em>Preferred Target Nodes</em>}' reference list.
 	 * <!-- begin-user-doc -->
 	 * <!-- end-user-doc -->
 	 * @see #getPreferredTargetNodes()
 	 * @generated
 	 * @ordered
 	 */
 	protected EList<Node> preferredTargetNodes;

 	/**
 	 * <!-- begin-user-doc -->
 	 * <!-- end-user-doc -->
 	 * @generated
 	 */
 	protected NodeConnectionImpl() {
 		super();
 	}

 	/**
 	 * <!-- begin-user-doc -->
 	 * <!-- end-user-doc -->
 	 * @generated
 	 */
 	@Override
 	protected EClass eStaticClass() {
 		return QVTschedulePackage.Literals.NODE_CONNECTION;
 	}

 	/**
 	 * <!-- begin-user-doc -->
 	 * <!-- end-user-doc -->
 	 * @generated
 	 */
 	@Override
 	public ClassDatum getClassDatum() {
 		if (classDatum != null && classDatum.eIsProxy()) {
 			InternalEObject oldClassDatum = (InternalEObject)classDatum;
 			classDatum = (ClassDatum)eResolveProxy(oldClassDatum);
 			if (classDatum != oldClassDatum) {
 				if (eNotificationRequired())
 					eNotify(new ENotificationImpl(this, Notification.RESOLVE, ElementImpl.ELEMENT_FEATURE_COUNT + 7, oldClassDatum, classDatum));
 			}
 		}
 		return classDatum;
 	}

 	/**
 	 * <!-- begin-user-doc -->
 	 * <!-- end-user-doc -->
 	 * @generated
 	 */
 	public ClassDatum basicGetClassDatum() {
 		return classDatum;
 	}

 	/**
 	 * <!-- begin-user-doc -->
 	 * <!-- end-user-doc -->
 	 * @generated
 	 */
 	@Override
 	public void setClassDatum(ClassDatum newClassDatum) {
 		ClassDatum oldClassDatum = classDatum;
 		classDatum = newClassDatum;
 		if (eNotificationRequired())
 			eNotify(new ENotificationImpl(this, Notification.SET, ElementImpl.ELEMENT_FEATURE_COUNT + 7, oldClassDatum, classDatum));
 	}

 	/**
 	 * <!-- begin-user-doc -->
 	 * <!-- end-user-doc -->
 	 * @generated NOT
 	 */
 	@Override
 	public List<Node> getMandatoryTargetNodes() {
 		if (mandatoryTargetNodes == null) {
 			mandatoryTargetNodes = new NodeList(this, QVTschedulePackage.Literals.NODE_CONNECTION__MANDATORY_TARGET_NODES.getFeatureID(), ConnectionRole.MANDATORY_NODE);
 		}
 		return mandatoryTargetNodes;
 	}

 	/**
 	 * <!-- begin-user-doc -->
 	 * <!-- end-user-doc -->
 	 * @generated NOT
 	 */
 	@Override
 	public List<Node> getPassedTargetNodes() {
 		if (passedTargetNodes == null) {
 			passedTargetNodes = new NodeList(this, QVTschedulePackage.Literals.NODE_CONNECTION__PASSED_TARGET_NODES.getFeatureID(), ConnectionRole.PASSED);
 		}
 		return passedTargetNodes;
 	}

 	/**
 	 * <!-- begin-user-doc -->
 	 * <!-- end-user-doc -->
 	 * @generated NOT
 	 */
 	@Override
 	public List<Node> getPreferredTargetNodes() {
 		if (preferredTargetNodes == null) {
 			preferredTargetNodes = new NodeList(this, QVTschedulePackage.Literals.NODE_CONNECTION__PREFERRED_TARGET_NODES.getFeatureID(), ConnectionRole.PREFERRED_NODE);
 		}
 		return preferredTargetNodes;
 	}

 	/**
 	 * <!-- begin-user-doc -->
 	 * <!-- end-user-doc -->
 	 * @generated
 	 */
 	@Override
 	public Object eGet(int featureID, boolean resolve, boolean coreType) {
 		switch (featureID) {
 			case ElementImpl.ELEMENT_FEATURE_COUNT + 7:
 				if (resolve) return getClassDatum();
 				return basicGetClassDatum();
 			case ElementImpl.ELEMENT_FEATURE_COUNT + 8:
 				return getMandatoryTargetNodes();
 			case ElementImpl.ELEMENT_FEATURE_COUNT + 9:
 				return getPassedTargetNodes();
 			case ElementImpl.ELEMENT_FEATURE_COUNT + 10:
 				return getPreferredTargetNodes();
 		}
 		return super.eGet(featureID, resolve, coreType);
 	}

 	/**
 	 * <!-- begin-user-doc -->
 	 * <!-- end-user-doc -->
 	 * @generated
 	 */
 	@SuppressWarnings("unchecked")
 	@Override
 	public void eSet(int featureID, Object newValue) {
 		switch (featureID) {
 			case ElementImpl.ELEMENT_FEATURE_COUNT + 7:
 				setClassDatum((ClassDatum)newValue);
 				return;
 			case ElementImpl.ELEMENT_FEATURE_COUNT + 8:
 				getMandatoryTargetNodes().clear();
 				getMandatoryTargetNodes().addAll((Collection<? extends Node>)newValue);
 				return;
 			case ElementImpl.ELEMENT_FEATURE_COUNT + 9:
 				getPassedTargetNodes().clear();
 				getPassedTargetNodes().addAll((Collection<? extends Node>)newValue);
 				return;
 			case ElementImpl.ELEMENT_FEATURE_COUNT + 10:
 				getPreferredTargetNodes().clear();
 				getPreferredTargetNodes().addAll((Collection<? extends Node>)newValue);
 				return;
 		}
 		super.eSet(featureID, newValue);
 	}

 	/**
 	 * <!-- begin-user-doc -->
 	 * <!-- end-user-doc -->
 	 * @generated
 	 */
 	@Override
 	public void eUnset(int featureID) {
 		switch (featureID) {
 			case ElementImpl.ELEMENT_FEATURE_COUNT + 7:
 				setClassDatum((ClassDatum)null);
 				return;
 			case ElementImpl.ELEMENT_FEATURE_COUNT + 8:
 				getMandatoryTargetNodes().clear();
 				return;
 			case ElementImpl.ELEMENT_FEATURE_COUNT + 9:
 				getPassedTargetNodes().clear();
 				return;
 			case ElementImpl.ELEMENT_FEATURE_COUNT + 10:
 				getPreferredTargetNodes().clear();
 				return;
 		}
 		super.eUnset(featureID);
 	}

 	/**
 	 * <!-- begin-user-doc -->
 	 * <!-- end-user-doc -->
 	 * @generated
 	 */
 	@Override
 	public boolean eIsSet(int featureID) {
 		switch (featureID) {
 			case ElementImpl.ELEMENT_FEATURE_COUNT + 7:
 				return classDatum != null;
 			case ElementImpl.ELEMENT_FEATURE_COUNT + 8:
 				return mandatoryTargetNodes != null && !mandatoryTargetNodes.isEmpty();
 			case ElementImpl.ELEMENT_FEATURE_COUNT + 9:
 				return passedTargetNodes != null && !passedTargetNodes.isEmpty();
 			case ElementImpl.ELEMENT_FEATURE_COUNT + 10:
 				return preferredTargetNodes != null && !preferredTargetNodes.isEmpty();
 		}
 		return super.eIsSet(featureID);
 	}

 	/**
 	 * {@inheritDoc}
 	 * @generated
 	 */
 	@SuppressWarnings("unchecked")
 	@Override
 	public <R> R accept(@NonNull Visitor<R> visitor) {
 		if (visitor instanceof QVTscheduleVisitor) {
 			return (R) ((QVTscheduleVisitor<?>)visitor).visitNodeConnection(this);
 		}
 		else {
 			return super.accept(visitor);
 		}
 	}

 	@Override
 	public boolean isMandatory() {
 		return getConnectionRole().isMandatory();
 	}

 	@Override
 	public boolean isPassed() {
 		return getConnectionRole().isPassed();
 	}

 	@Override
 	public boolean isUsed() {
 		return getConnectionRole().isPreferred();
 	}

 	private final @NonNull Map<@NonNull Node, @NonNull ConnectionRole> targetEnd2role = new HashMap<>();

 	@Override
 	public void addPassedTargetNode(@NonNull Node targetNode) {
 		mergeRole(ConnectionRole.PASSED);
 		ConnectionRole targetRole = getTargetRole(targetNode);
 		assert targetRole == null;
 		putTargetRole(targetNode, ConnectionRole.PASSED);
 		targetNode.setIncomingConnection(this);
 		//		assert Sets.intersection(getSourceRegions(), getTargetRegions()).isEmpty();
 	}

 	@Override
 	public void addUsedTargetNode(@NonNull Node targetNode, boolean mustBeLater) {
 		ConnectionRole newConnectionRole = mustBeLater ? ConnectionRole.MANDATORY_NODE : ConnectionRole.PREFERRED_NODE;
 		ConnectionRole oldConnectionRole = getTargetRole(targetNode);
 		if ((oldConnectionRole != null) && (oldConnectionRole != newConnectionRole)) {
 			newConnectionRole = newConnectionRole.merge(oldConnectionRole);
 		}
 		mergeRole(newConnectionRole);
 		putTargetRole(targetNode, newConnectionRole);
 		assert targetNode.getIncomingConnection() == null;
 		targetNode.setIncomingConnection(this);
 		//		assert Sets.intersection(getSourceRegions(), getTargetRegions()).isEmpty();
 	}

 	@Override
 	public @Nullable Node basicGetSource(@NonNull Partition sourcePartition) {
 		Node sourceNode = null;
 		for (@NonNull Node sourceEnd : QVTscheduleUtil.getSourceEnds(this)) {
 			Region sourceRegion = QVTscheduleUtil.getOwningRegion(sourceEnd);
 			Iterable<@NonNull MappingPartition> sourceRegionPartitions = QVTscheduleUtil.getRegionPartitions(sourceRegion);
 			if (Iterables.contains(sourceRegionPartitions, sourcePartition)) {
 				Role sourceRole = QVTscheduleUtil.getRole(sourcePartition, sourceEnd);
 				if ((sourceRole != null) && !sourceRole.isChecked()) { //(sourceRole.isNew() || sourceRole.isLoaded())) {
 					assert sourceNode == null;
 					sourceNode = sourceEnd;
 				}
 			}
 		}
 		return sourceNode;
 	}

 	@Override
 	public void destroy() {
 		for (@NonNull Node sourceNode : QVTscheduleUtil.getSourceEnds(this)) {
 			assert Iterables.contains(QVTscheduleUtil.getSourceEnds(this), sourceNode);
 			//		assert edge.getRegion() == getRegion();
 			List<NodeConnection> outgoingConnections2 = sourceNode.getOutgoingConnections();
 			assert outgoingConnections2 != null;
 			@SuppressWarnings("unused")
 			boolean wasRemoved = outgoingConnections2.remove(this);
 			//		assert wasRemoved;
 		}
 		for (@NonNull Node targetNode : targetEnd2role.keySet()) {
 			targetNode.setIncomingConnection(null);
 		}
 		targetEnd2role.clear();
 		super.destroy();
 	}

 	@Override
 	public @NonNull Node getSource(@NonNull Partition sourcePartition) {
 		return (Node) super.getSource(sourcePartition);
 	}

 	@Override
 	public @NonNull Iterable<@NonNull Node> getSourceNodes() {
 		return QVTscheduleUtil.getSourceEnds(this);
 	}

 	@Override
 	public @NonNull Type getSourcesType(@NonNull IdResolver idResolver) {
 		//		System.out.println("commonType of " + this);
 		Type commonType = null;
 		for (@NonNull Node node : QVTscheduleUtil.getSourceEnds(this)) {
 			ClassDatum classDatum2 = QVTscheduleUtil.getClassDatum(node);
 			for (@NonNull CompleteClass completeClass : QVTscheduleUtil.getCompleteClasses(classDatum2)) { // ?? never a multiple
 				Type nodeType = completeClass.getPrimaryClass();
 				//	if (nodeType instanceof CollectionType) {
 				//		nodeType = ((CollectionType)nodeType).getElementType();		// FIXME needed for composed source nodes
 				//		assert nodeType != null;
 				//	}
 				//			System.out.println("  nodeType " + nodeType);
 				//			CompleteEnvironment environment = idResolver.getEnvironment();
 				//			if (!(nodeType instanceof CollectionType)) {		// RealizedVariable accumulated on Connection
 				//				nodeType = isOrdered() ? environment.getOrderedSetType(nodeType, true, null, null) : environment.getSetType(nodeType, true, null, null);
 				//			}
 				if (commonType == null) {
 					commonType = nodeType;
 				}
 				else if (nodeType != commonType) {
 					commonType = commonType.getCommonType(idResolver, nodeType);
 				}
 			}
 		}
 		//		System.out.println("=> " + commonType);
 		assert commonType != null;
 		return commonType;
 	}

 	@Override
 	public @NonNull Set<@NonNull Node> getTargetEnds() {
 		return targetEnd2role.keySet();
 	}

 	@Override
 	public @NonNull Set<@NonNull Node> getTargetNodes() {
 		return targetEnd2role.keySet();
 	}

 	@Override
 	public @Nullable ConnectionRole getTargetRole(@NonNull ConnectionEnd connectionEnd) {
 		return targetEnd2role.get(connectionEnd);
 	}

 	@Override
 	public boolean isNode2Node() {
 		List<Node> sourceEnds = QVTscheduleUtil.getSourceEnds(this);
 		Set<@NonNull Node> targetNodes = getTargetNodes();
 		return (sourceEnds.size() == 1) && (targetNodes.size() == 1);
 	}

 	@Override
 	public boolean isPassed(@NonNull Partition targetPartition) {
 		if (Iterables.contains(targetPartition.getIncomingPassedConnections(), this)) {		// FIXME unify cyclic/non-cyclic
 			return true;
 		}
 		for (@NonNull Node targetNode : getTargetNodes()) {
 			if (!targetNode.isDependency() && targetPartition.isHead(targetNode)) {
 				ConnectionRole role = getTargetRole(targetNode);
 				assert role != null;
 				assert role.isPassed();
 				return true;

 			}
 		}
 		return false;
 	}

 	@Override
 	public boolean isUsed(@NonNull Node targetNode) {
 		ConnectionRole targetConnectionRole = getTargetRole(targetNode);
 		assert targetConnectionRole != null;
 		return targetConnectionRole.isPreferred();
 	}

 	@Override
 	public @Nullable ConnectionRole putTargetRole(@NonNull Node targetNode, @NonNull ConnectionRole newConnectionRole) {
 		ConnectionRole oldConnectionRole = targetEnd2role.get(targetNode);
 		switch (newConnectionRole) {
 			case MANDATORY_NODE: getMandatoryTargetNodes().add(targetNode); break;
 			case PASSED: getPassedTargetNodes().add(targetNode); break;
 			case PREFERRED_NODE: getPreferredTargetNodes().add(targetNode); break;
 			default: throw new UnsupportedOperationException(newConnectionRole.toString());
 		}
 		return oldConnectionRole;
 	}

 	@Override
 	public @Nullable ConnectionRole removeTarget(@NonNull Node targetNode) {
 		if (getMandatoryTargetNodes().remove(targetNode)) {
 			return ConnectionRole.MANDATORY_NODE;
 		}
 		else if (getPassedTargetNodes().remove(targetNode)) {
 			return ConnectionRole.PASSED;
 		}
 		else if (getPreferredTargetNodes().remove(targetNode)) {
 			return ConnectionRole.PREFERRED_NODE;
 		}
 		else {
 			return null;
 		}
 	}

 	/*	@Override
 	public void removeTargetRegion(@NonNull Region targetRegion) {
 		for (@NonNull Node targetNode : Lists.newArrayList(getTargetNodes())) {
 			if (targetNode.getOwningRegion() == targetRegion) {
 				targetNode.setIncomingConnection(null);
 				removeTarget(targetNode);
 			}
 		}
 		if (getTargetNodes().isEmpty()) {
 			destroy();
 		}
 	} */

 	@Override
 	public void setCommonPartition(@NonNull Partition commonPartition, @NonNull List<@NonNull Partition> intermediatePartitions) {
 		assert getCommonPartition() == null;
 		assert getIntermediatePartitions().isEmpty();
 		setCommonPartition(commonPartition);
 		getIntermediatePartitions().addAll(intermediatePartitions);
 		commonPartition.addRootConnection(this);
 		for (@NonNull Partition intermediatePartition : intermediatePartitions) {
 			intermediatePartition.addIntermediateConnection(this);
 		}
 		if (QVTscheduleConstants.CONNECTION_ROUTING.isActive()) {
 			StringBuilder s = new StringBuilder();
 			s.append(getSymbolName() + " common: " + commonPartition + " intermediate:");
 			for (@NonNull Partition intermediatePartition : intermediatePartitions) {
 				s.append(" " + intermediatePartition);
 			}
 			QVTscheduleConstants.CONNECTION_ROUTING.println(s.toString());
 		}
 	}
 } //NodeConnectionImpl
	/**
	* <copyright>
	*
	* Copyright (c) 2013, 2019 Willink Transformations and others.
	* All rights reserved. This program and the accompanying materials
	* are made available under the terms of the Eclipse Public License v2.0
	* which accompanies this distribution, and is available at
	* http://www.eclipse.org/legal/epl-v20.html
	*
	* Contributors:
	* E.D.Willink - Initial API and implementation
	*
	* </copyright>
	*/
	package org.eclipse.qvtd.pivot.qvtschedule.impl;

	import java.util.HashMap;
	import java.util.List;
	import java.util.Map;
	import java.util.Set;

	import org.eclipse.emf.common.notify.Notification;
	import org.eclipse.emf.common.util.EList;
	import org.eclipse.emf.ecore.EClass;

	import org.eclipse.emf.ecore.InternalEObject;
	import org.eclipse.emf.ecore.impl.ENotificationImpl;
	import org.eclipse.emf.ecore.util.EObjectResolvingEList;
	import org.eclipse.jdt.annotation.NonNull;
	import org.eclipse.jdt.annotation.Nullable;
	import org.eclipse.ocl.pivot.CompleteClass;
	import org.eclipse.ocl.pivot.Type;
	import org.eclipse.ocl.pivot.ids.IdResolver;
	import org.eclipse.ocl.pivot.internal.ElementImpl;
	import org.eclipse.ocl.pivot.util.Visitor;
	import org.eclipse.qvtd.pivot.qvtschedule.ClassDatum;
	import org.eclipse.qvtd.pivot.qvtschedule.ConnectionEnd;
	import org.eclipse.qvtd.pivot.qvtschedule.ConnectionRole;
	import org.eclipse.qvtd.pivot.qvtschedule.MappingPartition;
	import org.eclipse.qvtd.pivot.qvtschedule.Node;
	import org.eclipse.qvtd.pivot.qvtschedule.NodeConnection;
	import org.eclipse.qvtd.pivot.qvtschedule.Partition;
	import org.eclipse.qvtd.pivot.qvtschedule.QVTschedulePackage;
	import org.eclipse.qvtd.pivot.qvtschedule.Region;
	import org.eclipse.qvtd.pivot.qvtschedule.Role;
	import org.eclipse.qvtd.pivot.qvtschedule.util.QVTscheduleVisitor;
	import org.eclipse.qvtd.pivot.qvtschedule.utilities.QVTscheduleConstants;
	import org.eclipse.qvtd.pivot.qvtschedule.utilities.QVTscheduleUtil;

	import com.google.common.collect.Iterables;
	import java.util.Collection;

	/**
	* <!-- begin-user-doc -->
	* An implementation of the model object '<em><b>Node Connection</b></em>'.
	* <!-- end-user-doc -->
	* <p>
	* The following features are implemented:
	* </p>
	* <ul>
	* <li>{@link org.eclipse.qvtd.pivot.qvtschedule.impl.NodeConnectionImpl#getClassDatum <em>Class Datum</em>}</li>
	* <li>{@link org.eclipse.qvtd.pivot.qvtschedule.impl.NodeConnectionImpl#getMandatoryTargetNodes <em>Mandatory Target Nodes</em>}</li>
	* <li>{@link org.eclipse.qvtd.pivot.qvtschedule.impl.NodeConnectionImpl#getPassedTargetNodes <em>Passed Target Nodes</em>}</li>
	* <li>{@link org.eclipse.qvtd.pivot.qvtschedule.impl.NodeConnectionImpl#getPreferredTargetNodes <em>Preferred Target Nodes</em>}</li>
	* </ul>
	*
	* @generated
	*/
	public class NodeConnectionImpl extends ConnectionImpl implements NodeConnection
	{
	/**
	* The number of structural features of the '<em>Node Connection</em>' class.
	* <!-- begin-user-doc -->
	* <!-- end-user-doc -->
	* @generated
	* @ordered
	*/
	public static final int NODE_CONNECTION_FEATURE_COUNT = ConnectionImpl.CONNECTION_FEATURE_COUNT + 4;

	/**
	* The number of operations of the '<em>Node Connection</em>' class.
	* <!-- begin-user-doc -->
	* <!-- end-user-doc -->
	* @generated
	* @ordered
	*/
	public static final int NODE_CONNECTION_OPERATION_COUNT = ConnectionImpl.CONNECTION_OPERATION_COUNT + 0;

	/**
	* NodeList duplicates changes to the lists-of-nodes to the 'redundant' node-to-role map.
	*/
	@SuppressWarnings("serial")
	protected static class NodeList extends EObjectResolvingEList<@NonNull Node>
	{
	protected final @NonNull ConnectionRole connectionRole;
	private final @NonNull Map<@NonNull Node, @NonNull ConnectionRole> targetEnd2role;

	protected NodeList(@NonNull NodeConnectionImpl owner, int featureID, @NonNull ConnectionRole connectionRole) {
	super(Node.class, owner, featureID);
	this.connectionRole = connectionRole;
	this.targetEnd2role = owner.targetEnd2role;
	}

	@Override
	protected void didAdd(int index, @NonNull Node newObject) {
	targetEnd2role.put(newObject, connectionRole);
	}

	@Override
	protected void didRemove(int index, @NonNull Node oldObject) {
	targetEnd2role.remove(oldObject);
	}
	}

	/**
	* The cached value of the '{@link #getClassDatum() <em>Class Datum</em>}' reference.
	* <!-- begin-user-doc -->
	* <!-- end-user-doc -->
	* @see #getClassDatum()
	* @generated
	* @ordered
	*/
	protected ClassDatum classDatum;

	/**
	* The cached value of the '{@link #getMandatoryTargetNodes() <em>Mandatory Target Nodes</em>}' reference list.
	* <!-- begin-user-doc -->
	* <!-- end-user-doc -->
	* @see #getMandatoryTargetNodes()
	* @generated
	* @ordered
	*/
	protected EList<Node> mandatoryTargetNodes;
	/**
	* The cached value of the '{@link #getPassedTargetNodes() <em>Passed Target Nodes</em>}' reference list.
	* <!-- begin-user-doc -->
	* <!-- end-user-doc -->
	* @see #getPassedTargetNodes()
	* @generated
	* @ordered
	*/
	protected EList<Node> passedTargetNodes;
	/**
	* The cached value of the '{@link #getPreferredTargetNodes() <em>Preferred Target Nodes</em>}' reference list.
	* <!-- begin-user-doc -->
	* <!-- end-user-doc -->
	* @see #getPreferredTargetNodes()
	* @generated
	* @ordered
	*/
	protected EList<Node> preferredTargetNodes;

	/**
	* <!-- begin-user-doc -->
	* <!-- end-user-doc -->
	* @generated
	*/
	protected NodeConnectionImpl() {
	super();
	}

	/**
	* <!-- begin-user-doc -->
	* <!-- end-user-doc -->
	* @generated
	*/
	@Override
	protected EClass eStaticClass() {
	return QVTschedulePackage.Literals.NODE_CONNECTION;
	}

	/**
	* <!-- begin-user-doc -->
	* <!-- end-user-doc -->
	* @generated
	*/
	@Override
	public ClassDatum getClassDatum() {
	if (classDatum != null && classDatum.eIsProxy()) {
	InternalEObject oldClassDatum = (InternalEObject)classDatum;
	classDatum = (ClassDatum)eResolveProxy(oldClassDatum);
	if (classDatum != oldClassDatum) {
	if (eNotificationRequired())
	eNotify(new ENotificationImpl(this, Notification.RESOLVE, ElementImpl.ELEMENT_FEATURE_COUNT + 7, oldClassDatum, classDatum));
	}
	}
	return classDatum;
	}

	/**
	* <!-- begin-user-doc -->
	* <!-- end-user-doc -->
	* @generated
	*/
	public ClassDatum basicGetClassDatum() {
	return classDatum;
	}

	/**
	* <!-- begin-user-doc -->
	* <!-- end-user-doc -->
	* @generated
	*/
	@Override
	public void setClassDatum(ClassDatum newClassDatum) {
	ClassDatum oldClassDatum = classDatum;
	classDatum = newClassDatum;
	if (eNotificationRequired())
	eNotify(new ENotificationImpl(this, Notification.SET, ElementImpl.ELEMENT_FEATURE_COUNT + 7, oldClassDatum, classDatum));
	}

	/**
	* <!-- begin-user-doc -->
	* <!-- end-user-doc -->
	* @generated NOT
	*/
	@Override
	public List<Node> getMandatoryTargetNodes() {
	if (mandatoryTargetNodes == null) {
	mandatoryTargetNodes = new NodeList(this, QVTschedulePackage.Literals.NODE_CONNECTION__MANDATORY_TARGET_NODES.getFeatureID(), ConnectionRole.MANDATORY_NODE);
	}
	return mandatoryTargetNodes;
	}

	/**
	* <!-- begin-user-doc -->
	* <!-- end-user-doc -->
	* @generated NOT
	*/
	@Override
	public List<Node> getPassedTargetNodes() {
	if (passedTargetNodes == null) {
	passedTargetNodes = new NodeList(this, QVTschedulePackage.Literals.NODE_CONNECTION__PASSED_TARGET_NODES.getFeatureID(), ConnectionRole.PASSED);
	}
	return passedTargetNodes;
	}

	/**
	* <!-- begin-user-doc -->
	* <!-- end-user-doc -->
	* @generated NOT
	*/
	@Override
	public List<Node> getPreferredTargetNodes() {
	if (preferredTargetNodes == null) {
	preferredTargetNodes = new NodeList(this, QVTschedulePackage.Literals.NODE_CONNECTION__PREFERRED_TARGET_NODES.getFeatureID(), ConnectionRole.PREFERRED_NODE);
	}
	return preferredTargetNodes;
	}

	/**
	* <!-- begin-user-doc -->
	* <!-- end-user-doc -->
	* @generated
	*/
	@Override
	public Object eGet(int featureID, boolean resolve, boolean coreType) {
	switch (featureID) {
	case ElementImpl.ELEMENT_FEATURE_COUNT + 7:
	if (resolve) return getClassDatum();
	return basicGetClassDatum();
	case ElementImpl.ELEMENT_FEATURE_COUNT + 8:
	return getMandatoryTargetNodes();
	case ElementImpl.ELEMENT_FEATURE_COUNT + 9:
	return getPassedTargetNodes();
	case ElementImpl.ELEMENT_FEATURE_COUNT + 10:
	return getPreferredTargetNodes();
	}
	return super.eGet(featureID, resolve, coreType);
	}

	/**
	* <!-- begin-user-doc -->
	* <!-- end-user-doc -->
	* @generated
	*/
	@SuppressWarnings("unchecked")
	@Override
	public void eSet(int featureID, Object newValue) {
	switch (featureID) {
	case ElementImpl.ELEMENT_FEATURE_COUNT + 7:
	setClassDatum((ClassDatum)newValue);
	return;
	case ElementImpl.ELEMENT_FEATURE_COUNT + 8:
	getMandatoryTargetNodes().clear();
	getMandatoryTargetNodes().addAll((Collection<? extends Node>)newValue);
	return;
	case ElementImpl.ELEMENT_FEATURE_COUNT + 9:
	getPassedTargetNodes().clear();
	getPassedTargetNodes().addAll((Collection<? extends Node>)newValue);
	return;
	case ElementImpl.ELEMENT_FEATURE_COUNT + 10:
	getPreferredTargetNodes().clear();
	getPreferredTargetNodes().addAll((Collection<? extends Node>)newValue);
	return;
	}
	super.eSet(featureID, newValue);
	}

	/**
	* <!-- begin-user-doc -->
	* <!-- end-user-doc -->
	* @generated
	*/
	@Override
	public void eUnset(int featureID) {
	switch (featureID) {
	case ElementImpl.ELEMENT_FEATURE_COUNT + 7:
	setClassDatum((ClassDatum)null);
	return;
	case ElementImpl.ELEMENT_FEATURE_COUNT + 8:
	getMandatoryTargetNodes().clear();
	return;
	case ElementImpl.ELEMENT_FEATURE_COUNT + 9:
	getPassedTargetNodes().clear();
	return;
	case ElementImpl.ELEMENT_FEATURE_COUNT + 10:
	getPreferredTargetNodes().clear();
	return;
	}
	super.eUnset(featureID);
	}

	/**
	* <!-- begin-user-doc -->
	* <!-- end-user-doc -->
	* @generated
	*/
	@Override
	public boolean eIsSet(int featureID) {
	switch (featureID) {
	case ElementImpl.ELEMENT_FEATURE_COUNT + 7:
	return classDatum != null;
	case ElementImpl.ELEMENT_FEATURE_COUNT + 8:
	return mandatoryTargetNodes != null && !mandatoryTargetNodes.isEmpty();
	case ElementImpl.ELEMENT_FEATURE_COUNT + 9:
	return passedTargetNodes != null && !passedTargetNodes.isEmpty();
	case ElementImpl.ELEMENT_FEATURE_COUNT + 10:
	return preferredTargetNodes != null && !preferredTargetNodes.isEmpty();
	}
	return super.eIsSet(featureID);
	}

	/**
	* {@inheritDoc}
	* @generated
	*/
	@SuppressWarnings("unchecked")
	@Override
	public <R> R accept(@NonNull Visitor<R> visitor) {
	if (visitor instanceof QVTscheduleVisitor) {
	return (R) ((QVTscheduleVisitor<?>)visitor).visitNodeConnection(this);
	}
	else {
	return super.accept(visitor);
	}
	}

	@Override
	public boolean isMandatory() {
	return getConnectionRole().isMandatory();
	}

	@Override
	public boolean isPassed() {
	return getConnectionRole().isPassed();
	}

	@Override
	public boolean isUsed() {
	return getConnectionRole().isPreferred();
	}

	private final @NonNull Map<@NonNull Node, @NonNull ConnectionRole> targetEnd2role = new HashMap<>();

	@Override
	public void addPassedTargetNode(@NonNull Node targetNode) {
	mergeRole(ConnectionRole.PASSED);
	ConnectionRole targetRole = getTargetRole(targetNode);
	assert targetRole == null;
	putTargetRole(targetNode, ConnectionRole.PASSED);
	targetNode.setIncomingConnection(this);
	// assert Sets.intersection(getSourceRegions(), getTargetRegions()).isEmpty();
	}

	@Override
	public void addUsedTargetNode(@NonNull Node targetNode, boolean mustBeLater) {
	ConnectionRole newConnectionRole = mustBeLater ? ConnectionRole.MANDATORY_NODE : ConnectionRole.PREFERRED_NODE;
	ConnectionRole oldConnectionRole = getTargetRole(targetNode);
	if ((oldConnectionRole != null) && (oldConnectionRole != newConnectionRole)) {
	newConnectionRole = newConnectionRole.merge(oldConnectionRole);
	}
	mergeRole(newConnectionRole);
	putTargetRole(targetNode, newConnectionRole);
	assert targetNode.getIncomingConnection() == null;
	targetNode.setIncomingConnection(this);
	// assert Sets.intersection(getSourceRegions(), getTargetRegions()).isEmpty();
	}

	@Override
	public @Nullable Node basicGetSource(@NonNull Partition sourcePartition) {
	Node sourceNode = null;
	for (@NonNull Node sourceEnd : QVTscheduleUtil.getSourceEnds(this)) {
	Region sourceRegion = QVTscheduleUtil.getOwningRegion(sourceEnd);
	Iterable<@NonNull MappingPartition> sourceRegionPartitions = QVTscheduleUtil.getRegionPartitions(sourceRegion);
	if (Iterables.contains(sourceRegionPartitions, sourcePartition)) {
	Role sourceRole = QVTscheduleUtil.getRole(sourcePartition, sourceEnd);
	if ((sourceRole != null) && !sourceRole.isChecked()) { //(sourceRole.isNew() \|\| sourceRole.isLoaded())) {
	assert sourceNode == null;
	sourceNode = sourceEnd;
	}
	}
	}
	return sourceNode;
	}

	@Override
	public void destroy() {
	for (@NonNull Node sourceNode : QVTscheduleUtil.getSourceEnds(this)) {
	assert Iterables.contains(QVTscheduleUtil.getSourceEnds(this), sourceNode);
	// assert edge.getRegion() == getRegion();
	List<NodeConnection> outgoingConnections2 = sourceNode.getOutgoingConnections();
	assert outgoingConnections2 != null;
	@SuppressWarnings("unused")
	boolean wasRemoved = outgoingConnections2.remove(this);
	// assert wasRemoved;
	}
	for (@NonNull Node targetNode : targetEnd2role.keySet()) {
	targetNode.setIncomingConnection(null);
	}
	targetEnd2role.clear();
	super.destroy();
	}

	@Override
	public @NonNull Node getSource(@NonNull Partition sourcePartition) {
	return (Node) super.getSource(sourcePartition);
	}

	@Override
	public @NonNull Iterable<@NonNull Node> getSourceNodes() {
	return QVTscheduleUtil.getSourceEnds(this);
	}

	@Override
	public @NonNull Type getSourcesType(@NonNull IdResolver idResolver) {
	// System.out.println("commonType of " + this);
	Type commonType = null;
	for (@NonNull Node node : QVTscheduleUtil.getSourceEnds(this)) {
	ClassDatum classDatum2 = QVTscheduleUtil.getClassDatum(node);
	for (@NonNull CompleteClass completeClass : QVTscheduleUtil.getCompleteClasses(classDatum2)) { // ?? never a multiple
	Type nodeType = completeClass.getPrimaryClass();
	// if (nodeType instanceof CollectionType) {
	// nodeType = ((CollectionType)nodeType).getElementType(); // FIXME needed for composed source nodes
	// assert nodeType != null;
	// }
	// System.out.println(" nodeType " + nodeType);
	// CompleteEnvironment environment = idResolver.getEnvironment();
	// if (!(nodeType instanceof CollectionType)) { // RealizedVariable accumulated on Connection
	// nodeType = isOrdered() ? environment.getOrderedSetType(nodeType, true, null, null) : environment.getSetType(nodeType, true, null, null);
	// }
	if (commonType == null) {
	commonType = nodeType;
	}
	else if (nodeType != commonType) {
	commonType = commonType.getCommonType(idResolver, nodeType);
	}
	}
	}
	// System.out.println("=> " + commonType);
	assert commonType != null;
	return commonType;
	}

	@Override
	public @NonNull Set<@NonNull Node> getTargetEnds() {
	return targetEnd2role.keySet();
	}

	@Override
	public @NonNull Set<@NonNull Node> getTargetNodes() {
	return targetEnd2role.keySet();
	}

	@Override
	public @Nullable ConnectionRole getTargetRole(@NonNull ConnectionEnd connectionEnd) {
	return targetEnd2role.get(connectionEnd);
	}

	@Override
	public boolean isNode2Node() {
	List<Node> sourceEnds = QVTscheduleUtil.getSourceEnds(this);
	Set<@NonNull Node> targetNodes = getTargetNodes();
	return (sourceEnds.size() == 1) && (targetNodes.size() == 1);
	}

	@Override
	public boolean isPassed(@NonNull Partition targetPartition) {
	if (Iterables.contains(targetPartition.getIncomingPassedConnections(), this)) { // FIXME unify cyclic/non-cyclic
	return true;
	}
	for (@NonNull Node targetNode : getTargetNodes()) {
	if (!targetNode.isDependency() && targetPartition.isHead(targetNode)) {
	ConnectionRole role = getTargetRole(targetNode);
	assert role != null;
	assert role.isPassed();
	return true;

	}
	}
	return false;
	}

	@Override
	public boolean isUsed(@NonNull Node targetNode) {
	ConnectionRole targetConnectionRole = getTargetRole(targetNode);
	assert targetConnectionRole != null;
	return targetConnectionRole.isPreferred();
	}

	@Override
	public @Nullable ConnectionRole putTargetRole(@NonNull Node targetNode, @NonNull ConnectionRole newConnectionRole) {
	ConnectionRole oldConnectionRole = targetEnd2role.get(targetNode);
	switch (newConnectionRole) {
	case MANDATORY_NODE: getMandatoryTargetNodes().add(targetNode); break;
	case PASSED: getPassedTargetNodes().add(targetNode); break;
	case PREFERRED_NODE: getPreferredTargetNodes().add(targetNode); break;
	default: throw new UnsupportedOperationException(newConnectionRole.toString());
	}
	return oldConnectionRole;
	}

	@Override
	public @Nullable ConnectionRole removeTarget(@NonNull Node targetNode) {
	if (getMandatoryTargetNodes().remove(targetNode)) {
	return ConnectionRole.MANDATORY_NODE;
	}
	else if (getPassedTargetNodes().remove(targetNode)) {
	return ConnectionRole.PASSED;
	}
	else if (getPreferredTargetNodes().remove(targetNode)) {
	return ConnectionRole.PREFERRED_NODE;
	}
	else {
	return null;
	}
	}

	/* @Override
	public void removeTargetRegion(@NonNull Region targetRegion) {
	for (@NonNull Node targetNode : Lists.newArrayList(getTargetNodes())) {
	if (targetNode.getOwningRegion() == targetRegion) {
	targetNode.setIncomingConnection(null);
	removeTarget(targetNode);
	}
	}
	if (getTargetNodes().isEmpty()) {
	destroy();
	}
	} */

	@Override
	public void setCommonPartition(@NonNull Partition commonPartition, @NonNull List<@NonNull Partition> intermediatePartitions) {
	assert getCommonPartition() == null;
	assert getIntermediatePartitions().isEmpty();
	setCommonPartition(commonPartition);
	getIntermediatePartitions().addAll(intermediatePartitions);
	commonPartition.addRootConnection(this);
	for (@NonNull Partition intermediatePartition : intermediatePartitions) {
	intermediatePartition.addIntermediateConnection(this);
	}
	if (QVTscheduleConstants.CONNECTION_ROUTING.isActive()) {
	StringBuilder s = new StringBuilder();
	s.append(getSymbolName() + " common: " + commonPartition + " intermediate:");
	for (@NonNull Partition intermediatePartition : intermediatePartitions) {
	s.append(" " + intermediatePartition);
	}
	QVTscheduleConstants.CONNECTION_ROUTING.println(s.toString());
	}
	}
	} //NodeConnectionImpl