Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

org.opennms.netmgt.linkd
Class AbstractQueryManager

java.lang.Object
  extended by org.opennms.netmgt.linkd.AbstractQueryManager
All Implemented Interfaces:
QueryManager
Direct Known Subclasses:
DbEventWriter, HibernateEventWriter
public abstract class AbstractQueryManager
extends Object
implements QueryManager

Field Summary
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
AbstractQueryManager()
           
 
Method Summary
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
Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD
Copyright © 2011. All Rights Reserved.