host/java/DecodeCPU_TXT.java

/* 
 * i-scream central monitoring system
 * http://www.i-scream.org.uk
 * Copyright (C) 2000-2002 i-scream
 * 
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License
 * as published by the Free Software Foundation; either version 2
 * of the License, or (at your option) any later version.
 * 
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 * 
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
 */

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