import org.simantics.db.Session;
import org.simantics.db.VirtualGraph;
import org.simantics.db.WriteGraph;
-import org.simantics.db.common.CommentMetadata;
import org.simantics.db.common.request.WriteRequest;
+import org.simantics.db.common.request.WriteResultRequest;
import org.simantics.db.common.utils.NameUtils;
import org.simantics.db.exception.DatabaseException;
import org.simantics.db.service.VirtualGraphSupport;
import org.simantics.simulation.experiment.IExperiment;
import org.simantics.simulation.experiment.IExperimentListener;
import org.simantics.simulation.ontology.SimulationResource;
-import org.simantics.utils.datastructures.Callback;
import org.simantics.utils.ui.ErrorLogger;
/**
*/
public static void createRun(final Session session, VirtualGraph vg, final Resource experimentResource,
final IExperiment experiment, final String experimentRunTypeURI,
- final IExperimentActivationListener listener, final Function2<WriteGraph, Resource, Object> external, final Consumer<Resource> successCallback)
+ final IExperimentActivationListener listener,
+ final Function2<WriteGraph, Resource, Object> externalWrite,
+ final Consumer<Resource> successCallback)
+ {
+ createRun(session, vg,
+ experimentResource, experiment, experimentRunTypeURI,
+ listener, externalWrite, successCallback, true);
+ }
+
+ /**
+ * Create new experiment run in a selected virtual graph.
+ *
+ * @param session
+ * @param vg
+ * @param experimentResource
+ * @param experiment
+ * @param experimentRunTypeURI
+ * @param listener
+ * @param successCallback if non-null invoked with the created run resource
+ * as an argument, just before invoking
+ * listener.onExperimentActivated(experiment)
+ * @param attachDeactivationListener <code>true</code> to run for the created run-resource
+ * {@link #attachStateListener(Session, IExperiment, Resource)}
+ */
+ public static void createRun(
+ Session session,
+ VirtualGraph vg,
+ Resource experimentResource,
+ IExperiment experiment,
+ String experimentRunTypeURI,
+ IExperimentActivationListener listener,
+ Function2<WriteGraph, Resource, Object> externalWrite,
+ Consumer<Resource> successCallback,
+ boolean attachDeactivationListener)
{
- final AtomicReference<Resource> _run = new AtomicReference<Resource>();
+ final AtomicReference<Resource> run = new AtomicReference<>();
session.asyncRequest(new WriteRequest(vg) {
@Override
public void perform(WriteGraph graph) throws DatabaseException {
// System.out.println("ExperimentActivator " + experimentResource + " " + experiment.getIdentifier());
+ run.set( createRun(graph, experimentResource, experiment, experimentRunTypeURI, externalWrite) );
+ }
+ }, e -> {
+ if (e != null) {
+ if (listener != null)
+ listener.onFailure(e);
+ else
+ ErrorLogger.defaultLogError(e);
+ } else {
+ if (attachDeactivationListener)
+ attachStateListener(session, experiment, run.get());
+ if (successCallback != null)
+ successCallback.accept(run.get());
+ if (listener != null)
+ listener.onExperimentActivated(experiment);
+ }
+ });
+ }
- final Layer0 L0 = Layer0.getInstance(graph);
- final SimulationResource SIMU = SimulationResource.getInstance(graph);
-
- final Resource run = graph.newResource();
- String label = NameUtils.findFreshLabel(graph, "Experiment", experimentResource);
- graph.claim(run, L0.InstanceOf, null, graph.getResource(experimentRunTypeURI));
- graph.addLiteral(run, L0.HasName, L0.NameOf, L0.String, experiment.getIdentifier(), Bindings.STRING);
- graph.addLiteral(run, L0.HasLabel, L0.HasLabel_Inverse, L0.String, label, Bindings.STRING);
- graph.addLiteral(run, SIMU.HasActivationTime, SIMU.HasActivationTime_Inverse, L0.Long, System.currentTimeMillis(), Bindings.LONG);
- graph.claim(experimentResource, L0.ConsistsOf, L0.PartOf, run);
-
- // Mark the run active in the transient virtual graph.
- VirtualGraph runtime = graph.getService(VirtualGraph.class);
- graph.syncRequest(new WriteRequest(runtime) {
- @Override
- public void perform(WriteGraph graph) throws DatabaseException {
- graph.claim(run, SIMU.IsActive, run);
- if(external != null)
- external.apply(graph, run);
- }
- });
-
- _run.set(run);
+ /**
+ * Create new experiment run in a selected virtual graph.
+ *
+ * @param session
+ * @param vg
+ * @param experimentResource
+ * @param experiment
+ * @param experimentRunTypeURI
+ * @param listener
+ * @param successCallback if non-null invoked with the created run resource
+ * as an argument, just before invoking
+ * listener.onExperimentActivated(experiment)
+ */
+ public static Resource createRun(WriteGraph graph,
+ VirtualGraph vg,
+ Resource experimentResource,
+ IExperiment experiment,
+ String experimentRunTypeURI,
+ Function2<WriteGraph, Resource, Object> externalWrite)
+ throws DatabaseException
+ {
+ return graph.syncRequest(new WriteResultRequest<Resource>(vg) {
+ @Override
+ public Resource perform(WriteGraph graph) throws DatabaseException {
+ return createRun(graph, experimentResource, experiment, experimentRunTypeURI, externalWrite);
}
- }, new Callback<DatabaseException>() {
+ });
+ }
+
+ public static Resource createRun(WriteGraph graph,
+ Resource experimentResource,
+ IExperiment experiment,
+ String experimentRunTypeURI,
+ Function2<WriteGraph, Resource, Object> externalWrite)
+ throws DatabaseException
+ {
+ Layer0 L0 = Layer0.getInstance(graph);
+ SimulationResource SIMU = SimulationResource.getInstance(graph);
+
+ Resource run = graph.newResource();
+ String label = NameUtils.findFreshLabel(graph, "Experiment", experimentResource);
+ graph.claim(run, L0.InstanceOf, null, graph.getResource(experimentRunTypeURI));
+ graph.addLiteral(run, L0.HasName, L0.NameOf, L0.String, experiment.getIdentifier(), Bindings.STRING);
+ graph.addLiteral(run, L0.HasLabel, L0.HasLabel_Inverse, L0.String, label, Bindings.STRING);
+ graph.addLiteral(run, SIMU.HasActivationTime, SIMU.HasActivationTime_Inverse, L0.Long, System.currentTimeMillis(), Bindings.LONG);
+ graph.claim(experimentResource, L0.ConsistsOf, L0.PartOf, run);
+
+ markRunActive(graph, run, externalWrite);
+
+ return run;
+ }
+
+ /**
+ * Mark the run active in the transient virtual graph.
+ *
+ * @param graph
+ * @param run
+ * @param externalWrite
+ * @throws DatabaseException
+ */
+ private static void markRunActive(
+ WriteGraph graph,
+ Resource run,
+ Function2<WriteGraph, Resource, Object> externalWrite)
+ throws DatabaseException
+ {
+ SimulationResource SIMU = SimulationResource.getInstance(graph);
+ VirtualGraph runtime = graph.getService(VirtualGraph.class);
+ graph.syncRequest(new WriteRequest(runtime) {
@Override
- public void run(DatabaseException e) {
- if (e != null) {
- if (listener != null)
- listener.onFailure(e);
- else
- ErrorLogger.defaultLogError(e);
- } else {
- attachStateListener(session, experiment, _run.get());
- if (successCallback != null)
- successCallback.accept(_run.get());
- if (listener != null)
- listener.onExperimentActivated(experiment);
- }
+ public void perform(WriteGraph graph) throws DatabaseException {
+ graph.claim(run, SIMU.IsActive, run);
+ if(externalWrite != null)
+ externalWrite.apply(graph, run);
}
});
}
public void perform(WriteGraph graph) throws DatabaseException {
SimulationResource SIMU = SimulationResource.getInstance(graph);
graph.denyStatement(run, SIMU.IsActive, run);
-
- CommentMetadata cm = graph.getMetadata(CommentMetadata.class);
- graph.addMetadata(cm.add("Attaching state listener to track isActive for run"));
- }
- }, new Callback<DatabaseException>() {
- @Override
- public void run(DatabaseException e) {
- if (e != null)
- ErrorLogger.defaultLogError(e);
}
+ }, e -> {
+ if (e != null)
+ ErrorLogger.defaultLogError(e);
});
}
}
Code Review / simantics / platform.git / blobdiff