|
@@ -53,16 +53,20 @@ public class FrameworkTest implements GreenApp {
|
|
public static String connectionUser = "postgres";
|
|
public static String connectionUser = "postgres";
|
|
public static String connectionPassword = "postgres";
|
|
public static String connectionPassword = "postgres";
|
|
|
|
|
|
|
|
+ static final int c = 250; //needed to reach 16K simultainious calls
|
|
|
|
+
|
|
|
|
+
|
|
public FrameworkTest() {
|
|
public FrameworkTest() {
|
|
|
|
|
|
// use this in commit messages to narrow travis testing to just this project
|
|
// use this in commit messages to narrow travis testing to just this project
|
|
// rebase before using this: [ci fw-only Java/greenlightning]
|
|
// rebase before using this: [ci fw-only Java/greenlightning]
|
|
|
|
|
|
|
|
+
|
|
//this server works best with -XX:+UseNUMA
|
|
//this server works best with -XX:+UseNUMA
|
|
this(System.getProperty("host","0.0.0.0"),
|
|
this(System.getProperty("host","0.0.0.0"),
|
|
8080, //default port for test
|
|
8080, //default port for test
|
|
- 391, //needed to reach 16K simultainious calls
|
|
|
|
- 1<<10, // (router to module)
|
|
|
|
|
|
+ c, //needed to reach 16K simultainious calls
|
|
|
|
+ c*2, //(router to module) //TODO: do we have a minimum in place here?
|
|
1<<11, //default total size of network buffer used by blocks
|
|
1<<11, //default total size of network buffer used by blocks
|
|
Integer.parseInt(System.getProperty("telemetry.port", "-1")),
|
|
Integer.parseInt(System.getProperty("telemetry.port", "-1")),
|
|
"tfb-database", // jdbc:postgresql://tfb-database:5432/hello_world
|
|
"tfb-database", // jdbc:postgresql://tfb-database:5432/hello_world
|
|
@@ -93,13 +97,13 @@ public class FrameworkTest implements GreenApp {
|
|
this.telemetryPort = telemetryPort;
|
|
this.telemetryPort = telemetryPort;
|
|
this.pipelineBits = 14;//max concurrent in flight database requests 1<<pipelineBits
|
|
this.pipelineBits = 14;//max concurrent in flight database requests 1<<pipelineBits
|
|
|
|
|
|
- this.dbCallMaxResponseCount = 1<<6;
|
|
|
|
- this.jsonMaxResponseCount = 1<<10;
|
|
|
|
|
|
+ this.dbCallMaxResponseCount = c*2;
|
|
|
|
+ this.jsonMaxResponseCount = c*2;
|
|
|
|
|
|
this.dbCallMaxResponseSize = 20_000; //for 500 mult db call in JSON format
|
|
this.dbCallMaxResponseSize = 20_000; //for 500 mult db call in JSON format
|
|
this.jsonMaxResponseSize = 1<<8;
|
|
this.jsonMaxResponseSize = 1<<8;
|
|
|
|
|
|
- this.maxQueueOut = 8;
|
|
|
|
|
|
+ this.maxQueueOut = 4;
|
|
this.maxConnectionBits = 15; //32K connections, default is larger but this is all we need
|
|
this.maxConnectionBits = 15; //32K connections, default is larger but this is all we need
|
|
|
|
|
|
this.maxRequestSize = 1<<9;
|
|
this.maxRequestSize = 1<<9;
|
|
@@ -153,7 +157,7 @@ public class FrameworkTest implements GreenApp {
|
|
@Override
|
|
@Override
|
|
public void declareConfiguration(GreenFramework framework) {
|
|
public void declareConfiguration(GreenFramework framework) {
|
|
|
|
|
|
- framework.setDefaultRate(200_000);
|
|
|
|
|
|
+ framework.setDefaultRate(120_000);
|
|
|
|
|
|
//for 14 cores this is expected to use less than 16G, must use next largest prime to ensure smaller groups are not multiples.
|
|
//for 14 cores this is expected to use less than 16G, must use next largest prime to ensure smaller groups are not multiples.
|
|
framework.useHTTP1xServer(bindPort, this::parallelBehavior) //standard auto-scale
|
|
framework.useHTTP1xServer(bindPort, this::parallelBehavior) //standard auto-scale
|