com.serotonin.mango.rt.dataSource.bacnet

Class BACnetIPDataSourceRT

java.lang.Object

com.serotonin.mango.rt.dataSource.DataSourceRT

com.serotonin.mango.rt.dataSource.PollingDataSource

com.serotonin.mango.rt.dataSource.bacnet.BACnetIPDataSourceRT

All Implemented Interfaces:

com.serotonin.bacnet4j.event.DeviceEventListener, com.serotonin.bacnet4j.event.ExceptionListener, TimeoutClient, com.serotonin.util.ILifecycle

public class BACnetIPDataSourceRT
extends PollingDataSource
implements com.serotonin.bacnet4j.event.DeviceEventListener, com.serotonin.bacnet4j.event.ExceptionListener

Author:

Matthew Lohbihler

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	BACnetIPDataSourceRT.CovResubscriptionTask
(package private) class	BACnetIPDataSourceRT.DevicePoller

Field Summary

Fields

Modifier and Type	Field and Description
private BACnetIPDataSourceRT.CovResubscriptionTask	covResubscriptionTask
static int	DEVICE_EXCEPTION_EVENT
static int	INITIALIZATION_EXCEPTION_EVENT
private boolean	initialized
private com.serotonin.bacnet4j.LocalDevice	localDevice
(package private) org.apache.commons.logging.Log	log
static int	MESSAGE_EXCEPTION_EVENT
(package private) java.util.List<com.serotonin.bacnet4j.RemoteDevice>	pollsInProgress
(package private) BACnetIPDataSourceVO	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
BACnetIPDataSourceRT(BACnetIPDataSourceVO vo)

Method Summary

Modifier and Type	Method and Description
void	addDataPoint(DataPointRT dataPoint)
boolean	allowPropertyWrite(com.serotonin.bacnet4j.obj.BACnetObject obj, com.serotonin.bacnet4j.type.constructed.PropertyValue pv)
void	beginPolling()
void	covNotificationReceived(com.serotonin.bacnet4j.type.primitive.UnsignedInteger subscriberProcessIdentifier, com.serotonin.bacnet4j.RemoteDevice initiatingDevice, com.serotonin.bacnet4j.type.primitive.ObjectIdentifier monitoredObjectIdentifier, com.serotonin.bacnet4j.type.primitive.UnsignedInteger timeRemaining, com.serotonin.bacnet4j.type.constructed.SequenceOf<com.serotonin.bacnet4j.type.constructed.PropertyValue> listOfValues)
private void	dereferencePoint(DataPointRT dp, com.serotonin.bacnet4j.type.Encodable encodable, long time)
private void	disablePoint(DataPointRT dataPoint)
protected void	doPoll(long time)
private MangoValue	encodableToValue(com.serotonin.bacnet4j.type.Encodable encodable, int dataTypeId)
void	eventNotificationReceived(com.serotonin.bacnet4j.type.primitive.UnsignedInteger processIdentifier, com.serotonin.bacnet4j.RemoteDevice initiatingDevice, com.serotonin.bacnet4j.type.primitive.ObjectIdentifier eventObjectIdentifier, com.serotonin.bacnet4j.type.constructed.TimeStamp timeStamp, com.serotonin.bacnet4j.type.primitive.UnsignedInteger notificationClass, com.serotonin.bacnet4j.type.primitive.UnsignedInteger priority, com.serotonin.bacnet4j.type.enumerated.EventType eventType, com.serotonin.bacnet4j.type.primitive.CharacterString messageText, com.serotonin.bacnet4j.type.enumerated.NotifyType notifyType, com.serotonin.bacnet4j.type.primitive.Boolean ackRequired, com.serotonin.bacnet4j.type.enumerated.EventState fromState, com.serotonin.bacnet4j.type.enumerated.EventState toState, com.serotonin.bacnet4j.type.notificationParameters.NotificationParameters eventValues)
private void	fireDeviceExceptionEvent(java.lang.String key, java.lang.Object... args)
private void	fireMessageExceptionEvent(java.lang.String key, java.lang.Object... args)
private void	fireMessageExceptionEvent(java.lang.Throwable t)
void	forcePointRead(DataPointRT dataPoint)
(package private) java.util.List<DataPointRT>	getDataPoints()
(package private) java.lang.Boolean	getPointListChangeLock()
void	iAmReceived(com.serotonin.bacnet4j.RemoteDevice d)
void	iHaveReceived(com.serotonin.bacnet4j.RemoteDevice d, com.serotonin.bacnet4j.RemoteObject o)
void	initialize()
void	listenerException(java.lang.Throwable e)
(package private) void	pollDevice(com.serotonin.bacnet4j.RemoteDevice d, java.util.List<DataPointRT> points, long time)
void	privateTransferReceived(com.serotonin.bacnet4j.type.primitive.UnsignedInteger vendorId, com.serotonin.bacnet4j.type.primitive.UnsignedInteger serviceNumber, com.serotonin.bacnet4j.type.Encodable serviceParameters)
void	propertyWritten(com.serotonin.bacnet4j.obj.BACnetObject obj, com.serotonin.bacnet4j.type.constructed.PropertyValue pv)
void	receivedException(java.lang.Exception e)
void	receivedThrowable(java.lang.Throwable t)
void	reinitializeDevice(com.serotonin.bacnet4j.service.confirmed.ReinitializeDeviceRequest.ReinitializedStateOfDevice reinitializedStateOfDevice)
void	relinquish(DataPointRT dataPoint)
void	removeDataPoint(DataPointRT dataPoint)
(package private) boolean	sendCovSubscription(DataPointRT dataPoint, boolean unsubscribe)
private void	sendCovSubscriptionImpl(com.serotonin.bacnet4j.RemoteDevice remoteDevice, com.serotonin.bacnet4j.type.primitive.ObjectIdentifier oid, int covId, boolean unsubscribe)
void	setPointValue(DataPointRT dataPoint, PointValueTime pvt, SetPointSource source)
void	synchronizeTime(com.serotonin.bacnet4j.type.constructed.DateTime arg0, boolean arg1)
void	terminate()
void	textMessageReceived(com.serotonin.bacnet4j.RemoteDevice textMessageSourceDevice, com.serotonin.bacnet4j.type.constructed.Choice messageClass, com.serotonin.bacnet4j.type.enumerated.MessagePriority messagePriority, com.serotonin.bacnet4j.type.primitive.CharacterString message)
void	unimplementedVendorService(com.serotonin.bacnet4j.type.primitive.UnsignedInteger vendorId, com.serotonin.bacnet4j.type.primitive.UnsignedInteger serviceNumber, com.serotonin.util.queue.ByteQueue queue)
private com.serotonin.bacnet4j.type.Encodable	valueToEncodable(MangoValue value, com.serotonin.bacnet4j.type.enumerated.ObjectType objectType, com.serotonin.bacnet4j.type.enumerated.PropertyIdentifier pid)

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

joinTermination, scheduleTimeout, setPollingPeriod, updateChangedPoints

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

getExceptionMessage, getId, getName, getPersistentData, getSerialExceptionMessage, raiseEvent, returnToNormal, setPersistentData

Methods inherited from class java.lang.Object

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

Field Detail

INITIALIZATION_EXCEPTION_EVENT

public static final int INITIALIZATION_EXCEPTION_EVENT

See Also:

Constant Field Values

MESSAGE_EXCEPTION_EVENT

public static final int MESSAGE_EXCEPTION_EVENT

See Also:

Constant Field Values

DEVICE_EXCEPTION_EVENT

public static final int DEVICE_EXCEPTION_EVENT

See Also:

Constant Field Values

log

final org.apache.commons.logging.Log log

vo

final BACnetIPDataSourceVO vo

localDevice

private com.serotonin.bacnet4j.LocalDevice localDevice

initialized

private boolean initialized

pollsInProgress

final java.util.List<com.serotonin.bacnet4j.RemoteDevice> pollsInProgress

covResubscriptionTask

private BACnetIPDataSourceRT.CovResubscriptionTask covResubscriptionTask

Constructor Detail

BACnetIPDataSourceRT

public BACnetIPDataSourceRT(BACnetIPDataSourceVO vo)

Method Detail

initialize

public void initialize()

Specified by:

initialize in interface com.serotonin.util.ILifecycle

Overrides:

initialize in class DataSourceRT

beginPolling

public void beginPolling()

Overrides:

beginPolling in class PollingDataSource

terminate

public void terminate()

Specified by:

terminate in interface com.serotonin.util.ILifecycle

Overrides:

terminate in class PollingDataSource

addDataPoint

public void addDataPoint(DataPointRT dataPoint)

Overrides:

addDataPoint in class DataSourceRT

removeDataPoint

public void removeDataPoint(DataPointRT dataPoint)

Overrides:

removeDataPoint in class DataSourceRT

doPoll

protected void doPoll(long time)

Specified by:

doPoll in class PollingDataSource

pollDevice

void pollDevice(com.serotonin.bacnet4j.RemoteDevice d,
                java.util.List<DataPointRT> points,
                long time)

forcePointRead

public void forcePointRead(DataPointRT dataPoint)

Overrides:

forcePointRead in class DataSourceRT

dereferencePoint

private void dereferencePoint(DataPointRT dp,
                              com.serotonin.bacnet4j.type.Encodable encodable,
                              long time)

setPointValue

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

Specified by:

setPointValue in class DataSourceRT

relinquish

public void relinquish(DataPointRT dataPoint)

Overrides:

relinquish in class DataSourceRT

getPointListChangeLock

java.lang.Boolean getPointListChangeLock()

getDataPoints

java.util.List<DataPointRT> getDataPoints()

listenerException

public void listenerException(java.lang.Throwable e)

Specified by:

listenerException in interface com.serotonin.bacnet4j.event.DeviceEventListener

allowPropertyWrite

public boolean allowPropertyWrite(com.serotonin.bacnet4j.obj.BACnetObject obj,
                                  com.serotonin.bacnet4j.type.constructed.PropertyValue pv)

Specified by:

allowPropertyWrite in interface com.serotonin.bacnet4j.event.DeviceEventListener

iAmReceived

public void iAmReceived(com.serotonin.bacnet4j.RemoteDevice d)

Specified by:

iAmReceived in interface com.serotonin.bacnet4j.event.DeviceEventListener

propertyWritten

public void propertyWritten(com.serotonin.bacnet4j.obj.BACnetObject obj,
                            com.serotonin.bacnet4j.type.constructed.PropertyValue pv)

Specified by:

propertyWritten in interface com.serotonin.bacnet4j.event.DeviceEventListener

iHaveReceived

public void iHaveReceived(com.serotonin.bacnet4j.RemoteDevice d,
                          com.serotonin.bacnet4j.RemoteObject o)

Specified by:

iHaveReceived in interface com.serotonin.bacnet4j.event.DeviceEventListener

covNotificationReceived

public void covNotificationReceived(com.serotonin.bacnet4j.type.primitive.UnsignedInteger subscriberProcessIdentifier,
                                    com.serotonin.bacnet4j.RemoteDevice initiatingDevice,
                                    com.serotonin.bacnet4j.type.primitive.ObjectIdentifier monitoredObjectIdentifier,
                                    com.serotonin.bacnet4j.type.primitive.UnsignedInteger timeRemaining,
                                    com.serotonin.bacnet4j.type.constructed.SequenceOf<com.serotonin.bacnet4j.type.constructed.PropertyValue> listOfValues)

Specified by:

covNotificationReceived in interface com.serotonin.bacnet4j.event.DeviceEventListener

eventNotificationReceived

public void eventNotificationReceived(com.serotonin.bacnet4j.type.primitive.UnsignedInteger processIdentifier,
                                      com.serotonin.bacnet4j.RemoteDevice initiatingDevice,
                                      com.serotonin.bacnet4j.type.primitive.ObjectIdentifier eventObjectIdentifier,
                                      com.serotonin.bacnet4j.type.constructed.TimeStamp timeStamp,
                                      com.serotonin.bacnet4j.type.primitive.UnsignedInteger notificationClass,
                                      com.serotonin.bacnet4j.type.primitive.UnsignedInteger priority,
                                      com.serotonin.bacnet4j.type.enumerated.EventType eventType,
                                      com.serotonin.bacnet4j.type.primitive.CharacterString messageText,
                                      com.serotonin.bacnet4j.type.enumerated.NotifyType notifyType,
                                      com.serotonin.bacnet4j.type.primitive.Boolean ackRequired,
                                      com.serotonin.bacnet4j.type.enumerated.EventState fromState,
                                      com.serotonin.bacnet4j.type.enumerated.EventState toState,
                                      com.serotonin.bacnet4j.type.notificationParameters.NotificationParameters eventValues)

Specified by:

eventNotificationReceived in interface com.serotonin.bacnet4j.event.DeviceEventListener

textMessageReceived

public void textMessageReceived(com.serotonin.bacnet4j.RemoteDevice textMessageSourceDevice,
                                com.serotonin.bacnet4j.type.constructed.Choice messageClass,
                                com.serotonin.bacnet4j.type.enumerated.MessagePriority messagePriority,
                                com.serotonin.bacnet4j.type.primitive.CharacterString message)

Specified by:

textMessageReceived in interface com.serotonin.bacnet4j.event.DeviceEventListener

privateTransferReceived

public void privateTransferReceived(com.serotonin.bacnet4j.type.primitive.UnsignedInteger vendorId,
                                    com.serotonin.bacnet4j.type.primitive.UnsignedInteger serviceNumber,
                                    com.serotonin.bacnet4j.type.Encodable serviceParameters)

Specified by:

privateTransferReceived in interface com.serotonin.bacnet4j.event.DeviceEventListener

reinitializeDevice

public void reinitializeDevice(com.serotonin.bacnet4j.service.confirmed.ReinitializeDeviceRequest.ReinitializedStateOfDevice reinitializedStateOfDevice)

Specified by:

reinitializeDevice in interface com.serotonin.bacnet4j.event.DeviceEventListener

synchronizeTime

public void synchronizeTime(com.serotonin.bacnet4j.type.constructed.DateTime arg0,
                            boolean arg1)

Specified by:

synchronizeTime in interface com.serotonin.bacnet4j.event.DeviceEventListener

receivedException

public void receivedException(java.lang.Exception e)

Specified by:

receivedException in interface com.serotonin.bacnet4j.event.ExceptionListener

receivedThrowable

public void receivedThrowable(java.lang.Throwable t)

Specified by:

receivedThrowable in interface com.serotonin.bacnet4j.event.ExceptionListener

unimplementedVendorService

public void unimplementedVendorService(com.serotonin.bacnet4j.type.primitive.UnsignedInteger vendorId,
                                       com.serotonin.bacnet4j.type.primitive.UnsignedInteger serviceNumber,
                                       com.serotonin.util.queue.ByteQueue queue)

Specified by:

unimplementedVendorService in interface com.serotonin.bacnet4j.event.ExceptionListener

sendCovSubscription

boolean sendCovSubscription(DataPointRT dataPoint,
                            boolean unsubscribe)

sendCovSubscriptionImpl

private void sendCovSubscriptionImpl(com.serotonin.bacnet4j.RemoteDevice remoteDevice,
                                     com.serotonin.bacnet4j.type.primitive.ObjectIdentifier oid,
                                     int covId,
                                     boolean unsubscribe)
                              throws com.serotonin.bacnet4j.exception.BACnetException

Throws:

com.serotonin.bacnet4j.exception.BACnetException

fireMessageExceptionEvent

private void fireMessageExceptionEvent(java.lang.Throwable t)

fireMessageExceptionEvent

private void fireMessageExceptionEvent(java.lang.String key,
                                       java.lang.Object... args)

fireDeviceExceptionEvent

private void fireDeviceExceptionEvent(java.lang.String key,
                                      java.lang.Object... args)

disablePoint

private void disablePoint(DataPointRT dataPoint)

encodableToValue

private MangoValue encodableToValue(com.serotonin.bacnet4j.type.Encodable encodable,
                                    int dataTypeId)

valueToEncodable

private com.serotonin.bacnet4j.type.Encodable valueToEncodable(MangoValue value,
                                                               com.serotonin.bacnet4j.type.enumerated.ObjectType objectType,
                                                               com.serotonin.bacnet4j.type.enumerated.PropertyIdentifier pid)