ViewVC Help

View File | Revision Log | Show Annotations | Revision Graph | Root Listing

root/i-scream/projects/cms/source/host/java/SystemMonitor.java

Comparing projects/cms/source/host/java/SystemMonitor.java (file contents):
Revision 1.1 by ab11, Mon Nov 27 19:44:32 2000 UTC vs.
Revision 1.5 by ab11, Thu Dec 7 18:25:37 2000 UTC

#	Line 1 | Line 1
1	+	//---PACKAGE DECLARATION---
2	+
3	+	//---IMPORTS---
4	+
5	+	import java.util.Random;
6	+	import java.io.*;
7	+
8	+	/**
9	+	* Gathers system information then outputs it as XML
10	+	* Collects data based on properties gained from the configurator
11	+	* then packages these up using XMLFormatter and outputs them if
12	+	* the timeout has passed.
13	+	*
14	+	* @author  $Author$
15	+	* @version $Id$
16	+	*/
17		class SystemMonitor {
18
19	<	public SystemMonitor( Config config ){
4	<	// create a new instace, get the info we need out of config
5	<	// like things to monitor
6	<
7	<	lastCheck = System.currentTimeMillis();
8	<	sequence = 0;
19	>	//---FINAL ATTRIBUTES---
20
21	+	//---STATIC METHODS---
22
23	<	// why oh why wont ultra edit let me put Long in the next line? oh its trying to
12	<	// correct keywords =|
13	<	checkInterval = Long.parseLong(config.getProperty("UDPINTEVAL"));
14	<
15	<	}
23	>	//---CONSTRUCTORS---
24
25	<	public String getInfo(){
26	<	// called to retrieve the stored averages and output them as a XML string
27	<	XMLFormatter xml = new XMLFormatter("packet");
28	<
29	<	// just send some dummy info for now.
30	<	xml.addNest("packet_info");
31	<	String currentTime = Long.toString(System.currentTimeMillis());
32	<	xml.addElement("date_time", currentTime );
33	<	xml.addElement("sequence", Integer.toString(sequence));
34	<	xml.closeNest();
35	<	xml.addNest("core");
36	<	xml.addElement("cpu","100");
37	<	xml.addElement("memory","200");
38	<	xml.closeNest();
39	<	xml.addNest("additional");
40	<	xml.addElement("users","20");
41	<	xml.closeNest();
42	<
43	<	// MUST FIX THIS..!!!!
44	<	while ( System.currentTimeMillis() < ( lastCheck + checkInterval ) ){
45	<	// errm do nothing.. block or something.
25	>	/**
26	>	* Public constructor for the class. Takes in a Config object to gain its
27	>	* properties from.
28	>	*
29	>	*/
30	>	public SystemMonitor( Config config ){
31	>	// create a new instace, get the info we need out of config
32	>	// like things to monitor
33	>
34	>	lastCheck = System.currentTimeMillis();
35	>	sequence = 0;
36	>
37	>
38	>	// why oh why wont ultra edit let me put Long in the next line? oh its trying to
39	>	// correct keywords =|
40	>	try {
41	>	udpcheckInterval = Long.parseLong(config.getProperty("UDPUpdateTime")) * 1000;
42	>	}
43	>	catch ( NumberFormatException e ){
44	>	System.out.println("The value for UDPUpdateTime is invalid, using a default");
45	>	// 5 mins
46	>	udpcheckInterval = 5000 * 60;
47	>	}
48	>	// make the check interval into seconds
49	>
50	>	}
51	>
52	>	//---PUBLIC METHODS---
53	>
54	>	/**
55	>	* Gathers system information and will black until the timeout has passed.
56	>	*
57	>	* @return the system information in an XML packet
58	>	*/
59	>	public String getInfo(){
60	>	// called to retrieve the stored averages and output them as a XML string
61	>	XMLFormatter xml = new XMLFormatter("packet");
62	>
63	>	// the process to run
64	>	try {
65	>	Process proc = Runtime.getRuntime().exec("/usr/local/sbin/top -s1 -d2 0 > top.txt");
66	>	// this process will take atleast 2 seconds to complete
67	>	try {
68	>	proc.waitFor();
69	>	}
70	>	catch ( InterruptedException e ){
71	>
72		}
73	<
74	<	// increment sequence.
75	<	sequence++;
76	<
77	<	// finally return a string
78	<	return xml.returnXML();
79	<	} // getinfo()
73	>
74	>	}
75	>	catch ( IOException e ){
76	>
77	>	}
78	>
79	>
80	>
81	>	// now do some text processing.
82	>	DecodeCPU_TXT details = new DecodeCPU_TXT("top.txt");
83	>
84	>
85	>	Random rand = new Random();
86	>
87	>	// just send some dummy info for now.
88	>	xml.addNest("packet_info");
89	>	String currentTime = Long.toString(System.currentTimeMillis());
90	>	xml.addElement("date_time", currentTime );
91	>	xml.addElement("sequence", Integer.toString(sequence));
92	>	xml.closeNest();
93	>	xml.addString(details.getItems());
94	>
95	>
96	>	// MUST FIX THIS..!!!!
97	>	try {
98	>	long updateIn = ( lastCheck + udpcheckInterval )-System.currentTimeMillis();
99	>	if ( updateIn > 0 ){
100	>	Thread.sleep(updateIn);
101	>	}
102	>	else
103	>	{
104	>	Thread.sleep(defaultUpdateTime);
105	>	}
106	>	}
107	>	catch( InterruptedException e ){
108	>	System.out.println("Sleep interrupted");
109	>	}
110	>
111	>	// increment sequence.
112	>	sequence++;
113	>	lastCheck = System.currentTimeMillis();
114	>
115	>	// finally return a string
116	>	return xml.returnXML();
117	>	} // getinfo()
118	>
119	>	//---PRIVATE METHODS---
120
121	<	// last time the system data was returned.
121	>	//---ACCESSOR/MUTATOR METHODS---
122	>
123	>	//---ATTRIBUTES---
124	>
125		private long lastCheck;
126		private int sequence;
127	<	private long checkInterval;
127	>	private long udpcheckInterval;
128	>	private final long defaultUpdateTime = 60000;
129	>
130	>	//---STATIC ATTRIBUTES---
131
132		} // class

Diff Legend

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