br.org.scadabr.rt.dataSource.asciiSerial

Class ASCIISerialDataSource

java.lang.Object

com.serotonin.mango.rt.dataSource.DataSourceRT

com.serotonin.mango.rt.dataSource.PollingDataSource

br.org.scadabr.rt.dataSource.asciiSerial.ASCIISerialDataSource

All Implemented Interfaces:

TimeoutClient, com.serotonin.util.ILifecycle

public class ASCIISerialDataSource
extends PollingDataSource

Field Summary

Fields

Modifier and Type	Field and Description
static int	DATA_SOURCE_EXCEPTION_EVENT
private java.io.InputStream	inSerialStream
private org.apache.commons.logging.Log	LOG
private java.io.OutputStream	outSerialStream
static int	POINT_READ_EXCEPTION_EVENT
private java.util.Enumeration	portList
private gnu.io.SerialPort	sPort
private ASCIISerialDataSourceVO<?>	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
ASCIISerialDataSource(ASCIISerialDataSourceVO<?> vo)

Method Summary

Modifier and Type	Method and Description
void	configurePort(gnu.io.SerialPort port)
protected void	doPoll(long time)
java.io.InputStream	getInSerialStream()
java.io.OutputStream	getOutSerialStream()
gnu.io.SerialPort	getPort(java.lang.String port)
gnu.io.SerialPort	getsPort()
private long	getTimestamp(ASCIISerialPointLocatorVO point, java.lang.String arquivo)
private MangoValue	getValue(ASCIISerialPointLocatorVO point, java.lang.String arquivo)
void	initialize()
private boolean	reconnect()
void	setInSerialStream(java.io.InputStream inSerialStream)
void	setOutSerialStream(java.io.OutputStream outSerialStream)
void	setPointValue(DataPointRT dataPoint, PointValueTime valueTime, SetPointSource source)
void	setsPort(gnu.io.SerialPort sPort)
void	terminate()

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 final org.apache.commons.logging.Log LOG

POINT_READ_EXCEPTION_EVENT

public static final int POINT_READ_EXCEPTION_EVENT

See Also:

Constant Field Values

DATA_SOURCE_EXCEPTION_EVENT

public static final int DATA_SOURCE_EXCEPTION_EVENT

See Also:

Constant Field Values

vo

private final ASCIISerialDataSourceVO<?> vo

portList

private java.util.Enumeration portList

inSerialStream

private java.io.InputStream inSerialStream

outSerialStream

private java.io.OutputStream outSerialStream

sPort

private gnu.io.SerialPort sPort

Constructor Detail

ASCIISerialDataSource

public ASCIISerialDataSource(ASCIISerialDataSourceVO<?> vo)

Method Detail

reconnect

private boolean reconnect()

doPoll

protected void doPoll(long time)

Specified by:

doPoll in class PollingDataSource

initialize

public void initialize()

Specified by:

initialize in interface com.serotonin.util.ILifecycle

Overrides:

initialize in class DataSourceRT

getValue

private MangoValue getValue(ASCIISerialPointLocatorVO point,
                            java.lang.String arquivo)
                     throws java.lang.Exception

Throws:

java.lang.Exception

getTimestamp

private long getTimestamp(ASCIISerialPointLocatorVO point,
                          java.lang.String arquivo)
                   throws java.lang.Exception

Throws:

java.lang.Exception

terminate

public void terminate()

Specified by:

terminate in interface com.serotonin.util.ILifecycle

Overrides:

terminate in class PollingDataSource

setPointValue

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

Specified by:

setPointValue in class DataSourceRT

configurePort

public void configurePort(gnu.io.SerialPort port)

getPort

public gnu.io.SerialPort getPort(java.lang.String port)

getOutSerialStream

public java.io.OutputStream getOutSerialStream()

setOutSerialStream

public void setOutSerialStream(java.io.OutputStream outSerialStream)

getInSerialStream

public java.io.InputStream getInSerialStream()

setInSerialStream

public void setInSerialStream(java.io.InputStream inSerialStream)

getsPort

public gnu.io.SerialPort getsPort()

setsPort

public void setsPort(gnu.io.SerialPort sPort)