public abstract class AbstractQueryManager extends Object implements QueryManager
Modifier and Type | Field and Description |
---|---|
protected Linkd |
m_linkd |
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 and Description |
---|
AbstractQueryManager() |
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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getSnmpNode, getSnmpNodeList, storeDiscoveryLink, storeSnmpCollection, update, updateDeletedNodes, updateForInterface
protected Linkd m_linkd
public void setLinkd(Linkd linkd)
setLinkd
in interface QueryManager
public Linkd getLinkd()
getLinkd
in interface QueryManager
protected void sendNewSuspectEvent(InetAddress ipaddress, InetAddress ipowner, String name)
public abstract NodeDao getNodeDao()
public abstract IpInterfaceDao getIpInterfaceDao()
public abstract AtInterfaceDao getAtInterfaceDao()
protected abstract int getIfIndexByName(Connection dbConn, int targetCdpNodeId, String cdpTargetDevicePort) throws SQLException
SQLException
protected abstract int getNodeidFromIp(Connection dbConn, InetAddress cdpTargetIpAddr) throws SQLException
SQLException
protected abstract RouterInterface getNodeidMaskFromIp(Connection dbConn, InetAddress nexthop) throws SQLException
SQLException
protected abstract RouterInterface getNodeFromIp(Connection dbConn, InetAddress nexthop) throws SQLException
SQLException
protected abstract int getSnmpIfType(Connection dbConn, int nodeId, Integer ifindex) throws SQLException
SQLException
protected abstract void saveIpRouteInterface(Connection dbConn, OnmsIpRouteInterface ipRouteInterface) throws SQLException
SQLException
protected abstract void saveVlan(Connection dbConn, OnmsVlan vlan) throws SQLException
SQLException
protected abstract void saveStpNode(Connection dbConn, OnmsStpNode stpNode) throws SQLException
SQLException
protected abstract void saveStpInterface(Connection dbConn, OnmsStpInterface stpInterface) throws SQLException
SQLException
protected abstract List<String> getPhysAddrs(int nodeId, DBUtils d, Connection dbConn) throws SQLException
SQLException
protected abstract void markOldDataInactive(Connection dbConn, Timestamp now, int nodeid) throws SQLException
SQLException
protected OnmsNode getNode(Integer nodeId) throws SQLException
SQLException
protected void processIpNetToMediaTable(LinkableNode node, SnmpCollection snmpcoll, Connection dbConn, Timestamp scanTime) throws SQLException
SQLException
protected void processCdpCacheTable(LinkableNode node, SnmpCollection snmpcoll, Connection dbConn, Timestamp scanTime) throws SQLException
SQLException
protected void processRouteTable(LinkableNode node, SnmpCollection snmpcoll, Connection dbConn, Timestamp scanTime) throws SQLException
SQLException
protected void processVlanTable(LinkableNode node, SnmpCollection snmpcoll, Connection dbConn, Timestamp scanTime) throws SQLException
SQLException
protected void processDot1DBase(LinkableNode node, SnmpCollection snmpcoll, DBUtils d, Connection dbConn, Timestamp scanTime, OnmsVlan vlan, org.opennms.netmgt.linkd.SnmpVlanCollection snmpVlanColl) throws SQLException
SQLException
protected void processQBridgeDot1dTpFdbTable(LinkableNode node, 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) throws SQLException
SQLException
protected void processDot1DBasePortTable(LinkableNode node, SnmpCollection snmpcoll, Connection dbConn, Timestamp scanTime, OnmsVlan vlan, org.opennms.netmgt.linkd.SnmpVlanCollection snmpVlanColl) throws SQLException
SQLException
protected void processStpNode(LinkableNode node, SnmpCollection snmpcoll, Connection dbConn, Timestamp scanTime, OnmsVlan vlan, org.opennms.netmgt.linkd.SnmpVlanCollection snmpVlanColl) throws SQLException
SQLException
Copyright © 2015. All Rights Reserved.