client/monitors/Disk__Monitor.java

//---PACKAGE DECLARATION---
package uk.ac.ukc.iscream.client.monitors;

//---IMPORTS---
import java.util.HashMap;
import java.util.ArrayList;
import java.util.Set;
import java.util.Iterator;
import java.text.NumberFormat;
import uk.ac.ukc.iscream.client.*;
import uk.ac.ukc.iscream.core.*;
import uk.ac.ukc.iscream.util.*;
import uk.ac.ukc.iscream.componentmanager.*;

/**
 * This Monitor watches the Disks for all machines
 *
 * @author  $Author: ajm4 $
 * @version $Id: Disk__Monitor.java,v 1.1 2001/03/09 01:22:46 ajm4 Exp $
 */
public class Disk__Monitor extends MonitorSkeleton {

//---FINAL ATTRIBUTES---

    /**
     * The current CVS revision of this class
     */
    public final String REVISION = "$Revision: 1.1 $";
    
    public final String DESC = "Monitors all host disks.";
    
//---STATIC METHODS---

//---CONSTRUCTORS---

//---PUBLIC METHODS---

    public void analysePacket(XMLPacket packet) {
        if (packet.getParam("packet.attributes.type").equals("data")) {
            String source = packet.getParam("packet.attributes.machine_name");
            if (!_hosts.containsKey(source)) {
                _hosts.put(source, new HashMap());
            }
                        
            HashMap diskRegisters = (HashMap) _hosts.get(source);
            
            // a tempory holder for all the disk attributes we find
            ArrayList disks = new ArrayList();
            
            // unfortunatly we need to check the whole packet
            // to find the disks, and then get the data attributes
            Set packetSet = packet.getSet();
            Iterator i = packetSet.iterator();
            while (i.hasNext()) {
                String dataKey = (String) i.next();
                if(dataKey.startsWith("packet.disk.p")) {
                    if(!disks.contains(dataKey)) {
                        String diskNumber = "";
            
                        // pos is after "packet.disk.p"
                        int pos = 13;
                        while (dataKey.charAt(pos) != '.') {
                            diskNumber = diskNumber + dataKey.charAt(pos);
                            pos++;
                        }
                        
                        // add the disk to our list, with the packet data
                        
                        // used (we won't use this value - but we need it to forget about it ;)
                        disks.add("packet.disk.p" + diskNumber + ".attributes.used");
                        
                        // device
                        disks.add("packet.disk.p" + diskNumber + ".attributes.name");
                        String device = packet.getParam("packet.disk.p" + diskNumber + ".attributes.name");
                        // mount point
                        disks.add("packet.disk.p" + diskNumber + ".attributes.mount");
                        String mount = packet.getParam("packet.disk.p" + diskNumber + ".attributes.mount");

                        // these next two will be used to calculate the %age
                        // total
                        disks.add("packet.disk.p" + diskNumber + ".attributes.kbytes");
                        String total = packet.getParam("packet.disk.p" + diskNumber + ".attributes.kbytes");
                        // available
                        disks.add("packet.disk.p" + diskNumber + ".attributes.avail");
                        String avail = packet.getParam("packet.disk.p" + diskNumber + ".attributes.avail");

                        // *** now process this disk ***

                        // check if we've seen this disk before on a previous run
                        // if not, we need to create a register for it
                        if(!diskRegisters.containsKey(diskNumber)) {
                            diskRegisters.put(diskNumber, new Register(source, _name));
                        }

                        // get the register for this disk
                        Register reg = (Register) diskRegisters.get(diskNumber);

                        // get the packet data
                        double diskTotal, diskAvail;
                        try {
                
                            if(total==null || avail==null) {
                                throw new NumberFormatException("Disk data invalid");
                            }
                            diskTotal = Double.parseDouble(total);
                            diskAvail = Double.parseDouble(avail);
                        } catch (NumberFormatException e) {
                            _logger.write(this.toString(), Logger.WARNING, "Received packet from "+source+" with bad disk information: "+e);
                            // don't try to continue and process, try next disk
                            break;
                        }
            
                        // percentage of memory in use
                        double diskInUse = (1 - (diskAvail / diskTotal)) * 100;
                        int newThreshold = checkAttributeThreshold(diskInUse, reg);
            
                        // format the memoryInUse to a String
                        NumberFormat nf = NumberFormat.getInstance();
                        nf.setMaximumFractionDigits(2);
                        nf.setMinimumFractionDigits(2);
                        String strDiskInUse = nf.format(diskInUse);
  
                        // say which disk had the problem
                        String attributeName = "Disk in use % on " + mount + " (" + device + ")";
                                                
                        processAlert(newThreshold, attributeName, reg, source, strDiskInUse);
                    }
                }
            }
        }
    }

    /**
     * Overrides the {@link java.lang.Object#toString() Object.toString()}
     * method to provide clean logging (every class should have this).
     *
     * This uses the uk.ac.ukc.iscream.util.NameFormat class
     * to format the toString()
     *
     * @return the name of this class and its CVS revision
     */
    public String toString() {
        return FormatName.getName(
            _name,
            getClass().getName(),
            REVISION);
    }

    /**
     * return the String representation of what the monitor does
     */
    public String getDescription(){
        return DESC;
    }

//---PRIVATE METHODS---

    private int checkAttributeThreshold(double diskInUse, Register reg) {
        for(int thresholdLevel = Alert.thresholdLevels.length - 1; thresholdLevel >= 0; thresholdLevel--) {
            if (reg.getThreshold(thresholdLevel) != -1.0) {
                if(((double) reg.getThreshold(thresholdLevel)) < diskInUse) {
                    return thresholdLevel;
                }
            }
        }
        return Alert.thresholdNORMAL;
    }

//---ACCESSOR/MUTATOR METHODS---

//---ATTRIBUTES---

    /**
     * This is the friendly identifier of the
     * component this class is running in.
     * eg, a Filter may be called "filter1",
     * If this class does not have an owning
     * component,  a name from the configuration
     * can be placed here.  This name could also
     * be changed to null for utility classes.
     */
    private String _name = "Disk";
    
    /**
     * A reference to the configuration proxy in use
     */
    private ConfigurationProxy _cp = ConfigurationProxy.getInstance();

    private HashMap _hosts = new HashMap();

//---STATIC ATTRIBUTES---

}
Revision:	1.2
Committed:	Fri Mar 9 03:30:55 2001 UTC (23 years, 3 months ago) by ajm
Branch:	MAIN
Changes since 1.1:	+15 -6 lines
Log Message:	TOTALLY re-wrote the Register class and made appropriate changes thoughout. It is now much more obvious what is going on in many places. The problem was probably caused by doing CPU as a first monitor and hard coding the number of attributes a Register stores. Now if a monitor wants to store multiple attributes, it has to do that itself. This makes alot of things much more readable and inteligable as a result.
#	Content
1	//---PACKAGE DECLARATION---
2	package uk.ac.ukc.iscream.client.monitors;
3
4	//---IMPORTS---
5	import java.util.HashMap;
6	import java.util.ArrayList;
7	import java.util.Set;
8	import java.util.Iterator;
9	import java.text.NumberFormat;
10	import uk.ac.ukc.iscream.client.*;
11	import uk.ac.ukc.iscream.core.*;
12	import uk.ac.ukc.iscream.util.*;
13	import uk.ac.ukc.iscream.componentmanager.*;
14
15	/**
16	* This Monitor watches the Disks for all machines
17	*
18	* @author $Author: ajm4 $
19	* @version $Id: Disk__Monitor.java,v 1.1 2001/03/09 01:22:46 ajm4 Exp $
20	*/
21	public class Disk__Monitor extends MonitorSkeleton {
22
23	//---FINAL ATTRIBUTES---
24
25	/**
26	* The current CVS revision of this class
27	*/
28	public final String REVISION = "$Revision: 1.1 $";
29
30	public final String DESC = "Monitors all host disks.";
31
32	//---STATIC METHODS---
33
34	//---CONSTRUCTORS---
35
36	//---PUBLIC METHODS---
37
38	public void analysePacket(XMLPacket packet) {
39	if (packet.getParam("packet.attributes.type").equals("data")) {
40	String source = packet.getParam("packet.attributes.machine_name");
41	if (!_hosts.containsKey(source)) {
42	_hosts.put(source, new HashMap());
43	}
44
45	HashMap diskRegisters = (HashMap) _hosts.get(source);
46
47	// a tempory holder for all the disk attributes we find
48	ArrayList disks = new ArrayList();
49
50	// unfortunatly we need to check the whole packet
51	// to find the disks, and then get the data attributes
52	Set packetSet = packet.getSet();
53	Iterator i = packetSet.iterator();
54	while (i.hasNext()) {
55	String dataKey = (String) i.next();
56	if(dataKey.startsWith("packet.disk.p")) {
57	if(!disks.contains(dataKey)) {
58	String diskNumber = "";
59
60	// pos is after "packet.disk.p"
61	int pos = 13;
62	while (dataKey.charAt(pos) != '.') {
63	diskNumber = diskNumber + dataKey.charAt(pos);
64	pos++;
65	}
66
67	// add the disk to our list, with the packet data
68
69	// used (we won't use this value - but we need it to forget about it ;)
70	disks.add("packet.disk.p" + diskNumber + ".attributes.used");
71
72	// device
73	disks.add("packet.disk.p" + diskNumber + ".attributes.name");
74	String device = packet.getParam("packet.disk.p" + diskNumber + ".attributes.name");
75	// mount point
76	disks.add("packet.disk.p" + diskNumber + ".attributes.mount");
77	String mount = packet.getParam("packet.disk.p" + diskNumber + ".attributes.mount");
78
79	// these next two will be used to calculate the %age
80	// total
81	disks.add("packet.disk.p" + diskNumber + ".attributes.kbytes");
82	String total = packet.getParam("packet.disk.p" + diskNumber + ".attributes.kbytes");
83	// available
84	disks.add("packet.disk.p" + diskNumber + ".attributes.avail");
85	String avail = packet.getParam("packet.disk.p" + diskNumber + ".attributes.avail");
86
87	// * now process this disk *
88
89	// check if we've seen this disk before on a previous run
90	// if not, we need to create a register for it
91	if(!diskRegisters.containsKey(diskNumber)) {
92	diskRegisters.put(diskNumber, new Register(source, _name));
93	}
94
95	// get the register for this disk
96	Register reg = (Register) diskRegisters.get(diskNumber);
97
98	// get the packet data
99	double diskTotal, diskAvail;
100	try {
101
102	if(total==null \|\| avail==null) {
103	throw new NumberFormatException("Disk data invalid");
104	}
105	diskTotal = Double.parseDouble(total);
106	diskAvail = Double.parseDouble(avail);
107	} catch (NumberFormatException e) {
108	_logger.write(this.toString(), Logger.WARNING, "Received packet from "+source+" with bad disk information: "+e);
109	// don't try to continue and process, try next disk
110	break;
111	}
112
113	// percentage of memory in use
114	double diskInUse = (1 - (diskAvail / diskTotal)) * 100;
115	int newThreshold = checkAttributeThreshold(diskInUse, reg);
116
117	// format the memoryInUse to a String
118	NumberFormat nf = NumberFormat.getInstance();
119	nf.setMaximumFractionDigits(2);
120	nf.setMinimumFractionDigits(2);
121	String strDiskInUse = nf.format(diskInUse);
122
123	// say which disk had the problem
124	String attributeName = "Disk in use % on " + mount + " (" + device + ")";
125
126	processAlert(newThreshold, attributeName, reg, source, strDiskInUse);
127	}
128	}
129	}
130	}
131	}
132
133	/**
134	* Overrides the {@link java.lang.Object#toString() Object.toString()}
135	* method to provide clean logging (every class should have this).
136	*
137	* This uses the uk.ac.ukc.iscream.util.NameFormat class
138	* to format the toString()
139	*
140	* @return the name of this class and its CVS revision
141	*/
142	public String toString() {
143	return FormatName.getName(
144	_name,
145	getClass().getName(),
146	REVISION);
147	}
148
149	/**
150	* return the String representation of what the monitor does
151	*/
152	public String getDescription(){
153	return DESC;
154	}
155
156	//---PRIVATE METHODS---
157
158	private int checkAttributeThreshold(double diskInUse, Register reg) {
159	for(int thresholdLevel = Alert.thresholdLevels.length - 1; thresholdLevel >= 0; thresholdLevel--) {
160	if (reg.getThreshold(thresholdLevel) != -1.0) {
161	if(((double) reg.getThreshold(thresholdLevel)) < diskInUse) {
162	return thresholdLevel;
163	}
164	}
165	}
166	return Alert.thresholdNORMAL;
167	}
168
169	//---ACCESSOR/MUTATOR METHODS---
170
171	//---ATTRIBUTES---
172
173	/**
174	* This is the friendly identifier of the
175	* component this class is running in.
176	* eg, a Filter may be called "filter1",
177	* If this class does not have an owning
178	* component, a name from the configuration
179	* can be placed here. This name could also
180	* be changed to null for utility classes.
181	*/
182	private String _name = "Disk";
183
184	/**
185	* A reference to the configuration proxy in use
186	*/
187	private ConfigurationProxy _cp = ConfigurationProxy.getInstance();
188
189	private HashMap _hosts = new HashMap();
190
191	//---STATIC ATTRIBUTES---
192
193	}