org.rvpf.processor.engine.replicator

Class ResynchronizedBehavior

Object

AbstractBehavior

PrimaryBehavior

ReplicatedBehavior

ResynchronizedBehavior

All Implemented Interfaces:

Behavior, Proxied

public final class ResynchronizedBehavior
extends ReplicatedBehavior

Resynchronized behavior.

Nested Class Summary

Nested classes/interfaces inherited from interface Proxied

Proxied.Abstract

Field Summary

Fields inherited from class PrimaryBehavior

AFTER_RESULT_SYNC_POSITION_PARAM, FILTER_STAMP_TRIM_UNIT_PARAM, FILTER_TIME_LIMIT_PARAM, POLATOR_TIME_LIMIT_PARAM, SELECT_PREVIOUS_VALUE_PARAM, SELECT_SYNC_POSITION_PARAM, SINCE_RESULT_SYNC_POSITION_PARAM, SINCE_SYNC_POSITION_PARAM

Constructor Summary

Constructors

Constructor and Description
ResynchronizedBehavior()

Method Summary

Modifier and Type	Method and Description
protected boolean	doValidate() Does validate this behavior.
boolean	prepareSelect(ResultValue resultValue, Batch batch) Allows a behavior to prepare for a call to Behavior.select(org.rvpf.base.value.ResultValue, org.rvpf.metadata.processor.Batch).
boolean	prepareTrigger(PointValue noticeValue, Batch batch) Allows a behavior to prepare for a call to Behavior.trigger(org.rvpf.base.value.PointValue, org.rvpf.metadata.processor.Batch).
boolean	select(ResultValue resultValue, Batch batch) Selects input values for computing the result.
boolean	setUp(Metadata metadata, ProxyEntity proxyEntity) Sets up the instance for action.
void	trigger(PointValue noticeValue, Batch batch) Triggers the computation of results if needed.

Methods inherited from class ReplicatedBehavior

isResultFetched

Methods inherited from class PrimaryBehavior

addInputToResult, equals, getAfterResultSyncPosition, getInputSync, getResultSync, getResultSyncStamp, getSelectSyncPosition, getSinceResultSyncPosition, getSinceSyncPosition, getSync, getSynchronizedResultStamp, getSyncStamp, hasAfterResultSyncPosition, hashCode, hasSelectSyncPosition, hasSinceResultSyncPosition, hasSinceSyncPosition, isInSync, isPrimary, isSelectPreviousValue, supportsExtrapolated, supportsInterpolated, validate, validateNoLoop, validateNotSynchronized

Methods inherited from class AbstractBehavior

getBehavior, getBooleanInputValue, getDoubleInputValue, getElapsedInputValue, getEntity, getInput, getInputPoint, getName, getNext, getParams, getProxyEntity, getRelation, getRelations, getRelationSync, getRelationSyncEntity, getResultPoint, getThisLogger, getTransform, isInherited, isInputExtrapolated, isInputInterpolated, isInputRequired, isInputValid, isSynchronized, newResultValue, setInherited, setNext, setRelation, tearDown, toString, validateNoResults, validateTransform

Methods inherited from class Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

ResynchronizedBehavior

public ResynchronizedBehavior()

Method Detail

prepareSelect

public boolean prepareSelect(ResultValue resultValue,
                             Batch batch)

Allows a behavior to prepare for a call to Behavior.select(org.rvpf.base.value.ResultValue, org.rvpf.metadata.processor.Batch).

The result value has been triggered either by this behavior or the behavior of an other input. Will be called until all the batch behaviors return true.

Specified by:

prepareSelect in interface Behavior

Overrides:

prepareSelect in class ReplicatedBehavior

Parameters:

resultValue - The result value to be computed.

batch - The current batch context.

Returns:

True if ready for select.

prepareTrigger

public boolean prepareTrigger(PointValue noticeValue,
                              Batch batch)

Allows a behavior to prepare for a call to Behavior.trigger(org.rvpf.base.value.PointValue, org.rvpf.metadata.processor.Batch).

Will be called until all the batch behaviors return true.

When the input Point is not the result Point, a later input may resolve to the same result timestamp.

Specified by:

prepareTrigger in interface Behavior

Overrides:

prepareTrigger in class AbstractBehavior

Parameters:

noticeValue - A point value acting as potential trigger.

batch - The current batch context.

Returns:

True if ready for trigger.

select

public boolean select(ResultValue resultValue,
                      Batch batch)

Selects input values for computing the result.

This is called after all the calls to the Behavior.prepareSelect(org.rvpf.base.value.ResultValue, org.rvpf.metadata.processor.Batch) method have returned true.

Specified by:

select in interface Behavior

Overrides:

select in class ReplicatedBehavior

Parameters:

resultValue - The result value to be computed.

batch - The current batch context.

Returns:

False if a problem was identified.

setUp

public boolean setUp(Metadata metadata,
                     ProxyEntity proxyEntity)

Sets up the instance for action.

Specified by:

setUp in interface Proxied

Overrides:

setUp in class PrimaryBehavior

Parameters:

metadata - The metadata available to the current process.

proxyEntity - The proxy entity refering to the proxied.

Returns:

True on success.

trigger

public void trigger(PointValue noticeValue,
                    Batch batch)

Triggers the computation of results if needed.

This is called after all the calls to the Behavior.prepareTrigger(org.rvpf.base.value.PointValue, org.rvpf.metadata.processor.Batch) method have returned true.

Since we are replicating, it would be reasonable for the notice and the result to refer to the same point definition. In order to be able to get the result value from its locally configured Store, we ask the Batch to forget about the notice, then set up a result with the notice as input.

Specified by:

trigger in interface Behavior

Overrides:

trigger in class ReplicatedBehavior

Parameters:

noticeValue - A point value acting as potential trigger.

batch - The current batch context.

doValidate

protected boolean doValidate()

Does validate this behavior.

Because of its special interaction with the Batch, this Behavior is intolerant of others on the same relation.

If the input replicates itself, it is not allowed to have other dependents on the same Processor.

If the input resynchronizes itself, it is not allowed to have other dependents on the same Processor.

Overrides:

doValidate in class ReplicatedBehavior

Returns:

True when valid.