-package org.simantics.db.impl.graph;\r
-\r
-import org.simantics.db.Resource;\r
-import org.simantics.db.common.utils.Logger;\r
-import org.simantics.db.impl.query.IntProcedure;\r
-import org.simantics.db.impl.query.QuerySupport;\r
-import org.simantics.db.procedure.AsyncMultiProcedure;\r
-\r
-public class MultiIntProcedure implements IntProcedure {\r
-\r
- final private AsyncMultiProcedure<Resource> procedure;\r
- final private ReadGraphImpl impl;\r
- final private QuerySupport support;\r
- \r
- public MultiIntProcedure(AsyncMultiProcedure<Resource> procedure, ReadGraphImpl impl, QuerySupport support) {\r
- this.procedure = procedure;\r
- this.impl = impl;\r
- this.support = support;\r
- }\r
- \r
- @Override\r
- public void execute(ReadGraphImpl graph, int i) {\r
- try {\r
- procedure.execute(graph, support.getResource(i));\r
- } catch (Throwable t2) {\r
- Logger.defaultLogError(t2);\r
- }\r
- }\r
-\r
- @Override\r
- public void finished(ReadGraphImpl graph) {\r
- try {\r
- procedure.finished(graph);\r
-// impl.state.barrier.dec(this);\r
- } catch (Throwable t2) {\r
- Logger.defaultLogError(t2);\r
- }\r
- }\r
-\r
- @Override\r
- public void exception(ReadGraphImpl graph, Throwable t) {\r
- try {\r
- procedure.exception(graph, t);\r
- } catch (Throwable t2) {\r
- Logger.defaultLogError(t2);\r
- }\r
-// impl.state.barrier.dec("ReadGraphSupportImpl.516");\r
- }\r
-\r
- @Override\r
- public String toString() {\r
- return "forEachObject with " + procedure;\r
- }\r
- \r
+package org.simantics.db.impl.graph;
+
+import org.simantics.db.Resource;
+import org.simantics.db.common.utils.Logger;
+import org.simantics.db.impl.query.IntProcedure;
+import org.simantics.db.impl.query.QuerySupport;
+import org.simantics.db.procedure.AsyncMultiProcedure;
+
+public class MultiIntProcedure implements IntProcedure {
+
+ final private AsyncMultiProcedure<Resource> procedure;
+ final private ReadGraphImpl impl;
+ final private QuerySupport support;
+
+ public MultiIntProcedure(AsyncMultiProcedure<Resource> procedure, ReadGraphImpl impl, QuerySupport support) {
+ this.procedure = procedure;
+ this.impl = impl;
+ this.support = support;
+ }
+
+ @Override
+ public void execute(ReadGraphImpl graph, int i) {
+ try {
+ procedure.execute(graph, support.getResource(i));
+ } catch (Throwable t2) {
+ Logger.defaultLogError(t2);
+ }
+ }
+
+ @Override
+ public void finished(ReadGraphImpl graph) {
+ try {
+ procedure.finished(graph);
+// impl.state.barrier.dec(this);
+ } catch (Throwable t2) {
+ Logger.defaultLogError(t2);
+ }
+ }
+
+ @Override
+ public void exception(ReadGraphImpl graph, Throwable t) {
+ try {
+ procedure.exception(graph, t);
+ } catch (Throwable t2) {
+ Logger.defaultLogError(t2);
+ }
+// impl.state.barrier.dec("ReadGraphSupportImpl.516");
+ }
+
+ @Override
+ public String toString() {
+ return "forEachObject with " + procedure;
+ }
+
}
\ No newline at end of file