org.opennms.netmgt.linkd

Class AbstractQueryManager

java.lang.Object

org.opennms.netmgt.linkd.AbstractQueryManager

All Implemented Interfaces:

QueryManager

Direct Known Subclasses:

DbEventWriter, 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

ACTION_DELETE, ACTION_UPTODATE, CDP_ADDRESS_TYPE_IP_ADDRESS, 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

Constructor Summary

Constructors

Constructor and Description
AbstractQueryManager()

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract void	deleteOlderData(Connection dbConn, Timestamp now, int nodeid)
abstract AtInterfaceDao	getAtInterfaceDao()
protected Integer	getFromSysnameAgentCircuitId(String lldpRemSysname, String lldpRemPortid)
protected Integer	getFromSysnameIfAlias(String lldpRemSysname, String lldpRemPortid)
protected Integer	getFromSysnameIfName(String lldpRemSysname, String lldpRemPortid)
protected abstract Integer	getFromSysnameIpAddress(String lldpRemSysname, InetAddress lldpRemIpAddr)
protected Integer	getFromSysnameMacAddress(String lldpRemSysname, String lldpRemPortid)
protected Integer	getFromSysnamePortComponent(String lldpRemSysname, String lldpRemPortid)
protected Integer	getIfIndex(Integer nodeid, String ipaddress)
protected abstract int	getIfIndexByName(Connection dbConn, int targetCdpNodeId, String cdpTargetDevicePort)
abstract IpInterfaceDao	getIpInterfaceDao()
Linkd	getLinkd()
protected OnmsNode	getNode(Integer nodeId)
abstract NodeDao	getNodeDao()
protected abstract RouterInterface	getNodeFromIp(Connection dbConn, InetAddress nexthop)
protected abstract List<Integer>	getNodeidFromIp(Connection dbConn, InetAddress cdpTargetIpAddr)
protected abstract RouterInterface	getNodeidMaskFromIp(Connection dbConn, InetAddress nexthop)
protected abstract List<String>	getPhysAddrs(int nodeId, DBUtils d, Connection dbConn)
protected abstract int	getSnmpIfType(Connection dbConn, int nodeId, Integer ifindex)
abstract SnmpInterfaceDao	getSnmpInterfaceDao()
protected abstract void	markOldDataInactive(Connection dbConn, Timestamp now, int nodeid)
protected void	processCdpCacheTable(LinkableNode node, SnmpCollection snmpcoll, Connection dbConn, Timestamp scanTime)
protected void	processDot1DBase(LinkableNode node, SnmpCollection snmpcoll, DBUtils d, Connection dbConn, Timestamp scanTime, OnmsVlan vlan, org.opennms.netmgt.linkd.SnmpVlanCollection snmpVlanColl)
protected Map<Integer,OnmsStpInterface>	processDot1DBasePortTable(OnmsNode onmsNode, LinkableNode node, SnmpCollection snmpcoll, Timestamp scanTime, OnmsVlan vlan, org.opennms.netmgt.linkd.SnmpVlanCollection snmpVlanColl, Map<Integer,OnmsStpInterface> stpinterfaces)
protected void	processDot1DTpFdbTable(LinkableNode node, OnmsVlan vlan, org.opennms.netmgt.linkd.SnmpVlanCollection snmpVlanColl, Timestamp scanTime)
protected Map<Integer,OnmsStpInterface>	processDot1StpPortTable(LinkableNode node, SnmpCollection snmpcoll, Timestamp scanTime, OnmsVlan vlan, org.opennms.netmgt.linkd.SnmpVlanCollection snmpVlanColl, Map<Integer,OnmsStpInterface> stpinterfaces)
protected void	processIpNetToMediaTable(LinkableNode node, SnmpCollection snmpcoll, Connection dbConn, Timestamp scanTime)
protected void	processLldp(LinkableNode node, SnmpCollection snmpcoll, Connection dbConn, Timestamp scanTime)
protected void	processOspf(LinkableNode node, SnmpCollection snmpcoll, Connection dbConn, Timestamp scanTime)
protected void	processQBridgeDot1dTpFdbTable(LinkableNode node, OnmsVlan vlan, org.opennms.netmgt.linkd.SnmpVlanCollection snmpVlanColl)
protected void	processRouteTable(LinkableNode node, SnmpCollection snmpcoll, Connection dbConn, Timestamp scanTime)
protected void	processStpInterfaces(LinkableNode node, SnmpCollection snmpcoll, Connection dbConn, Map<Integer,OnmsStpInterface> stpinterfaces)
protected void	processStpNode(OnmsNode onmsNode, LinkableNode node, SnmpCollection snmpcoll, Connection dbConn, Timestamp scanTime, OnmsVlan vlan, org.opennms.netmgt.linkd.SnmpVlanCollection snmpVlanColl)
protected void	processVlanTable(LinkableNode node, SnmpCollection snmpcoll, Connection dbConn, Timestamp scanTime)
protected abstract void	saveIpRouteInterface(Connection dbConn, OnmsIpRouteInterface ipRouteInterface)
protected abstract void	saveStpInterface(Connection dbConn, OnmsStpInterface stpInterface)
protected abstract void	saveStpNode(Connection dbConn, OnmsStpNode stpNode)
protected abstract void	saveVlan(Connection dbConn, OnmsVlan vlan)
protected void	sendNewSuspectEvent(InetAddress ipaddress, InetAddress ipowner, String name)
void	setLinkd(Linkd linkd)

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(Connection dbConn,
                   int targetCdpNodeId,
                   String cdpTargetDevicePort)
                                 throws SQLException

Throws:

SQLException

getNodeidFromIp

protected abstract List<Integer> getNodeidFromIp(Connection dbConn,
                            InetAddress cdpTargetIpAddr)
                                          throws SQLException

Throws:

SQLException

getNodeidMaskFromIp

protected abstract RouterInterface getNodeidMaskFromIp(Connection dbConn,
                                  InetAddress nexthop)
                                                throws SQLException

Throws:

SQLException

getNodeFromIp

protected abstract RouterInterface getNodeFromIp(Connection dbConn,
                            InetAddress nexthop)
                                          throws SQLException

Throws:

SQLException

getSnmpIfType

protected abstract int getSnmpIfType(Connection dbConn,
                int nodeId,
                Integer ifindex)
                              throws SQLException

Throws:

SQLException

saveIpRouteInterface

protected abstract void saveIpRouteInterface(Connection dbConn,
                        OnmsIpRouteInterface ipRouteInterface)
                                      throws SQLException

Throws:

SQLException

saveVlan

protected abstract void saveVlan(Connection dbConn,
            OnmsVlan vlan)
                          throws SQLException

Throws:

SQLException

saveStpNode

protected abstract void saveStpNode(Connection dbConn,
               OnmsStpNode stpNode)
                             throws SQLException

Throws:

SQLException

saveStpInterface

protected abstract void saveStpInterface(Connection dbConn,
                    OnmsStpInterface stpInterface)
                                  throws SQLException

Throws:

SQLException

getPhysAddrs

protected abstract List<String> getPhysAddrs(int nodeId,
                        DBUtils d,
                        Connection dbConn)
                                      throws SQLException

Throws:

SQLException

markOldDataInactive

protected abstract void markOldDataInactive(Connection dbConn,
                       Timestamp now,
                       int nodeid)
                                     throws SQLException

Throws:

SQLException

deleteOlderData

protected abstract void deleteOlderData(Connection dbConn,
                   Timestamp now,
                   int nodeid)
                                 throws SQLException

Throws:

SQLException

getNode

protected OnmsNode getNode(Integer nodeId)
                    throws SQLException

Throws:

SQLException

processIpNetToMediaTable

protected void processIpNetToMediaTable(LinkableNode node,
                            SnmpCollection snmpcoll,
                            Connection dbConn,
                            Timestamp scanTime)
                                 throws SQLException

Throws:

SQLException

getIfIndex

protected Integer getIfIndex(Integer nodeid,
                 String ipaddress)

processOspf

protected void processOspf(LinkableNode node,
               SnmpCollection snmpcoll,
               Connection dbConn,
               Timestamp scanTime)

processLldp

protected void processLldp(LinkableNode node,
               SnmpCollection snmpcoll,
               Connection dbConn,
               Timestamp scanTime)

getFromSysnameAgentCircuitId

protected Integer getFromSysnameAgentCircuitId(String lldpRemSysname,
                                   String lldpRemPortid)

getFromSysnameIfName

protected Integer getFromSysnameIfName(String lldpRemSysname,
                           String lldpRemPortid)

getFromSysnameIpAddress

protected abstract Integer getFromSysnameIpAddress(String lldpRemSysname,
                              InetAddress lldpRemIpAddr)

getFromSysnameMacAddress

protected Integer getFromSysnameMacAddress(String lldpRemSysname,
                               String lldpRemPortid)

getFromSysnamePortComponent

protected Integer getFromSysnamePortComponent(String lldpRemSysname,
                                  String lldpRemPortid)

getFromSysnameIfAlias

protected Integer getFromSysnameIfAlias(String lldpRemSysname,
                            String lldpRemPortid)

processCdpCacheTable

protected void processCdpCacheTable(LinkableNode node,
                        SnmpCollection snmpcoll,
                        Connection dbConn,
                        Timestamp scanTime)
                             throws SQLException

Throws:

SQLException

processRouteTable

protected void processRouteTable(LinkableNode node,
                     SnmpCollection snmpcoll,
                     Connection dbConn,
                     Timestamp scanTime)
                          throws SQLException

Throws:

SQLException

processVlanTable

protected void processVlanTable(LinkableNode node,
                    SnmpCollection snmpcoll,
                    Connection dbConn,
                    Timestamp scanTime)
                         throws SQLException

Throws:

SQLException

processDot1DBase

protected void processDot1DBase(LinkableNode node,
                    SnmpCollection snmpcoll,
                    DBUtils d,
                    Connection dbConn,
                    Timestamp scanTime,
                    OnmsVlan vlan,
                    org.opennms.netmgt.linkd.SnmpVlanCollection snmpVlanColl)
                         throws SQLException

Throws:

SQLException

processQBridgeDot1dTpFdbTable

protected void processQBridgeDot1dTpFdbTable(LinkableNode node,
                                 OnmsVlan vlan,
                                 org.opennms.netmgt.linkd.SnmpVlanCollection snmpVlanColl)

processDot1DTpFdbTable

protected void processDot1DTpFdbTable(LinkableNode node,
                          OnmsVlan vlan,
                          org.opennms.netmgt.linkd.SnmpVlanCollection snmpVlanColl,
                          Timestamp scanTime)

processDot1StpPortTable

protected Map<Integer,OnmsStpInterface> processDot1StpPortTable(LinkableNode node,
                                                    SnmpCollection snmpcoll,
                                                    Timestamp scanTime,
                                                    OnmsVlan vlan,
                                                    org.opennms.netmgt.linkd.SnmpVlanCollection snmpVlanColl,
                                                    Map<Integer,OnmsStpInterface> stpinterfaces)
                                                         throws SQLException

Throws:

SQLException

processStpInterfaces

protected void processStpInterfaces(LinkableNode node,
                        SnmpCollection snmpcoll,
                        Connection dbConn,
                        Map<Integer,OnmsStpInterface> stpinterfaces)
                             throws SQLException

Throws:

SQLException

processDot1DBasePortTable

protected Map<Integer,OnmsStpInterface> processDot1DBasePortTable(OnmsNode onmsNode,
                                                      LinkableNode node,
                                                      SnmpCollection snmpcoll,
                                                      Timestamp scanTime,
                                                      OnmsVlan vlan,
                                                      org.opennms.netmgt.linkd.SnmpVlanCollection snmpVlanColl,
                                                      Map<Integer,OnmsStpInterface> stpinterfaces)
                                                           throws SQLException

Throws:

SQLException

processStpNode

protected void processStpNode(OnmsNode onmsNode,
                  LinkableNode node,
                  SnmpCollection snmpcoll,
                  Connection dbConn,
                  Timestamp scanTime,
                  OnmsVlan vlan,
                  org.opennms.netmgt.linkd.SnmpVlanCollection snmpVlanColl)
                       throws SQLException

Throws:

SQLException