1 files changed, 130 insertions, 0 deletions
diff --git a/sandbox/Moka/org.eclipse.papyrus.moka.fuml/generated/org/eclipse/papyrus/moka/fuml/Semantics/Activities/IntermediateActivities/ObjectNodeActivation.java b/sandbox/Moka/org.eclipse.papyrus.moka.fuml/generated/org/eclipse/papyrus/moka/fuml/Semantics/Activities/IntermediateActivities/ObjectNodeActivation.java
new file mode 100644
index 00000000000..99d2b602241
--- /dev/null
+++ b/sandbox/Moka/org.eclipse.papyrus.moka.fuml/generated/org/eclipse/papyrus/moka/fuml/Semantics/Activities/IntermediateActivities/ObjectNodeActivation.java
@@ -0,0 +1,130 @@
+/*****************************************************************************
+ * Copyright (c) 2012 CEA LIST.
+ *
+ *    
+ * 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:
+ *  CEA LIST - Initial API and implementation
+ *
+ *****************************************************************************/
+package org.eclipse.papyrus.moka.fuml.Semantics.Activities.IntermediateActivities;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public abstract class ObjectNodeActivation extends ActivityNodeActivation {
+
+	/*
+	 * The number of held tokens that have already been offered.
+	 */
+	public Integer offeredTokenCount;
+
+	public void run() {
+		// Initialize the offered token count to zero.
+		super.run();
+		this.offeredTokenCount = 0;
+	}
+
+	public void sendOffers(List<Token> tokens) {
+		// If the set of tokens to be sent is empty, then offer a null token
+		// instead.
+		// Otherwise, offer the given tokens as usual.
+		if(tokens.size() == 0) {
+			ObjectToken token = new ObjectToken();
+			token.holder = this;
+			tokens.add(token);
+		}
+		super.sendOffers(tokens);
+	}
+
+	public void terminate() {
+		// Remove any offered tokens and terminate.
+		this.clearTokens();
+		super.terminate();
+	}
+
+	public void addToken(Token token) {
+		// Transfer the given token to be held by this node only if it is a
+		// non-null object token.
+		// If it is a control token or a null token, consume it without holding
+		// it.
+		if(token.getValue() == null) {
+			token.withdraw();
+		} else {
+			super.addToken(token);
+		}
+	}
+
+	public Integer removeToken(Token token) {
+		// Remove the given token, if it is held by this node activation.
+		int i = super.removeToken(token);
+		if(i > 0 & i <= this.offeredTokenCount) {
+			this.offeredTokenCount = this.offeredTokenCount - 1;
+		}
+		return i;
+	}
+
+	public void clearTokens() {
+		// Remove all held tokens.
+		super.clearTokens();
+		this.offeredTokenCount = 0;
+	}
+
+	public Integer countOfferedValues() {
+		// Count the total number of non-null object tokens being offered to
+		// this node activation.
+		int totalValueCount = 0;
+		int i = 1;
+		while(i <= this.incomingEdges.size()) {
+			totalValueCount = totalValueCount + this.incomingEdges.get(i - 1).countOfferedValues();
+			i = i + 1;
+		}
+		return totalValueCount;
+	}
+
+	public void sendUnofferedTokens() {
+		// Send offers over all outgoing edges, if there are any tokens to be
+		// offered.
+		List<Token> tokens = this.getUnofferedTokens();
+		this.offeredTokenCount = this.offeredTokenCount + tokens.size();
+		this.sendOffers(tokens);
+	}
+
+	public Integer countUnofferedTokens() {
+		// Return the number of unoffered tokens that are to be offered next.
+		// (By default, this is all unoffered tokens.)
+		if(this.heldTokens.size() == 0) {
+			this.offeredTokenCount = 0;
+		}
+		return this.heldTokens.size() - this.offeredTokenCount;
+	}
+
+	public List<Token> getUnofferedTokens() {
+		// Get the next set of unoffered tokens to be offered and return it.
+		// [Note: This effectively treats all object flows as if they have
+		// weight=*, rather than the weight=1 default in the current
+		// superstructure semantics.]
+		List<Token> tokens = new ArrayList<Token>();
+		int i = 1;
+		while(i <= this.countUnofferedTokens()) {
+			tokens.add(this.heldTokens.get(this.offeredTokenCount + i - 1));
+			i = i + 1;
+		}
+		return tokens;
+	}
+
+	public List<Token> takeUnofferedTokens() {
+		// Take the next set of unoffered tokens to be offered from this node
+		// activation and return them.
+		List<Token> tokens = this.getUnofferedTokens();
+		for(int i = 0; i < tokens.size(); i++) {
+			Token token = tokens.get(i);
+			token.withdraw();
+		}
+		return tokens;
+	}
+}