Skip to content

Commit

Permalink
Issue 94: Log test parameters at start of run (#96)
Browse files Browse the repository at this point in the history
Logs the parameters being used by the test before it starts.

Signed-off-by: David Maddison <david.maddison@dell.com>
  • Loading branch information
maddisondavid authored and RaulGracia committed Jan 20, 2020
1 parent 8c2ebaa commit 8ea4bd1
Showing 1 changed file with 34 additions and 0 deletions.
34 changes: 34 additions & 0 deletions src/main/java/io/pravega/perf/PravegaPerfTest.java
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
import org.apache.commons.cli.HelpFormatter;
import org.apache.commons.cli.Options;
import org.apache.commons.cli.ParseException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.IOException;
import java.net.URI;
Expand All @@ -42,6 +44,7 @@
* Data format is in comma separated format as following: {TimeStamp, Sensor Id, Location, TempValue }.
*/
public class PravegaPerfTest {
private static Logger log = LoggerFactory.getLogger(PravegaPerfTest.class);
final static String BENCHMARKNAME = "pravega-benchmark";

public static void main(String[] args) {
Expand Down Expand Up @@ -392,6 +395,9 @@ static private class PravegaTest extends Test {

PravegaTest(long startTime, CommandLine commandline) throws Exception {
super(startTime, commandline);

log.info("Test Parameters: {}", toString());

final ScheduledExecutorService bgExecutor = Executors.newScheduledThreadPool(10);
final ControllerImpl controller = new ControllerImpl(ControllerImplConfig.builder()
.clientConfig(ClientConfig.builder().controllerURI(new URI(controllerUri)).build())
Expand Down Expand Up @@ -475,5 +481,33 @@ public void closeReaderGroup() {
}
}

@Override
public String toString() {
return "streamName='" + streamName + '\'' +
", rdGrpName='" + rdGrpName + '\'' +
", scopeName='" + scopeName + '\'' +
", recreate=" + recreate +
", writeAndRead=" + writeAndRead +
", producerCount=" + producerCount +
", consumerCount=" + consumerCount +
", segmentCount=" + segmentCount +
", segmentScaleKBps=" + segmentScaleKBps +
", segmentScaleEventsPerSecond=" + segmentScaleEventsPerSecond +
", scaleFactor=" + scaleFactor +
", events=" + events +
", eventsPerSec=" + eventsPerSec +
", eventsPerProducer=" + eventsPerProducer +
", eventsPerConsumer=" + eventsPerConsumer +
", EventsPerFlush=" + EventsPerFlush +
", transactionPerCommit=" + transactionPerCommit +
", runtimeSec=" + runtimeSec +
", throughput=" + throughput +
", writeFile='" + writeFile + '\'' +
", readFile='" + readFile + '\'' +
", startTime=" + startTime +
", enableConnectionPooling=" + enableConnectionPooling +
", writeWatermarkPeriodMillis=" + writeWatermarkPeriodMillis +
", readWatermarkPeriodMillis=" + readWatermarkPeriodMillis;
}
}
}

0 comments on commit 8ea4bd1

Please sign in to comment.