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 XPSockStat extends SysStatHandler {
38: private static final String command = "typeperf \"\\TCP\\Connections Established\" -sc 1";
39:
40: private String tcp_key;
41:
42: public void initialize(String host, int pid) {
43: tcp_key = "Host" + KEY_SEPR + host + KEY_SEPR + "Network"
44: + KEY_SEPR + "TCP" + KEY_SEPR + "sockets" + KEY_SEPR
45: + "inuse";
46: }
47:
48: public void getData(Map<String, DataValue> map) {
49: Logger logger = org.cougaar.qos.qrs.Logging
50: .getLogger(XPLoadAverage.class);
51: String line = null;
52: try {
53: Process process = Runtime.getRuntime().exec(command);
54: InputStream stdOut = process.getInputStream();
55: InputStreamReader rdr = new InputStreamReader(stdOut);
56: BufferedReader bufferedStdOut = new BufferedReader(rdr);
57: line = bufferedStdOut.readLine(); // handy blank line -- ignore
58: line = bufferedStdOut.readLine(); //headers --- ignore
59: line = bufferedStdOut.readLine();
60: bufferedStdOut.close();
61: process.destroy();
62: } catch (java.io.IOException ioex) {
63: logger.warn("Error running typeperf: " + ioex.getMessage());
64: return;
65: }
66:
67: String[] csv = line.split(",");
68: if (csv.length == 2) {
69: String connectionCount = csv[1];
70: // remove the extra pair of surrounding quotes
71: connectionCount = connectionCount.substring(1,
72: connectionCount.length() - 2);
73: double count = Double.parseDouble(connectionCount);
74: map.put(tcp_key, new DataValue(count,
75: SECOND_MEAS_CREDIBILITY, "", PROVENANCE));
76: }
77: }
78: }
|