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/Load__Monitor.java
Revision: 1.7
Committed: Wed Feb 5 16:43:45 2003 UTC (21 years, 4 months ago) by tdb
Branch: MAIN
Changes since 1.6: +4 -4 lines
Log Message:
Changed the server to use the external util package. Quite a minor change,
but does affect a lot of files.

File Contents

# User Rev Content
1 tdb 1.5 /*
2     * i-scream central monitoring system
3 tdb 1.6 * http://www.i-scream.org.uk
4 tdb 1.5 * 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 tdb 1.1 //---PACKAGE DECLARATION---
22 tdb 1.4 package uk.org.iscream.cms.server.client.monitors;
23 tdb 1.1
24     //---IMPORTS---
25     import java.util.HashMap;
26 tdb 1.4 import uk.org.iscream.cms.server.client.*;
27     import uk.org.iscream.cms.server.core.*;
28 tdb 1.7 import uk.org.iscream.cms.util.*;
29 tdb 1.4 import uk.org.iscream.cms.server.componentmanager.*;
30 tdb 1.1
31     /**
32     * This Monitor watches the Load for all machines
33     *
34 tdb 1.5 * @author $Author: tdb $
35 tdb 1.7 * @version $Id: Load__Monitor.java,v 1.6 2002/05/21 16:47:16 tdb Exp $
36 tdb 1.1 */
37     public class Load__Monitor extends MonitorSkeleton {
38    
39     //---FINAL ATTRIBUTES---
40    
41     /**
42     * The current CVS revision of this class
43     */
44 tdb 1.7 public final String REVISION = "$Revision: 1.6 $";
45 tdb 1.1
46 tdb 1.3 /**
47     * A description of this monitor
48     */
49 tdb 1.1 public final String DESC = "Monitors Load.";
50    
51     //---STATIC METHODS---
52    
53     //---CONSTRUCTORS---
54    
55     //---PUBLIC METHODS---
56 tdb 1.3
57     /**
58     * Analyse a packet of data, and generate an alert if
59     * necessary.
60     *
61     * @param packet the XMLPacket to analyse
62     */
63 tdb 1.1 public void analysePacket(XMLPacket packet) {
64    
65 ajm 1.2 String source = packet.getParam("packet.attributes.machine_name");
66     if (!_hosts.containsKey(source)) {
67     HashMap attributeRegisters = new HashMap();
68     initAttributeRegsiters(source, attributeRegisters);
69     _hosts.put(source, attributeRegisters);
70     }
71    
72     HashMap attributeRegisters = (HashMap) _hosts.get(source);
73     for(int attributeNum = 0; attributeNum < _attributes.length; attributeNum++) {
74     Register reg = (Register) attributeRegisters.get(_attributes[attributeNum]);
75     // find out the threshold level we're at
76     String attribute = _attributes[attributeNum];
77     String attributeName = _attributeNames[attributeNum];
78     String currentValue = packet.getParam(attribute);
79 tdb 1.3 // find out our new threshold
80 ajm 1.2 int newThreshold = checkAttributeThreshold(currentValue, reg);
81 tdb 1.3 // process this data to generate an alert
82 ajm 1.2 processAlert(newThreshold, attributeName, reg, source, currentValue);
83 tdb 1.1 }
84 ajm 1.2
85 tdb 1.1 }
86    
87     /**
88     * Overrides the {@link java.lang.Object#toString() Object.toString()}
89     * method to provide clean logging (every class should have this).
90     *
91 tdb 1.7 * This uses the uk.org.iscream.cms.util.NameFormat class
92 tdb 1.1 * to format the toString()
93     *
94     * @return the name of this class and its CVS revision
95     */
96     public String toString() {
97     return FormatName.getName(
98     _name,
99     getClass().getName(),
100     REVISION);
101     }
102    
103     /**
104     * return the String representation of what the monitor does
105     */
106     public String getDescription(){
107     return DESC;
108     }
109    
110     //---PRIVATE METHODS---
111 tdb 1.3
112     /**
113     * Checks a piece of current data, and returns the
114     * threshold it breaches, if any.
115     *
116     * @param attributeString a String representing the current data value
117     * @param reg the Register for the host
118     * @return the threshold level breached, if any
119     */
120 tdb 1.1 private int checkAttributeThreshold(String attributeString, Register reg) {
121     for(int thresholdLevel = Alert.thresholdLevels.length - 1; thresholdLevel >= 0; thresholdLevel--) {
122     if (reg.getThreshold(thresholdLevel) != -1.0) {
123     if(attributeString != null) {
124     try {
125     double attribute = Double.parseDouble(attributeString);
126     if (reg.getThreshold(thresholdLevel) < attribute) return thresholdLevel;
127     } catch (NumberFormatException e) {
128     // we got some duff data in the packet, but we shouldn't have
129     _logger.write(toString(), Logger.DEBUG, "possible errenous packet data, should be double value - " + attributeString);
130     }
131     }
132     }
133     }
134     return Alert.thresholdNORMAL;
135     }
136 tdb 1.3
137     /**
138     * Initialises a HashMap of Registers with the current list
139     * of attributes. This is only used if we are looking at more
140     * than one distinct attribute.
141     *
142     * @param source the host we are looking at
143     * @param attributeRegisters a HashMap to put the new Registers in
144     */
145 tdb 1.1 private void initAttributeRegsiters(String source, HashMap attributeRegisters) {
146     for(int attributeNum = 0; attributeNum < _attributes.length; attributeNum++) {
147     String attributeName = _attributes[attributeNum].substring(_attributes[attributeNum].lastIndexOf(".") + 1);
148     attributeRegisters.put(_attributes[attributeNum], new Register(source, _name, attributeName));
149     }
150     }
151    
152     //---ACCESSOR/MUTATOR METHODS---
153 tdb 1.3
154     /**
155     * Returns a reference to a specific Queue for this
156     * monitor. This Queue returns only the data packets
157     * (based on type) that we want too look at.
158     *
159     * @return a reference to a Queue
160     */
161 ajm 1.2 protected Queue getQueue() {
162     return MonitorManager.getInstance().getDataQueue();
163     }
164    
165 tdb 1.1
166     //---ATTRIBUTES---
167    
168     /**
169     * This is the friendly identifier of the
170     * component this class is running in.
171     * eg, a Filter may be called "filter1",
172     * If this class does not have an owning
173     * component, a name from the configuration
174     * can be placed here. This name could also
175     * be changed to null for utility classes.
176     */
177     private String _name = "Load";
178    
179     /**
180 tdb 1.3 * A HashMap of Registers (or groups of Registers), one
181     * for each host we're monitoring.
182 tdb 1.1 */
183     private HashMap _hosts = new HashMap();
184 tdb 1.3
185     /**
186     * An array of attributes which we will be checking.
187     */
188 tdb 1.1 private String[] _attributes = { "packet.load.load1", "packet.load.load5", "packet.load.load15" };
189 tdb 1.3
190     /**
191     * An array of "nice names" for the attributes in _attributes.
192     */
193 tdb 1.1 private String[] _attributeNames = {"1 min load avg.", "5 min load avg.", "15 min load avg."};
194    
195     //---STATIC ATTRIBUTES---
196    
197     }