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
(Generate patch)

Comparing projects/cms/source/server/uk/org/iscream/cms/server/client/monitors/Disk__Monitor.java (file contents):
Revision 1.7 by ajm, Thu Mar 22 17:57:05 2001 UTC vs.
Revision 1.12 by tdb, Wed Nov 7 17:55:40 2001 UTC

# Line 1 | Line 1
1   //---PACKAGE DECLARATION---
2 < package uk.org.iscream.client.monitors;
2 > package uk.org.iscream.cms.server.client.monitors;
3  
4   //---IMPORTS---
5   import java.util.HashMap;
# Line 7 | Line 7 | import java.util.ArrayList;
7   import java.util.Set;
8   import java.util.Iterator;
9   import java.text.NumberFormat;
10 < import uk.org.iscream.client.*;
11 < import uk.org.iscream.core.*;
12 < import uk.org.iscream.util.*;
13 < import uk.org.iscream.componentmanager.*;
10 > import uk.org.iscream.cms.server.client.*;
11 > import uk.org.iscream.cms.server.core.*;
12 > import uk.org.iscream.cms.server.util.*;
13 > import uk.org.iscream.cms.server.componentmanager.*;
14  
15   /**
16   * This Monitor watches the Disks for all machines
# Line 27 | Line 27 | public class Disk__Monitor extends MonitorSkeleton {
27       */
28      public final String REVISION = "$Revision$";
29      
30 +    /**
31 +     * A description of this monitor
32 +     */
33      public final String DESC = "Monitors all host disks.";
34      
35   //---STATIC METHODS---
# Line 34 | Line 37 | public class Disk__Monitor extends MonitorSkeleton {
37   //---CONSTRUCTORS---
38  
39   //---PUBLIC METHODS---
40 <
40 >    
41 >    /**
42 >     * Analyse a packet of data, and generate an alert if
43 >     * necessary.
44 >     *
45 >     * @param packet the XMLPacket to analyse
46 >     */
47      public void analysePacket(XMLPacket packet) {
48          String source = packet.getParam("packet.attributes.machine_name");
49          if (!_hosts.containsKey(source)) {
# Line 42 | Line 51 | public class Disk__Monitor extends MonitorSkeleton {
51          }
52  
53          HashMap diskRegisters = (HashMap) _hosts.get(source);
54 <
55 <        // a tempory holder for all the disk attributes we find
54 >        
55 >        // key prefix
56 >        String keyPrefix = "packet.disk.p";
57 >        
58 >        // a temporary holder for all the disk attributes we find
59          ArrayList disks = new ArrayList();
60  
61          // unfortunatly we need to check the whole packet
# Line 52 | Line 64 | public class Disk__Monitor extends MonitorSkeleton {
64          Iterator i = packetSet.iterator();
65          while (i.hasNext()) {
66              String dataKey = (String) i.next();
67 <            if(dataKey.startsWith("packet.disk.p")) {
67 >            if(dataKey.startsWith(keyPrefix)) {
68                  if(!disks.contains(dataKey)) {
69                      String diskNumber = "";
70  
71                      // pos is after "packet.disk.p"
72 <                    int pos = 13;
72 >                    int pos = keyPrefix.length();
73                      while (dataKey.charAt(pos) != '.') {
74                          diskNumber = diskNumber + dataKey.charAt(pos);
75                          pos++;
# Line 66 | Line 78 | public class Disk__Monitor extends MonitorSkeleton {
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("packet.disk.p" + diskNumber + ".attributes.used");
81 >                    disks.add(keyPrefix + diskNumber + ".attributes.used");
82  
83                      // device
84 <                    disks.add("packet.disk.p" + diskNumber + ".attributes.name");
85 <                    String device = packet.getParam("packet.disk.p" + diskNumber + ".attributes.name");
84 >                    disks.add(keyPrefix + diskNumber + ".attributes.name");
85 >                    String device = packet.getParam(keyPrefix + diskNumber + ".attributes.name");
86                      // mount point
87 <                    disks.add("packet.disk.p" + diskNumber + ".attributes.mount");
88 <                    String mount = packet.getParam("packet.disk.p" + diskNumber + ".attributes.mount");
87 >                    disks.add(keyPrefix + diskNumber + ".attributes.mount");
88 >                    String mount = packet.getParam(keyPrefix + diskNumber + ".attributes.mount");
89  
90                      // these next two will be used to calculate the %age
91                      // total
92 <                    disks.add("packet.disk.p" + diskNumber + ".attributes.kbytes");
93 <                    String total = packet.getParam("packet.disk.p" + diskNumber + ".attributes.kbytes");
92 >                    disks.add(keyPrefix + diskNumber + ".attributes.kbytes");
93 >                    String total = packet.getParam(keyPrefix + diskNumber + ".attributes.kbytes");
94                      // available
95 <                    disks.add("packet.disk.p" + diskNumber + ".attributes.avail");
96 <                    String avail = packet.getParam("packet.disk.p" + diskNumber + ".attributes.avail");
95 >                    disks.add(keyPrefix + diskNumber + ".attributes.avail");
96 >                    String avail = packet.getParam(keyPrefix + diskNumber + ".attributes.avail");
97  
98                      // *** now process this disk ***
99  
100                      // check if we've seen this disk before on a previous run
101                      // if not, we need to create a register for it
102 <                    if(!diskRegisters.containsKey(diskNumber)) {
103 <                        diskRegisters.put(diskNumber, new Register(source, _name, mount));
102 >                    //   nb. use the device as the key as this is unlikely to change,
103 >                    //       unlike diskNumber which could easily change
104 >                    //         (diskNumber is based on the order of df's output!)
105 >                    if(!diskRegisters.containsKey(device)) {
106 >                        diskRegisters.put(device, new Register(source, _name, mount));
107                      }
108  
109                      // get the register for this disk
110 <                    Register reg = (Register) diskRegisters.get(diskNumber);
110 >                    Register reg = (Register) diskRegisters.get(device);
111  
112                      // get the packet data
113                      double diskTotal, diskAvail;
# Line 121 | Line 136 | public class Disk__Monitor extends MonitorSkeleton {
136  
137                      // this  bit determines if the disk check is a % check
138                      // or a kb check
124 –                    double diskInUse;
139                      String type;
140 +                    double curValue;
141 +                    int newThreshold;
142                      if(useValue) {
143 <                        // kb disk in use
144 <                        diskInUse = diskTotal - diskAvail;
143 >                        // kb disk available
144 >                        curValue = diskAvail;
145 >                        // negate check
146 >                        newThreshold = checkAttributeThreshold(curValue, reg, true);
147                          type = "kb";
148                      } else {
149                          // % disk in use
150 <                        diskInUse = (1 - (diskAvail / diskTotal)) * 100;
150 >                        curValue = (1 - (diskAvail / diskTotal)) * 100;
151 >                        // normal check
152 >                        newThreshold = checkAttributeThreshold(curValue, reg, false);
153                          type = "%";
154                      }
155  
136 –
137 –
138 –                    int newThreshold = checkAttributeThreshold(diskInUse, reg);
139 –
156                      // format the diskInUse to a String
157                      NumberFormat nf = NumberFormat.getInstance();
158                      nf.setMaximumFractionDigits(2);
159                      nf.setMinimumFractionDigits(2);
160 <                    String strDiskInUse = nf.format(diskInUse);
160 >                    String strCurValue = nf.format(curValue);
161  
162                      // say which disk had the problem
163                      String attributeName = "Disk in use " + type + " on " + mount + " (" + device + ")";
164  
165 <                    processAlert(newThreshold, attributeName, reg, source, strDiskInUse);
165 >                    processAlert(newThreshold, attributeName, reg, source, strCurValue);
166                  }
167              }
168          }
# Line 156 | Line 172 | public class Disk__Monitor extends MonitorSkeleton {
172       * Overrides the {@link java.lang.Object#toString() Object.toString()}
173       * method to provide clean logging (every class should have this).
174       *
175 <     * This uses the uk.org.iscream.util.NameFormat class
175 >     * This uses the uk.org.iscream.cms.server.util.NameFormat class
176       * to format the toString()
177       *
178       * @return the name of this class and its CVS revision
# Line 176 | Line 192 | public class Disk__Monitor extends MonitorSkeleton {
192      }
193  
194   //---PRIVATE METHODS---
195 <
196 <    private int checkAttributeThreshold(double diskInUse, Register reg) {
195 >    
196 >    /**
197 >     * Checks a piece of current data, and returns the
198 >     * threshold it breaches, if any.
199 >     *
200 >     * The option to negate the check can be used in
201 >     * situations where being *below* the threshold
202 >     * is an 'alertable' situation. In this specific
203 >     * case, we'd do this with kb disk checks.
204 >     *
205 >     * @param value the current value
206 >     * @param reg the Register for the host
207 >     * @param negateCheck whether to negate the check
208 >     * @return the threshold level breached, if any
209 >     */
210 >    private int checkAttributeThreshold(double diskInUse, Register reg, boolean negateCheck) {
211          for(int thresholdLevel = Alert.thresholdLevels.length - 1; thresholdLevel >= 0; thresholdLevel--) {
212              if (reg.getThreshold(thresholdLevel) != -1.0) {
213 <                if(((double) reg.getThreshold(thresholdLevel)) < diskInUse) {
214 <                    return thresholdLevel;
213 >                if(!negateCheck) {
214 >                    // normal check - has the value gone *over* the threshold
215 >                    if(((double) reg.getThreshold(thresholdLevel)) < diskInUse) {
216 >                        return thresholdLevel;
217 >                    }
218                  }
219 +                else {
220 +                    // negated check - has the value gone *under* the threshold
221 +                    if(((double) reg.getThreshold(thresholdLevel)) > diskInUse) {
222 +                        return thresholdLevel;
223 +                    }
224 +                }
225              }
226          }
227          return Alert.thresholdNORMAL;
# Line 190 | Line 229 | public class Disk__Monitor extends MonitorSkeleton {
229  
230   //---ACCESSOR/MUTATOR METHODS---
231      
232 +    /**
233 +     * Returns a reference to a specific Queue for this
234 +     * monitor. This Queue returns only the data packets
235 +     * (based on type) that we want too look at.
236 +     *
237 +     * @return a reference to a Queue
238 +     */
239      protected Queue getQueue() {
240          return MonitorManager.getInstance().getDataQueue();
241      }
# Line 211 | Line 257 | public class Disk__Monitor extends MonitorSkeleton {
257       * A reference to the configuration proxy in use
258       */
259      private ConfigurationProxy _cp = ConfigurationProxy.getInstance();
260 <
260 >    
261 >    /**
262 >     * A HashMap of Registers (or groups of Registers), one
263 >     * for each host we're monitoring.
264 >     */
265      private HashMap _hosts = new HashMap();
266  
267   //---STATIC ATTRIBUTES---

Diff Legend

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