client/monitors/Heartbeat__Monitor.java

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

//---IMPORTS---
import java.util.HashMap;
import java.util.Iterator;
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 heartbeats
 *
 * @author  $Author: tdb1 $
 * @version $Id: Heartbeat__Monitor.java,v 1.11 2001/03/07 21:38:14 tdb1 Exp $
 */
public class Heartbeat__Monitor extends MonitorSkeleton implements Runnable {

//---FINAL ATTRIBUTES---

    /**
     * The current CVS revision of this class
     */
    public final String REVISION = "$Revision: 1.11 $";
    
    public final String DESC = "Monitors Heartbeats.";
    
    public final int DEFAULT_CHECK_PERIOD = 60;
    
//---STATIC METHODS---

//---CONSTRUCTORS---

    public Heartbeat__Monitor() {
        new Thread(this).start();
    }

//---PUBLIC METHODS---
    
    public void run() {
        ConfigurationProxy cp = ConfigurationProxy.getInstance();
        while(true) {
            // this cycle period of this monitor's checks
            int checkPeriod = 0;
            try {
                checkPeriod = Integer.parseInt(cp.getProperty(_name, "Monitor.Heartbeat.checkPeriod"));
            } catch (PropertyNotFoundException e) {
                checkPeriod = DEFAULT_CHECK_PERIOD;
                _logger.write(toString(), Logger.WARNING, "Monitor.Heartbeat.checkPeriod value unavailable using default of " + checkPeriod + " seconds");
            } catch (NumberFormatException e) {
                checkPeriod = DEFAULT_CHECK_PERIOD;
                _logger.write(toString(), Logger.WARNING, "Erronous Monitor.Heartbeat.checkPeriod value in configuration using default of " + checkPeriod + " seconds");
            }
            
            synchronized(this) {
                // perform the checks (use HB hash, although they *should* be the same)
                Iterator i = _hosts.keySet().iterator();
                while(i.hasNext()) {
                    // get host
                    String source = (String) i.next();
                    // check it
                    boolean remove = analyseHB(source);
                    if(remove) {
                        i.remove();
                    }
                }
            }
            
            // wait a while
            try {Thread.sleep(checkPeriod * 1000);} catch (InterruptedException e) {}
        }
    }
    
    public void analysePacket(XMLPacket packet) {
        if (packet.getParam("packet.attributes.type").equals("heartbeat")) {
            String source = packet.getParam("packet.attributes.machine_name");
            if (!_hosts.containsKey(source)) {
                synchronized(this) {
                    HashMap registerHash = new HashMap();
                    registerHash.put(source, new Register(source, _name));
                    _hosts.put(source, new HeartbeatHolder(registerHash));
                }
            }
            HeartbeatHolder lastHeartbeat = (HeartbeatHolder) _hosts.get(source);
            lastHeartbeat.setLastHeartbeat(System.currentTimeMillis()/1000);
        }
    }
    
    /**
     * 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 boolean analyseHB(String source) {
        ConfigurationProxy cp = ConfigurationProxy.getInstance();
        HeartbeatHolder hbHolder = (HeartbeatHolder) _hosts.get(source);
        Register reg = (Register) ((HashMap) hbHolder.getRegisterHash()).get(source);
        
        // get host's HB interval (seconds)
        // this should always exist, thus we set to 0
        int hostHBinterval = 0;
        try {
            hostHBinterval = Integer.parseInt(cp.getProperty("Host."+source, "Host.TCPUpdateTime"));
        } catch (PropertyNotFoundException e) {
            hostHBinterval = 0;
            _logger.write(toString(), Logger.WARNING, "TCPUpdateTime value unavailable using default of " + hostHBinterval + " seconds");
        } catch (NumberFormatException e) {
            hostHBinterval = 0;
            _logger.write(toString(), Logger.WARNING, "Erronous TCPUpdateTime value in configuration using default of " + hostHBinterval + " seconds");
        }
        
        // get host's last HB time (seconds)
        long lastHeartbeat = hbHolder.getLastHeartbeat();
        // time since last heartbeat (seconds)
        long timeSinceLastHB = (System.currentTimeMillis()/1000) - lastHeartbeat;
        // time since (or until if negative) the expected heartbeat
        long timeSinceExpectedHB = timeSinceLastHB - (long) hostHBinterval;
        
        // best do a check in case the expected heartbeat is in the future
        if(timeSinceExpectedHB < 0) {
            timeSinceExpectedHB = 0;
        }
        
        // find out the threshold level we're at
        int newThreshold = checkAttributeThreshold(timeSinceExpectedHB, reg);
        
        // process the alert
        processAlert(newThreshold, "Heartbeat", reg, source, String.valueOf(timeSinceExpectedHB));
        
        if(reg.getLastAlertLevel() == Alert.alertFINAL) {
            return true;
        }
        return false;
    }
    
    private int checkAttributeThreshold(long timeSinceLastHB, Register reg) {
        for(int thresholdLevel = Alert.thresholdLevels.length - 1; thresholdLevel >= 0; thresholdLevel--) {
            if (reg.getThreshold(thresholdLevel) != -1.0) {
                if (((long) reg.getThreshold(thresholdLevel)) < timeSinceLastHB) {
                    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 = "Heartbeat";
    
    /**
     * A reference to the configuration proxy in use
     */
    private ConfigurationProxy _cp = ConfigurationProxy.getInstance();

    private HashMap _hosts = new HashMap();

//---STATIC ATTRIBUTES---

//---INNER CLASSES---

    private class HeartbeatHolder {
        
        public HeartbeatHolder(HashMap registerHash) {
            _registerHash = registerHash;
        }
        
        public void setLastHeartbeat(long lastHeartbeat) {
            _lastHeartbeat = lastHeartbeat;
        }
        
        public long getLastHeartbeat() {
            return _lastHeartbeat;
        }
        
        public HashMap getRegisterHash() {
            return _registerHash;
        }
        
        private long _lastHeartbeat;
        private HashMap _registerHash;
    }   

}
Revision:	1.12
Committed:	Fri Mar 9 03:30:55 2001 UTC (23 years, 2 months ago) by ajm
Branch:	MAIN
Changes since 1.11:	+5 -5 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	tdb	1.1	//---PACKAGE DECLARATION---
2			package uk.ac.ukc.iscream.client.monitors;
3
4			//---IMPORTS---
5			import java.util.HashMap;
6			import java.util.Iterator;
7			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 heartbeats
14			*
15	tdb	1.7	* @author $Author: tdb1 $
16	ajm	1.12	* @version $Id: Heartbeat__Monitor.java,v 1.11 2001/03/07 21:38:14 tdb1 Exp $
17	tdb	1.1	*/
18	tdb	1.7	public class Heartbeat__Monitor extends MonitorSkeleton implements Runnable {
19	tdb	1.1
20			//---FINAL ATTRIBUTES---
21
22			/**
23			* The current CVS revision of this class
24			*/
25	ajm	1.12	public final String REVISION = "$Revision: 1.11 $";
26	tdb	1.1
27			public final String DESC = "Monitors Heartbeats.";
28
29	tdb	1.3	public final int DEFAULT_CHECK_PERIOD = 60;
30
31	tdb	1.1	//---STATIC METHODS---
32
33			//---CONSTRUCTORS---
34
35	tdb	1.2	public Heartbeat__Monitor() {
36	tdb	1.3	new Thread(this).start();
37	tdb	1.2	}
38
39	tdb	1.1	//---PUBLIC METHODS---
40
41			public void run() {
42			ConfigurationProxy cp = ConfigurationProxy.getInstance();
43			while(true) {
44	tdb	1.3	// this cycle period of this monitor's checks
45			int checkPeriod = 0;
46			try {
47			checkPeriod = Integer.parseInt(cp.getProperty(_name, "Monitor.Heartbeat.checkPeriod"));
48			} catch (PropertyNotFoundException e) {
49			checkPeriod = DEFAULT_CHECK_PERIOD;
50			_logger.write(toString(), Logger.WARNING, "Monitor.Heartbeat.checkPeriod value unavailable using default of " + checkPeriod + " seconds");
51			} catch (NumberFormatException e) {
52			checkPeriod = DEFAULT_CHECK_PERIOD;
53			_logger.write(toString(), Logger.WARNING, "Erronous Monitor.Heartbeat.checkPeriod value in configuration using default of " + checkPeriod + " seconds");
54			}
55	tdb	1.1
56	tdb	1.9	synchronized(this) {
57			// perform the checks (use HB hash, although they should be the same)
58			Iterator i = _hosts.keySet().iterator();
59			while(i.hasNext()) {
60			// get host
61			String source = (String) i.next();
62			// check it
63			boolean remove = analyseHB(source);
64			if(remove) {
65			i.remove();
66			}
67	tdb	1.6	}
68	tdb	1.1	}
69
70			// wait a while
71			try {Thread.sleep(checkPeriod * 1000);} catch (InterruptedException e) {}
72			}
73			}
74
75	tdb	1.10	public void analysePacket(XMLPacket packet) {
76	tdb	1.1	if (packet.getParam("packet.attributes.type").equals("heartbeat")) {
77			String source = packet.getParam("packet.attributes.machine_name");
78	tdb	1.6	if (!_hosts.containsKey(source)) {
79	tdb	1.10	synchronized(this) {
80			HashMap registerHash = new HashMap();
81	ajm	1.12	registerHash.put(source, new Register(source, _name));
82	tdb	1.10	_hosts.put(source, new HeartbeatHolder(registerHash));
83			}
84	tdb	1.1	}
85	tdb	1.6	HeartbeatHolder lastHeartbeat = (HeartbeatHolder) _hosts.get(source);
86	tdb	1.2	lastHeartbeat.setLastHeartbeat(System.currentTimeMillis()/1000);
87	tdb	1.1	}
88			}
89
90			/**
91			* Overrides the {@link java.lang.Object#toString() Object.toString()}
92			* method to provide clean logging (every class should have this).
93			*
94			* This uses the uk.ac.ukc.iscream.util.NameFormat class
95			* to format the toString()
96			*
97			* @return the name of this class and its CVS revision
98			*/
99			public String toString() {
100			return FormatName.getName(
101			_name,
102			getClass().getName(),
103			REVISION);
104			}
105
106			/**
107			* return the String representation of what the monitor does
108			*/
109			public String getDescription(){
110			return DESC;
111			}
112
113			//---PRIVATE METHODS---
114	tdb	1.7
115			private boolean analyseHB(String source) {
116			ConfigurationProxy cp = ConfigurationProxy.getInstance();
117			HeartbeatHolder hbHolder = (HeartbeatHolder) _hosts.get(source);
118			Register reg = (Register) ((HashMap) hbHolder.getRegisterHash()).get(source);
119
120			// get host's HB interval (seconds)
121			// this should always exist, thus we set to 0
122			int hostHBinterval = 0;
123			try {
124			hostHBinterval = Integer.parseInt(cp.getProperty("Host."+source, "Host.TCPUpdateTime"));
125			} catch (PropertyNotFoundException e) {
126			hostHBinterval = 0;
127			_logger.write(toString(), Logger.WARNING, "TCPUpdateTime value unavailable using default of " + hostHBinterval + " seconds");
128			} catch (NumberFormatException e) {
129			hostHBinterval = 0;
130			_logger.write(toString(), Logger.WARNING, "Erronous TCPUpdateTime value in configuration using default of " + hostHBinterval + " seconds");
131			}
132
133			// get host's last HB time (seconds)
134			long lastHeartbeat = hbHolder.getLastHeartbeat();
135			// time since last heartbeat (seconds)
136			long timeSinceLastHB = (System.currentTimeMillis()/1000) - lastHeartbeat;
137	tdb	1.8	// time since (or until if negative) the expected heartbeat
138	tdb	1.11	long timeSinceExpectedHB = timeSinceLastHB - (long) hostHBinterval;
139	tdb	1.8
140			// best do a check in case the expected heartbeat is in the future
141			if(timeSinceExpectedHB < 0) {
142			timeSinceExpectedHB = 0;
143			}
144	tdb	1.7
145			// find out the threshold level we're at
146	tdb	1.8	int newThreshold = checkAttributeThreshold(timeSinceExpectedHB, reg);
147	tdb	1.7
148			// process the alert
149	ajm	1.12	processAlert(newThreshold, "Heartbeat", reg, source, String.valueOf(timeSinceExpectedHB));
150	tdb	1.7
151	ajm	1.12	if(reg.getLastAlertLevel() == Alert.alertFINAL) {
152	tdb	1.7	return true;
153			}
154			return false;
155			}
156	tdb	1.1
157	tdb	1.2	private int checkAttributeThreshold(long timeSinceLastHB, Register reg) {
158	tdb	1.1	for(int thresholdLevel = Alert.thresholdLevels.length - 1; thresholdLevel >= 0; thresholdLevel--) {
159			if (reg.getThreshold(thresholdLevel) != -1.0) {
160	tdb	1.2	if (((long) reg.getThreshold(thresholdLevel)) < timeSinceLastHB) {
161	tdb	1.1	return thresholdLevel;
162			}
163			}
164			}
165	tdb	1.7	return Alert.thresholdNORMAL;
166	tdb	1.1	}
167
168			//---ACCESSOR/MUTATOR METHODS---
169
170			//---ATTRIBUTES---
171
172			/**
173			* This is the friendly identifier of the
174			* component this class is running in.
175			* eg, a Filter may be called "filter1",
176			* If this class does not have an owning
177			* component, a name from the configuration
178			* can be placed here. This name could also
179			* be changed to null for utility classes.
180			*/
181			private String _name = "Heartbeat";
182
183			/**
184			* A reference to the configuration proxy in use
185			*/
186			private ConfigurationProxy _cp = ConfigurationProxy.getInstance();
187
188	tdb	1.6	private HashMap _hosts = new HashMap();
189	tdb	1.1
190			//---STATIC ATTRIBUTES---
191
192			//---INNER CLASSES---
193
194			private class HeartbeatHolder {
195
196	tdb	1.6	public HeartbeatHolder(HashMap registerHash) {
197			_registerHash = registerHash;
198			}
199
200	tdb	1.2	public void setLastHeartbeat(long lastHeartbeat) {
201	tdb	1.1	_lastHeartbeat = lastHeartbeat;
202			}
203
204	tdb	1.2	public long getLastHeartbeat() {
205	tdb	1.1	return _lastHeartbeat;
206			}
207
208	tdb	1.6	public HashMap getRegisterHash() {
209			return _registerHash;
210			}
211
212	tdb	1.2	private long _lastHeartbeat;
213	tdb	1.6	private HashMap _registerHash;
214	tdb	1.1	}
215
216			}