Properly set inbound and outbound connection and stream window sizes

qoakzmxncb · Jun 11, 2015 · 58a142a · 58a142a
1 parent 483738e
commit 58a142a
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/AbstractBenchmark.java b/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/AbstractBenchmark.java
@@ -64,7 +64,7 @@ public int bytes() {
    * Standard flow-control window sizes.
    */
   public enum FlowWindowSize {
-    SMALL(16383), MEDIUM(65535), LARGE(1048575), JUMBO(16777215);
+    SMALL(16383), MEDIUM(65535), LARGE(1048575), JUMBO(8388607);
 
     private final int bytes;
     FlowWindowSize(int bytes) {
@@ -140,7 +140,13 @@ public void setup(ExecutorType clientExecutor,
 
     // Always use a different worker group from the client.
     serverBuilder.workerEventLoopGroup(new NioEventLoopGroup());
+
+    // Always set connection and stream window size to same value
     serverBuilder.connectionWindowSize(windowSize.bytes());
+    serverBuilder.streamWindowSize(windowSize.bytes());
+    channelBuilder.connectionWindowSize(windowSize.bytes());
+    channelBuilder.streamWindowSize(windowSize.bytes());
+
     channelBuilder.negotiationType(NegotiationType.PLAINTEXT);
     serverBuilder.maxConcurrentCallsPerConnection(maxConcurrentStreams);