1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
|
package org.apache.qpid.perftests.dlq.test;
import static org.apache.qpid.perftests.dlq.client.Config.*;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.PrintStream;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* Run a series of performance tests, based on specific configuration properties, and
* collect the results to generate statistics.
*/
public class PerformanceStatistics
{
private static final Logger _log = LoggerFactory.getLogger(PerformanceStatistics.class);
private Properties _props;
private List<Double> _sent = new ArrayList<Double>();
private List<Double> _received = new ArrayList<Double>();
private List<Double> _consumed = new ArrayList<Double>();
private List<Double> _rejected = new ArrayList<Double>();
private List<Double> _duration = new ArrayList<Double>();
private List<Double> _throughputIn = new ArrayList<Double>();
private List<Double> _throughputOut = new ArrayList<Double>();
private List<Double> _bandwidthIn = new ArrayList<Double>();
private List<Double> _bandwidthOut = new ArrayList<Double>();
private List<Double> _latency = new ArrayList<Double>();
private List<Statistics> _statistics = new ArrayList<Statistics>();
public PerformanceStatistics(File propertyFile)
{
try
{
InputStream input = new FileInputStream(propertyFile);
_props = new Properties();
_props.load(input);
}
catch (IOException ioe)
{
throw new RuntimeException("file error with " + propertyFile.getName());
}
}
public PerformanceStatistics(Properties props)
{
_props = props;
}
public boolean single(PrintStream out) throws Exception
{
PerformanceTest test = new PerformanceTest(_props);
if (test.test())
{
test.check(out);
_sent.add(test.getSent());
_received.add(test.getTotalReceived());
_consumed.add(test.getConsumed());
_rejected.add(test.getRejected());
_duration.add(test.getDuration());
_throughputIn.add(test.getThroughputIn());
_throughputOut.add(test.getThroughputOut());
_bandwidthIn.add(test.getBandwidthIn());
_bandwidthOut.add(test.getBandwidthOut());
_latency.add(test.getLatency());
return true;
}
else
{
return false;
}
}
public boolean series(File file) throws Exception
{
try
{
PrintStream out = new PrintStream(new FileOutputStream(file));
out.println(PerformanceTest.getHeader());
int repeat = Integer.parseInt(_props.getProperty(REPEAT));
for (int i = 0; i < repeat; i++)
{
_log.info("starting individual test run " + i);
if (!single(out))
{
return false;
}
_log.info("completed individual test run " + i);
}
}
catch (Exception e)
{
throw new RuntimeException("error running test series", e);
}
_statistics.add(new Statistics(_sent, "sent"));
_statistics.add(new Statistics(_received, "received"));
_statistics.add(new Statistics(_consumed, "consumed"));
_statistics.add(new Statistics(_rejected, "rejected"));
_statistics.add(new Statistics(_duration, "duration"));
_statistics.add(new Statistics(_throughputIn, "throughputIn"));
_statistics.add(new Statistics(_throughputOut, "throughputOut"));
_statistics.add(new Statistics(_bandwidthIn, "bandwidthIn"));
_statistics.add(new Statistics(_bandwidthOut, "bandwidthOut"));
_statistics.add(new Statistics(_latency, "latency"));
return true;
}
public void statistics(File file)
{
try
{
PrintStream out = new PrintStream(new FileOutputStream(file));
out.println(Statistics.getHeader());
for (Statistics stats : _statistics)
{
out.println(stats.toString());
}
}
catch (Exception e)
{
throw new RuntimeException("error outputting stats", e);
}
}
public static void main(String[] argv) throws Exception
{
if (argv.length != 1)
{
throw new IllegalArgumentException("must pass name of property file as argument");
}
File propertyFile = new File(argv[0]);
if (!propertyFile.exists() || !propertyFile.canRead())
{
throw new RuntimeException("property file '" + propertyFile.getAbsolutePath() + "' must exist and be readable");
}
PerformanceStatistics stats = new PerformanceStatistics(propertyFile);
if (stats.series(new File("series.csv")))
{
stats.statistics(new File("statistics.csv"));
}
else
{
System.err.println("connection faulre, test series aborted");
}
}
}
|
