Package io.deephaven.enterprise.test

Class CapturingUpdateGraph

java.lang.Object

io.deephaven.enterprise.test.CapturingUpdateGraph

All Implemented Interfaces:

LogOutputAppendable, NotificationQueue, NotificationQueue.Dependency, UpdateGraph, UpdateSourceRegistrar

public final class CapturingUpdateGraph
extends Object
implements UpdateGraph

Nested Class Summary

Nested classes/interfaces inherited from interface io.deephaven.engine.updategraph.NotificationQueue

NotificationQueue.Dependency, NotificationQueue.ErrorNotification, NotificationQueue.Notification

Field Summary

Fields

Modifier and Type	Field	Description
final ExecutionContext	context

Constructor Summary

Constructors

Constructor	Description
CapturingUpdateGraph(@NotNull io.deephaven.engine.testutil.ControlledUpdateGraph delegate)

Method Summary

Modifier and Type	Method	Description
void	addNotification(@NotNull NotificationQueue.Notification notification)
void	addNotifications(@NotNull Collection<? extends NotificationQueue.Notification> notifications)
void	addSource(@NotNull Runnable updateSource)
LogOutput	append(LogOutput logOutput)
LogicalClock	clock()
boolean	currentThreadProcessesUpdates()
AwareFunctionalLock	exclusiveLock()
String	getName()
UpdateGraph	getUpdateGraph()
LogEntry	logDependencies()
boolean	maybeAddNotification(@NotNull NotificationQueue.Notification notification, long deliveryStep)
int	parallelismFactor()
void	refreshSources()
void	removeSource(@NotNull Runnable updateSource)
void	requestRefresh()
<T extends Exception> void	runWithinUnitTestCycle(@NotNull ThrowingRunnable<T> runnable)
<T extends Exception> void	runWithinUnitTestCycle(@NotNull ThrowingRunnable<T> runnable, boolean satisfied)
boolean	satisfied(long step)
boolean	serialTableOperationsSafe()
boolean	setSerialTableOperationsSafe(boolean newValue)
AwareFunctionalLock	sharedLock()
void	stop()
boolean	supportsRefreshing()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.deephaven.engine.updategraph.NotificationQueue.Dependency

getUpdateGraph

Methods inherited from interface io.deephaven.engine.updategraph.UpdateGraph

allowSerialTableOperations, allowSerialTableOperations, cast, checkInitiateSerialTableOperation, requestSignal

Methods inherited from interface io.deephaven.engine.updategraph.UpdateSourceRegistrar

removeSources

Field Details

context

public final ExecutionContext context

Constructor Details

CapturingUpdateGraph

public CapturingUpdateGraph(@NotNull
 @NotNull io.deephaven.engine.testutil.ControlledUpdateGraph delegate)

Method Details

addSource

public void addSource(@NotNull
 @NotNull Runnable updateSource)

Specified by:

addSource in interface UpdateSourceRegistrar

refreshSources

public void refreshSources()

append

public LogOutput append(LogOutput logOutput)

Specified by:

append in interface LogOutputAppendable

satisfied

public boolean satisfied(long step)

Specified by:

satisfied in interface NotificationQueue.Dependency

getUpdateGraph

public UpdateGraph getUpdateGraph()

Specified by:

getUpdateGraph in interface NotificationQueue.Dependency

addNotification

public void addNotification(@NotNull
 @NotNull NotificationQueue.Notification notification)

Specified by:

addNotification in interface NotificationQueue

addNotifications

public void addNotifications(@NotNull
 @NotNull Collection<? extends NotificationQueue.Notification> notifications)

Specified by:

addNotifications in interface NotificationQueue

maybeAddNotification

public boolean maybeAddNotification(@NotNull
 @NotNull NotificationQueue.Notification notification,
 long deliveryStep)

Specified by:

maybeAddNotification in interface NotificationQueue

getName

public String getName()

Specified by:

getName in interface UpdateGraph

sharedLock

public AwareFunctionalLock sharedLock()

Specified by:

sharedLock in interface UpdateGraph

exclusiveLock

public AwareFunctionalLock exclusiveLock()

Specified by:

exclusiveLock in interface UpdateGraph

clock

public LogicalClock clock()

Specified by:

clock in interface UpdateGraph

parallelismFactor

public int parallelismFactor()

Specified by:

parallelismFactor in interface UpdateGraph

logDependencies

public LogEntry logDependencies()

Specified by:

logDependencies in interface UpdateGraph

currentThreadProcessesUpdates

public boolean currentThreadProcessesUpdates()

Specified by:

currentThreadProcessesUpdates in interface UpdateGraph

serialTableOperationsSafe

public boolean serialTableOperationsSafe()

Specified by:

serialTableOperationsSafe in interface UpdateGraph

setSerialTableOperationsSafe

public boolean setSerialTableOperationsSafe(boolean newValue)

Specified by:

setSerialTableOperationsSafe in interface UpdateGraph

supportsRefreshing

public boolean supportsRefreshing()

Specified by:

supportsRefreshing in interface UpdateGraph

requestRefresh

public void requestRefresh()

Specified by:

requestRefresh in interface UpdateGraph

Specified by:

requestRefresh in interface UpdateSourceRegistrar

removeSource

public void removeSource(@NotNull
 @NotNull Runnable updateSource)

Specified by:

removeSource in interface UpdateSourceRegistrar

runWithinUnitTestCycle

public <T extends Exception> void runWithinUnitTestCycle(@NotNull
 @NotNull ThrowingRunnable<T> runnable)
                                                  throws T

Throws:

T extends Exception

runWithinUnitTestCycle

public <T extends Exception> void runWithinUnitTestCycle(@NotNull
 @NotNull ThrowingRunnable<T> runnable,
 boolean satisfied)
                                                  throws T

Throws:

T extends Exception

stop

public void stop()

Specified by:

stop in interface UpdateGraph