X-Git-Url: https://gerrit.simantics.org/r/gitweb?p=simantics%2Fplatform.git;a=blobdiff_plain;f=bundles%2Forg.simantics.db.impl%2Fsrc%2Forg%2Fsimantics%2Fdb%2Fimpl%2Fgraph%2FMultiIntProcedure.java;h=4695b8b338c02b7a87e85c8985f83a20e54c301a;hp=45b40a92b2d465b81f06952ebe67cde4a27dbfad;hb=0ae2b770234dfc3cbb18bd38f324125cf0faca07;hpb=24e2b34260f219f0d1644ca7a138894980e25b14 diff --git a/bundles/org.simantics.db.impl/src/org/simantics/db/impl/graph/MultiIntProcedure.java b/bundles/org.simantics.db.impl/src/org/simantics/db/impl/graph/MultiIntProcedure.java index 45b40a92b..4695b8b33 100644 --- a/bundles/org.simantics.db.impl/src/org/simantics/db/impl/graph/MultiIntProcedure.java +++ b/bundles/org.simantics.db.impl/src/org/simantics/db/impl/graph/MultiIntProcedure.java @@ -1,55 +1,55 @@ -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 procedure; - final private ReadGraphImpl impl; - final private QuerySupport support; - - public MultiIntProcedure(AsyncMultiProcedure 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; - } - +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 procedure; + final private ReadGraphImpl impl; + final private QuerySupport support; + + public MultiIntProcedure(AsyncMultiProcedure 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