Skip to content

ID for PerfTest jobs and Unique system out for better output in multithreading. #170

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 8 commits into from
Aug 24, 2016
Merged

ID for PerfTest jobs and Unique system out for better output in multithreading. #170

Changes from all commits
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
14f2166
Add config manager for openstack perf utility
abousselmi Aug 9, 2016
9fd23be
Remove Configuration and empty P/C classes.
abousselmi Aug 9, 2016
d1c4b17
Add an ID to PerfTest output.
abousselmi Aug 22, 2016
6d44cbf
Update test ID declaration.
abousselmi Aug 22, 2016
e57d3f0
Update PerfTest System.out.
abousselmi Aug 22, 2016
686a033
Correction of an identation mistake.
abousselmi Aug 23, 2016
4995878
Change showRate to getRate.
abousselmi Aug 23, 2016
56686ae
Correct indentation mistake.
abousselmi Aug 23, 2016
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
59 changes: 36 additions & 23 deletions src/test/java/com/rabbitmq/examples/PerfTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,9 @@

package com.rabbitmq.examples;

import java.text.SimpleDateFormat;
import java.util.Arrays;
import java.util.Calendar;
import java.util.List;

import com.rabbitmq.examples.perf.MulticastParams;
Expand All @@ -33,6 +35,7 @@


public class PerfTest {

public static void main(String[] args) {
Options options = getOptions();
CommandLineParser parser = new GnuParser();
Expand All @@ -43,7 +46,9 @@ public static void main(String[] args) {
usage(options);
System.exit(0);
}

String testID = new SimpleDateFormat("HHmmss-SSS").format(Calendar.
getInstance().getTime());
testID = strArg(cmd, 'd', "test-"+testID);
String exchangeType = strArg(cmd, 't', "direct");
String exchangeName = strArg(cmd, 'e', exchangeType);
String queueName = strArg(cmd, 'u', "");
Expand Down Expand Up @@ -73,12 +78,13 @@ public static void main(String[] args) {
String uri = strArg(cmd, 'h', "amqp://localhost");

//setup
PrintlnStats stats = new PrintlnStats(1000L * samplingInterval,
producerCount > 0,
consumerCount > 0,
(flags.contains("mandatory") ||
flags.contains("immediate")),
confirm != -1);
PrintlnStats stats = new PrintlnStats(testID,
1000L * samplingInterval,
producerCount > 0,
consumerCount > 0,
(flags.contains("mandatory") ||
flags.contains("immediate")),
confirm != -1);

ConnectionFactory factory = new ConnectionFactory();
factory.setShutdownTimeout(0); // So we still shut down even with slow consumers
Expand Down Expand Up @@ -135,6 +141,7 @@ private static void usage(Options options) {
private static Options getOptions() {
Options options = new Options();
options.addOption(new Option("?", "help", false,"show usage"));
options.addOption(new Option("d", "id", true, "Test ID"));
options.addOption(new Option("h", "uri", true, "connection URI"));
options.addOption(new Option("t", "type", true, "exchange type"));
options.addOption(new Option("e", "exchange", true, "exchange name"));
Expand Down Expand Up @@ -191,42 +198,48 @@ private static class PrintlnStats extends Stats {
private final boolean recvStatsEnabled;
private final boolean returnStatsEnabled;
private final boolean confirmStatsEnabled;

private final String testID;

public PrintlnStats(long interval,
public PrintlnStats(String testID, long interval,
boolean sendStatsEnabled, boolean recvStatsEnabled,
boolean returnStatsEnabled, boolean confirmStatsEnabled) {
super(interval);
this.sendStatsEnabled = sendStatsEnabled;
this.recvStatsEnabled = recvStatsEnabled;
this.returnStatsEnabled = returnStatsEnabled;
this.confirmStatsEnabled = confirmStatsEnabled;
this.testID = testID;
}

@Override
protected void report(long now) {
System.out.print("time: " + String.format("%.3f", (now - startTime)/1000.0) + "s");

showRate("sent", sendCountInterval, sendStatsEnabled, elapsedInterval);
showRate("returned", returnCountInterval, sendStatsEnabled && returnStatsEnabled, elapsedInterval);
showRate("confirmed", confirmCountInterval, sendStatsEnabled && confirmStatsEnabled, elapsedInterval);
showRate("nacked", nackCountInterval, sendStatsEnabled && confirmStatsEnabled, elapsedInterval);
showRate("received", recvCountInterval, recvStatsEnabled, elapsedInterval);

System.out.print((latencyCountInterval > 0 ?
String output = "id: " + testID + ", ";

output += "time: " + String.format("%.3f", (now - startTime)/1000.0) + "s";
output +=
getRate("sent", sendCountInterval, sendStatsEnabled, elapsedInterval) +
getRate("returned", returnCountInterval, sendStatsEnabled && returnStatsEnabled, elapsedInterval) +
getRate("confirmed", confirmCountInterval, sendStatsEnabled && confirmStatsEnabled, elapsedInterval) +
getRate("nacked", nackCountInterval, sendStatsEnabled && confirmStatsEnabled, elapsedInterval) +
getRate("received", recvCountInterval, recvStatsEnabled, elapsedInterval);

output += (latencyCountInterval > 0 ?
", min/avg/max latency: " +
minLatency/1000L + "/" +
cumulativeLatencyInterval / (1000L * latencyCountInterval) + "/" +
maxLatency/1000L + " microseconds" :
""));
"");

System.out.println();
System.out.println(output);
}

private void showRate(String descr, long count, boolean display,
private String getRate(String descr, long count, boolean display,
long elapsed) {
if (display) {
System.out.print(", " + descr + ": " + formatRate(1000.0 * count / elapsed) + " msg/s");
}
if (display)
return ", " + descr + ": " + formatRate(1000.0 * count / elapsed) + " msg/s";
else
return "";
}

public void printFinal() {
Expand Down