01: /*
02: * <copyright>
03: *
04: * Copyright 2002-2007 BBNT Solutions, LLC
05: * under sponsorship of the Defense Advanced Research Projects
06: * Agency (DARPA).
07: *
08: * You can redistribute this software and/or modify it under the
09: * terms of the Cougaar Open Source License as published on the
10: * Cougaar Open Source Website (www.cougaar.org).
11: *
12: * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
13: * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
14: * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
15: * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
16: * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
17: * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
18: * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
19: * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
20: * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
21: * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
22: * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
23: *
24: * </copyright>
25: */
26:
27: package org.cougaar.qos.qrs.sysstat;
28:
29: import java.io.BufferedReader;
30: import java.io.InputStream;
31: import java.io.InputStreamReader;
32: import java.util.Map;
33:
34: import org.cougaar.qos.qrs.DataValue;
35: import org.cougaar.util.log.Logger;
36:
37: public class XPMemory extends SysStatHandler {
38: private static final String command = "typeperf \"\\Memory\\Available KBytes\" -sc 1";
39:
40: private String free_key;
41:
42: public void initialize(String host, int pid) {
43: free_key = "Host" + KEY_SEPR + host + KEY_SEPR + "Memory"
44: + KEY_SEPR + "Physical" + KEY_SEPR + "Free";
45: }
46:
47: public void getData(Map<String, DataValue> map) {
48: Logger logger = org.cougaar.qos.qrs.Logging
49: .getLogger(XPLoadAverage.class);
50: String line = null;
51: try {
52: Process process = Runtime.getRuntime().exec(command);
53: InputStream stdOut = process.getInputStream();
54: InputStreamReader rdr = new InputStreamReader(stdOut);
55: BufferedReader bufferedStdOut = new BufferedReader(rdr);
56: line = bufferedStdOut.readLine(); // handy blank line -- ignore
57: line = bufferedStdOut.readLine(); //headers --- ignore
58: line = bufferedStdOut.readLine();
59: bufferedStdOut.close();
60: process.destroy();
61: } catch (java.io.IOException ioex) {
62: logger.warn("Error running typeperf: " + ioex.getMessage());
63: return;
64: }
65:
66: String[] csv = line.split(",");
67: if (csv.length == 2) {
68: String connectionCount = csv[1];
69: // remove the extra pair of surrounding quotes
70: connectionCount = connectionCount.substring(1,
71: connectionCount.length() - 2);
72: double count = Double.parseDouble(connectionCount);
73: map.put(free_key, new DataValue(count,
74: SECOND_MEAS_CREDIBILITY, "", PROVENANCE));
75: }
76: }
77: }
|