org.opennms.netmgt.linkd

Class HibernateEventWriter

java.lang.Object

org.opennms.netmgt.linkd.HibernateEventWriter

All Implemented Interfaces:

QueryManager

public class HibernateEventWriter
extends Object
implements QueryManager

Field Summary

Fields

Modifier and Type	Field and Description
static int	SNMP_DOT1D_FDB_STATUS_INVALID The status of the info in FDB table entry The status of this entry.
static int	SNMP_DOT1D_FDB_STATUS_LEARNED The status of the info in FDB table entry The status of this entry.
static int	SNMP_DOT1D_FDB_STATUS_MGMT mgmt(5) : the value of the corresponding instance of dot1dTpFdbAddress is also the value of an existing instance of dot1dStaticAddress.
static int	SNMP_DOT1D_FDB_STATUS_OTHER The status of the info in FDB table entry The meanings of the value is other(1): none of the following.
static int	SNMP_DOT1D_FDB_STATUS_SELF The status of the info in FDB table entry The status of this entry.
static int	SNMP_IF_TYPE_ETHERNET
static int	SNMP_IF_TYPE_L2_VLAN
static int	SNMP_IF_TYPE_L3_VLAN
static int	SNMP_IF_TYPE_PROP_VIRTUAL

Constructor Summary

Constructors

Constructor and Description
HibernateEventWriter()

Method Summary

Modifier and Type	Method and Description
protected void	deleteOlderData(Date scanTime, int nodeid)
AtInterfaceDao	getAtInterfaceDao()
DataLinkInterfaceDao	getDataLinkInterfaceDao()
protected OnmsSnmpInterface	getFromSysnameAgentCircuitId(String lldpRemSysname, String lldpRemPortid)
protected OnmsSnmpInterface	getFromSysnameIfAlias(String lldpRemSysname, String lldpRemPortid)
protected OnmsSnmpInterface	getFromSysnameIfIndex(String lldpRemSysname, Integer lldpRemPortid)
protected OnmsSnmpInterface	getFromSysnameIfName(String lldpRemSysname, String lldpRemPortid)
protected OnmsSnmpInterface	getFromSysnameIpAddress(String lldpRemSysname, InetAddress lldpRemPortid)
protected OnmsSnmpInterface	getFromSysnameMacAddress(String lldpRemSysname, String lldpRemPortid)
protected OnmsSnmpInterface	getFromSysnamePortComponent(String lldpRemSysname, String lldpRemPortid)
protected Integer	getIfIndex(Integer nodeid, String ipaddress)
protected int	getIfIndexByName(int targetCdpNodeId, String cdpTargetDevicePort)
IpInterfaceDao	getIpInterfaceDao()
IpRouteInterfaceDao	getIpRouteInterfaceDao()
NodeDao	getNodeDao()
protected List<OnmsNode>	getNodeidFromIp(InetAddress cdpTargetIpAddr)
protected OnmsStpNode	getOnmsStpNode(OnmsNode onmsNode, LinkableNode node, Date scanTime, OnmsVlan vlan, SnmpVlanCollection snmpVlanColl)
protected Map<Integer,String>	getPhysAddrs(int nodeId)
protected List<RouterInterface>	getRouteInterface(InetAddress nexthop, int ifindex)
protected int	getSnmpIfType(int nodeId, Integer ifIndex)
SnmpInterfaceDao	getSnmpInterfaceDao()
LinkableSnmpNode	getSnmpNode(int nodeid) getSnmpNode
List<LinkableSnmpNode>	getSnmpNodeList() getSnmpNodeList
StpInterfaceDao	getStpInterfaceDao()
StpNodeDao	getStpNodeDao()
VlanDao	getVlanDao()
protected void	markOldDataInactive(Date scanTime, int nodeid)
protected void	processCdp(LinkableNode node, SnmpCollection snmpcoll, Date scanTime, Linkd linkd)
protected Map<Integer,OnmsStpInterface>	processDot1DBasePortTable(OnmsNode onmsNode, LinkableNode node, Date scanTime, OnmsVlan vlan, SnmpVlanCollection snmpVlanColl, Map<Integer,OnmsStpInterface> stpinterfaces)
protected void	processDot1DTpFdbTable(LinkableNode node, OnmsVlan vlan, SnmpVlanCollection snmpVlanColl, Date scanTime)
protected Map<Integer,OnmsStpInterface>	processDot1StpPortTable(LinkableNode node, Date scanTime, OnmsVlan vlan, SnmpVlanCollection snmpVlanColl, Map<Integer,OnmsStpInterface> stpinterfaces)
protected void	processIpNetToMediaTable(LinkableNode node, SnmpCollection snmpcoll, Date scanTime, Linkd linkd)
protected void	processIsis(LinkableNode node, SnmpCollection snmpcoll, Date scanTime)
protected void	processLldp(LinkableNode node, SnmpCollection snmpcoll, Date scanTime)
protected void	processOspf(LinkableNode node, SnmpCollection snmpcoll, Date scanTime)
protected void	processQBridgeDot1dTpFdbTable(LinkableNode node, OnmsVlan vlan, SnmpVlanCollection snmpVlanColl)
protected void	processRouteTable(OnmsNode onmsNode, LinkableNode node, SnmpCollection snmpcoll, Date scanTime, Linkd linkd)
protected void	processVlanTable(OnmsNode onmsNode, LinkableNode node, SnmpCollection snmpcoll, Date scanTime)
protected void	processWifi(LinkableNode node, SnmpCollection snmpcoll, Date scanTime)
protected void	saveAtInterface(OnmsAtInterface saveMe)
protected void	saveIpRouteInterface(OnmsIpRouteInterface saveMe)
protected void	saveStpInterface(OnmsStpInterface saveMe)
protected void	saveStpNode(OnmsStpNode saveMe)
protected void	saveVlan(OnmsVlan saveMe)
protected void	sendNewSuspectEvent(InetAddress ipaddress, InetAddress ipowner, String name, Linkd linkd)
void	setAtInterfaceDao(AtInterfaceDao atInterfaceDao)
void	setDataLinkInterfaceDao(DataLinkInterfaceDao dataLinkInterfaceDao)
void	setIpInterfaceDao(IpInterfaceDao ipInterfaceDao)
void	setIpRouteInterfaceDao(IpRouteInterfaceDao ipRouteInterfaceDao)
void	setNodeDao(NodeDao nodeDao)
void	setSnmpInterfaceDao(SnmpInterfaceDao snmpInterfaceDao)
void	setStpInterfaceDao(StpInterfaceDao stpInterfaceDao)
void	setStpNodeDao(StpNodeDao stpNodeDao)
void	setVlanDao(VlanDao vlanDao)
void	storeDiscoveryLink(DiscoveryLink discoveryLink) storeDiscoveryLink
LinkableNode	storeSnmpCollection(LinkableNode node, SnmpCollection snmpColl, Linkd linkd) storeSnmpCollection
protected void	storeSnmpVlanCollection(OnmsNode onmsNode, LinkableNode node, OnmsVlan vlan, SnmpVlanCollection snmpVlanColl, Date scanTime, Linkd linkd)
void	update(int nodeid, OnmsArpInterface.StatusType action, Set<String> activePackages) update
void	updateDeletedNodes() updateDeletedNodes
void	updateForInterface(int nodeid, String ipAddr, int ifIndex, OnmsArpInterface.StatusType action, Set<String> activePackages) updateForInterface

Methods inherited from class java.lang.Object

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

Field Detail

SNMP_IF_TYPE_ETHERNET

public static final int SNMP_IF_TYPE_ETHERNET

See Also:

Constant Field Values

SNMP_IF_TYPE_PROP_VIRTUAL

public static final int SNMP_IF_TYPE_PROP_VIRTUAL

See Also:

Constant Field Values

SNMP_IF_TYPE_L2_VLAN

public static final int SNMP_IF_TYPE_L2_VLAN

See Also:

Constant Field Values

SNMP_IF_TYPE_L3_VLAN

public static final int SNMP_IF_TYPE_L3_VLAN

See Also:

Constant Field Values

SNMP_DOT1D_FDB_STATUS_OTHER

public static final int SNMP_DOT1D_FDB_STATUS_OTHER

The status of the info in FDB table entry The meanings of the value is other(1): none of the following. This would include the case where some other MIB object (not the corresponding instance of dot1dTpFdbPort, nor an entry in the dot1dStaticTable) is being used to determine if and how frames addressed to the value of the corresponding instance of dot1dTpFdbAddress are being forwarded.

See Also:

Constant Field Values

SNMP_DOT1D_FDB_STATUS_INVALID

public static final int SNMP_DOT1D_FDB_STATUS_INVALID

The status of the info in FDB table entry The status of this entry. The meanings of the values are: invalid(2) : this entry is not longer valid (e.g., it was learned but has since aged-out), but has not yet been flushed from the table.

See Also:

Constant Field Values

SNMP_DOT1D_FDB_STATUS_LEARNED

public static final int SNMP_DOT1D_FDB_STATUS_LEARNED

The status of the info in FDB table entry The status of this entry. The meanings of the values are: learned(3) : the value of the corresponding instance of dot1dTpFdbPort was learned, and is being used.

See Also:

Constant Field Values

SNMP_DOT1D_FDB_STATUS_SELF

public static final int SNMP_DOT1D_FDB_STATUS_SELF

The status of the info in FDB table entry The status of this entry. The meanings of the values are: self(4) : the value of the corresponding instance of dot1dTpFdbAddress represents one of the bridge's addresses. The corresponding instance of dot1dTpFdbPort indicates which of the bridge's ports has this address.

See Also:

Constant Field Values

SNMP_DOT1D_FDB_STATUS_MGMT

public static final int SNMP_DOT1D_FDB_STATUS_MGMT

mgmt(5) : the value of the corresponding instance of dot1dTpFdbAddress is also the value of an existing instance of dot1dStaticAddress.

See Also:

Constant Field Values

Constructor Detail

HibernateEventWriter

public HibernateEventWriter()

Method Detail

getNodeDao

public NodeDao getNodeDao()

setNodeDao

public void setNodeDao(NodeDao nodeDao)

getIpInterfaceDao

public IpInterfaceDao getIpInterfaceDao()

setIpInterfaceDao

public void setIpInterfaceDao(IpInterfaceDao ipInterfaceDao)

getSnmpInterfaceDao

public SnmpInterfaceDao getSnmpInterfaceDao()

setSnmpInterfaceDao

public void setSnmpInterfaceDao(SnmpInterfaceDao snmpInterfaceDao)

getAtInterfaceDao

public AtInterfaceDao getAtInterfaceDao()

setAtInterfaceDao

public void setAtInterfaceDao(AtInterfaceDao atInterfaceDao)

getVlanDao

public VlanDao getVlanDao()

setVlanDao

public void setVlanDao(VlanDao vlanDao)

getStpNodeDao

public StpNodeDao getStpNodeDao()

setStpNodeDao

public void setStpNodeDao(StpNodeDao stpNodeDao)

getStpInterfaceDao

public StpInterfaceDao getStpInterfaceDao()

setStpInterfaceDao

public void setStpInterfaceDao(StpInterfaceDao stpInterfaceDao)

getIpRouteInterfaceDao

public IpRouteInterfaceDao getIpRouteInterfaceDao()

setIpRouteInterfaceDao

public void setIpRouteInterfaceDao(IpRouteInterfaceDao ipRouteInterfaceDao)

getDataLinkInterfaceDao

public DataLinkInterfaceDao getDataLinkInterfaceDao()

setDataLinkInterfaceDao

public void setDataLinkInterfaceDao(DataLinkInterfaceDao dataLinkInterfaceDao)

sendNewSuspectEvent

protected void sendNewSuspectEvent(InetAddress ipaddress,
                                   InetAddress ipowner,
                                   String name,
                                   Linkd linkd)

getSnmpNodeList

public List<LinkableSnmpNode> getSnmpNodeList()

Description copied from interface: QueryManager

getSnmpNodeList

Specified by:

getSnmpNodeList in interface QueryManager

Returns:

a List object.

getSnmpNode

public LinkableSnmpNode getSnmpNode(int nodeid)

Description copied from interface: QueryManager

getSnmpNode

Specified by:

getSnmpNode in interface QueryManager

Parameters:

nodeid - a int.

Returns:

a LinkableNode object.

updateDeletedNodes

public void updateDeletedNodes()

Description copied from interface: QueryManager

updateDeletedNodes

Specified by:

updateDeletedNodes in interface QueryManager

markOldDataInactive

protected void markOldDataInactive(Date scanTime,
                                   int nodeid)

deleteOlderData

protected void deleteOlderData(Date scanTime,
                               int nodeid)

storeSnmpCollection

@Transactional
public LinkableNode storeSnmpCollection(LinkableNode node,
                                                       SnmpCollection snmpColl,
                                                       Linkd linkd)

Description copied from interface: QueryManager

storeSnmpCollection

Specified by:

storeSnmpCollection in interface QueryManager

Parameters:

node - a LinkableNode object.

snmpColl - a SnmpCollection object.

Returns:

a LinkableNode object.

storeDiscoveryLink

@Transactional
public void storeDiscoveryLink(DiscoveryLink discoveryLink)

Description copied from interface: QueryManager

storeDiscoveryLink

Specified by:

storeDiscoveryLink in interface QueryManager

Parameters:

discoveryLink - a DiscoveryLink object.

update

public void update(int nodeid,
                   OnmsArpInterface.StatusType action,
                   Set<String> activePackages)

Description copied from interface: QueryManager

update

Specified by:

update in interface QueryManager

Parameters:

nodeid - a int.

action - a char.

updateForInterface

public void updateForInterface(int nodeid,
                               String ipAddr,
                               int ifIndex,
                               OnmsArpInterface.StatusType action,
                               Set<String> activePackages)

Description copied from interface: QueryManager

updateForInterface

Specified by:

updateForInterface in interface QueryManager

Parameters:

nodeid - a int.

ipAddr - a String object.

ifIndex - a int.

action - a char.

getIfIndexByName

protected int getIfIndexByName(int targetCdpNodeId,
                               String cdpTargetDevicePort)

getNodeidFromIp

protected List<OnmsNode> getNodeidFromIp(InetAddress cdpTargetIpAddr)

getRouteInterface

protected List<RouterInterface> getRouteInterface(InetAddress nexthop,
                                                  int ifindex)

getSnmpIfType

protected int getSnmpIfType(int nodeId,
                            Integer ifIndex)

getPhysAddrs

protected Map<Integer,String> getPhysAddrs(int nodeId)

saveIpRouteInterface

@Transactional
protected void saveIpRouteInterface(OnmsIpRouteInterface saveMe)

saveVlan

@Transactional
protected void saveVlan(OnmsVlan saveMe)

saveStpNode

@Transactional
protected void saveStpNode(OnmsStpNode saveMe)

saveStpInterface

@Transactional
protected void saveStpInterface(OnmsStpInterface saveMe)

saveAtInterface

@Transactional
protected void saveAtInterface(OnmsAtInterface saveMe)

getFromSysnameIpAddress

protected OnmsSnmpInterface getFromSysnameIpAddress(String lldpRemSysname,
                                                    InetAddress lldpRemPortid)

getFromSysnameIfName

protected OnmsSnmpInterface getFromSysnameIfName(String lldpRemSysname,
                                                 String lldpRemPortid)

getFromSysnameIfIndex

protected OnmsSnmpInterface getFromSysnameIfIndex(String lldpRemSysname,
                                                  Integer lldpRemPortid)

getFromSysnameMacAddress

protected OnmsSnmpInterface getFromSysnameMacAddress(String lldpRemSysname,
                                                     String lldpRemPortid)

getFromSysnameIfAlias

protected OnmsSnmpInterface getFromSysnameIfAlias(String lldpRemSysname,
                                                  String lldpRemPortid)

getFromSysnameAgentCircuitId

protected OnmsSnmpInterface getFromSysnameAgentCircuitId(String lldpRemSysname,
                                                         String lldpRemPortid)

getFromSysnamePortComponent

protected OnmsSnmpInterface getFromSysnamePortComponent(String lldpRemSysname,
                                                        String lldpRemPortid)

processIpNetToMediaTable

protected void processIpNetToMediaTable(LinkableNode node,
                                        SnmpCollection snmpcoll,
                                        Date scanTime,
                                        Linkd linkd)

getIfIndex

protected Integer getIfIndex(Integer nodeid,
                             String ipaddress)

processIsis

protected void processIsis(LinkableNode node,
                           SnmpCollection snmpcoll,
                           Date scanTime)

processWifi

protected void processWifi(LinkableNode node,
                           SnmpCollection snmpcoll,
                           Date scanTime)

processOspf

protected void processOspf(LinkableNode node,
                           SnmpCollection snmpcoll,
                           Date scanTime)

processLldp

protected void processLldp(LinkableNode node,
                           SnmpCollection snmpcoll,
                           Date scanTime)

processCdp

protected void processCdp(LinkableNode node,
                          SnmpCollection snmpcoll,
                          Date scanTime,
                          Linkd linkd)

processRouteTable

protected void processRouteTable(OnmsNode onmsNode,
                                 LinkableNode node,
                                 SnmpCollection snmpcoll,
                                 Date scanTime,
                                 Linkd linkd)

processVlanTable

protected void processVlanTable(OnmsNode onmsNode,
                                LinkableNode node,
                                SnmpCollection snmpcoll,
                                Date scanTime)

storeSnmpVlanCollection

protected void storeSnmpVlanCollection(OnmsNode onmsNode,
                                       LinkableNode node,
                                       OnmsVlan vlan,
                                       SnmpVlanCollection snmpVlanColl,
                                       Date scanTime,
                                       Linkd linkd)

processQBridgeDot1dTpFdbTable

protected void processQBridgeDot1dTpFdbTable(LinkableNode node,
                                             OnmsVlan vlan,
                                             SnmpVlanCollection snmpVlanColl)

processDot1DTpFdbTable

protected void processDot1DTpFdbTable(LinkableNode node,
                                      OnmsVlan vlan,
                                      SnmpVlanCollection snmpVlanColl,
                                      Date scanTime)

processDot1StpPortTable

protected Map<Integer,OnmsStpInterface> processDot1StpPortTable(LinkableNode node,
                                                                Date scanTime,
                                                                OnmsVlan vlan,
                                                                SnmpVlanCollection snmpVlanColl,
                                                                Map<Integer,OnmsStpInterface> stpinterfaces)

processDot1DBasePortTable

protected Map<Integer,OnmsStpInterface> processDot1DBasePortTable(OnmsNode onmsNode,
                                                                  LinkableNode node,
                                                                  Date scanTime,
                                                                  OnmsVlan vlan,
                                                                  SnmpVlanCollection snmpVlanColl,
                                                                  Map<Integer,OnmsStpInterface> stpinterfaces)

getOnmsStpNode

protected OnmsStpNode getOnmsStpNode(OnmsNode onmsNode,
                                     LinkableNode node,
                                     Date scanTime,
                                     OnmsVlan vlan,
                                     SnmpVlanCollection snmpVlanColl)