make MapStatsContainer thread-safe and fix tests

Author: mtf90

api/src/main/java/de/learnlib/sul/TimedSUL.java

@@ -1,9 +1,9 @@
 package de.learnlib.sul;
 
-import net.automatalib.symbol.time.TimedOutput;
-import net.automatalib.symbol.time.TimedInput;
 import net.automatalib.symbol.time.InputSymbol;
 import net.automatalib.symbol.time.TimeStepSequence;
+import net.automatalib.symbol.time.TimedInput;
+import net.automatalib.symbol.time.TimedOutput;
 import net.automatalib.symbol.time.TimeoutSymbol;
 import net.automatalib.word.Word;
 import net.automatalib.word.WordBuilder;
@@ -101,4 +101,8 @@ default Word<TimedOutput<O>> collectTimeouts(TimeStepSequence<I> input) {
         return wbOutput.toWord();
     }
 
+    @Override
+    default TimedSUL<I, O> fork() {
+        throw new UnsupportedOperationException();
+    }
 }

examples/src/main/java/de/learnlib/example/mmlt/Example1.java

@@ -126,7 +126,7 @@ private static void runExperiment(ExtensibleLStarMMLT<String, String> learner,
         stats.setCounter("result_locs", "Locations in result", finalHypothesis.getStates().size());
 
         // Print final result + statistics:
-        stats.printStats();
+        System.out.println(stats.printStats());
 
         new ObservationTableASCIIWriter<>().write(learner.getObservationTable(), System.out);
 

filters/cache/src/test/java/de/learnlib/filter/cache/AbstractParallelCacheTest.java

@@ -22,6 +22,7 @@
 import de.learnlib.oracle.EquivalenceOracle;
 import de.learnlib.oracle.ParallelOracle;
 import de.learnlib.query.DefaultQuery;
+import de.learnlib.statistic.Statistics;
 import net.automatalib.alphabet.Alphabet;
 import net.automatalib.common.util.collection.IterableUtil;
 import net.automatalib.word.Word;
@@ -64,14 +65,15 @@ public void setUp() {
         this.targetModel = getTargetModel();
         this.cache = getCacheRepresentative();
         this.parallelOracle = getParallelOracle();
+        Statistics.getContainer().clear();
     }
 
     @AfterClass
     public void teardown() {
         this.parallelOracle.shutdownNow();
     }
 
-    @Test(timeOut = 20000)
+    @Test
     public void testConcurrentMembershipQueries() {
         Assert.assertEquals(getNumberOfQueries(), 0);
 
@@ -103,7 +105,7 @@ public void testConcurrentMembershipQueries() {
         Assert.assertEquals(numOfQueriesAfter, numOfQueriesBefore);
     }
 
-    @Test(dependsOnMethods = "testConcurrentMembershipQueries", timeOut = 20000)
+    @Test(dependsOnMethods = "testConcurrentMembershipQueries")
     public void testConcurrentEquivalenceQueries() {
         final long previousCount = getNumberOfQueries();
         final EquivalenceOracle<? super A, I, D> eqOracle = cache.createCacheConsistencyTest();

filters/cache/src/test/java/de/learnlib/filter/cache/dfa/AbstractDFACacheTest.java

@@ -58,7 +58,7 @@ protected DFACacheOracle<Character> getResumedOracle(DFACacheOracle<Character> o
 
     @Override
     protected long getNumberOfPosedQueries() {
-        return Statistics.getContainer().getCount(DFACounterOracle.SYMBOL_KEY).orElse(0L);
+        return Statistics.getContainer().getCount(DFACounterOracle.QUERY_KEY).orElse(0L);
     }
 
     @Override

filters/cache/src/test/java/de/learnlib/filter/cache/dfa/DFAHashCacheTest.java

@@ -56,7 +56,7 @@ protected DFAHashCacheOracle<Character> getResumedOracle(DFAHashCacheOracle<Char
 
     @Override
     protected long getNumberOfPosedQueries() {
-        return Statistics.getContainer().getCount(DFACounterOracle.SYMBOL_KEY).orElse(0L);
+        return Statistics.getContainer().getCount(DFACounterOracle.QUERY_KEY).orElse(0L);
     }
 
     @Override

filters/cache/src/test/java/de/learnlib/filter/cache/dfa/DFAParallelCacheTest.java

@@ -75,6 +75,6 @@ protected ParallelOracle<Character, Boolean> getParallelOracle() {
 
     @Override
     protected long getNumberOfQueries() {
-        return Statistics.getContainer().getCount(DFACounterOracle.SYMBOL_KEY).orElse(0L);
+        return Statistics.getContainer().getCount(DFACounterOracle.QUERY_KEY).orElse(0L);
     }
 }

filters/statistics/pom.xml

@@ -52,6 +52,10 @@ limitations under the License.
             <groupId>de.learnlib.tooling</groupId>
             <artifactId>annotations</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.kohsuke.metainf-services</groupId>
+            <artifactId>metainf-services</artifactId>
+        </dependency>
 
         <!-- test -->
         <dependency>

filters/statistics/src/main/java/de/learnlib/filter/statistic/container/MapStatsContainer.java

@@ -14,12 +14,12 @@ public class MapStatsContainer implements StatsContainer {
     private final Map<String, LearnerStatistic> statistics = new HashMap<>(); // id -> stat
 
     @Override
-    public void addTextInfo(String id, @Nullable String description, String text) {
+    public synchronized void addTextInfo(String id, @Nullable String description, String text) {
         statistics.put(id, new TextStatistic(id, description, text));
     }
 
     @Override
-    public Optional<String> getTextValue(String id) {
+    public synchronized Optional<String> getTextValue(String id) {
         var value = statistics.get(id);
         if (value instanceof TextStatistic textStatistic) {
             return Optional.of(textStatistic.getText());
@@ -28,12 +28,12 @@ public Optional<String> getTextValue(String id) {
     }
 
     @Override
-    public void setFlag(String id, @Nullable String description, boolean value) {
+    public synchronized void setFlag(String id, @Nullable String description, boolean value) {
         statistics.put(id, new FlagStatistic(id, description, value));
     }
 
     @Override
-    public Optional<Boolean> getFlagValue(String id) {
+    public synchronized Optional<Boolean> getFlagValue(String id) {
         var value = statistics.get(id);
         if (value instanceof FlagStatistic flagStatistic) {
             return Optional.of(flagStatistic.isFlagged());
@@ -42,7 +42,7 @@ public Optional<Boolean> getFlagValue(String id) {
     }
 
     @Override
-    public void startOrResumeClock(String id, @Nullable String description) {
+    public synchronized void startOrResumeClock(String id, @Nullable String description) {
         var value = statistics.get(id);
         if (value instanceof StopClockStatistic clockStatistic) {
             clockStatistic.resume();
@@ -55,15 +55,15 @@ public void startOrResumeClock(String id, @Nullable String description) {
     }
 
     @Override
-    public void pauseClock(String id) {
+    public synchronized void pauseClock(String id) {
         var value = statistics.get(id);
         if (value instanceof StopClockStatistic clockStatistic) {
             clockStatistic.pause();
         }
     }
 
     @Override
-    public Optional<Duration> getClockValue(String id) {
+    public synchronized Optional<Duration> getClockValue(String id) {
         var value = statistics.get(id);
         if (value instanceof StopClockStatistic clockStatistic) {
             return Optional.of(clockStatistic.getElapsed());
@@ -72,7 +72,7 @@ public Optional<Duration> getClockValue(String id) {
     }
 
     @Override
-    public void increaseCounter(String id, @Nullable String description, long increment) {
+    public synchronized void increaseCounter(String id, @Nullable String description, long increment) {
         var value = statistics.get(id);
         if (value instanceof CounterStatistic counterStatistic) {
             counterStatistic.increase(increment);
@@ -83,12 +83,12 @@ public void increaseCounter(String id, @Nullable String description, long increm
     }
 
     @Override
-    public void setCounter(String id, @Nullable String description, long count) {
+    public synchronized void setCounter(String id, @Nullable String description, long count) {
         statistics.put(id, new CounterStatistic(id, description, count));
     }
 
     @Override
-    public Optional<Long> getCount(String id) {
+    public synchronized Optional<Long> getCount(String id) {
         var value = statistics.get(id);
         if (value instanceof CounterStatistic counterStatistic) {
             return Optional.of(counterStatistic.getCount());
@@ -97,7 +97,7 @@ public Optional<Long> getCount(String id) {
     }
 
     @Override
-    public void clear() {
+    public synchronized void clear() {
         statistics.clear();
     }
 

filters/statistics/src/main/java/de/learnlib/filter/statistic/container/MapStatsProvider.java

@@ -2,7 +2,9 @@
 
 import de.learnlib.statistic.StatisticsProvider;
 import de.learnlib.statistic.StatsContainer;
+import org.kohsuke.MetaInfServices;
 
+@MetaInfServices(StatisticsProvider.class)
 public class MapStatsProvider implements StatisticsProvider {
 
     final ThreadLocal<StatsContainer> threadLocal = ThreadLocal.withInitial(MapStatsContainer::new);

filters/statistics/src/main/java/de/learnlib/filter/statistic/sul/CounterObservableSUL.java

@@ -15,6 +15,8 @@
  */
 package de.learnlib.filter.statistic.sul;
 
+import de.learnlib.statistic.Statistics;
+import de.learnlib.statistic.StatsContainer;
 import de.learnlib.sul.ObservableSUL;
 
 public class CounterObservableSUL<S, I, O> extends CounterSUL<I, O> implements ObservableSUL<S, I, O> {
@@ -25,14 +27,18 @@ public CounterObservableSUL(ObservableSUL<S, I, O> sul) {
         this(sul, "");
     }
 
-    private CounterObservableSUL(ObservableSUL<S, I, O> sul, String prefix) {
-        super(sul, prefix);
+    public CounterObservableSUL(ObservableSUL<S, I, O> sul, String prefix) {
+        this(sul, prefix, Statistics.getContainer());
+    }
+
+    protected CounterObservableSUL(ObservableSUL<S, I, O> sul, String prefix, StatsContainer statistics) {
+        super(sul, prefix, statistics);
         this.sul = sul;
     }
 
     @Override
     public ObservableSUL<S, I, O> fork() {
-        return new CounterObservableSUL<>(this.sul.fork(), super.prefix);
+        return new CounterObservableSUL<>(this.sul.fork(), super.prefix, super.statistics);
     }
 
     @Override