| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyChannelBuilder.java | 78 private int flowControlWindow = DEFAULT_FLOW_CONTROL_WINDOW; field in NettyChannelBuilder
197 public NettyChannelBuilder flowControlWindow(int flowControlWindow) { in flowControlWindow() argument
198 checkArgument(flowControlWindow > 0, "flowControlWindow must be positive"); in flowControlWindow()
199 this.flowControlWindow = flowControlWindow; in flowControlWindow()
352 eventLoopGroup, flowControlWindow, maxInboundMessageSize(), in buildTransportFactory()
467 private final int flowControlWindow; field in NettyChannelBuilder.NettyTransportFactory
479 EventLoopGroup group, int flowControlWindow, int maxMessageSize, int maxHeaderListSize, in NettyTransportFactory() argument
485 this.flowControlWindow = flowControlWindow; in NettyTransportFactory()
523 dparams.getProtocolNegotiator(), flowControlWindow, in newClientTransport()
|
| D | NettyServerBuilder.java | 81 private int flowControlWindow = DEFAULT_FLOW_CONTROL_WINDOW; field in NettyServerBuilder
251 public NettyServerBuilder flowControlWindow(int flowControlWindow) { in flowControlWindow() method in NettyServerBuilder
252 checkArgument(flowControlWindow > 0, "flowControlWindow must be positive"); in flowControlWindow()
253 this.flowControlWindow = flowControlWindow; in flowControlWindow()
435 maxConcurrentCallsPerConnection, flowControlWindow, in buildTransportServer()
|
| D | NettyServerTransport.java | 67 private final int flowControlWindow; field in NettyServerTransport
87 int flowControlWindow, in NettyServerTransport() argument
104 this.flowControlWindow = flowControlWindow; in NettyServerTransport()
260 flowControlWindow, in createHandler()
|
| D | NettyServer.java | 82 private final int flowControlWindow; field in NettyServer
107 int maxStreamsPerConnection, int flowControlWindow, int maxMessageSize, int maxHeaderListSize, in NettyServer() argument
125 this.flowControlWindow = flowControlWindow; in NettyServer()
199 flowControlWindow, in start()
|
| D | NettyClientTransport.java | 74 private final int flowControlWindow; field in NettyClientTransport
98 ProtocolNegotiator negotiator, int flowControlWindow, int maxMessageSize, in NettyClientTransport() argument
107 this.flowControlWindow = flowControlWindow; in NettyClientTransport()
195 flowControlWindow,
|
| D | NettyClientHandler.java | 115 int flowControlWindow, in newHandler() argument
139 flowControlWindow, in newHandler()
155 int flowControlWindow, in newHandler() argument
165 Preconditions.checkArgument(flowControlWindow > 0, "flowControlWindow must be positive"); in newHandler()
200 settings.initialWindowSize(flowControlWindow); in newHandler()
|
| D | NettyServerHandler.java | 138 int flowControlWindow, in newHandler() argument
163 flowControlWindow, in newHandler()
184 int flowControlWindow, in newHandler() argument
195 Preconditions.checkArgument(flowControlWindow > 0, "flowControlWindow must be positive"); in newHandler()
217 settings.initialWindowSize(flowControlWindow); in newHandler()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyTransportTest.java | 42 .flowControlWindow(65 * 1024)
61 .flowControlWindow(65 * 1024) in newServer()
72 .flowControlWindow(65 * 1024) in newServer()
|
| D | NettyHandlerTestBase.java | 103 protected int flowControlWindow = DEFAULT_WINDOW_SIZE; field in NettyHandlerTestBase
455 assertEquals(flowControlWindow, transportStats.localFlowControlWindow); in transportTracer_windowSizeDefault()
460 flowControlWindow = 1024 * 1024; in transportTracer_windowSize()
464 assertEquals(flowControlWindow, transportStats.localFlowControlWindow); in transportTracer_windowSize()
479 assertEquals(flowControlWindow, after.localFlowControlWindow); in transportTracer_windowUpdate_remote()
487 assertEquals(flowControlWindow, before.localFlowControlWindow); in transportTracer_windowUpdate_local()
496 assertEquals(flowControlWindow + 8 * Http2CodecUtil.DEFAULT_WINDOW_SIZE, in transportTracer_windowUpdate_local()
|
| D | NettyClientHandlerTest.java | 495 flowControlWindow = 1048576; // 1MiB in connectionWindowShouldBeOverridden()
502 assertEquals(flowControlWindow, actualWindowSize); in connectionWindowShouldBeOverridden()
503 assertEquals(flowControlWindow, actualInitialWindowSize); in connectionWindowShouldBeOverridden()
720 flowControlWindow, in newHandler()
|
| D | NettyServerHandlerTest.java | 391 flowControlWindow = 1048576; // 1MiB in connectionWindowShouldBeOverridden()
398 assertEquals(flowControlWindow, actualWindowSize); in connectionWindowShouldBeOverridden()
399 assertEquals(flowControlWindow, actualInitialWindowSize); in connectionWindowShouldBeOverridden()
1069 flowControlWindow, in newHandler()
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/ |
| D | Utils.java | 134 SocketAddress address, boolean tls, boolean testca, int flowControlWindow) in newNettyClientChannel() argument
137 NettyChannelBuilder.forAddress(address).flowControlWindow(flowControlWindow); in newNettyClientChannel()
199 int flowControlWindow, boolean directExecutor) { in newClientChannel() argument
205 builder = newNettyClientChannel(transport, address, tls, testca, flowControlWindow); in newClientChannel()
|
| /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
| D | Http2NettyLocalChannelTest.java | 40 .flowControlWindow(65 * 1024) in getServerBuilder()
51 .flowControlWindow(65 * 1024) in createChannel()
|
| D | Http2NettyTest.java | 48 .flowControlWindow(65 * 1024) in getServerBuilder()
66 .flowControlWindow(65 * 1024) in createChannel()
|
| D | NettyFlowControlTest.java | 172 .flowControlWindow(clientFlowControlWindow) in resetConnection()
180 .flowControlWindow(serverFlowControlWindow); in startServer()
|
| D | Http2OkHttpTest.java | 80 .flowControlWindow(65 * 1024) in getServerBuilder()
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/ |
| D | ClientConfiguration.java | 55 int flowControlWindow = Utils.DEFAULT_FLOW_CONTROL_WINDOW; field in ClientConfiguration
70 flowControlWindow, directExecutor); in newChannel()
218 "" + DEFAULT.flowControlWindow) {
221 config.flowControlWindow = parseInt(value); in setClientValue()
|
| D | ServerConfiguration.java | 43 int flowControlWindow = NettyChannelBuilder.DEFAULT_FLOW_CONTROL_WINDOW; field in ServerConfiguration
175 "" + DEFAULT.flowControlWindow) {
178 config.flowControlWindow = parseInt(value); in setServerValue()
|
| D | AsyncServer.java | 162 .flowControlWindow(config.flowControlWindow); in newServer()
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | OkHttpTransportTest.java | 56 .flowControlWindow(65 * 1024), in newServer()
68 .flowControlWindow(65 * 1024), in newServer()
|
| /external/grpc-grpc-java/gae-interop-testing/gae-jdk8/src/main/java/io/grpc/testing/integration/ |
| D | NettyClientInteropServlet.java | 138 ((NettyChannelBuilder) builder).flowControlWindow(65 * 1024); in createChannel()
|
| /external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/ |
| D | AbstractBenchmark.java | 225 serverBuilder.flowControlWindow(windowSize.bytes()); in setup()
226 channelBuilder.flowControlWindow(windowSize.bytes()); in setup()
|
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| D | TestServiceClient.java | 372 .flowControlWindow(65 * 1024) in createChannel()
|