input.java

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

		}

		if (com.getTidAvg() )
		{
			param[3] = "type=avg";
		} else
		{
			param[3] = "type=max";
		}

		Vector[] v = fetch(param, "http://bigbud.itea.ntnu.no/cgi-bin/vPLast/last.pl");

		listCPULast = v[4];
		listLinkLast = v[0];
		listNetLast = v[2];
		Vector elinkLast = v[3];

		// putt elink inn i netLast
		for (int i = 0; i < elinkLast.size(); i++)
		{
			listNetLast.addElement(elinkLast.elementAt(i));
		}


		for (int i = 0; i < listCPULast.size(); i++)
		{
			com.d("" + i + ": " + ((String[])listCPULast.elementAt(i))[0] + ", " + ((String[])listCPULast.elementAt(i))[1] ,1 );

		}

	}
*/

	public Vector[] getLastData(Vector nettel, Vector nettelLinks)
	{
		// hent ut alle id'er
		Vector net = new Vector();
		Vector sw = new Vector();

		for (int i = 0; i < 3; i++)
		{
			String[] s = (String[])nettelLinks.elementAt(i);
			for (int j = 1; j < s.length; j++)
			{
				int nettelId = Integer.parseInt( (misc.tokenize(s[j], ","))[0] );
				String linkId = (misc.tokenize(s[j], ","))[1];
				String type = (misc.tokenize(s[j], ","))[2];

/*
				if (type.equals("sw") )
				{
					sw.addElement(linkId);
				} else
				{
					net.addElement(linkId);
					if (type.equals("gw"))
					{
						String linkIdInn = (misc.tokenize(s[j], ","))[4];
						net.addElement(linkIdInn);
					}
				}
*/

				if (type.equals("gw") || type.equals("net") )
				{
					net.addElement(linkId);
					if (type.equals("gw"))
					{
						String linkIdInn = (misc.tokenize(s[j], ","))[6];
						net.addElement(linkIdInn);
					}

				} else
				{
					sw.addElement(linkId);
				}


			}
		}

		String[] param = new String[4];
		StringBuffer b = new StringBuffer();

		// legg til id for net (router) linker
		b.append("net=");
		for (int i = 0; i < net.size(); i++)
		{
			String s = (String)net.elementAt(i);
			b.append(s + ",");
		}
		if (net.size() > 0)
		{
			b.setLength(b.length()-1);
		} else
		{
			b.append("0");
		}
		param[0] = b.toString();

		// legg til id for sw linker
		b = new StringBuffer();
		b.append("sw=");
		for (int i = 0; i < sw.size(); i++)
		{
			String s = (String)sw.elementAt(i);
			b.append(s + ",");
		}
		if (sw.size() > 0)
		{
			b.setLength(b.length()-1);
		} else
		{
			b.append("0");
		}
		param[1] = b.toString();

		// tid
		long[] lastInterval = com.getLastInterval();

		if (lastInterval[1] >= 0) {
			param[2] = "time=" + lastInterval[0] + ",now";
		} else {
			param[2] = "time=" + lastInterval[0] + "," + lastInterval[1];
		}

		if (com.getTidAvg()) {
			param[3] = "type=avg";
		} else {
			param[3] = "type=max";
		}

		Vector[] lastData = fetch_old(param, lastURL);

com.d("Last hentet", 1);
		Vector CPULast = lastData[4];
		Vector BakplanLast = lastData[5];
		Vector linkLast = lastData[0];
		Vector elinkLast = lastData[3];
		Vector lanLast = lastData[1];
		Vector netLast = lastData[2];
		Vector swLast = lastData[6];
com.d("Vectorer OK", 1);
		// putt lan inn i netLast
		for (int i = 0; i < lanLast.size(); i++)
		{
			netLast.addElement(lanLast.elementAt(i));
		}
		// putt elink inn i netLast
		for (int i = 0; i < elinkLast.size(); i++)
		{
			netLast.addElement(elinkLast.elementAt(i));
		}
com.d("put OK", 1);
		return lastData;

	}

	public static String processText(String text, String[] data, Hashtable keywords)
	{
		// && = variabelnavn fra hashtable, ## = bytt ut med gitt verdi, !! = \n
		int i, tagLen="##".length();
		int cnt=1; // data starter på andre element (det første er en id)

		// Først bytter vi ut alle ##
		while ( (i=text.indexOf("##")) != -1) {
			if (cnt == data.length) {
				// Error, flere ## enn elementer i data
				break;
			}
			text = text.substring(0, i)+data[cnt++]+text.substring(i+tagLen, text.length());
		}

		// Så sjekker vi for && og evt. bytter ut fra keywords
		while ( (i=text.indexOf("&&")) != -1) {
			// Dersom teksten inneholder "!!", ")" eller " " etter && tar vi den som er nærmest,
			// i motsatt fall slutten på strengen
			int end = text.indexOf("!!", i);
			int end2 = text.indexOf(")", i);
			int end3 = text.indexOf(" ", i);
			end = min(end, end2, end3, text.length() );
			/*
			if (end == -1 && end2 == -1) {
				end = text.length();
			} else
			if (end == -1) {
				end = end2;
			} else
			if (end != -1 && end2 != -1) {
				if (end > end2) end = end2;
			}
			*/

			String word = text.substring(i+tagLen, end).toLowerCase();
			word = (String)keywords.get(word);
			if (word == null) word = "";
			//if (end == text.length()) end--;

			text = text.substring(0, i)+word+text.substring(end, text.length());
			//System.out.println("WORD: " + word);
		}

		// Så setter vi inn linjeskift
		while ( (i=text.indexOf("!!")) != -1) text = text.substring(0, i)+"\n"+text.substring(i+tagLen, text.length());

		return text;
	}

	private static int min(int i1, int i2, int i3, int i4)
	{
		if (i1 < 0) i1 = Integer.MAX_VALUE;
		if (i2 < 0) i2 = Integer.MAX_VALUE;
		if (i3 < 0) i3 = Integer.MAX_VALUE;
		if (i4 < 0) i4 = Integer.MAX_VALUE;

		i1 = Math.min(i1, i2);
		i1 = Math.min(i1, i3);
		i1 = Math.min(i1, i4);
		return i1;
	}




	public Vector[] fetch_old(String[] req, String param, String serverURL)
	{
		Vector[] ret = new Vector[req.length];
		int teller = 0;
		Vector v = new Vector();
		Vector v2 = new Vector();

		try
		{
			StringBuffer b = new StringBuffer();

			// lag URL
			//b.append("http://bigbud.itea.ntnu.no/vlanPlot/vPServer/vPServer");
			b.append(serverURL);
			b.append("?section=nettel&");
			if (param.length() > 0)
			{
				b.append(param + "&");
			}
			b.append("request=");
			for (int i = 0; i < req.length; i++)
			{
				b.append(req[i]);
				if ((i+1) < req.length)
				{
					b.append("^");
				}
			}
			//b.append("&");
			//b.append("send=Send\n");

			com.d("URL: " + b.toString(), 2);

			//URL url = new URL("http://home.dataparty.no/kristian/itea/nettelServer/nettelServer");
			URL url = new URL(b.toString() );
			URLConnection connection = url.openConnection();
			connection.connect();

			//connection.setRequestProperty("Referer", "http://www.itea.ntnu.no/");
/*
			connection.setDoOutput(true);
			PrintWriter out = new PrintWriter(connection.getOutputStream());

			out.print("section=nettel&");

			if (param.length() > 0)
			{
				out.print(param + "&");
			}

			out.print("request=");
			for (int i = 0; i < req.length; i++)
			{
				out.print(req[i]);
				if ((i+1) < req.length)
				{
					out.print("^");
				}
			}
			out.print("&");
			out.print("send=Send\n");

			out.close();
*/
			BufferedReader in = new BufferedReader(new InputStreamReader(connection.getInputStream()));
			String line;
			while ((line = in.readLine()) != null)
			{
				v.addElement(misc.tokenize(line, "^"));
			}

			for (int i = 1; i < v.size(); i++)
			{
				String[] s = (String[])v.elementAt(i);
				if (s[0].length() >= 4)
				{
					if (s[0].substring(0, 4).equals("list"))
					{
						ret[teller] = v2;
						v2 = new Vector();
						teller++;
					} else
					{
						v2.addElement(s);
					}
				} else
				{
					v2.addElement(s);
				}
			}
			ret[teller] = v2;

		}
		catch (Exception e)
		{
			com.d("Error: " + e.getMessage(), 0);
		}
		return ret;
	}

	public Vector[] fetch_old(String[] param, String serverURL)
	{
		Vector retV = new Vector();
		int teller = 0;
		Vector v = new Vector();
		Vector v2 = new Vector();

		try
		{
			StringBuffer b = new StringBuffer();

			// lag URL
			b.append(serverURL + "?");

			for (int i = 0; i < param.length; i++)
			{
				b.append(param[i]);

			}
			//b.append("send=Send\n");

			com.d("URL: " + b.toString(), 2);

			URL url = new URL(b.toString() );
			URLConnection connection = url.openConnection();
			connection.connect();

			BufferedReader in = new BufferedReader(new InputStreamReader(connection.getInputStream()));
			String line;
			while ((line = in.readLine()) != null)
			{
				v.addElement(misc.tokenize(line, ","));
			}

			for (int i = 1; i < v.size(); i++)
			{
				String[] s = (String[])v.elementAt(i);
				if (s[0].length() >= 4)
				{
					if (s[0].substring(0, 4).equals("list"))
					{
						retV.addElement(v2);
						v2 = new Vector();
						teller++;
					} else
					{
						v2.addElement(s);
					}
				} else
				{
					v2.addElement(s);
				}
			}
			retV.addElement(v2);

		}
		catch (Exception e)
		{
			com.d("Error: " + e.getMessage(), 0);
		}

		Vector[] ret = new Vector[retV.size()];
		for (int i = 0; i < retV.size(); i++)
		{
			ret[i] = (Vector)retV.elementAt(i);
		}

		return ret;
	}


	public int getNettelIndex(int n)
	{
		for (int i = 0; i < listRouters.size(); i++)
		{
			String[] s = (String[])listRouters.elementAt(i);
			int index = Integer.parseInt(s[0]);

			if (index == n)
			{
				return i;
			}
		}
		return -1;
	}

	public int getIndex(Vector v, int n)
	{
		for (int i = 0; i < v.size(); i++)
		{
			String[] s = (String[])v.elementAt(i);
			int index = Integer.parseInt(s[0]);

			if (index == n)
			{
				return i;
			}
		}
		return -1;
	}

	public int getXYIndex(int[][] xy, int n)
	{
		for (int i = 0; i < xy[0].length; i++)
		{
			if (xy[0][i] == n)
			{
				return i;
			}
		}
		return -1;
	}

	public int getId(Vector v, int n)
	{
		for (int i = 0; i < v.size(); i++)
		{
			if (n == ((Nettel)v.elementAt(i)).getBoksid() )
			{
				return i;
			}
		}
		return -1;
	}


	public int lookupIndex(Vector v, int n)
	{
		String[] s = (String[])v.elementAt(n);

		return Integer.parseInt(s[0]);
	}



	public boolean getAuth(String user, String pw)
	{
		/*
		if ( user.equals("admin") && pw.equals("admin") )
		{
			return true;
		} else
		{
			return false;
		}
		*/
		return user.equals("admin") ? true : false;
	}


	public Vector getListRouters() { return listRouters; }
	public Vector getListRouterLinks() { return listRouterLinks; }
	public Vector getListNetRouters() { return listNetRouters; }
	public Vector getListNetLinks() { return listNetLinks; }
	public Vector getRouterGroups() { return listRouterGroups; }

	public Vector getCPULast() { return listCPULast; }
	public Vector getLinkLast() { return listLinkLast; }
	public Vector getNetLast() { return listNetLast; }

	public int[][] getNettelXY() { return nettelXY; }
	//public int[][] getNettelXYGrp() { return nettelXYGrp; }
}