host/java/DecodeCPU_TXT.java

import java.io.*;
import java.util.*;

class DecodeCPU_TXT {

    XMLFormatter packet;

    public DecodeCPU_TXT(){
        HashMap data;
        try {
            String[] cmd = {"statgrab.pl"};
            Process proc = Runtime.getRuntime().exec(cmd);
            BufferedReader in = new BufferedReader(new InputStreamReader(proc.getInputStream()));
            
            data = new HashMap();
            
            // Messy, but it'll keep going until no more data :/
            try {
                String line = new String();
                while(true) {
                    line = in.readLine();
                    int split = line.indexOf(' ');
                    data.put(line.substring(0, split), line.substring(split+1));
                }
            }
            catch (Exception e) {}
            
            String load1 = (String) data.get("packet.load.load1");
            String load5 = (String) data.get("packet.load.load5");
            String load15 = (String) data.get("packet.load.load15");
            
            String totalProcesses = (String) data.get("packet.processes.total");
            String sleeping = (String) data.get("packet.processes.sleeping");
            String zombie = (String) data.get("packet.processes.zombie");
            String stopped = (String) data.get("packet.processes.stopped");
            String onCPU = (String) data.get("packet.processes.cpu");
            
            String idle = (String) data.get("packet.cpu.idle");
            String user = (String) data.get("packet.cpu.user");
            String kernel = (String) data.get("packet.cpu.kernel");
            String iowait = (String) data.get("packet.cpu.iowait");
            String swap = (String) data.get("packet.cpu.swap");
            
            String real = (String) data.get("packet.memory.real");
            String free = (String) data.get("packet.memory.free");
            String swapTotal = (String) data.get("packet.memory.swap_total");
            String swapFree = (String) data.get("packet.memory.swap_free");
            
            String osname = (String) data.get("packet.os.name");
            String osrelease = (String) data.get("packet.os.release");
            String osplatform = (String) data.get("packet.os.platform");
            String ossysname = (String) data.get("packet.os.sysname");
            String osversion = (String) data.get("packet.os.version");
            
            String usercount = (String) data.get("packet.users.count");
            String userlist = (String) data.get("packet.users.list");
            
            packet = new XMLFormatter();
            packet.addNest("os");
                packet.addElement("name",osname);
                packet.addElement("release",osrelease);
                packet.addElement("platform",osplatform);
                packet.addElement("sysname",ossysname);
                packet.addElement("version",osversion);
            packet.closeNest(); 
            packet.addNest("load");
                packet.addElement("load1",load1);
                packet.addElement("load5",load5);
                packet.addElement("load15",load15);
            packet.closeNest(); 
            packet.addNest("processes");
                packet.addElement("total",totalProcesses);
                packet.addElement("sleeping",sleeping);
                packet.addElement("zombie",zombie);
                packet.addElement("stopped",stopped);
                packet.addElement("cpu",onCPU);
            packet.closeNest();
            packet.addNest("cpu");
                packet.addElement("idle",idle);
                packet.addElement("user",user);
                packet.addElement("kernel",kernel);
                packet.addElement("iowait",iowait);
                packet.addElement("swap",swap);
            packet.closeNest();
            packet.addNest("memory");
                packet.addElement("total",real);
                packet.addElement("free",free);
            packet.closeNest();
            packet.addNest("swap");
                packet.addElement("total",swapTotal);
                packet.addElement("free",swapFree);
            packet.closeNest(); 
            packet.addNest("users");
                packet.addElement("count",usercount);
                packet.addElement("list",userlist);
            packet.closeNest();
            packet.addNest("disk");
                int i=0;
                while(true) {
                    String check = (String) data.get("packet.disk.p"+i+".attributes.name");
                    if(check == null) {
                        break;
                    }
                    packet.addNest("p"+i);
                        packet.addElement("name",check);
                        packet.addElement("kbytes",(String) data.get("packet.disk.p"+i+".attributes.kbytes"));
                        packet.addElement("used",(String) data.get("packet.disk.p"+i+".attributes.used"));
                        packet.addElement("avail",(String) data.get("packet.disk.p"+i+".attributes.avail"));
                        packet.addElement("mount",(String) data.get("packet.disk.p"+i+".attributes.mount"));
                    packet.closeNest();
                    i++;
                }
            packet.closeNest();
            in.close();
            
        }
        catch(Exception e) {
            System.out.println("ERROR IN DECODE: "+e);
            e.printStackTrace();
        }

    }

    public String getItems(){
        // return the xml
        return packet.returnXML();
    }
    

} // class
Revision:	1.11
Committed:	Fri Jan 26 17:01:09 2001 UTC (23 years, 7 months ago) by tdb
Branch:	MAIN
CVS Tags:	PROJECT_COMPLETION
Changes since 1.10:	+1 -0 lines
Log Message:	Seems I missed one !
#	User	Rev	Content
1	ab11	1.1	import java.io.*;
2			import java.util.*;
3
4			class DecodeCPU_TXT {
5
6	tdb	1.10	XMLFormatter packet;
7	ab11	1.1
8	tdb	1.10	public DecodeCPU_TXT(){
9			HashMap data;
10	tdb	1.8	try {
11			String[] cmd = {"statgrab.pl"};
12			Process proc = Runtime.getRuntime().exec(cmd);
13			BufferedReader in = new BufferedReader(new InputStreamReader(proc.getInputStream()));
14
15			data = new HashMap();
16
17			// Messy, but it'll keep going until no more data :/
18			try {
19			String line = new String();
20			while(true) {
21			line = in.readLine();
22			int split = line.indexOf(' ');
23			data.put(line.substring(0, split), line.substring(split+1));
24			}
25			}
26			catch (Exception e) {}
27
28			String load1 = (String) data.get("packet.load.load1");
29	tdb	1.10	String load5 = (String) data.get("packet.load.load5");
30			String load15 = (String) data.get("packet.load.load15");
31
32			String totalProcesses = (String) data.get("packet.processes.total");
33			String sleeping = (String) data.get("packet.processes.sleeping");
34			String zombie = (String) data.get("packet.processes.zombie");
35			String stopped = (String) data.get("packet.processes.stopped");
36			String onCPU = (String) data.get("packet.processes.cpu");
37
38			String idle = (String) data.get("packet.cpu.idle");
39			String user = (String) data.get("packet.cpu.user");
40			String kernel = (String) data.get("packet.cpu.kernel");
41			String iowait = (String) data.get("packet.cpu.iowait");
42			String swap = (String) data.get("packet.cpu.swap");
43
44			String real = (String) data.get("packet.memory.real");
45			String free = (String) data.get("packet.memory.free");
46			String swapTotal = (String) data.get("packet.memory.swap_total");
47			String swapFree = (String) data.get("packet.memory.swap_free");
48	tdb	1.8
49			String osname = (String) data.get("packet.os.name");
50			String osrelease = (String) data.get("packet.os.release");
51			String osplatform = (String) data.get("packet.os.platform");
52			String ossysname = (String) data.get("packet.os.sysname");
53			String osversion = (String) data.get("packet.os.version");
54
55			String usercount = (String) data.get("packet.users.count");
56			String userlist = (String) data.get("packet.users.list");
57
58			packet = new XMLFormatter();
59			packet.addNest("os");
60			packet.addElement("name",osname);
61			packet.addElement("release",osrelease);
62			packet.addElement("platform",osplatform);
63			packet.addElement("sysname",ossysname);
64			packet.addElement("version",osversion);
65	tdb	1.10	packet.closeNest();
66			packet.addNest("load");
67			packet.addElement("load1",load1);
68			packet.addElement("load5",load5);
69			packet.addElement("load15",load15);
70			packet.closeNest();
71			packet.addNest("processes");
72			packet.addElement("total",totalProcesses);
73			packet.addElement("sleeping",sleeping);
74			packet.addElement("zombie",zombie);
75			packet.addElement("stopped",stopped);
76	tdb	1.11	packet.addElement("cpu",onCPU);
77	tdb	1.10	packet.closeNest();
78			packet.addNest("cpu");
79			packet.addElement("idle",idle);
80			packet.addElement("user",user);
81			packet.addElement("kernel",kernel);
82			packet.addElement("iowait",iowait);
83			packet.addElement("swap",swap);
84			packet.closeNest();
85			packet.addNest("memory");
86			packet.addElement("total",real);
87			packet.addElement("free",free);
88			packet.closeNest();
89			packet.addNest("swap");
90			packet.addElement("total",swapTotal);
91			packet.addElement("free",swapFree);
92			packet.closeNest();
93	tdb	1.8	packet.addNest("users");
94			packet.addElement("count",usercount);
95	tdb	1.10	packet.addElement("list",userlist);
96			packet.closeNest();
97			packet.addNest("disk");
98			int i=0;
99			while(true) {
100			String check = (String) data.get("packet.disk.p"+i+".attributes.name");
101			if(check == null) {
102			break;
103			}
104			packet.addNest("p"+i);
105			packet.addElement("name",check);
106			packet.addElement("kbytes",(String) data.get("packet.disk.p"+i+".attributes.kbytes"));
107			packet.addElement("used",(String) data.get("packet.disk.p"+i+".attributes.used"));
108			packet.addElement("avail",(String) data.get("packet.disk.p"+i+".attributes.avail"));
109			packet.addElement("mount",(String) data.get("packet.disk.p"+i+".attributes.mount"));
110			packet.closeNest();
111			i++;
112			}
113			packet.closeNest();
114			in.close();
115	tdb	1.8
116			}
117			catch(Exception e) {
118			System.out.println("ERROR IN DECODE: "+e);
119			e.printStackTrace();
120			}
121
122	tdb	1.10	}
123	ab11	1.1
124	tdb	1.10	public String getItems(){
125			// return the xml
126			return packet.returnXML();
127			}
128
129	ab11	1.1
130	tdb	1.5	} // class