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.9 by ajm, Fri Mar 2 03:57:06 2001 UTC vs.
Revision 1.15 by ajm, Tue Mar 6 02:33:55 2001 UTC

#	Line 29 | Line 29 | public class CPU__Monitor implements PluginMonitor {
29
30		//---CONSTRUCTORS---
31
32	–	public CPU__Monitor() {
33	–	_alerterQueue = ClientMain._alerterQueue;
34	–	// get the configuration for this plug-in
35	–	Configuration config = _refman.getCM().getConfiguration(_name);
36	–	_levels = new double[(Alert.alerts).length];
37	–	for (int x = 0; x < Alert.alerts.length; x++) {
38	–	try {
39	–	_levels[x] = Double.parseDouble(config.getProperty("Monitor.CPU.level." + x));
40	–	} catch (NumberFormatException e) {
41	–	_logger.write(toString(), Logger.ERROR, "Invalid configured value for alert level " + x + " - ignoring level.");
42	–	_levels[x] = -1;
43	–	} catch (org.omg.CORBA.MARSHAL e2) {
44	–	_logger.write(toString(), Logger.WARNING, "Alert level " + x + " unused.");
45	–	_levels[x] = -1;
46	–	}
47	–
48	–	}
49	–	}
50	–
32		//---PUBLIC METHODS---
33
34		public void analysePacket(XMLPacket packet) {
35		if (packet.getParam("packet.attributes.type").equals("data")) {
36		String source = packet.getParam("packet.attributes.machine_name");
37		if (!_hosts.containsKey(source)) {
38	<	_hosts.put(source, new Register(_attributes.length));
38	>	_hosts.put(source, new Register(source, _name, _attributes.length));
39		}
40
41		Register reg = (Register) _hosts.get(source);
42	<	for(int x = 0; x < _attributes.length; x++) {
43	<	int result = checkAttribute(packet, _attributes[x]);
44	<	if (result != reg.getRegister(x)) {
45	<	reg.setRegister(x, result);
46	<	fireAlert(result, source, packet.getParam(_attributes[x]), _attributeNames[x]);
47	<	}
48	<	}
42	>	for(int attributeNum = 0; attributeNum < _attributes.length; attributeNum++) {
43	>	// find out the threshold level we're at
44	>	int result = checkAttributeThreshold(packet.getParam(_attributes[attributeNum]), reg);
45	>
46	>	// decide what threshold level we're on, if we've changed, record that
47	>	if (result != reg.getLastThresholdLevel(attributeNum)) {
48	>	reg.setLastThresholdLevel(attributeNum, result);
49	>	}
50	>	// as long as this isn't a normal level
51	>	if(reg.getLastThresholdLevel(attributeNum) != Alert.thresholdNORMAL) {
52	>	// if the time since the last alert is more than the time for
53	>	// its timeout, fire an alert, escalate the alert
54	>	long timeout = reg.getLastAlertTimeout(attributeNum);
55	>	if ((timeout > 0) && (reg.getTimeLastSent(attributeNum) > 0)) {
56	>	if((System.currentTimeMillis() - reg.getTimeLastSent(attributeNum)) > timeout) {
57	>	int lastAlert = reg.getLastAlertLevel(attributeNum);
58	>	reg.escalateAlert(attributeNum);
59	>	reg.setTimeLastSent(attributeNum, System.currentTimeMillis());
60	>	reg.setLastAlertTimeout(attributeNum, reg.getAlertTimeout(reg.getLastAlertLevel(attributeNum), attributeNum));
61	>	fireAlert(reg, lastAlert, packet, attributeNum);
62	>	}
63	>	// if we don't have a timeout configured...we got STRAIGHT to the next level
64	>	} else {
65	>	int lastAlert = reg.getLastAlertLevel(attributeNum);
66	>	reg.escalateAlert(attributeNum);
67	>	reg.setTimeLastSent(attributeNum, System.currentTimeMillis());
68	>	reg.setLastAlertTimeout(attributeNum, reg.getAlertTimeout(reg.getLastAlertLevel(attributeNum), attributeNum));
69	>	fireAlert(reg, lastAlert, packet, attributeNum);
70	>	}
71	>
72	>	// we must be on ok, check the timeout value for this
73	>	} else {
74	>	// if we were on an OK alert before, then we don't do anything
75	>	// but if we weren't we only set OK, once the timout of the last
76	>	// alert has occourd
77	>	if (reg.getLastAlertLevel(attributeNum) != Alert.alertOK) {
78	>	long timeout = reg.getLastAlertTimeout(attributeNum);
79	>	if ((timeout > 0) && (reg.getTimeLastSent(attributeNum) > 0)) {
80	>	if ((System.currentTimeMillis() - reg.getTimeLastSent(attributeNum)) > timeout) {
81	>	int lastAlert = reg.getLastAlertLevel(attributeNum);
82	>	reg.setLastAlertLevel(attributeNum, Alert.alertOK);
83	>	reg.setTimeLastSent(attributeNum, System.currentTimeMillis());
84	>	reg.setLastAlertTimeout(attributeNum, timeout);
85	>	fireAlert(reg, lastAlert, packet, attributeNum);
86	>	}
87	>	}
88	>	}
89	>	}
90	>	}
91		}
92		}
93
#	Line 85 | Line 108 | public class CPU__Monitor implements PluginMonitor {
108		}
109
110		/**
111	<	* return the String representation of what the filter does
111	>	* return the String representation of what the monitor does
112		*/
113		public String getDescription(){
114		return DESC;
#	Line 93 | Line 116 | public class CPU__Monitor implements PluginMonitor {
116
117		//---PRIVATE METHODS---
118
119	<	private int checkAttribute(XMLPacket packet, String packetAttribute) {
120	<	for(int x= _levels.length; x > 0; x--) {
121	<	if (_levels[x] != -1) {
122	<	if(packet.getParam(packetAttribute) != null) {
123	<	double attribute = Double.parseDouble(packet.getParam(packetAttribute));
124	<	if (_levels[x] < attribute) return x;
119	>	private int checkAttributeThreshold(String attributeString, Register reg) {
120	>	for(int thresholdLevel = Alert.thresholdLevels.length - 1; thresholdLevel >= 0; thresholdLevel--) {
121	>	if (reg.getThreshold(thresholdLevel) != -1.0) {
122	>	if(attributeString != null) {
123	>	try {
124	>	double attribute = Double.parseDouble(attributeString);
125	>	if (reg.getThreshold(thresholdLevel) < attribute) return thresholdLevel;
126	>	} catch (NumberFormatException e) {
127	>	// we got some duff data in the packet, but we shouldn't have
128	>	_logger.write(toString(), Logger.DEBUG, "possible errenous packet data, should be double value - " + attributeString);
129	>	}
130		}
131		}
132		}
133		return 0;
134		}
135
136	<	private void fireAlert(int alertLevel, String source, String currentValue, String attributeName) {
137	<	String thresholdValue = Double.toString(_levels[alertLevel]);
138	<	Alert alert = new Alert(alertLevel, source, thresholdValue, currentValue, attributeName);
136	>	private void fireAlert(Register reg, int lastAlert, XMLPacket packet, int attributeNum) {
137	>	int alertLevel = reg.getLastAlertLevel(attributeNum);
138	>	int thresholdLevel = reg.getLastThresholdLevel(attributeNum);
139	>	String source = packet.getParam("packet.attributes.machine_name");
140	>	String currentValue = packet.getParam(_attributes[attributeNum]);
141	>	String attributeName = _attributeNames[attributeNum];
142	>	String thresholdValue = Double.toString(reg.getThreshold(thresholdLevel));
143	>	String timeout = Long.toString(reg.getAlertTimeout(reg.getLastAlertLevel(attributeNum), attributeNum) / 1000);
144	>	if (thresholdLevel == Alert.thresholdNORMAL) {
145	>	thresholdValue = "-";
146	>	}
147	>	if (alertLevel == Alert.alertOK) {
148	>	timeout = "0";
149	>	}
150	>	Alert alert = new Alert(alertLevel, lastAlert, thresholdLevel, source, thresholdValue, currentValue, attributeName, timeout, reg.getInitialAlertTime(attributeNum));
151		_alerterQueue.add(alert);
152	<	_logger.write(toString(), Logger.DEBUG, "Fired alert for source:" + source + " at alert level:" + alertLevel + " on:" + attributeName + " at:" +  currentValue + " exceeding threshold:" + _levels[alertLevel]);
152	>	_logger.write(toString(), Logger.DEBUG, "Fired alert for source:" + source + " at alert level:" + Alert.alertLevels[alertLevel] + " on:" + attributeName + " for threshold level:" + Alert.thresholdLevels[thresholdLevel] + " at:" +  currentValue + " exceeding threshold of:" +thresholdValue + " next alert sent in:" + timeout + "secs");
153		}
154
155		//---ACCESSOR/MUTATOR METHODS---
#	Line 125 | Line 165 | public class CPU__Monitor implements PluginMonitor {
165		* can be placed here.  This name could also
166		* be changed to null for utility classes.
167		*/
168	<	private String _name = ClientMain.NAME;
168	>	private String _name = "CPU";
169
170		/**
171		* This holds a reference to the
#	Line 133 | Line 173 | public class CPU__Monitor implements PluginMonitor {
173		*/
174		private Logger _logger = ReferenceManager.getInstance().getLogger();
175
176	<	private double[] _levels;
137	<
138	<	private Queue _alerterQueue;
176	>	private Queue _alerterQueue = ClientMain._alerterQueue;
177
178		/**
179	<	* A reference to the reference manager in use
179	>	* A reference to the configuration proxy in use
180		*/
181	<	private ReferenceManager _refman = ReferenceManager.getInstance();
181	>	private ConfigurationProxy _cp = ConfigurationProxy.getInstance();
182
183		private HashMap _hosts = new HashMap();
184

Diff Legend

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