org.opennms.netmgt.linkd

Class AbstractQueryManager

java.lang.Object

org.opennms.netmgt.linkd.AbstractQueryManager

All Implemented Interfaces:

QueryManager

Direct Known Subclasses:

HibernateEventWriter

public abstract class AbstractQueryManager
extends Object
implements QueryManager

Field Summary

Fields

Modifier and Type	Field and Description
protected Linkd	m_linkd

Fields inherited from interface org.opennms.netmgt.linkd.QueryManager

SNMP_DOT1D_FDB_STATUS_INVALID, SNMP_DOT1D_FDB_STATUS_LEARNED, SNMP_DOT1D_FDB_STATUS_MGMT, SNMP_DOT1D_FDB_STATUS_OTHER, SNMP_DOT1D_FDB_STATUS_SELF, SNMP_IF_TYPE_ETHERNET, SNMP_IF_TYPE_L2_VLAN, SNMP_IF_TYPE_L3_VLAN, SNMP_IF_TYPE_PROP_VIRTUAL

Constructor Summary

Constructors

Constructor and Description
AbstractQueryManager()

Method Summary

Modifier and Type	Method and Description
protected abstract void	deleteOlderData(Date now, int nodeid)
abstract AtInterfaceDao	getAtInterfaceDao()
protected abstract OnmsSnmpInterface	getFromSysnameAgentCircuitId(String lldpRemSysname, String lldpRemPortid)
protected abstract OnmsSnmpInterface	getFromSysnameIfAlias(String lldpRemSysname, String lldpRemPortid)
protected abstract OnmsSnmpInterface	getFromSysnameIfIndex(String lldpRemSysname, Integer lldpRemPortid)
protected abstract OnmsSnmpInterface	getFromSysnameIfName(String lldpRemSysname, String lldpRemPortid)
protected abstract OnmsSnmpInterface	getFromSysnameIpAddress(String lldpRemSysname, InetAddress lldpRemIpAddr)
protected abstract OnmsSnmpInterface	getFromSysnameMacAddress(String lldpRemSysname, String lldpRemPortid)
protected abstract OnmsSnmpInterface	getFromSysnamePortComponent(String lldpRemSysname, String lldpRemPortid)
protected Integer	getIfIndex(Integer nodeid, String ipaddress)
protected abstract int	getIfIndexByName(int targetCdpNodeId, String cdpTargetDevicePort)
abstract IpInterfaceDao	getIpInterfaceDao()
Linkd	getLinkd()
protected OnmsNode	getNode(Integer nodeId)
abstract NodeDao	getNodeDao()
protected abstract List<OnmsNode>	getNodeidFromIp(InetAddress cdpTargetIpAddr)
protected OnmsStpNode	getOnmsStpNode(OnmsNode onmsNode, LinkableNode node, Date scanTime, OnmsVlan vlan, SnmpVlanCollection snmpVlanColl)
protected abstract Map<Integer,String>	getPhysAddrs(int nodeId)
protected abstract List<RouterInterface>	getRouteInterface(InetAddress nexthop, int ifindex)
protected abstract int	getSnmpIfType(int nodeId, Integer ifindex)
abstract SnmpInterfaceDao	getSnmpInterfaceDao()
protected abstract void	markOldDataInactive(Date now, int nodeid)
protected void	processCdp(LinkableNode node, SnmpCollection snmpcoll, Date scanTime)
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)
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)
protected void	processVlanTable(OnmsNode onmsNode, LinkableNode node, SnmpCollection snmpcoll, Date scanTime)
protected void	processWifi(LinkableNode node, SnmpCollection snmpcoll, Date scanTime)
protected abstract void	saveAtInterface(OnmsAtInterface saveMe)
protected abstract void	saveIpRouteInterface(OnmsIpRouteInterface ipRouteInterface)
protected abstract void	saveStpInterface(OnmsStpInterface stpInterface)
protected abstract void	saveStpNode(OnmsStpNode stpNode)
protected abstract void	saveVlan(OnmsVlan vlan)
protected void	sendNewSuspectEvent(InetAddress ipaddress, InetAddress ipowner, String name)
void	setLinkd(Linkd linkd)
protected void	storeSnmpVlanCollection(OnmsNode onmsNode, LinkableNode node, OnmsVlan vlan, SnmpVlanCollection snmpVlanColl, Date scanTime)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.opennms.netmgt.linkd.QueryManager

getSnmpNode, getSnmpNodeList, storeDiscoveryLink, storeSnmpCollection, update, updateDeletedNodes, updateForInterface

Field Detail

m_linkd

protected Linkd m_linkd

Constructor Detail

AbstractQueryManager

public AbstractQueryManager()

Method Detail

setLinkd

public void setLinkd(Linkd linkd)

Specified by:

setLinkd in interface QueryManager

getLinkd

public Linkd getLinkd()

Specified by:

getLinkd in interface QueryManager

sendNewSuspectEvent

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

getNodeDao

public abstract NodeDao getNodeDao()

getIpInterfaceDao

public abstract IpInterfaceDao getIpInterfaceDao()

getAtInterfaceDao

public abstract AtInterfaceDao getAtInterfaceDao()

getSnmpInterfaceDao

public abstract SnmpInterfaceDao getSnmpInterfaceDao()

getIfIndexByName

protected abstract int getIfIndexByName(int targetCdpNodeId,
                                        String cdpTargetDevicePort)

getNodeidFromIp

protected abstract List<OnmsNode> getNodeidFromIp(InetAddress cdpTargetIpAddr)

getRouteInterface

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

getSnmpIfType

protected abstract int getSnmpIfType(int nodeId,
                                     Integer ifindex)

saveIpRouteInterface

protected abstract void saveIpRouteInterface(OnmsIpRouteInterface ipRouteInterface)

saveVlan

protected abstract void saveVlan(OnmsVlan vlan)

saveStpNode

protected abstract void saveStpNode(OnmsStpNode stpNode)

saveStpInterface

protected abstract void saveStpInterface(OnmsStpInterface stpInterface)

saveAtInterface

protected abstract void saveAtInterface(OnmsAtInterface saveMe)

getPhysAddrs

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

markOldDataInactive

protected abstract void markOldDataInactive(Date now,
                                            int nodeid)

deleteOlderData

protected abstract void deleteOlderData(Date now,
                                        int nodeid)

getNode

protected OnmsNode getNode(Integer nodeId)

processIpNetToMediaTable

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

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)

getFromSysnamePortComponent

protected abstract OnmsSnmpInterface getFromSysnamePortComponent(String lldpRemSysname,
                                                                 String lldpRemPortid)

getFromSysnameAgentCircuitId

protected abstract OnmsSnmpInterface getFromSysnameAgentCircuitId(String lldpRemSysname,
                                                                  String lldpRemPortid)

getFromSysnameIfName

protected abstract OnmsSnmpInterface getFromSysnameIfName(String lldpRemSysname,
                                                          String lldpRemPortid)

getFromSysnameIfAlias

protected abstract OnmsSnmpInterface getFromSysnameIfAlias(String lldpRemSysname,
                                                           String lldpRemPortid)

getFromSysnameIpAddress

protected abstract OnmsSnmpInterface getFromSysnameIpAddress(String lldpRemSysname,
                                                             InetAddress lldpRemIpAddr)

getFromSysnameMacAddress

protected abstract OnmsSnmpInterface getFromSysnameMacAddress(String lldpRemSysname,
                                                              String lldpRemPortid)

getFromSysnameIfIndex

protected abstract OnmsSnmpInterface getFromSysnameIfIndex(String lldpRemSysname,
                                                           Integer lldpRemPortid)

processCdp

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

processRouteTable

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

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)

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)