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/Disk__Monitor.java

Comparing projects/cms/source/server/uk/org/iscream/cms/server/client/monitors/Disk__Monitor.java (file contents):
Revision 1.14 by tdb, Mon Nov 26 11:59:19 2001 UTC vs.
Revision 1.21 by tdb, Thu Jan 15 14:10:13 2004 UTC

#	Line 1 | Line 1
1	+	/*
2	+	* i-scream central monitoring system
3	+	* http://www.i-scream.org.uk
4	+	* Copyright (C) 2000-2002 i-scream
5	+	*
6	+	* This program is free software; you can redistribute it and/or
7	+	* modify it under the terms of the GNU General Public License
8	+	* as published by the Free Software Foundation; either version 2
9	+	* of the License, or (at your option) any later version.
10	+	*
11	+	* This program is distributed in the hope that it will be useful,
12	+	* but WITHOUT ANY WARRANTY; without even the implied warranty of
13	+	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14	+	* GNU General Public License for more details.
15	+	*
16	+	* You should have received a copy of the GNU General Public License
17	+	* along with this program; if not, write to the Free Software
18	+	* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
19	+	*/
20	+
21		//---PACKAGE DECLARATION---
22		package uk.org.iscream.cms.server.client.monitors;
23
24		//---IMPORTS---
25		import java.util.HashMap;
26	<	import java.util.ArrayList;
26	>	import java.util.HashSet;
27		import java.util.Set;
28		import java.util.Iterator;
29		import java.text.NumberFormat;
30		import uk.org.iscream.cms.server.client.*;
31		import uk.org.iscream.cms.server.core.*;
32	<	import uk.org.iscream.cms.server.util.*;
32	>	import uk.org.iscream.cms.util.*;
33		import uk.org.iscream.cms.server.componentmanager.*;
34
35		/**
#	Line 46 | Line 66 | public class Disk__Monitor extends MonitorSkeleton {
66		*/
67		public void analysePacket(XMLPacket packet) {
68		String source = packet.getParam("packet.attributes.machine_name");
69	+	if(!checkBooleanConfig("Host." + source, "Monitor." + _name + ".enable")) {
70	+	return;
71	+	}
72		if (!_hosts.containsKey(source)) {
73		_hosts.put(source, new HashMap());
74		}
75	+	if (!_hostsInode.containsKey(source)) {
76	+	_hostsInode.put(source, new HashMap());
77	+	}
78
79		HashMap diskRegisters = (HashMap) _hosts.get(source);
80	+	HashMap diskInodeRegisters = (HashMap) _hostsInode.get(source);
81
82		// key prefix
83		String keyPrefix = "packet.disk.p";
84
85		// a temporary holder for all the disk attributes we find
86	<	ArrayList disks = new ArrayList();
86	>	HashSet disks = new HashSet();
87
88		// unfortunatly we need to check the whole packet
89		// to find the disks, and then get the data attributes
#	Line 65 | Line 92 | public class Disk__Monitor extends MonitorSkeleton {
92		while (i.hasNext()) {
93		String dataKey = (String) i.next();
94		if(dataKey.startsWith(keyPrefix)) {
95	<	if(!disks.contains(dataKey)) {
96	<	String diskNumber = "";
95	>	// pos is after "packet.disk.p"
96	>	int pos = keyPrefix.length();
97	>	String diskNumber = dataKey.substring(pos, dataKey.indexOf('.', pos));
98	>	String thisDisk = keyPrefix.concat(diskNumber);
99	>
100	>	if(!disks.contains(thisDisk)) {
101	>	// add the disk to our list
102	>	disks.add(thisDisk);
103
71	–	// pos is after "packet.disk.p"
72	–	int pos = keyPrefix.length();
73	–	while (dataKey.charAt(pos) != '.') {
74	–	diskNumber = diskNumber + dataKey.charAt(pos);
75	–	pos++;
76	–	}
77	–
78	–	// add the disk to our list, with the packet data
79	–
80	–	// used (we won't use this value - but we need it to forget about it ;)
81	–	disks.add(keyPrefix + diskNumber + ".attributes.used");
82	–
104		// device
105	<	disks.add(keyPrefix + diskNumber + ".attributes.name");
85	<	String device = packet.getParam(keyPrefix + diskNumber + ".attributes.name");
105	>	String device = packet.getParam(thisDisk + ".attributes.name");
106		// mount point
107	<	disks.add(keyPrefix + diskNumber + ".attributes.mount");
88	<	String mount = packet.getParam(keyPrefix + diskNumber + ".attributes.mount");
107	>	String mount = packet.getParam(thisDisk + ".attributes.mount");
108
109		// these next two will be used to calculate the %age
110		// total
111	<	disks.add(keyPrefix + diskNumber + ".attributes.kbytes");
93	<	String total = packet.getParam(keyPrefix + diskNumber + ".attributes.kbytes");
111	>	String total = packet.getParam(thisDisk + ".attributes.total");
112		// available
113	<	disks.add(keyPrefix + diskNumber + ".attributes.avail");
114	<	String avail = packet.getParam(keyPrefix + diskNumber + ".attributes.avail");
113	>	String avail = packet.getParam(thisDisk + ".attributes.avail");
114	>
115	>	String totalInodes = packet.getParam(thisDisk + ".attributes.totalinodes");
116	>	String availInodes = packet.getParam(thisDisk + ".attributes.freeinodes");
117
118		// *** now process this disk ***
119
120		// check if we've seen this disk before on a previous run
121		// if not, we need to create a register for it
122	<	//   nb. use the device as the key as this is unlikely to change,
122	>	//   nb. use the mount as the key as this is unlikely to change,
123		//       unlike diskNumber which could easily change
124		//         (diskNumber is based on the order of df's output!)
125	<	if(!diskRegisters.containsKey(device)) {
126	<	diskRegisters.put(device, new Register(source, _name, mount));
125	>	if(!diskRegisters.containsKey(mount)) {
126	>	diskRegisters.put(mount, new Register(source, _name, mount));
127		}
128	+	if(!diskInodeRegisters.containsKey(mount)) {
129	+	diskInodeRegisters.put(mount, new Register(source, _nameInode, mount));
130	+	}
131
132		// get the register for this disk
133	<	Register reg = (Register) diskRegisters.get(device);
133	>	Register reg = (Register) diskRegisters.get(mount);
134	>	Register regInode = (Register) diskInodeRegisters.get(mount);
135
136		// get the packet data
137		double diskTotal, diskAvail;
138	+	int diskInodeTotal, diskInodeAvail;
139		try {
140
141	<	if(total==null || avail==null) {
141	>	if(total==null || avail==null || totalInodes==null || availInodes==null) {
142		throw new NumberFormatException("Disk data invalid");
143		}
144		diskTotal = Double.parseDouble(total);
145		diskAvail = Double.parseDouble(avail);
146	+	diskInodeTotal = Integer.parseInt(totalInodes);
147	+	diskInodeAvail = Integer.parseInt(availInodes);
148		} catch (NumberFormatException e) {
149		_logger.write(this.toString(), Logger.WARNING, "Received packet from "+source+" with bad disk information: "+e);
150		// don't try to continue and process, try next disk
#	Line 125 | Line 152 | public class Disk__Monitor extends MonitorSkeleton {
152		}
153
154		boolean useValue = false;
155	+	boolean useValueInode = false;
156		try {
157		// try looking for a mount-point specific thresholdMeasure first
158		String option = _cp.getProperty("Host." + source, "Monitor." + _name + "." + mount + ".thresholdMeasure");
159		if (option.equals("VALUE")) {
160		useValue = true;
161		}
162	+	option = _cp.getProperty("Host." + source, "Monitor." + _nameInode + "." + mount + ".thresholdMeasure");
163	+	if (option.equals("VALUE")) {
164	+	useValueInode = true;
165	+	}
166		} catch (PropertyNotFoundException e) {
167		try {
168		// now look for a more general thresholdMeasure
#	Line 138 | Line 170 | public class Disk__Monitor extends MonitorSkeleton {
170		if (option.equals("VALUE")) {
171		useValue = true;
172		}
173	+	option = _cp.getProperty("Host." + source, "Monitor." + _nameInode + ".thresholdMeasure");
174	+	if (option.equals("VALUE")) {
175	+	useValueInode = true;
176	+	}
177		} catch (PropertyNotFoundException f) {
178		// we default to percentage in any case
179		}
180		}
181
182		// this  bit determines if the disk check is a % check
183	<	// or a kb check
183	>	// or a byte check
184		String type;
185		double curValue;
186		int newThreshold;
187		if(useValue) {
188	<	// kb disk available
188	>	// byte disk available
189		curValue = diskAvail;
190		// negate check
191		newThreshold = checkAttributeThreshold(curValue, reg, true);
192	<	type = "kb";
192	>	type = "bytes";
193		} else {
194		// % disk in use
195	<	curValue = (1 - (diskAvail / diskTotal)) * 100;
195	>	curValue = (1 - ((double)diskAvail / (double)diskTotal)) * 100;
196		// normal check
197		newThreshold = checkAttributeThreshold(curValue, reg, false);
198		type = "%";
199		}
200	<
200	>
201	>	String typeInode;
202	>	double curValueInode;
203	>	int newThresholdInode;
204	>	if(useValueInode) {
205	>	// inodes available
206	>	curValueInode = diskInodeAvail;
207	>	// negate check
208	>	newThresholdInode = checkAttributeThreshold(curValueInode, regInode, true);
209	>	typeInode = "count";
210	>	} else {
211	>	// % inodes in use
212	>	curValueInode = (1 - ((double)diskInodeAvail / (double)diskInodeTotal)) * 100;
213	>	// normal check
214	>	newThresholdInode = checkAttributeThreshold(curValueInode, regInode, false);
215	>	typeInode = "%";
216	>	}
217	>
218		// format the diskInUse to a String
219		NumberFormat nf = NumberFormat.getInstance();
220		nf.setMaximumFractionDigits(2);
221		nf.setMinimumFractionDigits(2);
222		String strCurValue = nf.format(curValue);
223	+	String strCurValueInode = nf.format(curValueInode);
224
225		// say which disk had the problem
226		String attributeName = "Disk in use " + type + " on " + mount + " (" + device + ")";
227	+	String attributeNameInode = "Disk inodes in use " + type + " on " + mount + " (" + device +")";
228
229		processAlert(newThreshold, attributeName, reg, source, strCurValue);
230	+	processAlert(newThresholdInode, attributeNameInode, regInode, source, strCurValueInode);
231		}
232		}
233		}
#	Line 181 | Line 237 | public class Disk__Monitor extends MonitorSkeleton {
237		* Overrides the {@link java.lang.Object#toString() Object.toString()}
238		* method to provide clean logging (every class should have this).
239		*
240	<	* This uses the uk.org.iscream.cms.server.util.NameFormat class
240	>	* This uses the uk.org.iscream.cms.util.NameFormat class
241		* to format the toString()
242		*
243		* @return the name of this class and its CVS revision
#	Line 263 | Line 319 | public class Disk__Monitor extends MonitorSkeleton {
319		private String _name = "Disk";
320
321		/**
322	+	* Inodes have the name "DiskInode" in the
323	+	* configuration.
324	+	*/
325	+	private String _nameInode = "DiskInode";
326	+
327	+	/**
328		* A reference to the configuration proxy in use
329		*/
330		private ConfigurationProxy _cp = ConfigurationProxy.getInstance();
#	Line 272 | Line 334 | public class Disk__Monitor extends MonitorSkeleton {
334		* for each host we're monitoring.
335		*/
336		private HashMap _hosts = new HashMap();
337	+
338	+	/**
339	+	* A HashMap of Registers (or groups of Registers), one
340	+	* for each host we're monitoring (inodes).
341	+	*/
342	+	private HashMap _hostsInode = new HashMap();
343
344		//---STATIC ATTRIBUTES---
345

Diff Legend

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