org.eclipse.scada.protocol.iec60870.server.data.testing

Class SineDataModel

java.lang.Object

org.eclipse.scada.protocol.iec60870.server.data.AbstractBaseDataModel

org.eclipse.scada.protocol.iec60870.server.data.testing.SineDataModel

All Implemented Interfaces:

DataModel

public class SineDataModel
extends AbstractBaseDataModel

Field Summary

Fields inherited from class org.eclipse.scada.protocol.iec60870.server.data.AbstractBaseDataModel

executor

Constructor Summary

Constructors

Constructor and Description
SineDataModel(int size)

Method Summary

Methods

Modifier and Type	Method and Description
BackgroundIterator	createBackgroundIterator() Create a new background iterator If the implementation does not support background transmissions, null may be returned.
void	forAllAsdu(com.google.common.base.Function<ASDUAddress,Void> function, Runnable ifNoneFound) A method that will call the provided function for each known ASDU address
protected void	handleWriteCommand(MirrorCommand mirrorCommand)
protected Value<?>	performRead(ASDUAddress asduAddress, InformationObjectAddress address)
protected Void	performReadAll(DataListener listener)
protected Object	proceedBackgroundScan(AtomicInteger positionRef)
com.google.common.util.concurrent.ListenableFuture<Value<?>>	read(ASDUAddress asduAddress, InformationObjectAddress address) Read a specific value The future will be called with the result of the read operation.
com.google.common.util.concurrent.ListenableFuture<Void>	readAll(ASDUAddress asduAddress, Runnable prepare, DataListener listener) Read all values from the internal structures The data will not be returned by the future, but pushed to the DataListener.
protected void	update()
void	writeCommand(ASDUHeader header, InformationObjectAddress informationObjectAddress, boolean state, byte type, MirrorCommand mirrorCommand, boolean execute)
void	writeScaledValue(ASDUHeader header, InformationObjectAddress informationObjectAddress, short value, byte type, MirrorCommand mirrorCommand, boolean execute)
void	writeValue(ASDUHeader header, InformationObjectAddress informationObjectAddress, float value, byte type, MirrorCommand mirrorCommand, boolean execute)

Methods inherited from class org.eclipse.scada.protocol.iec60870.server.data.AbstractBaseDataModel

dispose, disposeAndWait, disposeSubscription, getNumberOfSubscriptions, notifyChangeBoolean, notifyChangeFloat, subscribe

Methods inherited from class java.lang.Object

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

Constructor Detail

SineDataModel

public SineDataModel(int size)

Method Detail

update

protected void update()

read

public com.google.common.util.concurrent.ListenableFuture<Value<?>> read(ASDUAddress asduAddress,
                                                                InformationObjectAddress address)

Description copied from interface: DataModel

Read a specific value
The future will be called with the result of the read operation. If the value is unknown the future must be called with null.

address - the address to read

Returns:

a listener to the operation, null if the data model instantly decide that the value cannot be read

performRead

protected Value<?> performRead(ASDUAddress asduAddress,
                   InformationObjectAddress address)

readAll

public com.google.common.util.concurrent.ListenableFuture<Void> readAll(ASDUAddress asduAddress,
                                                               Runnable prepare,
                                                               DataListener listener)

Description copied from interface: DataModel

Read all values from the internal structures
The data will not be returned by the future, but pushed to the DataListener.

Parameters:

asduAddress - the ASDU common address

prepare - a runnable that will be called before the actual processing, from the same thread the listener will be called. But only when the request actually can be processed. If the runnable was called, the method must not return null.

listener - the data receiver

Returns:

the future which indicates the end of the transmission. This can be null if the ASDU address was unknown.

performReadAll

protected Void performReadAll(DataListener listener)

forAllAsdu

public void forAllAsdu(com.google.common.base.Function<ASDUAddress,Void> function,
              Runnable ifNoneFound)

Description copied from interface: DataModel

A method that will call the provided function for each known ASDU address

Note that the ASDUs must not change until each function call has been completed.

The function call can be performed asynchronously.

Parameters:

function - the function to call for each known ASDU address

ifNoneFound - will be called if there are no known common ASDU addresses, may be null

createBackgroundIterator

public BackgroundIterator createBackgroundIterator()

Description copied from interface: DataModel

Create a new background iterator
If the implementation does not support background transmissions, null may be returned.
The background iterator instance must not cache values. As this would cause a situation where more up-to-date values would get overwritten by the cached values of the background iterator.

Returns:

the new background iterator or null

proceedBackgroundScan

protected Object proceedBackgroundScan(AtomicInteger positionRef)

writeCommand

public void writeCommand(ASDUHeader header,
                InformationObjectAddress informationObjectAddress,
                boolean state,
                byte type,
                MirrorCommand mirrorCommand,
                boolean execute)

writeValue

public void writeValue(ASDUHeader header,
              InformationObjectAddress informationObjectAddress,
              float value,
              byte type,
              MirrorCommand mirrorCommand,
              boolean execute)

writeScaledValue

public void writeScaledValue(ASDUHeader header,
                    InformationObjectAddress informationObjectAddress,
                    short value,
                    byte type,
                    MirrorCommand mirrorCommand,
                    boolean execute)

handleWriteCommand

protected void handleWriteCommand(MirrorCommand mirrorCommand)