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
abstract AtInterfaceDao	getAtInterfaceDao()
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 int	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)
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 void	processDot1DBasePortTable(LinkableNode node, SnmpCollection snmpcoll, Connection dbConn, Timestamp scanTime, OnmsVlan vlan, org.opennms.netmgt.linkd.SnmpVlanCollection snmpVlanColl)
protected void	processDot1DTpFdbTable(LinkableNode node, OnmsVlan vlan, org.opennms.netmgt.linkd.SnmpVlanCollection snmpVlanColl, Timestamp scanTime)
protected void	processDot1StpPortTable(LinkableNode node, SnmpCollection snmpcoll, Connection dbConn, Timestamp scanTime, OnmsVlan vlan, org.opennms.netmgt.linkd.SnmpVlanCollection snmpVlanColl)
protected void	processIpNetToMediaTable(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	processStpNode(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()

getIfIndexByName

protected abstract int getIfIndexByName(Connection dbConn,
                   int targetCdpNodeId,
                   String cdpTargetDevicePort)
                                 throws SQLException

Throws:

SQLException

getNodeidFromIp

protected abstract int 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

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

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 void processDot1StpPortTable(LinkableNode node,
                           SnmpCollection snmpcoll,
                           Connection dbConn,
                           Timestamp scanTime,
                           OnmsVlan vlan,
                           org.opennms.netmgt.linkd.SnmpVlanCollection snmpVlanColl)
                                throws SQLException

Throws:

SQLException

processDot1DBasePortTable

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

Throws:

SQLException

processStpNode

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

Throws:

SQLException