com.serotonin.mango.rt.dataSource.onewire

Class OneWireDataSourceRT

java.lang.Object

com.serotonin.mango.rt.dataSource.DataSourceRT

com.serotonin.mango.rt.dataSource.PollingDataSource

com.serotonin.mango.rt.dataSource.onewire.OneWireDataSourceRT

All Implemented Interfaces:

TimeoutClient, com.serotonin.util.ILifecycle

public class OneWireDataSourceRT
extends PollingDataSource

Author:

Matthew Lohbihler

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	OneWireDataSourceRT.NetworkReloadException

Field Summary

Fields

Modifier and Type	Field and Description
static int	DATA_SOURCE_EXCEPTION_EVENT
private static org.apache.commons.logging.Log	LOG
private Network	network
private long	nextRescan
static int	POINT_READ_EXCEPTION_EVENT
static int	POINT_WRITE_EXCEPTION_EVENT
private OneWireDataSourceVO	vo

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

dataPoints, pointListChanged

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
OneWireDataSourceRT(OneWireDataSourceVO vo)

Method Summary

Modifier and Type	Method and Description
private boolean	arePointsThatNeedAddress(java.lang.Long address, java.util.List<DataPointRT> points)
protected void	doPoll(long time)
Network	getNetwork()
void	initialize()
private void	initializeNetwork()
private void	readSensor(com.dalsemi.onewire.container.OneWireContainer owc, java.util.List<DataPointRT> points, java.lang.Long address, long time)
void	setPointValue(DataPointRT dataPoint, PointValueTime valueTime, SetPointSource source)
void	terminate()
private void	terminateNetwork()
private com.serotonin.web.i18n.LocalizableMessage	tryRead(java.util.List<DataPointRT> points, long time, boolean throwToReload)
private void	updateNextRescan(long time)

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

beginPolling, joinTermination, scheduleTimeout, setPollingPeriod, updateChangedPoints

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

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

Methods inherited from class java.lang.Object

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

Field Detail

LOG

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

DATA_SOURCE_EXCEPTION_EVENT

public static final int DATA_SOURCE_EXCEPTION_EVENT

See Also:

Constant Field Values

POINT_READ_EXCEPTION_EVENT

public static final int POINT_READ_EXCEPTION_EVENT

See Also:

Constant Field Values

POINT_WRITE_EXCEPTION_EVENT

public static final int POINT_WRITE_EXCEPTION_EVENT

See Also:

Constant Field Values

vo

private final OneWireDataSourceVO vo

network

private Network network

nextRescan

private long nextRescan

Constructor Detail

OneWireDataSourceRT

public OneWireDataSourceRT(OneWireDataSourceVO vo)

Method Detail

getNetwork

public Network getNetwork()

doPoll

protected void doPoll(long time)

Specified by:

doPoll in class PollingDataSource

tryRead

private com.serotonin.web.i18n.LocalizableMessage tryRead(java.util.List<DataPointRT> points,
                                                          long time,
                                                          boolean throwToReload)
                                                   throws OneWireDataSourceRT.NetworkReloadException

Throws:

OneWireDataSourceRT.NetworkReloadException

arePointsThatNeedAddress

private boolean arePointsThatNeedAddress(java.lang.Long address,
                                         java.util.List<DataPointRT> points)

readSensor

private void readSensor(com.dalsemi.onewire.container.OneWireContainer owc,
                        java.util.List<DataPointRT> points,
                        java.lang.Long address,
                        long time)
                 throws com.dalsemi.onewire.adapter.OneWireIOException,
                        com.dalsemi.onewire.OneWireException

Throws:

com.dalsemi.onewire.adapter.OneWireIOException

com.dalsemi.onewire.OneWireException

setPointValue

public void setPointValue(DataPointRT dataPoint,
                          PointValueTime valueTime,
                          SetPointSource source)

Specified by:

setPointValue in class DataSourceRT

initialize

public void initialize()

Specified by:

initialize in interface com.serotonin.util.ILifecycle

Overrides:

initialize in class DataSourceRT

terminate

public void terminate()

Specified by:

terminate in interface com.serotonin.util.ILifecycle

Overrides:

terminate in class PollingDataSource

initializeNetwork

private void initializeNetwork()

terminateNetwork

private void terminateNetwork()

updateNextRescan

private void updateNextRescan(long time)