cc.radiuino.scadabr.rt.datasource.radiuino

Class RadiuinoEventDataSource

java.lang.Object

com.serotonin.mango.rt.dataSource.DataSourceRT

com.serotonin.mango.rt.dataSource.EventDataSource

cc.radiuino.scadabr.rt.datasource.radiuino.RadiuinoEventDataSource

All Implemented Interfaces:

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

public class RadiuinoEventDataSource
extends EventDataSource
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.EventDataSource

dataPoints

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
RadiuinoEventDataSource(RadiuinoDataSourceVO<?> vo)

Method Summary

Modifier and Type	Method and Description
private void	configurePort(gnu.io.SerialPort port)
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.EventDataSource

addDataPoint, removeDataPoint

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

beginPolling, forcePointRead, getExceptionMessage, getId, getName, getPersistentData, getSerialExceptionMessage, joinTermination, raiseEvent, relinquish, 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

esperandoPacoteEndereco

private byte esperandoPacoteEndereco

esperandoPacote

private boolean esperandoPacote

Constructor Detail

RadiuinoEventDataSource

public RadiuinoEventDataSource(RadiuinoDataSourceVO<?> vo)

Method Detail

reconnect

private boolean reconnect()

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 DataSourceRT

setPointValue

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

Overrides:

setPointValue in class EventDataSource

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()