X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;f=bundles%2Forg.simantics.db.impl%2Fsrc%2Forg%2Fsimantics%2Fdb%2Fimpl%2Fgraph%2FMultiIntProcedure.java;h=0f0ad8319413c997e2f932d70ffb4d7eb925f98f;hb=HEAD;hp=45b40a92b2d465b81f06952ebe67cde4a27dbfad;hpb=969bd23cab98a79ca9101af33334000879fb60c5;p=simantics%2Fplatform.git 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..0f0ad8319 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.SyncMultiProcedure; + +public class MultiIntProcedure implements IntProcedure { + + final private SyncMultiProcedure procedure; + final private ReadGraphImpl impl; + final private QuerySupport support; + + public MultiIntProcedure(SyncMultiProcedure 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