1 package org.simantics.document.server.request;
3 import java.util.ArrayList;
4 import java.util.Collection;
5 import java.util.Collections;
6 import java.util.Comparator;
7 import java.util.HashSet;
11 import org.simantics.db.ReadGraph;
12 import org.simantics.db.common.procedure.adapter.TransientCacheAsyncListener;
13 import org.simantics.db.common.request.UnaryRead;
14 import org.simantics.db.exception.DatabaseException;
15 import org.simantics.db.layer0.request.VariableRead;
16 import org.simantics.db.layer0.variable.Variable;
17 import org.simantics.document.server.JSONObject;
19 public class DocumentRequest extends VariableRead<List<JSONObject>> {
21 public static boolean PROFILE = false;
22 // Thresholds in microseconds
23 public static int PROFILE_THRESHOLD_NODEREQUEST = 2000;
24 public static int PROFILE_THRESHOLD_VALUEREQUEST = 500;
26 public DocumentRequest(Variable var) {
30 static class CollectNodesRequest extends UnaryRead<Collection<Variable>, Collection<JSONObject>> {
32 public CollectNodesRequest(Collection<Variable> nodes) {
37 public Collection<JSONObject> perform(ReadGraph graph) throws DatabaseException {
38 HashSet<JSONObject> rs = new HashSet<>(); // result
39 for(Variable node : parameter) {
40 rs.add(graph.syncRequest(new NodeRequest(node)));
47 private static final Comparator<JSONObject> JSON_COMPARATOR = (o1, o2) -> o1.id.compareTo(o2.id);
50 public List<JSONObject> perform(ReadGraph graph) throws DatabaseException {
52 long s = System.nanoTime();
54 Set<Variable> nodes = graph.syncRequest(new NodesRequest(variable), TransientCacheAsyncListener.<Set<Variable>>instance());
56 return Collections.emptyList();
59 Collection<JSONObject> rs = graph.syncRequest(new CollectNodesRequest(nodes));
61 ArrayList<JSONObject> result = new ArrayList<>(rs);
62 Collections.sort(result, JSON_COMPARATOR);
65 long dura = System.nanoTime()-s;
66 System.err.println("DocumentRequest " + System.identityHashCode(this) + " in " + 1e-6*dura + "ms. " + variable.getURI(graph));