mirror of https://github.com/grpc/grpc-java.git
Reduce flow control window for interop tests
Many of the interop tests were designed with the default 64 KB flow control window in mind. If we test with 1 MB then it defeats the flow control testing. 65 KB is an arbitrary number, but I chose it to be rather small, but still not the HTTP/2-default 64 KB because implementations have had trouble with applying flow control changes correctly.
This commit is contained in:
parent
867c76d185
commit
ac9db3b157
|
|
@ -250,6 +250,7 @@ public class TestServiceClient {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return NettyChannelBuilder.forAddress(new InetSocketAddress(address, serverPort))
|
return NettyChannelBuilder.forAddress(new InetSocketAddress(address, serverPort))
|
||||||
|
.flowControlWindow(65 * 1024)
|
||||||
.negotiationType(useTls ? NegotiationType.TLS : NegotiationType.PLAINTEXT)
|
.negotiationType(useTls ? NegotiationType.TLS : NegotiationType.PLAINTEXT)
|
||||||
.sslContext(sslContext)
|
.sslContext(sslContext)
|
||||||
.build();
|
.build();
|
||||||
|
|
|
||||||
|
|
@ -56,6 +56,7 @@ public class Http2NettyLocalChannelTest extends AbstractTransportTest {
|
||||||
startStaticServer(
|
startStaticServer(
|
||||||
NettyServerBuilder
|
NettyServerBuilder
|
||||||
.forAddress(new LocalAddress("in-process-1"))
|
.forAddress(new LocalAddress("in-process-1"))
|
||||||
|
.flowControlWindow(65 * 1024)
|
||||||
.channelType(LocalServerChannel.class));
|
.channelType(LocalServerChannel.class));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -57,6 +57,7 @@ public class Http2NettyTest extends AbstractTransportTest {
|
||||||
public static void startServer() {
|
public static void startServer() {
|
||||||
try {
|
try {
|
||||||
startStaticServer(NettyServerBuilder.forPort(serverPort)
|
startStaticServer(NettyServerBuilder.forPort(serverPort)
|
||||||
|
.flowControlWindow(65 * 1024)
|
||||||
.sslContext(GrpcSslContexts
|
.sslContext(GrpcSslContexts
|
||||||
.forServer(TestUtils.loadCert("server1.pem"), TestUtils.loadCert("server1.key"))
|
.forServer(TestUtils.loadCert("server1.pem"), TestUtils.loadCert("server1.key"))
|
||||||
.ciphers(TestUtils.preferredTestCiphers(), SupportedCipherSuiteFilter.INSTANCE)
|
.ciphers(TestUtils.preferredTestCiphers(), SupportedCipherSuiteFilter.INSTANCE)
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue