org.eclipse.neoscada.da.server.exporter.iec60870

Class DataModelImpl

java.lang.Object

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

org.eclipse.neoscada.protocol.iec60870.server.data.model.ChangeDataModel

org.eclipse.neoscada.da.server.exporter.iec60870.DataModelImpl

All Implemented Interfaces:

DataModel

public class DataModelImpl
extends ChangeDataModel

An IEC60870-5 data model for Eclipse SCADA

Implementation details

All entries are initialized with DataItemValue.DISCONNECTED in order to populate the caches. This will allow the background transfer to already have data before changes came in.

Field Summary

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

executor

Constructor Summary

Constructors

Constructor and Description
DataModelImpl(HiveSource hiveSource, Set<MappingEntry> entries, Properties hiveProperties, InformationBean info, Long flushDelay, boolean supportBackgroundScan)

Method Summary

Modifier and Type	Method and Description
protected BackgroundModel	createBackgroundModel() Create a BackgroundModel for this data model instance
protected ChangeModel	createChangeModel() Create a ChangeModel for this data model instance
protected WriteModel	createWriteModel() Create a WriteModel for this data model instance
protected com.google.common.util.concurrent.ListenableFuture<Void>	disposeSubscription(DefaultSubscription subscription)
protected void	handleStateChanged(MappingEntry entry, DataItemValue value, boolean notify)
protected WriteModel.Action	prepareCommand(WriteModel.Request<Boolean> request)
protected WriteModel.Action	prepareSetpointFloat(WriteModel.Request<Float> request)
protected WriteModel.Action	prepareSetpointScaled(WriteModel.Request<Short> request)
void	start()
Stopping	stop()
Subscription	subscribe(DataListener listener)

Methods inherited from class org.eclipse.neoscada.protocol.iec60870.server.data.model.ChangeDataModel

createBackgroundIterator, forAllAsdu, makeBufferingChangeModel, makeDefaultBackgroundModel, makeInstantChangeModel, notifyDataChange, performForAllAsdu, performRead, performReadAll, read, readAll, writeCommand, writeFloatValue, writeScaledValue

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

getNumberOfSubscriptions, notifyChangeBoolean, notifyChangeBoolean, notifyChangeFloat, notifyChangeFloat, notifyChangeShort, notifyChangeShort

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.neoscada.protocol.iec60870.server.data.DataModel

forAllAsdu

Constructor Detail

DataModelImpl

public DataModelImpl(HiveSource hiveSource,
                     Set<MappingEntry> entries,
                     Properties hiveProperties,
                     InformationBean info,
                     Long flushDelay,
                     boolean supportBackgroundScan)

Method Detail

createBackgroundModel

protected BackgroundModel createBackgroundModel()

Description copied from class: ChangeDataModel

Create a BackgroundModel for this data model instance

This method is called exactly once by the ChangeDataModel.start() method

Specified by:

createBackgroundModel in class ChangeDataModel

Returns:

a new background model instance

createChangeModel

protected ChangeModel createChangeModel()

Description copied from class: ChangeDataModel

Create a ChangeModel for this data model instance

This method is called exactly once by the ChangeDataModel.start() method

Specified by:

createChangeModel in class ChangeDataModel

Returns:

a new change model instance

createWriteModel

protected WriteModel createWriteModel()

Description copied from class: ChangeDataModel

Create a WriteModel for this data model instance

This method is called exactly once by the ChangeDataModel.start() method

Specified by:

createWriteModel in class ChangeDataModel

Returns:

a new write model instance

subscribe

public Subscription subscribe(DataListener listener)

Specified by:

subscribe in interface DataModel

Overrides:

subscribe in class AbstractBaseDataModel

disposeSubscription

protected com.google.common.util.concurrent.ListenableFuture<Void> disposeSubscription(DefaultSubscription subscription)

Overrides:

disposeSubscription in class AbstractBaseDataModel

handleStateChanged

protected void handleStateChanged(MappingEntry entry,
                                  DataItemValue value,
                                  boolean notify)

start

public void start()

Specified by:

start in interface DataModel

Overrides:

start in class ChangeDataModel

stop

public Stopping stop()

Specified by:

stop in interface DataModel

Overrides:

stop in class ChangeDataModel

prepareCommand

protected WriteModel.Action prepareCommand(WriteModel.Request<Boolean> request)

prepareSetpointFloat

protected WriteModel.Action prepareSetpointFloat(WriteModel.Request<Float> request)

prepareSetpointScaled

protected WriteModel.Action prepareSetpointScaled(WriteModel.Request<Short> request)