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.
#	User	Rev	Content
1	ajm	1.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	ajm	1.2	* @author $Author: ajm4 $
19			* @version $Id: Disk__Monitor.java,v 1.1 2001/03/09 01:22:46 ajm4 Exp $
20	ajm	1.1	*/
21			public class Disk__Monitor extends MonitorSkeleton {
22
23			//---FINAL ATTRIBUTES---
24
25			/**
26			* The current CVS revision of this class
27			*/
28	ajm	1.2	public final String REVISION = "$Revision: 1.1 $";
29	ajm	1.1
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	ajm	1.2	_hosts.put(source, new HashMap());
43	ajm	1.1	}
44
45	ajm	1.2	HashMap diskRegisters = (HashMap) _hosts.get(source);
46	ajm	1.1
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	ajm	1.2	// 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	ajm	1.1	// 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	ajm	1.2	processAlert(newThreshold, attributeName, reg, source, strDiskInUse);
127	ajm	1.1	}
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			}