client/monitors/Swap__Monitor.java

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

//---IMPORTS---
import java.util.HashMap;
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 Swap for all machines
 *
 * @author  $Author: tdb1 $
 * @version $Id: Swap__Monitor.java,v 1.1 2001/03/06 23:46:13 tdb1 Exp $
 */
public class Swap__Monitor extends MonitorSkeleton {

//---FINAL ATTRIBUTES---

    /**
     * The current CVS revision of this class
     */
    public final String REVISION = "$Revision: 1.1 $";
    
    public final String DESC = "Monitors Swap.";
    
//---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 Register(source, _name, 1));
            }
            
            Register reg = (Register) _hosts.get(source);
            
            // find out the threshold level we're at
            String attributeName = "Swap In Use %";
            
            // get the packet data
            double swapTotal, swapFree;
            try {
                String total = packet.getParam("packet.swap.total");
                String free = packet.getParam("packet.swap.free");
                if(total==null || free==null) {
                    throw new NumberFormatException("Memory data invalid");
                }
                swapTotal = Double.parseDouble(total);
                swapFree = Double.parseDouble(free);
            } catch (NumberFormatException e) {
                _logger.write(this.toString(), Logger.WARNING, "Received packet from "+source+" with bad swap information"+e);
                // don't try to continue and process
                return;
            }
            
            // percentage of memory in use
            double swapInUse = (1-(swapFree / swapTotal)) * 100;
            int newThreshold = checkAttributeThreshold(swapInUse, reg);
            
            // format the memoryInUse to a String
            NumberFormat nf = NumberFormat.getInstance();
            nf.setMaximumFractionDigits(2);
            nf.setMinimumFractionDigits(2);
            String strSwapInUse = nf.format(swapInUse);
            
            processAlert(newThreshold, 0, attributeName, reg, source, strSwapInUse);
            
        }
    }

    /**
     * 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 swapInUse, Register reg) {
        for(int thresholdLevel = Alert.thresholdLevels.length - 1; thresholdLevel >= 0; thresholdLevel--) {
            if (reg.getThreshold(thresholdLevel) != -1.0) {
                if(((double) reg.getThreshold(thresholdLevel)) < swapInUse) {
                    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 = "Swap";
    
    /**
     * A reference to the configuration proxy in use
     */
    private ConfigurationProxy _cp = ConfigurationProxy.getInstance();

    private HashMap _hosts = new HashMap();

//---STATIC ATTRIBUTES---

}
Revision:	1.2
Committed:	Wed Mar 7 00:38:05 2001 UTC (23 years, 2 months ago) by tdb
Branch:	MAIN
Changes since 1.1:	+21 -8 lines
Log Message:	Bug Fix: Made the mistake of comparing % of swap free, not the % of swap being used. This made the alerts all fire when they shouldn't. Also noticed that some "Infinity" items appeared, probably due to a divide by zero whilst working out the percentage. It seems that Double.parseDouble() wasn't throwing NumberFormatException.. maybe :/ Finally, the numbers were appearing like 95.238172732123, which looks silly. Now the NumberFormat class is used to set it to two decimal places.
#	User	Rev	Content
1	tdb	1.1	//---PACKAGE DECLARATION---
2			package uk.ac.ukc.iscream.client.monitors;
3
4			//---IMPORTS---
5			import java.util.HashMap;
6	tdb	1.2	import java.text.NumberFormat;
7	tdb	1.1	import uk.ac.ukc.iscream.client.*;
8			import uk.ac.ukc.iscream.core.*;
9			import uk.ac.ukc.iscream.util.*;
10			import uk.ac.ukc.iscream.componentmanager.*;
11
12			/**
13			* This Monitor watches the Swap for all machines
14			*
15	tdb	1.2	* @author $Author: tdb1 $
16			* @version $Id: Swap__Monitor.java,v 1.1 2001/03/06 23:46:13 tdb1 Exp $
17	tdb	1.1	*/
18			public class Swap__Monitor extends MonitorSkeleton {
19
20			//---FINAL ATTRIBUTES---
21
22			/**
23			* The current CVS revision of this class
24			*/
25			public final String REVISION = "$Revision: 1.1 $";
26
27			public final String DESC = "Monitors Swap.";
28
29			//---STATIC METHODS---
30
31			//---CONSTRUCTORS---
32
33			//---PUBLIC METHODS---
34
35			public void analysePacket(XMLPacket packet) {
36			if (packet.getParam("packet.attributes.type").equals("data")) {
37			String source = packet.getParam("packet.attributes.machine_name");
38			if (!_hosts.containsKey(source)) {
39			_hosts.put(source, new Register(source, _name, 1));
40			}
41
42			Register reg = (Register) _hosts.get(source);
43
44			// find out the threshold level we're at
45			String attributeName = "Swap In Use %";
46
47			// get the packet data
48			double swapTotal, swapFree;
49			try {
50	tdb	1.2	String total = packet.getParam("packet.swap.total");
51			String free = packet.getParam("packet.swap.free");
52			if(total==null \|\| free==null) {
53			throw new NumberFormatException("Memory data invalid");
54			}
55			swapTotal = Double.parseDouble(total);
56			swapFree = Double.parseDouble(free);
57	tdb	1.1	} catch (NumberFormatException e) {
58	tdb	1.2	_logger.write(this.toString(), Logger.WARNING, "Received packet from "+source+" with bad swap information"+e);
59	tdb	1.1	// don't try to continue and process
60			return;
61			}
62
63			// percentage of memory in use
64	tdb	1.2	double swapInUse = (1-(swapFree / swapTotal)) * 100;
65			int newThreshold = checkAttributeThreshold(swapInUse, reg);
66
67			// format the memoryInUse to a String
68			NumberFormat nf = NumberFormat.getInstance();
69			nf.setMaximumFractionDigits(2);
70			nf.setMinimumFractionDigits(2);
71			String strSwapInUse = nf.format(swapInUse);
72
73			processAlert(newThreshold, 0, attributeName, reg, source, strSwapInUse);
74	tdb	1.1
75			}
76			}
77
78			/**
79			* Overrides the {@link java.lang.Object#toString() Object.toString()}
80			* method to provide clean logging (every class should have this).
81			*
82			* This uses the uk.ac.ukc.iscream.util.NameFormat class
83			* to format the toString()
84			*
85			* @return the name of this class and its CVS revision
86			*/
87			public String toString() {
88			return FormatName.getName(
89			_name,
90			getClass().getName(),
91			REVISION);
92			}
93
94			/**
95			* return the String representation of what the monitor does
96			*/
97			public String getDescription(){
98			return DESC;
99			}
100
101			//---PRIVATE METHODS---
102
103			private int checkAttributeThreshold(double swapInUse, Register reg) {
104			for(int thresholdLevel = Alert.thresholdLevels.length - 1; thresholdLevel >= 0; thresholdLevel--) {
105			if (reg.getThreshold(thresholdLevel) != -1.0) {
106			if(((double) reg.getThreshold(thresholdLevel)) < swapInUse) {
107			return thresholdLevel;
108			}
109			}
110			}
111			return Alert.thresholdNORMAL;
112			}
113
114			//---ACCESSOR/MUTATOR METHODS---
115
116			//---ATTRIBUTES---
117
118			/**
119			* This is the friendly identifier of the
120			* component this class is running in.
121			* eg, a Filter may be called "filter1",
122			* If this class does not have an owning
123			* component, a name from the configuration
124			* can be placed here. This name could also
125			* be changed to null for utility classes.
126			*/
127			private String _name = "Swap";
128
129			/**
130			* A reference to the configuration proxy in use
131			*/
132			private ConfigurationProxy _cp = ConfigurationProxy.getInstance();
133
134			private HashMap _hosts = new HashMap();
135
136			//---STATIC ATTRIBUTES---
137
138			}