2 |
|
|
3 |
|
//---IMPORTS--- |
4 |
|
|
5 |
– |
import java.util.Random; |
5 |
|
import java.io.*; |
6 |
+ |
import java.net.*; |
7 |
+ |
import java.util.*; |
8 |
|
|
9 |
|
/** |
10 |
|
* Gathers system information then outputs it as XML |
33 |
|
// like things to monitor |
34 |
|
|
35 |
|
lastCheck = System.currentTimeMillis(); |
36 |
< |
sequence = 0; |
36 |
> |
sequence = 1; |
37 |
|
|
38 |
|
|
39 |
|
// why oh why wont ultra edit let me put Long in the next line? oh its trying to |
40 |
|
// correct keywords =| |
41 |
+ |
/* |
42 |
+ |
|
43 |
|
try { |
44 |
|
udpcheckInterval = Long.parseLong(config.getProperty("UDPUpdateTime")) * 1000; |
45 |
|
} |
48 |
|
// 5 mins |
49 |
|
udpcheckInterval = 5000 * 60; |
50 |
|
} |
51 |
+ |
*/ |
52 |
+ |
|
53 |
|
// make the check interval into seconds |
54 |
|
|
55 |
|
} |
63 |
|
*/ |
64 |
|
public String getInfo(){ |
65 |
|
// called to retrieve the stored averages and output them as a XML string |
66 |
< |
XMLFormatter xml = new XMLFormatter("packet"); |
67 |
< |
|
63 |
< |
// the process to run |
66 |
> |
String host = new String(); |
67 |
> |
String ip = new String(); |
68 |
|
try { |
69 |
< |
Process proc = Runtime.getRuntime().exec("/usr/local/sbin/top -s1 -d2 0 > top.txt"); |
70 |
< |
// this process will take atleast 2 seconds to complete |
71 |
< |
try { |
72 |
< |
proc.waitFor(); |
69 |
< |
} |
70 |
< |
catch ( InterruptedException e ){ |
71 |
< |
|
72 |
< |
} |
73 |
< |
|
69 |
> |
host = InetAddress.getLocalHost().getHostName(); |
70 |
> |
ip = InetAddress.getLocalHost().getHostAddress(); |
71 |
> |
} catch(UnknownHostException e) { |
72 |
> |
System.out.println(e); |
73 |
|
} |
74 |
< |
catch ( IOException e ){ |
75 |
< |
|
76 |
< |
} |
77 |
< |
|
78 |
< |
|
79 |
< |
|
80 |
< |
// 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(); |
74 |
> |
String date = Long.toString(System.currentTimeMillis()); |
75 |
> |
XMLFormatter xml = new XMLFormatter("packet", "machine_name=\""+host+"\" ip=\""+ip+"\" date=\""+date+"\" seq_no=\""+sequence+"\" type=\"data\""); |
76 |
> |
|
77 |
> |
// get and decode the data |
78 |
> |
DecodeCPU_TXT details = new DecodeCPU_TXT(); |
79 |
> |
|
80 |
> |
// add the decoded info |
81 |
|
xml.addString(details.getItems()); |
82 |
|
|
83 |
|
|
84 |
+ |
/* |
85 |
|
// MUST FIX THIS..!!!! |
86 |
|
try { |
87 |
|
long updateIn = ( lastCheck + udpcheckInterval )-System.currentTimeMillis(); |
96 |
|
catch( InterruptedException e ){ |
97 |
|
System.out.println("Sleep interrupted"); |
98 |
|
} |
99 |
+ |
*/ |
100 |
|
|
101 |
|
// increment sequence. |
102 |
|
sequence++; |
103 |
< |
lastCheck = System.currentTimeMillis(); |
103 |
> |
// lastCheck = System.currentTimeMillis(); |
104 |
|
|
105 |
|
// finally return a string |
106 |
|
return xml.returnXML(); |
114 |
|
|
115 |
|
private long lastCheck; |
116 |
|
private int sequence; |
127 |
– |
private long udpcheckInterval; |
128 |
– |
private final long defaultUpdateTime = 60000; |
117 |
|
|
118 |
|
//---STATIC ATTRIBUTES--- |
119 |
|
|