X-Git-Url: https://gerrit.simantics.org/r/gitweb?p=simantics%2Fplatform.git;a=blobdiff_plain;f=bundles%2Forg.simantics.db.procore%2Fsrc%2Ffi%2Fvtt%2Fsimantics%2Fprocore%2Finternal%2FInitSupportImpl.java;h=0789ac3b64e12f1612a37a0ab19aa402aa7de5c8;hp=e25e099e19d1baa8b775419e4e0d8986bd050b03;hb=4aa615b51b887cd75b558a823f0d87b3174e5f5e;hpb=969bd23cab98a79ca9101af33334000879fb60c5 diff --git a/bundles/org.simantics.db.procore/src/fi/vtt/simantics/procore/internal/InitSupportImpl.java b/bundles/org.simantics.db.procore/src/fi/vtt/simantics/procore/internal/InitSupportImpl.java index e25e099e1..0789ac3b6 100644 --- a/bundles/org.simantics.db.procore/src/fi/vtt/simantics/procore/internal/InitSupportImpl.java +++ b/bundles/org.simantics.db.procore/src/fi/vtt/simantics/procore/internal/InitSupportImpl.java @@ -1,64 +1,64 @@ -package fi.vtt.simantics.procore.internal; - -import java.util.HashSet; -import java.util.Vector; - -import org.simantics.db.WriteGraph; -import org.simantics.db.common.request.WriteRequest; -import org.simantics.db.exception.DatabaseException; -import org.simantics.db.exception.InternalException; -import org.simantics.db.exception.RuntimeDatabaseException; -import org.simantics.db.exception.TimeoutException; -import org.simantics.db.impl.ClusterBase; -import org.simantics.db.impl.ClusterSupport; -import org.simantics.db.service.ClusterUID; -import org.simantics.db.service.InitSupport; -import org.simantics.db.service.LifecycleSupport; - -public class InitSupportImpl implements InitSupport { - final private SessionImplSocket session; - - InitSupportImpl(SessionImplSocket session) { - this.session = session; - } - - @Override - public void close() throws DatabaseException, TimeoutException { - session.getService(LifecycleSupport.class).close(); - } - - @Override - public void addBuiltins(final HashSet builtins) - throws InternalException { - try { - session.syncRequest(new WriteRequest() { - @Override - public void perform(WriteGraph graph) throws DatabaseException { - ClusterSupport cs = session.getService(ClusterSupport.class); - Vector v = new Vector(); - final int N = builtins.size(); - v.setSize(N + 1); // Index starts with one, zero left as sentinel. - for (Builtin b : builtins) { - if (b.index < 1 || b.index > N) - throw new RuntimeDatabaseException("Illeagal resource index for builtin." - + " index=" + b.index + " uri=" + b.uri + " N=" + N); - v.set(b.index, b); - } - for (int i=1; i builtins) + throws InternalException { + try { + session.syncRequest(new WriteRequest() { + @Override + public void perform(WriteGraph graph) throws DatabaseException { + ClusterSupport cs = session.getService(ClusterSupport.class); + Vector v = new Vector(); + final int N = builtins.size(); + v.setSize(N + 1); // Index starts with one, zero left as sentinel. + for (Builtin b : builtins) { + if (b.index < 1 || b.index > N) + throw new RuntimeDatabaseException("Illeagal resource index for builtin." + + " index=" + b.index + " uri=" + b.uri + " N=" + N); + v.set(b.index, b); + } + for (int i=1; i