Migrated source code from Simantics SVN

[simantics/platform.git] / bundles / org.simantics.mapping / src / org / simantics / mapping / constraint / instructions / AndInstruction.java

diff --git a/bundles/org.simantics.mapping/src/org/simantics/mapping/constraint/instructions/AndInstruction.java b/bundles/org.simantics.mapping/src/org/simantics/mapping/constraint/instructions/AndInstruction.java
new file mode 100644 (file)
index 0000000..fffb139
--- /dev/null
+++ b/bundles/org.simantics.mapping/src/org/simantics/mapping/constraint/instructions/AndInstruction.java
@@ -0,0 +1,136 @@
+/*******************************************************************************\r
+ * Copyright (c) 2007, 2010 Association for Decentralized Information Management\r
+ * in Industry THTH ry.\r
+ * All rights reserved. This program and the accompanying materials\r
+ * are made available under the terms of the Eclipse Public License v1.0\r
+ * which accompanies this distribution, and is available at\r
+ * http://www.eclipse.org/legal/epl-v10.html\r
+ *\r
+ * Contributors:\r
+ *     VTT Technical Research Centre of Finland - initial API and implementation\r
+ *******************************************************************************/\r
+package org.simantics.mapping.constraint.instructions;\r
+\r
+import org.simantics.db.ReadGraph;\r
+import org.simantics.db.exception.DatabaseException;\r
+\r
+public class AndInstruction extends CombinedInstruction {\r
+       \r
+       public AndInstruction(IInstruction... instructions) {\r
+               super(instructions);\r
+       }\r
+\r
+       static class Continuation {\r
+               Object continuation;\r
+               int instructionId;      \r
+               Continuation next;              \r
+               \r
+               public Continuation(Object continuation, int instructionId,\r
+                               Continuation next) {\r
+                       this.continuation = continuation;\r
+                       this.instructionId = instructionId;\r
+                       this.next = next;\r
+               }\r
+\r
+       }\r
+       \r
+       @Override\r
+       public Object query(ReadGraph g, Object[] bindings) throws DatabaseException {\r
+               Continuation ret = null;\r
+               int instructionId = 0;\r
+               while(instructionId < instructions.length) {\r
+                       if(DEBUG)\r
+                               System.out.println("AndInstruction.query " + instructionId + "/" + instructions.length);\r
+                       Object continuation = instructions[instructionId].query(g, bindings);\r
+                       if(continuation == IInstruction.FAILURE) {\r
+                               while(true) {\r
+                                       if(ret == null)\r
+                                               return IInstruction.FAILURE;\r
+                                       instructionId = ret.instructionId;\r
+                                       continuation = instructions[instructionId].next(g, bindings, ret.continuation);\r
+                                       if(continuation == IInstruction.FAILURE) {\r
+                                               ret = ret.next;                                         \r
+                                               continue;\r
+                                       }\r
+                                       if(continuation == null) \r
+                                               ret = ret.next;\r
+                                       else\r
+                                               ret.continuation = continuation;\r
+                                       break;\r
+                               }                                                                       \r
+                       }\r
+                       else if(continuation != null)\r
+                               ret = new Continuation(continuation, instructionId, ret);\r
+                       ++instructionId;\r
+               }\r
+               return ret;\r
+       }\r
+       \r
+       @Override\r
+       public Object next(ReadGraph g, Object[] bindings, Object ret_) throws DatabaseException {\r
+               Continuation ret = (Continuation)ret_;\r
+               int instructionId;\r
+               while(true) {\r
+                       if(ret == null)\r
+                               return IInstruction.FAILURE;\r
+                       instructionId = ret.instructionId;\r
+                       Object continuation = \r
+                               instructions[instructionId].next(g, bindings, ret.continuation);\r
+                       if(continuation == IInstruction.FAILURE) {\r
+                               ret = ret.next;                                         \r
+                               continue;\r
+                       }\r
+                       if(continuation == null) \r
+                               ret = ret.next;\r
+                       else\r
+                               ret.continuation = continuation;\r
+                       break;\r
+               }\r
+               ++instructionId;\r
+               while(instructionId < instructions.length) {\r
+                       Object continuation = instructions[instructionId].query(g, bindings);\r
+                       if(continuation == IInstruction.FAILURE) {\r
+                               while(true) {\r
+                                       if(ret == null)\r
+                                               return IInstruction.FAILURE;\r
+                                       instructionId = ret.instructionId;\r
+                                       continuation = instructions[instructionId].next(g, bindings, ret.continuation);\r
+                                       if(continuation == IInstruction.FAILURE) {\r
+                                               ret = ret.next;                                         \r
+                                               continue;\r
+                                       }\r
+                                       if(continuation == null) \r
+                                               ret = ret.next;\r
+                                       else\r
+                                               ret.continuation = continuation;\r
+                                       break;\r
+                               }                                                                       \r
+                       }\r
+                       else if(continuation != null)\r
+                               ret = new Continuation(continuation, instructionId, ret);\r
+                       ++instructionId;\r
+               }\r
+               return ret;\r
+       }\r
+\r
+       @Override\r
+       public void toString(StringBuilder b, int indent) {             \r
+               b.append("(    ");\r
+               boolean first = true;\r
+               for(IInstruction inst : instructions) {\r
+                       if(first)\r
+                               first = false;\r
+                       else {\r
+                               b.append(",\n");\r
+                               for(int i=0;i<indent+1;++i)\r
+                                       b.append(INDENTATION);\r
+                       }\r
+                       inst.toString(b, indent + 1);                   \r
+               }\r
+               b.append('\n');\r
+               for(int i=0;i<indent;++i)\r
+                       b.append(INDENTATION);\r
+               b.append(")");          \r
+       }\r
+       \r
+}
\ No newline at end of file