|
|
@@ -31,6 +31,8 @@ public class FrameworkTest implements GreenApp {
|
|
|
private int dbCallMaxResponseSize;
|
|
|
private final int dbCallMaxResponseCount;
|
|
|
private int pipelineBits;
|
|
|
+ private int maxQueueOut = 256;
|
|
|
+ private int maxConnectionBits = 13;
|
|
|
|
|
|
private final int jsonMaxResponseCount;
|
|
|
private final int jsonMaxResponseSize;
|
|
|
@@ -52,9 +54,9 @@ public class FrameworkTest implements GreenApp {
|
|
|
//this server works best with -XX:+UseNUMA
|
|
|
this(System.getProperty("host","0.0.0.0"),
|
|
|
8080, //default port for test
|
|
|
- 7, //default concurrency per track
|
|
|
- 2*1024, //default max rest requests allowed to queue in wait
|
|
|
- 1<<20, //default network buffer per input socket connection
|
|
|
+ 7, //default concurrency per track
|
|
|
+ 8*1024, //default max rest requests allowed to queue in wait
|
|
|
+ 1<<21, //default network buffer per input socket connection
|
|
|
Integer.parseInt(System.getProperty("telemetry.port", "-1")),
|
|
|
"tfb-database", // jdbc:postgresql://tfb-database:5432/hello_world
|
|
|
"hello_world",
|
|
|
@@ -81,8 +83,8 @@ public class FrameworkTest implements GreenApp {
|
|
|
this.telemetryPort = telemetryPort;
|
|
|
this.pipelineBits = 14;//max concurrent in flight database requests 1<<pipelineBits
|
|
|
|
|
|
- this.dbCallMaxResponseCount = 1<<4;
|
|
|
- this.jsonMaxResponseCount = 1<<13;
|
|
|
+ this.dbCallMaxResponseCount = 1<<6;
|
|
|
+ this.jsonMaxResponseCount = 1<<16;
|
|
|
|
|
|
this.dbCallMaxResponseSize = 20_000; //for 500 mult db call in JSON format
|
|
|
this.jsonMaxResponseSize = 1<<9;
|
|
|
@@ -141,13 +143,14 @@ public class FrameworkTest implements GreenApp {
|
|
|
//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
|
|
|
.setHost(host)
|
|
|
- .setMaxConnectionBits(13) //8K max client connections.
|
|
|
+ .setMaxConnectionBits(maxConnectionBits) //8K max client connections.
|
|
|
.setConcurrentChannelsPerDecryptUnit(concurrentWritesPerChannel)
|
|
|
.setConcurrentChannelsPerEncryptUnit(concurrentWritesPerChannel)
|
|
|
- .setMaxQueueIn(queueLengthOfPendingRequests)
|
|
|
|
|
|
+ .setMaxQueueIn(queueLengthOfPendingRequests)
|
|
|
+
|
|
|
.setMinimumInputPipeMemory(minMemoryOfInputPipes)
|
|
|
- .setMaxQueueOut(256)
|
|
|
+ .setMaxQueueOut(maxQueueOut)
|
|
|
.setMaxResponseSize(dbCallMaxResponseSize) //big enough for large mult db response
|
|
|
.useInsecureServer(); //turn off TLS
|
|
|
|
Nathan Tippy