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

Class PosetAwareMailbox

java.lang.Object

tools.refinery.interpreter.rete.network.mailbox.timeless.AbstractUpdateSplittingMailbox<GroupBasedMessageIndexer,PosetAwareReceiver>

tools.refinery.interpreter.rete.network.mailbox.timeless.PosetAwareMailbox

All Implemented Interfaces:

Clearable, IGroupable, Mailbox

public class PosetAwareMailbox
extends AbstractUpdateSplittingMailbox<GroupBasedMessageIndexer,PosetAwareReceiver>

A monotonicity aware mailbox implementation. The mailbox uses an IPosetComparator to identify if a pair of REVOKE - INSERT updates represent a monotone change pair. The mailbox is used by PosetAwareReceivers.

Since:

2.0

Field Summary

Fields

Modifier and Type	Field	Description
protected final TupleMask	groupMask

Fields inherited from class tools.refinery.interpreter.rete.network.mailbox.timeless.AbstractUpdateSplittingMailbox

antiMonotoneBuffer, antiMonotoneQueue, container, deliveringAntiMonotone, deliveringMonotone, group, monotoneBuffer, monotoneQueue, receiver

Constructor Summary

Constructors

Constructor	Description
PosetAwareMailbox(PosetAwareReceiver receiver, ReteContainer container)

Method Summary

Modifier and Type	Method	Description
void	deliverAll(MessageSelector kind)	Delivers all messages according to the given selector from this mailbox.
void	postMessage(Direction direction, Tuple update, Timestamp timestamp)	Posts a new message to this mailbox.
String	toString()
protected Set<Tuple>	tryFindCounterPart(Tuple first, boolean findPositiveCounterPart, boolean findAllCounterParts)

Methods inherited from class tools.refinery.interpreter.rete.network.mailbox.timeless.AbstractUpdateSplittingMailbox

clear, getActiveAntiMonotoneQueue, getActiveMonotoneQueue, getCurrentGroup, getReceiver, isEmpty, setCurrentGroup, swapAndClearAntiMonotone, swapAndClearMonotone

Methods inherited from class java.lang.Object

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

Field Details

groupMask

protected final TupleMask groupMask

Constructor Details

PosetAwareMailbox

public PosetAwareMailbox(PosetAwareReceiver receiver,
 ReteContainer container)

Method Details

postMessage

public void postMessage(Direction direction,
 Tuple update,
 Timestamp timestamp)

Description copied from interface: Mailbox

Posts a new message to this mailbox.

Parameters:

direction - the direction of the update

update - the update element

tryFindCounterPart

protected Set<Tuple> tryFindCounterPart(Tuple first,
 boolean findPositiveCounterPart,
 boolean findAllCounterParts)

deliverAll

public void deliverAll(MessageSelector kind)

Description copied from interface: Mailbox

Delivers all messages according to the given selector from this mailbox. The selector can also be null. In this case, no special separation is expected between the messages.

Parameters:

kind - the message selector

toString

public String toString()

Overrides:

toString in class Object