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

Class TimelessCommunicationTracker

java.lang.Object

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

tools.refinery.interpreter.rete.network.communication.timeless.TimelessCommunicationTracker

public class TimelessCommunicationTracker
extends CommunicationTracker

Timeless implementation of the communication tracker.

Since:

2.2

Field Summary

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

dependencyGraph, groupMap, groupQueue, maxGroupId, minGroupId

Constructor Summary

Constructors

Constructor	Description
TimelessCommunicationTracker(org.apache.log4j.Logger logger)

Method Summary

Modifier and Type	Method	Description
protected CommunicationGroup	createGroup(Node representative, int index)
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

Constructor Details

TimelessCommunicationTracker

public TimelessCommunicationTracker(org.apache.log4j.Logger logger)

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

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