Home
last modified time | relevance | path

Searched refs:DEFAULT_WINDOW_SIZE (Results 1 – 7 of 7) sorted by relevance

/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyHandlerTestBase.java20 import static io.netty.handler.codec.http2.Http2CodecUtil.DEFAULT_WINDOW_SIZE;
103 protected int flowControlWindow = DEFAULT_WINDOW_SIZE;
454 assertEquals(Http2CodecUtil.DEFAULT_WINDOW_SIZE, transportStats.remoteFlowControlWindow); in transportTracer_windowSizeDefault()
463 assertEquals(Http2CodecUtil.DEFAULT_WINDOW_SIZE, transportStats.remoteFlowControlWindow); in transportTracer_windowSize()
471 assertEquals(Http2CodecUtil.DEFAULT_WINDOW_SIZE, before.remoteFlowControlWindow); in transportTracer_windowUpdate_remote()
472 assertEquals(Http2CodecUtil.DEFAULT_WINDOW_SIZE, before.localFlowControlWindow); in transportTracer_windowUpdate_remote()
477 assertEquals(Http2CodecUtil.DEFAULT_WINDOW_SIZE + 1000, in transportTracer_windowUpdate_remote()
486 assertEquals(Http2CodecUtil.DEFAULT_WINDOW_SIZE, before.remoteFlowControlWindow); in transportTracer_windowUpdate_local()
492 connection().connectionStream(), 8 * Http2CodecUtil.DEFAULT_WINDOW_SIZE); in transportTracer_windowUpdate_local()
495 assertEquals(Http2CodecUtil.DEFAULT_WINDOW_SIZE, after.remoteFlowControlWindow); in transportTracer_windowUpdate_local()
[all …]
DNettyClientTransportTest.java29 import static io.netty.handler.codec.http2.Http2CodecUtil.DEFAULT_WINDOW_SIZE;
176 DEFAULT_WINDOW_SIZE, DEFAULT_MAX_MESSAGE_SIZE, GrpcUtil.DEFAULT_MAX_HEADER_LIST_SIZE, in setSoLingerChannelOption()
416 newNegotiator(), DEFAULT_WINDOW_SIZE, DEFAULT_MAX_MESSAGE_SIZE, in failingToConstructChannelShouldFailGracefully()
593 DEFAULT_WINDOW_SIZE, maxMsgSize, maxHeaderListSize, in newTransport()
614 DEFAULT_WINDOW_SIZE, DEFAULT_MAX_MESSAGE_SIZE, maxHeaderListSize, in startServer()
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpClientStream.java46 private static final int WINDOW_UPDATE_THRESHOLD = Utils.DEFAULT_WINDOW_SIZE / 2;
196 private int window = Utils.DEFAULT_WINDOW_SIZE;
198 private int processedWindow = Utils.DEFAULT_WINDOW_SIZE;
271 int delta = Utils.DEFAULT_WINDOW_SIZE - processedWindow; in bytesRead()
DOutboundFlowController.java20 import static io.grpc.okhttp.Utils.DEFAULT_WINDOW_SIZE;
40 private int initialWindowSize = DEFAULT_WINDOW_SIZE;
DUtils.java39 static final int DEFAULT_WINDOW_SIZE = 65535; field in Utils
DOkHttpClientTransport.java1025 if (connectionUnacknowledgedBytesRead >= Utils.DEFAULT_WINDOW_SIZE / 2) { in data()
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
DOkHttpClientTransportTest.java560 assertEquals(Utils.DEFAULT_WINDOW_SIZE, stats.remoteFlowControlWindow); in transportTracer_windowSizeDefault()
569 assertEquals(Utils.DEFAULT_WINDOW_SIZE, before.remoteFlowControlWindow); in transportTracer_windowSize_remote()
575 assertEquals(Utils.DEFAULT_WINDOW_SIZE + 1000, after.remoteFlowControlWindow); in transportTracer_windowSize_remote()
601 int messageLength = Utils.DEFAULT_WINDOW_SIZE / 4; in windowUpdate()
654 int messageLength = Utils.DEFAULT_WINDOW_SIZE / 2 + 1; in windowUpdateWithInboundFlowControl()
688 int messageLength = Utils.DEFAULT_WINDOW_SIZE / 2 + 1; in outboundFlowControl()
701 Utils.DEFAULT_WINDOW_SIZE - messageLength - HEADER_LENGTH; in outboundFlowControl()
706 frameHandler().windowUpdate(3, Utils.DEFAULT_WINDOW_SIZE); in outboundFlowControl()
707 frameHandler().windowUpdate(0, Utils.DEFAULT_WINDOW_SIZE); in outboundFlowControl()
1079 int messageLength = Utils.DEFAULT_WINDOW_SIZE + 1; in receivingWindowExceeded()
[all …]