com.serotonin.mango.rt.dataSource.snmp

Class SnmpDataSourceRT

java.lang.Object

com.serotonin.mango.rt.dataSource.DataSourceRT

com.serotonin.mango.rt.dataSource.PollingDataSource

com.serotonin.mango.rt.dataSource.snmp.SnmpDataSourceRT

All Implemented Interfaces:

TimeoutClient, com.serotonin.util.ILifecycle

public class SnmpDataSourceRT
extends PollingDataSource

Author:

Matthew Lohbihler

Field Summary

Fields

Modifier and Type	Field and Description
private java.lang.String	address
static int	DATA_SOURCE_EXCEPTION_EVENT
private org.apache.commons.logging.Log	log
static int	PDU_EXCEPTION_EVENT
private org.snmp4j.Snmp	snmp
private org.snmp4j.Target	target
private Version	version
private SnmpDataSourceVO	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
SnmpDataSourceRT(SnmpDataSourceVO vo)

Method Summary

Modifier and Type	Method and Description
protected void	doPoll(long time)
private void	doPollImpl(long time)
(package private) java.lang.String	getAddress()
(package private) java.lang.String	getLocalAddress()
private SnmpPointLocatorVO	getLocatorVO(DataPointRT dp)
private org.snmp4j.smi.OID	getOid(DataPointRT dp)
(package private) int	getTrapPort()
void	initialize()
(package private) void	receivedTrap(org.snmp4j.PDU trap)
void	setPointValue(DataPointRT dataPoint, PointValueTime valueTime, SetPointSource source)
void	terminate()
private void	updatePoint(DataPointRT dp, org.snmp4j.smi.Variable variable, long time)
private com.serotonin.web.i18n.LocalizableMessage	validatePdu(org.snmp4j.PDU pdu)

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

DATA_SOURCE_EXCEPTION_EVENT

public static final int DATA_SOURCE_EXCEPTION_EVENT

See Also:

Constant Field Values

PDU_EXCEPTION_EVENT

public static final int PDU_EXCEPTION_EVENT

See Also:

Constant Field Values

log

private final org.apache.commons.logging.Log log

vo

private final SnmpDataSourceVO vo

version

private final Version version

address

private java.lang.String address

target

private org.snmp4j.Target target

snmp

private org.snmp4j.Snmp snmp

Constructor Detail

SnmpDataSourceRT

public SnmpDataSourceRT(SnmpDataSourceVO vo)

Method Detail

setPointValue

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

Specified by:

setPointValue in class DataSourceRT

doPoll

protected void doPoll(long time)

Specified by:

doPoll in class PollingDataSource

doPollImpl

private void doPollImpl(long time)
                 throws java.io.IOException

Throws:

java.io.IOException

validatePdu

private com.serotonin.web.i18n.LocalizableMessage validatePdu(org.snmp4j.PDU pdu)

getOid

private org.snmp4j.smi.OID getOid(DataPointRT dp)

getLocatorVO

private SnmpPointLocatorVO getLocatorVO(DataPointRT dp)

getTrapPort

int getTrapPort()

getLocalAddress

java.lang.String getLocalAddress()

getAddress

java.lang.String getAddress()

receivedTrap

void receivedTrap(org.snmp4j.PDU trap)

updatePoint

private void updatePoint(DataPointRT dp,
                         org.snmp4j.smi.Variable variable,
                         long time)

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