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%2FForEachObjectContextProcedure.java;h=188917994a26881ccafe58a313ac6cb4559c2a67;hp=7299059b9dc1bc96c1846b509eef0637ef8ee547;hb=e19c37f84fd1ce2d946578f7c05f3e45444ba67a;hpb=969bd23cab98a79ca9101af33334000879fb60c5 diff --git a/bundles/org.simantics.db.impl/src/org/simantics/db/impl/ForEachObjectContextProcedure.java b/bundles/org.simantics.db.impl/src/org/simantics/db/impl/ForEachObjectContextProcedure.java index 7299059b9..188917994 100644 --- a/bundles/org.simantics.db.impl/src/org/simantics/db/impl/ForEachObjectContextProcedure.java +++ b/bundles/org.simantics.db.impl/src/org/simantics/db/impl/ForEachObjectContextProcedure.java @@ -1,44 +1,44 @@ -package org.simantics.db.impl; - -import org.simantics.db.AsyncReadGraph; -import org.simantics.db.RelationInfo; -import org.simantics.db.Resource; -import org.simantics.db.impl.query.QueryProcessor; -import org.simantics.db.procedure.AsyncContextMultiProcedure; - -public final class ForEachObjectContextProcedure implements AsyncContextMultiProcedure { - - public final int predicateKey; - public final int[] clusterKey; - public final int[] predicateReference; - public final RelationInfo info; - public final QueryProcessor processor; - public final ClusterI.CompleteTypeEnum completeType; - private final AsyncContextMultiProcedure user; - - public ForEachObjectContextProcedure(int predicateKey, RelationInfo info, QueryProcessor processor, AsyncContextMultiProcedure user) { - this.predicateKey = predicateKey; - this.completeType = ClusterTraitsBase.getCompleteTypeFromResourceKey(predicateKey); - this.info = info; - this.user = user; - this.processor = processor; - this.clusterKey = new int[32*8]; - this.predicateReference = new int[32*8]; - } - - @Override - public void execute(AsyncReadGraph graph, C context, Resource result) { - user.execute(graph, context, result); - } - - @Override - public void finished(AsyncReadGraph graph) { - user.finished(graph); - } - - @Override - public void exception(AsyncReadGraph graph, Throwable throwable) { - user.exception(graph, throwable); - } - -} +package org.simantics.db.impl; + +import org.simantics.db.AsyncReadGraph; +import org.simantics.db.RelationInfo; +import org.simantics.db.Resource; +import org.simantics.db.impl.query.QueryProcessor; +import org.simantics.db.procedure.AsyncContextMultiProcedure; + +public final class ForEachObjectContextProcedure implements AsyncContextMultiProcedure { + + public final int predicateKey; + public final int[] clusterKey; + public final int[] predicateReference; + public final RelationInfo info; + public final QueryProcessor processor; + public final ClusterI.CompleteTypeEnum completeType; + private final AsyncContextMultiProcedure user; + + public ForEachObjectContextProcedure(int predicateKey, RelationInfo info, QueryProcessor processor, AsyncContextMultiProcedure user) { + this.predicateKey = predicateKey; + this.completeType = ClusterTraitsBase.getCompleteTypeFromResourceKey(predicateKey); + this.info = info; + this.user = user; + this.processor = processor; + this.clusterKey = new int[32*8]; + this.predicateReference = new int[32*8]; + } + + @Override + public void execute(AsyncReadGraph graph, C context, Resource result) { + user.execute(graph, context, result); + } + + @Override + public void finished(AsyncReadGraph graph, C context) { + user.finished(graph, context); + } + + @Override + public void exception(AsyncReadGraph graph, Throwable throwable) { + user.exception(graph, throwable); + } + +}