1 files changed, 60 insertions, 0 deletions
diff --git a/plugins/org.eclipse.etrice.core.etphys/src/org/eclipse/etrice/core/etphys/validation/ETPhysJavaValidator.java b/plugins/org.eclipse.etrice.core.etphys/src/org/eclipse/etrice/core/etphys/validation/ETPhysJavaValidator.java
new file mode 100644
index 000000000..fa08b23b2
--- /dev/null
+++ b/plugins/org.eclipse.etrice.core.etphys/src/org/eclipse/etrice/core/etphys/validation/ETPhysJavaValidator.java
@@ -0,0 +1,60 @@
+/*******************************************************************************
+ * Copyright (c) 2012 protos software gmbh (http://www.protos.de).
+ * 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:
+ * 		Henrik Rentz-Reichert (initial contribution)
+ * 
+ *******************************************************************************/
+
+package org.eclipse.etrice.core.etphys.validation;
+
+import org.eclipse.etrice.core.etphys.eTPhys.ETPhysPackage;
+import org.eclipse.etrice.core.etphys.eTPhys.NodeClass;
+import org.eclipse.etrice.core.etphys.eTPhys.PhysicalThread;
+import org.eclipse.etrice.core.etphys.eTPhys.ThreadModel;
+import org.eclipse.xtext.validation.Check;
+ 
+
+public class ETPhysJavaValidator extends AbstractETPhysJavaValidator {
+
+	@Check
+	public void checkThread(PhysicalThread thread) {
+		NodeClass nc = (NodeClass) thread.eContainer();
+		
+		if (thread.getPrio()<nc.getPriomin())
+			error("prio less than minimum", ETPhysPackage.Literals.PHYSICAL_THREAD__PRIO);
+		
+		if (thread.getPrio()>nc.getPriomax())
+			error("prio greater than maximum", ETPhysPackage.Literals.PHYSICAL_THREAD__PRIO);
+	}
+	
+	@Check
+	public void checkNodeClass(NodeClass nc) {
+		{
+			// make sure there is one and only one DefaultThread
+			boolean hasDefault = false;
+			for (PhysicalThread thread : nc.getThreads()) {
+				if (thread.isDefault())
+					if (hasDefault) {
+						int idx = nc.getThreads().indexOf(thread);
+						error("only one DefaultThread allowed", ETPhysPackage.Literals.NODE_CLASS__THREADS, idx);
+					}
+					else
+						hasDefault = true;
+			}
+			
+			if (!hasDefault)
+				error("there must be one DefaultThread", ETPhysPackage.Literals.NODE_CLASS__THREADS);
+		}
+		
+		// single threaded mode has to have one thread
+		if (nc.getRuntime()!=null) {
+			if (nc.getRuntime().getThreadModel()==ThreadModel.SINGLE_THREADED && nc.getThreads().size()>1)
+				error("runtime is single threaded but more than one thread defined", ETPhysPackage.Literals.NODE_CLASS__THREADS);
+		}
+	}
+}