Skip to content

Commit

Permalink
Merge remote-tracking branch 'origin/master' into use-jol-for-object-…
Browse files Browse the repository at this point in the history 
…layout
  • Loading branch information
@earthling-amzn
earthling-amzn committed Dec 6, 2024
2 parents 59e7c33 + 4c7e556 commit fa8fd47
Show file tree
Hide file tree
Showing 5 changed files with 39 additions and 87 deletions.
9 changes: 0 additions & 9 deletions HyperAlloc/pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -64,11 +64,6 @@
<artifactId>junit-jupiter</artifactId>
<version>5.6.2</version>
</dependency>
<dependency>
<groupId>com.github.stefanbirkner</groupId>
<artifactId>system-lambda</artifactId>
<version>1.0.0</version>
</dependency>
<dependency>
<groupId>org.hamcrest</groupId>
<artifactId>hamcrest-core</artifactId>
Expand Down Expand Up @@ -96,10 +91,6 @@
<groupId>org.junit.jupiter</groupId>
<artifactId>junit-jupiter</artifactId>
</dependency>
<dependency>
<groupId>com.github.stefanbirkner</groupId>
<artifactId>system-lambda</artifactId>
</dependency>
<dependency>
<groupId>org.hamcrest</groupId>
<artifactId>hamcrest-core</artifactId>
Expand Down
29 changes: 5 additions & 24 deletions HyperAlloc/src/main/java/com/amazon/corretto/benchmark/hyperalloc/HyperAlloc.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,35 +2,16 @@
// SPDX-License-Identifier: Apache-2.0
package com.amazon.corretto.benchmark.hyperalloc;

import org.openjdk.jol.info.ClassLayout;

public final class HyperAlloc {
private static final String DEFAULT_RUN_TYPE = "simple";

private HyperAlloc() {}

public static void main(String[] args) {

System.out.println(ClassLayout.parseClass(AllocObject.class).instanceSize());

switch (findRunType(args)) {
case "simple" :
new SimpleRunner(new SimpleRunConfig(args)).start();
break;
default:
System.out.println("Current supported run type (-u): simple.");
System.exit(1);
try {
new SimpleRunner(new SimpleRunConfig(args)).start();
} catch (IllegalArgumentException e) {
SimpleRunConfig.usage();
System.exit(1);
}
}

private static String findRunType(final String[] args) {
for (int i = 0; i < args.length - 1; i++) {
if (args[i].equals("-u")) {
return args[i + 1];
}
}
return DEFAULT_RUN_TYPE;
}
}


48 changes: 23 additions & 25 deletions HyperAlloc/src/main/java/com/amazon/corretto/benchmark/hyperalloc/SimpleRunConfig.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,10 +17,10 @@ public class SimpleRunConfig {
private int numOfThreads = 4;
private int minObjectSize = 128;
private int maxObjectSize = 1024;
private boolean useCompressedOops;
private final boolean useCompressedOops;
private int pruneRatio = ObjectStore.DEFAULT_PRUNE_RATIO;
private int reshuffleRatio = ObjectStore.DEFAULT_RESHUFFLE_RATIO;
private int heapSizeInMb = (int)(ManagementFactory.getMemoryMXBean().getHeapMemoryUsage().getMax() / 1048576L);
private final int heapSizeInMb = (int) (ManagementFactory.getMemoryMXBean().getHeapMemoryUsage().getMax() / 1048576L);
private String logFile = "output.csv";
private String allocationLogFile = null;
private Double allocationSmoothnessFactor = null;
Expand All @@ -33,6 +33,7 @@ public class SimpleRunConfig {

/**
* Parse input arguments from a string array.
*
* @param args The string array of the arguments.
*/
public SimpleRunConfig(final String[] args) {
Expand Down Expand Up @@ -71,27 +72,26 @@ public SimpleRunConfig(final String[] args) {
} else if (args[i].equals("-z")) {
allocationSmoothnessFactor = Double.parseDouble(args[++i]);
if (allocationSmoothnessFactor < 0 || allocationSmoothnessFactor > 1.0) {
usage();
System.exit(1);
throw new IllegalArgumentException("-z must be between 0.0 and 1.0");
}
} else if (args[i].equals("-l")) {
logFile = args[++i];
} else if (args[i].equals("-b") || args[i].equals("--allocation-log")) {
allocationLogFile = args[++i];
} else if (args[i].equals("-u")) {
System.out.println("Use of -u has been deprecated");
i++;
} else if (args[i].equals("-p") || args[i].equals("--ramp-up-seconds")) {
rampUpSeconds = Double.parseDouble(args[++i]);
} else {
usage();
System.exit(1);
throw new IllegalArgumentException("Unknown argument: " + args[i]);
}
}
}

private void usage() {
public static void usage() {
System.out.println("Usage: java -jar HyperAlloc.jar " +
"[-u run type] [-a allocRateInMb] [-s longLivedObjectsInMb] " +
"[-a allocRateInMb] [-s longLivedObjectsInMb] " +
"[-m midAgedObjectsInMb] [-d runDurationInSeconds ] [-t numOfThreads] [-n minObjectSize] " +
"[-x maxObjectSize] [-r pruneRatio] [-f reshuffleRatio] " +
"[-l outputFile] [-b|-allocation-log logFile] [-z allocationSmoothness (0 to 1.0)] " +
Expand All @@ -100,26 +100,24 @@ private void usage() {

/**
* Creating a simple config from parameters.
*
* @param allocRateInMbPerSecond Allocation rate in Mb per second.
* @param heapSizeInMb Heap size (-Xmx) in Mb.
* @param longLivedInMb The size of long-lived objects in Mb.
* @param midAgedInMb The size of mid-aged objects in Mb.
* @param durationInSecond The run duration in seconds.
* @param numOfThreads The number of runner threads.
* @param minObjectSize The minimum object size in byte.
* @param maxObjectSize The maximum object size in byte.
* @param pruneRatio The prune ratio per minute.
* @param reshuffleRatio The reshuffle ratio.
* @param useCompressedOops Whether compressedOops is enabled.
* @param logFile The name of the output .csv file.
* @param allocationLogFile The name of the allocation log file.
* @param rampUpSeconds Gradually increase allocation rate over this period of time.
* @param longLivedInMb The size of long-lived objects in Mb.
* @param midAgedInMb The size of mid-aged objects in Mb.
* @param durationInSecond The run duration in seconds.
* @param numOfThreads The number of runner threads.
* @param minObjectSize The minimum object size in byte.
* @param maxObjectSize The maximum object size in byte.
* @param pruneRatio The prune ratio per minute.
* @param reshuffleRatio The reshuffle ratio.
* @param logFile The name of the output .csv file.
* @param allocationLogFile The name of the allocation log file.
* @param rampUpSeconds Gradually increase allocation rate over this period of time.
*/
public SimpleRunConfig(final long allocRateInMbPerSecond, final double allocSmoothnessFactor,
final int heapSizeInMb, final int longLivedInMb,
final int midAgedInMb, final int durationInSecond, final int numOfThreads,
final int longLivedInMb, final int midAgedInMb, final int durationInSecond, final int numOfThreads,
final int minObjectSize, final int maxObjectSize, final int pruneRatio,
final int reshuffleRatio, final boolean useCompressedOops, final String logFile,
final int reshuffleRatio, final String logFile,
final String allocationLogFile, final double rampUpSeconds) {
this.allocRateInMbPerSecond = allocRateInMbPerSecond;
this.allocationSmoothnessFactor = allocSmoothnessFactor;
Expand Down Expand Up @@ -188,7 +186,7 @@ public Double getAllocationSmoothnessFactor() {
return allocationSmoothnessFactor;
}

public String getAllocationLogFile() {
public String getAllocationLogFile() {
return allocationLogFile;
}

Expand Down
17 changes: 0 additions & 17 deletions HyperAlloc/src/test/java/com/amazon/corretto/benchmark/hyperalloc/HyperAllocTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -4,26 +4,9 @@

import org.junit.jupiter.api.Test;

import static com.github.stefanbirkner.systemlambda.SystemLambda.catchSystemExit;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.is;

class HyperAllocTest {

@Test
void SimpleRunTest() {
HyperAlloc.main(new String[]{"-u", "simple", "-d", "5"});
}

@Test
void DefaultRunTypeTest() {
HyperAlloc.main(new String[]{"-d", "5"});
}

@Test
void UnknownRunTypeTest() throws Exception {
int status = catchSystemExit(
() -> HyperAlloc.main(new String[]{"-u", "unknown", "-a", "5"}));
assertThat(status, is(1));
}
}
23 changes: 11 additions & 12 deletions HyperAlloc/src/test/java/com/amazon/corretto/benchmark/hyperalloc/SimpleRunConfigTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -3,15 +3,13 @@
package com.amazon.corretto.benchmark.hyperalloc;

import com.sun.management.HotSpotDiagnosticMXBean;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;

import java.lang.management.ManagementFactory;

import static com.github.stefanbirkner.systemlambda.SystemLambda.catchSystemExit;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.CoreMatchers.containsString;
import static org.hamcrest.CoreMatchers.is;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.junit.jupiter.api.Assertions.*;

class SimpleRunConfigTest {
Expand Down Expand Up @@ -45,9 +43,9 @@ void DefaultStringsTest() {

@Test
void ConstructorTest() {
final SimpleRunConfig config = new SimpleRunConfig(16384L, 0.0, 32768, 256,
final SimpleRunConfig config = new SimpleRunConfig(16384L, 0.0, 256,
32, 3000, 16, 256, 512,
10, 20, false, "nosuch.csv", null, 0.0);
10, 20, "nosuch.csv", null, 0.0);

assertThat(config.getNumOfThreads(), is(16));
assertThat(config.getAllocRateInMbPerSecond(), is(16384L));
Expand Down Expand Up @@ -84,11 +82,12 @@ void StringArgsTest() {
}

@Test
void UnknownParameterShouldExitTest() throws Exception {
int status = catchSystemExit(
() -> new SimpleRunConfig(new String[]{"-w", "who"}));
assertThat(status, is(1));
void UnknownParameterShouldExitTest() {
try {
new SimpleRunConfig(new String[]{"-w", "who"});
fail("Expected IllegalArgumentException here");
} catch (IllegalArgumentException e) {
assertThat(e.getMessage(), containsString("Unknown"));
}
}

class MySecurityManager extends SecurityManager {}
}

0 comments on commit fa8fd47

Please sign in to comment.