Package tools.refinery.interpreter.rete.network.communication.timely

Class TimelyCommunicationTracker

java.lang.Object

tools.refinery.interpreter.rete.network.communication.CommunicationTracker

tools.refinery.interpreter.rete.network.communication.timely.TimelyCommunicationTracker

public class TimelyCommunicationTracker
extends CommunicationTracker

Timely (DDF) implementation of the CommunicationTracker.

Since:

2.3

Field Summary

Fields

Modifier and Type	Field	Description
protected final TimelyConfiguration	configuration
static final Function<Node,Function<Node,String>>	EDGE_LABEL_FUNCTION	This static field is used for debug purposes in the DotGenerator.

Fields inherited from class tools.refinery.interpreter.rete.network.communication.CommunicationTracker

dependencyGraph, groupMap, groupQueue, maxGroupId, minGroupId

Constructor Summary

Constructors

Constructor	Description
TimelyCommunicationTracker(org.apache.log4j.Logger logger, TimelyConfiguration configuration)

Method Summary

Modifier and Type	Method	Description
protected CommunicationGroup	createGroup(Node representative, int index)
protected TimestampTransformation	getPreprocessor(Node source, Node target)
protected void	postProcessGroup(CommunicationGroup group)	This hook allows concrete tracker implementations to perform tracker-specific post processing on groups.
protected void	postProcessNode(Node node)	This hook allows concrete tracker implementations to perform tracker-specific post processing on nodes (cf.
IndexerListener	proxifyIndexerListener(Node requester, IndexerListener original)	Creates a proxy for the given IndexerListener for the given requester Node.
Mailbox	proxifyMailbox(Node requester, Mailbox original)	Creates a proxy for the given Mailbox for the given requester Node.
protected void	reconstructQueueContents(Set<CommunicationGroup> oldActiveGroups)	This method is responsible for reconstructing the active queue contents after the network structure has changed.

Methods inherited from class tools.refinery.interpreter.rete.network.communication.CommunicationTracker

activateUnenqueued, areInSameGroup, createAndStoreGroup, deactivate, getAndRemoveFirstGroup, getDependencyGraph, getGroup, getPartition, getReducedGraph, getRepresentative, hasOutgoingEdges, isEmpty, isInRecursiveGroup, isRecursionCutPoint, isSingleton, registerDependency, unregisterDependency

Methods inherited from class java.lang.Object

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

Field Details

configuration

protected final TimelyConfiguration configuration

EDGE_LABEL_FUNCTION

public static final Function<Node,Function<Node,String>> EDGE_LABEL_FUNCTION

This static field is used for debug purposes in the DotGenerator.

Constructor Details

TimelyCommunicationTracker

public TimelyCommunicationTracker(org.apache.log4j.Logger logger,
 TimelyConfiguration configuration)

Method Details

createGroup

protected CommunicationGroup createGroup(Node representative,
 int index)

Specified by:

createGroup in class CommunicationTracker

reconstructQueueContents

protected void reconstructQueueContents(Set<CommunicationGroup> oldActiveGroups)

Description copied from class: CommunicationTracker

This method is responsible for reconstructing the active queue contents after the network structure has changed. It it defined as abstract because the reconstruction logic is specific to each CommunicationTracker.

Specified by:

reconstructQueueContents in class CommunicationTracker

proxifyMailbox

public Mailbox proxifyMailbox(Node requester,
 Mailbox original)

Description copied from class: CommunicationTracker

Creates a proxy for the given Mailbox for the given requester Node. The proxy creation is CommunicationTracker-specific and depends on the identity of the requester. This method is primarily used to create TimelyMailboxProxys depending on the network topology. There is no guarantee that the same proxy instance is returned when this method is called multiple times with the same arguments.

Specified by:

proxifyMailbox in class CommunicationTracker

proxifyIndexerListener

public IndexerListener proxifyIndexerListener(Node requester,
 IndexerListener original)

Description copied from class: CommunicationTracker

Creates a proxy for the given IndexerListener for the given requester Node. The proxy creation is CommunicationTracker-specific and depends on the identity of the requester. This method is primarily used to create TimelyIndexerListenerProxys depending on the network topology. There is no guarantee that the same proxy instance is returned when this method is called multiple times with the same arguments.

Specified by:

proxifyIndexerListener in class CommunicationTracker

getPreprocessor

protected TimestampTransformation getPreprocessor(Node source,
 Node target)

postProcessNode

protected void postProcessNode(Node node)

Description copied from class: CommunicationTracker

This hook allows concrete tracker implementations to perform tracker-specific post processing on nodes (cf. NetworkStructureChangeSensitiveNode and BehaviorChangingMailbox). At the time of the invocation, the network topology has already been updated.

Specified by:

postProcessNode in class CommunicationTracker

postProcessGroup

protected void postProcessGroup(CommunicationGroup group)

Description copied from class: CommunicationTracker

This hook allows concrete tracker implementations to perform tracker-specific post processing on groups. At the time of the invocation, the network topology has already been updated.

Specified by:

postProcessGroup in class CommunicationTracker