--- /dev/null
+/*******************************************************************************\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 OrInstruction extends CombinedInstruction {\r
+ \r
+ public OrInstruction(IInstruction... instructions) {\r
+ super(instructions);\r
+ }\r
+\r
+ static class Continuation {\r
+ Object continuation;\r
+ int instructionId; \r
+ \r
+ public Continuation(Object continuation, int instructionId) {\r
+ this.continuation = continuation;\r
+ this.instructionId = instructionId;\r
+ }\r
+ }\r
+ \r
+ @Override\r
+ public Object query(ReadGraph g, Object[] bindings) throws DatabaseException {\r
+ int instructionId;\r
+ for(instructionId=0;instructionId<instructions.length-1;++instructionId) {\r
+ if(DEBUG)\r
+ System.out.println("OrInstruction.query " + instructionId + "/" + instructions.length);\r
+ Object continuation = instructions[instructionId].query(g, bindings);\r
+ if(continuation != IInstruction.FAILURE)\r
+ return new Continuation(continuation, instructionId);\r
+ }\r
+ return instructions[instructionId].query(g, bindings);\r
+ }\r
+ \r
+ @Override\r
+ public Object next(ReadGraph g, Object[] bindings, Object ret_) throws DatabaseException {\r
+ Continuation ret = (Continuation)ret_;\r
+ int instructionId = ret.instructionId;\r
+ Object continuation = ret.continuation;\r
+ \r
+ if(continuation != null) {\r
+ continuation = instructions[instructionId].next(g, bindings, continuation);\r
+ if(continuation != IInstruction.FAILURE) {\r
+ ret.continuation = continuation;\r
+ return ret;\r
+ }\r
+ }\r
+ \r
+ for(++instructionId;instructionId<instructions.length-1;++instructionId) {\r
+ continuation = instructions[instructionId].query(g, bindings);\r
+ if(continuation != IInstruction.FAILURE) {\r
+ ret.continuation = continuation;\r
+ ret.instructionId = instructionId; \r
+ return ret;\r
+ }\r
+ }\r
+ return instructions[instructionId].query(g, bindings);\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