diff options
Diffstat (limited to 'store/src/main/java/org/eclipse/viatra/solver/data/query/RelationalScope.java')
-rw-r--r-- | store/src/main/java/org/eclipse/viatra/solver/data/query/RelationalScope.java | 34 |
1 files changed, 34 insertions, 0 deletions
diff --git a/store/src/main/java/org/eclipse/viatra/solver/data/query/RelationalScope.java b/store/src/main/java/org/eclipse/viatra/solver/data/query/RelationalScope.java new file mode 100644 index 00000000..97b33935 --- /dev/null +++ b/store/src/main/java/org/eclipse/viatra/solver/data/query/RelationalScope.java | |||
@@ -0,0 +1,34 @@ | |||
1 | package org.eclipse.viatra.solver.data.query; | ||
2 | |||
3 | import java.util.Set; | ||
4 | |||
5 | import org.apache.log4j.Logger; | ||
6 | import org.eclipse.viatra.query.runtime.api.ViatraQueryEngine; | ||
7 | import org.eclipse.viatra.query.runtime.api.scope.IEngineContext; | ||
8 | import org.eclipse.viatra.query.runtime.api.scope.IIndexingErrorListener; | ||
9 | import org.eclipse.viatra.query.runtime.api.scope.QueryScope; | ||
10 | import org.eclipse.viatra.solver.data.model.Model; | ||
11 | import org.eclipse.viatra.solver.data.model.Tuple; | ||
12 | import org.eclipse.viatra.solver.data.query.internal.RelationUpdateListener; | ||
13 | import org.eclipse.viatra.solver.data.query.internal.RelationalEngineContext; | ||
14 | import org.eclipse.viatra.solver.data.query.view.RelationView; | ||
15 | |||
16 | public class RelationalScope extends QueryScope{ | ||
17 | private final Model model; | ||
18 | private final RelationUpdateListener updateListener; | ||
19 | |||
20 | public RelationalScope(Model model, Set<RelationView<?>> relationViews) { | ||
21 | this.model = model; | ||
22 | updateListener = new RelationUpdateListener(relationViews); | ||
23 | } | ||
24 | |||
25 | public <D> void processUpdate(RelationView<D> relationView, Tuple key, D oldValue, D newValue) { | ||
26 | updateListener.processChange(relationView, key, oldValue, newValue); | ||
27 | } | ||
28 | |||
29 | @Override | ||
30 | protected IEngineContext createEngineContext(ViatraQueryEngine engine, IIndexingErrorListener errorListener, | ||
31 | Logger logger) { | ||
32 | return new RelationalEngineContext(model, updateListener); | ||
33 | } | ||
34 | } | ||