com.serotonin.mango.rt.dataSource

Class PollingDataSource

java.lang.Object

com.serotonin.mango.rt.dataSource.DataSourceRT

com.serotonin.mango.rt.dataSource.PollingDataSource

All Implemented Interfaces:

TimeoutClient, com.serotonin.util.ILifecycle

Direct Known Subclasses:

Alpha2DataSource, ASCIIFileDataSource, ASCIISerialDataSource, BACnetIPDataSourceRT, Dnp3DataSource, DrStorageHt5bDataSource, EBI25DataSourceRT, GalilDataSourceRT, HttpImageDataSourceRT, HttpRetrieverDataSourceRT, IEC101DataSource, InternalDataSourceRT, JmxDataSourceRT, MBusDataSourceRT, ModbusDataSource, NodaveS7DataSource, OneWireDataSourceRT, OPCDataSource, OpenV4JDataSourceRT, PachubeDataSourceRT, Pop3DataSourceRT, RadiuinoPollingDataSource, SnmpDataSourceRT, SqlDataSourceRT, VirtualDataSourceRT

public abstract class PollingDataSource
extends DataSourceRT
implements TimeoutClient

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.List<DataPointRT>	dataPoints
private java.lang.Thread	jobThread
private long	jobThreadStartTime
private org.apache.commons.logging.Log	LOG
protected boolean	pointListChanged
private long	pollingPeriodMillis
private boolean	quantize
private com.serotonin.timer.TimerTask	timerTask
private DataSourceVO<?>	vo

Fields inherited from class com.serotonin.mango.rt.dataSource.DataSourceRT

addedChangedPoints, ATTR_DISCONNECTED_KEY, ATTR_UNRELIABLE_KEY, pointListChangeLock, removedPoints

Constructor Summary

Constructors

Constructor and Description
PollingDataSource(DataSourceVO<?> vo)

Method Summary

Modifier and Type	Method and Description
void	beginPolling()
protected abstract void	doPoll(long time)
void	joinTermination()
void	scheduleTimeout(long fireTime)
void	setPollingPeriod(int periodType, int periods, boolean quantize)
void	terminate()
protected void	updateChangedPoints()

Methods inherited from class com.serotonin.mango.rt.dataSource.DataSourceRT

addDataPoint, forcePointRead, getExceptionMessage, getId, getName, getPersistentData, getSerialExceptionMessage, initialize, raiseEvent, relinquish, removeDataPoint, returnToNormal, setPersistentData, setPointValue

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private final org.apache.commons.logging.Log LOG

vo

private final DataSourceVO<?> vo

dataPoints

protected java.util.List<DataPointRT> dataPoints

pointListChanged

protected boolean pointListChanged

pollingPeriodMillis

private long pollingPeriodMillis

quantize

private boolean quantize

timerTask

private com.serotonin.timer.TimerTask timerTask

jobThread

private volatile java.lang.Thread jobThread

jobThreadStartTime

private long jobThreadStartTime

Constructor Detail

PollingDataSource

public PollingDataSource(DataSourceVO<?> vo)

Method Detail

setPollingPeriod

public void setPollingPeriod(int periodType,
                             int periods,
                             boolean quantize)

scheduleTimeout

public void scheduleTimeout(long fireTime)

Specified by:

scheduleTimeout in interface TimeoutClient

doPoll

protected abstract void doPoll(long time)

updateChangedPoints

protected void updateChangedPoints()

beginPolling

public void beginPolling()

Overrides:

beginPolling in class DataSourceRT

terminate

public void terminate()

Specified by:

terminate in interface com.serotonin.util.ILifecycle

Overrides:

terminate in class DataSourceRT

joinTermination

public void joinTermination()

Specified by:

joinTermination in interface com.serotonin.util.ILifecycle

Overrides:

joinTermination in class DataSourceRT