cc.radiuino.scadabr.rt.datasource.radiuino

Class RadiuinoPollingDataSource

java.lang.Object

com.serotonin.mango.rt.dataSource.DataSourceRT

com.serotonin.mango.rt.dataSource.PollingDataSource

cc.radiuino.scadabr.rt.datasource.radiuino.RadiuinoPollingDataSource

All Implemented Interfaces:

TimeoutClient, com.serotonin.util.ILifecycle, gnu.io.SerialPortEventListener, java.util.EventListener

public class RadiuinoPollingDataSource
extends PollingDataSource
implements gnu.io.SerialPortEventListener

Field Summary

Fields

Modifier and Type	Field and Description
private byte[]	buffer
static int	DATA_SOURCE_EXCEPTION_EVENT
private boolean	esperandoPacote
private byte	esperandoPacoteEndereco
private int	iBuffer
private static int	INDICE_ENDERECO_DESTINO
private static int	INDICE_ENDERECO_ORIGEM
private java.io.InputStream	inSerialStream
private org.apache.commons.logging.Log	LOG
private java.io.OutputStream	outSerialStream
private byte[]	pacote
static int	POINT_READ_EXCEPTION_EVENT
private java.util.Enumeration	portList
private gnu.io.SerialPort	sPort
private RadiuinoDataSourceVO<?>	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
RadiuinoPollingDataSource(RadiuinoDataSourceVO<?> vo)

Method Summary

Modifier and Type	Method and Description
private void	configurePort(gnu.io.SerialPort port)
protected void	doPoll(long time)
private void	enviarPacote(byte[] pacoteEnvio, int retries)
java.io.InputStream	getInSerialStream()
java.io.OutputStream	getOutSerialStream()
private gnu.io.SerialPort	getPort(java.lang.String port, int timeout)
gnu.io.SerialPort	getsPort()
void	initialize()
private void	pacoteRecebido()
private boolean	reconnect()
void	serialEvent(gnu.io.SerialPortEvent serialPortEvent)
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

INDICE_ENDERECO_ORIGEM

private static final int INDICE_ENDERECO_ORIGEM

See Also:

Constant Field Values

INDICE_ENDERECO_DESTINO

private static final int INDICE_ENDERECO_DESTINO

See Also:

Constant Field Values

vo

private final RadiuinoDataSourceVO<?> 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

buffer

private byte[] buffer

iBuffer

private int iBuffer

pacote

private byte[] pacote

esperandoPacote

private boolean esperandoPacote

esperandoPacoteEndereco

private byte esperandoPacoteEndereco

Constructor Detail

RadiuinoPollingDataSource

public RadiuinoPollingDataSource(RadiuinoDataSourceVO<?> 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

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

enviarPacote

private void enviarPacote(byte[] pacoteEnvio,
                          int retries)
                   throws java.io.IOException

Throws:

java.io.IOException

configurePort

private void configurePort(gnu.io.SerialPort port)

getPort

private gnu.io.SerialPort getPort(java.lang.String port,
                                  int timeout)

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)

serialEvent

public void serialEvent(gnu.io.SerialPortEvent serialPortEvent)

Specified by:

serialEvent in interface gnu.io.SerialPortEventListener

pacoteRecebido

private void pacoteRecebido()