org.eclipse.scada.da.server.common.memory

Class AbstractRequestBlock

java.lang.Object

org.eclipse.scada.da.server.common.memory.AbstractRequestBlock

All Implemented Interfaces:

PollRequest, MemoryRequestBlock

Direct Known Subclasses:

DaveRequestBlock, ModbusRequestBlock

public abstract class AbstractRequestBlock
extends Object
implements PollRequest, MemoryRequestBlock

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	AbstractRequestBlock.Statistics

Constructor Summary

Constructors

Constructor and Description
AbstractRequestBlock(org.osgi.framework.BundleContext context, Executor executor, String mainTypeName, String variablePrefix, String blockPrefix, boolean enableStatistics, long period, int requestSize, long timeoutQuietPeriod, boolean eager)

Method Summary

Modifier and Type	Method and Description
protected long	calculatePriority(long now)
void	dispose()
void	handleData(org.apache.mina.core.buffer.IoBuffer data)
void	handleDisconnect() Handle a device disconnect
void	handleError(int error)
void	handleFailure(Throwable e)
void	handleTimeout()
protected void	initialize()
protected void	recordChecksumError()
protected void	recordUpdate(boolean error)
protected void	requestUpdate() Request an update as soon as possible
void	setVariables(Variable[] variables) Set the new variable configuration
Long	updatePriority(long now) The the update priority used to find the next block to request

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.scada.da.server.common.io.PollRequest

createPollRequest, getPollRequestTimeout, handleMessage

Methods inherited from interface org.eclipse.scada.da.server.common.memory.MemoryRequestBlock

getStartAddress, writeBit, writeData

Constructor Detail

AbstractRequestBlock

public AbstractRequestBlock(org.osgi.framework.BundleContext context,
                            Executor executor,
                            String mainTypeName,
                            String variablePrefix,
                            String blockPrefix,
                            boolean enableStatistics,
                            long period,
                            int requestSize,
                            long timeoutQuietPeriod,
                            boolean eager)

Method Detail

initialize

protected void initialize()

updatePriority

public Long updatePriority(long now)

The the update priority used to find the next block to request

Specified by:

updatePriority in interface PollRequest

Parameters:

now -

Returns:

the update priority, or null if the block does not want to be updated right now

calculatePriority

protected long calculatePriority(long now)

handleDisconnect

public void handleDisconnect()

Handle a device disconnect

Specified by:

handleDisconnect in interface PollRequest

handleTimeout

public void handleTimeout()

Specified by:

handleTimeout in interface PollRequest

handleFailure

public void handleFailure(Throwable e)

Specified by:

handleFailure in interface PollRequest

dispose

public void dispose()

Specified by:

dispose in interface PollRequest

setVariables

public void setVariables(Variable[] variables)

Set the new variable configuration

Parameters:

variables - the new variables to set

recordChecksumError

protected void recordChecksumError()

recordUpdate

protected void recordUpdate(boolean error)

handleError

public void handleError(int error)

handleData

public void handleData(org.apache.mina.core.buffer.IoBuffer data)

requestUpdate

protected void requestUpdate()

Request an update as soon as possible