| Methods Summary |
|---|
| public void | clearData()Clear all data, prepare for more tests.
points.clear();
|
| private Report | genReportFromList(int reported, java.util.LinkedHashMap p2)
String longetOp = longestOp(p2.values());
boolean first = true;
StringBuffer sb = new StringBuffer();
sb.append(tableTitle(longetOp));
sb.append(newline);
int lineNum = 0;
for (Iterator it = p2.values().iterator(); it.hasNext();) {
TaskStats stat = (TaskStats) it.next();
if (!first) {
sb.append(newline);
}
first = false;
String line = taskReportLine(longetOp,stat);
lineNum++;
if (p2.size()>2&& lineNum%2==0) {
line = line.replaceAll(" "," - ");
}
sb.append(line);
}
String reptxt = (reported==0 ? "No Matching Entries Were Found!" : sb.toString());
return new Report(reptxt,p2.size(),reported,points.size());
|
| private java.lang.String | longestOp(java.util.Collection c)
String longest = OP;
for (Iterator it = c.iterator(); it.hasNext();) {
TaskStats stat = (TaskStats) it.next();
if (stat.getElapsed()>=0) { // consider only tasks that ended
String name = stat.getTask().getName();
if (name.length() > longest.length()) {
longest = name;
}
}
}
return longest;
|
| public synchronized void | markTaskEnd(TaskStats stats, int count)mark the end of a task
int numParallelTasks = nextTaskRunNum - 1 - stats.getTaskRunNum();
// note: if the stats were cleared, might be that this stats object is
// no longer in points, but this is just ok.
stats.markEnd(numParallelTasks, count);
|
| public synchronized TaskStats | markTaskStart(org.apache.lucene.benchmark.byTask.tasks.PerfTask task, int round)Mark that a task is starting.
Create a task stats for it and store it as a point.
TaskStats stats = new TaskStats(task, nextTaskRunNum(), round);
points.add(stats);
return stats;
|
| private synchronized int | nextTaskRunNum()
return nextTaskRunNum++;
|
| public Report | reportAll()Report detailed statistics as a string
String longestOp = longestOp(points);
boolean first = true;
StringBuffer sb = new StringBuffer();
sb.append(tableTitle(longestOp));
sb.append(newline);
int reported = 0;
for (Iterator it = points.iterator(); it.hasNext();) {
TaskStats stat = (TaskStats) it.next();
if (stat.getElapsed()>=0) { // consider only tasks that ended
if (!first) {
sb.append(newline);
}
first = false;
String line = taskReportLine(longestOp, stat);
reported++;
if (points.size()>2&& reported%2==0) {
line = line.replaceAll(" "," - ");
}
sb.append(line);
}
}
String reptxt = (reported==0 ? "No Matching Entries Were Found!" : sb.toString());
return new Report(reptxt,reported,reported,points.size());
|
| public Report | reportSelectByPrefix(java.lang.String prefix)
String longestOp = longestOp(points);
boolean first = true;
StringBuffer sb = new StringBuffer();
sb.append(tableTitle(longestOp));
sb.append(newline);
int reported = 0;
for (Iterator it = points.iterator(); it.hasNext();) {
TaskStats stat = (TaskStats) it.next();
if (stat.getElapsed()>=0 && stat.getTask().getName().startsWith(prefix)) { // only ended tasks with proper name
reported++;
if (!first) {
sb.append(newline);
}
first = false;
String line = taskReportLine(longestOp,stat);
if (points.size()>2&& reported%2==0) {
line = line.replaceAll(" "," - ");
}
sb.append(line);
}
}
String reptxt = (reported==0 ? "No Matching Entries Were Found!" : sb.toString());
return new Report(reptxt,reported,reported, points.size());
|
| public Report | reportSumByName()Report statistics as a string, aggregate for tasks named the same.
// aggregate by task name
int reported = 0;
LinkedHashMap p2 = new LinkedHashMap();
for (Iterator it = points.iterator(); it.hasNext();) {
TaskStats stat1 = (TaskStats) it.next();
if (stat1.getElapsed()>=0) { // consider only tasks that ended
reported++;
String name = stat1.getTask().getName();
TaskStats stat2 = (TaskStats) p2.get(name);
if (stat2 == null) {
try {
stat2 = (TaskStats) stat1.clone();
} catch (CloneNotSupportedException e) {
throw new RuntimeException(e);
}
p2.put(name,stat2);
} else {
stat2.add(stat1);
}
}
}
// now generate report from secondary list p2
return genReportFromList(reported, p2);
|
| public Report | reportSumByNameRound()Report statistics as a string, aggregate for tasks named the same, and from the same round.
// aggregate by task name and round
LinkedHashMap p2 = new LinkedHashMap();
int reported = 0;
for (Iterator it = points.iterator(); it.hasNext();) {
TaskStats stat1 = (TaskStats) it.next();
if (stat1.getElapsed()>=0) { // consider only tasks that ended
reported++;
String name = stat1.getTask().getName();
String rname = stat1.getRound()+"."+name; // group by round
TaskStats stat2 = (TaskStats) p2.get(rname);
if (stat2 == null) {
try {
stat2 = (TaskStats) stat1.clone();
} catch (CloneNotSupportedException e) {
throw new RuntimeException(e);
}
p2.put(rname,stat2);
} else {
stat2.add(stat1);
}
}
}
// now generate report from secondary list p2
return genReportFromList(reported, p2);
|
| public Report | reportSumByPrefix(java.lang.String prefix)
// aggregate by task name
int reported = 0;
LinkedHashMap p2 = new LinkedHashMap();
for (Iterator it = points.iterator(); it.hasNext();) {
TaskStats stat1 = (TaskStats) it.next();
if (stat1.getElapsed()>=0 && stat1.getTask().getName().startsWith(prefix)) { // only ended tasks with proper name
reported++;
String name = stat1.getTask().getName();
TaskStats stat2 = (TaskStats) p2.get(name);
if (stat2 == null) {
try {
stat2 = (TaskStats) stat1.clone();
} catch (CloneNotSupportedException e) {
throw new RuntimeException(e);
}
p2.put(name,stat2);
} else {
stat2.add(stat1);
}
}
}
// now generate report from secondary list p2
return genReportFromList(reported, p2);
|
| public Report | reportSumByPrefixRound(java.lang.String prefix)
// aggregate by task name and by round
int reported = 0;
LinkedHashMap p2 = new LinkedHashMap();
for (Iterator it = points.iterator(); it.hasNext();) {
TaskStats stat1 = (TaskStats) it.next();
if (stat1.getElapsed()>=0 && stat1.getTask().getName().startsWith(prefix)) { // only ended tasks with proper name
reported++;
String name = stat1.getTask().getName();
String rname = stat1.getRound()+"."+name; // group by round
TaskStats stat2 = (TaskStats) p2.get(rname);
if (stat2 == null) {
try {
stat2 = (TaskStats) stat1.clone();
} catch (CloneNotSupportedException e) {
throw new RuntimeException(e);
}
p2.put(rname,stat2);
} else {
stat2.add(stat1);
}
}
}
// now generate report from secondary list p2
return genReportFromList(reported, p2);
|
| private java.lang.String | tableTitle(java.lang.String longestOp)
StringBuffer sb = new StringBuffer();
sb.append(Format.format(OP,longestOp));
sb.append(ROUND);
sb.append(config.getColsNamesForValsByRound());
for (int i = 0; i < COLS.length; i++) {
sb.append(COLS[i]);
}
return sb.toString();
|
| private java.lang.String | taskReportLine(java.lang.String longestOp, TaskStats stat)
PerfTask task = stat.getTask();
StringBuffer sb = new StringBuffer();
sb.append(Format.format(task.getName(), longestOp));
String round = (stat.getRound()>=0 ? ""+stat.getRound() : "-");
sb.append(Format.formatPaddLeft(round, ROUND));
sb.append(config.getColsValuesForValsByRound(stat.getRound()));
sb.append(Format.format(stat.getNumRuns(), RUNCNT));
sb.append(Format.format(stat.getCount() / stat.getNumRuns(), RECCNT));
long elapsed = (stat.getElapsed()>0 ? stat.getElapsed() : 1); // assume at least 1ms
sb.append(Format.format(1,(float) (stat.getCount() * 1000.0 / elapsed), RECSEC));
sb.append(Format.format(2, (float) stat.getElapsed() / 1000, ELAPSED));
sb.append(Format.format(0, (float) stat.getMaxUsedMem() / stat.getNumRuns(), USEDMEM));
sb.append(Format.format(0, (float) stat.getMaxTotMem() / stat.getNumRuns(), TOTMEM));
return sb.toString();
|
