EventDrivenUpdateGraph. (deephaven#4613)

* EventDrivenUpdateGraph. * bad import * Comment on PoisonedNotificationProcessor. * running into state problems. * rename stuff * move graph name collision check into base. * test, but in an impossible place * Use EDUG for default. * flush reset * also clear on end * some comments * spotless * self-review. * rset UPT. * live code review comments to address. * cleanup * spotless * javadoc * Cleanup of unused variables, move budget calculation. * Fix existingOrBuild. * speling. * Apply suggestions from code review Co-authored-by: Ryan Caudy <rcaudy@gmail.com> --------- Co-authored-by: Ryan Caudy <rcaudy@gmail.com>
rcaudy · Dec 5, 2023 · 374188a · 374188a
1 parent 771e735
commit 374188a
Show file tree

Hide file tree

Showing 10 changed files with 1,623 additions and 966 deletions.
diff --git a/engine/context/src/main/java/io/deephaven/engine/context/PoisonedUpdateGraph.java b/engine/context/src/main/java/io/deephaven/engine/context/PoisonedUpdateGraph.java
@@ -118,4 +118,7 @@ public boolean supportsRefreshing() {
     public void requestRefresh() {
         fail();
     }
+
+    @Override
+    public void stop() {}
 }
diff --git a/engine/table/src/main/java/io/deephaven/engine/table/impl/perf/UpdatePerformanceTracker.java b/engine/table/src/main/java/io/deephaven/engine/table/impl/perf/UpdatePerformanceTracker.java
@@ -17,13 +17,14 @@
 import io.deephaven.engine.tablelogger.EngineTableLoggers;
 import io.deephaven.engine.tablelogger.UpdatePerformanceLogLogger;
 import io.deephaven.engine.updategraph.UpdateGraph;
-import io.deephaven.engine.updategraph.impl.PeriodicUpdateGraph;
+import io.deephaven.engine.updategraph.impl.BaseUpdateGraph;
 import io.deephaven.engine.util.string.StringUtils;
 import io.deephaven.internal.log.LoggerFactory;
 import io.deephaven.io.logger.Logger;
 import io.deephaven.stream.StreamToBlinkTableAdapter;
 import io.deephaven.util.QueryConstants;
 import io.deephaven.util.SafeCloseable;
+import io.deephaven.util.annotations.TestUseOnly;
 import org.apache.commons.lang3.mutable.MutableObject;
 import org.jetbrains.annotations.NotNull;
 
@@ -37,7 +38,7 @@
 
 /**
  * <p>
- * This tool is meant to track periodic update events that take place in an {@link PeriodicUpdateGraph}. This generally
+ * This tool is meant to track periodic update events that take place in an {@link UpdateGraph}. This generally
  * includes:
  * <ol>
  * <li>Update source {@code run()} invocations</li>
@@ -88,8 +89,8 @@ private static class InternalState {
 
         private InternalState() {
             final UpdateGraph publishingGraph =
-                    PeriodicUpdateGraph.getInstance(PeriodicUpdateGraph.DEFAULT_UPDATE_GRAPH_NAME);
-            Assert.neqNull(publishingGraph, "The " + PeriodicUpdateGraph.DEFAULT_UPDATE_GRAPH_NAME + " UpdateGraph "
+                    BaseUpdateGraph.getInstance(BaseUpdateGraph.DEFAULT_UPDATE_GRAPH_NAME);
+            Assert.neqNull(publishingGraph, "The " + BaseUpdateGraph.DEFAULT_UPDATE_GRAPH_NAME + " UpdateGraph "
                     + "must be created before UpdatePerformanceTracker can be initialized.");
             try (final SafeCloseable ignored = ExecutionContext.getContext().withUpdateGraph(publishingGraph).open()) {
                 tableLogger = EngineTableLoggers.get().updatePerformanceLogLogger();
@@ -286,4 +287,11 @@ public long getIntervalEndTimeEpochNanos() {
     public static QueryTable getQueryTable() {
         return (QueryTable) BlinkTableTools.blinkToAppendOnly(getInternalState().blink);
     }
+
+    @TestUseOnly
+    public static void resetForUnitTests() {
+        synchronized (UpdatePerformanceTracker.class) {
+            INSTANCE = null;
+        }
+    }
 }