hp.java

监控大型网络的软件。能够自动发现拓扑结构

package no.ntnu.nav.getDeviceData.deviceplugins.HP;

import java.util.*;

import no.ntnu.nav.logger.*;
import no.ntnu.nav.SimpleSnmp.*;
import no.ntnu.nav.ConfigParser.*;
import no.ntnu.nav.netboxinfo.*;
import no.ntnu.nav.getDeviceData.Netbox;
import no.ntnu.nav.getDeviceData.deviceplugins.*;
import no.ntnu.nav.getDeviceData.dataplugins.*;
import no.ntnu.nav.getDeviceData.dataplugins.Netbox.*;
import no.ntnu.nav.getDeviceData.dataplugins.Module.*;
import no.ntnu.nav.getDeviceData.dataplugins.Swport.*;

/**
 * <p>
 * DeviceHandler for collecting switch port data from HP switches.
 * </p>
 *
 * <p>
 * This plugin handles the following OID keys:
 * </p>
 *
 * <p>
 * <ui>
 *  <li>ifSerial</li>
 *  <li>hpFwVer</li>
 *  <li>hpSwVer</li>
 *  <li>hpPortType</li>
 *  <li>hpVlan</li>
 * </ul>
 * </p>
 *
 * <p>
 * <b>Note:</b> Both ifSerial and hpPortType are required for any OID fetching to take place.
 * </p>
 */

public class HP implements DeviceHandler
{

	public static final int HANDLE_PRI_HP = -22;

	private static String[] canHandleOids = {
		"ifSerial",
		"hpFwVer",
		"hpSwVer",
		"hpPortType",
		"hpVlan"
	};

	private SimpleSnmp sSnmp;

	public int canHandleDevice(Netbox nb) {
		int v = nb.isSupportedOids(canHandleOids) ? HANDLE_PRI_HP : NEVER_HANDLE;
		Log.d("HP_CANHANDLE", "CHECK_CAN_HANDLE", "Can handle device: " + v);
		return v;
	}

	public void handleDevice(Netbox nb, SimpleSnmp sSnmp, ConfigParser cp, DataContainers containers) throws TimeoutException
	{
		Log.setDefaultSubsystem("HP_DEVHANDLER");

		NetboxContainer nc;
		{
			DataContainer dc = containers.getContainer("NetboxContainer");
			if (dc == null) {
				Log.w("NO_CONTAINER", "No NetboxContainer found, plugin may not be loaded");
				return;
			}
			if (!(dc instanceof NetboxContainer)) {
				Log.w("NO_CONTAINER", "Container is not a NetboxContainer! " + dc);
				return;
			}
			nc = (NetboxContainer)dc;
		}

		ModuleContainer mc;
		{
			DataContainer dc = containers.getContainer("ModuleContainer");
			if (dc == null) {
				Log.w("NO_CONTAINER", "No ModuleContainer found, plugin may not be loaded");
				return;
			}
			if (!(dc instanceof ModuleContainer)) {
				Log.w("NO_CONTAINER", "Container is not a ModuleContainer! " + dc);
				return;
			}
			mc = (ModuleContainer)dc;
		}

		SwportContainer sc;
		{
			DataContainer dc = containers.getContainer("SwportContainer");
			if (dc == null) {
				Log.w("NO_CONTAINER", "No SwportContainer found, plugin may not be loaded");
				return;
			}
			if (!(dc instanceof SwportContainer)) {
				Log.w("NO_CONTAINER", "Container is not an SwportContainer! " + dc);
				return;
			}
			sc = (SwportContainer)dc;
		}

		String netboxid = nb.getNetboxidS();
		String ip = nb.getIp();
		String cs_ro = nb.getCommunityRo();
		String type = nb.getType();
		String sysName = nb.getSysname();
		String cat = nb.getCat();
		this.sSnmp = sSnmp;

		processHP(nb, netboxid, ip, cs_ro, type, nc, mc, sc);

		// Commit data
		if (mc.isCommited()) sc.setEqual(mc);
		sc.commit();
	}

	/*
	 * HP
	 *
	 */
	private void processHP(Netbox nb, String netboxid, String ip, String cs_ro, String type, NetboxContainer nc, ModuleContainer mc, SwportContainer sc) throws TimeoutException {

		/*
		HP 2524:
		=====

		Først henter vi ut antall i stack'en med MIB:

		.1.3.6.1.4.1.11.2.14.11.5.1.10.4.1.1

		Denne gir ut et tall for hvert member, 0 er alltid til stedet og er commanderen

	Standard fra MIB-II:

		ifIndex: .1.3.6.1.2.1.2.2.1.1
		ifSpeed: .1.3.6.1.2.1.2.2.1.5
		ifAdminStatus: .1.3.6.1.2.1.2.2.1.7
		ifOperStatus: .1.3.6.1.2.1.2.2.1.8

	HpSwitchPortEntry gir resten:

		HpSwitchPortEntry ::= .1.3.6.1.4.1.11.2.14.11.5.1.7.1.3.1.1
			SEQUENCE {
				hpSwitchPortIndex                  INTEGER,
				hpSwitchPortType                   HpSwitchPortType,
				hpSwitchPortDescr                  DisplayString,
				hpSwitchPortAdminStatus            INTEGER,
				hpSwitchPortEtherMode              INTEGER,
				hpSwitchPortVgMode                 INTEGER,
				hpSwitchPortLinkbeat               INTEGER,
				hpSwitchPortTrunkGroup             INTEGER,
				hpSwitchPortBcastLimit             INTEGER,
				hpSwitchPortFastEtherMode          INTEGER,
				hpSwitchPortFlowControl            INTEGER,
				hpSwitchPortBcastPktLimit          INTEGER,
				hpSwitchPortTrunkType              INTEGER,
				hpSwitchPortTrunkLACPStatus        INTEGER
			}

		Interessante:
				HpSwitchPortType ::= TEXTUAL-CONVENTION
					STATUS      current
					DESCRIPTION "Used to indicate the type of port."
					SYNTAX      INTEGER {
									other(1),
									none(2),
									ethernetCsmacd(6),
									iso88023Csmacd(7),
									fddi(15),
									atm(37),
									propMultiplexor(54),
									ieee80212(55),
									fastEther(62),
									fastEtherFX(69),
									gigabitEthernetSX (117),
									gigabitEthernetLX (118),
									gigabitEthernetT (119),
									gigabitEthernetStk (120)
								}

				hpSwitchPortEtherMode OBJECT-TYPE
					SYNTAX      INTEGER {
									half-duplex(1),
									full-duplex(2)
								}

				hpSwitchPortFastEtherMode OBJECT-TYPE
					SYNTAX      INTEGER {
									half-duplex-10Mbits(1),
									half-duplex-100Mbits(2),
									full-duplex-10Mbits(3),
									full-duplex-100Mbits(4),
									auto-neg(5),
									full-duplex-1000Mbits(6),
									auto-10Mbits(7),
									auto-100Mbits(8),
									auto-1000Mbits(9)
								}

	Vlan:

		.1.3.6.1.4.1.11.2.14.11.5.1.7.1.15.3.1.1

		Gir vlan.port = vlan


		*/

		/*
		String stackOid = "1.3.6.1.4.1.11.2.14.11.5.1.10.4.1.1";
                       

		String ifIndexOid = ".1.3.6.1.2.1.2.2.1.1";
		String ifSpeedOid = ".1.3.6.1.2.1.2.2.1.5";
		String ifAdmStatusOid = ".1.3.6.1.2.1.2.2.1.7";
		String ifOperStatusOid = ".1.3.6.1.2.1.2.2.1.8";

		String serialOid = ".1.3.6.1.2.1.47.1.1.1.1.11.1";
		String hwOid = ".1.3.6.1.4.1.11.2.14.11.5.1.1.4.0";
		String swOid = ".1.3.6.1.4.1.11.2.14.11.5.1.1.3.0";

		String portTypeOid = ".1.3.6.1.4.1.11.2.14.11.5.1.7.1.3.1.1.2";
		//String etherModeOid = ".1.3.6.1.4.1.11.2.14.11.5.1.7.1.3.1.1.5";
		//String fastEtherModeOid = ".1.3.6.1.4.1.11.2.14.11.5.1.7.1.3.1.1.10";

		String vlanOid = "1.3.6.1.4.1.11.2.14.11.5.1.7.1.15.3.1.1";
		*/

		// We always want the serial as well as the port type (since we
		// don't use ifIndex)
		if (!nb.canGetOid("ifSerial") ||
				!nb.canGetOid("hpPortType")) {
			return;
		}

		List l;

		// Which module is the commander
		String moduleWithIP = "0";
		List memberList = sSnmp.getAll(nb.getOid("hpStackStatsMemberOperStatus"));
		if (memberList != null) {
			for (Iterator it = memberList.iterator(); it.hasNext();) {
				String[] s = (String[])it.next();
				String module;
				if (s.length < 4) {
					Log.e("PROCESS_HP", "Missing 4th element from SimpleSnmp response");
					module = s[0];
				} else {
					module = s[3];
				}
				int status = Integer.parseInt(s[1]);
				if (status == 12) {
					// Commander
					moduleWithIP = module;
					NetboxInfo.put(nb.getNetboxidS(), null, "ModuleWithIP", moduleWithIP);
					break;
				}
			}
		} else {
			String moduleWithIPL = NetboxInfo.getSingleton(nb.getNetboxidS(), null, "ModuleWithIP");
			if (moduleWithIPL != null) moduleWithIP = moduleWithIPL;
		}

		// Module data
		l = sSnmp.getNext(nb.getOid("ifSerial"), 1, true, false);
		if (l != null) {
			for (Iterator it = l.iterator(); it.hasNext();) {
				String[] s = (String[])it.next();
				// Assume only one module if info is missing
				String module = (s.length >= 3 ? s[2] : "0");

				if (s.length < 3 && "hp2524".equals(nb.getType())) {
					Log.e("PROCESS_HP", "Missing 3rd element from ifSerial (" + nb.getType() + ")");
				}
				
				if (moduleWithIP.equals(module) && nc.netboxDataFactory(nb).getSerial() == null) {
					nc.netboxDataFactory(nb).setSerial(s[1]);
				}
				int moduleNum = Integer.parseInt(module);
				mc.moduleFactory(moduleNum);
				sc.swModuleFactory(moduleNum).setSerial(s[1]);
				Log.d("PROCESS_HP", "Module: " + module + " Serial: " + s[1]);
			}
		}

		l = sSnmp.getNext(nb.getOid("hpFwVer"), 1, true, false);
		if (l != null) {
			for (Iterator it = l.iterator(); it.hasNext();) {
				String[] s = (String[])it.next();
				String module = (s.length >= 3 ? s[2] : "0");
				sc.swModuleFactory(Integer.parseInt(module)).setFwVer(s[1]);
			}
		}

		l = sSnmp.getNext(nb.getOid("hpSwVer"), 1, true, false);
		if (l != null) {
			for (Iterator it = l.iterator(); it.hasNext();) {
				String[] s = (String[])it.next();
				String module = (s.length >= 3 ? s[2] : "0");
				sc.swModuleFactory(Integer.parseInt(module)).setSwVer(s[1]);
			}
		}

		l = sSnmp.getNext(nb.getOid("hpStackName"), 1, true, false);
		if (l != null && !l.isEmpty()) {
			String[] s = (String[])l.get(0);
			if (s[1].length() > 0) NetboxInfo.put(nb.getNetboxidS(), null, "stackName", s[1]);
		}

		// Switch port data
		l = sSnmp.getAll(nb.getOid("hpPortType"));
		if (l != null) {
			for (Iterator it = l.iterator(); it.hasNext();) {
				String[] portType = (String[])it.next();
				String ifindex = portType[0];
				String module = (portType.length >= 3 ? portType[2] : "0");
				String port = (portType.length >= 4 ? portType[3] : ifindex);

				/*
				if (portType.length < 4) {
					Log.w("PROCESS_HP", "netboxid: " + netboxid + " Module/port number missing");
					continue;
				}
				*/
				
				Swport swp = sc.swModuleFactory(Integer.parseInt(module)).swportFactory(ifindex);

				//System.err.println("ifindex: " + ifindex + ", p0: " + portType[0] + ", p1: " + portType[1] + ", p2: " + portType[2]);

				try {
					swp.setPort(new Integer(Integer.parseInt(port)));
				} catch (NumberFormatException e) {
					Log.w("PROCESS_HP", "netboxid: " + netboxid + " NumberFormatException on ifindex: " + ifindex);
				}

				char duplex;
				String media = null;
				try {
					int n = Integer.parseInt(portType[1]);
					switch (n) {
					case   1: // other(1),
						media = "Unknown";
						duplex = 'f'; // full
						break;

					case   2: // none(2),
						media = "None";
						duplex = 'f'; // full
						break;

					case   6: // ethernetCsmacd(6),
						media = "ethernetCsmacd";
						duplex = 'f'; // full
						break;

					case   7: // iso88023Csmacd(7),
						media = "iso88023Csmacd";
						duplex = 'f'; // full
						break;

					case  15: // fddi(15),
						media = "FDDI";
						duplex = 'h'; // half
						break;

					case  37: // atm(37),
						media = "ATM";
						duplex = 'f'; // full
						break;

					case  54: // propMultiplexor(54),
						media = "propMultiplexor";
						duplex = 'f'; // full
						break;

					case  55: // ieee80212(55),
						media = "ieee80212";
						duplex = 'f'; // full
						break;

					case  62: // fastEther(62),
						media = "100BaseTX";
						duplex = 'f'; // full
						break;

					case  69: // fastEtherFX(69),
						media = "100BaseFX";
						duplex = 'f'; // full
						break;

					case 117: // gigabitEthernetSX (117),
						media = "1000BaseSX";
						duplex = 'f'; // full
						break;

					case 118: // gigabitEthernetLX (118),
						media = "1000BaseLX";
						duplex = 'f'; // full
						break;

					case 119: // gigabitEthernetT (119),
						media = "1000BaseTX";
						duplex = 'f'; // full
						break;

					case 120: // gigabitEthernetStk (120)
						media = "1000BaseSTK";
						duplex = 'f'; // full
						break;

					default:
						Log.w("PROCESS_HP", "netboxid: " + netboxid + " ifindex: " + ifindex + " Unknown port type: " + n);
						continue;
					}

					swp.setMedia(media);
					swp.setDuplex(duplex);

				} catch (NumberFormatException e) {
					Log.w("PROCESS_HP", "netboxid: " + netboxid + " ifindex: " + ifindex + " NumberFormatException for port type: " + portType[1]);
				}
			}
		}

		Map vlanMap = sSnmp.getAllMapList(nb.getOid("hpVlan"), 1);
		if (vlanMap != null) {
			for (Iterator it = vlanMap.entrySet().iterator(); it.hasNext();) {
				Map.Entry me = (Map.Entry)it.next();
				String ifindex = (String)me.getKey();
				List vlanList = (List)me.getValue();
				Swport swp = sc.swportFactory(ifindex);

				// Vlan
				if (vlanList.size() > 1) {
					swp.setTrunk(true);
					for (Iterator k=vlanList.iterator(); k.hasNext();) {
						swp.addTrunkVlan((String)k.next());
					}
				} else {
					int vlan = 0;
					try {
						vlan = Integer.parseInt((String)vlanList.get(0));
						swp.setVlan(vlan);
					} catch (NumberFormatException e) {
						Log.w("PROCESS_HP", "Cannot parse vlan: " + vlanList.get(0));
					}
				}
			}
		}
	}

}