com.serotonin.mango.rt.dataImage

Class DataPointRT

java.lang.Object

com.serotonin.mango.rt.dataImage.DataPointRT

All Implemented Interfaces:

IDataPoint, TimeoutClient, com.serotonin.util.ILifecycle

public class DataPointRT
extends java.lang.Object
implements IDataPoint, com.serotonin.util.ILifecycle, TimeoutClient

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	DataPointRT.EventNotifyWorkItem

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.Map<java.lang.String,java.lang.Object>	attributes
private java.util.List<IValueTime>	averagingValues
private java.util.List<PointEventDetectorRT>	detectors
private java.lang.Object	intervalLoggingLock
private com.serotonin.timer.TimerTask	intervalLoggingTask
private long	intervalStartTime
private PointValueTime	intervalValue
private static org.apache.commons.logging.Log	LOG
private PointLocatorRT	pointLocator
private PointValueTime	pointValue
private static PvtTimeComparator	pvtTimeComparator
private RuntimeManager	rm
private double	toleranceOrigin This is the value around which tolerance decisions will be made when determining whether to log numeric values.
private PointValueCache	valueCache
private DataPointVO	vo

Constructor Summary

Constructors

Constructor and Description
DataPointRT(DataPointVO vo, PointLocatorRT pointLocator)

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object obj)
private void	fireEvents(PointValueTime oldValue, PointValueTime newValue, boolean set, boolean backdate)
java.lang.Object	getAttribute(java.lang.String key)
java.util.Map<java.lang.String,java.lang.Object>	getAttributes()
int	getDataSourceId()
int	getDataTypeId()
int	getId()
java.util.List<PointValueTime>	getLatestPointValues(int limit)
<T extends PointLocatorRT> T	getPointLocator()
PointValueTime	getPointValue()
PointValueTime	getPointValueAt(long time)
PointValueTime	getPointValueBefore(long time)
java.util.List<PointValueTime>	getPointValues(long since)
java.util.List<PointValueTime>	getPointValuesBetween(long from, long to)
DataPointVO	getVO()
int	hashCode()
void	initialize()
void	initializeHistorical()
private void	initializeIntervalLogging()
private void	intervalSave(PointValueTime pvt)
void	joinTermination()
void	resetValues()
private void	savePointValue(PointValueTime newValue, SetPointSource source, boolean async)
void	scheduleTimeout(long fireTime)
void	setAttribute(java.lang.String key, java.lang.Object value)
void	setPointValue(PointValueTime newValue, SetPointSource source) Use this method to update a data point for reasons other than just data source update.
void	terminate()
void	terminateHistorical()
private void	terminateIntervalLogging()
java.lang.String	toString()
void	updatePointValue(PointValueTime newValue) This method should only be called by the data source.
void	updatePointValue(PointValueTime newValue, boolean async)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

LOG

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

pvtTimeComparator

private static final PvtTimeComparator pvtTimeComparator

vo

private final DataPointVO vo

pointLocator

private final PointLocatorRT pointLocator

pointValue

private volatile PointValueTime pointValue

valueCache

private final PointValueCache valueCache

rm

private RuntimeManager rm

detectors

private java.util.List<PointEventDetectorRT> detectors

attributes

private final java.util.Map<java.lang.String,java.lang.Object> attributes

intervalValue

private PointValueTime intervalValue

intervalStartTime

private long intervalStartTime

averagingValues

private java.util.List<IValueTime> averagingValues

intervalLoggingLock

private final java.lang.Object intervalLoggingLock

intervalLoggingTask

private com.serotonin.timer.TimerTask intervalLoggingTask

toleranceOrigin

private double toleranceOrigin

This is the value around which tolerance decisions will be made when determining whether to log numeric values.

Constructor Detail

DataPointRT

public DataPointRT(DataPointVO vo,
                   PointLocatorRT pointLocator)

Method Detail

getLatestPointValues

public java.util.List<PointValueTime> getLatestPointValues(int limit)

Specified by:

getLatestPointValues in interface IDataPoint

getPointValueBefore

public PointValueTime getPointValueBefore(long time)

Specified by:

getPointValueBefore in interface IDataPoint

getPointValueAt

public PointValueTime getPointValueAt(long time)

getPointValues

public java.util.List<PointValueTime> getPointValues(long since)

Specified by:

getPointValues in interface IDataPoint

getPointValuesBetween

public java.util.List<PointValueTime> getPointValuesBetween(long from,
                                                            long to)

Specified by:

getPointValuesBetween in interface IDataPoint

updatePointValue

public void updatePointValue(PointValueTime newValue)

This method should only be called by the data source. Other types of point setting should include a set point source object so that the annotation can be logged.

Specified by:

updatePointValue in interface IDataPoint

Parameters:

newValue -

updatePointValue

public void updatePointValue(PointValueTime newValue,
                             boolean async)

Specified by:

updatePointValue in interface IDataPoint

setPointValue

public void setPointValue(PointValueTime newValue,
                          SetPointSource source)

Use this method to update a data point for reasons other than just data source update.

Specified by:

setPointValue in interface IDataPoint

Parameters:

newValue - the value to set

source - the source of the set. This can be a user object if the point was set from the UI, or could be a program run by schedule or on event.

savePointValue

private void savePointValue(PointValueTime newValue,
                            SetPointSource source,
                            boolean async)

initializeIntervalLogging

private void initializeIntervalLogging()

terminateIntervalLogging

private void terminateIntervalLogging()

intervalSave

private void intervalSave(PointValueTime pvt)

scheduleTimeout

public void scheduleTimeout(long fireTime)

Specified by:

scheduleTimeout in interface TimeoutClient

resetValues

public void resetValues()

getId

public int getId()

getPointValue

public PointValueTime getPointValue()

Specified by:

getPointValue in interface IDataPoint

getPointLocator

public <T extends PointLocatorRT> T getPointLocator()

getDataSourceId

public int getDataSourceId()

getVO

public DataPointVO getVO()

getDataTypeId

public int getDataTypeId()

Specified by:

getDataTypeId in interface IDataPoint

getAttributes

public java.util.Map<java.lang.String,java.lang.Object> getAttributes()

setAttribute

public void setAttribute(java.lang.String key,
                         java.lang.Object value)

getAttribute

public java.lang.Object getAttribute(java.lang.String key)

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

fireEvents

private void fireEvents(PointValueTime oldValue,
                        PointValueTime newValue,
                        boolean set,
                        boolean backdate)

initialize

public void initialize()

Specified by:

initialize in interface com.serotonin.util.ILifecycle

terminate

public void terminate()

Specified by:

terminate in interface com.serotonin.util.ILifecycle

joinTermination

public void joinTermination()

Specified by:

joinTermination in interface com.serotonin.util.ILifecycle

initializeHistorical

public void initializeHistorical()

terminateHistorical

public void terminateHistorical()