bundles/org.simantics.mapping/src/org/simantics/mapping/constraint/instructions/AndInstruction.java

   1 /*******************************************************************************\r
   2  * Copyright (c) 2007, 2010 Association for Decentralized Information Management\r
   3  * in Industry THTH ry.\r
   4  * All rights reserved. This program and the accompanying materials\r
   5  * are made available under the terms of the Eclipse Public License v1.0\r
   6  * which accompanies this distribution, and is available at\r
   7  * http://www.eclipse.org/legal/epl-v10.html\r
   8  *\r
   9  * Contributors:\r
  10  *     VTT Technical Research Centre of Finland - initial API and implementation\r
  11  *******************************************************************************/\r
  12 package org.simantics.mapping.constraint.instructions;\r
  13 \r
  14 import org.simantics.db.ReadGraph;\r
  15 import org.simantics.db.exception.DatabaseException;\r
  16 \r
  17 public class AndInstruction extends CombinedInstruction {\r
  18         \r
  19         public AndInstruction(IInstruction... instructions) {\r
  20                 super(instructions);\r
  21         }\r
  22 \r
  23         static class Continuation {\r
  24                 Object continuation;\r
  25                 int instructionId;      \r
  26                 Continuation next;              \r
  27                 \r
  28                 public Continuation(Object continuation, int instructionId,\r
  29                                 Continuation next) {\r
  30                         this.continuation = continuation;\r
  31                         this.instructionId = instructionId;\r
  32                         this.next = next;\r
  33                 }\r
  34 \r
  35         }\r
  36         \r
  37         @Override\r
  38         public Object query(ReadGraph g, Object[] bindings) throws DatabaseException {\r
  39                 Continuation ret = null;\r
  40                 int instructionId = 0;\r
  41                 while(instructionId < instructions.length) {\r
  42                         if(DEBUG)\r
  43                                 System.out.println("AndInstruction.query " + instructionId + "/" + instructions.length);\r
  44                         Object continuation = instructions[instructionId].query(g, bindings);\r
  45                         if(continuation == IInstruction.FAILURE) {\r
  46                                 while(true) {\r
  47                                         if(ret == null)\r
  48                                                 return IInstruction.FAILURE;\r
  49                                         instructionId = ret.instructionId;\r
  50                                         continuation = instructions[instructionId].next(g, bindings, ret.continuation);\r
  51                                         if(continuation == IInstruction.FAILURE) {\r
  52                                                 ret = ret.next;                                         \r
  53                                                 continue;\r
  54                                         }\r
  55                                         if(continuation == null) \r
  56                                                 ret = ret.next;\r
  57                                         else\r
  58                                                 ret.continuation = continuation;\r
  59                                         break;\r
  60                                 }                                                                       \r
  61                         }\r
  62                         else if(continuation != null)\r
  63                                 ret = new Continuation(continuation, instructionId, ret);\r
  64                         ++instructionId;\r
  65                 }\r
  66                 return ret;\r
  67         }\r
  68         \r
  69         @Override\r
  70         public Object next(ReadGraph g, Object[] bindings, Object ret_) throws DatabaseException {\r
  71                 Continuation ret = (Continuation)ret_;\r
  72                 int instructionId;\r
  73                 while(true) {\r
  74                         if(ret == null)\r
  75                                 return IInstruction.FAILURE;\r
  76                         instructionId = ret.instructionId;\r
  77                         Object continuation = \r
  78                                 instructions[instructionId].next(g, bindings, ret.continuation);\r
  79                         if(continuation == IInstruction.FAILURE) {\r
  80                                 ret = ret.next;                                         \r
  81                                 continue;\r
  82                         }\r
  83                         if(continuation == null) \r
  84                                 ret = ret.next;\r
  85                         else\r
  86                                 ret.continuation = continuation;\r
  87                         break;\r
  88                 }\r
  89                 ++instructionId;\r
  90                 while(instructionId < instructions.length) {\r
  91                         Object continuation = instructions[instructionId].query(g, bindings);\r
  92                         if(continuation == IInstruction.FAILURE) {\r
  93                                 while(true) {\r
  94                                         if(ret == null)\r
  95                                                 return IInstruction.FAILURE;\r
  96                                         instructionId = ret.instructionId;\r
  97                                         continuation = instructions[instructionId].next(g, bindings, ret.continuation);\r
  98                                         if(continuation == IInstruction.FAILURE) {\r
  99                                                 ret = ret.next;                                         \r
 100                                                 continue;\r
 101                                         }\r
 102                                         if(continuation == null) \r
 103                                                 ret = ret.next;\r
 104                                         else\r
 105                                                 ret.continuation = continuation;\r
 106                                         break;\r
 107                                 }                                                                       \r
 108                         }\r
 109                         else if(continuation != null)\r
 110                                 ret = new Continuation(continuation, instructionId, ret);\r
 111                         ++instructionId;\r
 112                 }\r
 113                 return ret;\r
 114         }\r
 115 \r
 116         @Override\r
 117         public void toString(StringBuilder b, int indent) {             \r
 118                 b.append("(    ");\r
 119                 boolean first = true;\r
 120                 for(IInstruction inst : instructions) {\r
 121                         if(first)\r
 122                                 first = false;\r
 123                         else {\r
 124                                 b.append(",\n");\r
 125                                 for(int i=0;i<indent+1;++i)\r
 126                                         b.append(INDENTATION);\r
 127                         }\r
 128                         inst.toString(b, indent + 1);                   \r
 129                 }\r
 130                 b.append('\n');\r
 131                 for(int i=0;i<indent;++i)\r
 132                         b.append(INDENTATION);\r
 133                 b.append(")");          \r
 134         }\r
 135         \r
 136 }