ViewVC Help

View File | Revision Log | Show Annotations | Revision Graph | Root Listing

root/i-scream/projects/cms/source/server/uk/org/iscream/cms/server/client/monitors/CPU__Monitor.java

Comparing projects/cms/source/server/uk/org/iscream/cms/server/client/monitors/CPU__Monitor.java (file contents):
Revision 1.6 by ajm, Fri Mar 2 01:07:04 2001 UTC vs.
Revision 1.21 by tdb, Thu Mar 22 00:52:48 2001 UTC

#	Line 1 | Line 1
1		//---PACKAGE DECLARATION---
2	<	package uk.ac.ukc.iscream.client.monitors;
2	>	package uk.org.iscream.client.monitors;
3
4		//---IMPORTS---
5	<	import uk.ac.ukc.iscream.client.*;
6	<	import uk.ac.ukc.iscream.core.*;
7	<	import uk.ac.ukc.iscream.util.*;
8	<	import uk.ac.ukc.iscream.componentmanager.*;
5	>	import java.util.HashMap;
6	>	import uk.org.iscream.client.*;
7	>	import uk.org.iscream.core.*;
8	>	import uk.org.iscream.util.*;
9	>	import uk.org.iscream.componentmanager.*;
10
11		/**
12		* This Monitor watches the CPU load for all machines
#	Line 13 | Line 14 | import uk.ac.ukc.iscream.componentmanager.*;
14		* @author  $Author$
15		* @version $Id$
16		*/
17	<	public class CPU__Monitor implements PluginMonitor {
17	>	public class CPU__Monitor extends MonitorSkeleton {
18
19		//---FINAL ATTRIBUTES---
20
#	Line 28 | Line 29 | public class CPU__Monitor implements PluginMonitor {
29
30		//---CONSTRUCTORS---
31
31	–	public CPU__Monitor() {
32	–	_alerterQueue = ClientMain._alerterQueue;
33	–	// get the configuration for this plug-in
34	–	Configuration config = _refman.getCM().getConfiguration(_name);
35	–	_levels = new double[(Alert.alerts).length];
36	–	for (int x = 0; x < Alert.alerts.length; x++) {
37	–	try {
38	–	_levels[x] = Double.parseDouble(config.getProperty("Monitor.CPU.level." + x));
39	–	} catch (NumberFormatException e) {
40	–	_logger.write(toString(), Logger.ERROR, "Invalid configured value for alert level " + x + " - ignoring level.");
41	–	_levels[x] = -1;
42	–	} catch (org.omg.CORBA.MARSHAL e2) {
43	–	_logger.write(toString(), Logger.WARNING, "Alert level " + x + " unused.");
44	–	_levels[x] = -1;
45	–	}
46	–
47	–	}
48	–	}
32		//---PUBLIC METHODS---
33
34		public void analysePacket(XMLPacket packet) {
35	<	String source = packet.getParam("packet.attributes.hostname");
36	<	for(int x=0; x < _levels.length; x++) {
37	<	if (_levels[x] != -1) {
38	<	double idle = Double.parseDouble(packet.getParam("packet.cpu.idle"));
39	<	if (_levels[x] < idle) fireAlert(x, source, idle, "idle");
40	<	double user = Double.parseDouble(packet.getParam("packet.cpu.user"));
58	<	if (_levels[x] < user) fireAlert(x, source, user, "user");
59	<	double kernel = Double.parseDouble(packet.getParam("packet.cpu.kernel"));
60	<	if (_levels[x] < kernel) fireAlert(x, source, kernel, "kernel");
61	<	double iowait = Double.parseDouble(packet.getParam("packet.cpu.iowait"));
62	<	if (_levels[x] < iowait) fireAlert(x, source, iowait, "iowait");
63	<	double swap = Double.parseDouble(packet.getParam("packet.cpu.swap"));
64	<	if (_levels[x] < swap) fireAlert(x, source, swap, "swap");
35	>	if (packet.getParam("packet.attributes.type").equals("data")) {
36	>	String source = packet.getParam("packet.attributes.machine_name");
37	>	if (!_hosts.containsKey(source)) {
38	>	HashMap attributeRegisters = new HashMap();
39	>	initAttributeRegsiters(source, attributeRegisters);
40	>	_hosts.put(source, attributeRegisters);
41		}
42	+
43	+	HashMap attributeRegisters = (HashMap) _hosts.get(source);
44	+	for(int attributeNum = 0; attributeNum < _attributes.length; attributeNum++) {
45	+	Register reg = (Register) attributeRegisters.get(_attributes[attributeNum]);
46	+	// find out the threshold level we're at
47	+	String attribute = _attributes[attributeNum];
48	+	String attributeName = _attributeNames[attributeNum];
49	+	String currentValue = packet.getParam(attribute);
50	+	int newThreshold = checkAttributeThreshold(currentValue, reg);
51	+	processAlert(newThreshold, attributeName, reg, source, currentValue);
52	+	}
53		}
54		}
55
#	Line 70 | Line 57 | public class CPU__Monitor implements PluginMonitor {
57		* Overrides the {@link java.lang.Object#toString() Object.toString()}
58		* method to provide clean logging (every class should have this).
59		*
60	<	* This uses the uk.ac.ukc.iscream.util.NameFormat class
60	>	* This uses the uk.org.iscream.util.NameFormat class
61		* to format the toString()
62		*
63		* @return the name of this class and its CVS revision
#	Line 83 | Line 70 | public class CPU__Monitor implements PluginMonitor {
70		}
71
72		/**
73	<	* return the String representation of what the filter does
73	>	* return the String representation of what the monitor does
74		*/
75		public String getDescription(){
76		return DESC;
#	Line 91 | Line 78 | public class CPU__Monitor implements PluginMonitor {
78
79		//---PRIVATE METHODS---
80
81	<	private void fireAlert(int alertLevel, String source, double currentValue, String type) {
82	<	String value = Double.toString(currentValue);
83	<	String thresholdValue = Double.toString(_levels[alertLevel]);
84	<	String attributeName = "CPU " + type;
85	<	Alert alert = new Alert(alertLevel, source, thresholdValue, value, attributeName);
86	<	_alerterQueue.add(alert);
81	>	private int checkAttributeThreshold(String attributeString, Register reg) {
82	>	for(int thresholdLevel = Alert.thresholdLevels.length - 1; thresholdLevel >= 0; thresholdLevel--) {
83	>	if (reg.getThreshold(thresholdLevel) != -1.0) {
84	>	if(attributeString != null) {
85	>	try {
86	>	double attribute = Double.parseDouble(attributeString);
87	>	if (reg.getThreshold(thresholdLevel) < attribute) return thresholdLevel;
88	>	} catch (NumberFormatException e) {
89	>	// we got some duff data in the packet, but we shouldn't have
90	>	_logger.write(toString(), Logger.DEBUG, "possible errenous packet data, should be double value - " + attributeString);
91	>	}
92	>	}
93	>	}
94	>	}
95	>	return Alert.thresholdNORMAL;
96		}
97
98	+	private void initAttributeRegsiters(String source, HashMap attributeRegisters) {
99	+	for(int attributeNum = 0; attributeNum < _attributes.length; attributeNum++) {
100	+	String attributeName = _attributes[attributeNum].substring(_attributes[attributeNum].lastIndexOf(".") + 1);
101	+	attributeRegisters.put(_attributes[attributeNum], new Register(source, _name, attributeName));
102	+	}
103	+	}
104	+
105		//---ACCESSOR/MUTATOR METHODS---
106
107		//---ATTRIBUTES---
#	Line 112 | Line 115 | public class CPU__Monitor implements PluginMonitor {
115		* can be placed here.  This name could also
116		* be changed to null for utility classes.
117		*/
118	<	private String _name = ClientMain.NAME;
116	<
117	<	/**
118	<	* This holds a reference to the
119	<	* system logger that is being used.
120	<	*/
121	<	private Logger _logger = ReferenceManager.getInstance().getLogger();
118	>	private String _name = "CPU";
119
123	–	private double[] _levels;
124	–
125	–	private Queue _alerterQueue;
126	–
120		/**
121	<	* A reference to the reference manager in use
121	>	* A reference to the configuration proxy in use
122		*/
123	<	private ReferenceManager _refman = ReferenceManager.getInstance();
123	>	private ConfigurationProxy _cp = ConfigurationProxy.getInstance();
124	>
125	>	private HashMap _hosts = new HashMap();
126	>
127	>	private String[] _attributes = { "packet.cpu.user", "packet.cpu.kernel", "packet.cpu.iowait", "packet.cpu.swap" };
128	>	private String[] _attributeNames = {"User CPU", "Kernel CPU", "I/O Wait CPU", "Swap CPU"};
129
130		//---STATIC ATTRIBUTES---
131

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines