1 files changed, 141 insertions, 0 deletions
diff --git a/doc/org.eclipse.qvtd.doc.minioclcs.xtext/src-gen/org/eclipse/qvtd/doc/minioclcs/xtext/internal/tx/AbstractInvocationManagerInternal.java b/doc/org.eclipse.qvtd.doc.minioclcs.xtext/src-gen/org/eclipse/qvtd/doc/minioclcs/xtext/internal/tx/AbstractInvocationManagerInternal.java
new file mode 100644
index 000000000..b68eb17cc
--- /dev/null
+++ b/doc/org.eclipse.qvtd.doc.minioclcs.xtext/src-gen/org/eclipse/qvtd/doc/minioclcs/xtext/internal/tx/AbstractInvocationManagerInternal.java
@@ -0,0 +1,141 @@
+/**
+ * This file was copied and re-packaged automatically by
+ *     org.eclipse.qvtd.doc.miniocl.build.MiniOCLBuildEverything
+ * from 
+ *     ..\..\plugins\org.eclipse.qvtd.runtime\src\org\eclipse\qvtd\runtime\internal\evaluation\AbstractInvocationManagerInternal.java
+ *
+ * Do not edit this file. 
+ */
+/*******************************************************************************
+ * Copyright (c) 2013, 2016 Willink Transformations and others.
+ * All rights reserved.   This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ *   E.D.Willink - Initial API and implementation
+ *******************************************************************************/
+package org.eclipse.qvtd.doc.minioclcs.xtext.internal.tx;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import org.eclipse.jdt.annotation.NonNull;
+import org.eclipse.ocl.pivot.evaluation.Executor;
+import org.eclipse.qvtd.doc.minioclcs.xtext.tx.AbstractInvocationManager;
+import org.eclipse.qvtd.doc.minioclcs.xtext.tx.DefaultInterval;
+import org.eclipse.qvtd.doc.minioclcs.xtext.tx.Interval;
+import org.eclipse.qvtd.doc.minioclcs.xtext.tx.Invocation;
+import org.eclipse.qvtd.doc.minioclcs.xtext.tx.InvocationConstructor;
+
+import com.google.common.collect.Iterables;
+
+/**
+ * InvocationManager supervises and provides thread safety for the lists of blocked and waiting invocations.
+ */
+public abstract class AbstractInvocationManagerInternal extends AbstractInvocationManager
+{
+	/**
+	 * The distinct intervals of the schedule. Wherever possible work for earlier intervals is completed before that
+	 * for later intervals.
+	 */
+	private final @NonNull List<@NonNull Interval> intervals = new ArrayList<>();
+
+	/**
+	 * The invokers that create invocations.
+	 */
+	private final @NonNull List<@NonNull InvocationConstructor> invokers = new ArrayList<>();
+
+	private volatile int nextIndex = Integer.MAX_VALUE;
+
+	protected final @NonNull Executor executor;
+
+	protected AbstractInvocationManagerInternal(@NonNull Executor executor) {
+		this.executor = executor;
+	}
+
+	@Override
+	public void addInvoker(@NonNull InvocationConstructor constructor) {
+		assert !invokers.contains(constructor);
+		invokers.add(constructor);
+	}
+
+	@Override
+	public @NonNull Interval createInterval() {
+		Interval interval = new DefaultInterval(this, intervals.size());
+		intervals.add(interval);
+		return interval;
+	}
+
+	/*	@Override
+	public @NonNull InvocationConstructor createInvoker(@NonNull InvocationConstructor constructor, int consumedConnections, @NonNull Interval interval, @NonNull Connection @NonNull  ... connections) {
+		InvocationConstructor invoker;
+		if (consumedConnections == 1) {
+			invoker = new AbstractInvoker1(interval, constructor, connections[0], Arrays.copyOfRange(connections, 1, connections.length));
+		}
+		else {
+			invoker = new AbstractInvokerN(interval, constructor, Arrays.copyOf(connections, consumedConnections), Arrays.copyOfRange(connections, consumedConnections, connections.length));
+		}
+		invokers.add(invoker);
+		return invoker;
+	} */
+
+	public @NonNull Iterable<@NonNull Invocation> debugGetAllInvocations() {
+		List<@NonNull Invocation> allInvocations = new ArrayList<>();
+		for (@NonNull InvocationConstructor invoker : invokers) {
+			Iterables.addAll(allInvocations, invoker.debugGetInvocations());
+		}
+		return allInvocations;
+	}
+
+	@Override
+	public boolean flush() {
+		for (int index = nextIndex; index < intervals.size(); index = nextIndex) {
+			nextIndex = index+1;
+			Interval nextInterval = intervals.get(index);
+			nextInterval.flush();				// May set nextIndex back to 'same' or even earlier
+		}
+		for (@NonNull Interval interval : intervals) {
+			if (!interval.isFlushed()) {
+				return false;
+			}
+		}
+		return true;
+	}
+
+	@Override
+	public @NonNull Executor getExecutor() {
+		return executor;
+	}
+
+	@Override
+	public @NonNull Iterable<@NonNull Interval> getIntervals() {
+		return intervals;
+	}
+
+	@Override
+	public @NonNull Iterable<@NonNull InvocationConstructor> getInvokers() {
+		return invokers;
+	}
+
+	@Override
+	public @NonNull Interval getRootInterval() {
+		if (intervals.size() <= 0) {
+			createInterval();
+		}
+		return intervals.get(0);
+	}
+
+	//	@Override
+	//	public @Nullable Transformer getTransformer() {
+	//		return transformer;
+	//	}
+
+	@Override
+	public void setWorkToDoAt(int intervalIndex) {
+		if (intervalIndex < nextIndex) {
+			nextIndex = intervalIndex;
+		}
+	}
+}
+\ No newline at end of file