EventDrivenUpdateGraph. (#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>

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() {}
 }

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;
+ }
+ }
 }